Refactor PoS downloader (#3717)
* Remove blockHeight arg from FeedHeaderPoW * Revert "Remove blockHeight arg from FeedHeaderPoW" This reverts commit 9bf92921db11cd4e13386fcee29f30241d070fc6. * Move PayloadMessage & ForkChoiceMessage to package engineapi * RequestList instead of newPayloadCh & forkChoiceCh * Introduce request status * Send reply only when request status is New * Move BeaconRequestList to HeaderDownload * Don't SetFetching when PoS (Fetching means handling newBlockHashes) * Merge Syncing & Synced into DataWasMissing * Introduce SyncStatus * onlyNew arg in WaitForRequest * Move waitingForBeaconChain into RequestList * Interrupt instead of skipCycleHack * Introduce timeout for PoS headers * Split downloadMissingPoSHeaders * Move StartPoSDownloader into HeaderDownload * Move Stopping interrupt to StartPoSDownloader * Move stopping PayloadStatus back to HeadersPOS * cleanUpPoSDownload * Post-merge fix * TestBogusForkchoice * TestPoSDownloader * requestStatus in attemptPoSDownload * Broadcast in SetStatus * Cosmetics * attemptPoSDownload -> schedulePoSDownload * Demote some logs to Trace
Showing
- cmd/integration/commands/stages.go 1 addition, 2 deletionscmd/integration/commands/stages.go
- cmd/rpcdaemon/rpcdaemontest/test_util.go 1 addition, 1 deletioncmd/rpcdaemon/rpcdaemontest/test_util.go
- eth/backend.go 5 additions, 12 deletionseth/backend.go
- eth/stagedsync/stage_headers.go 151 additions, 195 deletionseth/stagedsync/stage_headers.go
- ethdb/privateapi/engine_test.go 12 additions, 21 deletionsethdb/privateapi/engine_test.go
- ethdb/privateapi/ethbackend.go 37 additions, 56 deletionsethdb/privateapi/ethbackend.go
- go.mod 1 addition, 0 deletionsgo.mod
- go.sum 2 additions, 0 deletionsgo.sum
- turbo/engineapi/request_list.go 167 additions, 0 deletionsturbo/engineapi/request_list.go
- turbo/stages/headerdownload/header_algos.go 152 additions, 28 deletionsturbo/stages/headerdownload/header_algos.go
- turbo/stages/headerdownload/header_data_struct.go 19 additions, 8 deletionsturbo/stages/headerdownload/header_data_struct.go
- turbo/stages/mock_sentry.go 15 additions, 11 deletionsturbo/stages/mock_sentry.go
- turbo/stages/sentry_mock_test.go 104 additions, 7 deletionsturbo/stages/sentry_mock_test.go
- turbo/stages/stageloop.go 0 additions, 6 deletionsturbo/stages/stageloop.go
Loading
Please register or sign in to comment