mirror of
https://github.com/ipfs/kubo.git
synced 2026-03-05 16:28:06 +08:00
defer tock.Stop()
This commit is contained in:
parent
2f934e8c58
commit
ce0d2f46d6
@ -178,6 +178,7 @@ func (pm *WantManager) Disconnected(p peer.ID) {
|
||||
// TODO: use goprocess here once i trust it
|
||||
func (pm *WantManager) Run() {
|
||||
tock := time.NewTicker(rebroadcastDelay.Get())
|
||||
defer tock.Stop()
|
||||
for {
|
||||
select {
|
||||
case entries := <-pm.incoming:
|
||||
|
||||
Loading…
Reference in New Issue
Block a user