src/Ryujinx.Audio/Backends/Common/HardwareDeviceSessionOutputBase.cs


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76

using Ryujinx.Audio.Common;
using Ryujinx.Audio.Integration;
using Ryujinx.Memory;
using System.Runtime.CompilerServices;

namespace Ryujinx.Audio.Backends.Common
{
    public abstract class HardwareDeviceSessionOutputBase : IHardwareDeviceSession
    {
        public IVirtualMemoryManager MemoryManager { get; }
        public SampleFormat RequestedSampleFormat { get; }
        public uint RequestedSampleRate { get; }
        public uint RequestedChannelCount { get; }

        public HardwareDeviceSessionOutputBase(IVirtualMemoryManager memoryManager, SampleFormat requestedSampleFormat, uint requestedSampleRate, uint requestedChannelCount)
        {
            MemoryManager = memoryManager;
            RequestedSampleFormat = requestedSampleFormat;
            RequestedSampleRate = requestedSampleRate;
            RequestedChannelCount = requestedChannelCount;
        }

        private byte[] GetBufferSamples(AudioBuffer buffer)
        {
            if (buffer.DataPointer == 0)
            {
                return null;
            }

            byte[] data = new byte[buffer.DataSize];

            MemoryManager.Read(buffer.DataPointer, data);

            return data;
        }

        protected ulong GetSampleCount(AudioBuffer buffer)
        {
            return GetSampleCount((int)buffer.DataSize);
        }

        [MethodImpl(MethodImplOptions.AggressiveInlining)]
        protected ulong GetSampleCount(int dataSize)
        {
            return (ulong)BackendHelper.GetSampleCount(RequestedSampleFormat, (int)RequestedChannelCount, dataSize);
        }

        public abstract void Dispose();
        public abstract void PrepareToClose();
        public abstract void QueueBuffer(AudioBuffer buffer);
        public abstract void SetVolume(float volume);
        public abstract float GetVolume();
        public abstract void Start();
        public abstract void Stop();
        public abstract ulong GetPlayedSampleCount();
        public abstract bool WasBufferFullyConsumed(AudioBuffer buffer);
        public virtual bool RegisterBuffer(AudioBuffer buffer)
        {
            return RegisterBuffer(buffer, GetBufferSamples(buffer));
        }

        public virtual bool RegisterBuffer(AudioBuffer buffer, byte[] samples)
        {
            if (samples == null)
            {
                return false;
            }

            buffer.Data ??= samples;

            return true;
        }

        public virtual void UnregisterBuffer(AudioBuffer buffer) { }
    }
}