From 127aaa154f293a1e0c981628a4ab73d8982f351d Mon Sep 17 00:00:00 2001 From: thinkAfCod Date: Thu, 16 Jan 2025 15:19:03 +0800 Subject: [PATCH] fix lint --- portalwire/portal_protocol.go | 9 ++------- 1 file changed, 2 insertions(+), 7 deletions(-) diff --git a/portalwire/portal_protocol.go b/portalwire/portal_protocol.go index d46482b..2f785ce 100644 --- a/portalwire/portal_protocol.go +++ b/portalwire/portal_protocol.go @@ -1196,18 +1196,14 @@ func (p *PortalProtocol) handleOffer(id enode.ID, addr *net.UDPAddr, request *Of go func(bctx context.Context, connId *zenutp.ConnectionId) { var conn *zenutp.UtpStream - var connectCtx context.Context - var cancel context.CancelFunc - defer func() { - cancel() - }() for { select { case <-bctx.Done(): return default: p.Log.Debug("will accept offer conn from: ", "source", addr, "connId", connId) - connectCtx, cancel = context.WithTimeout(bctx, defaultUTPConnectTimeout) + connectCtx, cancel := context.WithTimeout(bctx, defaultUTPConnectTimeout) + defer cancel() conn, err = p.Utp.AcceptWithCid(connectCtx, connectionId) if err != nil { if metrics.Enabled() { @@ -1238,7 +1234,6 @@ func (p *PortalProtocol) handleOffer(id enode.ID, addr *net.UDPAddr, request *Of if metrics.Enabled() { p.portalMetrics.utpInSuccess.Inc(1) } - return } } }(p.closeCtx, connectionId)