dht: Fix race

dht/getpeers.go

@@ -128,7 +128,9 @@ func (me *peerDiscovery) closingCh() chan struct{} {
 }
 
 func (me *peerDiscovery) announcePeer(to dHTAddr, token string) {
+	me.server.mu.Lock()
 	err := me.server.announcePeer(to, me.infoHash, me.announcePort, token, me.announcePortImplied)
+	me.server.mu.Unlock()
 	if err != nil {
 		logonce.Stderr.Printf("error announcing peer: %s", err)
 	}