Struct BufferPool 

pub struct BufferPool { /* private fields */ }

Lock-free buffer pool for reusing large I/O buffers.

Uses bounded ArrayQueues so queue slots are allocated once at startup and buffer return does not allocate linked queue blocks on the forwarding path.

Implementations

impl BufferPool

pub fn new(buffer_size: BufferSize, max_pool_size: usize) -> Self

Create a new lazy buffer pool

Arguments

• buffer_size - Size of each buffer in bytes (must be non-zero)
• max_pool_size - Maximum number of buffers to pool

Design Philosophy

Buffer pool queue capacity is allocated once at application boot. Backing buffers are allocated lazily as clients/backend work first need them, then returned to the pool for reuse. This is a critical performance optimization:

• Boot time: Queue slots only; idle RSS stays small
• Warm runtime: Zero allocations in hot path (acquire/release from pool)
• Per-connection: Buffers are borrowed and returned, never owned

IMPORTANT: Do NOT create a BufferPool per-client, per-connection, or per-request. Create ONE pool at application startup and share it across all operations via Arc or static reference.

Buffers are allocated on first use up to max_pool_size; allocations beyond that remain visible through fallback metrics.

pub fn with_capture_pool(self, capacity: usize, count: usize) -> Self

Configure the capture buffer pool for accumulator buffers

Capture buffers are used for accumulating streaming data (e.g., caching).

Arguments

• capacity - Size of each capture buffer in bytes (e.g., 1 MiB by default)
• count - Maximum number of capture buffers to pool

pub fn available_buffers(&self) -> usize

Get the current number of available buffers in the pool

pub fn buffers_in_use(&self) -> usize

Get the number of buffers currently in use

pub fn stats(&self) -> (usize, usize, usize)

Get buffer pool statistics (available, in-use, total)

pub fn acquire(&self) -> PooledBuffer

pub fn acquire_capture(&self) -> PooledBuffer

Trait Implementations

impl Clone for BufferPool

fn clone(&self) -> BufferPool

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for BufferPool

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

Formats the value using the given formatter.