From 784ca276c9e701629652a8d3ee194d41ecc06fdf Mon Sep 17 00:00:00 2001 From: Christian Cunningham Date: Fri, 18 Mar 2022 13:54:07 -0700 Subject: Deadlock prevention for managed mutexs --- src/util/mutex.c | 36 ++++++++++++++++++++++++++++++++++++ 1 file changed, 36 insertions(+) (limited to 'src') diff --git a/src/util/mutex.c b/src/util/mutex.c index 226bfbc..802558e 100644 --- a/src/util/mutex.c +++ b/src/util/mutex.c @@ -1,4 +1,6 @@ +#include #include +#include #include void mutex_init(void) @@ -50,3 +52,37 @@ unsigned char delete_mutex(struct Mutex* m) prepend_to_queue(entry, &mutex_manager.free); return 0; } + +void lock_mutex(struct Mutex* m) +{ + struct Thread* rthread = scheduler.rthread; + unsigned long rpid = rthread->pid; + unsigned long mode = getmode() & 0x1F; + if (mode == 0x10) { + sys1(SYS_LOCK, m); + // Find this mutex + struct Entry* mentry = find_value(m, &mutex_manager.used); + // If it is not a managed mutex, break away + if (mentry == 0) + return; + // Get the next entry + mentry = mentry->next->next; + // Ensure this thread locks all mutexs sequentially + // To avoid a deadlock + while (mentry->entry_type == VALUE_ENTRY) { + struct Mutex* vmutex = mentry->value; + // If this thread had locked it + // Toggle the lock to prevent deadlock + if (vmutex->pid == rpid) { + sys1(SYS_UNLOCK, m); + sys1(SYS_LOCK, m); + } + mentry = mentry->next; + } + } +} + +void unlock_mutex(struct Mutex* m) +{ + unlock((struct Lock*)m); +} -- cgit v1.2.1