This commit is contained in:
alex.sharov 2023-04-19 12:52:51 +07:00
parent 279bc6063b
commit c0cf958215

View File

@ -230,7 +230,9 @@ func ExecV3(ctx context.Context,
for outputTxNum.Load() <= maxTxNum { for outputTxNum.Load() <= maxTxNum {
if outputTxNum.Load() > 9300_000 {
log.Warn("[dbg] before drain", "outputTxNum.Load()", outputTxNum.Load(), "maxTxNum", maxTxNum, "rws.ResultChLen()", rws.ResultChLen(), "rws.Len", rws.Len()) 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 { if err := rws.Drain(ctx); err != nil {
return err return err
} }