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

Fix PeerManager signalAvailabiity() race

Merge pull request #417 from ipfs/fix/peermgr-race
Fix PeerManager signalAvailabiity() race
06129d6f · Steven Allen · GitHub · 25318da3 · 980ca8d4 · 06129d6f
Unverified Commit 06129d6f authored Jun 10, 2020 by Steven Allen Committed by GitHub Jun 10, 2020
Show whitespace changes
Inline Side-by-side

Showing with 3 additions and 0 deletions

internal/peermanager/peermanager.go internal/peermanager/peermanager.go +3 -0

No files found.
--- 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