kamkow1/mop3
1
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Dynamically assign cpu upon mutex unlock
All checks were successful
Build documentation / build-and-deploy (push) Successful in 35s
Details

Browse Source
This commit is contained in:
Kamil Kowalczyk
2026-01-25 20:39:51 +01:00
parent 8650010992
commit a68373e4ee
1 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
kernel/proc/mutex.c
View File

@@ -42,6 +42,7 @@ static void proc_mutex_suspend (struct proc* proc, struct proc_suspension_q* sq,
cpu->proc_current = NULL;
list_append (sq->proc_list, &proc->suspension_link);
proc->cpu = NULL;
spin_unlock (&sq->lock, &ctxsq);
spin_unlock (&proc->lock, &ctxpr);
@@ -52,26 +53,25 @@ static void proc_mutex_suspend (struct proc* proc, struct proc_suspension_q* sq,
static void proc_mutex_resume (struct proc* proc) {
spin_lock_ctx_t ctxsq, ctxpr, ctxcpu;
struct cpu* cpu = proc->cpu;
struct cpu* cpu = cpu_find_lightest ();
spin_lock (&cpu->lock, &ctxcpu);
spin_lock (&proc->lock, &ctxpr);
proc->cpu = cpu;
struct proc_suspension_q* sq = proc->suspension_q;
if (sq) {
spin_lock (&sq->lock, &ctxsq);
spin_lock (&sq->lock, &ctxsq);
list_remove (sq->proc_list, &proc->suspension_link);
list_remove (sq->proc_list, &proc->suspension_link);
proc->suspension_q = NULL;
atomic_store (&proc->state, PROC_READY);
proc->suspension_q = NULL;
atomic_store (&proc->state, PROC_READY);
list_append (cpu->proc_run_q, &proc->cpu_run_q_link);
atomic_fetch_add (&cpu->proc_run_q_count, 1);
list_append (cpu->proc_run_q, &proc->cpu_run_q_link);
atomic_fetch_add (&cpu->proc_run_q_count, 1);
spin_unlock (&sq->lock, &ctxsq);
}
spin_unlock (&sq->lock, &ctxsq);
spin_unlock (&proc->lock, &ctxpr);
spin_unlock (&cpu->lock, &ctxcpu);