Function solana_core::retransmit_stage::retransmitter [−][src]
pub fn retransmitter(
sockets: Arc<Vec<UdpSocket>>,
bank_forks: Arc<RwLock<BankForks>>,
leader_schedule_cache: &Arc<LeaderScheduleCache>,
cluster_info: Arc<ClusterInfo>,
r: Arc<Mutex<PacketReceiver>>,
max_slots: &Arc<MaxSlots>,
rpc_subscriptions: Option<Arc<RpcSubscriptions>>
) -> Vec<JoinHandle<()>>
Service to retransmit messages from the leader or layer 1 to relevant peer nodes.
See cluster_info for network layer definitions.
Arguments
sockets- Sockets to read from.bank_forks- The BankForks structureleader_schedule_cache- The leader schedule to verify shredscluster_info- This structure needs to be updated and populated by the bank and via gossip.r- Receive channel for shreds to be retransmitted to all the layer 1 nodes.