wangzhengquan
2020-08-05 509cf5db80c1d8919e19e1e061f2014e1ff3caf7
src/socket/include/dgram_mod_socket.h
@@ -26,12 +26,20 @@
int dgram_mod_bind(void * _socket, int port);
/**
 * 强制绑定端口到socket, 适用于程序非正常关闭的情况下,重启程序绑定原来还没释放的key
 * @return 0 成功, 其他值 失败的错误码
*/
int dgram_mod_force_bind(void * _socket, int port);
/**
 * 发送信息
 * @port 发送给谁
 * @return 0 成功, 其他值 失败的错误码
 */
int dgram_mod_sendto(void *_socket, const void *buf, const int size, const int port);
// 发送信息超时返回。 @sec 秒 , @nsec 纳秒
int dgram_mod_sendto_timeout(void *_socket, const void *buf, const int size, const int port, int sec, int nsec);
// 发送信息立刻返回。
int dgram_mod_sendto_nowait(void *_socket, const void *buf, const int size, const int port);
/**
 * 接收信息
@@ -39,6 +47,9 @@
 * @return 0 成功, 其他值 失败的错误码
*/
int dgram_mod_recvfrom(void *_socket, void **buf, int *size, int *port);
// 接受信息超时返回。 @sec 秒 , @nsec 纳秒
int dgram_mod_recvfrom_timeout(void *_socket, void **buf, int *size, int *port, int sec, int nsec);
int dgram_mod_recvfrom_nowait(void *_socket, void **buf, int *size, int *port);
/**
 * 发送请求信息并等待接收应答
@@ -46,6 +57,9 @@
 * @return 0 成功, 其他值 失败的错误码
*/
int dgram_mod_sendandrecv(void * _socket, const void *send_buf, const int send_size, const int port, void **recv_buf, int *recv_size) ;
// 超时返回。 @sec 秒 , @nsec 纳秒
int dgram_mod_sendandrecv_timeout(void * _socket, const void *send_buf, const int send_size, const int port, void **recv_buf, int *recv_size, int sec, int nsec) ;
int dgram_mod_sendandrecv_nowait(void * _socket, const void *send_buf, const int send_size, const int port, void **recv_buf, int *recv_size) ;
/**
@@ -62,6 +76,11 @@
 * @port 总线端口
 */
int  dgram_mod_sub(void * _socket, void *topic, int size, int port);
// 超时返回。 @sec 秒 , @nsec 纳秒
int  dgram_mod_sub_timeout(void * _socket, void *topic, int size, int port, int sec, int nsec);
int  dgram_mod_sub_nowait(void * _socket, void *topic, int size, int port);
/**
 * 发布主题
@@ -70,6 +89,9 @@
 * @port 总线端口
 */
int  dgram_mod_pub(void * _socket, void *topic, int topic_size, void *content, int content_size, int port);
//  超时返回。 @sec 秒 , @nsec 纳秒
int  dgram_mod_pub_timeout(void * _socket, void *topic, int topic_size, void *content, int content_size, int port, int sec, int nsec);
int  dgram_mod_pub_nowait(void * _socket, void *topic, int topic_size, void *content, int content_size, int port);
/**