diff --git a/block/manager.go b/block/manager.go index 20f026c9e7..4951abdeaa 100644 --- a/block/manager.go +++ b/block/manager.go @@ -216,7 +216,6 @@ func (m *Manager) AggregationLoop(ctx context.Context, lazy bool) { } } } else { - <-timer.C for { select { case <-ctx.Done(): diff --git a/node/full_node_integration_test.go b/node/full_node_integration_test.go index 0327aeff2e..d98d3e2201 100644 --- a/node/full_node_integration_test.go +++ b/node/full_node_integration_test.go @@ -177,17 +177,17 @@ func TestLazyAggregator(t *testing.T) { _, err = client.BroadcastTxCommit(context.Background(), []byte{0, 0, 0, 1}) assert.NoError(err) time.Sleep(2 * time.Second) - assert.Equal(node.(*FullNode).Store.Height(), uint64(1)) + assert.Equal(node.(*FullNode).Store.Height(), uint64(2)) _, err = client.BroadcastTxCommit(context.Background(), []byte{0, 0, 0, 2}) assert.NoError(err) time.Sleep(2 * time.Second) - assert.Equal(node.(*FullNode).Store.Height(), uint64(2)) + assert.Equal(node.(*FullNode).Store.Height(), uint64(3)) _, err = client.BroadcastTxCommit(context.Background(), []byte{0, 0, 0, 3}) assert.NoError(err) time.Sleep(2 * time.Second) - assert.Equal(node.(*FullNode).Store.Height(), uint64(3)) + assert.Equal(node.(*FullNode).Store.Height(), uint64(4)) }