Skip to content
This repository was archived by the owner on Nov 15, 2023. It is now read-only.

chain_head/tests: Check finalized block event before new block #13680

Merged
lexnv merged 7 commits into from
Mar 23, 2023
Merged

chain_head/tests: Check finalized block event before new block #13680

Changes from 1 commit
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
ab062f2
chain_head/tests: Mock client for custom block notification
lexnv Mar 22, 2023
b8d00c1
chain_head/tests: Check finalized block event before new block
lexnv Mar 22, 2023
c249289
Update client/rpc-spec-v2/src/chain_head/test_utils.rs
lexnv Mar 23, 2023
a81fbbd
Update client/rpc-spec-v2/src/chain_head/test_utils.rs
lexnv Mar 23, 2023
ab28f73
Update client/rpc-spec-v2/src/chain_head/test_utils.rs
lexnv Mar 23, 2023
0678bf4
chain_head/tests: Run import events with 10min timeout
lexnv Mar 23, 2023
8e93ef2
chain_head/tests: Add comments about test
lexnv Mar 23, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Update client/rpc-spec-v2/src/chain_head/test_utils.rs 
Co-authored-by: Bastian Köcher <[email protected]>
  • Loading branch information
@lexnv @bkchr
lexnv and bkchr authored Mar 23, 2023
commit ab28f73fa665a1299f180fb64ebfd999a172cbde
6 changes: 2 additions & 4 deletions client/rpc-spec-v2/src/chain_head/test_utils.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -69,10 +69,8 @@ impl<Client> ChainHeadMockClient<Client> {

pub async fn trigger_finality_stream(&self, header: Header) {
// Ensure the client called the `finality_notification_stream`.
let mut retries = NUM_RETRIES;
while retries > 0 && self.finality_sinks.lock().is_empty() {
retries -= 1;
tokio::time::sleep(tokio::time::Duration::from_secs(SLEEP_SECS)).await;
while self.finality_sinks.lock().is_empty() {
tokio::time::sleep(tokio::time::Duration::from_secs(1)).await;
}

// Build the notification.
Expand Down