FileStream.hpp

 
//
//  Copyright Phoenix Contact GmbH & Co. KG
//
#pragma once
#include "Arp/System/Core/Arp.h"
#include "Arp/System/Commons/Io/Stream.hpp"
#include "Arp/System/Commons/Io/FileMode.hpp"
#include "Arp/System/Commons/Io/FileAccess.hpp"
 
// forwards
namespace Arp { namespace System { namespace Ve
{
class IFileService;
}}}
 
namespace Arp { namespace System { namespace Commons { namespace Io
{
 
class FileStream : public Stream
{
public: // usings
    using IFileService = Arp::System::Ve::IFileService;
 
public: // construction/destruction
 
    FileStream(const String& path, FileMode mode);
    FileStream(const String& path, FileMode mode, FileAccess access);
    FileStream(const String& path, FileMode mode, FileAccess access, bool sync);
 
    FileStream(const FileStream& arg) = delete;
 
    FileStream& operator=(const FileStream& arg) = delete;
 
    ~FileStream(void)override;
 
public: // setter/getter operations
    size_t GetLength(void);
    void SetLength(size_t length);
    size_t GetPosition(void) override;
    void SetPosition(size_t position) override;
 
 
public: // operations
    void Flush(void) override;
    size_t Seek(size_t offset, SeekOrigin origin) override;
    size_t Read(byte* pBuffer, size_t bufferSize, size_t offset, size_t count) override;
    void Write(const byte* pBuffer, size_t bufferSize, size_t offset, size_t count) override;
    void Close(void);
 
private: // methods
    void Construct(const String& path, FileMode mode, FileAccess access);
    void Construct(const String& path, FileMode mode, FileAccess access, bool sync);
    static bool DetermineCanRead(FileAccess access);
    static bool DetermineCanWrite(FileAccess access);
 
private: // fields
    String pathName;
    IFileService* pFileService = nullptr;
};
 
}}}} // end of namespace Arp::System::Commons::Io