Merge pull request #508 from ipfs/fix/disconnect-data-race

fix(decision): fix a datarace on disconnect
ipfs · Jun 24, 2021 · 5f2fd63 · 5f2fd63
2 parents b35e9ce + 4ffb5e9
commit 5f2fd63
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/internal/decision/engine.go b/internal/decision/engine.go
@@ -703,7 +703,11 @@ func (e *Engine) PeerDisconnected(p peer.ID) {
 
 	ledger, ok := e.ledgerMap[p]
 	if ok {
-		for _, entry := range ledger.Entries() {
+		ledger.lk.RLock()
+		entries := ledger.Entries()
+		ledger.lk.RUnlock()
+
+		for _, entry := range entries {
 			e.peerLedger.CancelWant(p, entry.Cid)
 		}
 	}