fix: don't hang on to disconnected peer refs

ba4b52e7 · Dirk McCormick · c1922c0d · ba4b52e7
Commit ba4b52e7 authored Apr 16, 2020 by Dirk McCormick
Hide whitespace changes
Inline Side-by-side

Showing with 5 additions and 2 deletions

network/ipfs_impl.go network/ipfs_impl.go +5 -2

No files found.
--- a/network/ipfs_impl.go
+++ b/network/ipfs_impl.go
@@ -424,8 +424,11 @@ func (c *connectEventManager) Disconnected(p peer.ID) {
 	state.refs--
 	c.conns[p] = state

-	if state.refs == 0 && state.responsive {
-		c.bsnet.receiver.PeerDisconnected(p)
+	if state.refs == 0 {
+		if state.responsive {
+			c.bsnet.receiver.PeerDisconnected(p)
+		}
+		delete(c.conns, p)
 	}
 }