pipe.h

Go to the documentation of this file.

 
#ifndef CPPCOMMON_SYSTEM_PIPE_H
#define CPPCOMMON_SYSTEM_PIPE_H
 
#include "common/reader.h"
#include "common/writer.h"
#include "errors/exceptions.h"
 
#include <memory>
 
namespace CppCommon {
 
 
class Pipe : public Reader, public Writer
{
public:
    Pipe();
    Pipe(const Pipe&) = delete;
    Pipe(Pipe&& pipe) = delete;
    virtual ~Pipe();
 
    Pipe& operator=(const Pipe&) = delete;
    Pipe& operator=(Pipe&& pipe) = delete;
 
    void* reader() const noexcept;
    void* writer() const noexcept;
 
    bool IsPipeOpened() const noexcept;
    bool IsPipeReadOpened() const noexcept;
    bool IsPipeWriteOpened() const noexcept;
 
 
    size_t Read(void* buffer, size_t size) override;
 
    using Reader::ReadAllBytes;
    using Reader::ReadAllText;
    using Reader::ReadAllLines;
 
 
    size_t Write(const void* buffer, size_t size) override;
 
    using Writer::Write;
 
    void CloseRead();
    void CloseWrite();
 
    void Close();
 
    void swap(Pipe& pipe) noexcept;
    friend void swap(Pipe& pipe1, Pipe& pipe2) noexcept;
 
private:
    class Impl;
 
    Impl& impl() noexcept { return reinterpret_cast<Impl&>(_storage); }
    const Impl& impl() const noexcept { return reinterpret_cast<Impl const&>(_storage); }
 
    static const size_t StorageSize = 16;
#if defined(unix) || defined(__unix) || defined(__unix__) || defined(__APPLE__)
    static const size_t StorageAlign = 4;
#else
    static const size_t StorageAlign = 8;
#endif
    alignas(StorageAlign) std::byte _storage[StorageSize];
};
 
} // namespace CppCommon
 
#include "pipe.inl"
 
#endif // CPPCOMMON_SYSTEM_PIPE_H