aboutsummaryrefslogtreecommitdiff
path: root/Ryujinx.HLE/HOS/Services/Sockets/Bsd/Impl/EventFileDescriptor.cs
diff options
context:
space:
mode:
authorTSR Berry <20988865+TSRBerry@users.noreply.github.com>2023-04-08 01:22:00 +0200
committerMary <thog@protonmail.com>2023-04-27 23:51:14 +0200
commitcee712105850ac3385cd0091a923438167433f9f (patch)
tree4a5274b21d8b7f938c0d0ce18736d3f2993b11b1 /Ryujinx.HLE/HOS/Services/Sockets/Bsd/Impl/EventFileDescriptor.cs
parentcd124bda587ef09668a971fa1cac1c3f0cfc9f21 (diff)
Move solution and projects to src
Diffstat (limited to 'Ryujinx.HLE/HOS/Services/Sockets/Bsd/Impl/EventFileDescriptor.cs')
-rw-r--r--Ryujinx.HLE/HOS/Services/Sockets/Bsd/Impl/EventFileDescriptor.cs153
1 files changed, 0 insertions, 153 deletions
diff --git a/Ryujinx.HLE/HOS/Services/Sockets/Bsd/Impl/EventFileDescriptor.cs b/Ryujinx.HLE/HOS/Services/Sockets/Bsd/Impl/EventFileDescriptor.cs
deleted file mode 100644
index 6514d485..00000000
--- a/Ryujinx.HLE/HOS/Services/Sockets/Bsd/Impl/EventFileDescriptor.cs
+++ /dev/null
@@ -1,153 +0,0 @@
-using Ryujinx.HLE.HOS.Services.Sockets.Bsd.Types;
-using System;
-using System.Runtime.InteropServices;
-using System.Threading;
-
-namespace Ryujinx.HLE.HOS.Services.Sockets.Bsd.Impl
-{
- class EventFileDescriptor : IFileDescriptor
- {
- private ulong _value;
- private readonly EventFdFlags _flags;
-
- private object _lock = new object();
-
- public bool Blocking { get => !_flags.HasFlag(EventFdFlags.NonBlocking); set => throw new NotSupportedException(); }
-
- public ManualResetEvent WriteEvent { get; }
- public ManualResetEvent ReadEvent { get; }
-
- public EventFileDescriptor(ulong value, EventFdFlags flags)
- {
- // FIXME: We should support blocking operations.
- // Right now they can't be supported because it would cause the
- // service to lock up as we only have one thread processing requests.
- flags |= EventFdFlags.NonBlocking;
-
- _value = value;
- _flags = flags;
-
- WriteEvent = new ManualResetEvent(false);
- ReadEvent = new ManualResetEvent(false);
- UpdateEventStates();
- }
-
- public int Refcount { get; set; }
-
- public void Dispose()
- {
- WriteEvent.Dispose();
- ReadEvent.Dispose();
- }
-
- private void ResetEventStates()
- {
- WriteEvent.Reset();
- ReadEvent.Reset();
- }
-
- private void UpdateEventStates()
- {
- if (_value > 0)
- {
- ReadEvent.Set();
- }
-
- if (_value != uint.MaxValue - 1)
- {
- WriteEvent.Set();
- }
- }
-
- public LinuxError Read(out int readSize, Span<byte> buffer)
- {
- if (buffer.Length < sizeof(ulong))
- {
- readSize = 0;
-
- return LinuxError.EINVAL;
- }
-
- lock (_lock)
- {
- ResetEventStates();
-
- ref ulong count = ref MemoryMarshal.Cast<byte, ulong>(buffer)[0];
-
- if (_value == 0)
- {
- if (Blocking)
- {
- while (_value == 0)
- {
- Monitor.Wait(_lock);
- }
- }
- else
- {
- readSize = 0;
-
- UpdateEventStates();
- return LinuxError.EAGAIN;
- }
- }
-
- readSize = sizeof(ulong);
-
- if (_flags.HasFlag(EventFdFlags.Semaphore))
- {
- --_value;
-
- count = 1;
- }
- else
- {
- count = _value;
-
- _value = 0;
- }
-
- UpdateEventStates();
- return LinuxError.SUCCESS;
- }
- }
-
- public LinuxError Write(out int writeSize, ReadOnlySpan<byte> buffer)
- {
- if (!MemoryMarshal.TryRead(buffer, out ulong count) || count == ulong.MaxValue)
- {
- writeSize = 0;
-
- return LinuxError.EINVAL;
- }
-
- lock (_lock)
- {
- ResetEventStates();
-
- if (_value > _value + count)
- {
- if (Blocking)
- {
- Monitor.Wait(_lock);
- }
- else
- {
- writeSize = 0;
-
- UpdateEventStates();
- return LinuxError.EAGAIN;
- }
- }
-
- writeSize = sizeof(ulong);
-
- _value += count;
- Monitor.Pulse(_lock);
-
- UpdateEventStates();
- return LinuxError.SUCCESS;
- }
- }
- }
-} \ No newline at end of file