SF-6393 Millisecond Ordering

Src/StackifyLib/Internal/Logs/LogClient.cs

@@ -4,6 +4,7 @@
 using System.Linq;
 using System.Net;
 using System.Text;
+using System.Threading;
 using System.Threading.Tasks;
 //using System.Web.Configuration;
 using Newtonsoft.Json;
@@ -123,6 +124,11 @@ public bool ErrorShouldBeSent(StackifyError error)
             return governor.ErrorShouldBeSent(error);
         }
 
+
+
+        private static long _lastEpochMs = 0;
+        private static int _millisecondCount = 0;
+
         public void QueueMessage(LogMsg msg)
         {
             if (msg == null) return;
@@ -139,6 +145,21 @@ public void QueueMessage(LogMsg msg)
                 isError = 1;
             }
 
+            // works on the assumption that the epochMS will always be incrementing as it reaches this point
+            if (_lastEpochMs < msg.EpochMs)
+            {
+                // reset counter if we are no longer in the same ms
+                //https://msdn.microsoft.com/en-us/library/system.threading.interlocked_methods(v=vs.110).aspx
+                Interlocked.Exchange(ref _lastEpochMs, msg.EpochMs);
+                Interlocked.Exchange(ref _millisecondCount, 0);
+                msg.Order = 0;
+            }
+            else if (_lastEpochMs == msg.EpochMs)
+            {
+                msg.Order = Interlocked.Increment(ref _millisecondCount);
+            }
+            // else defaulted to 0
+
             //Used by Stackify profiler only
             if (Logger.PrefixEnabled())
             {

Src/StackifyLib/Models/LogMsgGroup.cs

@@ -95,6 +95,9 @@ public LogMsg()
         [JsonProperty]
         public List<string> Tags { get; set; }
 
+        [JsonProperty]
+        public int Order { get; set; }
+
         [JsonIgnore]
         public LogMsgGroup AppDetails { get; set; }