TheCloud/thor-os
1
0
Fork 0
mirror of https://github.com/wichtounet/thor-os.git synced 2025-09-14 23:16:55 -04:00
Code Issues Packages Projects Releases Wiki Activity

Improve interface

Browse Source
This commit is contained in:
Baptiste Wicht 2016-07-09 16:30:25 +02:00
parent 8aabdab355
commit 426c1e33fd
2 changed files with 16 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
kernel/include/scheduler.hpp
View File

@ -50,6 +50,7 @@ void block_process_light(pid_t pid);
//TODO Maybe do that for unblock as well!
process_t& create_kernel_task(char* user_stack, char* kernel_stack, void (*fun)());
void queue_system_process(pid_t pid);
} //end of namespace scheduler

31
kernel/src/scheduler.cpp
View File

@ -189,19 +189,6 @@ scheduler::process_t& new_process(){
return process.process;
}
void queue_system_process(scheduler::pid_t pid){
thor_assert(pid < scheduler::MAX_PROCESS, "pid out of bounds");
auto& process = pcb[pid];
thor_assert(process.process.priority <= scheduler::MAX_PRIORITY, "Invalid priority");
thor_assert(process.process.priority >= scheduler::MIN_PRIORITY, "Invalid priority");
process.state = scheduler::process_state::READY;
run_queue(process.process.priority).push_back(pid);
}
void queue_process(scheduler::pid_t pid){
thor_assert(pid < scheduler::MAX_PROCESS, "pid out of bounds");
@ -222,7 +209,7 @@ void create_idle_task(){
idle_process.ppid = 0;
idle_process.priority = scheduler::MIN_PRIORITY;
queue_system_process(idle_process.pid);
scheduler::queue_system_process(idle_process.pid);
idle_pid = idle_process.pid;
}
@ -233,7 +220,7 @@ void create_init_task(){
init_process.ppid = 0;
init_process.priority = scheduler::MIN_PRIORITY + 1;
queue_system_process(init_process.pid);
scheduler::queue_system_process(init_process.pid);
}
void create_gc_task(){
@ -242,7 +229,7 @@ void create_gc_task(){
gc_process.ppid = 1;
gc_process.priority = scheduler::MIN_PRIORITY + 1;
queue_system_process(gc_process.pid);
scheduler::queue_system_process(gc_process.pid);
gc_pid = gc_process.pid;
}
@ -881,3 +868,15 @@ scheduler::process_t& scheduler::create_kernel_task(char* user_stack, char* kern
return process;
}
void scheduler::queue_system_process(scheduler::pid_t pid){
thor_assert(pid < scheduler::MAX_PROCESS, "pid out of bounds");
auto& process = pcb[pid];
thor_assert(process.process.priority <= scheduler::MAX_PRIORITY, "Invalid priority");
thor_assert(process.process.priority >= scheduler::MIN_PRIORITY, "Invalid priority");
process.state = scheduler::process_state::READY;
run_queue(process.process.priority).push_back(pid);
}