jleony/nanoreth
1
0
Fork 0
mirror of https://github.com/hl-archive-node/nanoreth.git synced 2025-12-06 10:59:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: randomly sample peers in NetworkState::announce_new_block() for block propagation (#5930)

Browse Source
This commit is contained in:
Fabian Zeiher
2024-01-10 16:14:17 +01:00
committed by GitHub
parent 56a3548915
commit df4774c709
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
crates/net/network/src/state.rs
View File

@ -12,6 +12,8 @@ use crate::{
peers::{PeerAction, PeersManager},
FetchClient,
};
use rand::seq::SliceRandom;
use reth_eth_wire::{
capability::Capabilities, BlockHashNumber, DisconnectReason, NewBlockHashes, Status,
};
@ -176,7 +178,12 @@ where
let number = msg.block.block.header.number;
let mut count = 0;
for (peer_id, peer) in self.active_peers.iter_mut() {
// Shuffle to propagate to a random sample of peers on every block announcement
let mut peers: Vec<_> = self.active_peers.iter_mut().collect();
peers.shuffle(&mut rand::thread_rng());
for (peer_id, peer) in peers.into_iter() {
if peer.blocks.contains(&msg.hash) {
// skip peers which already reported the block
continue