Skip to content

Commit

Permalink
eth/downloader: add beacon header retrieval tests
Browse files Browse the repository at this point in the history
  • Loading branch information
karalabe committed Feb 23, 2022
1 parent f6d435c commit 5cae439
Show file tree
Hide file tree
Showing 2 changed files with 455 additions and 10 deletions.
6 changes: 4 additions & 2 deletions eth/downloader/skeleton.go
Expand Up @@ -400,8 +400,10 @@ func (s *skeleton) sync(head *types.Header) (*types.Header, error) {
// checked for potential assignment or reassignment
peerid := event.peer.id
if event.join {
log.Debug("Joining skeleton peer", "id", peerid)
s.idles[peerid] = event.peer
} else {
log.Debug("Leaving skeleton peer", "id", peerid)
s.revertRequests(peerid)
delete(s.idles, peerid)
}
Expand Down Expand Up @@ -763,8 +765,8 @@ func (s *skeleton) executeTask(peer *peerConnection, req *headerRequest) {
// is correct too, deliver for storage
for i := 0; i < len(headers)-1; i++ {
if headers[i].ParentHash != headers[i+1].Hash() {
peer.log.Debug("Invalid genesis header count", "have", len(headers), "want", headers[0].Number.Uint64())
res.Done <- errors.New("not enough genesis headers delivered")
peer.log.Debug("Invalid hash progression", "index", i, "wantparenthash", headers[i].ParentHash, "haveparenthash", headers[i+1].Hash())
res.Done <- errors.New("invalid hash progression")
s.scheduleRevertRequest(req)
return
}
Expand Down

0 comments on commit 5cae439

Please sign in to comment.