@@ -294,8 +294,8 @@ func (dht *FullRT) runCrawler(ctx context.Context) {
294
294
defer dht .wg .Done ()
295
295
t := time .NewTicker (dht .crawlerInterval )
296
296
297
- m := make (map [peer.ID ]* crawlVal )
298
- mxLk := sync.Mutex {}
297
+ foundPeers := make (map [peer.ID ]* crawlVal )
298
+ foundPeersLk := sync.Mutex {}
299
299
300
300
initialTrigger := make (chan struct {}, 1 )
301
301
initialTrigger <- struct {}{}
@@ -311,15 +311,15 @@ func (dht *FullRT) runCrawler(ctx context.Context) {
311
311
312
312
var addrs []* peer.AddrInfo
313
313
dht .peerAddrsLk .Lock ()
314
- for k := range m {
314
+ for k := range foundPeers {
315
315
addrs = append (addrs , & peer.AddrInfo {ID : k }) // Addrs: v.addrs
316
316
}
317
317
318
318
addrs = append (addrs , dht .bootstrapPeers ... )
319
319
dht .peerAddrsLk .Unlock ()
320
320
321
- for k := range m {
322
- delete (m , k )
321
+ for k := range foundPeers {
322
+ delete (foundPeers , k )
323
323
}
324
324
325
325
start := time .Now ()
@@ -343,9 +343,9 @@ func (dht *FullRT) runCrawler(ctx context.Context) {
343
343
return
344
344
}
345
345
346
- mxLk .Lock ()
347
- defer mxLk .Unlock ()
348
- m [p ] = & crawlVal {
346
+ foundPeersLk .Lock ()
347
+ defer foundPeersLk .Unlock ()
348
+ foundPeers [p ] = & crawlVal {
349
349
addrs : addrs ,
350
350
}
351
351
},
@@ -369,11 +369,11 @@ func (dht *FullRT) runCrawler(ctx context.Context) {
369
369
peerAddrs := make (map [peer.ID ][]multiaddr.Multiaddr )
370
370
kPeerMap := make (map [string ]peer.ID )
371
371
newRt := trie .New ()
372
- for k , v := range m {
373
- v .key = kadkey .KbucketIDToKey (kb .ConvertPeerID (k ))
374
- peerAddrs [k ] = v .addrs
375
- kPeerMap [string (v .key )] = k
376
- newRt .Add (v .key )
372
+ for peerID , foundCrawlVal := range foundPeers {
373
+ foundCrawlVal .key = kadkey .KbucketIDToKey (kb .ConvertPeerID (peerID ))
374
+ peerAddrs [peerID ] = foundCrawlVal .addrs
375
+ kPeerMap [string (foundCrawlVal .key )] = peerID
376
+ newRt .Add (foundCrawlVal .key )
377
377
}
378
378
379
379
dht .peerAddrsLk .Lock ()
0 commit comments