2014-05-20 20:03:45 -07:00
|
|
|
// Copyright 2014 Citra Emulator Project
|
2014-12-16 21:38:14 -08:00
|
|
|
// Licensed under GPLv2 or any later version
|
2014-11-19 00:49:13 -08:00
|
|
|
// Refer to the license.txt file included.
|
2014-05-20 20:03:45 -07:00
|
|
|
|
|
|
|
#include <map>
|
|
|
|
#include <vector>
|
|
|
|
|
2015-01-31 13:22:40 -08:00
|
|
|
#include <boost/range/algorithm_ext/erase.hpp>
|
|
|
|
|
2015-05-06 00:06:12 -07:00
|
|
|
#include "common/assert.h"
|
2014-05-20 20:03:45 -07:00
|
|
|
|
|
|
|
#include "core/hle/kernel/kernel.h"
|
2014-05-29 20:31:01 -07:00
|
|
|
#include "core/hle/kernel/mutex.h"
|
2014-05-20 20:03:45 -07:00
|
|
|
#include "core/hle/kernel/thread.h"
|
|
|
|
|
|
|
|
namespace Kernel {
|
|
|
|
|
2014-12-07 12:44:21 -08:00
|
|
|
/**
|
|
|
|
* Resumes a thread waiting for the specified mutex
|
|
|
|
* @param mutex The mutex that some thread is waiting on
|
|
|
|
*/
|
2015-01-10 19:20:49 -08:00
|
|
|
static void ResumeWaitingThread(Mutex* mutex) {
|
2015-01-22 17:12:19 -08:00
|
|
|
// Reset mutex lock thread handle, nothing is waiting
|
2015-02-09 19:06:09 -08:00
|
|
|
mutex->lock_count = 0;
|
2015-01-22 17:12:19 -08:00
|
|
|
mutex->holding_thread = nullptr;
|
2015-06-07 20:39:37 -07:00
|
|
|
mutex->WakeupAllWaitingThreads();
|
2014-05-20 20:03:45 -07:00
|
|
|
}
|
|
|
|
|
2015-01-20 15:33:23 -08:00
|
|
|
void ReleaseThreadMutexes(Thread* thread) {
|
2015-01-31 13:22:40 -08:00
|
|
|
for (auto& mtx : thread->held_mutexes) {
|
|
|
|
ResumeWaitingThread(mtx.get());
|
2014-12-07 12:44:21 -08:00
|
|
|
}
|
2015-01-31 13:22:40 -08:00
|
|
|
thread->held_mutexes.clear();
|
2014-12-07 12:44:21 -08:00
|
|
|
}
|
|
|
|
|
2015-01-31 16:56:59 -08:00
|
|
|
Mutex::Mutex() {}
|
|
|
|
Mutex::~Mutex() {}
|
|
|
|
|
2015-01-31 18:14:40 -08:00
|
|
|
SharedPtr<Mutex> Mutex::Create(bool initial_locked, std::string name) {
|
2015-01-22 17:12:19 -08:00
|
|
|
SharedPtr<Mutex> mutex(new Mutex);
|
2014-05-20 20:03:45 -07:00
|
|
|
|
2015-02-09 19:06:09 -08:00
|
|
|
mutex->lock_count = 0;
|
2015-01-22 17:12:19 -08:00
|
|
|
mutex->name = std::move(name);
|
2015-01-20 15:33:23 -08:00
|
|
|
mutex->holding_thread = nullptr;
|
2014-05-20 20:03:45 -07:00
|
|
|
|
|
|
|
// Acquire mutex with current thread if initialized as locked...
|
2015-01-22 17:12:19 -08:00
|
|
|
if (initial_locked)
|
|
|
|
mutex->Acquire();
|
2014-05-20 20:03:45 -07:00
|
|
|
|
2015-01-31 18:14:40 -08:00
|
|
|
return mutex;
|
2014-05-20 20:03:45 -07:00
|
|
|
}
|
|
|
|
|
2015-01-20 15:16:45 -08:00
|
|
|
bool Mutex::ShouldWait() {
|
2015-04-03 15:40:16 -07: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-17 19:23:49 -08:00
|
|
|
}
|
|
|
|
|
2015-01-20 15:16:45 -08:00
|
|
|
void Mutex::Acquire() {
|
2015-01-22 17:12:19 -08:00
|
|
|
Acquire(GetCurrentThread());
|
|
|
|
}
|
|
|
|
|
2015-01-31 17:26:16 -08:00
|
|
|
void Mutex::Acquire(SharedPtr<Thread> thread) {
|
2015-01-20 17:16:47 -08:00
|
|
|
ASSERT_MSG(!ShouldWait(), "object unavailable!");
|
2015-01-22 17:12:19 -08:00
|
|
|
|
2015-02-09 19:06:09 -08: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-22 17:12:19 -08:00
|
|
|
|
2015-02-09 19:06:09 -08:00
|
|
|
lock_count++;
|
2015-01-22 17:12:19 -08:00
|
|
|
}
|
|
|
|
|
|
|
|
void Mutex::Release() {
|
2015-02-09 19:06:09 -08: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 12:57:28 -08:00
|
|
|
}
|
2015-01-20 15:16:45 -08:00
|
|
|
|
2014-05-20 20:03:45 -07:00
|
|
|
} // namespace
|