summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJoe Crayne <joe@jerkface.net>2020-01-07 02:12:32 -0500
committerJoe Crayne <joe@jerkface.net>2020-01-07 13:24:59 -0500
commit2782cde60ac66c75d1e1ab6993a3075e375c1786 (patch)
treebc40fc16af50071d8dd9c56863aab51b721cf92c
parent09db68d3248f44a751c637713af936502a7e5152 (diff)
async-search: clean up old query keys.
-rw-r--r--kad/src/Network/Kademlia/Search.hs2
1 files changed, 2 insertions, 0 deletions
diff --git a/kad/src/Network/Kademlia/Search.hs b/kad/src/Network/Kademlia/Search.hs
index 19d0df69..1f0cfa13 100644
--- a/kad/src/Network/Kademlia/Search.hs
+++ b/kad/src/Network/Kademlia/Search.hs
@@ -132,6 +132,7 @@ reset nearestNodes qsearch target st = do
132 writeTVar (searchInformant st) MM.empty 132 writeTVar (searchInformant st) MM.empty
133 writeTVar (searchVisited st) Set.empty 133 writeTVar (searchVisited st) Set.empty
134 writeTVar (searchPendingCount st) 0 134 writeTVar (searchPendingCount st) 0
135 writeTVar (searchPending st) Map.empty
135 return st 136 return st
136 137
137grokQuery :: forall addr nid tok ni r qk. 138grokQuery :: forall addr nid tok ni r qk.
@@ -209,6 +210,7 @@ searchCancel SearchState{..} = do
209 writeTVar searchQueued Nothing 210 writeTVar searchQueued Nothing
210 m <- readTVar searchPending 211 m <- readTVar searchPending
211 foldr (>>) (return ()) m 212 foldr (>>) (return ()) m
213 writeTVar searchPending Map.empty
212 214
213search :: 215search ::
214 ( Ord r 216 ( Ord r