forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-15 08:23:46 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix: contentLookup and traceContentLookup

Browse source
This commit is contained in:
qcloud 2024-05-15 15:30:37 +08:00 committed by Chen Kai
parent 0819e81eea
commit ec5865f6e3
1 changed files with 12 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
p2p/discover/portal_protocol.go
View file

@ -1473,8 +1473,14 @@ func (p *PortalProtocol) contentLookupWorker(n *enode.Node, contentKey []byte, r
wrapedNode := make([]*node, 0) wrapedNode := make([]*node, 0)
flag, content, err := p.findContent(n, contentKey) flag, content, err := p.findContent(n, contentKey)
if err != nil { if err != nil {
p.Log.Error("contentLookupWorker failed", "ip", n.IP().String(), "err", err)
return nil, 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 { switch flag {
case portalwire.ContentRawSelector, portalwire.ContentConnIdSelector: case portalwire.ContentRawSelector, portalwire.ContentConnIdSelector:
content, ok := content.([]byte) content, ok := content.([]byte)
@ -1609,6 +1615,12 @@ func (p *PortalProtocol) traceContentLookupWorker(n *enode.Node, contentKey []by
if err != nil { if err != nil {
return nil, err 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 { switch flag {
case portalwire.ContentRawSelector, portalwire.ContentConnIdSelector: case portalwire.ContentRawSelector, portalwire.ContentConnIdSelector:
content, ok := content.([]byte) content, ok := content.([]byte)