|
|
@ -24,7 +24,9 @@ typedef enum { |
|
|
|
|
|
|
|
class XsyncNetAdd { |
|
|
|
public: |
|
|
|
uint32_t ip; |
|
|
|
XsyncNetAdd(){}; |
|
|
|
XsyncNetAdd(string ip, uint32_t port) : ip(ip), port(port) {} |
|
|
|
string ip; |
|
|
|
uint32_t port; |
|
|
|
}; |
|
|
|
|
|
|
@ -62,8 +64,10 @@ class I_XSUDP { |
|
|
|
* @param data |
|
|
|
* @param length |
|
|
|
* @return int |
|
|
|
* >0 发送成功,返回发送的字节数 |
|
|
|
* <0 发送失败 |
|
|
|
*/ |
|
|
|
virtual xs_error_code_t sendto(const XsyncNetAdd& to, const char* data, int32_t length) = 0; |
|
|
|
virtual xs_error_code_t sendto(const XsyncNetAdd& to, const char* data, int32_t length, int32_t* sendlength) = 0; |
|
|
|
/**
|
|
|
|
* @brief 接收UDP消息 |
|
|
|
* |
|
|
@ -71,8 +75,10 @@ class I_XSUDP { |
|
|
|
* @param length |
|
|
|
* @param from |
|
|
|
* @return int |
|
|
|
* >0 接收成功,返回接收的字节数 |
|
|
|
* <0 接收失败 |
|
|
|
*/ |
|
|
|
virtual xs_error_code_t receive(const char* data, int32_t length, XsyncNetAdd& from, int overtimems) = 0; |
|
|
|
virtual xs_error_code_t receive(char* data, int32_t& length, XsyncNetAdd& from, int overtimems) = 0; |
|
|
|
|
|
|
|
virtual ~I_XSUDP() {} |
|
|
|
}; |
|
|
|