Function solana_core::retransmit_stage::retransmitter

source · [−]
pub fn retransmitter(
    sockets: Arc<Vec<UdpSocket>>, 
    bank_forks: Arc<RwLock<BankForks>>, 
    leader_schedule_cache: Arc<LeaderScheduleCache>, 
    cluster_info: Arc<ClusterInfo>, 
    shreds_receiver: Receiver<Vec<Shred>>, 
    max_slots: Arc<MaxSlots>, 
    rpc_subscriptions: Option<Arc<RpcSubscriptions>>
) -> JoinHandle<()>
Expand description

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 structure
  • leader_schedule_cache - The leader schedule to verify shreds
  • cluster_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.