Skip to content

Commit

Permalink
Don't announce blocks in `sync_to_tip_when_we_sync_together_with_mult…
Browse files Browse the repository at this point in the history
…iple_peers` (paritytech#12783)

* Fix syncing test

* cargo fmt

* Fix test
  • Loading branch information
altonen authored and ltfschoen committed Feb 22, 2023
1 parent 06ed7f8 commit c4f126b
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 4 deletions.
3 changes: 2 additions & 1 deletion client/network/test/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -428,8 +428,9 @@ where
at: BlockId<Block>,
count: usize,
with_tx: bool,
announce_block: bool,
) -> H256 {
self.generate_tx_blocks_at(at, count, with_tx, false, false, true)
self.generate_tx_blocks_at(at, count, with_tx, false, false, announce_block)
}

/// Push blocks to the peer (simplified: with or without a TX) starting from
Expand Down
10 changes: 7 additions & 3 deletions client/network/test/src/sync.rs
Original file line number Diff line number Diff line change
Expand Up @@ -775,7 +775,9 @@ fn sync_to_tip_requires_that_sync_protocol_is_informed_about_best_block() {
let mut net = TestNet::new(1);

// Produce some blocks
let block_hash = net.peer(0).push_blocks_at_without_informing_sync(BlockId::Number(0), 3, true);
let block_hash =
net.peer(0)
.push_blocks_at_without_informing_sync(BlockId::Number(0), 3, true, true);

// Add a node and wait until they are connected
net.add_full_peer_with_config(Default::default());
Expand Down Expand Up @@ -818,17 +820,19 @@ fn sync_to_tip_when_we_sync_together_with_multiple_peers() {

let block_hash =
net.peer(0)
.push_blocks_at_without_informing_sync(BlockId::Number(0), 10_000, false);
.push_blocks_at_without_informing_sync(BlockId::Number(0), 10_000, false, false);

net.peer(1)
.push_blocks_at_without_informing_sync(BlockId::Number(0), 5_000, false);
.push_blocks_at_without_informing_sync(BlockId::Number(0), 5_000, false, false);

net.block_until_connected();
net.block_until_idle();

assert!(!net.peer(2).has_block(block_hash));

net.peer(0).network_service().new_best_block_imported(block_hash, 10_000);
net.peer(0).network_service().announce_block(block_hash, None);

while !net.peer(2).has_block(block_hash) && !net.peer(1).has_block(block_hash) {
net.block_until_idle();
}
Expand Down

0 comments on commit c4f126b

Please sign in to comment.