aboutsummaryrefslogtreecommitdiff
path: root/Ryujinx.HLE/HOS/Services/Aud/IHardwareOpusDecoder.cs
blob: a71b8602ad1c06b663749b67b7f123a52c429326 (plain) (blame)
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
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
using Concentus.Structs;
using Ryujinx.HLE.HOS.Ipc;
using System.Collections.Generic;

using static Ryujinx.HLE.HOS.ErrorCode;

namespace Ryujinx.HLE.HOS.Services.Aud
{
    class IHardwareOpusDecoder : IpcService
    {
        private const int FixedSampleRate = 48000;

        private Dictionary<int, ServiceProcessRequest> m_Commands;

        public override IReadOnlyDictionary<int, ServiceProcessRequest> Commands => m_Commands;

        private int SampleRate;
        private int ChannelsCount;

        private OpusDecoder Decoder;

        public IHardwareOpusDecoder(int SampleRate, int ChannelsCount)
        {
            m_Commands = new Dictionary<int, ServiceProcessRequest>()
            {
                { 0, DecodeInterleaved         },
                { 4, DecodeInterleavedWithPerf }
            };

            this.SampleRate    = SampleRate;
            this.ChannelsCount = ChannelsCount;

            Decoder = new OpusDecoder(FixedSampleRate, ChannelsCount);
        }

        public long DecodeInterleavedWithPerf(ServiceCtx Context)
        {
            long Result = DecodeInterleaved(Context);

            //TODO: Figure out what this value is.
            //According to switchbrew, it is now used.
            Context.ResponseData.Write(0L);

            return Result;
        }

        public long DecodeInterleaved(ServiceCtx Context)
        {
            long InPosition = Context.Request.SendBuff[0].Position;
            long InSize     = Context.Request.SendBuff[0].Size;

            if (InSize < 8)
            {
                return MakeError(ErrorModule.Audio, AudErr.OpusInvalidInput);
            }

            long OutPosition = Context.Request.ReceiveBuff[0].Position;
            long OutSize     = Context.Request.ReceiveBuff[0].Size;

            byte[] OpusData = Context.Memory.ReadBytes(InPosition, InSize);

            int Processed = ((OpusData[0] << 24) |
                             (OpusData[1] << 16) |
                             (OpusData[2] << 8)  |
                             (OpusData[3] << 0)) + 8;

            if ((uint)Processed > (ulong)InSize)
            {
                return MakeError(ErrorModule.Audio, AudErr.OpusInvalidInput);
            }

            short[] Pcm = new short[OutSize / 2];

            int FrameSize = Pcm.Length / (ChannelsCount * 2);

            int Samples = Decoder.Decode(OpusData, 0, OpusData.Length, Pcm, 0, FrameSize);

            foreach (short Sample in Pcm)
            {
                Context.Memory.WriteInt16(OutPosition, Sample);

                OutPosition += 2;
            }

            Context.ResponseData.Write(Processed);
            Context.ResponseData.Write(Samples);

            return 0;
        }
    }
}