aboutsummaryrefslogtreecommitdiff
path: root/src/Ryujinx.HLE/HOS/Kernel/Threading/KReadableEvent.cs
diff options
context:
space:
mode:
Diffstat (limited to 'src/Ryujinx.HLE/HOS/Kernel/Threading/KReadableEvent.cs')
-rw-r--r--src/Ryujinx.HLE/HOS/Kernel/Threading/KReadableEvent.cs65
1 files changed, 65 insertions, 0 deletions
diff --git a/src/Ryujinx.HLE/HOS/Kernel/Threading/KReadableEvent.cs b/src/Ryujinx.HLE/HOS/Kernel/Threading/KReadableEvent.cs
new file mode 100644
index 00000000..d9e7befa
--- /dev/null
+++ b/src/Ryujinx.HLE/HOS/Kernel/Threading/KReadableEvent.cs
@@ -0,0 +1,65 @@
+using Ryujinx.HLE.HOS.Kernel.Common;
+using Ryujinx.Horizon.Common;
+
+namespace Ryujinx.HLE.HOS.Kernel.Threading
+{
+ class KReadableEvent : KSynchronizationObject
+ {
+ private readonly KEvent _parent;
+
+ private bool _signaled;
+
+ public KReadableEvent(KernelContext context, KEvent parent) : base(context)
+ {
+ _parent = parent;
+ }
+
+ public override void Signal()
+ {
+ KernelContext.CriticalSection.Enter();
+
+ if (!_signaled)
+ {
+ _signaled = true;
+
+ base.Signal();
+ }
+
+ KernelContext.CriticalSection.Leave();
+ }
+
+ public Result Clear()
+ {
+ _signaled = false;
+
+ return Result.Success;
+ }
+
+ public Result ClearIfSignaled()
+ {
+ Result result;
+
+ KernelContext.CriticalSection.Enter();
+
+ if (_signaled)
+ {
+ _signaled = false;
+
+ result = Result.Success;
+ }
+ else
+ {
+ result = KernelResult.InvalidState;
+ }
+
+ KernelContext.CriticalSection.Leave();
+
+ return result;
+ }
+
+ public override bool IsSignaled()
+ {
+ return _signaled;
+ }
+ }
+} \ No newline at end of file