mirror of
https://gitlab.com/pulsechaincom/erigon-pulse.git
synced 2024-12-24 20:47:16 +00:00
save
This commit is contained in:
parent
b2f5bbbff9
commit
8a7f9b5163
@ -130,6 +130,14 @@ func (q *QueueWithRetry) RetriesLen() (l int) {
|
||||
q.retiresLock.Unlock()
|
||||
return l
|
||||
}
|
||||
func (q *QueueWithRetry) RetryTxNumsList() (out []uint64) {
|
||||
q.retiresLock.Lock()
|
||||
for _, t := range q.retires {
|
||||
out = append(out, t.TxNum)
|
||||
}
|
||||
q.retiresLock.Unlock()
|
||||
return out
|
||||
}
|
||||
func (q *QueueWithRetry) Len() (l int) { return q.RetriesLen() + len(q.newTasks) }
|
||||
|
||||
// Add "new task" (which was never executed yet). May block internal channel is full.
|
||||
|
@ -302,7 +302,10 @@ func ExecV3(ctx context.Context,
|
||||
|
||||
case <-logEvery.C:
|
||||
stepsInDB := rawdbhelpers.IdxStepsCountV3(tx)
|
||||
log.Warn("[dbg] stat of in-queue", "newTasks", in.NewTasksLen(), "retires", in.RetriesLen())
|
||||
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))
|
||||
}
|
||||
progress.Log(rs, in, rws, rs.DoneCount(), inputBlockNum.Load(), outputBlockNum.Get(), outputTxNum.Load(), ExecRepeats.Get(), stepsInDB)
|
||||
if agg.HasBackgroundFilesBuild() {
|
||||
log.Info(fmt.Sprintf("[%s] Background files build", logPrefix), "progress", agg.BackgroundProgress())
|
||||
|
Loading…
Reference in New Issue
Block a user