Struct SinkMonitor 

pub(crate) struct SinkMonitor {
    pub(crate) prev: Option<Vec<u64>>,
    pub(crate) published: Vec<bool>,
    pub(crate) hot_streak: Vec<u32>,
    pub(crate) quiet: Vec<u32>,
    pub(crate) stable: u32,
    pub(crate) interval: u32,
    pub(crate) ticks: u32,
}

Live IRQ-sink tracking riding the 1 s run loop (§G30, §G33, §R.25/§R.26).

Each window the handler-time deltas are split at their widest gap. A CPU above the cut for FLAG_POLLS consecutive windows is published as a sink – a real sink ranks above the cut every window, ranking noise does not – and a published sink is released after UNFLAG_POLLS windows below it, because removal merely returns placement freedom and a loading screen must not flap the mask. A set that keeps repeating earns a doubled sampling interval up to INTERVAL_MAX (longer windows accumulate more ticks, so confidence also buys resolution); any change resets to every tick. All four constants are agreement counts: every value that steers comes from the measured distribution alone (§R.26).

Fields

prev: Option<Vec<u64>>

Last accepted read; deltas span the full gap between accepted reads, so a slower cadence measures a longer, smoother window.

published: Vec<bool>

The set currently pushed to the scheduler.

hot_streak: Vec<u32>

Consecutive windows each CPU has ranked above the cut.

quiet: Vec<u32>

Consecutive windows each published sink has ranked below the cut.

stable: u32

Windows since the published set last changed.

interval: u32

Current sampling interval in run-loop ticks.

ticks: u32

Implementations

impl SinkMonitor

pub(crate) const STABLE_POLLS: u32 = 8

Unchanged windows that earn an interval doubling.

pub(crate) const INTERVAL_MAX: u32 = 16

Sampling never slows past this many ticks.

pub(crate) const FLAG_POLLS: u32 = 2

Above-cut windows before a CPU is published.

pub(crate) const UNFLAG_POLLS: u32 = 3

Below-cut windows before a published sink is removed.

pub(crate) fn new(nr_cpus: usize) -> Self

pub(crate) fn tick(&mut self, nr_cpus: usize) -> Option<Vec<bool>>

One run-loop tick; Some(set) when the published set changed.