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

cumulative index stage: ctrl+C support

Browse Source
This commit is contained in:
alex.sharov 2023-04-19 13:02:42 +07:00
parent b8a02642e2
commit d5a06a2d4f
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
cmd/state/exec3/state.go
View File

@ -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
}

2
eth/stagedsync/exec3.go
View File

@ -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() {