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

Use the wait_list

Browse Source
This commit is contained in:
Baptiste Wicht 2016-09-24 21:19:39 +02:00
parent 6c5bfd491e
commit 4e1efd2eaa
2 changed files with 17 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
kernel/include/conc/mutex.hpp
View File

@ -8,10 +8,11 @@
#ifndef MUTEX_H
#define MUTEX_H
#include <circular_buffer.hpp>
#include <types.hpp>
#include <lock_guard.hpp>
#include "conc/spinlock.hpp"
#include "conc/wait_list.hpp"
#include "scheduler.hpp"
#include "logging.hpp"
@ -46,9 +47,9 @@ struct mutex {
value_lock.unlock();
} else {
auto pid = scheduler::get_pid();
queue.push(pid);
queue.enqueue();
auto pid = scheduler::get_pid();
scheduler::block_process_light(pid);
value_lock.unlock();
scheduler::reschedule();
@ -83,7 +84,7 @@ struct mutex {
if (queue.empty()) {
value = 1;
} else {
auto pid = queue.pop();
auto pid = queue.dequeue();
scheduler::unblock_process(pid);
//No need to increment value, the process won't
@ -92,9 +93,9 @@ struct mutex {
}
private:
mutable spinlock value_lock; ///< The spin protecting the value
volatile size_t value = 1; ///< The value of the mutex
circular_buffer<scheduler::pid_t, 16> queue; ///< The sleep queue
mutable spinlock value_lock; ///< The spin protecting the value
volatile size_t value = 1; ///< The value of the mutex
wait_list queue; ///< The sleep queue
};
#endif

17
kernel/include/conc/semaphore.hpp
View File

@ -8,10 +8,11 @@
#ifndef SEMAPHORE_H
#define SEMAPHORE_H
#include <circular_buffer.hpp>
#include <types.hpp>
#include <lock_guard.hpp>
#include "conc/spinlock.hpp"
#include "conc/wait_list.hpp"
#include "scheduler.hpp"
@ -42,9 +43,9 @@ struct semaphore {
--value;
value_lock.unlock();
} else {
auto pid = scheduler::get_pid();
queue.push(pid);
queue.enqueue();
auto pid = scheduler::get_pid();
scheduler::block_process_light(pid);
value_lock.unlock();
scheduler::reschedule();
@ -83,7 +84,7 @@ struct semaphore {
++value;
} else {
// Wake up the process
auto pid = queue.pop();
auto pid = queue.dequeue();
scheduler::unblock_process(pid);
//No need to increment value, the process won't
@ -104,7 +105,7 @@ struct semaphore {
value += n;
} else {
while (n && !queue.empty()) {
auto pid = queue.pop();
auto pid = queue.dequeue();
scheduler::unblock_process(pid);
--n;
}
@ -116,9 +117,9 @@ struct semaphore {
}
private:
mutable spinlock value_lock; ///< The spin lock protecting the counter
volatile size_t value; ///< The value of the counter
circular_buffer<scheduler::pid_t, 16> queue; ///< The sleep queue
mutable spinlock value_lock; ///< The spin lock protecting the counter
volatile size_t value; ///< The value of the counter
wait_list queue; ///< The sleep queue
};
#endif