#ifndef __NET_SERVER_MODE_SOCKET_H__
#define __NET_SERVER_MODE_SOCKET_H__

#include "usg_common.h"
#include "shm_mod_socket.h"
#include "socket_io.h"

class NetModServerSocket {

	struct net_mod_msg_t {
		int key;
		socket_mod_t mod;
		size_t content_size;
		void * content;
		size_t topic_size;
		void * topic;
	};

	struct pool{ /* Represents a pool of connected descriptors */ //line:conc:echoservers:beginpool
	  int maxfd;        /* Largest descriptor in read_set */
	  fd_set read_set;  /* Set of all active descriptors */
	  fd_set ready_set; /* Subset of descriptors ready for reading  */
	  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 */
	} ; 

private:
	int listenfd;
	int port;
	ShmModSocket shmModSocket;
	pool pool;

	void *buf;
	void *topic_buf;
	char *response_buf;

  size_t max_buf;
  size_t max_topic_buf;
  size_t max_response_buf;


	void init_pool(int listenfd);
	void add_client(int connfd);
	void check_clients();
	int process_client(int connfd);

public:

	NetModServerSocket(int port);
	
	/*
	 * 启动 server
	 * @return 0 success, 其他 failture
	*/
	int start();
	~NetModServerSocket();

};


#endif