We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 41eb312 commit a2e27f0Copy full SHA for a2e27f0
1 file changed
p2p/discv5/net.go
@@ -357,6 +357,8 @@ func (net *Network) loop() {
357
bucketRefreshTimer = time.NewTimer(bucketRefreshInterval)
358
refreshDone chan struct{} // closed when the 'refresh' lookup has ended
359
)
360
+ defer refreshTimer.Stop()
361
+ defer bucketRefreshTimer.Stop()
362
363
// Tracking the next ticket to register.
364
var (
@@ -393,11 +395,13 @@ func (net *Network) loop() {
393
395
searchInfo = make(map[Topic]topicSearchInfo)
394
396
activeSearchCount int
397
398
+ defer topicRegisterLookupTick.Stop()
399
topicSearchLookupDone := make(chan topicSearchResult, 100)
400
topicSearch := make(chan Topic, 100)
401
<-topicRegisterLookupTick.C
402
403
statsDump := time.NewTicker(10 * time.Second)
404
+ defer statsDump.Stop()
405
406
loop:
407
for {
0 commit comments