src/Ryujinx.Audio/Renderer/Common/WorkBufferAllocator.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

using Ryujinx.Audio.Renderer.Utils;
using Ryujinx.Common;
using System;
using System.Diagnostics;
using System.Runtime.CompilerServices;

namespace Ryujinx.Audio.Renderer.Common
{
    public class WorkBufferAllocator
    {
        public Memory<byte> BackingMemory { get; }

        public ulong Offset { get; private set; }

        public WorkBufferAllocator(Memory<byte> backingMemory)
        {
            BackingMemory = backingMemory;
        }

        public Memory<byte> Allocate(ulong size, int align)
        {
            Debug.Assert(align != 0);

            if (size != 0)
            {
                ulong alignedOffset = BitUtils.AlignUp<ulong>(Offset, (ulong)align);

                if (alignedOffset + size <= (ulong)BackingMemory.Length)
                {
                    Memory<byte> result = BackingMemory.Slice((int)alignedOffset, (int)size);

                    Offset = alignedOffset + size;

                    // Clear the memory to be sure that is does not contain any garbage.
                    result.Span.Fill(0);

                    return result;
                }
            }

            return Memory<byte>.Empty;
        }

        public Memory<T> Allocate<T>(ulong count, int align) where T : unmanaged
        {
            Memory<byte> allocatedMemory = Allocate((ulong)Unsafe.SizeOf<T>() * count, align);

            if (allocatedMemory.IsEmpty)
            {
                return Memory<T>.Empty;
            }

            return SpanMemoryManager<T>.Cast(allocatedMemory);
        }

        public static ulong GetTargetSize<T>(ulong currentSize, ulong count, int align) where T : unmanaged
        {
            return BitUtils.AlignUp<ulong>(currentSize, (ulong)align) + (ulong)Unsafe.SizeOf<T>() * count;
        }
    }
}