AuroraRuntime/Source/IO/FS/FileStream.Unix.hpp

/***
    Copyright (C) 2021 J Reece Wilson (a/k/a "Reece"). All rights reserved.

    File: FileStream.Unix.hpp
    Date: 2021-6-12
    Author: Reece
***/
#pragma once

#if !defined(_AURUNTIME_GENERICFILESTREAM)

namespace Aurora::IO::FS
{
    // Code-sharing for async API fallbacks...
    bool PosixSetOffset(int fd, AuUInt64 offset);
    AuUInt64 PosixGetLength(int fd);
    bool PosixRead(int fd, void *buf, AuUInt32 count, AuUInt32 *pRead);
    bool PosixWrite(int fd, const void *buf, AuUInt32 count, AuUInt32 *pWritten);
   
    struct PosixFileStream : IFileStream
    {
        PosixFileStream();
        ~PosixFileStream();

        bool Init(AuSPtr<IIOHandle> pHandle);

        AuUInt64 GetOffset() override;
        bool     SetOffset(AuUInt64 offset) override;
        AuUInt64 GetLength() override;
        bool     Read(const Memory::MemoryViewStreamWrite &parameters) override;
        bool     Write(const Memory::MemoryViewStreamRead & parameters) override;
        void     Close() override;
        void     Flush() override;
        void     WriteEoS() override;  
        void     MakeTemporary() override;
        bool     IsFlushOnClose() const override;
        void     SetFlushOnClose(bool bFlushOnClose) override;
        bool     IsWriteEoSOnClose() const override;
        void     SetWriteEoSOnClose(bool bFlushOnClose) override;
        AuSPtr<IIOHandle> GetHandle() override;
        IO::IStreamReader *ToStreamReader() override;
        IO::IStreamWriter *ToStreamWriter() override;
        int   GetUnixHandle();

    private:
        AuSPtr<IIOHandle> pHandle_;
        AuString path_;
        AuThreadPrimitives::SpinLock spinlock_;
        bool bMadeTemporary {}, bShouldWriteEoS {};
        AuFS::FileReader reader_;
        AuFS::FileWriter writer_;
    };
}
#endif