mirror/go-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/go-pulse.git synced 2024-12-22 19:40:36 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

cmd/devp2p, cmd/wnode, whisper: add missing calls to Timer.Stop (#20843)

Browse Source
This commit is contained in:
ucwong 2020-04-01 22:12:01 +08:00 committed by GitHub
parent d56dc038d2
commit 1e2e1b41f8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
cmd/devp2p/crawl.go
View File

@ -63,6 +63,7 @@ func (c *crawler) run(timeout time.Duration) nodeSet {
doneCh = make(chan enode.Iterator, len(c.iters)) doneCh = make(chan enode.Iterator, len(c.iters))
liveIters = len(c.iters) liveIters = len(c.iters)
) )
defer timeoutTimer.Stop()
for _, it := range c.iters { for _, it := range c.iters {
go c.runIterator(doneCh, it) go c.runIterator(doneCh, it)
} }

1
cmd/wnode/main.go
View File

@ -599,6 +599,7 @@ func messageLoop() {
} }
ticker := time.NewTicker(time.Millisecond * 50) ticker := time.NewTicker(time.Millisecond * 50)
defer ticker.Stop()
for { for {
select { select {

1
whisper/whisperv6/whisper.go
View File

@ -905,6 +905,7 @@ func (whisper *Whisper) update() {
defer whisper.wg.Done() defer whisper.wg.Done()
// Start a ticker to check for expirations // Start a ticker to check for expirations
expire := time.NewTicker(expirationCycle) expire := time.NewTicker(expirationCycle)
defer expire.Stop()
// Repeat updates until termination is requested // Repeat updates until termination is requested
for { for {