From ec5865f6e3dae3f238345395ea207f941b3f1c47 Mon Sep 17 00:00:00 2001 From: qcloud Date: Wed, 15 May 2024 15:30:37 +0800 Subject: [PATCH] fix: contentLookup and traceContentLookup --- p2p/discover/portal_protocol.go | 12 ++++++++++++ 1 file changed, 12 insertions(+) diff --git a/p2p/discover/portal_protocol.go b/p2p/discover/portal_protocol.go index 66537aecd8..b0b1c7f858 100644 --- a/p2p/discover/portal_protocol.go +++ b/p2p/discover/portal_protocol.go @@ -1473,8 +1473,14 @@ func (p *PortalProtocol) contentLookupWorker(n *enode.Node, contentKey []byte, r wrapedNode := make([]*node, 0) flag, content, err := p.findContent(n, contentKey) if err != nil { + p.Log.Error("contentLookupWorker failed", "ip", n.IP().String(), "err", err) return nil, err } + p.Log.Debug("contentLookupWorker reveice response", "ip", n.IP().String(), "flag", flag) + // has find content + if len(resChan) > 0 { + return []*node{}, nil + } switch flag { case portalwire.ContentRawSelector, portalwire.ContentConnIdSelector: content, ok := content.([]byte) @@ -1609,6 +1615,12 @@ func (p *PortalProtocol) traceContentLookupWorker(n *enode.Node, contentKey []by if err != nil { return nil, err } + p.Log.Debug("traceContentLookupWorker reveice response", "ip", n.IP().String(), "flag", flag) + // has find content + if len(resChan) > 0 { + return []*node{}, nil + } + switch flag { case portalwire.ContentRawSelector, portalwire.ContentConnIdSelector: content, ok := content.([]byte)