pipe.hpp

浏览该文件的文档.

#ifndef NEFORCE_CORE_SYSTEM_PIPE_HPP__
#define NEFORCE_CORE_SYSTEM_PIPE_HPP__

 
#include "NeForce/core/string/string.hpp"
NEFORCE_BEGIN_NAMESPACE__


struct pipe_exception final : system_exception {
    explicit pipe_exception(const char* info = "Pipe Operation Failed.", const char* type = static_type,
                            const int code = 0) noexcept :
    system_exception(info, type, code) {}
 
    explicit pipe_exception(const exception& e) :
    system_exception(e) {}
 
    ~pipe_exception() override = default;
    static constexpr auto static_type = "pipe_exception";
};
 // Exceptions


class NEFORCE_API pipe {
public:
    using native_handle_type = _NEFORCE native_handle_type;
 
private:
#ifdef NEFORCE_PLATFORM_WINDOWS
    native_handle_type read_handle_ = nullptr;
    native_handle_type write_handle_ = nullptr;
#else
    native_handle_type fds_[2] = {-1, -1};
#endif
 
public:
    pipe() noexcept = default;

    explicit pipe(bool inheritable);

    ~pipe();
 
    pipe(const pipe&) = delete;
    pipe& operator=(const pipe&) = delete;

    pipe(pipe&& other) noexcept;

    pipe& operator=(pipe&& other) noexcept;

    static void ignore_sigpipe() noexcept;

    int read(void* buffer, size_t size) noexcept;

    NEFORCE_NODISCARD string read_available();

    int write(const void* data, size_t size) noexcept;

    void close_read() noexcept;

    void close_write() noexcept;

    void close() noexcept;

    NEFORCE_NODISCARD bool is_valid() const noexcept;

    NEFORCE_NODISCARD native_handle_type native_read_handle() const noexcept {
#ifdef NEFORCE_PLATFORM_WINDOWS
        return read_handle_;
#else
        return fds_[0];
#endif
    }

    NEFORCE_NODISCARD native_handle_type native_write_handle() const noexcept {
#ifdef NEFORCE_PLATFORM_WINDOWS
        return write_handle_;
#else
        return fds_[1];
#endif
    }

    NEFORCE_NODISCARD native_handle_type detach_read_handle() noexcept;

    NEFORCE_NODISCARD native_handle_type detach_write_handle() noexcept;
};
 // Pipe
 
NEFORCE_END_NAMESPACE__
#endif // NEFORCE_CORE_SYSTEM_PIPE_HPP__