2014-05-21 05:03:45 +02:00
|
|
|
// Copyright 2014 Citra Emulator Project
|
2014-12-17 06:38:14 +01:00
|
|
|
// Licensed under GPLv2 or any later version
|
2014-11-19 09:49:13 +01:00
|
|
|
// Refer to the license.txt file included.
|
2014-05-21 05:03:45 +02:00
|
|
|
|
|
|
|
#include <map>
|
|
|
|
#include <vector>
|
|
|
|
|
2015-01-31 22:22:40 +01:00
|
|
|
#include <boost/range/algorithm_ext/erase.hpp>
|
|
|
|
|
2014-05-21 05:03:45 +02:00
|
|
|
#include "common/common.h"
|
|
|
|
|
|
|
|
#include "core/hle/kernel/kernel.h"
|
2014-05-30 05:31:01 +02:00
|
|
|
#include "core/hle/kernel/mutex.h"
|
2014-05-21 05:03:45 +02:00
|
|
|
#include "core/hle/kernel/thread.h"
|
|
|
|
|
|
|
|
namespace Kernel {
|
|
|
|
|
2014-12-07 21:44:21 +01:00
|
|
|
/**
|
|
|
|
* Resumes a thread waiting for the specified mutex
|
|
|
|
* @param mutex The mutex that some thread is waiting on
|
|
|
|
*/
|
2015-01-11 04:20:49 +01:00
|
|
|
static void ResumeWaitingThread(Mutex* mutex) {
|
2015-01-23 02:12:19 +01:00
|
|
|
// Reset mutex lock thread handle, nothing is waiting
|
2015-02-10 04:06:09 +01:00
|
|
|
mutex->lock_count = 0;
|
2015-01-23 02:12:19 +01:00
|
|
|
mutex->holding_thread = nullptr;
|
|
|
|
|
2014-12-07 21:44:21 +01:00
|
|
|
// Find the next waiting thread for the mutex...
|
2015-01-21 00:20:47 +01:00
|
|
|
auto next_thread = mutex->WakeupNextThread();
|
2015-01-15 01:22:50 +01:00
|
|
|
if (next_thread != nullptr) {
|
2015-01-23 02:12:19 +01:00
|
|
|
mutex->Acquire(next_thread);
|
2014-12-07 21:44:21 +01:00
|
|
|
}
|
2014-05-21 05:03:45 +02:00
|
|
|
}
|
|
|
|
|
2015-01-21 00:33:23 +01:00
|
|
|
void ReleaseThreadMutexes(Thread* thread) {
|
2015-01-31 22:22:40 +01:00
|
|
|
for (auto& mtx : thread->held_mutexes) {
|
|
|
|
ResumeWaitingThread(mtx.get());
|
2014-12-07 21:44:21 +01:00
|
|
|
}
|
2015-01-31 22:22:40 +01:00
|
|
|
thread->held_mutexes.clear();
|
2014-12-07 21:44:21 +01:00
|
|
|
}
|
|
|
|
|
2015-02-01 01:56:59 +01:00
|
|
|
Mutex::Mutex() {}
|
|
|
|
Mutex::~Mutex() {}
|
|
|
|
|
2015-02-01 03:14:40 +01:00
|
|
|
SharedPtr<Mutex> Mutex::Create(bool initial_locked, std::string name) {
|
2015-01-23 02:12:19 +01:00
|
|
|
SharedPtr<Mutex> mutex(new Mutex);
|
2014-05-21 05:03:45 +02:00
|
|
|
|
2015-02-10 04:06:09 +01:00
|
|
|
mutex->lock_count = 0;
|
2015-01-23 02:12:19 +01:00
|
|
|
mutex->name = std::move(name);
|
2015-01-21 00:33:23 +01:00
|
|
|
mutex->holding_thread = nullptr;
|
2014-05-21 05:03:45 +02:00
|
|
|
|
|
|
|
// Acquire mutex with current thread if initialized as locked...
|
2015-01-23 02:12:19 +01:00
|
|
|
if (initial_locked)
|
|
|
|
mutex->Acquire();
|
2014-05-21 05:03:45 +02:00
|
|
|
|
2015-02-01 03:14:40 +01:00
|
|
|
return mutex;
|
2014-05-21 05:03:45 +02:00
|
|
|
}
|
|
|
|
|
2015-01-21 00:16:45 +01:00
|
|
|
bool Mutex::ShouldWait() {
|
2015-04-04 00:40:16 +02:00
|
|
|
auto thread = GetCurrentThread();
|
|
|
|
bool wait = lock_count > 0 && holding_thread != thread;
|
|
|
|
|
|
|
|
// If the holding thread of the mutex is lower priority than this thread, that thread should
|
|
|
|
// temporarily inherit this thread's priority
|
|
|
|
if (wait && thread->current_priority < holding_thread->current_priority)
|
|
|
|
holding_thread->BoostPriority(thread->current_priority);
|
|
|
|
|
|
|
|
return wait;
|
2015-01-18 04:23:49 +01:00
|
|
|
}
|
|
|
|
|
2015-01-21 00:16:45 +01:00
|
|
|
void Mutex::Acquire() {
|
2015-01-23 02:12:19 +01:00
|
|
|
Acquire(GetCurrentThread());
|
|
|
|
}
|
|
|
|
|
2015-02-01 02:26:16 +01:00
|
|
|
void Mutex::Acquire(SharedPtr<Thread> thread) {
|
2015-01-21 02:16:47 +01:00
|
|
|
ASSERT_MSG(!ShouldWait(), "object unavailable!");
|
2015-01-23 02:12:19 +01:00
|
|
|
|
2015-02-10 04:06:09 +01:00
|
|
|
// Actually "acquire" the mutex only if we don't already have it...
|
|
|
|
if (lock_count == 0) {
|
|
|
|
thread->held_mutexes.insert(this);
|
|
|
|
holding_thread = std::move(thread);
|
|
|
|
}
|
2015-01-23 02:12:19 +01:00
|
|
|
|
2015-02-10 04:06:09 +01:00
|
|
|
lock_count++;
|
2015-01-23 02:12:19 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
void Mutex::Release() {
|
2015-02-10 04:06:09 +01:00
|
|
|
// Only release if the mutex is held...
|
|
|
|
if (lock_count > 0) {
|
|
|
|
lock_count--;
|
|
|
|
|
|
|
|
// Yield to the next thread only if we've fully released the mutex...
|
|
|
|
if (lock_count == 0) {
|
|
|
|
holding_thread->held_mutexes.erase(this);
|
|
|
|
ResumeWaitingThread(this);
|
|
|
|
}
|
|
|
|
}
|
2014-12-07 21:57:28 +01:00
|
|
|
}
|
2015-01-21 00:16:45 +01:00
|
|
|
|
2014-05-21 05:03:45 +02:00
|
|
|
} // namespace
|