Struct QueuedTask 

pub struct QueuedTask {
    pub pid: i32,
    pub cpu: i32,
    pub nr_cpus_allowed: u64,
    pub flags: u64,
    pub start_ts: u64,
    pub stop_ts: u64,
    pub exec_runtime: u64,
    pub weight: u64,
    pub vtime: u64,
    pub enq_cnt: u64,
    pub comm: [c_char; 16],
}

High-level Rust abstraction to interact with a generic sched-ext BPF component.

Overview

The main BPF interface is provided by the BpfScheduler() struct. When this object is initialized it will take care of registering and initializing the BPF component.

The scheduler then can use BpfScheduler() instance to receive tasks (in the form of QueuedTask objects) and dispatch tasks (in the form of DispatchedTask objects), using respectively the methods dequeue_task() and dispatch_task().

BPF counters and statistics can be accessed using the methods nr_*_mut(), in particular nr_queued_mut() and nr_scheduled_mut() can be updated to notify the BPF component if the user-space scheduler has some pending work to do or not.

Finally the methods exited() and shutdown_and_report() can be used respectively to test whether the BPF component exited, and to shutdown and report the exit message.

Fields

pid: i32

cpu: i32

nr_cpus_allowed: u64

flags: u64

start_ts: u64

stop_ts: u64

exec_runtime: u64

weight: u64

vtime: u64

enq_cnt: u64

comm: [c_char; 16]

Implementations

impl QueuedTask

pub fn comm_str(&self) -> String

Convert the task’s comm field (C char array) into a Rust String.

Trait Implementations

impl Clone for QueuedTask

fn clone(&self) -> QueuedTask

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for QueuedTask

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PartialEq for QueuedTask

fn eq(&self, other: &QueuedTask) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl PartialOrd for QueuedTask

fn partial_cmp(&self, other: &QueuedTask) -> Option<Ordering>

This method returns an ordering between self and other values if one exists.

fn lt(&self, other: &Rhs) -> bool

Tests less than (for self and other) and is used by the < operator.

fn le(&self, other: &Rhs) -> bool

Tests less than or equal to (for self and other) and is used by the <= operator.

fn gt(&self, other: &Rhs) -> bool

Tests greater than (for self and other) and is used by the > operator.

fn ge(&self, other: &Rhs) -> bool

Tests greater than or equal to (for self and other) and is used by the >= operator.

impl Eq for QueuedTask

impl StructuralPartialEq for QueuedTask