dht: Fix race

diff --git a/dht/getpeers.go b/dht/getpeers.go
index 74c366f38bc52a9b17b436ba6debca14566e64f9..0435b59b7c1053ac8656211476d3f96bfe3e2e0d 100644 (file)
--- a/dht/getpeers.go
+++ b/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)
        }