forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-06-12 09:51:36 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

cmd/devp2p/v5test: resend challenged FindnodeResults packets

Browse source
This commit is contained in:
Csaba Kiraly 2026-03-17 13:06:26 +00:00
parent 1dbb80afe6
commit d1b04ab2b3
No known key found for this signature in database
GPG key ID: 0FE274EE8C95166E
1 changed files with 23 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

32
cmd/devp2p/internal/v5test/discv5tests.go
View file

@ -331,6 +331,7 @@ type bystander struct {
l net.PacketConn
addedCh chan enode.ID
sent map[v5wire.Nonce]v5wire.Packet
done sync.WaitGroup
}
@ -342,6 +343,7 @@ func newBystander(t *utesting.T, s *Suite, added chan enode.ID) *bystander {
l: l,
dest: s.Dest,
addedCh: added,
sent: make(map[v5wire.Nonce]v5wire.Packet),
}
// Establish an initial session and let the remote learn this node before
// switching to the passive responder loop below.
@ -373,23 +375,35 @@ func (bn *bystander) loop() {
switch p := bn.conn.read(bn.l).(type) {
case *v5wire.Whoareyou:
p.Node = bn.dest
bn.conn.write(bn.l, &v5wire.Ping{
ReqID: bn.conn.nextReqID(),
ENRSeq: bn.dest.Seq(),
}, p)
if resp, ok := bn.sent[p.Nonce]; ok {
nonce := bn.conn.write(bn.l, resp, p)
delete(bn.sent, p.Nonce)
bn.sent[nonce] = resp
} else {
bn.conn.write(bn.l, &v5wire.Ping{
ReqID: bn.conn.nextReqID(),
ENRSeq: bn.dest.Seq(),
}, p)
}
case *v5wire.Ping:
bn.conn.write(bn.l, &v5wire.Pong{
ReqID: p.ReqID,
resp := &v5wire.Pong{
ReqID: append([]byte(nil), p.ReqID...),
ENRSeq: bn.conn.localNode.Seq(),
ToIP: bn.dest.IP(),
ToPort: uint16(bn.dest.UDP()),
}, nil)
}
nonce := bn.conn.write(bn.l, resp, nil)
bn.sent[nonce] = resp
bn.notifyAdded()
case *v5wire.Findnode:
bn.conn.write(bn.l, &v5wire.Nodes{ReqID: p.ReqID, RespCount: 1}, nil)
resp := &v5wire.Nodes{ReqID: append([]byte(nil), p.ReqID...), RespCount: 1}
nonce := bn.conn.write(bn.l, resp, nil)
bn.sent[nonce] = resp
bn.notifyAdded()
case *v5wire.TalkRequest:
bn.conn.write(bn.l, &v5wire.TalkResponse{ReqID: p.ReqID}, nil)
resp := &v5wire.TalkResponse{ReqID: append([]byte(nil), p.ReqID...)}
nonce := bn.conn.write(bn.l, resp, nil)
bn.sent[nonce] = resp
case *readError:
if netutil.IsTemporaryError(p.err) || v5wire.IsInvalidHeader(p.err) {
continue