diff --git a/dht/dht.go b/dht/dht.go index 791aeff..f12bf79 100644 --- a/dht/dht.go +++ b/dht/dht.go @@ -168,7 +168,11 @@ func (dht *DHT) init() error { t := time.NewTicker(dht.conf.PrintState) for { dht.PrintState() - <-t.C + select { + case <-t.C: + case <-dht.stop.Chan(): + return + } } }() }