From 758438289fc45829a8f6cef1b42afed0a1a8cb60 Mon Sep 17 00:00:00 2001 From: wangzhengquan <wangzhengquan85@126.com> Date: 星期三, 03 二月 2021 15:59:58 +0800 Subject: [PATCH] uuid msg --- src/net/net_mod_socket.cpp | 20 ++++++++++++++++++++ 1 files changed, 20 insertions(+), 0 deletions(-) diff --git a/src/net/net_mod_socket.cpp b/src/net/net_mod_socket.cpp index 3668b14..f939c67 100644 --- a/src/net/net_mod_socket.cpp +++ b/src/net/net_mod_socket.cpp @@ -141,6 +141,8 @@ } + + int NetModSocket::_sendandrecv_(net_node_t *node_arr, int arrlen, void *send_buf, int send_size, net_mod_recv_msg_t ** recv_arr, int *recv_arr_size, int msec ) { @@ -495,6 +497,24 @@ return shmModSocket.recvfrom(buf, size, key, NULL, BUS_NOWAIT_FLAG); } + + +int NetModSocket::recvandsend(void **recvbuf, int *recvsize, int *key, recv_callback_fn callback) { + return shmModSocket.recvandsend( recvbuf, recvsize, key, callback); + +} + +int NetModSocket::recvandsend_timeout(void **recvbuf, int *recvsize, int *key, recv_callback_fn callback, + const struct timespec *timeout ) { + return shmModSocket.recvandsend( recvbuf, recvsize, key, callback, timeout, BUS_TIMEOUT_FLAG); + +} + +int NetModSocket::recvandsend_nowait(void **recvbuf, int *recvsize, int *key, recv_callback_fn callback) { + return shmModSocket.recvandsend( recvbuf, recvsize, key, callback, NULL, BUS_NOWAIT_FLAG); + +} + /** * 鍙戦�佽姹備俊鎭苟绛夊緟鎺ユ敹搴旂瓟 * @key 鍙戦�佺粰璋� -- Gitblit v1.8.0