diff --git a/core/benches/cluster_info.rs b/core/benches/cluster_info.rs index d88f26d956..c2f29b6b1d 100644 --- a/core/benches/cluster_info.rs +++ b/core/benches/cluster_info.rs @@ -75,9 +75,9 @@ fn broadcast_shreds_bench(bencher: &mut Bencher) { &cluster_nodes_cache, &last_datapoint, &mut TransmitShredsStats::default(), - &SocketAddrSpace::Unspecified, &cluster_info, &bank_forks, + &SocketAddrSpace::Unspecified, ) .unwrap(); }); diff --git a/core/src/broadcast_stage.rs b/core/src/broadcast_stage.rs index a128878fc2..286c1f4c51 100644 --- a/core/src/broadcast_stage.rs +++ b/core/src/broadcast_stage.rs @@ -22,8 +22,10 @@ use { solana_metrics::{inc_new_counter_error, inc_new_counter_info}, solana_poh::poh_recorder::WorkingBankEntry, solana_runtime::{bank::Bank, bank_forks::BankForks}, - solana_sdk::timing::{timestamp, AtomicInterval}, - solana_sdk::{clock::Slot, pubkey::Pubkey}, + solana_sdk::{ + timing::{timestamp, AtomicInterval}, + {clock::Slot, pubkey::Pubkey}, + }, solana_streamer::{ sendmmsg::{batch_send, SendPktsError}, socket::SocketAddrSpace, @@ -31,9 +33,11 @@ use { std::{ collections::HashMap, net::UdpSocket, - sync::atomic::{AtomicBool, Ordering}, - sync::mpsc::{channel, Receiver, RecvError, RecvTimeoutError, Sender}, - sync::{Arc, Mutex, RwLock}, + sync::{ + atomic::{AtomicBool, Ordering}, + mpsc::{channel, Receiver, RecvError, RecvTimeoutError, Sender}, + Arc, Mutex, RwLock, + }, thread::{self, Builder, JoinHandle}, time::{Duration, Instant}, }, @@ -399,9 +403,9 @@ pub fn broadcast_shreds( cluster_nodes_cache: &ClusterNodesCache, last_datapoint_submit: &Arc, transmit_stats: &mut TransmitShredsStats, - socket_addr_space: &SocketAddrSpace, cluster_info: &ClusterInfo, bank_forks: &Arc>, + socket_addr_space: &SocketAddrSpace, ) -> Result<()> { let mut result = Ok(()); let mut shred_select = Measure::start("shred_select"); diff --git a/core/src/broadcast_stage/fail_entry_verification_broadcast_run.rs b/core/src/broadcast_stage/fail_entry_verification_broadcast_run.rs index 29e22fd28e..4f08d42f6f 100644 --- a/core/src/broadcast_stage/fail_entry_verification_broadcast_run.rs +++ b/core/src/broadcast_stage/fail_entry_verification_broadcast_run.rs @@ -145,9 +145,9 @@ impl BroadcastRun for FailEntryVerificationBroadcastRun { &self.cluster_nodes_cache, &Arc::new(AtomicInterval::default()), &mut TransmitShredsStats::default(), - cluster_info.socket_addr_space(), cluster_info, bank_forks, + cluster_info.socket_addr_space(), ) } fn record( diff --git a/core/src/broadcast_stage/standard_broadcast_run.rs b/core/src/broadcast_stage/standard_broadcast_run.rs index 5f96f79b29..7117d6c629 100644 --- a/core/src/broadcast_stage/standard_broadcast_run.rs +++ b/core/src/broadcast_stage/standard_broadcast_run.rs @@ -362,9 +362,9 @@ impl StandardBroadcastRun { &self.cluster_nodes_cache, &self.last_datapoint_submit, &mut transmit_stats, - cluster_info.socket_addr_space(), cluster_info, bank_forks, + cluster_info.socket_addr_space(), )?; transmit_time.stop();