Method tick

nodedb/src/data/executor/core_loop/tick.rs:123–152

Run one iteration of the event loop: drain requests, process tasks. After processing, update the per-priority queue-depth gauges so the Prometheus endpoint reflects the post-tick state.

(&mut self)

    /// After processing, update the per-priority queue-depth gauges so the
    /// Prometheus endpoint reflects the post-tick state.
    pub fn tick(&mut self) -> usize {
        self.poll_build_completions();
        self.poll_pending_reindex();
        // Adjust SPSC read depth based on current memory pressure.
        self.apply_spsc_pressure();
        self.drain_requests();
        let mut processed = 0;
        while !self.task_queue.is_empty() {
            let batched = self.poll_write_batch();
            if batched > 0 {
                processed += batched;
                continue;
            }
            if self.poll_one() {
                processed += 1;
            } else {
                break;
            }
        }

        // Update queue-depth gauges after draining.
        self.io_metrics
            .record_queue_depth(TIER_CRITICAL, self.task_queue.critical_len() as u64);
        self.io_metrics
            .record_queue_depth(TIER_HIGH, self.task_queue.high_len() as u64);
        self.io_metrics
            .record_queue_depth(TIER_LOW, self.task_queue.low_len() as u64);

        processed
    }
}