From 0e2e4b769c6d108d9a4d7c8ded4c329631a4c087 Mon Sep 17 00:00:00 2001 From: sh-cha Date: Thu, 15 Aug 2024 13:13:15 +0900 Subject: [PATCH] add log when broadcaster is waiting for tx timeout --- node/broadcaster/broadcaster.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/node/broadcaster/broadcaster.go b/node/broadcaster/broadcaster.go index 83a2151..53a7b73 100644 --- a/node/broadcaster/broadcaster.go +++ b/node/broadcaster/broadcaster.go @@ -158,7 +158,9 @@ func (b *Broadcaster) prepareBroadcaster(_ /*lastBlockHeight*/ uint64, lastBlock // if we have pending txs, wait until timeout if timeoutTime := pendingTxTime.Add(b.cfg.TxTimeout); lastBlockTime.Before(timeoutTime) { - timer := time.NewTimer(timeoutTime.Sub(lastBlockTime)) + waitingTime := timeoutTime.Sub(lastBlockTime) + timer := time.NewTimer(waitingTime) + b.logger.Info("waiting for pending txs to be processed", zap.Duration("waiting_time", waitingTime)) <-timer.C }