From b35f62794f050cdbb8a8e91c3a211febc7c49931 Mon Sep 17 00:00:00 2001 From: healthykim Date: Thu, 4 Dec 2025 14:52:04 +0900 Subject: [PATCH] fix: fix dispatcher pending delete logic --- eth/protocols/eth/dispatcher.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/eth/protocols/eth/dispatcher.go b/eth/protocols/eth/dispatcher.go index 37be07abde..95f897ef33 100644 --- a/eth/protocols/eth/dispatcher.go +++ b/eth/protocols/eth/dispatcher.go @@ -250,6 +250,9 @@ func (p *Peer) dispatcher() { // it can wait for a handler response and dispatch the data. res.Time = res.recv.Sub(res.Req.Sent) resOp.fail <- nil + + // Stop tracking the request, the response dispatcher will deliver + delete(pending, res.id) } case <-p.term: