MemoryView.cs

using System.IO.MemoryMappedFiles;
using System.Runtime.InteropServices;
using Cloudtoid.Interprocess.Memory.Unix;
using Cloudtoid.Interprocess.Memory.Windows;

namespace Cloudtoid.Interprocess;

// This class manages the underlying Memory Mapped File
internal sealed class MemoryView : IDisposable
{
    private readonly IMemoryFile file;
    private readonly MemoryMappedViewAccessor view;

    internal unsafe MemoryView(QueueOptions options, ILoggerFactory loggerFactory)
    {
        file = RuntimeInformation.IsOSPlatform(OSPlatform.Windows)
            ? new MemoryFileWindows(options)
            : new MemoryFileUnix(options, loggerFactory);

        try
        {
            view = file.MappedFile.CreateViewAccessor(0, 0, MemoryMappedFileAccess.ReadWrite);

            try
            {
                Pointer = AcquirePointer();
            }
            catch
            {
                view.Dispose();
                throw;
            }
        }
        catch
        {
            file.Dispose();
            throw;
        }
    }

    public unsafe byte* Pointer { get; }

    public void Dispose()
    {
        view.SafeMemoryMappedViewHandle.ReleasePointer();
        view.Flush();
        view.Dispose();
        file.Dispose();
    }

    private unsafe byte* AcquirePointer()
    {
        byte* ptr = null;
        view.SafeMemoryMappedViewHandle.AcquirePointer(ref ptr);
        if (ptr is null)
            throw new InvalidOperationException("Failed to acquire a pointer to the memory mapped file view.");

        return ptr;
    }
}