From dd0714b75b2e29087e3cd1184995bf38a453d833 Mon Sep 17 00:00:00 2001 From: wangzhengquan <wangzhengquan85@126.com> Date: 星期一, 01 二月 2021 17:36:13 +0800 Subject: [PATCH] update --- src/net/net_mod_socket_wrapper.cpp | 21 ++++++++++++--------- 1 files changed, 12 insertions(+), 9 deletions(-) diff --git a/src/net/net_mod_socket_wrapper.cpp b/src/net/net_mod_socket_wrapper.cpp index 683c543..be44751 100644 --- a/src/net/net_mod_socket_wrapper.cpp +++ b/src/net/net_mod_socket_wrapper.cpp @@ -53,14 +53,15 @@ int net_mod_socket_sendto_timeout(void *_socket, const void *buf, const int size, const int key, int sec, int nsec){ NetModSocket *sockt = (NetModSocket *)_socket; logger->debug("net_mod_socket_sendto: %d sendto %d", net_mod_socket_get_key(_socket), key); - return sockt->sendto_timeout(buf, size, key, sec, nsec); - // return sockt->sendto(buf, size, key); + // return sockt->sendto_timeout(buf, size, key, sec, nsec); + return sockt->sendto(buf, size, key); } // 鍙戦�佷俊鎭珛鍒昏繑鍥炪�� int net_mod_socket_sendto_nowait(void *_socket, const void *buf, const int size, const int key){ NetModSocket *sockt = (NetModSocket *)_socket; logger->debug("net_mod_socket_sendto: %d sendto %d", net_mod_socket_get_key(_socket), key); - return sockt->sendto_nowait(buf, size, key); + return sockt->sendto(buf, size, key); + // return sockt->sendto_nowait(buf, size, key); } /** @@ -80,12 +81,13 @@ // 鎺ュ彈淇℃伅瓒呮椂杩斿洖銆� @sec 绉� 锛� @nsec 绾崇 int net_mod_socket_recvfrom_timeout(void *_socket, void **buf, int *size, int *key, int sec, int nsec){ NetModSocket *sockt = (NetModSocket *)_socket; - // return sockt->recvfrom(buf, size, key); - return sockt->recvfrom_timeout(buf, size, key, sec, nsec); + return sockt->recvfrom(buf, size, key); + // return sockt->recvfrom_timeout(buf, size, key, sec, nsec); } int net_mod_socket_recvfrom_nowait(void *_socket, void **buf, int *size, int *key){ NetModSocket *sockt = (NetModSocket *)_socket; - return sockt->recvfrom_nowait(buf, size, key); + return sockt->recvfrom(buf, size, key); + // return sockt->recvfrom_nowait(buf, size, key); } int net_mod_socket_sendandrecv(void *_socket, net_node_t *node_arr, int arrlen, void *send_buf, int send_size, @@ -100,14 +102,15 @@ int net_mod_socket_sendandrecv_timeout(void *_socket, 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 timeout){ NetModSocket *sockt = (NetModSocket *)_socket; - // return sockt->sendandrecv(node_arr, arrlen, send_buf, send_size, recv_arr, recv_arr_size); - return sockt->sendandrecv_timeout(node_arr, arrlen, send_buf, send_size, recv_arr, recv_arr_size, timeout); + return sockt->sendandrecv(node_arr, arrlen, send_buf, send_size, recv_arr, recv_arr_size); + // return sockt->sendandrecv_timeout(node_arr, arrlen, send_buf, send_size, recv_arr, recv_arr_size, timeout); } int net_mod_socket_sendandrecv_nowait(void *_socket, net_node_t *node_arr, int arrlen, void *send_buf, int send_size, net_mod_recv_msg_t ** recv_arr, int *recv_arr_size) { NetModSocket *sockt = (NetModSocket *)_socket; - return sockt->sendandrecv_nowait(node_arr, arrlen, send_buf, send_size, recv_arr, recv_arr_size); + return sockt->sendandrecv(node_arr, arrlen, send_buf, send_size, recv_arr, recv_arr_size); + // return sockt->sendandrecv_nowait(node_arr, arrlen, send_buf, send_size, recv_arr, recv_arr_size); } -- Gitblit v1.8.0