#include "ace/SOCK_Acceptor.h"
#include "ace/Acceptor.h"
#include "ace/Thread_Manager.h"
#include "ace/TP_Reactor.h"
#include "ace/Reactor.h"
#include "ace/INET_Addr.h"
#include "ace/OS.h"

#include "Server.h"

using namespace ACE_Server;

int main(int argc, char *argv[])
{
	ACE::init();//初始化ACE庫，在windows下一定要

	//設置服務器地址
	ACE_INET_Addr local_addr(SERVER_PORT_NUM, "localhost");

	Request_Handler *endpoint;
	ACE_NEW_RETURN (endpoint,Request_Handler(local_addr),-1);
	// Read data from other side.
	if (ACE_Reactor::instance ()->register_handler(endpoint,ACE_Event_Handler::READ_MASK) == -1)
		ACE_ERROR_RETURN ((LM_ERROR,"ACE_Reactor::register_handler"),-1);

	Server server_tp;
	server_tp.activate(THR_NEW_LWP | THR_JOINABLE, SERVER_THREAD_POOL_SIZE);
	ACE_Thread_Manager::instance()->wait();

	ACE::fini();
	system("pause");
	return 0;
}