From d5a06a2d4fcd546a3c4129bc0087fe847fe2f417 Mon Sep 17 00:00:00 2001
From: "alex.sharov" <AskAlexSharov@gmail.com>
Date: Wed, 19 Apr 2023 13:02:42 +0700
Subject: [PATCH] cumulative index stage: ctrl+C support

---
 cmd/state/exec3/state.go | 6 +++---
 eth/stagedsync/exec3.go  | 2 +-
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/cmd/state/exec3/state.go b/cmd/state/exec3/state.go
index 932c1f413..34a7cbf65 100644
--- a/cmd/state/exec3/state.go
+++ b/cmd/state/exec3/state.go
@@ -104,9 +104,9 @@ func (rw *Worker) Run() error {
 		if err := rw.resultCh.Add(rw.ctx, txTask); err != nil {
 			return err
 		}
-		if txTask.TxNum > 9300_000 {
-			log.Warn("[dbg] before next", "newTasks", rw.in.NewTasksLen(), "retires", rw.in.RetriesLen())
-		}
+		//if txTask.TxNum > 930_000 {
+		//log.Warn("[dbg] before next", "newTasks", rw.in.NewTasksLen(), "retires", rw.in.RetriesLen())
+		//}
 	}
 	return nil
 }
diff --git a/eth/stagedsync/exec3.go b/eth/stagedsync/exec3.go
index 106005bf7..0f4618c7f 100644
--- a/eth/stagedsync/exec3.go
+++ b/eth/stagedsync/exec3.go
@@ -304,7 +304,7 @@ func ExecV3(ctx context.Context,
 					stepsInDB := rawdbhelpers.IdxStepsCountV3(tx)
 					l := in.RetryTxNumsList()
 					if len(l) > 0 {
-						log.Warn("[dbg] stat of in-queue", "newTasks", in.NewTasksLen(), "retires", in.RetriesLen(), "txNums", fmt.Sprintf("%d", l))
+						log.Warn("[dbg] stat of in-queue", "newTasks", in.NewTasksLen(), "retires", in.RetriesLen(), "txNums", fmt.Sprintf("%d", l), "outputTxNum.Load()", outputTxNum.Load())
 					}
 					progress.Log(rs, in, rws, rs.DoneCount(), inputBlockNum.Load(), outputBlockNum.Get(), outputTxNum.Load(), ExecRepeats.Get(), stepsInDB)
 					if agg.HasBackgroundFilesBuild() {