Struct ChunkQueue

pub struct ChunkQueue {
    chunks: [WriteChunk; 16],
    head: usize,
    tail: usize,
    count: usize,
    next_sequence: u32,
}

Chunk queue for buffering writes.

Used to decouple HTTP receive rate from disk write rate.

Fields

chunks: [WriteChunk; 16]

Queued chunks.

head: usize

Head index (next to dequeue).

tail: usize

Tail index (next slot to enqueue).

count: usize

Number of queued chunks.

next_sequence: u32

Next sequence number.

Implementations

impl ChunkQueue

pub const fn new() -> Self

Create empty chunk queue.

pub fn is_empty(&self) -> bool

Check if queue is empty.

pub fn is_full(&self) -> bool

Check if queue is full.

pub fn len(&self) -> usize

Get number of queued chunks.

pub fn enqueue( &mut self, buffer_phys: u64, buffer_cpu: *const u8, len: usize, ) -> Option<u32>

Enqueue a chunk.

pub fn dequeue(&mut self) -> Option<WriteChunk>

Dequeue a chunk.

pub fn peek(&self) -> Option<&WriteChunk>

Peek at front chunk without removing.

pub fn clear(&mut self)

Clear the queue.

Trait Implementations

impl Default for ChunkQueue

fn default() -> Self

Returns the “default value” for a type.