eth: abort requiredBlocks check if peer handler terminated (#32413)

klim0v · web-flow · commit 75fc56f27d5b · 2025-08-13T15:02:50.000+08:00
diff --git a/eth/handler.go b/eth/handler.go
@@ -352,6 +352,8 @@ func (h *handler) runEthPeer(peer *eth.Peer, handler eth.Handler) error {
 			case <-timeout.C:
 				peer.Log().Warn("Required block challenge timed out, dropping", "addr", peer.RemoteAddr(), "type", peer.Name())
 				h.removePeer(peer.ID())
+			case <-dead:
+				// Peer handler terminated, abort all goroutines
 			}
 		}(number, hash, req)
 	}

Original file line number	Diff line number	Diff line change
`@@ -352,6 +352,8 @@ func (h handler) runEthPeer(peer eth.Peer, handler eth.Handler) error {`
`352`	`352`	`case <-timeout.C:`
`353`	`353`	`peer.Log().Warn("Required block challenge timed out, dropping", "addr", peer.RemoteAddr(), "type", peer.Name())`
`354`	`354`	`h.removePeer(peer.ID())`
	`355`	`+ case <-dead:`
	`356`	`+ // Peer handler terminated, abort all goroutines`
`355`	`357`	`}`
`356`	`358`	`}(number, hash, req)`
`357`	`359`	`}`