Merge pull request #417 from ipfs/fix/peermgr-race

Fix PeerManager signalAvailabiity() race
ipfs · Jun 10, 2020 · 06129d6 · 06129d6
2 parents 25318da + 980ca8d
commit 06129d6
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/internal/peermanager/peermanager.go b/internal/peermanager/peermanager.go
@@ -231,6 +231,9 @@ func (pm *PeerManager) UnregisterSession(ses uint64) {
 // signalAvailability is called when a peer's connectivity changes.
 // It informs interested sessions.
 func (pm *PeerManager) signalAvailability(p peer.ID, isConnected bool) {
+	pm.psLk.Lock()
+	defer pm.psLk.Unlock()
+
 	sesIds, ok := pm.peerSessions[p]
 	if !ok {
 		return