MemoryStream.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/Exceptions/Exceptions.h"
#include <vector>
#include <cstring>
 
namespace Arp { namespace System { namespace Commons { namespace Io
{
 
class MemoryStream : public Stream
{
public: // construction/destruction
    MemoryStream(void);
    explicit MemoryStream(size_t capacity);
    MemoryStream(byte* buffer, size_t bufferSize);
    MemoryStream(byte* buffer, size_t bufferSize, boolean writable);
    MemoryStream(byte* buffer, size_t bufferSize, size_t index, size_t count);
    MemoryStream(byte* buffer, size_t bufferSize, size_t index, size_t count, boolean writable);
    MemoryStream(byte* buffer, size_t bufferSize, size_t index, size_t count, boolean writable, boolean publiclyVisible);
    MemoryStream(const MemoryStream& arg) = delete;
    MemoryStream& operator=(const MemoryStream& arg) = delete;
    virtual ~MemoryStream(void);
 
public: // setter/getter operations
    size_t  GetLength(void);
    void    SetLength(size_t value);
    size_t  GetPosition(void) override;
    void    SetPosition(size_t value) override;
    size_t  GetCapacity(void);
    void    SetCapacity(size_t value);
 
public: // overridden operations
    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    Flush(void)override;
 
public: // operations
    std::vector<byte> ToArray(void);
 
private: // methods
    void Construct(byte* buffer, size_t bufferSize, size_t index, size_t count, boolean publicallyVisible);
    void EnsureSize(size_t newSize);
 
private: // fields
    // The underlying buffer of this stream.
    byte* streamBuffer;
    size_t streamBufferSize;
    // The actual position of this stream
    size_t position;
    // The actual length of the stream.
    size_t length;
    // Is true, if the stream is expandable
    boolean expandable;
    // The capacity of the stream
    size_t capacity;
    // The initial start index in the buffer
    size_t bufferOffset;
    // Is true if it is allowed to get the underlying buffer
    boolean allowGetBuffer;
    // Is true, the buffer created by the memory stream self
    boolean selfCreated;
 
private: // static fields
    static size_t minCapacity;
};
 
}}}} // end of namespace Arp::System::Commons::Io