Struct solana_core::tpu::Tpu

[+] Show declaration

pub struct Tpu { /* fields omitted */ }

Implementations

impl Tpu[−]

pub fn new(
    cluster_info: &Arc<ClusterInfo>,
    poh_recorder: &Arc<Mutex<PohRecorder>>,
    entry_receiver: Receiver<WorkingBankEntry>,
    retransmit_slots_receiver: CrossbeamReceiver<HashMap<Slot, Arc<Bank>>>,
    transactions_sockets: Vec<UdpSocket>,
    tpu_forwards_sockets: Vec<UdpSocket>,
    broadcast_sockets: Vec<UdpSocket>,
    subscriptions: &Arc<RpcSubscriptions>,
    transaction_status_sender: Option<TransactionStatusSender>,
    blockstore: &Arc<Blockstore>,
    broadcast_type: &BroadcastStageType,
    exit: &Arc<AtomicBool>,
    shred_version: u16,
    vote_tracker: Arc<VoteTracker>,
    bank_forks: Arc<RwLock<BankForks>>,
    verified_vote_sender: VerifiedVoteSender,
    replay_vote_receiver: ReplayVoteReceiver,
    replay_vote_sender: ReplayVoteSender,
    bank_notification_sender: Option<BankNotificationSender>,
    tpu_coalesce_ms: u64
) -> Self

pub fn join(self) -> Result<()>