aboutsummaryrefslogtreecommitdiff
path: root/Ryujinx.HLE/HOS/Kernel/Threading/KSchedulingData.cs
diff options
context:
space:
mode:
authorgdkchan <gab.dark.100@gmail.com>2020-12-09 19:20:05 -0300
committerGitHub <noreply@github.com>2020-12-09 19:20:05 -0300
commit48278905d1470f89be31668c738397f569af156a (patch)
tree2e35b0695b33c8eb723f5948e3f6f040d84cfe76 /Ryujinx.HLE/HOS/Kernel/Threading/KSchedulingData.cs
parent3484265d37732b32951709e5abfa52a260db349d (diff)
Rewrite scheduler context switch code (#1786)
* Rewrite scheduler context switch code * Fix race in UnmapIpcRestorePermission * Fix thread exit issue that could leave the scheduler in a invalid state * Change context switch method to not wait on guest thread, remove spin wait, use SignalAndWait to pass control * Remove multi-core setting (it is always on now) * Re-enable assert * Remove multicore from default config and schema * Fix race in KTimeManager
Diffstat (limited to 'Ryujinx.HLE/HOS/Kernel/Threading/KSchedulingData.cs')
-rw-r--r--Ryujinx.HLE/HOS/Kernel/Threading/KSchedulingData.cs207
1 files changed, 0 insertions, 207 deletions
diff --git a/Ryujinx.HLE/HOS/Kernel/Threading/KSchedulingData.cs b/Ryujinx.HLE/HOS/Kernel/Threading/KSchedulingData.cs
deleted file mode 100644
index 83c4a079..00000000
--- a/Ryujinx.HLE/HOS/Kernel/Threading/KSchedulingData.cs
+++ /dev/null
@@ -1,207 +0,0 @@
-using System.Collections.Generic;
-
-namespace Ryujinx.HLE.HOS.Kernel.Threading
-{
- class KSchedulingData
- {
- private LinkedList<KThread>[][] _scheduledThreadsPerPrioPerCore;
- private LinkedList<KThread>[][] _suggestedThreadsPerPrioPerCore;
-
- private long[] _scheduledPrioritiesPerCore;
- private long[] _suggestedPrioritiesPerCore;
-
- public KSchedulingData()
- {
- _suggestedThreadsPerPrioPerCore = new LinkedList<KThread>[KScheduler.PrioritiesCount][];
- _scheduledThreadsPerPrioPerCore = new LinkedList<KThread>[KScheduler.PrioritiesCount][];
-
- for (int prio = 0; prio < KScheduler.PrioritiesCount; prio++)
- {
- _suggestedThreadsPerPrioPerCore[prio] = new LinkedList<KThread>[KScheduler.CpuCoresCount];
- _scheduledThreadsPerPrioPerCore[prio] = new LinkedList<KThread>[KScheduler.CpuCoresCount];
-
- for (int core = 0; core < KScheduler.CpuCoresCount; core++)
- {
- _suggestedThreadsPerPrioPerCore[prio][core] = new LinkedList<KThread>();
- _scheduledThreadsPerPrioPerCore[prio][core] = new LinkedList<KThread>();
- }
- }
-
- _scheduledPrioritiesPerCore = new long[KScheduler.CpuCoresCount];
- _suggestedPrioritiesPerCore = new long[KScheduler.CpuCoresCount];
- }
-
- public IEnumerable<KThread> SuggestedThreads(int core)
- {
- return Iterate(_suggestedThreadsPerPrioPerCore, _suggestedPrioritiesPerCore, core);
- }
-
- public IEnumerable<KThread> ScheduledThreads(int core)
- {
- return Iterate(_scheduledThreadsPerPrioPerCore, _scheduledPrioritiesPerCore, core);
- }
-
- private IEnumerable<KThread> Iterate(LinkedList<KThread>[][] listPerPrioPerCore, long[] prios, int core)
- {
- long prioMask = prios[core];
-
- int prio = CountTrailingZeros(prioMask);
-
- prioMask &= ~(1L << prio);
-
- while (prio < KScheduler.PrioritiesCount)
- {
- LinkedList<KThread> list = listPerPrioPerCore[prio][core];
-
- LinkedListNode<KThread> node = list.First;
-
- while (node != null)
- {
- yield return node.Value;
-
- node = node.Next;
- }
-
- prio = CountTrailingZeros(prioMask);
-
- prioMask &= ~(1L << prio);
- }
- }
-
- private int CountTrailingZeros(long value)
- {
- int count = 0;
-
- while (((value >> count) & 0xf) == 0 && count < 64)
- {
- count += 4;
- }
-
- while (((value >> count) & 1) == 0 && count < 64)
- {
- count++;
- }
-
- return count;
- }
-
- public void TransferToCore(int prio, int dstCore, KThread thread)
- {
- bool schedulable = thread.DynamicPriority < KScheduler.PrioritiesCount;
-
- int srcCore = thread.CurrentCore;
-
- thread.CurrentCore = dstCore;
-
- if (srcCore == dstCore || !schedulable)
- {
- return;
- }
-
- if (srcCore >= 0)
- {
- Unschedule(prio, srcCore, thread);
- }
-
- if (dstCore >= 0)
- {
- Unsuggest(prio, dstCore, thread);
- Schedule(prio, dstCore, thread);
- }
-
- if (srcCore >= 0)
- {
- Suggest(prio, srcCore, thread);
- }
- }
-
- public void Suggest(int prio, int core, KThread thread)
- {
- if (prio >= KScheduler.PrioritiesCount)
- {
- return;
- }
-
- thread.SiblingsPerCore[core] = SuggestedQueue(prio, core).AddFirst(thread);
-
- _suggestedPrioritiesPerCore[core] |= 1L << prio;
- }
-
- public void Unsuggest(int prio, int core, KThread thread)
- {
- if (prio >= KScheduler.PrioritiesCount)
- {
- return;
- }
-
- LinkedList<KThread> queue = SuggestedQueue(prio, core);
-
- queue.Remove(thread.SiblingsPerCore[core]);
-
- if (queue.First == null)
- {
- _suggestedPrioritiesPerCore[core] &= ~(1L << prio);
- }
- }
-
- public void Schedule(int prio, int core, KThread thread)
- {
- if (prio >= KScheduler.PrioritiesCount)
- {
- return;
- }
-
- thread.SiblingsPerCore[core] = ScheduledQueue(prio, core).AddLast(thread);
-
- _scheduledPrioritiesPerCore[core] |= 1L << prio;
- }
-
- public void SchedulePrepend(int prio, int core, KThread thread)
- {
- if (prio >= KScheduler.PrioritiesCount)
- {
- return;
- }
-
- thread.SiblingsPerCore[core] = ScheduledQueue(prio, core).AddFirst(thread);
-
- _scheduledPrioritiesPerCore[core] |= 1L << prio;
- }
-
- public void Reschedule(int prio, int core, KThread thread)
- {
- LinkedList<KThread> queue = ScheduledQueue(prio, core);
-
- queue.Remove(thread.SiblingsPerCore[core]);
-
- thread.SiblingsPerCore[core] = queue.AddLast(thread);
- }
-
- public void Unschedule(int prio, int core, KThread thread)
- {
- if (prio >= KScheduler.PrioritiesCount)
- {
- return;
- }
-
- LinkedList<KThread> queue = ScheduledQueue(prio, core);
-
- queue.Remove(thread.SiblingsPerCore[core]);
-
- if (queue.First == null)
- {
- _scheduledPrioritiesPerCore[core] &= ~(1L << prio);
- }
- }
-
- private LinkedList<KThread> SuggestedQueue(int prio, int core)
- {
- return _suggestedThreadsPerPrioPerCore[prio][core];
- }
-
- private LinkedList<KThread> ScheduledQueue(int prio, int core)
- {
- return _scheduledThreadsPerPrioPerCore[prio][core];
- }
- }
-} \ No newline at end of file