Remove race on date update

Author: benaadams

experimental/ManagedRIOHttpServer/Program.cs

@@ -24,7 +24,11 @@ public sealed class Program
             "Date:DDD, dd mmm yyyy hh:mm:ss GMT" +
             "\r\n\r\n";
 
-        private static byte[] _headersBytes = Encoding.ASCII.GetBytes(headersKeepAliveStr);
+        private static byte[][] _headersBytesBuffers = new byte[][] {
+            Encoding.ASCII.GetBytes(headersKeepAliveStr),
+            Encoding.ASCII.GetBytes(headersKeepAliveStr)
+        };
+        private static byte[] _headersBytes;
 
         private static readonly string bodyStr = "Hello, World!";
 
@@ -33,11 +37,14 @@ public sealed class Program
 
         static Program()
         {
-            var start = _headersBytes.Length - 33;
+            var start = _headersBytesBuffers[0].Length - 33;
+            var loop = 0u;
             UpdateDateTimer = new Timer((obj) =>
             {
-               var date = DateTime.UtcNow.ToString("r");
-               Encoding.ASCII.GetBytes(date, 0, date.Length, _headersBytes, start);
+                var date = DateTime.UtcNow.ToString("r");
+                var index = (++loop) & 1;
+                Encoding.ASCII.GetBytes(date, 0, date.Length, _headersBytesBuffers[index], start);
+                _headersBytes = _headersBytesBuffers[index];
             }, null, 0, 1000);
         }
 
@@ -46,7 +53,7 @@ static void Main(string[] args)
             Console.WriteLine("Starting Managed Registered IO Server");
             Console.WriteLine("* Hardware Accelerated SIMD: {0}", Vector.IsHardwareAccelerated);
             Console.WriteLine("* Vector<byte>.Count: {0}", Vector<byte>.Count);
-            
+
             if (IntPtr.Size != 8)
             {
                 Console.WriteLine("ManagedRIOHttpServer needs to be run in x64 mode");
@@ -186,7 +193,7 @@ static async Task ServeSocket(RIOTcpConnection socket)
 
                     var ul = r - 3;
                     var hasStart = false;
-                    
+
 
                     for (var i = start; i < buffer.Length - Vector<byte>.Count; i += Vector<byte>.Count)
                     {
@@ -284,8 +291,8 @@ static async Task ServeSocket(RIOTcpConnection socket)
                         socket.SendCachedBad();
                         break;
                     }
-                    
-                    
+
+
                     for (var i = 1; i < count; i++)
                     {
                         socket.QueueSend(headerBuffer, false);
@@ -317,7 +324,7 @@ static async Task ServeSocket(RIOTcpConnection socket)
         //    }
         //    var A = new Vector<byte>(65); // A
         //    var Z = new Vector<byte>(90); // Z
-            
+
         //    for (var o = data.Offset; o < data.Count - Vector<byte>.Count; o += Vector<byte>.Count)
         //    {
         //        var v = new Vector<byte>(data.Array, o);