This commit is contained in:
alex.sharov 2023-04-19 12:46:40 +07:00
parent 132cc8854f
commit 6e5e5e026c

View File

@ -334,7 +334,9 @@ func (q *ResultsQueue) Drain(ctx context.Context) error {
msg = append(msg, fmt.Sprintf("%d", t.TxNum)) msg = append(msg, fmt.Sprintf("%d", t.TxNum))
} }
} }
if len(msg) > 0 {
log.Warn("[dbg] before drain resultqueue", "txnum", strings.Join(msg, ",")) log.Warn("[dbg] before drain resultqueue", "txnum", strings.Join(msg, ","))
}
q.Unlock() q.Unlock()
select { select {