Commit 3429bf8f authored by Nick Craver's avatar Nick Craver

Time on PubSub logs

parent 2bc1a4e3
...@@ -312,7 +312,7 @@ public async Task PubSubGetAllAnyOrder() ...@@ -312,7 +312,7 @@ public async Task PubSubGetAllAnyOrder()
{ {
data.Add(int.Parse(Encoding.UTF8.GetString(val))); data.Add(int.Parse(Encoding.UTF8.GetString(val)));
pulse = data.Count == count; pulse = data.Count == count;
if ((data.Count % 100) == 99) Log(data.Count.ToString()); if ((data.Count % 100) == 99) Log(Time() + ": " + data.Count.ToString());
} }
if (pulse) if (pulse)
{ {
...@@ -367,7 +367,7 @@ async Task RunLoop() ...@@ -367,7 +367,7 @@ async Task RunLoop()
{ {
data.Add(i); data.Add(i);
if (data.Count == count) break; if (data.Count == count) break;
if ((data.Count % 100) == 99) Log(data.Count.ToString()); if ((data.Count % 100) == 99) Log(Time() + ": " + data.Count.ToString());
} }
} }
lock (syncLock) lock (syncLock)
...@@ -424,7 +424,7 @@ public async Task PubSubGetAllCorrectOrder_OnMessage_Sync() ...@@ -424,7 +424,7 @@ public async Task PubSubGetAllCorrectOrder_OnMessage_Sync()
{ {
data.Add(i); data.Add(i);
if (data.Count == count) pulse = true; if (data.Count == count) pulse = true;
if ((data.Count % 100) == 99) Log(data.Count.ToString()); if ((data.Count % 100) == 99) Log(Time() + ": " + data.Count.ToString());
} }
if (pulse) if (pulse)
{ {
...@@ -484,7 +484,7 @@ public async Task PubSubGetAllCorrectOrder_OnMessage_Async() ...@@ -484,7 +484,7 @@ public async Task PubSubGetAllCorrectOrder_OnMessage_Async()
{ {
data.Add(i); data.Add(i);
if (data.Count == count) pulse = true; if (data.Count == count) pulse = true;
if ((data.Count % 100) == 99) Log(data.Count.ToString()); if ((data.Count % 100) == 99) Log(Time() + ": " + data.Count.ToString());
} }
if (pulse) if (pulse)
{ {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment