mirror/prysm-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/prysm-pulse.git synced 2025-01-11 12:10:05 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Fallback To Historical Sync For Powchain (#8146)

Browse Source 
Co-authored-by: Raul Jordan <raul@prysmaticlabs.com>
Co-authored-by: prylabs-bulldozer[bot] <58059840+prylabs-bulldozer[bot]@users.noreply.github.com>
This commit is contained in:
Nishant Das 2020-12-18 02:49:22 +08:00 committed by GitHub
parent 44c3adb367
commit 46c67f1e9e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
beacon-chain/powchain/log_processing.go
View File

@ -31,6 +31,7 @@ var (
const eth1LookBackPeriod = 100 const eth1LookBackPeriod = 100
const eth1DataSavingInterval = 100 const eth1DataSavingInterval = 100
const maxTolerableDifference = 50
const defaultEth1HeaderReqLimit = uint64(1000) const defaultEth1HeaderReqLimit = uint64(1000)
const depositlogRequestLimit = 10000 const depositlogRequestLimit = 10000
@ -360,6 +361,11 @@ func (s *Service) requestBatchedHeadersAndLogs(ctx context.Context) error {
if err != nil { if err != nil {
return err return err
} }
if requestedBlock > s.latestEth1Data.LastRequestedBlock &&
requestedBlock-s.latestEth1Data.LastRequestedBlock > maxTolerableDifference {
log.Infof("Falling back to historical headers and logs sync. Current difference is %d", requestedBlock-s.latestEth1Data.LastRequestedBlock)
return s.processPastLogs(ctx)
}
for i := s.latestEth1Data.LastRequestedBlock + 1; i <= requestedBlock; i++ { for i := s.latestEth1Data.LastRequestedBlock + 1; i <= requestedBlock; i++ {
// Cache eth1 block header here. // Cache eth1 block header here.
_, err := s.BlockHashByHeight(ctx, big.NewInt(int64(i))) _, err := s.BlockHashByHeight(ctx, big.NewInt(int64(i)))