Struct IHaveQueue 

pub struct IHaveQueue { /* private fields */ }

Lock-free queue for pending IHave announcements.

Uses crossbeam’s SegQueue for efficient concurrent access without lock contention in the hot path.

Implementations

impl IHaveQueue

pub fn new(max_size: usize) -> Self

Create a new IHave queue with the specified maximum size.

pub fn with_flush_threshold(max_size: usize, flush_threshold: usize) -> Self

Create a new IHave queue with a specific flush threshold.

pub fn set_flush_threshold(&self, threshold: usize)

Set the flush threshold (batch size).

pub fn push(&self, message_id: MessageId, round: u32) -> bool

Push a new IHave announcement to the queue.

Returns true if the item was queued, false if the queue is full or not accepting new items.

pub fn should_flush(&self) -> bool

Check if the queue has reached the flush threshold.

This can be used to trigger early batch flush in high-throughput scenarios.

pub fn flush_threshold(&self) -> usize

Get the current flush threshold.

pub fn pop_batch(&self, max_batch: usize) -> SmallVec<[PendingIHave; 16]>

Pop a batch of IHave announcements from the queue.

Returns up to max_batch items.

pub fn len(&self) -> usize

Get the approximate length of the queue.

pub fn is_empty(&self) -> bool

Check if the queue is empty.

pub fn stop(&self)

Stop accepting new items.

pub fn resume(&self)

Resume accepting new items.

pub fn clear(&self)

Clear all pending items from the queue.

Trait Implementations

impl Debug for IHaveQueue

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for IHaveQueue

fn default() -> Self

Returns the “default value” for a type.