ax-task 0.7.0

OS-independent IRQ-safe SMP task scheduling core
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

//! Stable deterministic snapshot of one owner CPU.

use super::CpuLocal;
use crate::{sched::CpuId, thread::ThreadId};

/// Stable, allocation-free scheduler state used by deterministic model tests.
#[derive(Clone, Copy, Debug, Eq, PartialEq)]
pub struct CpuSnapshot {
    owner: CpuId,
    current: Option<ThreadId>,
    runnable: usize,
    need_resched: bool,
}

impl CpuSnapshot {
    pub(crate) fn capture(cpu: &CpuLocal) -> Self {
        Self {
            owner: cpu.owner(),
            current: cpu.current(),
            runnable: cpu.runnable_count(),
            need_resched: cpu.needs_reschedule(),
        }
    }

    /// Returns the owner CPU.
    pub const fn owner(self) -> CpuId {
        self.owner
    }

    /// Returns the current thread.
    pub const fn current(self) -> Option<ThreadId> {
        self.current
    }

    /// Returns Linux `rq->nr_running`, including a runnable current thread.
    pub const fn runnable(self) -> usize {
        self.runnable
    }

    /// Returns the sticky preemption state.
    pub const fn need_resched(self) -> bool {
        self.need_resched
    }
}