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
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72

//! Pinned owner-CPU scheduler state.

mod clock;
mod dispatch;
mod load;
mod local;
mod remote;
mod snapshot;
mod transaction;

use alloc::{boxed::Box, sync::Arc, vec, vec::Vec};
use core::{
    marker::{PhantomData, PhantomPinned},
    ops::Deref,
    pin::Pin,
    ptr::NonNull,
    sync::atomic::{AtomicBool, AtomicU16, AtomicU64, AtomicUsize, Ordering},
};

pub(crate) use clock::{RqTaskTime, RunQueueClock, RunQueueClockSnapshot};
pub(crate) use dispatch::{
    CurrentDispatch, CurrentRemotePublication, DispatchCharge, DispatchRole,
    PreviousSwitchDisposition, PreviousSwitchOwnership, SchedulerPolicyRef, SchedulerThreadRef,
    SwitchHandoff,
};
pub use load::{CpuLoadSummary, DeadlineBandwidthSnapshot, SchedulingClass};
use load::{SUMMARY_FAIR_IDLE_ONLY, SUMMARY_FAIR_PUSHABLE};
pub use local::CpuLocal;
pub(crate) use local::{
    HardTimerServiceClaim, HardTimerServiceStep, KtimerServiceClaim,
    SchedulerDeadlineDerivationSource, SchedulerDeadlineRqObservation, SoftTimerExpireBatch,
};
use remote::RqCurrentUpdate;
pub use remote::{CpuLifecycleState, CpuLocalOwnerBorrow, CpuRemote};
pub(crate) use remote::{
    CpuRemotePublication, CpuRunQueueState, DeadlineBaseGuardSource, EqualRtWakeAction,
    IdlePullReservation, KtimerClaimClass, OwnerRqEnqueue, PreparedMigrationDelivery,
    RescheduleKind, RunQueueDomainPublication, RunQueueGuardSource, SchedulerRequestClaim,
    SchedulerRequestScope, WakePreemptionContext, WakePreemptionDecision,
};
pub use snapshot::CpuSnapshot;
pub(in crate::sched::system) use transaction::OwnerRqTaskState;
pub(crate) use transaction::{OwnerRqEntry, OwnerRqTxn, RqSwitchBaton};

use crate::{
    runtime::{
        RuntimeStatus,
        config::TaskSystemConfig,
        cpu::{RuntimeCpuId, SchedulerDeadlineUpdate, SchedulerRuntimeDeadline},
        delivery::inbox::{InboxKind, InboxMessage, InboxNode, PublishResult, SchedulerInbox},
        lock::{IrqOwner, IrqScope, IrqTicketGuard, IrqTicketLock, RawTicketBaton},
        resource::AddressSpaceMembarrierState,
        task_runtime,
    },
    sched::{
        CpuId, CpuSet, FairMode, RtPriority, SchedulePolicy,
        algorithm::{
            ActiveSchedulingState, QueuedThread, RootRtBandwidth, RqTaskMetadata,
            RtRunQueueBandwidth, RunQueue, SchedulingEntity,
        },
    },
    thread::{TaskError, ThreadCore, ThreadId, ThreadState},
    time::{
        MonotonicDeadline, MonotonicInstant,
        queue::{
            ExpiredTaskDeadline, HardKernelTimerAction, HardTaskDeadlineClaim, KernelTimerEntry,
            KernelTimerExecution, KernelTimerQueue, TaskDeadlineExpireBatch,
            TaskDeadlineExpireRequest, TaskDeadlineKind, TaskDeadlineQueue,
            TaskDeadlineRegistration,
        },
    },
};