From 203df24a403a8c0cd8e93d0f33eaf10de2788969 Mon Sep 17 00:00:00 2001 From: wangzhengquan <wangzhengquan85@126.com> Date: 星期四, 06 八月 2020 10:22:46 +0800 Subject: [PATCH] add desub --- src/socket/dgram_mod_socket.c | 23 +++++++++++++++++++++++ 1 files changed, 23 insertions(+), 0 deletions(-) diff --git a/src/socket/dgram_mod_socket.c b/src/socket/dgram_mod_socket.c index e733ff6..ff3f31f 100644 --- a/src/socket/dgram_mod_socket.c +++ b/src/socket/dgram_mod_socket.c @@ -144,6 +144,29 @@ /** + * 鍙栨秷璁㈤槄鎸囧畾涓婚 + * @topic 涓婚 + * @size 涓婚闀垮害 + * @port 鎬荤嚎绔彛 + */ +int dgram_mod_desub(void * _socket, void *topic, int size, int port){ + dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket; + return socket->m_socket->desub(topic, size, port); +} +// 瓒呮椂杩斿洖銆� @sec 绉� 锛� @nsec 绾崇 +int dgram_mod_desub_timeout(void * _socket, void *topic, int size, int port, int sec, int nsec){ + dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket; + struct timespec timeout = {sec, nsec}; + return socket->m_socket->desub_timeout(topic, size, port, &timeout); +} +int dgram_mod_desub_nowait(void * _socket, void *topic, int size, int port){ + dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket; + return socket->m_socket->desub_nowait(topic, size, port); +} + + + +/** * 鍙戝竷涓婚 * @topic 涓婚 * @content 涓婚鍐呭 -- Gitblit v1.8.0