Skip to main content

DONE_QUEUE_CAPACITY

Constant DONE_QUEUE_CAPACITY 

Source
pub const DONE_QUEUE_CAPACITY: usize = 10_000;
Expand description

Capacity of the bounded done (results-pending-persist) channel between the producers (sink + ventilator reaper) and the finalize thread. A full channel blocks the producer — that is the backpressure (a slow DB makes the sink wait, which backs up the ZMQ PULL, which backs up the workers), replacing the old DONE_QUEUE_HARD_LIMIT panic-then-OOM backstop with a graceful, loss-free hand-off (a bounded channel blocks rather than drops). Phase 1 of the dispatcher rationalization (docs/archive/DISPATCHER_RATIONALIZATION.md).