ask for more peers on start

cenkalti · Nov 7, 2019 · 6a47d26 · 6a47d26
1 parent 6147937
commit 6a47d26
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/internal/announcer/dht.go b/internal/announcer/dht.go
@@ -21,6 +21,7 @@ func NewDHTAnnouncer() *DHTAnnouncer {
 		needMorePeersC: make(chan bool),
 		closeC:         make(chan struct{}),
 		doneC:          make(chan struct{}),
+		needMorePeers:  true,
 	}
 }
 
@@ -42,7 +43,7 @@ func (a *DHTAnnouncer) NeedMorePeers(val bool) {
 func (a *DHTAnnouncer) Run(announceFunc func(), interval, minInterval time.Duration, l logger.Logger) {
 	defer close(a.doneC)
 
-	timer := time.NewTimer(interval)
+	timer := time.NewTimer(minInterval)
 	defer timer.Stop()
 
 	resetTimer := func() {