From 05d487017a2a286cce5c60fbe310a411529e2677 Mon Sep 17 00:00:00 2001 From: ucwong Date: Fri, 5 Jan 2024 18:14:32 +0800 Subject: [PATCH] eth/handler : hand require blocks with wait group --- eth/handler.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/eth/handler.go b/eth/handler.go index a327af6113..9a4a1ccab6 100644 --- a/eth/handler.go +++ b/eth/handler.go @@ -410,7 +410,9 @@ func (h *handler) runEthPeer(peer *eth.Peer, handler eth.Handler) error { if err != nil { return err } + h.wg.Add(1) go func(number uint64, hash common.Hash, req *eth.Request) { + defer h.wg.Done() // Ensure the request gets cancelled in case of error/drop defer req.Close()