From 2b3d286e9ee06ca7e6b576d4ba700eaf4738489c Mon Sep 17 00:00:00 2001 From: Matt Joiner Date: Tue, 10 Feb 2015 00:21:22 +1100 Subject: [PATCH] dht: Fix race --- dht/getpeers.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/dht/getpeers.go b/dht/getpeers.go index 74c366f3..0435b59b 100644 --- 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) } -- 2.48.1