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
---
 Ryujinx.HLE/HOS/Kernel/Threading/HleCoreManager.cs | 66 ++++++++++++++++++++++
 1 file changed, 66 insertions(+)
 create mode 100644 Ryujinx.HLE/HOS/Kernel/Threading/HleCoreManager.cs

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

diff --git a/Ryujinx.HLE/HOS/Kernel/Threading/HleCoreManager.cs b/Ryujinx.HLE/HOS/Kernel/Threading/HleCoreManager.cs
new file mode 100644
index 00000000..c2597990
--- /dev/null
+++ b/Ryujinx.HLE/HOS/Kernel/Threading/HleCoreManager.cs
@@ -0,0 +1,66 @@
+using System.Collections.Concurrent;
+using System.Threading;
+
+namespace Ryujinx.HLE.HOS.Kernel.Threading
+{
+    class HleCoreManager
+    {
+        private class PausableThread
+        {
+            public ManualResetEvent Event { get; private set; }
+
+            public bool IsExiting { get; set; }
+
+            public PausableThread()
+            {
+                Event = new ManualResetEvent(false);
+            }
+        }
+
+        private ConcurrentDictionary<Thread, PausableThread> _threads;
+
+        public HleCoreManager()
+        {
+            _threads = new ConcurrentDictionary<Thread, PausableThread>();
+        }
+
+        public void Set(Thread thread)
+        {
+            GetThread(thread).Event.Set();
+        }
+
+        public void Reset(Thread thread)
+        {
+            GetThread(thread).Event.Reset();
+        }
+
+        public void Wait(Thread thread)
+        {
+            PausableThread pausableThread = GetThread(thread);
+
+            if (!pausableThread.IsExiting)
+            {
+                pausableThread.Event.WaitOne();
+            }
+        }
+
+        public void Exit(Thread thread)
+        {
+            GetThread(thread).IsExiting = true;
+        }
+
+        private PausableThread GetThread(Thread thread)
+        {
+            return _threads.GetOrAdd(thread, (key) => new PausableThread());
+        }
+
+        public void RemoveThread(Thread thread)
+        {
+            if (_threads.TryRemove(thread, out PausableThread pausableThread))
+            {
+                pausableThread.Event.Set();
+                pausableThread.Event.Dispose();
+            }
+        }
+    }
+}
\ No newline at end of file
-- 
cgit v1.2.3