From d9d5c2d3089345fa858deaf2c0dfbfb304b7a9f6 Mon Sep 17 00:00:00 2001 From: wangzhengquan <wangzhengquan85@126.com> Date: 星期五, 16 十月 2020 20:08:52 +0800 Subject: [PATCH] udpate --- src/socket/net_mod_server_socket.h | 13 +++++++++++-- 1 files changed, 11 insertions(+), 2 deletions(-) diff --git a/src/socket/net_mod_server_socket.h b/src/socket/net_mod_server_socket.h index c79837b..40219e1 100644 --- a/src/socket/net_mod_server_socket.h +++ b/src/socket/net_mod_server_socket.h @@ -23,7 +23,7 @@ int nready; /* Number of ready descriptors from select */ int maxi; /* Highwater index into client array */ int clientfd[FD_SETSIZE]; /* Set of active descriptors */ - rio_t clientrio[FD_SETSIZE]; /* Set of active read buffers */ + // rio_t clientrio[FD_SETSIZE]; /* Set of active read buffers */ } ; private: @@ -31,14 +31,23 @@ ShmModSocket shmModSocket; pool pool; + void *buf; + void *topic_buf; + size_t max_buf; + size_t max_topic_buf; + void init_pool(int listenfd); void add_client(int connfd); void check_clients(); - int process_client(rio_t *rio, int connfd); + int process_client(int connfd); public: NetModServerSocket(int port); + + /* + * 鍚姩 server + */ void start(); ~NetModServerSocket(); -- Gitblit v1.8.0