cleanup peerresponsetracker

Author: Wondertan

bitswap/client/internal/session/peerresponsetracker.go

@@ -61,3 +61,8 @@ func (prt *peerResponseTracker) getPeerCount(p peer.ID) int {
 	// will be chosen
 	return prt.firstResponder[p] + 1
 }
+
+// cleanup stops tracking a peer
+func (prt *peerResponseTracker) cleanup(p peer.ID) {
+	delete(prt.firstResponder, p)
+}

bitswap/client/internal/session/sessionwantsender.go

@@ -332,6 +332,7 @@ func (sws *sessionWantSender) processAvailability(availability map[peer.ID]bool)
 			// Reset the count of consecutive DONT_HAVEs received from the
 			// peer
 			delete(sws.peerConsecutiveDontHaves, p)
+			sws.peerRspTrkr.cleanup(p)
 		}
 	}