fix waiting pending txs loop break logic

initia-labs · Jan 23, 2025 · e733737 · e733737
1 parent 9c7791a
commit e733737
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/node/broadcaster/broadcaster.go b/node/broadcaster/broadcaster.go
@@ -160,19 +160,20 @@ func (b *Broadcaster) loadPendingTxs(ctx types.Context, stage types.BasicDB, las
 		pollingTimer := time.NewTicker(ctx.PollingInterval())
 		defer pollingTimer.Stop()
 
+	WAITLOOP:
 		for {
+			if len(pendingTxs) == 0 {
+				return nil
+			}
+
 			select {
 			case <-ctx.Done():
 				return ctx.Err()
 			case <-timer.C:
-				break
+				break WAITLOOP
 			case <-pollingTimer.C:
 			}
 
-			if len(pendingTxs) == 0 {
-				return nil
-			}
-
 			txHash, err := hex.DecodeString(pendingTxs[0].TxHash)
 			if err != nil {
 				return err