From b63ce299ddacea2ad487dc635926ed52ff422c20 Mon Sep 17 00:00:00 2001 From: wangzhengquan <wangzhengquan85@126.com> Date: 星期一, 03 八月 2020 11:40:17 +0800 Subject: [PATCH] add timeout nowait --- src/socket/include/dgram_mod_socket.h | 19 ++++++++++++++++++- 1 files changed, 18 insertions(+), 1 deletions(-) diff --git a/src/socket/include/dgram_mod_socket.h b/src/socket/include/dgram_mod_socket.h index 21d0d20..1670def 100644 --- a/src/socket/include/dgram_mod_socket.h +++ b/src/socket/include/dgram_mod_socket.h @@ -36,7 +36,10 @@ * @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); /** * 鎺ユ敹淇℃伅 @@ -44,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); /** * 鍙戦�佽姹備俊鎭苟绛夊緟鎺ユ敹搴旂瓟 @@ -51,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) ; /** @@ -67,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); + + /** * 鍙戝竷涓婚 @@ -75,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); /** -- Gitblit v1.8.0