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

save

Browse Source
This commit is contained in:
alex.sharov 2023-04-19 12:27:36 +07:00
parent ff3e6e629b
commit b8d974028d
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
cmd/state/exec22/txtask.go
View File

@ -11,6 +11,7 @@ import (
"github.com/ledgerwatch/erigon/core/types" "github.com/ledgerwatch/erigon/core/types"
"github.com/ledgerwatch/erigon/core/types/accounts" "github.com/ledgerwatch/erigon/core/types/accounts"
"github.com/ledgerwatch/erigon/core/vm/evmtypes" "github.com/ledgerwatch/erigon/core/vm/evmtypes"
"github.com/ledgerwatch/log/v3"
) )
// ReadWriteSet contains ReadSet, WriteSet and BalanceIncrease of a transaction, // ReadWriteSet contains ReadSet, WriteSet and BalanceIncrease of a transaction,
@ -157,6 +158,7 @@ func (q *QueueWithRetry) ReTry(t *TxTask) {
// Next - blocks until new task available // Next - blocks until new task available
func (q *QueueWithRetry) Next(ctx context.Context) (*TxTask, bool) { func (q *QueueWithRetry) Next(ctx context.Context) (*TxTask, bool) {
log.Warn("[dbg] before next", "newTasks", q.NewTasksLen(), "retires", q.RetriesLen())
task, ok := q.popNoWait() task, ok := q.popNoWait()
if ok { if ok {
return task, true return task, true