Pipe.hxx

#pragma once
 
// Linux
#include <unistd.h>
 
// cosmos
#include <cosmos/fs/FileDescriptor.hxx>
 
namespace cosmos {
 
 
class COSMOS_API Pipe {
        // disallow copy/assignment
        Pipe(const Pipe&) = delete;
        Pipe& operator=(const Pipe&) = delete;
 
public: // functions
 
        explicit Pipe();
 
        ~Pipe() { closeReadEnd(); closeWriteEnd(); }
 
        void closeReadEnd() { if (haveReadEnd()) m_read_end.close(); }
        void closeWriteEnd() { if (haveWriteEnd()) m_write_end.close(); }
 
        FileDescriptor readEnd() { return m_read_end; }
        FileDescriptor writeEnd() { return m_write_end; }
 
        bool haveReadEnd() const { return m_read_end.valid(); }
        bool haveWriteEnd() const { return m_write_end.valid(); }
 
 
        FileDescriptor takeReadEndOwnership() {
                auto ret = readEnd();
                invalidateReadEnd();
                return ret;
        }
 
 
        FileDescriptor takeWriteEndOwnership() {
                auto ret = writeEnd();
                invalidateWriteEnd();
                return ret;
        }
 
 
        static size_t maxAtomicWriteSize() {
                return MAX_ATOMIC_WRITE;
        }
 
protected: // functions
 
        void invalidateReadEnd() { m_read_end.reset(); }
        void invalidateWriteEnd() { m_write_end.reset(); }
 
protected: // data
 
        FileDescriptor m_read_end;
        FileDescriptor m_write_end;
        static const size_t MAX_ATOMIC_WRITE;
};
 
} // end ns