From 15f3911599a8d005edee46247470afe2a7a0b4aa Mon Sep 17 00:00:00 2001 From: Aleksa Vuckovic Date: Mon, 27 Feb 2023 01:59:33 +0100 Subject: almost done multitasking --- kernel/src/scheduler/scheduler.c | 29 ++++++++++++++++++++++++++++- 1 file changed, 28 insertions(+), 1 deletion(-) (limited to 'kernel/src/scheduler/scheduler.c') diff --git a/kernel/src/scheduler/scheduler.c b/kernel/src/scheduler/scheduler.c index 263c11a..3cbc461 100644 --- a/kernel/src/scheduler/scheduler.c +++ b/kernel/src/scheduler/scheduler.c @@ -2,11 +2,38 @@ #include #include #include +#include +#include +#include +#include -process_t *scheduler(void) +mutex_t scheduler_lock; +uint32_t sched_init = 0; + +__attribute__((noreturn)) void init_scheduler() +{ + INIT_LIST(process_queue.list); + init_mutex(&scheduler_lock); + uint64_t argc = 6; + uint64_t *argv = (uint64_t *)kalloc(sizeof(uint64_t) * 6); + memset(argv, 0, sizeof(uint64_t) * 6); + init_process(0, (uint64_t)idle_thread2, argc, argv); + curr_process = init_process(0, (uint64_t)idle_thread, argc, argv); + sched_init = 1; + restore_context_from_rsp(curr_process->rsp); +} + +process_t *scheduler() { + lock(scheduler_lock); process_t *pos = curr_process; + if (list_is_empty((&process_queue.list))) + return NULL; process_t *next_process = list_next_entry(pos, list); + while (next_process->rsp == 0) { + next_process = list_next_entry(next_process, list); + } + unlock(scheduler_lock); return next_process; } -- cgit v1.2.3