Struct Scheduler

pub(crate) struct Scheduler<'a> {
    pub(crate) skel: BpfSkel<'a>,
    pub(crate) struct_ops: Option<Link>,
    pub(crate) rb_mgr: RingBuffer<'static>,
    pub(crate) intrspc: introspec,
    pub(crate) intrspc_rx: Receiver<SchedSample>,
    pub(crate) monitor_tid: Option<ThreadId>,
    pub(crate) stats_server: StatsServer<StatsReq, StatsRes>,
    pub(crate) mseq_id: u64,
}

Fields

skel: BpfSkel<'a>

struct_ops: Option<Link>

rb_mgr: RingBuffer<'static>

intrspc: introspec

intrspc_rx: Receiver<SchedSample>

monitor_tid: Option<ThreadId>

stats_server: StatsServer<StatsReq, StatsRes>

mseq_id: u64

Implementations

impl<'a> Scheduler<'a>

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

pub(crate) fn init_cpus( skel: &mut OpenBpfSkel<'_>, opts: &Opts, topo: &FlatTopology, )

pub(crate) fn is_powersave_mode(opts: &Opts) -> bool

pub(crate) fn init_globals( skel: &mut OpenBpfSkel<'_>, opts: &Opts, topo: &FlatTopology, )

pub(crate) fn get_msg_seq_id() -> u64

pub(crate) fn relay_introspec( data: &[u8], intrspc_tx: &Sender<SchedSample>, ) -> i32

pub(crate) fn prep_introspec(&mut self)

pub(crate) fn cleanup_introspec(&mut self)

pub(crate) fn get_pc(x: u64, y: u64) -> f64

pub(crate) fn get_power_mode(power_mode: i32) -> &'static str

pub(crate) fn stats_req_to_res(&mut self, req: &StatsReq) -> Result<StatsRes>

pub fn exited(&mut self) -> bool

pub(crate) fn set_power_profile(&mut self, mode: u32) -> Result<(), u32>

pub(crate) fn update_power_profile( &mut self, prev_profile: PowerProfile, ) -> (bool, PowerProfile)

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

Trait Implementations

impl Drop for Scheduler<'_>

fn drop(&mut self)

Executes the destructor for this type.