This commit is contained in:
alex.sharov 2023-04-19 12:25:27 +07:00
parent 04a4b1ed56
commit 93d594cc8a

View File

@ -229,7 +229,8 @@ func ExecV3(ctx context.Context,
var lastBlockNum uint64
for outputTxNum.Load() <= maxTxNum {
log.Warn("[dbg] before drain", "outputTxNum.Load()", outputTxNum.Load(), "maxTxNum", maxTxNum)
log.Warn("[dbg] before drain", "outputTxNum.Load()", outputTxNum.Load(), "maxTxNum", maxTxNum, "rws.ResultChLen()", rws.ResultChLen(), "rws.Len", rws.Len())
if err := rws.Drain(ctx); err != nil {
return err
}