From 83956b12d863924936a98c9dfbece37feb0cce9c Mon Sep 17 00:00:00 2001 From: wangzhengquan <wangzhengquan85@126.com> Date: 星期四, 04 二月 2021 14:48:04 +0800 Subject: [PATCH] update --- src/net/net_mod_socket_wrapper.cpp | 20 +++++++++++++++++++- 1 files changed, 19 insertions(+), 1 deletions(-) diff --git a/src/net/net_mod_socket_wrapper.cpp b/src/net/net_mod_socket_wrapper.cpp index 57073f0..4be2d5c 100644 --- a/src/net/net_mod_socket_wrapper.cpp +++ b/src/net/net_mod_socket_wrapper.cpp @@ -113,7 +113,25 @@ return sockt->sendandrecv_nowait(node_arr, arrlen, send_buf, send_size, recv_arr, recv_arr_size); } - + +int net_mod_socket_recvandsend(void *_socket, recvandsend_callback_fn callback, void * user_data) { + NetModSocket *sockt = (NetModSocket *)_socket; + return sockt->recvandsend( callback, NULL, 0, user_data); + +} + +int net_mod_socket_recvandsend_timeout(void *_socket, recvandsend_callback_fn callback, + int sec, int nsec, void * user_data) { + NetModSocket *sockt = (NetModSocket *)_socket; + struct timespec timeout = {sec, nsec}; + return sockt->recvandsend( callback, &timeout, BUS_TIMEOUT_FLAG, user_data); +} + +int net_mod_socket_recvandsend_nowait(void *_socket, recvandsend_callback_fn callback, void * user_data) { + NetModSocket *sockt = (NetModSocket *)_socket; + return sockt->recvandsend( callback, NULL, BUS_NOWAIT_FLAG, user_data); +} + /** * 鍚憂ode_arr 涓殑鎵�鏈夌綉缁滆妭鐐瑰彂甯冩秷鎭� -- Gitblit v1.8.0