Skip to content

Commit

Permalink
waits for tip change after each commit call to the state-service in m…
Browse files Browse the repository at this point in the history
…empool_cancel_mined (#5347)
  • Loading branch information
arya2 authored Oct 6, 2022
1 parent 1ec632a commit 7207f9d
Showing 1 changed file with 30 additions and 0 deletions.
30 changes: 30 additions & 0 deletions zebrad/src/components/mempool/tests/vector.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand All @@ -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;

Expand Down

0 comments on commit 7207f9d

Please sign in to comment.