Struct solana::banking_stage::BankingStage

pub struct BankingStage { /* fields omitted */ }

Stores the stage's thread handle and output receiver.

Methods

impl BankingStage

pub fn new(
    cluster_info: &Arc<RwLock<ClusterInfo>>,
    poh_recorder: &Arc<Mutex<PohRecorder>>,
    verified_receiver: CrossbeamReceiver<VerifiedPackets>,
    verified_vote_receiver: CrossbeamReceiver<VerifiedPackets>
) -> Self

Create the stage using bank. Exit when verified_receiver is dropped.

pub fn consume_buffered_packets(
    my_pubkey: &Pubkey,
    poh_recorder: &Arc<Mutex<PohRecorder>>,
    buffered_packets: &mut Vec<(Packets, Vec<usize>)>,
    batch_limit: usize
) -> Result<UnprocessedPackets>

pub fn process_loop(
    my_pubkey: Pubkey,
    verified_receiver: &CrossbeamReceiver<VerifiedPackets>,
    poh_recorder: &Arc<Mutex<PohRecorder>>,
    cluster_info: &Arc<RwLock<ClusterInfo>>,
    recv_start: &mut Instant,
    enable_forwarding: bool,
    id: u32,
    batch_limit: usize
)

pub fn num_threads() -> u32

pub fn process_and_record_transactions(
    bank: &Bank,
    txs: &[Transaction],
    poh: &Arc<Mutex<PohRecorder>>,
    chunk_offset: usize
) -> (Result<()>, Vec<usize>)

pub fn process_packets(
    my_pubkey: &Pubkey,
    verified_receiver: &CrossbeamReceiver<VerifiedPackets>,
    poh: &Arc<Mutex<PohRecorder>>,
    recv_start: &mut Instant,
    recv_timeout: Duration,
    id: u32,
    batch_limit: usize
) -> Result<UnprocessedPackets>

Process the incoming packets

Trait Implementations

impl Service for BankingStage

type JoinReturnType = ()

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