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 13:01:21 +07:00
parent e308cfbdf8
commit b8a02642e2
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -181,6 +181,7 @@ func (q *QueueWithRetry) popWait(ctx context.Context) (task *TxTask, ok bool) {
case inTask, ok := <-q.newTasks: case inTask, ok := <-q.newTasks:
if !ok { if !ok {
q.retiresLock.Lock() q.retiresLock.Lock()
log.Warn("[dbg] Next: see closed chan, read task from queue", "q.retires.Len()", q.retires.Len())
if q.retires.Len() > 0 { if q.retires.Len() > 0 {
task = heap.Pop(&q.retires).(*TxTask) task = heap.Pop(&q.retires).(*TxTask)
} }