From 0039bb639493b2d1e2764cae380311ba8e87704b Mon Sep 17 00:00:00 2001
From: gdkchan <gab.dark.100@gmail.com>
Date: Tue, 18 Dec 2018 03:33:36 -0200
Subject: Refactor SVC handler (#540)
* Refactor SVC handler
* Get rid of KernelErr
* Split kernel code files into multiple folders
---
.../HOS/Kernel/Threading/KConditionVariable.cs | 71 ++++++++++++++++++++++
1 file changed, 71 insertions(+)
create mode 100644 Ryujinx.HLE/HOS/Kernel/Threading/KConditionVariable.cs
(limited to 'Ryujinx.HLE/HOS/Kernel/Threading/KConditionVariable.cs')
diff --git a/Ryujinx.HLE/HOS/Kernel/Threading/KConditionVariable.cs b/Ryujinx.HLE/HOS/Kernel/Threading/KConditionVariable.cs
new file mode 100644
index 00000000..41473643
--- /dev/null
+++ b/Ryujinx.HLE/HOS/Kernel/Threading/KConditionVariable.cs
@@ -0,0 +1,71 @@
+using System.Collections.Generic;
+using System.Threading;
+
+namespace Ryujinx.HLE.HOS.Kernel.Threading
+{
+ static class KConditionVariable
+ {
+ public static void Wait(Horizon system, LinkedList<KThread> threadList, object mutex, long timeout)
+ {
+ KThread currentThread = system.Scheduler.GetCurrentThread();
+
+ system.CriticalSection.Enter();
+
+ Monitor.Exit(mutex);
+
+ currentThread.Withholder = threadList;
+
+ currentThread.Reschedule(ThreadSchedState.Paused);
+
+ currentThread.WithholderNode = threadList.AddLast(currentThread);
+
+ if (currentThread.ShallBeTerminated ||
+ currentThread.SchedFlags == ThreadSchedState.TerminationPending)
+ {
+ threadList.Remove(currentThread.WithholderNode);
+
+ currentThread.Reschedule(ThreadSchedState.Running);
+
+ currentThread.Withholder = null;
+
+ system.CriticalSection.Leave();
+ }
+ else
+ {
+ if (timeout > 0)
+ {
+ system.TimeManager.ScheduleFutureInvocation(currentThread, timeout);
+ }
+
+ system.CriticalSection.Leave();
+
+ if (timeout > 0)
+ {
+ system.TimeManager.UnscheduleFutureInvocation(currentThread);
+ }
+ }
+
+ Monitor.Enter(mutex);
+ }
+
+ public static void NotifyAll(Horizon system, LinkedList<KThread> threadList)
+ {
+ system.CriticalSection.Enter();
+
+ LinkedListNode<KThread> node = threadList.First;
+
+ for (; node != null; node = threadList.First)
+ {
+ KThread thread = node.Value;
+
+ threadList.Remove(thread.WithholderNode);
+
+ thread.Withholder = null;
+
+ thread.Reschedule(ThreadSchedState.Running);
+ }
+
+ system.CriticalSection.Leave();
+ }
+ }
+}
\ No newline at end of file
--
cgit v1.2.3-70-g09d2