diff options
author | Joe Crayne <joe@jerkface.net> | 2020-01-07 02:12:32 -0500 |
---|---|---|
committer | Joe Crayne <joe@jerkface.net> | 2020-01-07 13:24:59 -0500 |
commit | 2782cde60ac66c75d1e1ab6993a3075e375c1786 (patch) | |
tree | bc40fc16af50071d8dd9c56863aab51b721cf92c /kad | |
parent | 09db68d3248f44a751c637713af936502a7e5152 (diff) |
async-search: clean up old query keys.
Diffstat (limited to 'kad')
-rw-r--r-- | kad/src/Network/Kademlia/Search.hs | 2 |
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 | ||
137 | grokQuery :: forall addr nid tok ni r qk. | 138 | grokQuery :: 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 | ||
213 | search :: | 215 | search :: |
214 | ( Ord r | 216 | ( Ord r |