From e994d555ba64d68d874099ed7c1b9e22c0b592b0 Mon Sep 17 00:00:00 2001
From: wangzhengquan <wangzhengquan85@126.com>
Date: 星期二, 01 十二月 2020 15:45:11 +0800
Subject: [PATCH] update
---
src/socket/net_mod_socket.h | 24 ++++++++++++------------
1 files changed, 12 insertions(+), 12 deletions(-)
diff --git a/src/socket/net_mod_socket.h b/src/socket/net_mod_socket.h
index 5e7b7b7..5f20ee9 100644
--- a/src/socket/net_mod_socket.h
+++ b/src/socket/net_mod_socket.h
@@ -5,12 +5,13 @@
#include "socket_io.h"
#include <poll.h>
-#define OPEN_MAX 1024
+
#define GET(p) (*(uint32_t *)(p))
#define PUT(p, val) (*(uint32_t *)(p) = (val))
#define GET_INT32(p) (*(int32_t *)(p))
#define PUT_INT32(p, val) (*(int32_t *)(p) = (val))
+
class NetModServerSocket;
@@ -60,13 +61,7 @@
};
class NetModSocket {
- struct pool{ /* Represents a pool of connected descriptors */ //line:conc:echoservers:beginpool
-
- int nready; /* Number of ready descriptors from select */
- int maxi; /* Highwater index into client array */
- struct pollfd conns[OPEN_MAX];
- // std::map<std::string, int> connectionMap;
- } ;
+
friend class NetModServerSocket;
private:
@@ -75,17 +70,22 @@
// pool req_resp_pool;
-
+ // request header 缂栫爜涓虹綉缁滀紶杈撶殑瀛楄妭
static void * encode_request_head(net_mod_request_head_t & request);
+ // 瑙ｇ爜request header
static net_mod_request_head_t decode_request_head(void *headbs);
static void * encode_response_head(net_mod_response_head_t & response);
static net_mod_response_head_t decode_response_head(void *_headbs);
- void init_conn_pool( pool& mpool);
- int connect(pool& mpool, net_node_t* node);
- void close_connect(pool& mpool , int connfd);
+ // 閿�姣乼hreadlocal pool
+ static void _destroyConnPool_(void *_pool);
+ // 鍒涘缓thread local key
+ static void _createKey_(void);
+
+ //璇诲彇杩斿洖淇℃伅
int read_response(int clientfd, net_mod_recv_msg_t *recv_msg);
+ // 鍙戦�佽姹備俊鎭�
int write_request(int clientfd, net_mod_request_head_t &request_head, void *send_buf, int send_size, void *topic_buf, int topic_size);
int _sendandrecv_(net_node_t *node_arr, int node_arr_len, void *send_buf, int send_size,
--
Gitblit v1.8.0