zero desired requests on close

erigontech · Jul 22, 2024 · 9f8d405 · 9f8d405
1 parent 9f65af9
commit 9f8d405
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/peer.go b/peer.go
@@ -395,6 +395,9 @@ func (p *Peer) close(lockTorrent bool) {
 		if p.t != nil {
 			p.t.decPeerPieceAvailability(p, false, false)
 		}
+
+		p.desiredRequestLen = 0
+
 		for _, f := range p.callbacks.PeerClosed {
 			f(p)
 		}
@@ -1138,6 +1141,7 @@ func (p *Peer) desiredRequests(lock bool) int {
 		p.mu.RLock()
 		defer p.mu.RUnlock()
 	}
+
 	return p.desiredRequestLen
 }
 

diff --git a/webseed-peer.go b/webseed-peer.go
@@ -448,7 +448,7 @@ func requestUpdate(ws *webseedPeer) {
 						if p == &ws.peer {
 							this = "*"
 						}
-						flags := p.connectionFlags()
+						flags := p.StatusFlags()
 						peerInfo = append(peerInfo, fmt.Sprintf("%s%s:p=%d,d=%d: %f", this, flags, pieces, desired, rate))
 
 					}, false)