mirror/erigon-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/erigon-pulse.git synced 2024-12-31 16:21:21 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

e3: fix sequential commit place (#5969)

Browse Source
This commit is contained in:
Alex Sharov 2022-11-06 10:27:52 +07:00 committed by GitHub
parent bc7128e671
commit e7c53ac9b7
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 24 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

51
eth/stagedsync/exec3.go
View File

@ -482,39 +482,36 @@ loop:
core.BlockExecutionTimer.UpdateDuration(t)
if !parallel {
syncMetrics[stages.Execution].Set(blockNum)
}
if rs.SizeEstimate() >= commitThreshold {
commitStart := time.Now()
log.Info("Committing...")
if err = agg.Prune(ctx, 10*ethconfig.HistoryV3AggregationStep); err != nil {
return err
}
if err := rs.Flush(applyTx); err != nil {
return err
}
if err := agg.Flush(applyTx); err != nil {
return err
}
if err = execStage.Update(applyTx, stageProgress); err != nil {
return err
}
applyTx.CollectMetrics()
if !useExternalTx {
if err := applyTx.Commit(); err != nil {
if rs.SizeEstimate() >= commitThreshold {
commitStart := time.Now()
log.Info("Committing...")
if err = agg.Prune(ctx, 10*ethconfig.HistoryV3AggregationStep); err != nil {
return err
}
if applyTx, err = chainDb.BeginRw(ctx); err != nil {
if err := rs.Flush(applyTx); err != nil {
return err
}
defer applyTx.Rollback()
agg.SetTx(applyTx)
reconWorkers[0].ResetTx(applyTx)
log.Info("Committed", "time", time.Since(commitStart), "toProgress", stageProgress)
if err := agg.Flush(applyTx); err != nil {
return err
}
if err = execStage.Update(applyTx, stageProgress); err != nil {
return err
}
applyTx.CollectMetrics()
if !useExternalTx {
if err := applyTx.Commit(); err != nil {
return err
}
if applyTx, err = chainDb.BeginRw(ctx); err != nil {
return err
}
defer applyTx.Rollback()
agg.SetTx(applyTx)
reconWorkers[0].ResetTx(applyTx)
log.Info("Committed", "time", time.Since(commitStart), "toProgress", stageProgress)
}
}
}
if !parallel {
select {
case <-logEvery.C:
stepsInDB := idxStepsInDB(applyTx)