public:

explicit UdpSocket(bool enable_broadcast = false); //! 用于只有发送的场景

explicit UdpSocket(event::Loop *wp_loop, bool enable_broadcast = false);

virtual ~UdpSocket();

NONCOPYABLE(UdpSocket);

public:

bool bind(const SockAddr &addr); //! 绑定地址与端口

bool connect(const SockAddr &addr); //! 连接目标地址与端口

//!NOTE:

//! bind() 与 connect() 不能一起使用，否则 bind() 会失效

//! 为规避该问题，可以在 send() 函数中直接传入要发送的目标地址

//! 设置接收回调

using RecvCallback = std::function<void (const void *, size_t, const SockAddr &)>;

void setRecvCallback(const RecvCallback &cb) { recv_cb_ = cb; }

//! 发送数据

ssize_t send(const void *data_ptr, size_t data_size, const SockAddr &to_addr);

ssize_t send(const void *data_ptr, size_t data_size); //! 要先 connect() 之后才能使用

//! 开启与关闭接收功能

bool enable();

bool disable();

protected:

void onSocketEvent(short events);

private:

SocketFd socket_;

bool connected_ = false;

event::FdEvent *sp_socket_ev_ = nullptr;

int cb_level_ = 0;

RecvCallback recv_cb_;