Struct solana_core::unprocessed_packet_batches::UnprocessedPacketBatches

pub struct UnprocessedPacketBatches {
    pub packet_priority_queue: MinMaxHeap<Rc<ImmutableDeserializedPacket>>,
    pub message_hash_to_transaction: HashMap<Hash, DeserializedPacket>,
    /* private fields */
}

Currently each banking_stage thread has a UnprocessedPacketBatches buffer to store PacketBatch’s received from sigverify. Banking thread continuously scans the buffer to pick proper packets to add to the block.

Fields

packet_priority_queue: MinMaxHeap<Rc<ImmutableDeserializedPacket>>

message_hash_to_transaction: HashMap<Hash, DeserializedPacket>

Implementations

impl UnprocessedPacketBatches

pub fn from_iter<I: IntoIterator<Item = DeserializedPacket>>(
    iter: I,
    capacity: usize
) -> Self

pub fn with_capacity(capacity: usize) -> Self

pub fn clear(&mut self)

pub fn insert_batch(
    &mut self,
    deserialized_packets: impl Iterator<Item = DeserializedPacket>
) -> usize

Insert new deserialized_packet_batch into inner MinMaxHeap<DeserializedPacket>, weighted first by the tx priority, then the stake of the sender. If buffer is at the max limit, the lowest weighted packet is dropped

Returns tuple of number of packets dropped

pub fn push(
    &mut self,
    deserialized_packet: DeserializedPacket
) -> Option<DeserializedPacket>

pub fn iter(&mut self) -> impl Iterator<Item = &DeserializedPacket>

pub fn iter_mut(&mut self) -> impl Iterator<Item = &mut DeserializedPacket>

pub fn retain<F>(&mut self, f: F) where
    F: FnMut(&mut DeserializedPacket) -> bool, 

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn pop_max(&mut self) -> Option<DeserializedPacket>

pub fn pop_max_n(&mut self, n: usize) -> Option<Vec<DeserializedPacket>>

Pop up to the next n highest priority transactions from the queue. Returns None if the queue is empty

pub fn capacity(&self) -> usize

Trait Implementations

impl Default for UnprocessedPacketBatches

fn default() -> UnprocessedPacketBatches

Returns the “default value” for a type.