From cee712105850ac3385cd0091a923438167433f9f Mon Sep 17 00:00:00 2001
From: TSR Berry <20988865+TSRBerry@users.noreply.github.com>
Date: Sat, 8 Apr 2023 01:22:00 +0200
Subject: Move solution and projects to src
---
src/Ryujinx.Audio/Input/AudioInputManager.cs | 266 ++++++++++++++++++
src/Ryujinx.Audio/Input/AudioInputSystem.cs | 392 +++++++++++++++++++++++++++
2 files changed, 658 insertions(+)
create mode 100644 src/Ryujinx.Audio/Input/AudioInputManager.cs
create mode 100644 src/Ryujinx.Audio/Input/AudioInputSystem.cs
(limited to 'src/Ryujinx.Audio/Input')
diff --git a/src/Ryujinx.Audio/Input/AudioInputManager.cs b/src/Ryujinx.Audio/Input/AudioInputManager.cs
new file mode 100644
index 00000000..ac012c4a
--- /dev/null
+++ b/src/Ryujinx.Audio/Input/AudioInputManager.cs
@@ -0,0 +1,266 @@
+using Ryujinx.Audio.Common;
+using Ryujinx.Audio.Integration;
+using Ryujinx.Common.Logging;
+using Ryujinx.Memory;
+using System;
+using System.Diagnostics;
+using System.Linq;
+using System.Threading;
+
+namespace Ryujinx.Audio.Input
+{
+ ///
+ /// The audio input manager.
+ ///
+ public class AudioInputManager : IDisposable
+ {
+ private object _lock = new object();
+
+ ///
+ /// Lock used for session allocation.
+ ///
+ private object _sessionLock = new object();
+
+ ///
+ /// The session ids allocation table.
+ ///
+ private int[] _sessionIds;
+
+ ///
+ /// The device driver.
+ ///
+ private IHardwareDeviceDriver _deviceDriver;
+
+ ///
+ /// The events linked to each session.
+ ///
+ private IWritableEvent[] _sessionsBufferEvents;
+
+ ///
+ /// The session instances.
+ ///
+ private AudioInputSystem[] _sessions;
+
+ ///
+ /// The count of active sessions.
+ ///
+ private int _activeSessionCount;
+
+ ///
+ /// The dispose state.
+ ///
+ private int _disposeState;
+
+ ///
+ /// Create a new .
+ ///
+ public AudioInputManager()
+ {
+ _sessionIds = new int[Constants.AudioInSessionCountMax];
+ _sessions = new AudioInputSystem[Constants.AudioInSessionCountMax];
+ _activeSessionCount = 0;
+
+ for (int i = 0; i < _sessionIds.Length; i++)
+ {
+ _sessionIds[i] = i;
+ }
+ }
+
+ ///
+ /// Initialize the .
+ ///
+ /// The device driver.
+ /// The events associated to each session.
+ public void Initialize(IHardwareDeviceDriver deviceDriver, IWritableEvent[] sessionRegisterEvents)
+ {
+ _deviceDriver = deviceDriver;
+ _sessionsBufferEvents = sessionRegisterEvents;
+ }
+
+ ///
+ /// Acquire a new session id.
+ ///
+ /// A new session id.
+ private int AcquireSessionId()
+ {
+ lock (_sessionLock)
+ {
+ int index = _activeSessionCount;
+
+ Debug.Assert(index < _sessionIds.Length);
+
+ int sessionId = _sessionIds[index];
+
+ _sessionIds[index] = -1;
+
+ _activeSessionCount++;
+
+ Logger.Info?.Print(LogClass.AudioRenderer, $"Registered new input ({sessionId})");
+
+ return sessionId;
+ }
+ }
+
+ ///
+ /// Release a given .
+ ///
+ /// The session id to release.
+ private void ReleaseSessionId(int sessionId)
+ {
+ lock (_sessionLock)
+ {
+ Debug.Assert(_activeSessionCount > 0);
+
+ int newIndex = --_activeSessionCount;
+
+ _sessionIds[newIndex] = sessionId;
+ }
+
+ Logger.Info?.Print(LogClass.AudioRenderer, $"Unregistered input ({sessionId})");
+ }
+
+ ///
+ /// Used to update audio input system.
+ ///
+ public void Update()
+ {
+ lock (_sessionLock)
+ {
+ foreach (AudioInputSystem input in _sessions)
+ {
+ input?.Update();
+ }
+ }
+ }
+
+ ///
+ /// Register a new .
+ ///
+ /// The to register.
+ private void Register(AudioInputSystem input)
+ {
+ lock (_sessionLock)
+ {
+ _sessions[input.GetSessionId()] = input;
+ }
+ }
+
+ ///
+ /// Unregister a new .
+ ///
+ /// The to unregister.
+ internal void Unregister(AudioInputSystem input)
+ {
+ lock (_sessionLock)
+ {
+ int sessionId = input.GetSessionId();
+
+ _sessions[input.GetSessionId()] = null;
+
+ ReleaseSessionId(sessionId);
+ }
+ }
+
+ ///
+ /// Get the list of all audio inputs names.
+ ///
+ /// If true, filter disconnected devices
+ /// The list of all audio inputs name
+ public string[] ListAudioIns(bool filtered)
+ {
+ if (filtered)
+ {
+ // TODO: Detect if the driver supports audio input
+ }
+
+ return new string[] { Constants.DefaultDeviceInputName };
+ }
+
+ ///
+ /// Open a new .
+ ///
+ /// The output device name selected by the
+ /// The output audio configuration selected by the
+ /// The new
+ /// The memory manager that will be used for all guest memory operations
+ /// The input device name wanted by the user
+ /// The sample format to use
+ /// The user configuration
+ /// The applet resource user id of the application
+ /// The process handle of the application
+ /// A reporting an error or a success
+ public ResultCode OpenAudioIn(out string outputDeviceName,
+ out AudioOutputConfiguration outputConfiguration,
+ out AudioInputSystem obj,
+ IVirtualMemoryManager memoryManager,
+ string inputDeviceName,
+ SampleFormat sampleFormat,
+ ref AudioInputConfiguration parameter,
+ ulong appletResourceUserId,
+ uint processHandle)
+ {
+ int sessionId = AcquireSessionId();
+
+ _sessionsBufferEvents[sessionId].Clear();
+
+ IHardwareDeviceSession deviceSession = _deviceDriver.OpenDeviceSession(IHardwareDeviceDriver.Direction.Input, memoryManager, sampleFormat, parameter.SampleRate, parameter.ChannelCount);
+
+ AudioInputSystem audioIn = new AudioInputSystem(this, _lock, deviceSession, _sessionsBufferEvents[sessionId]);
+
+ ResultCode result = audioIn.Initialize(inputDeviceName, sampleFormat, ref parameter, sessionId);
+
+ if (result == ResultCode.Success)
+ {
+ outputDeviceName = audioIn.DeviceName;
+ outputConfiguration = new AudioOutputConfiguration
+ {
+ ChannelCount = audioIn.ChannelCount,
+ SampleFormat = audioIn.SampleFormat,
+ SampleRate = audioIn.SampleRate,
+ AudioOutState = audioIn.GetState(),
+ };
+
+ obj = audioIn;
+
+ Register(audioIn);
+ }
+ else
+ {
+ ReleaseSessionId(sessionId);
+
+ obj = null;
+ outputDeviceName = null;
+ outputConfiguration = default;
+ }
+
+ return result;
+ }
+
+ public void Dispose()
+ {
+ if (Interlocked.CompareExchange(ref _disposeState, 1, 0) == 0)
+ {
+ Dispose(true);
+ }
+ }
+
+ protected virtual void Dispose(bool disposing)
+ {
+ if (disposing)
+ {
+ // Clone the sessions array to dispose them outside the lock.
+ AudioInputSystem[] sessions;
+
+ lock (_sessionLock)
+ {
+ sessions = _sessions.ToArray();
+ }
+
+ foreach (AudioInputSystem input in sessions)
+ {
+ input?.Dispose();
+ }
+ }
+ }
+ }
+}
\ No newline at end of file
diff --git a/src/Ryujinx.Audio/Input/AudioInputSystem.cs b/src/Ryujinx.Audio/Input/AudioInputSystem.cs
new file mode 100644
index 00000000..b3ca0fd6
--- /dev/null
+++ b/src/Ryujinx.Audio/Input/AudioInputSystem.cs
@@ -0,0 +1,392 @@
+using Ryujinx.Audio.Common;
+using Ryujinx.Audio.Integration;
+using System;
+using System.Threading;
+
+namespace Ryujinx.Audio.Input
+{
+ ///
+ /// Audio input system.
+ ///
+ public class AudioInputSystem : IDisposable
+ {
+ ///
+ /// The session id associated to the .
+ ///
+ private int _sessionId;
+
+ ///
+ /// The session the .
+ ///
+ private AudioDeviceSession _session;
+
+ ///
+ /// The target device name of the .
+ ///
+ public string DeviceName { get; private set; }
+
+ ///
+ /// The target sample rate of the .
+ ///
+ public uint SampleRate { get; private set; }
+
+ ///
+ /// The target channel count of the .
+ ///
+ public uint ChannelCount { get; private set; }
+
+ ///
+ /// The target sample format of the .
+ ///
+ public SampleFormat SampleFormat { get; private set; }
+
+ ///
+ /// The owning this.
+ ///
+ private AudioInputManager _manager;
+
+ ///
+ /// The lock of the parent.
+ ///
+ private object _parentLock;
+
+ ///
+ /// The dispose state.
+ ///
+ private int _disposeState;
+
+ ///
+ /// Create a new .
+ ///
+ /// The manager instance
+ /// The lock of the manager
+ /// The hardware device session
+ /// The buffer release event of the audio input
+ public AudioInputSystem(AudioInputManager manager, object parentLock, IHardwareDeviceSession deviceSession, IWritableEvent bufferEvent)
+ {
+ _manager = manager;
+ _parentLock = parentLock;
+ _session = new AudioDeviceSession(deviceSession, bufferEvent);
+ }
+
+ ///
+ /// Get the default device name on the system.
+ ///
+ /// The default device name on the system.
+ private static string GetDeviceDefaultName()
+ {
+ return Constants.DefaultDeviceInputName;
+ }
+
+ ///
+ /// Check if a given configuration and device name is valid on the system.
+ ///
+ /// The configuration to check.
+ /// The device name to check.
+ /// A reporting an error or a success.
+ private static ResultCode IsConfigurationValid(ref AudioInputConfiguration configuration, string deviceName)
+ {
+ if (deviceName.Length != 0 && !deviceName.Equals(GetDeviceDefaultName()))
+ {
+ return ResultCode.DeviceNotFound;
+ }
+ else if (configuration.SampleRate != 0 && configuration.SampleRate != Constants.TargetSampleRate)
+ {
+ return ResultCode.UnsupportedSampleRate;
+ }
+ else if (configuration.ChannelCount != 0 && configuration.ChannelCount != 1 && configuration.ChannelCount != 2 && configuration.ChannelCount != 6)
+ {
+ return ResultCode.UnsupportedChannelConfiguration;
+ }
+
+ return ResultCode.Success;
+ }
+
+ ///
+ /// Get the released buffer event.
+ ///
+ /// The released buffer event
+ public IWritableEvent RegisterBufferEvent()
+ {
+ lock (_parentLock)
+ {
+ return _session.GetBufferEvent();
+ }
+ }
+
+ ///
+ /// Update the .
+ ///
+ public void Update()
+ {
+ lock (_parentLock)
+ {
+ _session.Update();
+ }
+ }
+
+ ///
+ /// Get the id of this session.
+ ///
+ /// The id of this session
+ public int GetSessionId()
+ {
+ return _sessionId;
+ }
+
+ ///
+ /// Initialize the .
+ ///
+ /// The input device name wanted by the user
+ /// The sample format to use
+ /// The user configuration
+ /// The session id associated to this
+ /// A reporting an error or a success.
+ public ResultCode Initialize(string inputDeviceName, SampleFormat sampleFormat, ref AudioInputConfiguration parameter, int sessionId)
+ {
+ _sessionId = sessionId;
+
+ ResultCode result = IsConfigurationValid(ref parameter, inputDeviceName);
+
+ if (result == ResultCode.Success)
+ {
+ if (inputDeviceName.Length == 0)
+ {
+ DeviceName = GetDeviceDefaultName();
+ }
+ else
+ {
+ DeviceName = inputDeviceName;
+ }
+
+ if (parameter.ChannelCount == 6)
+ {
+ ChannelCount = 6;
+ }
+ else
+ {
+ ChannelCount = 2;
+ }
+
+ SampleFormat = sampleFormat;
+ SampleRate = Constants.TargetSampleRate;
+ }
+
+ return result;
+ }
+
+ ///
+ /// Append a new audio buffer to the audio input.
+ ///
+ /// The unique tag of this buffer.
+ /// The buffer informations.
+ /// A reporting an error or a success.
+ public ResultCode AppendBuffer(ulong bufferTag, ref AudioUserBuffer userBuffer)
+ {
+ lock (_parentLock)
+ {
+ AudioBuffer buffer = new AudioBuffer
+ {
+ BufferTag = bufferTag,
+ DataPointer = userBuffer.Data,
+ DataSize = userBuffer.DataSize
+ };
+
+ if (_session.AppendBuffer(buffer))
+ {
+ return ResultCode.Success;
+ }
+
+ return ResultCode.BufferRingFull;
+ }
+ }
+
+ ///
+ /// Append a new audio buffer to the audio input.
+ ///
+ /// This is broken by design, only added for completness.
+ /// The unique tag of this buffer.
+ /// The buffer informations.
+ /// Some unknown handle.
+ /// A reporting an error or a success.
+ public ResultCode AppendUacBuffer(ulong bufferTag, ref AudioUserBuffer userBuffer, uint handle)
+ {
+ lock (_parentLock)
+ {
+ AudioBuffer buffer = new AudioBuffer
+ {
+ BufferTag = bufferTag,
+ DataPointer = userBuffer.Data,
+ DataSize = userBuffer.DataSize
+ };
+
+ if (_session.AppendUacBuffer(buffer, handle))
+ {
+ return ResultCode.Success;
+ }
+
+ return ResultCode.BufferRingFull;
+ }
+ }
+
+ ///
+ /// Get the release buffers.
+ ///
+ /// The buffer to write the release buffers
+ /// The count of released buffers
+ /// A reporting an error or a success.
+ public ResultCode GetReleasedBuffers(Span releasedBuffers, out uint releasedCount)
+ {
+ releasedCount = 0;
+
+ // Ensure that the first entry is set to zero if no entries are returned.
+ if (releasedBuffers.Length > 0)
+ {
+ releasedBuffers[0] = 0;
+ }
+
+ lock (_parentLock)
+ {
+ for (int i = 0; i < releasedBuffers.Length; i++)
+ {
+ if (!_session.TryPopReleasedBuffer(out AudioBuffer buffer))
+ {
+ break;
+ }
+
+ releasedBuffers[i] = buffer.BufferTag;
+ releasedCount++;
+ }
+ }
+
+ return ResultCode.Success;
+ }
+
+ ///
+ /// Get the current state of the .
+ ///
+ /// Return the curent sta\te of the
+ public AudioDeviceState GetState()
+ {
+ lock (_parentLock)
+ {
+ return _session.GetState();
+ }
+ }
+
+ ///
+ /// Start the audio session.
+ ///
+ /// A reporting an error or a success
+ public ResultCode Start()
+ {
+ lock (_parentLock)
+ {
+ return _session.Start();
+ }
+ }
+
+ ///
+ /// Stop the audio session.
+ ///
+ /// A reporting an error or a success
+ public ResultCode Stop()
+ {
+ lock (_parentLock)
+ {
+ return _session.Stop();
+ }
+ }
+
+ ///
+ /// Get the volume of the session.
+ ///
+ /// The volume of the session
+ public float GetVolume()
+ {
+ lock (_parentLock)
+ {
+ return _session.GetVolume();
+ }
+ }
+
+ ///
+ /// Set the volume of the session.
+ ///
+ /// The new volume to set
+ public void SetVolume(float volume)
+ {
+ lock (_parentLock)
+ {
+ _session.SetVolume(volume);
+ }
+ }
+
+ ///
+ /// Get the count of buffer currently in use (server + driver side).
+ ///
+ /// The count of buffer currently in use
+ public uint GetBufferCount()
+ {
+ lock (_parentLock)
+ {
+ return _session.GetBufferCount();
+ }
+ }
+
+ ///
+ /// Check if a buffer is present.
+ ///
+ /// The unique tag of the buffer
+ /// Return true if a buffer is present
+ public bool ContainsBuffer(ulong bufferTag)
+ {
+ lock (_parentLock)
+ {
+ return _session.ContainsBuffer(bufferTag);
+ }
+ }
+
+ ///
+ /// Get the count of sample played in this session.
+ ///
+ /// The count of sample played in this session
+ public ulong GetPlayedSampleCount()
+ {
+ lock (_parentLock)
+ {
+ return _session.GetPlayedSampleCount();
+ }
+ }
+
+ ///
+ /// Flush all buffers to the initial state.
+ ///
+ /// True if any buffers was flushed
+ public bool FlushBuffers()
+ {
+ lock (_parentLock)
+ {
+ return _session.FlushBuffers();
+ }
+ }
+
+ public void Dispose()
+ {
+ if (Interlocked.CompareExchange(ref _disposeState, 1, 0) == 0)
+ {
+ Dispose(true);
+ }
+ }
+
+ protected virtual void Dispose(bool disposing)
+ {
+ if (disposing)
+ {
+ _session.Dispose();
+
+ _manager.Unregister(this);
+ }
+ }
+ }
+}
\ No newline at end of file
--
cgit v1.2.3