Skip to content

S
StackExchange.Redis
Commit 6d2cfb1a authored by Nick Craver's avatar Nick Craver
Browse files
Options

PubSub: moar logging

parent 5957f979
Hide whitespace changes
Inline Side-by-side
Showing with 6 additions and 3 deletions
StackExchange.Redis.Tests/PubSub.cs
View file @ 6d2cfb1a
...@@ -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("Received: " + data.Count.ToString());
} }
} }
lock (syncLock) lock (syncLock)
...@@ -383,6 +383,7 @@ async Task RunLoop() ...@@ -383,6 +383,7 @@ async Task RunLoop()
for (int i = 0; i < count; i++) for (int i = 0; i < count; i++)
{ {
sub.Publish(channel, i.ToString(), CommandFlags.FireAndForget); sub.Publish(channel, i.ToString(), CommandFlags.FireAndForget);
if ((data.Count % 100) == 99) Log("Published: " + data.Count.ToString());
} }
Log("Send loop complete."); Log("Send loop complete.");
if (!Monitor.Wait(syncLock, 20000)) if (!Monitor.Wait(syncLock, 20000))
...@@ -433,7 +434,7 @@ public async Task PubSubGetAllCorrectOrder_OnMessage_Sync() ...@@ -433,7 +434,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("Received: " + data.Count.ToString());
} }
if (pulse) if (pulse)
{ {
...@@ -450,6 +451,7 @@ public async Task PubSubGetAllCorrectOrder_OnMessage_Sync() ...@@ -450,6 +451,7 @@ public async Task PubSubGetAllCorrectOrder_OnMessage_Sync()
for (int i = 0; i < count; i++) for (int i = 0; i < count; i++)
{ {
sub.Publish(channel, i.ToString(), CommandFlags.FireAndForget); sub.Publish(channel, i.ToString(), CommandFlags.FireAndForget);
if ((data.Count % 100) == 99) Log("Published: " + data.Count.ToString());
} }
Log("Send loop complete."); Log("Send loop complete.");
if (!Monitor.Wait(syncLock, 20000)) if (!Monitor.Wait(syncLock, 20000))
...@@ -501,7 +503,7 @@ public async Task PubSubGetAllCorrectOrder_OnMessage_Async() ...@@ -501,7 +503,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("Received: " + data.Count.ToString());
} }
if (pulse) if (pulse)
{ {
...@@ -519,6 +521,7 @@ public async Task PubSubGetAllCorrectOrder_OnMessage_Async() ...@@ -519,6 +521,7 @@ public async Task PubSubGetAllCorrectOrder_OnMessage_Async()
for (int i = 0; i < count; i++) for (int i = 0; i < count; i++)
{ {
sub.Publish(channel, i.ToString(), CommandFlags.FireAndForget); sub.Publish(channel, i.ToString(), CommandFlags.FireAndForget);
if ((data.Count % 100) == 99) Log("Published: " + data.Count.ToString());
} }
Log("Send loop complete."); Log("Send loop complete.");
if (!Monitor.Wait(syncLock, 20000)) if (!Monitor.Wait(syncLock, 20000))
......
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