Struct Scheduler 

pub(crate) struct Scheduler<'a> {
    pub(crate) skel: BpfSkel<'a>,
    pub(crate) struct_ops: Option<Link>,
    pub(crate) stats_server: StatsServer<(), Metrics>,
    pub(crate) started_at: Instant,
    pub(crate) webui_tx: Option<Sender<WebMetrics>>,
    pub(crate) online_cpus: Vec<u32>,
    pub(crate) smt: Vec<bool>,
    pub(crate) topology: String,
}

Fields

skel: BpfSkel<'a>

struct_ops: Option<Link>

stats_server: StatsServer<(), Metrics>

started_at: Instant

webui_tx: Option<Sender<WebMetrics>>

online_cpus: Vec<u32>

smt: Vec<bool>

topology: String

Implementations

impl<'a> Scheduler<'a>

pub(crate) fn count_on_cpu(&self) -> u64

Count live pids for the on CPU gauge with no BPF counter. Walks the cached online list with one map read per CPU, so the gauge costs N reads with no atomic cost on the hot paths. The BPF on CPU field stays zero for wire compat and never drives this count.

pub(crate) fn get_metrics(&self) -> Metrics

pub(crate) fn read_stats(&self, cpu: usize) -> flow_sched_stats

Read one per CPU stats row without heap use. Failed lookups yield a zero row with no trap.

pub(crate) fn read_cpu(&self, cpu: usize) -> flow_cpu_state

Read one CPU pid view without heap use. Failed lookups yield an idle view with zero pid.

pub(crate) fn get_web_metrics(&self) -> WebMetrics

Dashboard snapshot with raw counters plus live pid cards. Counters stay raw with no deltas and the on CPU gauge counts live pids with the pid view. Costs 3N map reads for N online CPUs: N for the stats sum via get_metrics plus N for the gauge plus N for the cards, with one alloc sized to the online count. SMT comes from the cached init flags with no sysfs use on poll and stays display only. Offline stays out, so per CPU count matches the cached online count. Version plus timestamp plus topology join the counters for the page plus the log.

impl<'a> Scheduler<'a>

pub(crate) fn init( opts: &'a Opts, open_object: &'a mut MaybeUninit<OpenObject>, shutdown: Arc<AtomicBool>, ) -> Result<Self>

pub(crate) fn exited(&self) -> bool

pub(crate) fn seed_topo_with(skel: &mut BpfSkel<'_>, rows: &[(u32, u32, u32)])

pub(crate) fn run(&mut self, shutdown: Arc<AtomicBool>) -> Result<UserExitInfo>