e3: commit earlier (#6271)

erigontech · Dec 10, 2022 · e21b1b6 · e21b1b6
1 parent b4fd07b
commit e21b1b6
Showing 1 changed file with 8 additions and 7 deletions.
diff --git a/eth/stagedsync/exec3.go b/eth/stagedsync/exec3.go
@@ -258,7 +258,14 @@ func ExecV3(ctx context.Context,
 
 					stepsInDB := idxStepsInDB(tx)
 					progress.Log(rs, rwsLen, uint64(queueSize), rs.DoneCount(), inputBlockNum.Load(), outputBlockNum.Load(), outputTxNum.Load(), repeatCount.Load(), uint64(resultsSize.Load()), resultCh, stepsInDB)
+				case <-pruneEvery.C:
 					if rs.SizeEstimate() < commitThreshold {
+						if err = agg.Flush(tx); err != nil {
+							panic(err)
+						}
+						if err = agg.PruneWithTiemout(ctx, 1*time.Second); err != nil {
+							panic(err)
+						}
 						break
 					}
 
@@ -352,13 +359,7 @@ func ExecV3(ctx context.Context,
 						panic(err)
 					}
 					log.Info("Committed", "time", time.Since(commitStart), "drain", t1, "rs.flush", t2, "agg.flush", t3, "tx.commit", t4)
-				case <-pruneEvery.C:
-					if err = agg.Flush(tx); err != nil {
-						panic(err)
-					}
-					if err = agg.PruneWithTiemout(ctx, 1*time.Second); err != nil {
-						panic(err)
-					}
+
 				}
 			}
 			if err = rs.Flush(tx); err != nil {