diff --git a/zebrad/src/components/mempool/tests/vector.rs b/zebrad/src/components/mempool/tests/vector.rs index 32c157ea3..29b16868e 100644 --- a/zebrad/src/components/mempool/tests/vector.rs +++ b/zebrad/src/components/mempool/tests/vector.rs @@ -417,6 +417,21 @@ async fn mempool_cancel_mined() -> Result<(), Report> { .await .unwrap(); + // Wait for the chain tip update + if let Err(timeout_error) = timeout( + CHAIN_TIP_UPDATE_WAIT_LIMIT, + chain_tip_change.wait_for_tip_change(), + ) + .await + .map(|change_result| change_result.expect("unexpected chain tip update failure")) + { + info!( + timeout = ?humantime_seconds(CHAIN_TIP_UPDATE_WAIT_LIMIT), + ?timeout_error, + "timeout waiting for chain tip change after committing block" + ); + } + // Query the mempool to make it poll chain_tip_change mempool.dummy_call().await; @@ -431,6 +446,21 @@ async fn mempool_cancel_mined() -> Result<(), Report> { .await .unwrap(); + // Wait for the chain tip update + if let Err(timeout_error) = timeout( + CHAIN_TIP_UPDATE_WAIT_LIMIT, + chain_tip_change.wait_for_tip_change(), + ) + .await + .map(|change_result| change_result.expect("unexpected chain tip update failure")) + { + info!( + timeout = ?humantime_seconds(CHAIN_TIP_UPDATE_WAIT_LIMIT), + ?timeout_error, + "timeout waiting for chain tip change after committing block" + ); + } + // Query the mempool to make it poll chain_tip_change mempool.dummy_call().await;