EuvTcp.hpp

//
// Created by xiong on 2020/11/6.
//
 
#ifndef EMX_EUVTCP_HPP
#define EMX_EUVTCP_HPP
 
#include "EuvLoop.hpp"
#include "EuvStmClientBase.hpp"
#include "EuvStmServerBase.hpp"
 
namespace Emx {
    class EuvTcp : public EuvStreamInf {
    public:
        EuvTcp() : m_tcp(nullptr) {}
 
        virtual ~EuvTcp() {
            DoDestroy();
        }
 
        ErrCodeE Create(EuvLoop &loop) override;
 
        void Destroy() override { DoDestroy(); }
 
        ErrCodeE Bind(const char *ip, uint16_t port) override;
 
        ErrCodeE Open(int fd) 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_tcp; }
 
        int32_t GetFd() override { return m_tcp->io_watcher.fd; }
 
        bool IsReceiving() override { return (m_tcp->flags & 0x00001000); }
 
    private:
        static void OnDestroy(uv_handle_t *handle);
 
        void DoDestroy();
 
    private:
        uv_tcp_t *m_tcp;
    };
 
    class EuvTcpClientBase : public EuvStmClientBase {
    public:
        EuvTcpClientBase() : EuvStmClientBase(&m_tcp) {}
 
        virtual ~EuvTcpClientBase() {};
 
    private:
        EuvTcp m_tcp;
    };
 
    class EuvTcpServerClient : public EuvStmServerClientBase {
    public:
        EuvTcpServerClient(EuvStmServerHostBase *host) : EuvStmServerClientBase(&m_tcp, host) {}
 
        virtual ~EuvTcpServerClient() {};
 
    private:
        EuvTcp m_tcp;
    };
 
    class EuvTcpServerHost : public EuvStmServerHostBase {
    public:
        EuvTcpServerHost() : EuvStmServerHostBase(&m_tcp) {}
 
        virtual ~EuvTcpServerHost() {};
 
    private:
        EuvTcp m_tcp;
    };
}
 
#endif //EMX_EUVTCP_HPP