pipe.hpp

浏览该文件的文档.

#ifndef NEFORCE_CORE_SYSTEM_PIPE_HPP__
#define NEFORCE_CORE_SYSTEM_PIPE_HPP__

 
#include "NeForce/core/exception/system_exception.hpp"
NEFORCE_BEGIN_NAMESPACE__


struct pipe_exception final : system_exception {
    explicit pipe_exception(const char* info = "Pipe Operation Failed.", const error_code code = last_error()) noexcept
    :
    system_exception(info, code) {}
 
    explicit pipe_exception(const exception& e) :
    system_exception(e) {}
 
    ~pipe_exception() override = default;
 
    NEFORCE_NODISCARD const char* type() const noexcept override { return "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
    bool nonblocking_{false}; 
 
public:
    pipe() noexcept = default;

    explicit pipe(bool inheritable, bool nonblocking = false);

    ~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();

    bool set_nonblocking(bool v) noexcept;

    NEFORCE_NODISCARD bool is_nonblocking() const noexcept { return nonblocking_; }

    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;
};
 

class NEFORCE_API named_pipe {
public:
    using native_handle_type = _NEFORCE native_handle_type;
 
private:
#ifdef NEFORCE_PLATFORM_WINDOWS
    native_handle_type pipe_handle_;
    bool is_server_{false};
#else
    native_handle_type fd_{-1};
    string fifo_path_;
#endif
    string name_;
    bool nonblocking_{false};
 
public:
    named_pipe();

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

    named_pipe(named_pipe&& other) noexcept;

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

    bool create(const string& name, bool nonblocking = false);

    bool connect(const string& name, int timeout_ms = -1);

    bool wait_for_client();

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

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

    void close() noexcept;

    NEFORCE_NODISCARD bool is_valid() const noexcept;

    bool set_nonblocking(bool v) noexcept;

    NEFORCE_NODISCARD bool is_nonblocking() const noexcept { return nonblocking_; }

    NEFORCE_NODISCARD const string& name() const noexcept { return name_; }

    NEFORCE_NODISCARD native_handle_type native_handle() const noexcept {
#ifdef NEFORCE_PLATFORM_WINDOWS
        return pipe_handle_;
#else
        return fd_;
#endif
    }

    static bool remove(const string& path);
};
 // Pipe
 
NEFORCE_END_NAMESPACE__
#endif // NEFORCE_CORE_SYSTEM_PIPE_HPP__