Struct PortBuffer 

pub struct PortBuffer {
    pub node_id: u64,
    pub port: u32,
    pub buffer: VecDeque<DataPacket>,
    pub max_size: usize,
}

A bounded FIFO queue of DataPackets associated with one (node, port) pair.

Fields

node_id: u64

Node ID that owns this buffer.

port: u32

Port index this buffer serves.

buffer: VecDeque<DataPacket>

Queued packets, oldest at the front.

max_size: usize

Maximum number of packets this buffer may hold.

Implementations

impl PortBuffer

pub fn new(node_id: u64, port: u32, max_size: usize) -> Self

Creates a new, empty port buffer with the given capacity.

pub fn push(&mut self, packet: DataPacket) -> bool

Enqueues packet if there is room. Returns true on success.

pub fn pop(&mut self) -> Option<DataPacket>

Removes and returns the oldest packet, or None if empty.

pub fn is_full(&self) -> bool

Returns true if the buffer has reached its maximum capacity.

pub fn len(&self) -> usize

Returns the current number of packets in the buffer.

pub fn is_empty(&self) -> bool

Returns true if the buffer contains no packets.

Trait Implementations

impl Debug for PortBuffer

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

Formats the value using the given formatter.