diff --git a/internal/consensus/mempool_test.go b/internal/consensus/mempool_test.go index a0dd542ed..457c4bf05 100644 --- a/internal/consensus/mempool_test.go +++ b/internal/consensus/mempool_test.go @@ -51,7 +51,7 @@ func TestMempoolNoProgressUntilTxsAvailable(t *testing.T) { ensureNewEventOnChannel(t, newBlockCh) // first block gets committed ensureNoNewEventOnChannel(t, newBlockCh) - deliverTxsRange(ctx, t, cs, 0, 1) + checkTxsRange(ctx, t, cs, 0, 1) ensureNewEventOnChannel(t, newBlockCh) // commit txs ensureNewEventOnChannel(t, newBlockCh) // commit updated app hash ensureNoNewEventOnChannel(t, newBlockCh) @@ -118,7 +118,7 @@ func TestMempoolProgressInHigherRound(t *testing.T) { round = 0 ensureNewRound(t, newRoundCh, height, round) // first round at next height - deliverTxsRange(ctx, t, cs, 0, 1) // we deliver txs, but dont set a proposal so we get the next round + checkTxsRange(ctx, t, cs, 0, 1) // we deliver txs, but dont set a proposal so we get the next round ensureNewTimeout(t, timeoutCh, height, round, cs.config.TimeoutPropose.Nanoseconds()) round++ // moving to the next round @@ -126,7 +126,7 @@ func TestMempoolProgressInHigherRound(t *testing.T) { ensureNewEventOnChannel(t, newBlockCh) // now we can commit the block } -func deliverTxsRange(ctx context.Context, t *testing.T, cs *State, start, end int) { +func checkTxsRange(ctx context.Context, t *testing.T, cs *State, start, end int) { t.Helper() // Deliver some txs. for i := start; i < end; i++ { @@ -159,7 +159,7 @@ func TestMempoolTxConcurrentWithCommit(t *testing.T) { newBlockHeaderCh := subscribe(ctx, t, cs.eventBus, types.EventQueryNewBlockHeader) const numTxs int64 = 3000 - go deliverTxsRange(ctx, t, cs, 0, int(numTxs)) + go checkTxsRange(ctx, t, cs, 0, int(numTxs)) startTestRound(ctx, cs, cs.Height, cs.Round) for n := int64(0); n < numTxs; {