1 files changed, 109 insertions, 0 deletions
diff --git a/src/Ryujinx.Audio/Renderer/Server/Sink/CircularBufferSink.cs b/src/Ryujinx.Audio/Renderer/Server/Sink/CircularBufferSink.cs
new file mode 100644
index 00000000..722d8c4b
--- /dev/null
+++ b/src/Ryujinx.Audio/Renderer/Server/Sink/CircularBufferSink.cs
@@ -0,0 +1,109 @@
+using Ryujinx.Audio.Renderer.Common;
+using Ryujinx.Audio.Renderer.Parameter;
+using Ryujinx.Audio.Renderer.Parameter.Sink;
+using Ryujinx.Audio.Renderer.Server.MemoryPool;
+using System.Diagnostics;
+using System.Runtime.InteropServices;
+
+namespace Ryujinx.Audio.Renderer.Server.Sink
+{
+    /// <summary>
+    /// Server information for a circular buffer sink.
+    /// </summary>
+    public class CircularBufferSink : BaseSink
+    {
+        /// <summary>
+        /// The circular buffer parameter.
+        /// </summary>
+        public CircularBufferParameter Parameter;
+
+        /// <summary>
+        /// The last written data offset on the circular buffer.
+        /// </summary>
+        private uint _lastWrittenOffset;
+
+        /// <summary>
+        /// THe previous written offset of the circular buffer.
+        /// </summary>
+        private uint _oldWrittenOffset;
+
+        /// <summary>
+        /// The current offset to write data on the circular buffer.
+        /// </summary>
+        public uint CurrentWriteOffset { get; private set; }
+
+        /// <summary>
+        /// The <see cref="AddressInfo"/> of the circular buffer.
+        /// </summary>
+        public AddressInfo CircularBufferAddressInfo;
+
+        public CircularBufferSink()
+        {
+            CircularBufferAddressInfo = AddressInfo.Create();
+        }
+
+        public override SinkType TargetSinkType => SinkType.CircularBuffer;
+
+        public override void Update(out BehaviourParameter.ErrorInfo errorInfo, ref SinkInParameter parameter, ref SinkOutStatus outStatus, PoolMapper mapper)
+        {
+            errorInfo = new BehaviourParameter.ErrorInfo();
+            outStatus = new SinkOutStatus();
+
+            Debug.Assert(IsTypeValid(ref parameter));
+
+            ref CircularBufferParameter inputDeviceParameter = ref MemoryMarshal.Cast<byte, CircularBufferParameter>(parameter.SpecificData)[0];
+
+            if (parameter.IsUsed != IsUsed || ShouldSkip)
+            {
+                UpdateStandardParameter(ref parameter);
+
+                if (parameter.IsUsed)
+                {
+                    Debug.Assert(CircularBufferAddressInfo.CpuAddress == 0);
+                    Debug.Assert(CircularBufferAddressInfo.GetReference(false) == 0);
+
+                    ShouldSkip = !mapper.TryAttachBuffer(out errorInfo, ref CircularBufferAddressInfo, inputDeviceParameter.BufferAddress, inputDeviceParameter.BufferSize);
+                }
+                else
+                {
+                    Debug.Assert(CircularBufferAddressInfo.CpuAddress != 0);
+                    Debug.Assert(CircularBufferAddressInfo.GetReference(false) != 0);
+                }
+
+                Parameter = inputDeviceParameter;
+            }
+
+            outStatus.LastWrittenOffset = _lastWrittenOffset;
+        }
+
+        public override void UpdateForCommandGeneration()
+        {
+            Debug.Assert(Type == TargetSinkType);
+
+            if (IsUsed)
+            {
+                uint frameSize = Constants.TargetSampleSize * Parameter.SampleCount * Parameter.InputCount;
+
+                _lastWrittenOffset = _oldWrittenOffset;
+
+                _oldWrittenOffset = CurrentWriteOffset;
+
+                CurrentWriteOffset += frameSize;
+
+                if (Parameter.BufferSize > 0)
+                {
+                    CurrentWriteOffset %= Parameter.BufferSize;
+                }
+            }
+        }
+
+        public override void CleanUp()
+        {
+            CircularBufferAddressInfo = AddressInfo.Create();
+            _lastWrittenOffset = 0;
+            _oldWrittenOffset = 0;
+            CurrentWriteOffset = 0;
+            base.CleanUp();
+        }
+    }
+}
+\ No newline at end of file