1 files changed, 89 insertions, 0 deletions
diff --git a/Ryujinx.Horizon/Sdk/Sf/Hipc/Api.cs b/Ryujinx.Horizon/Sdk/Sf/Hipc/Api.cs
new file mode 100644
index 00000000..deac524c
--- /dev/null
+++ b/Ryujinx.Horizon/Sdk/Sf/Hipc/Api.cs
@@ -0,0 +1,89 @@
+using Ryujinx.Horizon.Common;
+using System;
+
+namespace Ryujinx.Horizon.Sdk.Sf.Hipc
+{
+    static class Api
+    {
+        public const int TlsMessageBufferSize = 0x100;
+
+        public static Result Receive(out ReceiveResult recvResult, int sessionHandle, Span<byte> messageBuffer)
+        {
+            Result result = ReceiveImpl(sessionHandle, messageBuffer);
+
+            if (result == KernelResult.PortRemoteClosed)
+            {
+                recvResult = ReceiveResult.Closed;
+
+                return Result.Success;
+            }
+            else if (result == KernelResult.ReceiveListBroken)
+            {
+                recvResult = ReceiveResult.NeedsRetry;
+
+                return Result.Success;
+            }
+
+            recvResult = ReceiveResult.Success;
+
+            return result;
+        }
+
+        private static Result ReceiveImpl(int sessionHandle, Span<byte> messageBuffer)
+        {
+            Span<int> handles = stackalloc int[1];
+
+            handles[0] = sessionHandle;
+
+            var tlsSpan = HorizonStatic.AddressSpace.GetSpan(HorizonStatic.ThreadContext.TlsAddress, TlsMessageBufferSize);
+
+            if (messageBuffer == tlsSpan)
+            {
+                return HorizonStatic.Syscall.ReplyAndReceive(out _, handles, 0, -1L);
+            }
+            else
+            {
+                throw new NotImplementedException();
+            }
+        }
+
+        public static Result Reply(int sessionHandle, ReadOnlySpan<byte> messageBuffer)
+        {
+            Result result = ReplyImpl(sessionHandle, messageBuffer);
+
+            result.AbortUnless(KernelResult.TimedOut, KernelResult.PortRemoteClosed);
+
+            return Result.Success;
+        }
+
+        private static Result ReplyImpl(int sessionHandle, ReadOnlySpan<byte> messageBuffer)
+        {
+            Span<int> handles = stackalloc int[1];
+
+            handles[0] = sessionHandle;
+
+            var tlsSpan = HorizonStatic.AddressSpace.GetSpan(HorizonStatic.ThreadContext.TlsAddress, TlsMessageBufferSize);
+
+            if (messageBuffer == tlsSpan)
+            {
+                return HorizonStatic.Syscall.ReplyAndReceive(out _, handles, sessionHandle, 0);
+            }
+            else
+            {
+                throw new NotImplementedException();
+            }
+        }
+
+        public static Result CreateSession(out int serverHandle, out int clientHandle)
+        {
+            Result result = HorizonStatic.Syscall.CreateSession(out serverHandle, out clientHandle, false, null);
+
+            if (result == KernelResult.OutOfResource)
+            {
+                return HipcResult.OutOfSessions;
+            }
+
+            return result;
+        }
+    }
+}