mirrors/Atmosphere
1
0
Fork 0
mirror of https://github.com/Atmosphere-NX/Atmosphere.git synced 2025-05-24 11:46:58 -04:00
Code Issues Projects Releases Packages Wiki Activity

kern: add page table contents debug

Browse source
This commit is contained in:
Michael Scire 2020-12-11 19:30:48 -08:00
parent 1ec2c0c2cb
commit 9a6cca7499
6 changed files with 189 additions and 16 deletions
Download patch file Download diff file Expand all files Collapse all files

46
libraries/libmesosphere/source/kern_k_dpc_manager.cpp
View file

@ -21,10 +21,11 @@ namespace ams::kern {
class KDpcTask {
private:
static inline KLightLock s_lock;
static inline KLightConditionVariable s_cond_var;
static inline u64 s_core_mask;
static inline KDpcTask *s_task;
static constinit inline KLightLock s_req_lock;
static constinit inline KLightLock s_lock;
static constinit inline KLightConditionVariable s_cond_var;
static constinit inline u64 s_core_mask;
static constinit inline KDpcTask *s_task;
private:
static bool HasRequest(s32 core_id) {
return (s_core_mask & (1ull << core_id)) != 0;
@ -40,12 +41,35 @@ namespace ams::kern {
public:
virtual void DoTask() { /* ... */ }
static void Request(KDpcTask *task) {
KScopedLightLock rlk(s_req_lock);
/* Acquire the requested task. */
MESOSPHERE_ABORT_UNLESS(s_task == nullptr);
s_task = task;
{
KScopedLightLock lk(s_lock);
MESOSPHERE_ABORT_UNLESS(s_core_mask == 0);
for (auto core = 0; core < static_cast<s32>(cpu::NumCores); ++core) {
SetRequest(core);
}
s_cond_var.Broadcast();
while (s_core_mask != 0) {
s_cond_var.Wait(std::addressof(s_lock), -1ll);
}
}
s_task = nullptr;
}
static void WaitForRequest() {
/* Wait for a request to come in. */
const auto core_id = GetCurrentCoreId();
KScopedLightLock lk(s_lock);
while (!HasRequest(core_id)) {
s_cond_var.Wait(&s_lock, -1ll);
s_cond_var.Wait(std::addressof(s_lock), -1ll);
}
}
@ -54,7 +78,7 @@ namespace ams::kern {
const auto core_id = GetCurrentCoreId();
KScopedLightLock lk(s_lock);
while (!HasRequest(core_id)) {
s_cond_var.Wait(&s_lock, timeout);
s_cond_var.Wait(std::addressof(s_lock), timeout);
if (KHardwareTimer::GetTick() >= timeout) {
return false;
}
@ -147,6 +171,9 @@ namespace ams::kern {
}
void KDpcManager::HandleDpc() {
MESOSPHERE_ASSERT(!KInterruptManager::AreInterruptsEnabled());
MESOSPHERE_ASSERT(!KScheduler::IsSchedulerLockedByCurrentThread());
/* The only deferred procedure supported by Horizon is thread termination. */
/* Check if we need to terminate the current thread. */
KThread *cur_thread = GetCurrentThreadPointer();
@ -156,4 +183,11 @@ namespace ams::kern {
}
}
void KDpcManager::Sync() {
MESOSPHERE_ASSERT(!KScheduler::IsSchedulerLockedByCurrentThread());
KDpcTask dummy_task;
KDpcTask::Request(std::addressof(dummy_task));
}
}