From b8a02642e28087a3cadd88b94e998c421527c2d8 Mon Sep 17 00:00:00 2001 From: "alex.sharov" Date: Wed, 19 Apr 2023 13:01:21 +0700 Subject: [PATCH] save --- cmd/state/exec22/txtask.go | 1 + 1 file changed, 1 insertion(+) diff --git a/cmd/state/exec22/txtask.go b/cmd/state/exec22/txtask.go index 135303cb7..7f4a411f9 100644 --- a/cmd/state/exec22/txtask.go +++ b/cmd/state/exec22/txtask.go @@ -181,6 +181,7 @@ func (q *QueueWithRetry) popWait(ctx context.Context) (task *TxTask, ok bool) { case inTask, ok := <-q.newTasks: if !ok { 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 { task = heap.Pop(&q.retires).(*TxTask) }