Method drain_requests

nodedb/src/data/executor/core_loop/tick.rs:19–30

Drain incoming requests from the SPSC bridge into the priority queues. The number of requests drained per call is bounded by `spsc_read_depth`, which is reduced under Critical memory pressure and set to zero under Emergency. Each request is routed to the Critical, High, or Low tier based on `Request.priority`.

(&mut self)

    /// Emergency. Each request is routed to the Critical, High, or Low tier
    /// based on `Request.priority`.
    pub fn drain_requests(&mut self) {
        if self.pressure_suspend_reads {
            // Emergency pressure: do not accept new requests.
            return;
        }
        let depth = self.spsc_read_depth.max(1);
        let mut batch = Vec::new();
        self.request_rx.drain_into(&mut batch, depth);
        for br in batch {
            self.task_queue.push(ExecutionTask::new(br.inner));
        }
    }

    /// Process the next pending task using the 8:4:2 priority drain ratio.
    ///