From b8133c19971c7a2026af803003fafedbdb70488e Mon Sep 17 00:00:00 2001
From: gdkchan <gab.dark.100@gmail.com>
Date: Tue, 18 Sep 2018 20:36:43 -0300
Subject: Thread scheduler rewrite (#393)

* Started to rewrite the thread scheduler

* Add a single core-like scheduling mode, enabled by default

* Clear exclusive monitor on context switch

* Add SetThreadActivity, misc fixes

* Implement WaitForAddress and SignalToAddress svcs, misc fixes

* Misc fixes (on SetActivity and Arbiter), other tweaks

* Rebased

* Add missing null check

* Rename multicore key on config, fix UpdatePriorityInheritance

* Make scheduling data MLQs private

* nit: Ordering
---
 Ryujinx.HLE/HOS/Kernel/KSynchronizationObject.cs | 36 +++++++++++++++---------
 1 file changed, 23 insertions(+), 13 deletions(-)

(limited to 'Ryujinx.HLE/HOS/Kernel/KSynchronizationObject.cs')

diff --git a/Ryujinx.HLE/HOS/Kernel/KSynchronizationObject.cs b/Ryujinx.HLE/HOS/Kernel/KSynchronizationObject.cs
index b83b0004..28eac330 100644
--- a/Ryujinx.HLE/HOS/Kernel/KSynchronizationObject.cs
+++ b/Ryujinx.HLE/HOS/Kernel/KSynchronizationObject.cs
@@ -1,28 +1,38 @@
-using System;
-using System.Threading;
+using System.Collections.Generic;
 
 namespace Ryujinx.HLE.HOS.Kernel
 {
-    class KSynchronizationObject : IDisposable
+    class KSynchronizationObject
     {
-        public ManualResetEvent WaitEvent { get; private set; }
+        public LinkedList<KThread> WaitingThreads;
 
-        public KSynchronizationObject()
+        protected Horizon System;
+
+        public KSynchronizationObject(Horizon System)
+        {
+            this.System = System;
+
+            WaitingThreads = new LinkedList<KThread>();
+        }
+
+        public LinkedListNode<KThread> AddWaitingThread(KThread Thread)
+        {
+            return WaitingThreads.AddLast(Thread);
+        }
+
+        public void RemoveWaitingThread(LinkedListNode<KThread> Node)
         {
-            WaitEvent = new ManualResetEvent(false);
+            WaitingThreads.Remove(Node);
         }
 
-        public void Dispose()
+        public virtual void Signal()
         {
-            Dispose(true);
+            System.Synchronization.SignalObject(this);
         }
 
-        protected virtual void Dispose(bool Disposing)
+        public virtual bool IsSignaled()
         {
-            if (Disposing)
-            {
-                WaitEvent.Dispose();
-            }
+            return false;
         }
     }
 }
\ No newline at end of file
-- 
cgit v1.2.3