Struct InFlightSet 

pub struct InFlightSet { /* private fields */ }

The dispatcher’s in-flight (progress) set: the dispatched-but-unfinished tasks, keyed by task id. Phase 4 of the dispatcher rationalization replaces the contended Arc<Mutex<HashMap<i64, TaskProgress>>> with a sharded, lock-free [DashMap] — so the ventilator’s lease (Self::insert), the sink’s return (Self::remove), and the reaper sweep (Self::take_expired) no longer serialise on one global lock — plus an AtomicUsize size counter so the per-request backpressure check (in_flight_saturated) reads the size in O(1) without locking or scanning the map.

The counter is maintained in lock-step with the map here (the only place either is mutated), so it converges to exactly the map size; a momentary ±1 skew between a map mutation and its atomic update is harmless for backpressure (self-correcting, never a leak). Shared as Arc<InFlightSet> across the ventilator / sink / reaper threads.

Implementations

impl InFlightSet

pub fn new() -> Self

A new, empty in-flight set.

pub fn len(&self) -> usize

Current number of in-flight tasks — an O(1) atomic load (the backpressure hot read), not a map scan.

pub fn is_empty(&self) -> bool

Whether the in-flight set is empty.

pub fn insert(&self, progress_task: TaskProgress)

Record a dispatched task as in-flight (keyed by task.id). Re-inserting the same id (a re-lease) overwrites without double-counting. Preserves the fail-fast hard-limit backstop: if the set ever exceeds PROGRESS_QUEUE_HARD_LIMIT (backpressure failed to hold the line) we panic → process abort → external restart, rather than grow unbounded.

pub fn remove(&self, taskid: i64) -> Option<TaskProgress>

Remove and return the in-flight task with taskid (the sink draining a returned result). Negative (mock-reply) ids are never tracked, so they short-circuit to None; removing an already-gone task is a no-op that never underflows the counter.

pub fn take_expired(&self) -> Vec<TaskProgress>

Remove and return every in-flight task past its visibility-timeout deadline (the reaper sweep).

pub fn ids(&self) -> Vec<i64>

Snapshot of the currently in-flight task ids — used on a ventilator restart to exclude these from the Queued → TODO crash-recovery reset (clear_limbo_tasks_except), so tasks the sink is still processing are not re-leased mid-flight (KNOWN_ISSUES D-4).

Trait Implementations

impl Default for InFlightSet

fn default() -> InFlightSet

Returns the “default value” for a type.