Struct Magazine 

pub struct Magazine { /* private fields */ }

Pool of num_slots reusable slot buffers. Owned by the reader thread.

Implementations

impl Magazine

pub fn new(num_slots: usize, slot_size: usize, num_workers: usize) -> Self

Allocate the pool. slice_size = slot_size / num_workers (≥1), the granularity at which the reader cuts big files. All slots start FREE.

pub fn from_plan(plan: PoolPlan) -> Self

Allocate the pool from a PoolPlan — the memory-bounded entry point.

pub fn with_slice_size( num_slots: usize, slot_size: usize, slice_size: usize, ) -> Self

Allocate the pool with slice_size given explicitly rather than derived from slot_size.

This is the seam that lets the reservation shrink without moving a single output byte: slice_size is the cut length (output-affecting — it lands in chunk boundaries and checksums), slot_size × num_slots is only how much buffer is held in flight. See PoolPlan.

pub fn slot_size(&self) -> usize

pub fn slice_size(&self) -> usize

pub fn num_slots(&self) -> usize

pub fn returner(&self) -> Ejector

Handle workers use to release slots. Clone it into each worker thread.

pub fn claim(&self) -> Option<Clip<'_>>

Reader: claim a free slot to fill. Blocks until one is free — this block is the ONLY backpressure in the pipeline. Returns None once the pool is shut down and drained (all return senders gone).