| | |
| | | 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: |
| | |
| | | ShmModSocket shmModSocket; |
| | | pool pool; |
| | | |
| | | void *buf = NULL; |
| | | 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: |
| | | |