EuvPipe.hpp

//
// Created by xiong on 2020/10/23.
//
 
#ifndef EMX_EUVPIPE_HPP
#define EMX_EUVPIPE_HPP
 
#include "EuvLoop.hpp"
#include "EuvStmClientBase.hpp"
#include "EuvStmServerBase.hpp"
 
namespace Emx {
    class EuvPipe : public EuvStreamInf {
    public:
        EuvPipe() : m_pipe(nullptr) {}
 
        virtual ~EuvPipe() {
            DoDestroy();
        }
 
        ErrCodeE Create(EuvLoop &loop) override;
 
        void Destroy() override { DoDestroy(); }
 
        ErrCodeE Bind(const char *ip, uint16_t port) override;
 
        ErrCodeE Connect(uv_connect_t *req,
                         const char *serverIp, uint16_t serverPort,
                         uv_connect_cb cb) override;
 
        ErrCodeE GetSockName(void *name, size_t &len) override;
 
        ErrCodeE GetPeerName(void *name, size_t &len) override;
 
        uv_stream_t *GetStm() override { return (uv_stream_t *) m_pipe; }
 
        int32_t GetFd() override { return m_pipe->io_watcher.fd; }
 
        bool IsReceiving() override { return (m_pipe->flags & 0x00001000); }
 
    private:
        static void OnDestroy(uv_handle_t *handle);
 
        void DoDestroy();
 
    private:
        uv_pipe_t *m_pipe;
    };
 
    class EuvPipeClientBase : public EuvStmClientBase {
    public:
        EuvPipeClientBase() : EuvStmClientBase(&m_pipe) {}
 
        virtual ~EuvPipeClientBase() {};
    private:
        EuvPipe m_pipe;
    };
 
    class EuvPipeServerClient : public EuvStmServerClientBase {
    public:
        EuvPipeServerClient(EuvStmServerHostBase *host) : EuvStmServerClientBase(&m_pipe, host) {}
 
        virtual ~EuvPipeServerClient() {};
 
    private:
        EuvPipe m_pipe;
    };
 
    class EuvPipeServerHost : public EuvStmServerHostBase {
    public:
        EuvPipeServerHost() : EuvStmServerHostBase(&m_pipe) {}
 
        virtual ~EuvPipeServerHost() {};
 
    private:
        EuvPipe m_pipe;
    };
 
}
 
 
#endif //EMX_EUVPIPE_HPP