save

erigontech · Jul 23, 2024 · f3cebdc · f3cebdc
1 parent e2df678
commit f3cebdc
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/eth/stagedsync/exec3.go b/eth/stagedsync/exec3.go
@@ -917,6 +917,7 @@ Loop:
 
 					tt = time.Now()
 					applyTx.CollectMetrics()
+
 					if !useExternalTx {
 						tt = time.Now()
 						if err = applyTx.Commit(); err != nil {
@@ -945,6 +946,11 @@ Loop:
 				}(); err != nil {
 					return err
 				}
+
+				// on chain-tip: if batch is full then stop execution - to allow stages commit
+				if !execStage.CurrentSyncCycle.IsInitialCycle {
+					break Loop
+				}
 				logger.Info("Committed", "time", time.Since(commitStart),
 					"block", doms.BlockNum(), "txNum", doms.TxNum(),
 					"step", fmt.Sprintf("%.1f", float64(doms.TxNum())/float64(agg.StepSize())),