mirror/erigon-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/erigon-pulse.git synced 2025-01-03 09:37:38 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

update stage progress before commit - to keep db always consistent (#1888)

Browse Source
This commit is contained in:
Alex Sharov 2021-05-06 14:18:43 +07:00 committed by GitHub
parent 49225f7319
commit b1dc618b95
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
eth/stagedsync/stage_bodies_new.go
View File

@ -159,6 +159,9 @@ func BodiesForward(
return err return err
} }
if !useExternalTx { if !useExternalTx {
if err := s.DoneAndUpdate(tx, bodyProgress); err != nil {
return err
}
if err = tx.CommitAndBegin(context.Background()); err != nil { if err = tx.CommitAndBegin(context.Background()); err != nil {
return err return err
} }

6
eth/stagedsync/stage_execute.go
View File

@ -212,15 +212,15 @@ func SpawnExecuteBlocksStage(s *StageState, stateDB ethdb.Database, toBlock uint
updateProgress := !useBatch || batch.BatchSize() >= int(params.batchSize) updateProgress := !useBatch || batch.BatchSize() >= int(params.batchSize)
if updateProgress { if updateProgress {
if err = s.Update(tx, stageProgress); err != nil {
return err
}
if useBatch { if useBatch {
if err = batch.CommitAndBegin(context.Background()); err != nil { if err = batch.CommitAndBegin(context.Background()); err != nil {
return err return err
} }
} }
if !useExternalTx { if !useExternalTx {
if err = s.Update(tx, stageProgress); err != nil {
return err
}
if err = tx.CommitAndBegin(context.Background()); err != nil { if err = tx.CommitAndBegin(context.Background()); err != nil {
return err return err
} }

3
eth/stagedsync/stage_headers_new.go
View File

@ -152,6 +152,9 @@ func HeadersForward(
return err return err
} }
if !useExternalTx { if !useExternalTx {
if err = s.Update(tx, headerInserter.GetHighest()); err != nil {
return err
}
if err = tx.CommitAndBegin(context.Background()); err != nil { if err = tx.CommitAndBegin(context.Background()); err != nil {
return err return err
} }