2014-12-17 06:38:14 +01:00
|
|
|
// Copyright 2014 Citra Emulator Project
|
|
|
|
// Licensed under GPLv2 or any later version
|
2014-11-19 09:49:13 +01:00
|
|
|
// Refer to the license.txt file included.
|
2014-05-10 04:11:18 +02:00
|
|
|
|
2018-08-28 18:30:33 +02:00
|
|
|
#include <array>
|
|
|
|
#include <atomic>
|
|
|
|
#include <memory>
|
|
|
|
#include <mutex>
|
|
|
|
#include <utility>
|
|
|
|
|
|
|
|
#include "common/assert.h"
|
|
|
|
#include "common/logging/log.h"
|
|
|
|
|
|
|
|
#include "core/core.h"
|
|
|
|
#include "core/core_timing.h"
|
2018-09-02 17:58:58 +02:00
|
|
|
#include "core/hle/kernel/client_port.h"
|
2017-05-30 01:45:42 +02:00
|
|
|
#include "core/hle/kernel/handle_table.h"
|
2016-09-21 08:52:38 +02:00
|
|
|
#include "core/hle/kernel/kernel.h"
|
2015-05-04 05:01:16 +02:00
|
|
|
#include "core/hle/kernel/process.h"
|
2015-08-06 02:26:52 +02:00
|
|
|
#include "core/hle/kernel/resource_limit.h"
|
2014-05-10 04:11:18 +02:00
|
|
|
#include "core/hle/kernel/thread.h"
|
2014-12-04 20:45:47 +01:00
|
|
|
#include "core/hle/kernel/timer.h"
|
2018-08-28 18:30:33 +02:00
|
|
|
#include "core/hle/lock.h"
|
|
|
|
#include "core/hle/result.h"
|
2014-05-10 04:11:18 +02:00
|
|
|
|
2014-05-21 00:13:25 +02:00
|
|
|
namespace Kernel {
|
2014-05-10 04:11:18 +02:00
|
|
|
|
2018-08-28 18:30:33 +02:00
|
|
|
/**
|
|
|
|
* Callback that will wake up the thread it was scheduled for
|
|
|
|
* @param thread_handle The handle of the thread that's been awoken
|
|
|
|
* @param cycles_late The number of CPU cycles that have passed since the desired wakeup time
|
|
|
|
*/
|
|
|
|
static void ThreadWakeupCallback(u64 thread_handle, [[maybe_unused]] int cycles_late) {
|
|
|
|
const auto proper_handle = static_cast<Handle>(thread_handle);
|
|
|
|
auto& system = Core::System::GetInstance();
|
|
|
|
|
|
|
|
// Lock the global kernel mutex when we enter the kernel HLE.
|
|
|
|
std::lock_guard<std::recursive_mutex> lock(HLE::g_hle_lock);
|
|
|
|
|
|
|
|
SharedPtr<Thread> thread =
|
|
|
|
system.Kernel().RetrieveThreadFromWakeupCallbackHandleTable(proper_handle);
|
|
|
|
if (thread == nullptr) {
|
|
|
|
LOG_CRITICAL(Kernel, "Callback fired for invalid thread {:08X}", proper_handle);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
bool resume = true;
|
|
|
|
|
2018-10-04 00:47:57 +02:00
|
|
|
if (thread->GetStatus() == ThreadStatus::WaitSynchAny ||
|
|
|
|
thread->GetStatus() == ThreadStatus::WaitSynchAll ||
|
|
|
|
thread->GetStatus() == ThreadStatus::WaitHLEEvent) {
|
2018-08-28 18:30:33 +02:00
|
|
|
// Remove the thread from each of its waiting objects' waitlists
|
2018-10-04 00:47:57 +02:00
|
|
|
for (const auto& object : thread->GetWaitObjects()) {
|
2018-08-28 18:30:33 +02:00
|
|
|
object->RemoveWaitingThread(thread.get());
|
|
|
|
}
|
2018-10-04 00:47:57 +02:00
|
|
|
thread->ClearWaitObjects();
|
2018-08-28 18:30:33 +02:00
|
|
|
|
|
|
|
// Invoke the wakeup callback before clearing the wait objects
|
2018-10-04 00:47:57 +02:00
|
|
|
if (thread->HasWakeupCallback()) {
|
|
|
|
resume = thread->InvokeWakeupCallback(ThreadWakeupReason::Timeout, thread, nullptr, 0);
|
2018-08-28 18:30:33 +02:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2018-10-04 00:47:57 +02:00
|
|
|
if (thread->GetMutexWaitAddress() != 0 || thread->GetCondVarWaitAddress() != 0 ||
|
|
|
|
thread->GetWaitHandle() != 0) {
|
|
|
|
ASSERT(thread->GetStatus() == ThreadStatus::WaitMutex);
|
|
|
|
thread->SetMutexWaitAddress(0);
|
|
|
|
thread->SetCondVarWaitAddress(0);
|
|
|
|
thread->SetWaitHandle(0);
|
2018-08-28 18:30:33 +02:00
|
|
|
|
2018-10-04 00:47:57 +02:00
|
|
|
auto* const lock_owner = thread->GetLockOwner();
|
2018-08-28 18:30:33 +02:00
|
|
|
// Threads waking up by timeout from WaitProcessWideKey do not perform priority inheritance
|
|
|
|
// and don't have a lock owner unless SignalProcessWideKey was called first and the thread
|
|
|
|
// wasn't awakened due to the mutex already being acquired.
|
2018-10-04 00:47:57 +02:00
|
|
|
if (lock_owner != nullptr) {
|
2018-08-28 18:30:33 +02:00
|
|
|
lock_owner->RemoveMutexWaiter(thread);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2018-10-04 00:47:57 +02:00
|
|
|
if (thread->GetArbiterWaitAddress() != 0) {
|
|
|
|
ASSERT(thread->GetStatus() == ThreadStatus::WaitArb);
|
|
|
|
thread->SetArbiterWaitAddress(0);
|
2018-08-28 18:30:33 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
if (resume) {
|
|
|
|
thread->ResumeFromWait();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
/// The timer callback event, called when a timer is fired
|
|
|
|
static void TimerCallback(u64 timer_handle, int cycles_late) {
|
|
|
|
const auto proper_handle = static_cast<Handle>(timer_handle);
|
|
|
|
auto& system = Core::System::GetInstance();
|
|
|
|
SharedPtr<Timer> timer = system.Kernel().RetrieveTimerFromCallbackHandleTable(proper_handle);
|
|
|
|
|
|
|
|
if (timer == nullptr) {
|
|
|
|
LOG_CRITICAL(Kernel, "Callback fired for invalid timer {:016X}", timer_handle);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
timer->Signal(cycles_late);
|
|
|
|
}
|
2014-05-14 03:57:12 +02:00
|
|
|
|
2018-08-28 18:30:33 +02:00
|
|
|
struct KernelCore::Impl {
|
|
|
|
void Initialize(KernelCore& kernel) {
|
|
|
|
Shutdown();
|
2015-04-28 04:12:35 +02:00
|
|
|
|
2018-08-28 18:30:33 +02:00
|
|
|
InitializeResourceLimits(kernel);
|
|
|
|
InitializeThreads();
|
|
|
|
InitializeTimers();
|
|
|
|
}
|
|
|
|
|
|
|
|
void Shutdown() {
|
|
|
|
next_object_id = 0;
|
|
|
|
next_process_id = 10;
|
|
|
|
next_thread_id = 1;
|
|
|
|
|
|
|
|
process_list.clear();
|
2018-10-10 06:42:10 +02:00
|
|
|
current_process = nullptr;
|
2018-08-28 18:30:33 +02:00
|
|
|
|
|
|
|
handle_table.Clear();
|
|
|
|
resource_limits.fill(nullptr);
|
|
|
|
|
|
|
|
thread_wakeup_callback_handle_table.Clear();
|
|
|
|
thread_wakeup_event_type = nullptr;
|
|
|
|
|
|
|
|
timer_callback_handle_table.Clear();
|
|
|
|
timer_callback_event_type = nullptr;
|
2018-09-02 17:58:58 +02:00
|
|
|
|
|
|
|
named_ports.clear();
|
2018-08-28 18:30:33 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
void InitializeResourceLimits(KernelCore& kernel) {
|
|
|
|
// Create the four resource limits that the system uses
|
|
|
|
// Create the APPLICATION resource limit
|
|
|
|
SharedPtr<ResourceLimit> resource_limit = ResourceLimit::Create(kernel, "Applications");
|
|
|
|
resource_limit->max_priority = 0x18;
|
|
|
|
resource_limit->max_commit = 0x4000000;
|
|
|
|
resource_limit->max_threads = 0x20;
|
|
|
|
resource_limit->max_events = 0x20;
|
|
|
|
resource_limit->max_mutexes = 0x20;
|
|
|
|
resource_limit->max_semaphores = 0x8;
|
|
|
|
resource_limit->max_timers = 0x8;
|
|
|
|
resource_limit->max_shared_mems = 0x10;
|
|
|
|
resource_limit->max_address_arbiters = 0x2;
|
|
|
|
resource_limit->max_cpu_time = 0x1E;
|
|
|
|
resource_limits[static_cast<u8>(ResourceLimitCategory::APPLICATION)] = resource_limit;
|
|
|
|
|
|
|
|
// Create the SYS_APPLET resource limit
|
|
|
|
resource_limit = ResourceLimit::Create(kernel, "System Applets");
|
|
|
|
resource_limit->max_priority = 0x4;
|
|
|
|
resource_limit->max_commit = 0x5E00000;
|
|
|
|
resource_limit->max_threads = 0x1D;
|
|
|
|
resource_limit->max_events = 0xB;
|
|
|
|
resource_limit->max_mutexes = 0x8;
|
|
|
|
resource_limit->max_semaphores = 0x4;
|
|
|
|
resource_limit->max_timers = 0x4;
|
|
|
|
resource_limit->max_shared_mems = 0x8;
|
|
|
|
resource_limit->max_address_arbiters = 0x3;
|
|
|
|
resource_limit->max_cpu_time = 0x2710;
|
|
|
|
resource_limits[static_cast<u8>(ResourceLimitCategory::SYS_APPLET)] = resource_limit;
|
|
|
|
|
|
|
|
// Create the LIB_APPLET resource limit
|
|
|
|
resource_limit = ResourceLimit::Create(kernel, "Library Applets");
|
|
|
|
resource_limit->max_priority = 0x4;
|
|
|
|
resource_limit->max_commit = 0x600000;
|
|
|
|
resource_limit->max_threads = 0xE;
|
|
|
|
resource_limit->max_events = 0x8;
|
|
|
|
resource_limit->max_mutexes = 0x8;
|
|
|
|
resource_limit->max_semaphores = 0x4;
|
|
|
|
resource_limit->max_timers = 0x4;
|
|
|
|
resource_limit->max_shared_mems = 0x8;
|
|
|
|
resource_limit->max_address_arbiters = 0x1;
|
|
|
|
resource_limit->max_cpu_time = 0x2710;
|
|
|
|
resource_limits[static_cast<u8>(ResourceLimitCategory::LIB_APPLET)] = resource_limit;
|
|
|
|
|
|
|
|
// Create the OTHER resource limit
|
|
|
|
resource_limit = ResourceLimit::Create(kernel, "Others");
|
|
|
|
resource_limit->max_priority = 0x4;
|
|
|
|
resource_limit->max_commit = 0x2180000;
|
|
|
|
resource_limit->max_threads = 0xE1;
|
|
|
|
resource_limit->max_events = 0x108;
|
|
|
|
resource_limit->max_mutexes = 0x25;
|
|
|
|
resource_limit->max_semaphores = 0x43;
|
|
|
|
resource_limit->max_timers = 0x2C;
|
|
|
|
resource_limit->max_shared_mems = 0x1F;
|
|
|
|
resource_limit->max_address_arbiters = 0x2D;
|
|
|
|
resource_limit->max_cpu_time = 0x3E8;
|
|
|
|
resource_limits[static_cast<u8>(ResourceLimitCategory::OTHER)] = resource_limit;
|
|
|
|
}
|
|
|
|
|
|
|
|
void InitializeThreads() {
|
|
|
|
thread_wakeup_event_type =
|
|
|
|
CoreTiming::RegisterEvent("ThreadWakeupCallback", ThreadWakeupCallback);
|
|
|
|
}
|
|
|
|
|
|
|
|
void InitializeTimers() {
|
|
|
|
timer_callback_handle_table.Clear();
|
|
|
|
timer_callback_event_type = CoreTiming::RegisterEvent("TimerCallback", TimerCallback);
|
|
|
|
}
|
|
|
|
|
|
|
|
std::atomic<u32> next_object_id{0};
|
2015-05-12 01:23:45 +02:00
|
|
|
// TODO(Subv): Start the process ids from 10 for now, as lower PIDs are
|
|
|
|
// reserved for low-level services
|
2018-08-28 18:30:33 +02:00
|
|
|
std::atomic<u32> next_process_id{10};
|
|
|
|
std::atomic<u32> next_thread_id{1};
|
|
|
|
|
|
|
|
// Lists all processes that exist in the current session.
|
|
|
|
std::vector<SharedPtr<Process>> process_list;
|
2018-10-10 06:42:10 +02:00
|
|
|
Process* current_process = nullptr;
|
2018-08-28 18:30:33 +02:00
|
|
|
|
|
|
|
Kernel::HandleTable handle_table;
|
|
|
|
std::array<SharedPtr<ResourceLimit>, 4> resource_limits;
|
|
|
|
|
|
|
|
/// The event type of the generic timer callback event
|
|
|
|
CoreTiming::EventType* timer_callback_event_type = nullptr;
|
|
|
|
// TODO(yuriks): This can be removed if Timer objects are explicitly pooled in the future,
|
|
|
|
// allowing us to simply use a pool index or similar.
|
|
|
|
Kernel::HandleTable timer_callback_handle_table;
|
|
|
|
|
|
|
|
CoreTiming::EventType* thread_wakeup_event_type = nullptr;
|
|
|
|
// TODO(yuriks): This can be removed if Thread objects are explicitly pooled in the future,
|
|
|
|
// allowing us to simply use a pool index or similar.
|
|
|
|
Kernel::HandleTable thread_wakeup_callback_handle_table;
|
2018-09-02 17:58:58 +02:00
|
|
|
|
|
|
|
/// Map of named ports managed by the kernel, which can be retrieved using
|
|
|
|
/// the ConnectToPort SVC.
|
|
|
|
NamedPortTable named_ports;
|
2018-08-28 18:30:33 +02:00
|
|
|
};
|
|
|
|
|
|
|
|
KernelCore::KernelCore() : impl{std::make_unique<Impl>()} {}
|
|
|
|
KernelCore::~KernelCore() {
|
|
|
|
Shutdown();
|
|
|
|
}
|
|
|
|
|
|
|
|
void KernelCore::Initialize() {
|
|
|
|
impl->Initialize(*this);
|
|
|
|
}
|
|
|
|
|
|
|
|
void KernelCore::Shutdown() {
|
|
|
|
impl->Shutdown();
|
|
|
|
}
|
|
|
|
|
|
|
|
Kernel::HandleTable& KernelCore::HandleTable() {
|
|
|
|
return impl->handle_table;
|
|
|
|
}
|
|
|
|
|
|
|
|
const Kernel::HandleTable& KernelCore::HandleTable() const {
|
|
|
|
return impl->handle_table;
|
|
|
|
}
|
|
|
|
|
|
|
|
SharedPtr<ResourceLimit> KernelCore::ResourceLimitForCategory(
|
|
|
|
ResourceLimitCategory category) const {
|
|
|
|
return impl->resource_limits.at(static_cast<std::size_t>(category));
|
|
|
|
}
|
|
|
|
|
|
|
|
SharedPtr<Thread> KernelCore::RetrieveThreadFromWakeupCallbackHandleTable(Handle handle) const {
|
|
|
|
return impl->thread_wakeup_callback_handle_table.Get<Thread>(handle);
|
|
|
|
}
|
|
|
|
|
|
|
|
SharedPtr<Timer> KernelCore::RetrieveTimerFromCallbackHandleTable(Handle handle) const {
|
|
|
|
return impl->timer_callback_handle_table.Get<Timer>(handle);
|
|
|
|
}
|
|
|
|
|
|
|
|
void KernelCore::AppendNewProcess(SharedPtr<Process> process) {
|
|
|
|
impl->process_list.push_back(std::move(process));
|
|
|
|
}
|
|
|
|
|
2018-10-10 06:42:10 +02:00
|
|
|
void KernelCore::MakeCurrentProcess(Process* process) {
|
|
|
|
impl->current_process = process;
|
2018-09-07 02:34:51 +02:00
|
|
|
}
|
|
|
|
|
2018-10-10 06:42:10 +02:00
|
|
|
Process* KernelCore::CurrentProcess() {
|
2018-09-07 02:34:51 +02:00
|
|
|
return impl->current_process;
|
|
|
|
}
|
|
|
|
|
2018-10-10 06:42:10 +02:00
|
|
|
const Process* KernelCore::CurrentProcess() const {
|
2018-09-07 02:34:51 +02:00
|
|
|
return impl->current_process;
|
|
|
|
}
|
|
|
|
|
2018-09-02 17:58:58 +02:00
|
|
|
void KernelCore::AddNamedPort(std::string name, SharedPtr<ClientPort> port) {
|
|
|
|
impl->named_ports.emplace(std::move(name), std::move(port));
|
|
|
|
}
|
|
|
|
|
|
|
|
KernelCore::NamedPortTable::iterator KernelCore::FindNamedPort(const std::string& name) {
|
|
|
|
return impl->named_ports.find(name);
|
|
|
|
}
|
|
|
|
|
|
|
|
KernelCore::NamedPortTable::const_iterator KernelCore::FindNamedPort(
|
|
|
|
const std::string& name) const {
|
|
|
|
return impl->named_ports.find(name);
|
|
|
|
}
|
|
|
|
|
|
|
|
bool KernelCore::IsValidNamedPort(NamedPortTable::const_iterator port) const {
|
|
|
|
return port != impl->named_ports.cend();
|
|
|
|
}
|
|
|
|
|
2018-08-28 18:30:33 +02:00
|
|
|
u32 KernelCore::CreateNewObjectID() {
|
|
|
|
return impl->next_object_id++;
|
|
|
|
}
|
|
|
|
|
|
|
|
u32 KernelCore::CreateNewThreadID() {
|
|
|
|
return impl->next_thread_id++;
|
2014-05-21 00:13:25 +02:00
|
|
|
}
|
|
|
|
|
2018-08-28 18:30:33 +02:00
|
|
|
u32 KernelCore::CreateNewProcessID() {
|
|
|
|
return impl->next_process_id++;
|
|
|
|
}
|
2015-08-06 02:26:52 +02:00
|
|
|
|
2018-08-28 18:30:33 +02:00
|
|
|
ResultVal<Handle> KernelCore::CreateTimerCallbackHandle(const SharedPtr<Timer>& timer) {
|
|
|
|
return impl->timer_callback_handle_table.Create(timer);
|
|
|
|
}
|
|
|
|
|
|
|
|
CoreTiming::EventType* KernelCore::ThreadWakeupCallbackEventType() const {
|
|
|
|
return impl->thread_wakeup_event_type;
|
|
|
|
}
|
|
|
|
|
|
|
|
CoreTiming::EventType* KernelCore::TimerCallbackEventType() const {
|
|
|
|
return impl->timer_callback_event_type;
|
|
|
|
}
|
|
|
|
|
|
|
|
Kernel::HandleTable& KernelCore::ThreadWakeupCallbackHandleTable() {
|
|
|
|
return impl->thread_wakeup_callback_handle_table;
|
|
|
|
}
|
2015-08-06 02:26:52 +02:00
|
|
|
|
2018-08-28 18:30:33 +02:00
|
|
|
const Kernel::HandleTable& KernelCore::ThreadWakeupCallbackHandleTable() const {
|
|
|
|
return impl->thread_wakeup_callback_handle_table;
|
2014-05-14 03:57:12 +02:00
|
|
|
}
|
2014-05-23 01:06:12 +02:00
|
|
|
|
2018-01-01 19:25:37 +01:00
|
|
|
} // namespace Kernel
|