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.