Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

test: restore unstable network tests #5197

Draft
wants to merge 4 commits into
base: main
Choose a base branch
from
Draft

test: restore unstable network tests #5197

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
b7932c3
feat: implement p2p TCP relay
0x009922 Oct 25, 2024
cd73f0c
feat: draft unstable network tests (doesn't work yet)
0x009922 Oct 29, 2024
66eea36
test: cover case with second block
0x009922 Oct 29, 2024
1c5fe2b
refactor: chores in core; faulty peers tests work, but unstable
0x009922 Nov 5, 2024
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
7 changes: 7 additions & 0 deletions Cargo.lock
View file
Open in desktop

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

1 change: 1 addition & 0 deletions crates/iroha/Cargo.toml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -95,3 +95,4 @@ hex = { workspace = true }
assertables = { workspace = true }
trybuild = { workspace = true }
assert_matches = "1.5.0"
ascii_table = "4.0.4"
8 changes: 4 additions & 4 deletions crates/iroha/tests/extra_functional/connected_peers.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -59,7 +59,7 @@ async fn connected_peers_with_f(faults: usize) -> Result<()> {

// Unregister a peer: committed with f = `faults` then `status.peers` decrements
let client = randomized_peers.choose(&mut thread_rng()).unwrap().client();
let unregister_peer = Unregister::peer(removed_peer.peer_id());
let unregister_peer = Unregister::peer(removed_peer.id());
spawn_blocking(move || client.submit_blocking(unregister_peer)).await??;
timeout(
network.sync_timeout(),
Expand All @@ -78,7 +78,7 @@ async fn connected_peers_with_f(faults: usize) -> Result<()> {
assert_eq!(status.peers, 0);

// Re-register the peer: committed with f = `faults` - 1 then `status.peers` increments
let register_peer = Register::peer(removed_peer.peer_id());
let register_peer = Register::peer(removed_peer.id());
let client = randomized_peers
.iter()
.choose(&mut thread_rng())
Expand Down Expand Up @@ -109,13 +109,13 @@ async fn assert_peers_status(
status.peers,
expected_peers,
"unexpected peers for {}",
peer.peer_id()
peer.id()
);
assert_eq!(
status.blocks,
expected_blocks,
"expected blocks for {}",
peer.peer_id()
peer.id()
);
})
.collect::<FuturesUnordered<_>>()
Expand Down
Loading
Loading