fix(DistributedQuery): if already visited, ignore the peer

richardschneider · Sep 2, 2019 · 9d849b0 · 9d849b0
1 parent 33849f6
commit 9d849b0
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/Routing/DistributedQuery.cs b/src/Routing/DistributedQuery.cs
@@ -171,8 +171,11 @@ async Task AskAsync(int taskId)
                     continue;
                 }
 
+                if (!visited.TryAdd(peer, peer))
+                {
+                    continue;
+                }
                 ++pass;
-                visited.TryAdd(peer, peer);
 
                 // Ask the nearest peer.
                 await askCount.WaitAsync(runningQuery.Token).ConfigureAwait(false);