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

Merge 8dce444578 into 406a852ec8

Browse source
This commit is contained in:
Delweng 2026-02-25 21:57:38 -08:00 committed by GitHub
commit 7fa4e8540c
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 12 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
eth/downloader/skeleton.go
View file

@ -872,8 +872,14 @@ func (s *skeleton) executeTask(peer *peerConnection, req *headerRequest) {
case headers[0].Number.Uint64() != req.head:
// Header batch anchored at non-requested number
peer.log.Debug("Invalid header response head", "have", headers[0].Number, "want", req.head)
res.Done <- errors.New("invalid header batch anchor")
if peerHeader := headers[0].Number.Uint64(); peerHeader > req.head {
peer.log.Debug("Invalid header response head", "have", peerHeader, "want", req.head)
res.Done <- errors.New("invalid header batch anchor")
} else {
peer.log.Debug("Peer behind requested head, rescheduling", "have", peerHeader, "want", req.head)
// Do not penalize the peer if it is behind our requested head
res.Done <- nil
}
s.scheduleRevertRequest(req)
case req.head >= requestHeaders && len(headers) != requestHeaders:

8
eth/downloader/skeleton_test.go
View file

@ -616,14 +616,14 @@ func TestSkeletonSyncRetrievals(t *testing.T) {
mid: skeletonExpect{
state: []*subchain{{Head: requestHeaders + 100, Tail: 100}},
serve: requestHeaders + 101 - 3, // len - head - genesis - missing
drop: 1, // penalize shortened header deliveries
drop: 0, // do not penalize in relaxed mode
},
newPeer: newSkeletonTestPeer("good-peer", chain),
end: skeletonExpect{
state: []*subchain{{Head: requestHeaders + 100, Tail: 1}},
serve: (requestHeaders + 101 - 3) + (100 - 1), // midserve + lenrest - genesis
drop: 1, // no new drops
drop: 0, // relaxed: no drops
},
},
// This test checks if a peer tries to withhold a header - *off* the sync
@ -662,14 +662,14 @@ func TestSkeletonSyncRetrievals(t *testing.T) {
mid: skeletonExpect{
state: []*subchain{{Head: requestHeaders + 100, Tail: 100}},
serve: requestHeaders + 101 - 2, // len - head - genesis
drop: 1, // penalize invalid header sequences
drop: 0, // do not penalize in relaxed mode
},
newPeer: newSkeletonTestPeer("good-peer", chain),
end: skeletonExpect{
state: []*subchain{{Head: requestHeaders + 100, Tail: 1}},
serve: (requestHeaders + 101 - 2) + (100 - 1), // midserve + lenrest - genesis
drop: 1, // no new drops
drop: 0, // relaxed: no drops
},
},
// This test checks if a peer tries to duplicate a header - *off* the sync