summaryrefslogtreecommitdiffstats
path: root/src/core/hle
diff options
context:
space:
mode:
Diffstat (limited to 'src/core/hle')
-rw-r--r--src/core/hle/kernel/scheduler.cpp37
-rw-r--r--src/core/hle/kernel/scheduler.h9
2 files changed, 35 insertions, 11 deletions
diff --git a/src/core/hle/kernel/scheduler.cpp b/src/core/hle/kernel/scheduler.cpp
index 9329202c6..aa1f1a305 100644
--- a/src/core/hle/kernel/scheduler.cpp
+++ b/src/core/hle/kernel/scheduler.cpp
@@ -53,7 +53,8 @@ u32 GlobalScheduler::SelectThreads() {
}
sched.selected_thread_set = SharedFrom(thread);
}
- const bool reschedule_pending = sched.selected_thread_set != sched.current_thread;
+ const bool reschedule_pending =
+ sched.is_context_switch_pending || (sched.selected_thread_set != sched.current_thread);
sched.is_context_switch_pending = reschedule_pending;
std::atomic_thread_fence(std::memory_order_seq_cst);
sched.guard.unlock();
@@ -552,7 +553,9 @@ void GlobalScheduler::Unlock() {
}
Scheduler::Scheduler(Core::System& system, std::size_t core_id)
- : system{system}, core_id{core_id} {}
+ : system(system), core_id(core_id) {
+ switch_fiber = std::make_shared<Common::Fiber>(std::function<void(void*)>(OnSwitch), this);
+}
Scheduler::~Scheduler() = default;
@@ -636,8 +639,9 @@ void Scheduler::SwitchContext() {
current_thread = selected_thread;
is_context_switch_pending = false;
- guard.unlock();
+
if (new_thread == previous_thread) {
+ guard.unlock();
return;
}
@@ -669,20 +673,31 @@ void Scheduler::SwitchContext() {
} else {
old_context = idle_thread->GetHostContext();
}
+ guard.unlock();
- std::shared_ptr<Common::Fiber> next_context;
- if (new_thread != nullptr) {
- next_context = new_thread->GetHostContext();
- } else {
- next_context = idle_thread->GetHostContext();
- }
-
- Common::Fiber::YieldTo(old_context, next_context);
+ Common::Fiber::YieldTo(old_context, switch_fiber);
/// When a thread wakes up, the scheduler may have changed to other in another core.
auto& next_scheduler = system.Kernel().CurrentScheduler();
next_scheduler.SwitchContextStep2();
}
+void Scheduler::OnSwitch(void* this_scheduler) {
+ Scheduler* sched = static_cast<Scheduler*>(this_scheduler);
+ sched->SwitchToCurrent();
+}
+
+void Scheduler::SwitchToCurrent() {
+ while (true) {
+ std::shared_ptr<Common::Fiber> next_context;
+ if (current_thread != nullptr) {
+ next_context = current_thread->GetHostContext();
+ } else {
+ next_context = idle_thread->GetHostContext();
+ }
+ Common::Fiber::YieldTo(switch_fiber, next_context);
+ }
+}
+
void Scheduler::UpdateLastContextSwitchTime(Thread* thread, Process* process) {
const u64 prev_switch_ticks = last_context_switch_time;
const u64 most_recent_switch_ticks = system.CoreTiming().GetCPUTicks();
diff --git a/src/core/hle/kernel/scheduler.h b/src/core/hle/kernel/scheduler.h
index f73ca777e..728cca802 100644
--- a/src/core/hle/kernel/scheduler.h
+++ b/src/core/hle/kernel/scheduler.h
@@ -15,6 +15,10 @@
#include "core/hardware_properties.h"
#include "core/hle/kernel/thread.h"
+namespace Common {
+ class Fiber;
+}
+
namespace Core {
class ARM_Interface;
class System;
@@ -247,12 +251,17 @@ private:
*/
void UpdateLastContextSwitchTime(Thread* thread, Process* process);
+ static void OnSwitch(void* this_scheduler);
+ void SwitchToCurrent();
+
std::shared_ptr<Thread> current_thread = nullptr;
std::shared_ptr<Thread> selected_thread = nullptr;
std::shared_ptr<Thread> current_thread_prev = nullptr;
std::shared_ptr<Thread> selected_thread_set = nullptr;
std::shared_ptr<Thread> idle_thread = nullptr;
+ std::shared_ptr<Common::Fiber> switch_fiber = nullptr;
+
Core::System& system;
u64 last_context_switch_time = 0;
u64 idle_selection_count = 0;