[boost] Asio multithreaded server: problem persists, sample program

23 Nov 2006

      I made the test with the CVS version of boost and I still fall in the  
problem that I have reported some days ago :(
Btw I think that a bug in the Windows API GetQueuedCompletionStatus sounds  
very strange to me because I think that implementations like this one are  
very common or I'm wrong?

//////////////////////////////////////////////////////////////////////////////////////////////////////////

#include "boost/asio.hpp"
#include "boost/thread.hpp"
#include "boost/bind.hpp"

//////////////////////////////////////////////////////////////////////////////////////////////////////////

class Session
{
public:
	Session(boost::asio::io_service &service) : m_socket(service) { }
	~Session() { m_socket.close(); }

	boost::asio::ip::tcp::socket & socket() { return m_socket; }

	void run()
	{
		m_socket.async_read_some(boost::asio::buffer(m_buffer),
		boost::bind(&Session::read_handler, this, _1, _2));
	}

	std::string generate_response()
	{
		Sleep(10000);  // It takes a lot of time to say Hello :)
		static int counter = 0;
		counter++;
		std::stringstream stream;
		stream << "<html><body><h2>Hello " << counter << "</h2></body></html>";
		return stream.str();
	}

	void read_handler(const boost::system::error_code &e, size_t  
bytes_transferred)
	{
		if(!e)
		{
			boost::asio::async_write(m_socket,  
boost::asio::buffer(generate_response()),
			boost::bind(&Session::write_handler, this, _1, _2));
		}
	}

	void write_handler(const boost::system::error_code &e, size_t  
bytes_transferred)
	{
		delete this;
	}

private:
	boost::asio::ip::tcp::socket m_socket;
	boost::array<char, 8192> m_buffer;	
};

//////////////////////////////////////////////////////////////////////////////////////////////////////////

class Server
{
public:
	Server(int port) : m_service(),
				 m_acceptor(m_service)
	{
		boost::asio::ip::tcp::endpoint endpoint(boost::asio::ip::tcp::v4(),  
port);
		m_acceptor.open(endpoint.protocol());
		m_acceptor.bind(endpoint);
		m_acceptor.listen();
		accept();
	}	

	void accept()
	{
		Session *connection = new Session(m_service);
		m_acceptor.async_accept(connection->socket(),  
boost::bind(&Server::accept_handler, this, _1, connection));	
	}

	void run(int threads = 10)
	{
		boost::thread_group threads_pool;
		while(threads-- > 0)
			threads_pool.create_thread(boost::bind(&boost::asio::io_service::run,  
&m_service));

		m_service.run();		
	}

	void accept_handler(const boost::system::error_code &e, Session  
*connection)
	{
		if(!e)
		{		
			connection->run();		
			accept();
		}
	}

protected:
	boost::asio::io_service m_service;		
	boost::asio::ip::tcp::acceptor m_acceptor;		
};

//////////////////////////////////////////////////////////////////////////////////////////////////////////

int main(int argc, char *argv)
{
	Server server(7070);
	server.run();	
	return 0;
}

//////////////////////////////////////////////////////////////////////////////////////////////////////////

As reported in my previous message all handlers are invoked with the  
params _1/_2 due to a multiple definition link error.
Bye

[boost] Asio multithreaded server: problem persists, sample program

berserker_r