Scheduler

include/sch/sched.h

struct idle_thread_data

Member Type	Member Name
enum idle_thread_state	state
atomic_bool	woken_from_timer
uint64_t	last_entry_ms
uint64_t	last_exit_ms

struct scheduler

Member Type	Member Name
atomic_bool	tick_enabled
time_t	tick_duration_ms
struct list_head	urgent_threads
struct rbt	thread_rbt
struct rbt	completed_rbt
struct list_head	rt_threads
struct list_head	bg_threads
uint8_t	queue_bitmap
struct thread	*current
size_t	thread_count[THREAD_PRIO_CLASS_COUNT]
size_t	total_thread_count
size_t	total_weight
bool	period_enabled
uint64_t	current_period
time_t	period_ms
time_t	period_start_ms
uint64_t	core_id
atomic_bool	being_robbed
atomic_bool	stealing_work
struct spinlock	lock
struct thread	*idle_thread
struct idle_thread_data	idle_thread_data

struct scheduler_data

Member Type	Member Name
uint32_t	max_concurrent_stealers
uint32_t	active_stealers
uint32_t	total_threads
int64_t	steal_min_diff

enum idle_thread_state

Name	Value
IDLE_THREAD_WORK_STEAL	0
IDLE_THREAD_SLEEP	1

• void scheduler_init()
• void scheduler_add_thread(struct scheduler *sched,struct thread *thread,bool lock_held)
• void scheduler_remove_thread(struct scheduler *sched,struct thread *t,bool lock_held)
• void schedule(void)
• void k_sch_main(void *)
• void scheduler_idle_main(void *)
• void scheduler_scheduler_preemption_enable()
• void scheduler_scheduler_preemption_disable()
• void scheduler_yield()
• void scheduler_enqueue(struct thread *t)
• void scheduler_enqueue_on_core(struct thread *t,uint64_t core_id)
• bool scheduler_wake(struct thread *t,enum thread_wake_reason reason,enum thread_prio_class prio,void *wake_src)
• void scheduler_period_start(struct scheduler *s,uint64_t now_ms)
• void switch_context(struct cpu_context *old,struct cpu_context *new)
• void load_context(struct cpu_context *new)
• void save_context(struct cpu_context *new)
• bool scheduler_can_steal_work(struct scheduler *sched)
• bool scheduler_can_steal_thread(size_t core,struct thread *target)
• uint64_t scheduler_compute_steal_threshold()
• struct thread *scheduler_try_do_steal(struct scheduler *sched)
• struct scheduler *scheduler_pick_victim(struct scheduler *self)
• struct thread *scheduler_steal_work(struct scheduler *victim)
• size_t scheduler_try_push_to_idle_core(struct scheduler *sched)
• bool scheduler_inherit_priority(struct thread *boosted,size_t new_weight,enum thread_prio_class new_class)
• void scheduler_uninherit_priority()
• void thread_migrate(struct thread *t,size_t dest_core)
• static inlinestruct thread *scheduler_get_current_thread()
• static inlineenum thread_flagsscheduler_pin_current_thread()
• static inline void scheduler_unpin_current_thread(enum thread_flags flags)
• static inlinestruct thread *thread_spawn(char *name,void (*entry)(void *),void *arg)
• static inlinestruct thread *thread_spawn_custom_stack(char *name,void (*entry)(void *),void *arg,size_t stack_size)
• static inlinestruct thread *thread_spawn_on_core(char *name,void (*entry)(void *),void *arg,uint64_t core_id)
• static inline void scheduler_wake_from_io_block(struct thread *t,void *wake_src)
• static inline bool scheduler_self_in_resched()
• static inline bool scheduler_mark_self_in_resched(bool new)
• static inline bool scheduler_mark_core_needs_resched(struct core *c,bool new)
• static inline bool scheduler_mark_self_needs_resched(bool new)
• static inline bool scheduler_self_needs_resched(void)
• static inline void scheduler_mark_self_idle(bool new)
• static inline void scheduler_resched_if_needed(void)
• static inline bool scheduler_core_idle(struct core *c)
• static inline void scheduler_force_resched(struct scheduler *sched)
• static inline uint32_t scheduler_preemption_disable(void)
• static inline uint32_t scheduler_preemption_enable(void)
• static inline bool scheduler_preemption_disabled(void)

Defines

• WORK_STEAL_THRESHOLD:

75ULL /* How little work the core needs to be
           * doing to try to steal work from another
           * core. This means "% of the average"
           */

• SCHEDULER_DEFAULT_WORK_STEAL_MIN_DIFF: 130

---