EuvUdp.hpp

//
// Created by xiong on 2020/11/7.
//
 
#ifndef EMX_EUVUDP_HPP
#define EMX_EUVUDP_HPP
 
#include "EuvLoop.hpp"
 
namespace Emx {
    class EuvUdp {
    public:
        using RecvCallback =
                std::function<void(Emx::ErrCodeE e, const char *data, int32_t size, const struct sockaddr *addr)>;
 
        EuvUdp() : m_udp(nullptr) {}
 
        virtual ~EuvUdp() { Destroy(); }
 
        ErrCodeE Create(EuvLoop &loop);
 
        void Destroy();
 
        ErrCodeE OpenExistSock(uv_os_sock_t sock);
 
        ErrCodeE Bind(const struct sockaddr *addr, unsigned int flags);
 
        ErrCodeE SetBroadcast(bool ena);
 
        ErrCodeE StartRecv(char *buffer, int32_t size, RecvCallback cbRecv);
 
        void StopRecv() { uv_udp_recv_stop(m_udp); }
 
        int32_t Send(uint8_t *data, int32_t size, const struct sockaddr *addr, socklen_t addrLen) {
            return sendto(m_udp->io_watcher.fd, data, size, 0, addr, addrLen);
        }
 
        ErrCodeE GetPeerName(struct sockaddr *name, int *len);
 
        ErrCodeE GetSockName(struct sockaddr *name, int *len);
 
        size_t GetSendQueueSize() { return uv_udp_get_send_queue_size(m_udp); }
 
        size_t GetSendQueueCount() { return uv_udp_get_send_queue_count(m_udp); }
 
        uv_udp_t *GetUDP() { return m_udp; }
 
        int32_t GetFD() { return m_udp->io_watcher.fd; }
 
        bool IsReceiving() { return (m_udp->flags & 0x00001000); }
 
    private:
        static void OnDestroy(uv_handle_t *handle);
 
    private:
        uv_udp_t *m_udp;
        RecvCallback m_cbRecv;
        char *m_buffer;
        int32_t m_size;
    };
}// namespace Emx
#endif//EMX_EUVUDP_HPP