From 973692652774a5ffe98478ee287b40af529d0b39 Mon Sep 17 00:00:00 2001
From: wangzhengquan <wangzhengquan85@126.com>
Date: 星期三, 13 一月 2021 14:14:58 +0800
Subject: [PATCH] update
---
src/socket/net_mod_socket.cpp | 17 ++---------------
1 files changed, 2 insertions(+), 15 deletions(-)
diff --git a/src/socket/net_mod_socket.cpp b/src/socket/net_mod_socket.cpp
index 2ac2dfa..f7c1242 100644
--- a/src/socket/net_mod_socket.cpp
+++ b/src/socket/net_mod_socket.cpp
@@ -137,24 +137,11 @@
}
NetConnPool* NetModSocket::_get_pool() {
- return gpool;
+ return _get_threadlocal_pool();
}
+
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 ) {
- int s, rv;
- if ((s = pthread_mutex_lock(&sendMutex)) != 0)
- err_exit(s, "NetModSocket : pthread_mutex_lock");
-
- rv = _sendandrecv_unsafe(node_arr, arrlen, send_buf, send_size, recv_arr, recv_arr_size, msec );
-
- if ((s = pthread_mutex_unlock(&sendMutex)) != 0)
- err_exit(s, "NetModSocket : pthread_mutex_lock");
-
- return rv;
-}
-
-int NetModSocket::_sendandrecv_unsafe(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 ) {
int i, n, recv_size, connfd;
--
Gitblit v1.8.0