wangzhengquan
2020-10-13 d6a27f15acd08e99841595cece2b3e3e8045491a
src/socket/net_mod_server_socket.h
@@ -23,21 +23,27 @@
     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:
   int listenfd;
   ShmModSocket * shm_mod_socket;
   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(int connfd);
public:
   NetModServerSocket(int port, ShmModSocket *_shm_mod_socket);
   NetModServerSocket(int port);
   void start();
   ~NetModServerSocket();