SuperTinyKernel™ RTOS 1.08.x
Lightweight, high-performance, deterministic, bare-metal C++ RTOS for resource-constrained embedded systems. MIT Open Source License.
Loading...
Searching...
No Matches
stk::Kernel< TMode, TSize, TStrategy, TPlatform > Class Template Referencefinal

Concrete implementation of IKernel. More...

#include <stk.h>

Inheritance diagram for stk::Kernel< TMode, TSize, TStrategy, TPlatform >:
Collaboration diagram for stk::Kernel< TMode, TSize, TStrategy, TPlatform >:

Classes

class  KernelTask
 Internal per-slot kernel descriptor that wraps a user ITask instance. More...
class  KernelService
 Concrete implementation of IKernelService exposed to running tasks. More...
class  SleepTrapStack
 Storage bundle for the sleep trap: a Stack descriptor paired with its backing memory. More...
class  ExitTrapStack
 Storage bundle for the exit trap: a Stack descriptor paired with its backing memory. More...

Public Types

enum  EKernelState : uint8_t {
  KSTATE_INACTIVE = 0 ,
  KSTATE_READY ,
  KSTATE_RUNNING ,
  KSTATE_SUSPENDED
}
 Kernel state. More...

Public Member Functions

 Kernel ()
 Construct the kernel with all storage zero-initialized, m_request cleared to REQ_NONE, and m_kstate set to KSTATE_INACTIVE (indicating uninitialized state; advanced to KSTATE_READY by Initialize()).
 ~Kernel ()=default
 Destructor.
void Initialize (uint32_t resolution_us=PERIODICITY_DEFAULT) override
 Initialize kernel.
void AddTask (ITask *user_task) override
 Register task for a soft real-time (SRT) scheduling.
void AddTask (ITask *user_task, Timeout periodicity_tc, Timeout deadline_tc, Timeout start_delay_tc) override
 Register a task for hard real-time (HRT) scheduling.
void RemoveTask (ITask *user_task) override
 Remove a previously added task from the kernel when it is not started.
void ScheduleTaskRemoval (ITask *user_task) override
 Schedule task removal from scheduling (exit).
void SuspendTask (ITask *user_task, bool &suspended) override
 Suspend task.
void ResumeTask (ITask *user_task) override
 Resume task.
size_t EnumerateKernelTasks (ArrayView< IKernelTask * > tasks) override
 Enumerate kernel tasks.
size_t EnumerateTasks (ArrayView< ITask * > user_tasks) override
 Enumerate user tasks.
void Start () override
 Start the scheduler. This call does not return until all tasks have exited (KERNEL_DYNAMIC mode) or indefinitely (KERNEL_STATIC mode).
bool IsStarted () const
 Check whether scheduler is currently running.
IPlatformGetPlatform () override
 Get platform driver instance owned by this kernel.
ITaskSwitchStrategyGetSwitchStrategy () override
 Get task-switching strategy instance owned by this kernel.
EKernelState GetState () const override
 Get kernel state.
template<size_t TMaxCount, typename TCallback>
size_t EnumerateTasksT (TCallback &&callback)
 Enumerate tasks, invoking a callback for each active task.

Static Public Attributes

static constexpr size_t TASKS_MAX = TSize
 Maximum number of concurrently registered tasks. Fixed at compile time. Exceeding this limit in AddTask() triggers a compile-time assert (TASKS_MAX > 0) and a runtime STK_ASSERT.

Protected Types

enum  ERequest : uint8_t {
  REQ_NONE = 0 ,
  REQ_ADD_TASK = (1 << 0)
}
 Bitmask flags for pending inter-task requests that must be processed by the kernel on the next tick (in UpdateTaskRequest()). More...
enum  EFsmState : int8_t {
  FSM_STATE_NONE = -1 ,
  FSM_STATE_SWITCHING ,
  FSM_STATE_SLEEPING ,
  FSM_STATE_WAKING ,
  FSM_STATE_EXITING ,
  FSM_STATE_MAX
}
 Finite-state machine (FSM) state. Encodes what the kernel is currently doing between two consecutive tick events. More...
enum  EFsmEvent : int8_t {
  FSM_EVENT_SWITCH = 0 ,
  FSM_EVENT_SLEEP ,
  FSM_EVENT_WAKE ,
  FSM_EVENT_EXIT ,
  FSM_EVENT_MAX
}
 Finite-state machine (FSM) event. Computed by FetchNextEvent() each tick based on strategy output and current kernel state. More...
typedef StackMemoryWrapper<((32U))> SleepTrapStackMemory
 Stack memory wrapper type for the sleep trap.
typedef StackMemoryWrapper< STACK_SIZE_MINExitTrapStackMemory
 Stack memory wrapper type for the exit trap.
typedef KernelTask TaskStorageType[TASKS_MAX]
 KernelTask array type used as a storage for the KernelTask instances.
typedef ISyncObject::ListHeadType SyncObjectList
 Intrusive list of active ISyncObject instances registered with this kernel. Each sync object in this list receives a Tick() call every kernel tick for timeout tracking. Allocated only when KERNEL_SYNC is set (zero-size otherwise).

Protected Member Functions

void InitTraps ()
 Initialize stack of the traps.
KernelTaskAllocateNewTask (ITask *user_task)
 Allocate new instance of KernelTask.
void AddKernelTask (KernelTask *task)
 Add kernel task to the scheduling strategy.
void AllocateAndAddNewTask (ITask *user_task)
 Allocate new instance of KernelTask and add it into the scheduling process.
void HrtAllocateAndAddNewTask (ITask *user_task, Timeout periodicity_tc, Timeout deadline_tc, Timeout start_delay_tc)
 Allocate new instance of KernelTask and add it into the HRT scheduling process.
void RequestAddTask (ITask *const user_task)
 Request to add new task.
KernelTaskFindTaskByUserTask (const ITask *user_task)
 Find kernel task by the bound ITask instance.
KernelTaskFindTaskByStack (const Stack *stack)
 Find kernel task by the bound Stack instance.
KernelTaskFindTaskBySP (Word SP)
 Find kernel task for a Stack Pointer (SP).
void RemoveTask (KernelTask *task)
 Remove kernel task.
void OnStart (Stack *&active) override
 Called by platform driver immediately after a scheduler start (first tick).
void OnStop () override
 Called by the platform driver after a scheduler stop (all tasks have exited).
bool OnTick (Stack *&idle, Stack *&active, Timeout &ticks) override
 Process one scheduler tick. Called from the platform timer/tick ISR.
bool OnForceContextSwitch (TId id, Stack *&idle, Stack *&active)
 Called when task state change forces a context switch (Sleep, SleepUntil, Wait).
void OnTaskSwitch (Word caller_SP) override
 Called by Thread process (via IKernelService::SwitchToNext) to switch to a next task.
void OnTaskSleep (Word caller_SP, Timeout ticks) override
 Called by Thread process (via IKernelService::Sleep) for exclusion of the calling process from scheduling (sleeping).
bool OnTaskSleepUntil (Word caller_SP, Ticks timestamp) override
 Called by Thread process (via IKernelService::SleepUntil) for exclusion of the calling process from scheduling (sleeping).
void OnTaskSleepCancel (TId task_id)
void OnTaskExit (Stack *stack) override
 Called from the Thread process when task finished (its Run function exited by return).
EWaitResult OnTaskWait (Word caller_SP, ISyncObject *sync_obj, IMutex *mutex, Timeout timeout) override
 Called from the Thread process when task needs to wait.
TId OnGetTid (Word caller_SP) override
 Called from the Thread process when for getting task/thread id of the process.
void OnSuspend (bool suspended) override
 Called from the Thread process to suspend scheduling.
void OnInheritWeight (TId tid, Weight weight)
void OnRestoreWeight (TId tid, ISyncObject *sobj)
Timeout UpdateTasks (const Timeout elapsed_ticks)
 Update tasks (sleep, requests).
void ProcessTaskPendingSleep (KernelTask *const task)
Timeout UpdateTaskState (const Timeout elapsed_ticks)
 Update task state: process removals, deliver sleep/wake notifications, advance sleep timers, and track HRT durations.
void UpdateSyncObjects (const Timeout elapsed_ticks)
 Update synchronization objects.
void UpdateTaskRequest ()
 Update pending task requests.
EFsmEvent FetchNextEvent (KernelTask *&next)
 Fetch next event for the FSM.
EFsmState GetNewFsmState (KernelTask *&next)
 Get new FSM state.
bool UpdateFsmState (Stack *&idle, Stack *&active)
 Update FSM state.
bool StateSwitch (KernelTask *now, KernelTask *next, Stack *&idle, Stack *&active)
 Switches contexts.
bool StateWake (KernelTask *now, KernelTask *next, Stack *&idle, Stack *&active)
 Wakes up after sleeping.
bool StateSleep (KernelTask *now, KernelTask *next, Stack *&idle, Stack *&active)
 Enters into a sleeping mode.
bool StateExit (KernelTask *now, KernelTask *next, Stack *&idle, Stack *&active)
 Exits from scheduling.
bool IsInitialized () const
 Check whether Initialize() has been called and completed successfully.
void ScheduleAddTask ()
 Signal the kernel to process a pending AddTask request on the next tick.

Static Protected Member Functions

static bool IsValidFsmState (EFsmState state)
 Check if FSM state is valid.
static constexpr bool IsStaticMode ()
static constexpr bool IsDynamicMode ()
static constexpr bool IsHrtMode ()
static constexpr bool IsSyncMode ()
static constexpr bool IsTicklessMode ()

Protected Attributes

KernelService m_service
 Kernel service singleton exposed to running tasks via IKernelService::GetInstance().
TPlatform m_platform
 Platform driver (SysTick, PendSV, context switch implementation).
TStrategy m_strategy
 Task-switching strategy (determines which task runs next).
KernelTaskm_task_now
 Currently executing task, or nullptr before Start() or after all tasks exit.
TaskStorageType m_task_storage
 Static pool of TSize KernelTask slots (free slots have m_user == nullptr).
SleepTrapStack m_sleep_trap [1]
 Sleep trap (always present): executed when all tasks are sleeping.
ExitTrapStack m_exit_trap [STK_ALLOCATE_COUNT< TMode, KERNEL_DYNAMIC, 1U, 0U >::Value]
 Exit trap: zero-size in KERNEL_STATIC mode; one entry in KERNEL_DYNAMIC mode.
EFsmState m_fsm_state
 Current FSM state. Drives context-switch decision on every tick.
volatile uint8_t m_request
 Bitmask of pending ERequest flags from running tasks. Written by tasks, read/cleared by UpdateTaskRequest() in tick context.
volatile EKernelState m_kstate
 Current kernel state.
SyncObjectList m_sync_list [STK_ALLOCATE_COUNT< TMode, KERNEL_SYNC, 1U, 0U >::Value]
 List of active sync objects. Zero-size (no memory) if KERNEL_SYNC is not set.
const EFsmState m_fsm [FSM_STATE_MAX][FSM_EVENT_MAX]

Static Protected Attributes

static constexpr Timeout YIELD_TICKS = 1
 Ticks to yield.

Detailed Description

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
class stk::Kernel< TMode, TSize, TStrategy, TPlatform >

Concrete implementation of IKernel.

All configuration is expressed as template parameters. No virtual dispatch, no heap allocation - the entire kernel, tasks, and traps live in statically reserved storage.

Template Parameters
TModeBitmask of EKernelMode flags that configures kernel features:
  • KERNEL_STATIC - fixed task list, no add/remove after Start().
  • KERNEL_DYNAMIC - tasks may be added or removed at runtime.
  • KERNEL_HRT - Hard Real-Time mode (must combine with STATIC or DYNAMIC).
  • KERNEL_SYNC - enables synchronization primitives (Mutex, Event, etc.).
  • KERNEL_TICKLESS - enables tickless low-power operation. Requires STK_TICKLESS_IDLE=1 in stk_config.h. Incompatible with KERNEL_HRT (tickless suppresses the timer, which destroys the precise periodicity HRT depends on - enforced by the compile-time assertion TICKLESS_HRT_CONFLICT). KERNEL_STATIC and KERNEL_DYNAMIC are mutually exclusive.
TSizeMaximum number of concurrent tasks. Must be > 0.
TStrategyTask-switching strategy type (e.g. SwitchStrategyRoundRobin). Must inherit ITaskSwitchStrategy.
TPlatformPlatform driver type (e.g. PlatformArmCortexM, or PlatformDefault). Must inherit IPlatform.
Note
At least 1 task is required: TSize must be > 0 (enforced by compile-time assertion).
KERNEL_HRT is incompatible with weighted scheduling strategies (WEIGHT_API == true), also enforced by a compile-time assertion.
KERNEL_TICKLESS is incompatible with KERNEL_HRT, also enforced by a compile-time assertion (TICKLESS_HRT_CONFLICT).

Usage example:

static MyTask1<256, ACCESS_PRIVILEGED> task1;
static MyTask2<512, ACCESS_USER> task2;
static MyTask3<512, ACCESS_USER> task3;
kernel.Initialize();
kernel.AddTask(&task1);
kernel.AddTask(&task2);
kernel.AddTask(&task3);
kernel.Start();
Concrete implementation of IKernel.
Definition stk.h:90
void AddTask(ITask *user_task) override
Register task for a soft real-time (SRT) scheduling.
Definition stk.h:1067
void Start() override
Start the scheduler. This call does not return until all tasks have exited (KERNEL_DYNAMIC mode) or i...
Definition stk.h:1301
void Initialize(uint32_t resolution_us=PERIODICITY_DEFAULT) override
Initialize kernel.
Definition stk.h:1030

Definition at line 85 of file stk.h.

Member Typedef Documentation

◆ ExitTrapStackMemory

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
typedef StackMemoryWrapper<STACK_SIZE_MIN> stk::Kernel< TMode, TSize, TStrategy, TPlatform >::ExitTrapStackMemory
protected

Stack memory wrapper type for the exit trap.

See also
ExitTrapStack, STACK_SIZE_MIN

Definition at line 102 of file stk.h.

◆ SleepTrapStackMemory

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
typedef StackMemoryWrapper< ( (32U) )> stk::Kernel< TMode, TSize, TStrategy, TPlatform >::SleepTrapStackMemory
protected

Stack memory wrapper type for the sleep trap.

See also
SleepTrapStack, STK_SLEEP_TRAP_STACK_SIZE

Definition at line 96 of file stk.h.

◆ SyncObjectList

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
typedef ISyncObject::ListHeadType stk::Kernel< TMode, TSize, TStrategy, TPlatform >::SyncObjectList
protected

Intrusive list of active ISyncObject instances registered with this kernel. Each sync object in this list receives a Tick() call every kernel tick for timeout tracking. Allocated only when KERNEL_SYNC is set (zero-size otherwise).

Definition at line 2570 of file stk.h.

◆ TaskStorageType

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
typedef KernelTask stk::Kernel< TMode, TSize, TStrategy, TPlatform >::TaskStorageType[TASKS_MAX]
protected

KernelTask array type used as a storage for the KernelTask instances.

Definition at line 2532 of file stk.h.

Member Enumeration Documentation

◆ EFsmEvent

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
enum stk::Kernel::EFsmEvent : int8_t
protected

Finite-state machine (FSM) event. Computed by FetchNextEvent() each tick based on strategy output and current kernel state.

Enumerator
FSM_EVENT_SWITCH 

Strategy returned a runnable task, perform a context switch.

FSM_EVENT_SLEEP 

No runnable tasks, enter sleep trap.

FSM_EVENT_WAKE 

A task became runnable while the kernel was sleeping, wake from sleep trap.

FSM_EVENT_EXIT 

No tasks remain (KERNEL_DYNAMIC), exit scheduling and return from Start().

FSM_EVENT_MAX 

Sentinel: number of valid events (used to size the FSM table).

Definition at line 1374 of file stk.h.

1375 {
1376 FSM_EVENT_SWITCH = 0,
1381 };
@ FSM_EVENT_EXIT
No tasks remain (KERNEL_DYNAMIC), exit scheduling and return from Start().
Definition stk.h:1379
@ FSM_EVENT_WAKE
A task became runnable while the kernel was sleeping, wake from sleep trap.
Definition stk.h:1378
@ FSM_EVENT_SLEEP
No runnable tasks, enter sleep trap.
Definition stk.h:1377
@ FSM_EVENT_SWITCH
Strategy returned a runnable task, perform a context switch.
Definition stk.h:1376
@ FSM_EVENT_MAX
Sentinel: number of valid events (used to size the FSM table).
Definition stk.h:1380

◆ EFsmState

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
enum stk::Kernel::EFsmState : int8_t
protected

Finite-state machine (FSM) state. Encodes what the kernel is currently doing between two consecutive tick events.

Enumerator
FSM_STATE_NONE 

Sentinel / uninitialized value. Set by the constructor, replaced by FSM_STATE_SWITCHING on the first tick.

FSM_STATE_SWITCHING 

Normal operation: switching between runnable tasks each tick.

FSM_STATE_SLEEPING 

All tasks are sleeping, the sleep trap is executing (CPU in low-power state).

FSM_STATE_WAKING 

At least one task woke up, transitioning from sleep trap back to a user task.

FSM_STATE_EXITING 

All tasks exited (KERNEL_DYNAMIC only), executing the exit trap to return from Start().

FSM_STATE_MAX 

Sentinel: number of valid states (used to size the FSM table), denotes uninitialized state.

Definition at line 1360 of file stk.h.

1361 {
1362 FSM_STATE_NONE = -1,
1368 };
@ FSM_STATE_EXITING
All tasks exited (KERNEL_DYNAMIC only), executing the exit trap to return from Start().
Definition stk.h:1366
@ FSM_STATE_SLEEPING
All tasks are sleeping, the sleep trap is executing (CPU in low-power state).
Definition stk.h:1364
@ FSM_STATE_SWITCHING
Normal operation: switching between runnable tasks each tick.
Definition stk.h:1363
@ FSM_STATE_NONE
Sentinel / uninitialized value. Set by the constructor, replaced by FSM_STATE_SWITCHING on the first ...
Definition stk.h:1362
@ FSM_STATE_MAX
Sentinel: number of valid states (used to size the FSM table), denotes uninitialized state.
Definition stk.h:1367
@ FSM_STATE_WAKING
At least one task woke up, transitioning from sleep trap back to a user task.
Definition stk.h:1365

◆ EKernelState

enum stk::IKernel::EKernelState : uint8_t
inherited

Kernel state.

Enumerator
KSTATE_INACTIVE 

Not ready, IKernel::Initialize() must be called.

KSTATE_READY 

Ready to start, IKernel::Start() must be called.

KSTATE_RUNNING 

Initialized and running, IKernel::Start() was called successfully.

KSTATE_SUSPENDED 

Scheduling is suspended with IKernelService::Suspend().

Definition at line 1413 of file stk_common.h.

1414 {
1415 KSTATE_INACTIVE = 0,
1416 KSTATE_READY,
1419 };
@ KSTATE_RUNNING
Initialized and running, IKernel::Start() was called successfully.
@ KSTATE_SUSPENDED
Scheduling is suspended with IKernelService::Suspend().
@ KSTATE_INACTIVE
Not ready, IKernel::Initialize() must be called.
@ KSTATE_READY
Ready to start, IKernel::Start() must be called.

◆ ERequest

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
enum stk::Kernel::ERequest : uint8_t
protected

Bitmask flags for pending inter-task requests that must be processed by the kernel on the next tick (in UpdateTaskRequest()).

Enumerator
REQ_NONE 

No pending requests.

REQ_ADD_TASK 

An AddTask() request is pending from a running task (KERNEL_DYNAMIC only).

Definition at line 108 of file stk.h.

109 {
110 REQ_NONE = 0,
111 REQ_ADD_TASK = (1 << 0)
112 };
@ REQ_ADD_TASK
An AddTask() request is pending from a running task (KERNEL_DYNAMIC only).
Definition stk.h:111
@ REQ_NONE
No pending requests.
Definition stk.h:110

Constructor & Destructor Documentation

◆ Kernel()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
stk::Kernel< TMode, TSize, TStrategy, TPlatform >::Kernel ( )
inlineexplicit

Construct the kernel with all storage zero-initialized, m_request cleared to REQ_NONE, and m_kstate set to KSTATE_INACTIVE (indicating uninitialized state; advanced to KSTATE_READY by Initialize()).

Note
In debug builds also verifies that TPlatform derives from IPlatform and TStrategy from ITaskSwitchStrategy.
If TMode includes KERNEL_TICKLESS, a compile-time assertion fires unless STK_TICKLESS_IDLE is defined to 1 in stk_config.h.

Definition at line 997 of file stk.h.

999 {
1000 #ifdef _DEBUG
1001 // TPlatform must inherit IPlatform
1004
1005 // TStrategy must inherit ITaskSwitchStrategy
1008 #endif
1009
1010 #if !STK_TICKLESS_IDLE
1012 "STK_TICKLESS_IDLE must be defined to 1 for KERNEL_TICKLESS");
1013 #endif
1014 }
#define STK_UNUSED(X)
Explicitly marks a variable as unused to suppress compiler warnings.
Definition stk_defs.h:715
#define STK_STATIC_ASSERT_DESC(X, DESC)
Compile-time assertion with a custom error description. Produces a compilation error if X is false.
Definition stk_defs.h:536
volatile uint8_t m_request
Bitmask of pending ERequest flags from running tasks. Written by tasks, read/cleared by UpdateTaskReq...
Definition stk.h:2580
TStrategy m_strategy
Task-switching strategy (determines which task runs next).
Definition stk.h:2574
SleepTrapStack m_sleep_trap[1]
Sleep trap (always present): executed when all tasks are sleeping.
Definition stk.h:2577
volatile EKernelState m_kstate
Current kernel state.
Definition stk.h:2581
ExitTrapStack m_exit_trap[STK_ALLOCATE_COUNT< TMode, KERNEL_DYNAMIC, 1U, 0U >::Value]
Exit trap: zero-size in KERNEL_STATIC mode; one entry in KERNEL_DYNAMIC mode.
Definition stk.h:2578
TaskStorageType m_task_storage
Static pool of TSize KernelTask slots (free slots have m_user == nullptr).
Definition stk.h:2576
KernelTask * m_task_now
Currently executing task, or nullptr before Start() or after all tasks exit.
Definition stk.h:2575
TPlatform m_platform
Platform driver (SysTick, PendSV, context switch implementation).
Definition stk.h:2573
EFsmState m_fsm_state
Current FSM state. Drives context-switch decision on every tick.
Definition stk.h:2579

◆ ~Kernel()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
stk::Kernel< TMode, TSize, TStrategy, TPlatform >::~Kernel ( )
default

Destructor.

Note
MISRA deviation: [STK-DEV-005] Rule 10-3-2.

Member Function Documentation

◆ AddKernelTask()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
void stk::Kernel< TMode, TSize, TStrategy, TPlatform >::AddKernelTask ( KernelTask * task)
inlineprotected

Add kernel task to the scheduling strategy.

Parameters
[in]taskPointer to the kernel task.

Definition at line 1474 of file stk.h.

1475 {
1476 #if STK_SEGGER_SYSVIEW
1477 // start tracing new task
1478 SEGGER_SYSVIEW_OnTaskCreate(task->GetUserStackPtr()->tid);
1479 if (IsStarted())
1480 {
1482 }
1483 #endif
1484
1485 m_strategy.AddTask(task);
1486 }
bool IsStarted() const
Check whether scheduler is currently running.
Definition stk.h:1328

Referenced by stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::AllocateAndAddNewTask(), and stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::HrtAllocateAndAddNewTask().

Here is the caller graph for this function:

◆ AddTask() [1/2]

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
void stk::Kernel< TMode, TSize, TStrategy, TPlatform >::AddTask ( ITask * user_task)
inlineoverridevirtual

Register task for a soft real-time (SRT) scheduling.

Parameters
[in]user_taskUser task to add. Must not already be registered. Must not be nullptr.
Note
Before Start(): allocates a free KernelTask slot and adds it to the strategy immediately.
After Start() (KERNEL_DYNAMIC only): serialises the request via RequestAddTask() - the calling task yields and the kernel processes the request on the next tick.
Warning
Asserts if called in KERNEL_HRT mode (use the HRT overload instead), if called after Start() without KERNEL_DYNAMIC, or if TASKS_MAX is exceeded.

Implements stk::IKernel.

Definition at line 1067 of file stk.h.

1068 {
1070 {
1071 STK_ASSERT(user_task != nullptr);
1073
1074 // when started the operation must be serialized by switching out from processing until
1075 // kernel processes this request
1076 if (IsStarted())
1077 {
1079 {
1081 }
1082 else
1083 {
1084 STK_ASSERT(false);
1085 }
1086 }
1087 else
1088 {
1090 }
1091 }
1092 else
1093 {
1094 STK_ASSERT(false);
1095 }
1096 }
#define STK_ASSERT(e)
Runtime assertion. Halts execution if the expression e evaluates to false.
Definition stk_defs.h:516
#define __stk_constexpr_cpp17
constexpr definition for C++17 and above.
Definition stk_defs.h:489
void RequestAddTask(ITask *const user_task)
Request to add new task.
Definition stk.h:1520
static constexpr bool IsHrtMode()
Definition stk.h:2502
void AllocateAndAddNewTask(ITask *user_task)
Allocate new instance of KernelTask and add it into the scheduling process.
Definition stk.h:1491
bool IsInitialized() const
Check whether Initialize() has been called and completed successfully.
Definition stk.h:2466
static constexpr bool IsDynamicMode()
Definition stk.h:2501

◆ AddTask() [2/2]

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
void stk::Kernel< TMode, TSize, TStrategy, TPlatform >::AddTask ( ITask * user_task,
Timeout periodicity_tc,
Timeout deadline_tc,
Timeout start_delay_tc )
inlineoverridevirtual

Register a task for hard real-time (HRT) scheduling.

Parameters
[in]user_taskUser task to add. Must not already be registered. Must not be nullptr.
[in]periodicity_tcActivation period in ticks. Must be > 0 and < INT32_MAX.
[in]deadline_tcMaximum allowed active duration in ticks. Must be > 0 and < INT32_MAX.
[in]start_delay_tcInitial sleep delay in ticks before the first activation. 0 means activate immediately.
Note
Must be called before Start(). Dynamic (post-Start) HRT task addition is not supported.
Warning
Asserts if called outside KERNEL_HRT mode (use the SRT overload instead) or after Start().

Implements stk::IKernel.

Definition at line 1106 of file stk.h.

1108 {
1110 {
1111 STK_ASSERT(user_task != nullptr);
1114
1116 }
1117 else
1118 {
1119 STK_ASSERT(false);
1120 }
1121 }
void HrtAllocateAndAddNewTask(ITask *user_task, Timeout periodicity_tc, Timeout deadline_tc, Timeout start_delay_tc)
Allocate new instance of KernelTask and add it into the HRT scheduling process.
Definition stk.h:1506

◆ AllocateAndAddNewTask()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
void stk::Kernel< TMode, TSize, TStrategy, TPlatform >::AllocateAndAddNewTask ( ITask * user_task)
inlineprotected

Allocate new instance of KernelTask and add it into the scheduling process.

Parameters
[in]user_taskUser task for which kernel task object is allocated.

Definition at line 1491 of file stk.h.

1492 {
1494 STK_ASSERT(task != nullptr);
1495
1497 }
KernelTask * AllocateNewTask(ITask *user_task)
Allocate new instance of KernelTask.
Definition stk.h:1434
void AddKernelTask(KernelTask *task)
Add kernel task to the scheduling strategy.
Definition stk.h:1474
Internal per-slot kernel descriptor that wraps a user ITask instance.
Definition stk.h:126

Referenced by stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::AddTask(), and stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::UpdateTaskRequest().

Here is the caller graph for this function:

◆ AllocateNewTask()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
KernelTask * stk::Kernel< TMode, TSize, TStrategy, TPlatform >::AllocateNewTask ( ITask * user_task)
inlineprotected

Allocate new instance of KernelTask.

Parameters
[in]user_taskUser task for which kernel task object is allocated.
Returns
Kernel task.

Definition at line 1434 of file stk.h.

1435 {
1436 // look for a free kernel task
1437 KernelTask *new_task = nullptr;
1438 for (size_t i = 0U; i < TASKS_MAX; ++i)
1439 {
1440 KernelTask *const task = &m_task_storage[i];
1441 if (task->IsBusy())
1442 {
1443 // avoid task collision
1444 STK_ASSERT(task->m_user != user_task);
1445
1446 // avoid stack collision
1447 STK_ASSERT(task->m_user->GetStack() != user_task->GetStack());
1448 }
1449 else
1450 if (new_task == nullptr)
1451 {
1452 new_task = task;
1453 #if defined(NDEBUG) && !defined(_STK_ASSERT_REDIRECT)
1454 break; // break if assertions are inactive and do not try to validate collision with existing tasks
1455 #endif
1456 }
1457 else
1458 {
1459 // noop, continue to the next slot
1460 }
1461 }
1462
1463 // if nullptr - exceeded max supported kernel task count, application design failure
1464 STK_ASSERT(new_task != nullptr);
1465
1466 new_task->Bind(&m_platform, user_task);
1467
1468 return new_task;
1469 }
static constexpr size_t TASKS_MAX
Maximum number of concurrently registered tasks. Fixed at compile time. Exceeding this limit in AddTa...
Definition stk.h:987

Referenced by stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::AllocateAndAddNewTask(), and stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::HrtAllocateAndAddNewTask().

Here is the caller graph for this function:

◆ EnumerateKernelTasks()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
size_t stk::Kernel< TMode, TSize, TStrategy, TPlatform >::EnumerateKernelTasks ( ArrayView< IKernelTask * > tasks)
inlineoverridevirtual

Enumerate kernel tasks.

Parameters
[in]tasksReference to the ArrayView of IKernelTask pointers.
Returns
Number of tasks in the array.

Implements stk::IKernel.

Definition at line 1249 of file stk.h.

1250 {
1251 size_t count = 0U;
1252 const size_t limit = Min(tasks.GetSize(), TASKS_MAX);
1253
1254 // avoid race with OnTick
1256
1257 for (size_t i = 0U; i < limit; ++i)
1258 {
1259 KernelTask *const task = &m_task_storage[i];
1260 if (task->IsBusy())
1261 {
1262 tasks[count++] = task;
1263 }
1264 }
1265
1266 return count;
1267 }
static constexpr T Min(T a, T b) noexcept
Compile-time minimum of two values.
Definition stk_defs.h:753

◆ EnumerateTasks()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
size_t stk::Kernel< TMode, TSize, TStrategy, TPlatform >::EnumerateTasks ( ArrayView< ITask * > user_tasks)
inlineoverridevirtual

Enumerate user tasks.

Parameters
[in]user_tasksReference to the ArrayView of ITask pointers.
Returns
Number of tasks in the array.

Implements stk::IKernel.

Definition at line 1273 of file stk.h.

1274 {
1275 size_t count = 0U;
1276 const size_t limit = Min(user_tasks.GetSize(), TASKS_MAX);
1277
1278 // avoid race with OnTick
1280
1281 for (size_t i = 0U; i < limit; ++i)
1282 {
1283 KernelTask *const task = &m_task_storage[i];
1284 if (task->IsBusy())
1285 {
1286 user_tasks[count++] = task->GetUserTask();
1287 }
1288 }
1289
1290 return count;
1291 }

◆ EnumerateTasksT()

template<size_t TMaxCount, typename TCallback>
size_t stk::IKernel::EnumerateTasksT ( TCallback && callback)
inlineinherited

Enumerate tasks, invoking a callback for each active task.

Template Parameters
TMaxCountMaximum number of tasks to enumerate. Should match or exceed the kernel's task capacity. Determines the size of the internal stack-allocated buffer (TMaxCount * sizeof(ITask*) bytes on the stack).
TCallbackCallable type, deduced automatically. Must satisfy: bool(ITask*)
Parameters
[in]callbackCallable invoked for each active task. Return true to continue, false to stop early.
Returns
Number of tasks visited (up to TMaxCount).
Warning
ISR-safe.

Example:

kernel.EnumerateTasks<_STK_KERNEL_TASKS_COUNT>([](ITask *t) {
Log(t->GetTraceName());
return true; // continue
});
Interface for a user task.
Definition stk_common.h:755

Definition at line 1518 of file stk_common.h.

1519 {
1520 STK_STATIC_ASSERT(TMaxCount > 0U);
1521
1522 ITask *tasks[TMaxCount] = {};
1523 size_t count = EnumerateTasks(ArrayView<ITask *>(tasks, TMaxCount));
1524 size_t i = 0U;
1525 bool fetch_next = true;
1526
1527 while ((i < count) && fetch_next)
1528 {
1529 fetch_next = callback(tasks[i]);
1530 ++i;
1531 }
1532
1533 return i;
1534 }
#define STK_STATIC_ASSERT(X)
Compile-time assertion. Produces a compilation error if X is false.
Definition stk_defs.h:553
virtual size_t EnumerateTasks(ArrayView< ITask * > user_tasks)=0
Enumerate user tasks.

References EnumerateTasks(), and STK_STATIC_ASSERT.

Here is the call graph for this function:

◆ FetchNextEvent()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
EFsmEvent stk::Kernel< TMode, TSize, TStrategy, TPlatform >::FetchNextEvent ( KernelTask *& next)
inlineprotected

Fetch next event for the FSM.

Parameters
[out]nextNext kernel task to which Kernel can switch.
Returns
FSM event.

Definition at line 2232 of file stk.h.

2233 {
2235
2236 // try getting next task for scheduling
2238
2239 // sleep-aware strategy returns nullptr if no active tasks available
2240 if (next != nullptr)
2241 {
2242 // strategy must provide active-only task
2243 STK_ASSERT(!next->IsSleeping());
2244
2245 // if was sleeping, process wake event first
2247 }
2248 // start sleeping
2249 else
2250 {
2252 {
2253 // if nullptr is returned then either strategy has all tasks sleeping or none left,
2254 // if KERNEL_DYNAMIC mode and no tasks left then exit from scheduling
2255 if (m_strategy.GetSize() == 0U)
2256 {
2257 next = nullptr;
2259 }
2260 }
2261 }
2262
2263 return type;
2264 }
EFsmEvent
Finite-state machine (FSM) event. Computed by FetchNextEvent() each tick based on strategy output and...
Definition stk.h:1375
static __stk_forceinline TTargetType * ListEntryToParent(TSourceType *const lentry)
Safely casts an intrusive list entry to its concrete parent container object type.

Referenced by stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::GetNewFsmState().

Here is the caller graph for this function:

◆ FindTaskBySP()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
KernelTask * stk::Kernel< TMode, TSize, TStrategy, TPlatform >::FindTaskBySP ( Word SP)
inlineprotected

Find kernel task for a Stack Pointer (SP).

Parameters
[in]SPStack pointer.
Returns
Kernel task.

Definition at line 1586 of file stk.h.

1587 {
1588 STK_ASSERT(m_task_now != nullptr);
1589
1590 KernelTask *found_task = nullptr;
1591
1592 if (m_task_now->IsMemoryOfSP(SP))
1593 {
1595 }
1596 else
1597 {
1598 for (size_t i = 0U; i < TASKS_MAX; ++i)
1599 {
1600 KernelTask *const task = &m_task_storage[i];
1601
1602 // skip finished tasks (applicable only for KERNEL_DYNAMIC mode)
1604 {
1605 if (!task->IsBusy())
1606 {
1607 continue;
1608 }
1609 }
1610
1611 if (task->IsMemoryOfSP(SP))
1612 {
1613 found_task = task;
1614 break;
1615 }
1616 }
1617 }
1618
1619 return found_task;
1620 }

Referenced by stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::OnGetTid(), stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::OnTaskSleep(), stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::OnTaskSleepUntil(), stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::OnTaskWait(), and stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::RequestAddTask().

Here is the caller graph for this function:

◆ FindTaskByStack()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
KernelTask * stk::Kernel< TMode, TSize, TStrategy, TPlatform >::FindTaskByStack ( const Stack * stack)
inlineprotected

Find kernel task by the bound Stack instance.

Parameters
[in]stackStack.
Returns
Kernel task.

Definition at line 1565 of file stk.h.

1566 {
1567 KernelTask *found_task = nullptr;
1568
1569 for (size_t i = 0U; i < TASKS_MAX; ++i)
1570 {
1571 KernelTask *const task = &m_task_storage[i];
1572 if (task->GetUserStackPtr() == stack)
1573 {
1574 found_task = task;
1575 break;
1576 }
1577 }
1578
1579 return found_task;
1580 }

Referenced by stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::OnTaskExit().

Here is the caller graph for this function:

◆ FindTaskByUserTask()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
KernelTask * stk::Kernel< TMode, TSize, TStrategy, TPlatform >::FindTaskByUserTask ( const ITask * user_task)
inlineprotected

Find kernel task by the bound ITask instance.

Parameters
[in]user_taskUser task.
Returns
Kernel task.

Definition at line 1544 of file stk.h.

1545 {
1546 KernelTask *found_task = nullptr;
1547
1548 for (size_t i = 0U; i < TASKS_MAX; ++i)
1549 {
1550 KernelTask *const task = &m_task_storage[i];
1551 if (task->GetUserTask() == user_task)
1552 {
1553 found_task = task;
1554 break;
1555 }
1556 }
1557
1558 return found_task;
1559 }

Referenced by stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::OnInheritWeight(), stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::OnRestoreWeight(), stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::OnTaskSleepCancel(), stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::RemoveTask(), stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::ResumeTask(), stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::ScheduleTaskRemoval(), and stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::SuspendTask().

Here is the caller graph for this function:

◆ GetNewFsmState()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
EFsmState stk::Kernel< TMode, TSize, TStrategy, TPlatform >::GetNewFsmState ( KernelTask *& next)
inlineprotected

Get new FSM state.

Parameters
[out]nextNext kernel task to which Kernel can switch.
Returns
FSM state.

Definition at line 2273 of file stk.h.

2274 {
2277 }
static bool IsValidFsmState(EFsmState state)
Check if FSM state is valid.
Definition stk.h:1393
const EFsmState m_fsm[FSM_STATE_MAX][FSM_EVENT_MAX]
Definition stk.h:2584
EFsmEvent FetchNextEvent(KernelTask *&next)
Fetch next event for the FSM.
Definition stk.h:2232

Referenced by stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::OnStart(), and stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::UpdateFsmState().

Here is the caller graph for this function:

◆ GetPlatform()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
IPlatform * stk::Kernel< TMode, TSize, TStrategy, TPlatform >::GetPlatform ( )
inlineoverridevirtual

Get platform driver instance owned by this kernel.

Returns
Pointer to the internal TPlatform cast to IPlatform*.

Implements stk::IKernel.

Definition at line 1336 of file stk.h.

1336{ return &m_platform; }

◆ GetState()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
EKernelState stk::Kernel< TMode, TSize, TStrategy, TPlatform >::GetState ( ) const
inlineoverridevirtual

Get kernel state.

Implements stk::IKernel.

Definition at line 1345 of file stk.h.

1345{ return m_kstate; }

◆ GetSwitchStrategy()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
ITaskSwitchStrategy * stk::Kernel< TMode, TSize, TStrategy, TPlatform >::GetSwitchStrategy ( )
inlineoverridevirtual

Get task-switching strategy instance owned by this kernel.

Returns
Pointer to the internal TStrategy cast to ITaskSwitchStrategy*.

Implements stk::IKernel.

Definition at line 1341 of file stk.h.

1341{ return &m_strategy; }

◆ HrtAllocateAndAddNewTask()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
void stk::Kernel< TMode, TSize, TStrategy, TPlatform >::HrtAllocateAndAddNewTask ( ITask * user_task,
Timeout periodicity_tc,
Timeout deadline_tc,
Timeout start_delay_tc )
inlineprotected

Allocate new instance of KernelTask and add it into the HRT scheduling process.

Note
Related to stk::KERNEL_HRT mode only.
Parameters
[in]user_taskUser task for which kernel task object is allocated.
[in]periodicity_tcPeriodicity time at which task is scheduled (ticks).
[in]deadline_tcDeadline time within which a task must complete its work (ticks).
[in]start_delay_tcInitial start delay for the task (ticks).

Definition at line 1506 of file stk.h.

1507 {
1509 STK_ASSERT(task != nullptr);
1510
1512
1514 }

Referenced by stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::AddTask().

Here is the caller graph for this function:

◆ Initialize()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
void stk::Kernel< TMode, TSize, TStrategy, TPlatform >::Initialize ( uint32_t resolution_us = PERIODICITY_DEFAULT)
inlineoverridevirtual

Initialize kernel.

Parameters
[in]resolution_usResolution of the system tick (SysTick) timer in microseconds. Defaults to PERIODICITY_DEFAULT (1000 µs = 1 ms).
Note
Must be called before AddTask() and Start().
If running on an STM32 device with HAL driver or on QEMU, do not change the default resolution (PERIODICITY_DEFAULT). STM32's HAL expects 1 millisecond resolution and QEMU does not have enough resolution on Windows to operate correctly at sub-millisecond resolution.
Kernel must be in KSTATE_INACTIVE state.

Implements stk::IKernel.

Definition at line 1030 of file stk.h.

1031 {
1035
1036 // reinitialize key state variables
1037 m_task_now = nullptr;
1040
1041 // exit trap is required only for KERNEL_DYNAMIC mode
1044 {
1045 exit_trap = &m_exit_trap[0].stack;
1046 }
1047 else
1048 {
1049 exit_trap = nullptr;
1050 }
1051
1052 m_service.Initialize(this);
1053 m_platform.Initialize(this, &m_service, resolution_us, exit_trap);
1054
1055 // now ready to Start()
1057 }
KernelService m_service
Kernel service singleton exposed to running tasks via IKernelService::GetInstance().
Definition stk.h:2572

◆ InitTraps()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
void stk::Kernel< TMode, TSize, TStrategy, TPlatform >::InitTraps ( )
inlineprotected

Initialize stack of the traps.

Definition at line 1400 of file stk.h.

1401 {
1402 // init stack for a Sleep trap
1403 {
1405
1407 sleep.stack.access_mode = ACCESS_PRIVILEGED;
1408 #if STK_STACK_NEEDS_TASK_ID
1409 sleep.stack.tid = SYS_TASK_ID_SLEEP;
1410 #endif
1411
1412 STK_UNUSED(m_platform.InitStack(STACK_SLEEP_TRAP, &sleep.stack, &wrapper, nullptr));
1413 }
1414
1415 // init stack for an Exit trap
1417 {
1419
1421 exit.stack.access_mode = ACCESS_PRIVILEGED;
1422 #if STK_STACK_NEEDS_TASK_ID
1423 exit.stack.tid = SYS_TASK_ID_EXIT;
1424 #endif
1425
1426 STK_UNUSED(m_platform.InitStack(STACK_EXIT_TRAP, &exit.stack, &wrapper, nullptr));
1427 }
1428 }
StackMemoryWrapper< STACK_SIZE_MIN > ExitTrapStackMemory
Stack memory wrapper type for the exit trap.
Definition stk.h:102
StackMemoryWrapper<((32U))> SleepTrapStackMemory
Stack memory wrapper type for the sleep trap.
Definition stk.h:96
Storage bundle for the sleep trap: a Stack descriptor paired with its backing memory.
Definition stk.h:2542
Storage bundle for the exit trap: a Stack descriptor paired with its backing memory.
Definition stk.h:2558

Referenced by stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::Start().

Here is the caller graph for this function:

◆ IsDynamicMode()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
constexpr bool stk::Kernel< TMode, TSize, TStrategy, TPlatform >::IsDynamicMode ( )
inlinestaticconstexprprotected

Definition at line 2501 of file stk.h.

2501{ return ((TMode & KERNEL_DYNAMIC) != 0U); }

Referenced by stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::AddTask(), stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::FetchNextEvent(), stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::FindTaskBySP(), stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::Initialize(), stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::InitTraps(), stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::OnStop(), stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::OnTaskExit(), stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::RemoveTask(), stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::ScheduleTaskRemoval(), stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::StateExit(), stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::UpdateTaskRequest(), and stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::UpdateTaskState().

Here is the caller graph for this function:

◆ IsHrtMode()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
constexpr bool stk::Kernel< TMode, TSize, TStrategy, TPlatform >::IsHrtMode ( )
inlinestaticconstexprprotected

Definition at line 2502 of file stk.h.

2502{ return ((TMode & KERNEL_HRT) != 0U); }

Referenced by stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::AddTask(), stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::AddTask(), stk::Kernel< TMode, TSize, TStrategy, TPlatform >::KernelTask::GetHrtDeadline(), stk::Kernel< TMode, TSize, TStrategy, TPlatform >::KernelTask::GetHrtPeriodicity(), stk::Kernel< TMode, TSize, TStrategy, TPlatform >::KernelTask::GetHrtRelativeDeadline(), stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::OnStart(), stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::OnTaskSleep(), stk::Kernel< TMode, TSize, TStrategy, TPlatform >::KernelTask::ScheduleRemoval(), stk::Kernel< TMode, TSize, TStrategy, TPlatform >::KernelService::Sleep(), stk::Kernel< TMode, TSize, TStrategy, TPlatform >::KernelService::SleepCancel(), stk::Kernel< TMode, TSize, TStrategy, TPlatform >::KernelService::SleepUntil(), stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::StateSleep(), stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::StateSwitch(), stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::StateWake(), stk::Kernel< TMode, TSize, TStrategy, TPlatform >::KernelTask::Unbind(), stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::UpdateTaskRequest(), and stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::UpdateTaskState().

Here is the caller graph for this function:

◆ IsInitialized()

◆ IsStarted()

◆ IsStaticMode()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
constexpr bool stk::Kernel< TMode, TSize, TStrategy, TPlatform >::IsStaticMode ( )
inlinestaticconstexprprotected

Definition at line 2500 of file stk.h.

2500{ return ((TMode & KERNEL_STATIC) != 0U); }

◆ IsSyncMode()

◆ IsTicklessMode()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
constexpr bool stk::Kernel< TMode, TSize, TStrategy, TPlatform >::IsTicklessMode ( )
inlinestaticconstexprprotected

◆ IsValidFsmState()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
bool stk::Kernel< TMode, TSize, TStrategy, TPlatform >::IsValidFsmState ( EFsmState state)
inlinestaticprotected

Check if FSM state is valid.

Definition at line 1393 of file stk.h.

1394 {
1395 return ((state > FSM_STATE_NONE) && (state < FSM_STATE_MAX));
1396 }

Referenced by stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::GetNewFsmState().

Here is the caller graph for this function:

◆ OnForceContextSwitch()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
bool stk::Kernel< TMode, TSize, TStrategy, TPlatform >::OnForceContextSwitch ( TId id,
Stack *& idle,
Stack *& active )
inlineprotectedvirtual

Called when task state change forces a context switch (Sleep, SleepUntil, Wait).

Parameters
[in]idTask id causing this forced context switch.
[out]idleStack of the task which must enter Idle state.
[out]activeStack of the task which must enter Active state (to which context will switch).
Returns
True if context switch is required, False otherwise.

Implements stk::IPlatform::IEventHandler.

Definition at line 1770 of file stk.h.

1771 {
1772 bool switch_context = false;
1773 KernelTask *const task = m_task_now;
1774
1775 // note: called from inside ISR, therefore protection by critical section is not needed
1776
1777 // current task is busy-waiting to be de-scheduled
1778 if ((task->GetTid() == id) && task->IsSleeping())
1779 {
1780 if ((task->m_state & KernelTask::STATE_SLEEP_PENDING) != 0U)
1781 {
1783
1785 }
1786 }
1787
1788 return switch_context;
1789 }
bool UpdateFsmState(Stack *&idle, Stack *&active)
Update FSM state.
Definition stk.h:2284
void ProcessTaskPendingSleep(KernelTask *const task)
Definition stk.h:2034
@ STATE_SLEEP_PENDING
Task called Sleep/SleepUntil/Yield; strategy's OnTaskSleep() will be invoked on the next tick (sleep-...
Definition stk.h:137

◆ OnGetTid()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
TId stk::Kernel< TMode, TSize, TStrategy, TPlatform >::OnGetTid ( Word caller_SP)
inlineoverrideprotectedvirtual

Called from the Thread process when for getting task/thread id of the process.

Parameters
[in]caller_SPValue of Stack Pointer (SP) register (for locating the calling process inside the kernel).
Returns
Task/thread id of the process (returns always valid TId belonging to a task).

Implements stk::IPlatform::IEventHandler.

Definition at line 1947 of file stk.h.

1948 {
1950 STK_ASSERT(task != nullptr);
1951
1952 return task->GetTid();
1953 }
KernelTask * FindTaskBySP(Word SP)
Find kernel task for a Stack Pointer (SP).
Definition stk.h:1586

◆ OnInheritWeight()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
void stk::Kernel< TMode, TSize, TStrategy, TPlatform >::OnInheritWeight ( TId tid,
Weight weight )
inlineprotected

Definition at line 1980 of file stk.h.

1981 {
1984
1985 if (weight != NO_WEIGHT)
1986 {
1988 STK_ASSERT(task != nullptr);
1989
1990 const Weight prev_weight = task->GetWeight();
1991
1992 if (prev_weight < weight)
1993 {
1994 task->SetCurrentWeight(weight);
1995 m_strategy.OnTaskWeightChange(task, prev_weight);
1996 }
1997 }
1998 }
static constexpr ITask * GetUserTaskFromTid(TId task_id) noexcept
Get task instance from its identifier.
Definition stk_arch.h:725
KernelTask * FindTaskByUserTask(const ITask *user_task)
Find kernel task by the bound ITask instance.
Definition stk.h:1544

◆ OnRestoreWeight()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
void stk::Kernel< TMode, TSize, TStrategy, TPlatform >::OnRestoreWeight ( TId tid,
ISyncObject * sobj )
inlineprotected

Definition at line 2000 of file stk.h.

2001 {
2004
2006 STK_ASSERT(task != nullptr);
2007
2008 const Weight prev_weight = task->GetWeight();
2009
2010 // restore to original or boost from wait objects
2011 task->SetCurrentWeight(sobj != nullptr ? sobj->FindWeightHigherThan(task->GetWeight()) : NO_WEIGHT);
2012
2013 m_strategy.OnTaskWeightChange(task, prev_weight);
2014 }

◆ OnStart()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
void stk::Kernel< TMode, TSize, TStrategy, TPlatform >::OnStart ( Stack *& active)
inlineoverrideprotectedvirtual

Called by platform driver immediately after a scheduler start (first tick).

Parameters
[out]activeSet to the stack of the first task to run, or to the sleep-trap stack if all tasks are initially sleeping.
Note
Delivers initial OnTaskSleep notifications to sleep-aware strategies for any tasks that were added in a sleeping state before Start() was called.
Selects the first runnable task via GetNewFsmState() and transitions the kernel to KSTATE_RUNNING.
If STK_SEGGER_SYSVIEW is enabled, emits a task-start trace event for the first task.
Warning
At least one task must have been added via AddTask(); asserts if the strategy pool is empty.

Implements stk::IPlatform::IEventHandler.

Definition at line 1651 of file stk.h.

1652 {
1653 STK_ASSERT(m_strategy.GetSize() != 0);
1654
1655 // iterate tasks and generate OnTaskSleep for a strategy for all initially sleeping tasks
1656 for (size_t i = 0U; i < TASKS_MAX; ++i)
1657 {
1658 KernelTask *const task = &m_task_storage[i];
1659
1660 if ((task->m_state & KernelTask::STATE_SLEEP_PENDING) != 0U)
1661 {
1662 STK_ASSERT(task->IsSleeping());
1663
1665
1666 // notify strategy that task is sleeping
1668 {
1669 m_strategy.OnTaskSleep(task);
1670 }
1671 }
1672 }
1673
1674 // get initial state and first task
1675 {
1677
1678 KernelTask *next = nullptr;
1680
1681 // expecting only SLEEPING or SWITCHING states
1683
1685 {
1686 m_task_now = next;
1687 active = next->GetUserStackPtr();
1688
1690 {
1691 next->HrtOnSwitchedIn();
1692 }
1693 }
1694 else
1696 {
1698 active = &m_sleep_trap[0].stack;
1699 }
1700 else
1701 {
1702 // unexpected state
1704 }
1705 }
1706
1707 // is in running state
1709 }
static void STK_KERNEL_PANIC(stk::EKernelPanicId id)
Called when the kernel detects an unrecoverable internal fault.
Definition stk_arch.h:183
EFsmState GetNewFsmState(KernelTask *&next)
Get new FSM state.
Definition stk.h:2273

◆ OnStop()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
void stk::Kernel< TMode, TSize, TStrategy, TPlatform >::OnStop ( )
inlineoverrideprotectedvirtual

Called by the platform driver after a scheduler stop (all tasks have exited).

Note
KERNEL_DYNAMIC mode only: resets FSM to FSM_STATE_NONE and transitions kernel back to KSTATE_READY so Start() may be called again.
Has no effect in KERNEL_STATIC mode (static kernels never stop).

Implements stk::IPlatform::IEventHandler.

Definition at line 1716 of file stk.h.

1717 {
1719 {
1721
1722 // is in stopped state, i.e. is ready to Start() again
1724 }
1725 }

◆ OnSuspend()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
void stk::Kernel< TMode, TSize, TStrategy, TPlatform >::OnSuspend ( bool suspended)
inlineoverrideprotectedvirtual

Called from the Thread process to suspend scheduling.

Parameters
[in]suspendedtrue if scheduling was successfully suspended, false otherwise.

Implements stk::IPlatform::IEventHandler.

Definition at line 1955 of file stk.h.

1956 {
1957 // toggle kernel state
1958 if (suspended)
1959 {
1960 if (m_kstate == KSTATE_RUNNING)
1961 {
1963 }
1964 }
1965 else
1966 {
1967 if (m_kstate == KSTATE_SUSPENDED)
1968 {
1970 }
1971 }
1972
1973 // force yield for a currently active task
1974 if (!m_task_now->IsSleeping())
1975 {
1976 m_task_now->ScheduleSleep(YIELD_TICKS);
1977 }
1978 }
static constexpr Timeout YIELD_TICKS
Ticks to yield.
Definition stk.h:1389

◆ OnTaskExit()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
void stk::Kernel< TMode, TSize, TStrategy, TPlatform >::OnTaskExit ( Stack * stack)
inlineoverrideprotectedvirtual

Called from the Thread process when task finished (its Run function exited by return).

Parameters
[out]stackStack of the exited task.

Implements stk::IPlatform::IEventHandler.

Definition at line 1878 of file stk.h.

1879 {
1881 {
1883 STK_ASSERT(task != nullptr);
1884
1885 // task is being stopped and will terminate
1886 #if STK_SEGGER_SYSVIEW
1888 #endif
1889
1890 // notify kernel to execute removal
1891 task->ScheduleRemoval();
1892 }
1893 else
1894 {
1895 // kernel operating mode must be KERNEL_DYNAMIC for tasks to be able to exit
1897 }
1898 }
KernelTask * FindTaskByStack(const Stack *stack)
Find kernel task by the bound Stack instance.
Definition stk.h:1565

◆ OnTaskSleep()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
void stk::Kernel< TMode, TSize, TStrategy, TPlatform >::OnTaskSleep ( Word caller_SP,
Timeout ticks )
inlineoverrideprotectedvirtual

Called by Thread process (via IKernelService::Sleep) for exclusion of the calling process from scheduling (sleeping).

Parameters
[in]caller_SPValue of Stack Pointer (SP) register (for locating the calling process inside the kernel).
[in]ticksTime to sleep (ticks).

Implements stk::IPlatform::IEventHandler.

Definition at line 1796 of file stk.h.

1797 {
1799 STK_ASSERT(task != nullptr);
1800
1801 // make change to HRT state and sleep time atomic
1802 {
1804
1806 {
1807 task->HrtOnWorkCompleted();
1808 }
1809
1810 if (ticks > 0)
1811 {
1812 task->ScheduleSleep(ticks);
1813
1814 // trace blocked on Sleep
1815 #if STK_SEGGER_SYSVIEW
1816 SEGGER_SYSVIEW_OnTaskStopReady(task->GetUserStackPtr()->tid, TRACE_EVENT_SLEEP);
1817 #endif
1818 }
1819 }
1820
1821 // note: we do not spin long here, kernel will switch this task out from scheduling on the next tick
1822 task->BusyWaitWhileSleeping(this);
1823 }

Referenced by stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::OnTaskSwitch().

Here is the caller graph for this function:

◆ OnTaskSleepCancel()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
void stk::Kernel< TMode, TSize, TStrategy, TPlatform >::OnTaskSleepCancel ( TId task_id)
inlineprotected

Definition at line 1864 of file stk.h.

1865 {
1867 if (task != nullptr)
1868 {
1870
1871 if (task->IsSleeping())
1872 {
1873 task->Wake();
1874 }
1875 }
1876 }

◆ OnTaskSleepUntil()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
bool stk::Kernel< TMode, TSize, TStrategy, TPlatform >::OnTaskSleepUntil ( Word caller_SP,
Ticks timestamp )
inlineoverrideprotectedvirtual

Called by Thread process (via IKernelService::SleepUntil) for exclusion of the calling process from scheduling (sleeping).

Parameters
[in]caller_SPValue of Stack Pointer (SP) register (for locating the calling process inside the kernel).
[in]timestampAbsolute timestamp (ticks).
Returns
True if sleep succeeded, false otherwise.

Implements stk::IPlatform::IEventHandler.

Definition at line 1825 of file stk.h.

1826 {
1828 STK_ASSERT(task != nullptr);
1829
1830 bool result = true;
1831
1832 // make change to HRT state and sleep time atomic
1833 {
1835
1836 // calculate signed delta (handles wrap-around correctly)
1837 const Ticks delta = timestamp - m_service.m_ticks;
1838
1839 if (delta > 0)
1840 {
1842 task->ScheduleSleep(static_cast<Timeout>(Min(delta, infinite_ticks)));
1843
1844 // trace blocked on on SleepUntil
1845 #if STK_SEGGER_SYSVIEW
1846 SEGGER_SYSVIEW_OnTaskStopReady(task->GetUserStackPtr()->tid, TRACE_EVENT_SLEEP);
1847 #endif
1848 }
1849 else
1850 {
1851 result = false; // deadline already hit or passed
1852 }
1853 }
1854
1855 // note: we do not spin long here, kernel will switch this task out from scheduling on the next tick
1856 if (result)
1857 {
1858 task->BusyWaitWhileSleeping(this);
1859 }
1860
1861 return result;
1862 }

◆ OnTaskSwitch()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
void stk::Kernel< TMode, TSize, TStrategy, TPlatform >::OnTaskSwitch ( Word caller_SP)
inlineoverrideprotectedvirtual

Called by Thread process (via IKernelService::SwitchToNext) to switch to a next task.

Parameters
[in]caller_SPValue of Stack Pointer (SP) register (for locating the calling process inside the kernel).

Implements stk::IPlatform::IEventHandler.

Definition at line 1791 of file stk.h.

1792 {
1794 }
void OnTaskSleep(Word caller_SP, Timeout ticks) override
Called by Thread process (via IKernelService::Sleep) for exclusion of the calling process from schedu...
Definition stk.h:1796

◆ OnTaskWait()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
EWaitResult stk::Kernel< TMode, TSize, TStrategy, TPlatform >::OnTaskWait ( Word caller_SP,
ISyncObject * sync_obj,
IMutex * mutex,
Timeout timeout )
inlineoverrideprotectedvirtual

Called from the Thread process when task needs to wait.

Parameters
[in]caller_SPValue of Stack Pointer (SP) register (for locating the calling process inside the kernel).
[in]sync_objISyncObject instance (passed by Wait).
[in]mutexIMutex instance (passed by Wait).
[in]timeoutTime to sleep (ticks).

Implements stk::IPlatform::IEventHandler.

Definition at line 1900 of file stk.h.

1901 {
1903 {
1904 STK_ASSERT(timeout != 0); // API contract: caller must not be in ISR
1905 STK_ASSERT(sync_obj != nullptr); // API contract: ISyncObject instance must be provided
1906 STK_ASSERT(mutex != nullptr); // API contract: IMutex instance must be provided
1907 STK_ASSERT((sync_obj->GetHead() == nullptr) || (sync_obj->GetHead() == &m_sync_list[0]));
1908
1910 STK_ASSERT(task != nullptr);
1911
1912 // configure waiting
1913 task->m_wait_obj->SetupWait(sync_obj, timeout);
1914
1915 // register ISyncObject if not yet
1916 if (sync_obj->GetHead() == nullptr)
1917 {
1918 m_sync_list->LinkBack(sync_obj);
1919 }
1920
1921 // start sleeping infinitely, we rely on a Wake call via WaitObject
1922 task->ScheduleSleep(WAIT_INFINITE);
1923
1924 // trace blocked on sync object's Wait
1925 #if STK_SEGGER_SYSVIEW
1926 SEGGER_SYSVIEW_OnTaskStopReady(task->GetUserStackPtr()->tid, TRACE_EVENT_WAIT);
1927 #endif
1928
1929 // unlock mutex locked externally, so that we could wait in a busy-waiting loop
1930 mutex->Unlock();
1931
1932 // note: we do not spin long here, kernel will switch this task out from scheduling on the next tick
1933 task->BusyWaitWhileSleeping(this);
1934
1935 // re-lock mutex when returning to the task's execution space
1936 mutex->Lock();
1937
1938 return (task->m_wait_obj->IsTimeout() ? WAIT_RESULT_TIMEOUT : WAIT_RESULT_SIGNAL);
1939 }
1940 else
1941 {
1942 STK_ASSERT(false);
1943 return WAIT_RESULT_FAIL;
1944 }
1945 }
SyncObjectList m_sync_list[STK_ALLOCATE_COUNT< TMode, KERNEL_SYNC, 1U, 0U >::Value]
List of active sync objects. Zero-size (no memory) if KERNEL_SYNC is not set.
Definition stk.h:2582
static constexpr bool IsSyncMode()
Definition stk.h:2503

◆ OnTick()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
bool stk::Kernel< TMode, TSize, TStrategy, TPlatform >::OnTick ( Stack *& idle,
Stack *& active,
Timeout & ticks )
inlineoverrideprotectedvirtual

Process one scheduler tick. Called from the platform timer/tick ISR.

Parameters
[out]idleStack descriptor to context-switch out (nullptr if no switch needed).
[out]activeStack descriptor to context-switch in (nullptr if no switch needed).
[in,out]ticks(KERNEL_TICKLESS builds only) On entry: actual number of ticks elapsed since the last call, as measured by the platform driver. On return: the number of ticks the hardware timer may suppress before the next required wakeup, computed as the minimum remaining sleep across all active tasks, clamped to [1, STK_TICKLESS_TICKS_MAX]. The platform driver programs this value into the timer to avoid unnecessary wakeups. This parameter is absent in non-tickless builds.
Returns
true if a context switch is required (idle and active are valid); false if the current task continues running.
Note
In non-tickless mode the internal tick counter always advances by exactly 1 per call.
In tickless mode (KERNEL_TICKLESS) the counter advances by the ticks value supplied by the platform driver, which may be greater than 1 after a suppressed interval.

Implements stk::IPlatform::IEventHandler.

Definition at line 1743 of file stk.h.

1748 {
1749 #if !STK_TICKLESS_IDLE
1750 // in non-tickless mode kernel is advancing strictly by 1 tick on every OnTick call
1751 enum { ticks = 1 };
1752 #endif
1753
1754 // advance internal timestamp
1755 m_service.IncrementTicks(ticks);
1756
1757 // consume elapsed and update to ticks to sleep
1758 #if STK_TICKLESS_IDLE
1759 ticks = (
1760 #else
1761 // notify compiler that we ignore a return value of UpdateTasks
1762 STK_UNUSED(
1763 #endif
1765
1766 // decide on a context switch
1767 return UpdateFsmState(idle, active);
1768 }
Timeout UpdateTasks(const Timeout elapsed_ticks)
Update tasks (sleep, requests).
Definition stk.h:2018

◆ ProcessTaskPendingSleep()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
void stk::Kernel< TMode, TSize, TStrategy, TPlatform >::ProcessTaskPendingSleep ( KernelTask *const task)
inlineprotected

◆ RemoveTask() [1/2]

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
void stk::Kernel< TMode, TSize, TStrategy, TPlatform >::RemoveTask ( ITask * user_task)
inlineoverridevirtual

Remove a previously added task from the kernel when it is not started.

Parameters
[in]user_taskUser task to remove. Must not be nullptr.
Note
Only valid before Start() (i.e. while the kernel is not running). To remove tasks after Start() the task should return from its Run function (in KERNEL_DYNAMIC mode the slot is freed automatically on the next tick).
Warning
KERNEL_DYNAMIC mode only. Asserts if called in KERNEL_STATIC or KERNEL_HRT mode, or if called after Start().

Implements stk::IKernel.

Definition at line 1131 of file stk.h.

1132 {
1134 {
1135 STK_ASSERT(user_task != nullptr);
1137
1139 if (task != nullptr)
1140 {
1142 }
1143 }
1144 else
1145 {
1146 // kernel operating mode must be KERNEL_DYNAMIC for tasks to be able to be removed
1147 STK_ASSERT(false);
1148 }
1149 }
void RemoveTask(ITask *user_task) override
Remove a previously added task from the kernel when it is not started.
Definition stk.h:1131

Referenced by stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::RemoveTask(), and stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::UpdateTaskState().

Here is the caller graph for this function:

◆ RemoveTask() [2/2]

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
void stk::Kernel< TMode, TSize, TStrategy, TPlatform >::RemoveTask ( KernelTask * task)
inlineprotected

Remove kernel task.

Note
Removal of the kernel task means releasing it from the user task details.
Parameters
[in]taskKernel task.

Definition at line 1626 of file stk.h.

1627 {
1628 STK_ASSERT(task != nullptr);
1629
1630 #if STK_SEGGER_SYSVIEW
1631 SEGGER_SYSVIEW_OnTaskTerminate(task->GetUserStackPtr()->tid);
1632 #endif
1633
1634 // notify task about pending exit
1635 task->GetUserTask()->OnExit();
1636
1637 m_strategy.RemoveTask(task);
1638 task->Unbind();
1639 }

◆ RequestAddTask()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
void stk::Kernel< TMode, TSize, TStrategy, TPlatform >::RequestAddTask ( ITask *const user_task)
inlineprotected

Request to add new task.

Note
Must be called by the task process only!
Parameters
[in]user_taskUser task to add.

Definition at line 1520 of file stk.h.

1521 {
1522 KernelTask *const caller = FindTaskBySP(m_platform.GetCallerSP());
1523 STK_ASSERT(caller != nullptr);
1524
1525 typename KernelTask::AddTaskRequest req = { .user_task = user_task };
1526 caller->m_srt[0].add_task_req = &req;
1527
1528 // notify kernel
1530
1531 // switch out and wait for completion (due to context switch request could be processed here)
1532 if (caller->m_srt[0].add_task_req != nullptr)
1533 {
1534 m_service.SwitchToNext();
1535 }
1536
1537 STK_ASSERT(caller->m_srt[0].add_task_req == nullptr);
1538 }
void ScheduleAddTask()
Signal the kernel to process a pending AddTask request on the next tick.
Definition stk.h:2472
Payload for an in-flight AddTask() request issued by a running task.
Definition stk.h:150

Referenced by stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::AddTask().

Here is the caller graph for this function:

◆ ResumeTask()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
void stk::Kernel< TMode, TSize, TStrategy, TPlatform >::ResumeTask ( ITask * user_task)
inlineoverridevirtual

Resume task.

Parameters
[in]user_taskPointer to the user task to resume.

Implements stk::IKernel.

Definition at line 1229 of file stk.h.

1230 {
1231 STK_ASSERT(user_task != nullptr);
1232
1233 // avoid race with OnTick
1235
1237 STK_ASSERT(task != nullptr);
1238
1239 if (task->IsSleeping())
1240 {
1241 task->Wake();
1242 }
1243 }

◆ ScheduleAddTask()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
void stk::Kernel< TMode, TSize, TStrategy, TPlatform >::ScheduleAddTask ( )
inlineprotected

Signal the kernel to process a pending AddTask request on the next tick.

Note
Sets the REQ_ADD_TASK bit in m_request under a hw::CriticalSection::ScopedLock, so the ISR-side tick handler observes the flag safely without a data race.

Definition at line 2472 of file stk.h.

2473 {
2476 }

Referenced by stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::RequestAddTask().

Here is the caller graph for this function:

◆ ScheduleTaskRemoval()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
void stk::Kernel< TMode, TSize, TStrategy, TPlatform >::ScheduleTaskRemoval ( ITask * user_task)
inlineoverridevirtual

Schedule task removal from scheduling (exit).

Parameters
[in]user_taskUser task to remove. Must not be nullptr.
Warning
KERNEL_DYNAMIC mode only. Asserts if called in KERNEL_STATIC or KERNEL_HRT mode, or if called after Start().

Implements stk::IKernel.

Definition at line 1156 of file stk.h.

1157 {
1159 {
1160 STK_ASSERT(user_task != nullptr);
1162
1164
1166 if (task != nullptr)
1167 {
1168 task->ScheduleRemoval();
1169 }
1170 }
1171 else
1172 {
1173 // kernel operating mode must be KERNEL_DYNAMIC for tasks to be able to be removed
1174 STK_ASSERT(false);
1175 }
1176 }

◆ Start()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
void stk::Kernel< TMode, TSize, TStrategy, TPlatform >::Start ( )
inlineoverridevirtual

Start the scheduler. This call does not return until all tasks have exited (KERNEL_DYNAMIC mode) or indefinitely (KERNEL_STATIC mode).

Note
Re-initializes trap stacks on every call so Start() can be called again after a previous scheduling session ended.
If STK_SEGGER_SYSVIEW is enabled, starts tracing and registers all pre-added tasks.
Warning
At least one task must have been added via AddTask() before calling Start(). Asserts if called before Initialize().

Implements stk::IKernel.

Definition at line 1301 of file stk.h.

1302 {
1304
1305 // stacks of the traps must be re-initilized on every subsequent Start
1306 InitTraps();
1307
1308 // start tracing
1309 #if STK_SEGGER_SYSVIEW
1311 for (size_t i = 0U; i < TASKS_MAX; ++i)
1312 {
1314 if (task->IsBusy())
1315 {
1317 }
1318 }
1319 #endif
1320
1321 m_platform.Start();
1322 }
void InitTraps()
Initialize stack of the traps.
Definition stk.h:1400

◆ StateExit()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
bool stk::Kernel< TMode, TSize, TStrategy, TPlatform >::StateExit ( KernelTask * now,
KernelTask * next,
Stack *& idle,
Stack *& active )
inlineprotected

Exits from scheduling.

Note
FSM state: stk::FSM_STATE_EXITING.
Exits only if stk::KERNEL_DYNAMIC mode is specified, otherwise ignored.
Parameters
[in]nowCurrently active kernel task (ignored).
[in]nextNext kernel task (ignored).
[out]idleStack of the task which must enter Idle state.
[out]activeStack of the task which must enter Active state (to which context will switch).

Definition at line 2437 of file stk.h.

2438 {
2439 STK_UNUSED(now);
2441
2443 {
2444 // dynamic tasks are not supported if main processes's stack memory is not provided in Start()
2445 STK_ASSERT(m_exit_trap[0].stack.SP != 0);
2446
2447 idle = nullptr;
2448 active = &m_exit_trap[0].stack;
2449
2450 m_task_now = nullptr;
2451
2452 m_platform.Stop();
2453 }
2454 else
2455 {
2458 }
2459
2460 return false;
2461 }

Referenced by stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::UpdateFsmState().

Here is the caller graph for this function:

◆ StateSleep()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
bool stk::Kernel< TMode, TSize, TStrategy, TPlatform >::StateSleep ( KernelTask * now,
KernelTask * next,
Stack *& idle,
Stack *& active )
inlineprotected

Enters into a sleeping mode.

Note
FSM state: stk::FSM_STATE_SLEEPING.
Parameters
[in]nowCurrently active kernel task.
[in]nextNext kernel task (ignored).
[out]idleStack of the task which must enter Idle state.
[out]activeStack of the task which must enter Active state (to which context will switch).

Definition at line 2406 of file stk.h.

2407 {
2409
2410 STK_ASSERT(now != nullptr);
2411 STK_ASSERT(m_sleep_trap[0].stack.SP != 0);
2412
2413 idle = now->GetUserStackPtr();
2414 active = &m_sleep_trap[0].stack;
2415
2417
2419 {
2420 if (!now->IsPendingRemoval())
2421 {
2422 now->HrtOnSwitchedOut();
2423 }
2424 }
2425
2426 return true; // switch context
2427 }

Referenced by stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::UpdateFsmState().

Here is the caller graph for this function:

◆ StateSwitch()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
bool stk::Kernel< TMode, TSize, TStrategy, TPlatform >::StateSwitch ( KernelTask * now,
KernelTask * next,
Stack *& idle,
Stack *& active )
inlineprotected

Switches contexts.

Note
FSM state: stk::FSM_STATE_SWITCHING.
Parameters
[in]nowCurrently active kernel task.
[in]nextNext kernel task.
[out]idleStack of the task which must enter Idle state.
[out]activeStack of the task which must enter Active state (to which context will switch).

Definition at line 2327 of file stk.h.

2328 {
2329 STK_ASSERT(now != nullptr);
2330 STK_ASSERT(next != nullptr);
2331
2332 bool switch_context = false;
2333
2334 // if equal: do not switch context because task did not change
2335 if (next != now)
2336 {
2337 idle = now->GetUserStackPtr();
2338 active = next->GetUserStackPtr();
2339
2340 // if stack memory is exceeded these assertions will be hit
2341 #if STK_STACK_GUARD
2342 if (now->IsBusy())
2343 {
2344 // current task could exit, thus we check it with IsBusy to avoid referencing nullptr returned by GetUserTask()
2345 STK_ASSERT(now->GetUserTask()->GetStack()[0] == STK_STACK_MEMORY_FILLER);
2346 }
2347 STK_ASSERT(next->GetUserTask()->GetStack()[0] == STK_STACK_MEMORY_FILLER);
2348 #endif
2349
2350 m_task_now = next;
2351
2353 {
2354 if (now->m_hrt[0].done)
2355 {
2356 now->HrtOnSwitchedOut();
2357 next->HrtOnSwitchedIn();
2358 }
2359 }
2360
2361 switch_context = true;
2362 }
2363
2364 return switch_context;
2365 }

Referenced by stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::UpdateFsmState().

Here is the caller graph for this function:

◆ StateWake()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
bool stk::Kernel< TMode, TSize, TStrategy, TPlatform >::StateWake ( KernelTask * now,
KernelTask * next,
Stack *& idle,
Stack *& active )
inlineprotected

Wakes up after sleeping.

Note
FSM state: stk::FSM_STATE_WAKING.
Parameters
[in]nowCurrently active kernel task (ignored).
[in]nextNext kernel task.
[out]idleStack of the task which must enter Idle state.
[out]activeStack of the task which must enter Active state (to which context will switch).

Definition at line 2374 of file stk.h.

2375 {
2376 STK_UNUSED(now);
2377
2378 STK_ASSERT(next != nullptr);
2379
2380 idle = &m_sleep_trap[0].stack;
2381 active = next->GetUserStackPtr();
2382
2383 // if stack memory is exceeded these assertions will be hit
2385 #if STK_STACK_GUARD
2386 STK_ASSERT(next->GetUserTask()->GetStack()[0] == STK_STACK_MEMORY_FILLER);
2387 #endif
2388
2389 m_task_now = next;
2390
2392 {
2393 next->HrtOnSwitchedIn();
2394 }
2395
2396 return true; // switch context
2397 }

Referenced by stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::UpdateFsmState().

Here is the caller graph for this function:

◆ SuspendTask()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
void stk::Kernel< TMode, TSize, TStrategy, TPlatform >::SuspendTask ( ITask * user_task,
bool & suspended )
inlineoverridevirtual

Suspend task.

Parameters
[in]user_taskPointer to the user task to suspend.
[out]suspendedSet to true if task is suspended.
Note
hw::CriticalSection must not be active otherwise a deadlock will happen if task is suspending self.

Implements stk::IKernel.

Definition at line 1184 of file stk.h.

1185 {
1186 STK_ASSERT(user_task != nullptr);
1187
1188 bool self = false;
1189
1190 // avoid race with OnTick
1191 {
1193
1195 STK_ASSERT(task != nullptr);
1196
1197 // only suspend if the task is currently awake: if it is already sleeping
1198 // (e.g. blocked on a mutex or timed Sleep), do not overwrite m_time_sleep,
1199 // that would corrupt the original sleep state and, for sync-object waits,
1200 // would interfere with WaitObject::Tick()
1201 suspended = !task->IsSleeping();
1202 if (suspended == true)
1203 {
1204 task->ScheduleSleep(WAIT_INFINITE);
1205
1206 // check if suspending self
1207 self = (task == m_task_now);
1208
1209 // trace blocked via Suspend
1210 if (self)
1211 {
1212 #if STK_SEGGER_SYSVIEW
1214 #endif
1215 }
1216 }
1217 }
1218
1219 // note: we do not spin long here, kernel will switch this task out from scheduling on the next tick
1220 if (self)
1221 {
1222 m_task_now->BusyWaitWhileSleeping(this);
1223 }
1224 }

◆ UpdateFsmState()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
bool stk::Kernel< TMode, TSize, TStrategy, TPlatform >::UpdateFsmState ( Stack *& idle,
Stack *& active )
inlineprotected

Update FSM state.

Parameters
[out]idleStack of the task which must enter Idle state.
[out]activeStack of the task which must enter Active state (to which context will switch).
Returns
FSM state.

Definition at line 2284 of file stk.h.

2285 {
2286 KernelTask *const now = m_task_now, *next = nullptr;
2287 bool switch_context = false;
2288
2290
2291 switch (new_state)
2292 {
2296 break;
2297 case FSM_STATE_SLEEPING:
2300 break;
2301 case FSM_STATE_WAKING:
2304 break;
2305 case FSM_STATE_EXITING:
2308 break;
2309 case FSM_STATE_NONE:
2310 break; // valid intermittent non-persisting state: no-transition
2311 case FSM_STATE_MAX:
2312 default: // invalid state value
2314 break;
2315 }
2316
2317 return switch_context;
2318 }
EFsmState
Finite-state machine (FSM) state. Encodes what the kernel is currently doing between two consecutive ...
Definition stk.h:1361
bool StateWake(KernelTask *now, KernelTask *next, Stack *&idle, Stack *&active)
Wakes up after sleeping.
Definition stk.h:2374
bool StateExit(KernelTask *now, KernelTask *next, Stack *&idle, Stack *&active)
Exits from scheduling.
Definition stk.h:2437
bool StateSwitch(KernelTask *now, KernelTask *next, Stack *&idle, Stack *&active)
Switches contexts.
Definition stk.h:2327
bool StateSleep(KernelTask *now, KernelTask *next, Stack *&idle, Stack *&active)
Enters into a sleeping mode.
Definition stk.h:2406

Referenced by stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::OnForceContextSwitch(), and stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::OnTick().

Here is the caller graph for this function:

◆ UpdateSyncObjects()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
void stk::Kernel< TMode, TSize, TStrategy, TPlatform >::UpdateSyncObjects ( const Timeout elapsed_ticks)
inlineprotected

Update synchronization objects.

Definition at line 2181 of file stk.h.

2182 {
2184
2185 while (itr != nullptr)
2186 {
2187 ISyncObject::ListEntryType *const next = itr->GetNext();
2188
2190 {
2191 m_sync_list->Unlink(itr);
2192 }
2193
2194 itr = next;
2195 }
2196 }

Referenced by stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::UpdateTasks().

Here is the caller graph for this function:

◆ UpdateTaskRequest()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
void stk::Kernel< TMode, TSize, TStrategy, TPlatform >::UpdateTaskRequest ( )
inlineprotected

Update pending task requests.

Definition at line 2200 of file stk.h.

2201 {
2202 // process AddTask requests coming from tasks (KERNEL_DYNAMIC mode only, KERNEL_HRT is
2203 // excluded as we assume that HRT tasks must be known to the kernel before a Start())
2205 {
2206 // process serialized AddTask request made from another active task, requesting process
2207 // is currently waiting due to SwitchToNext()
2208 if ((m_request & REQ_ADD_TASK) != 0U)
2209 {
2211
2212 for (size_t i = 0U; i < TASKS_MAX; ++i)
2213 {
2214 KernelTask *const task = &m_task_storage[i];
2215
2216 if (task->m_srt[0].add_task_req != nullptr)
2217 {
2218 AllocateAndAddNewTask(task->m_srt[0].add_task_req->user_task);
2219
2220 task->m_srt[0].add_task_req = nullptr;
2222 }
2223 }
2224 }
2225 }
2226 }

Referenced by stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::UpdateTasks().

Here is the caller graph for this function:

◆ UpdateTasks()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
Timeout stk::Kernel< TMode, TSize, TStrategy, TPlatform >::UpdateTasks ( const Timeout elapsed_ticks)
inlineprotected

Update tasks (sleep, requests).

Definition at line 2018 of file stk.h.

2019 {
2020 // sync objects are updated before UpdateTaskRequest which may add a new object (newly added object must become 1 tick older)
2022 {
2024 }
2025
2026 if (m_request != REQ_NONE)
2027 {
2029 }
2030
2032 }
void UpdateTaskRequest()
Update pending task requests.
Definition stk.h:2200
Timeout UpdateTaskState(const Timeout elapsed_ticks)
Update task state: process removals, deliver sleep/wake notifications, advance sleep timers,...
Definition stk.h:2076
void UpdateSyncObjects(const Timeout elapsed_ticks)
Update synchronization objects.
Definition stk.h:2181

Referenced by stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::OnTick().

Here is the caller graph for this function:

◆ UpdateTaskState()

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
Timeout stk::Kernel< TMode, TSize, TStrategy, TPlatform >::UpdateTaskState ( const Timeout elapsed_ticks)
inlineprotected

Update task state: process removals, deliver sleep/wake notifications, advance sleep timers, and track HRT durations.

Parameters
[in]elapsed_ticksNumber of ticks elapsed since the previous call. Always 1 in non-tickless mode, may be >1 in tickless mode.
Returns
In non-tickless mode: always 1. In tickless mode (KERNEL_TICKLESS): the minimum remaining sleep ticks across all active tasks, clamped to [1, STK_TICKLESS_TICKS_MAX]. The platform driver uses this value to program the next timer wakeup interval, suppressing timer/tick ISR for that many ticks when the system would otherwise be idle.
Note
Sleep entry/exit protocol: ScheduleSleep() sets STATE_SLEEP_PENDING and stores m_time_sleep = -ticks. This function's first pass over a newly-sleeping task (the "entry tick") consumes STATE_SLEEP_PENDING and delivers OnTaskSleep() to the strategy, but does NOT also advance m_time_sleep on that same pass - doing both in one call would let a 1-tick sleep collapse to zero elapsed time (OnTaskSleep and OnTaskWake firing back-to-back before the task was ever excluded from scheduling). The entry tick is therefore required to be a single, uncoalesced tick (asserted below); this holds because a task can only enter STATE_SLEEP_PENDING by putting itself to sleep, which means it was actively running (not idle) up to that point, so tickless coalescing, which only suppresses ticks while the CPU is idle, cannot have applied yet. If Wake()/SleepCancel() races in before the entry tick runs, STATE_WAKE_PENDING is set alongside STATE_SLEEP_PENDING. The entry tick then delivers OnTaskSleep() followed immediately by the normal advance (and OnTaskWake(), since m_time_sleep was already primed to -1 by Wake()) in the same pass, so the task still resumes on the next tick as promised, with the two notifications correctly paired instead of an orphaned OnTaskWake(). Tasks sleeping via WAIT_INFINITE (IsSleepInfinite()) are excluded from the per-tick advance entirely so they never spuriously time out; only an explicit Wake() (which directly sets m_time_sleep = -1) ends an infinite sleep.

Definition at line 2076 of file stk.h.

2077 {
2079
2080 for (size_t i = 0U; i < TASKS_MAX; ++i)
2081 {
2082 KernelTask *const task = &m_task_storage[i];
2083
2084 if (task->IsSleeping())
2085 {
2087 {
2088 // task is pending removal, wait until it is switched out
2089 if (task->IsPendingRemoval())
2090 {
2091 const size_t tasks_left = m_strategy.GetSize();
2092
2093 if ((task != m_task_now) ||
2094 ((tasks_left == 1U) && (m_fsm_state == FSM_STATE_SLEEPING)))
2095 {
2097 continue;
2098 }
2099 }
2100 }
2101
2102 bool just_entered_sleep = false;
2103
2104 // note: only currently scheduled task can be pending to sleep
2105 if ((task->m_state & KernelTask::STATE_SLEEP_PENDING) != 0U)
2106 {
2107 STK_ASSERT(elapsed_ticks == 1); // entry tick must be a single, uncoalesced tick
2108
2109 // if Wake() raced in before this entry tick ran, STATE_WAKE_PENDING is set:
2110 // deliver OnTaskSleep() below as usual, then fall through to the advance block
2111 // in this same pass instead of waiting an extra tick, so the paired OnTaskWake()
2112 // still fires on schedule.
2113 const bool wake_pending = ((task->m_state & KernelTask::STATE_WAKE_PENDING) != 0U);
2114
2116
2118 }
2119
2120 if (!just_entered_sleep && !task->IsSleepInfinite())
2121 {
2122 // advance sleep time by number of elapsed ticks (always 1 if non-Tickless)
2123 task->m_time_sleep += elapsed_ticks;
2124
2125 // deliver sleep event to the strategy
2127 {
2128 // notify strategy that the task woke up
2129 if (!task->IsSleeping())
2130 {
2131 m_strategy.OnTaskWake(task);
2132 }
2133 }
2134 }
2135 }
2136 else
2137 {
2139 {
2140 // in HRT mode we trace how long task spent in active state (doing some work)
2141 if (task->IsBusy())
2142 {
2143 task->m_hrt[0].duration += elapsed_ticks;
2144
2145 // check if deadline is missed (HRT failure)
2146 if (task->HrtIsDeadlineMissed(task->m_hrt[0].duration))
2147 {
2148 // report deadline overrun to the strategy which supports overrun recovery
2150 {
2151 if (!m_strategy.OnTaskDeadlineMissed(task))
2152 {
2153 // report failure if it could not be recovered by the scheduling strategy
2154 task->HrtHardFailDeadline(&m_platform);
2155 }
2156 }
2157 else
2158 {
2159 task->HrtHardFailDeadline(&m_platform);
2160 }
2161 }
2162 }
2163 }
2164 }
2165
2166 // get the number of ticks the driver has to keep CPU in Idle
2168 {
2169 if ((sleep_ticks > 1) && task->IsBusy())
2170 {
2171 sleep_ticks = task->GetSleepTicks(sleep_ticks);
2172 }
2173 }
2174 }
2175
2176 return sleep_ticks;
2177 }
Timeout GetInitialSleepTicks()
static constexpr bool IsTicklessMode()
Definition stk.h:2504

Referenced by stk::Kernel< stk::KERNEL_DYNAMIC|stk::KERNEL_SYNC|stk::KERNEL_TICKLESS,(16U), stk::SwitchStrategyFP32, stk::PlatformDefault >::UpdateTasks().

Here is the caller graph for this function:

Member Data Documentation

◆ m_exit_trap

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
ExitTrapStack stk::Kernel< TMode, TSize, TStrategy, TPlatform >::m_exit_trap[STK_ALLOCATE_COUNT< TMode, KERNEL_DYNAMIC, 1U, 0U >::Value]
protected

Exit trap: zero-size in KERNEL_STATIC mode; one entry in KERNEL_DYNAMIC mode.

Definition at line 2578 of file stk.h.

◆ m_fsm

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
const EFsmState stk::Kernel< TMode, TSize, TStrategy, TPlatform >::m_fsm[FSM_STATE_MAX][FSM_EVENT_MAX]
protected
Initial value:

Compile-time FSM transition table. Indexed as m_fsm[current_state][event] -> next_state. FSM_STATE_NONE as a next-state means "no transition": the FSM stays in the current state. Updated by UpdateFsmState() each tick via GetNewFsmState() -> FetchNextEvent().

Definition at line 2584 of file stk.h.

2584 {
2585 // FSM_EVENT_SWITCH FSM_EVENT_SLEEP FSM_EVENT_WAKE FSM_EVENT_EXIT
2590 };

◆ m_fsm_state

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
EFsmState stk::Kernel< TMode, TSize, TStrategy, TPlatform >::m_fsm_state
protected

Current FSM state. Drives context-switch decision on every tick.

Definition at line 2579 of file stk.h.

◆ m_kstate

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
volatile EKernelState stk::Kernel< TMode, TSize, TStrategy, TPlatform >::m_kstate
protected

Current kernel state.

Definition at line 2581 of file stk.h.

◆ m_platform

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
TPlatform stk::Kernel< TMode, TSize, TStrategy, TPlatform >::m_platform
protected

Platform driver (SysTick, PendSV, context switch implementation).

Definition at line 2573 of file stk.h.

Referenced by stk::Kernel< TMode, TSize, TStrategy, TPlatform >::KernelTask::BusyWaitWhileSleeping().

◆ m_request

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
volatile uint8_t stk::Kernel< TMode, TSize, TStrategy, TPlatform >::m_request
protected

Bitmask of pending ERequest flags from running tasks. Written by tasks, read/cleared by UpdateTaskRequest() in tick context.

Definition at line 2580 of file stk.h.

◆ m_service

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
KernelService stk::Kernel< TMode, TSize, TStrategy, TPlatform >::m_service
protected

Kernel service singleton exposed to running tasks via IKernelService::GetInstance().

Definition at line 2572 of file stk.h.

◆ m_sleep_trap

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
SleepTrapStack stk::Kernel< TMode, TSize, TStrategy, TPlatform >::m_sleep_trap[1]
protected

Sleep trap (always present): executed when all tasks are sleeping.

Definition at line 2577 of file stk.h.

◆ m_strategy

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
TStrategy stk::Kernel< TMode, TSize, TStrategy, TPlatform >::m_strategy
protected

Task-switching strategy (determines which task runs next).

Definition at line 2574 of file stk.h.

◆ m_sync_list

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
SyncObjectList stk::Kernel< TMode, TSize, TStrategy, TPlatform >::m_sync_list[STK_ALLOCATE_COUNT< TMode, KERNEL_SYNC, 1U, 0U >::Value]
protected

List of active sync objects. Zero-size (no memory) if KERNEL_SYNC is not set.

Definition at line 2582 of file stk.h.

◆ m_task_now

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
KernelTask* stk::Kernel< TMode, TSize, TStrategy, TPlatform >::m_task_now
protected

Currently executing task, or nullptr before Start() or after all tasks exit.

Definition at line 2575 of file stk.h.

◆ m_task_storage

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
TaskStorageType stk::Kernel< TMode, TSize, TStrategy, TPlatform >::m_task_storage
protected

Static pool of TSize KernelTask slots (free slots have m_user == nullptr).

Definition at line 2576 of file stk.h.

◆ TASKS_MAX

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
size_t stk::Kernel< TMode, TSize, TStrategy, TPlatform >::TASKS_MAX = TSize
staticconstexpr

Maximum number of concurrently registered tasks. Fixed at compile time. Exceeding this limit in AddTask() triggers a compile-time assert (TASKS_MAX > 0) and a runtime STK_ASSERT.

Definition at line 987 of file stk.h.

◆ YIELD_TICKS

template<uint8_t TMode, uint32_t TSize, class TStrategy, class TPlatform>
Timeout stk::Kernel< TMode, TSize, TStrategy, TPlatform >::YIELD_TICKS = 1
staticconstexprprotected

Ticks to yield.

Yield with 2 ticks: 1 will be incremented on the next OnTick call by UpdateTasks and remaining 1 will cause a context switch by UpdateFsmState when strategy detects it as a sleeping test.

Definition at line 1389 of file stk.h.


The documentation for this class was generated from the following file: