github/prysm
1
1
Fork 0
mirror of https://github.com/OffchainLabs/prysm.git synced 2026-05-02 03:02:54 -04:00
Code Issues Packages Projects Releases Wiki Activity

Fix Deposit Log Processing (#4352)

Browse Source 
* fix log processing
* Merge branch 'master' into fixLogs
* Merge refs/heads/master into fixLogs
This commit is contained in:
Nishant Das
2019-12-27 01:44:56 +08:00
committed by prylabs-bulldozer[bot]
parent d5181496c4
commit 28eadac172
2 changed files with 9 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -269,8 +269,7 @@ func (s *Service) processPastLogs(ctx context.Context) error {
return err
}
}
s.lastRequestedBlock.Set(s.blockHeight)
s.lastRequestedBlock.Set(big.NewInt(int64(currentBlockNum)))
currentState, err := s.beaconDB.HeadState(ctx)
if err != nil {
@@ -295,9 +294,8 @@ func (s *Service) requestBatchedLogs(ctx context.Context) error {
if err != nil {
return err
}
s.lastRequestedBlock.Set(big.NewInt(int64(i)))
}
s.lastRequestedBlock.Set(requestedBlock)
return nil
}

7
beacon-chain/powchain/service.go
View File

@@ -416,6 +416,13 @@ func (s *Service) handleDelayTicker() {
if s.lastRequestedBlock.Cmp(s.blockHeight) == 0 {
return
}
if !s.chainStarted {
if err := s.checkForChainStart(context.Background(), s.lastRequestedBlock); err != nil {
s.runError = err
log.Error(err)
return
}
}
if err := s.requestBatchedLogs(context.Background()); err != nil {
s.runError = err
log.Error(err)