mirror of
https://github.com/boostorg/asio.git
synced 2026-01-22 05:02:08 +00:00
d41d2d15e9
io_service.notify_fork() at the appropriate times. Two new examples have been added showing how to use this feature. Refs #3238, #4162. * Clean up the handling of errors reported by the close() system call. In particular, assume that most operating systems won't have close() fail with EWOULDBLOCK, but if it does then set blocking mode and restart the call. If any other error occurs we assume the descriptor is closed. Refs #3307. * EV_ONESHOT seems to cause problems on some versions of Mac OS X, with the io_service destructor getting stuck inside the close() system call. Use EV_CLEAR instead. Refs #5021. * Include function name in exception what() messages. * Fix insufficient initialisers warning with MinGW. * Make the shutdown_service() member functions private. * Add archetypes for testing socket option functions. * Add missing lock in signal_set_service::cancel(). * Fix copy/paste error in SignalHandler example. * The signal header needs to be included in signal_set_service.hpp so that we can use constants like NSIG and SIGRTMAX. * Don't use Boost.Thread's convenience header. Use the header file that is specifically for the boost::thread class instead. [SVN r69467]
75 lines
2.2 KiB
C++
75 lines
2.2 KiB
C++
//
|
|
// server.cpp
|
|
// ~~~~~~~~~~
|
|
//
|
|
// Copyright (c) 2003-2011 Christopher M. Kohlhoff (chris at kohlhoff dot com)
|
|
//
|
|
// Distributed under the Boost Software License, Version 1.0. (See accompanying
|
|
// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
|
|
//
|
|
|
|
#include "server.hpp"
|
|
#include <boost/thread/thread.hpp>
|
|
#include <boost/bind.hpp>
|
|
#include <boost/shared_ptr.hpp>
|
|
#include <vector>
|
|
|
|
namespace http {
|
|
namespace server3 {
|
|
|
|
server::server(const std::string& address, const std::string& port,
|
|
const std::string& doc_root, std::size_t thread_pool_size)
|
|
: thread_pool_size_(thread_pool_size),
|
|
acceptor_(io_service_),
|
|
new_connection_(new connection(io_service_, request_handler_)),
|
|
request_handler_(doc_root)
|
|
{
|
|
// Open the acceptor with the option to reuse the address (i.e. SO_REUSEADDR).
|
|
boost::asio::ip::tcp::resolver resolver(io_service_);
|
|
boost::asio::ip::tcp::resolver::query query(address, port);
|
|
boost::asio::ip::tcp::endpoint endpoint = *resolver.resolve(query);
|
|
acceptor_.open(endpoint.protocol());
|
|
acceptor_.set_option(boost::asio::ip::tcp::acceptor::reuse_address(true));
|
|
acceptor_.bind(endpoint);
|
|
acceptor_.listen();
|
|
acceptor_.async_accept(new_connection_->socket(),
|
|
boost::bind(&server::handle_accept, this,
|
|
boost::asio::placeholders::error));
|
|
}
|
|
|
|
void server::run()
|
|
{
|
|
// Create a pool of threads to run all of the io_services.
|
|
std::vector<boost::shared_ptr<boost::thread> > threads;
|
|
for (std::size_t i = 0; i < thread_pool_size_; ++i)
|
|
{
|
|
boost::shared_ptr<boost::thread> thread(new boost::thread(
|
|
boost::bind(&boost::asio::io_service::run, &io_service_)));
|
|
threads.push_back(thread);
|
|
}
|
|
|
|
// Wait for all threads in the pool to exit.
|
|
for (std::size_t i = 0; i < threads.size(); ++i)
|
|
threads[i]->join();
|
|
}
|
|
|
|
void server::stop()
|
|
{
|
|
io_service_.stop();
|
|
}
|
|
|
|
void server::handle_accept(const boost::system::error_code& e)
|
|
{
|
|
if (!e)
|
|
{
|
|
new_connection_->start();
|
|
new_connection_.reset(new connection(io_service_, request_handler_));
|
|
acceptor_.async_accept(new_connection_->socket(),
|
|
boost::bind(&server::handle_accept, this,
|
|
boost::asio::placeholders::error));
|
|
}
|
|
}
|
|
|
|
} // namespace server3
|
|
} // namespace http
|