server.accept.cpp

server::server(
	asio::io_service& io_service, int port) : io_service(io_service),
	acceptor(io_service, asio::ip::tcp::endpoint(asio::ip::tcp::v4(), port)),
	new_conn(connection::create(io_service)
) {
	acceptor.async_accept(
		new_conn->getSocket(),
		bind(
			&server::handle_accept,
			this,
			asio::placeholders::error
		)
	);
}

void server::handle_accept(const system::error_code& e) {
	if (!e) {
		boost::thread t(
			bind(
				&connection::run,
				new_conn
			)
		);

		new_conn = connection::create(io_service);

		acceptor.async_accept(
			new_conn->getSocket(),
			boost::bind(
				&server::handle_accept,
				this,
				asio::placeholders::error
			)
		);
	} else {
		cout << "Error: " << e << endl;;
	}
}