mirror of
https://github.com/boostorg/asio.git
synced 2026-01-30 19:32:09 +00:00
2b5306585d
........ r43377 | chris_kohlhoff | 2008-02-23 09:43:54 +1100 (Sat, 23 Feb 2008) | 2 lines Use the correct vector of timer queues when dispatching timers. ........ r43437 | chris_kohlhoff | 2008-02-29 23:57:57 +1100 (Fri, 29 Feb 2008) | 2 lines Add missing tie(). ........ r43469 | chris_kohlhoff | 2008-03-04 00:21:05 +1100 (Tue, 04 Mar 2008) | 4 lines Disable use of CancelIo by default, due to the possibility of silent failure on some system configurations. Swallow error returned by CancelIoEx if there are no operations to be cancelled. ........ r43470 | chris_kohlhoff | 2008-03-04 00:27:06 +1100 (Tue, 04 Mar 2008) | 2 lines Add missing 'boost_' prefix to helper namespace. ........ r43471 | chris_kohlhoff | 2008-03-04 00:36:35 +1100 (Tue, 04 Mar 2008) | 2 lines Regenerate documentation. ........ r43472 | chris_kohlhoff | 2008-03-04 01:05:35 +1100 (Tue, 04 Mar 2008) | 1 line Update copyright notices. ........ r43473 | chris_kohlhoff | 2008-03-04 01:13:01 +1100 (Tue, 04 Mar 2008) | 2 lines Update copyright notices. ........ r43569 | chris_kohlhoff | 2008-03-13 00:25:49 +1100 (Thu, 13 Mar 2008) | 4 lines Revert to having the windows-bug workaround (short timeout on GetQueuedCompletionStatus) on all threads as there are still scenarios where threads can get stuck indefinitely. ........ [SVN r43571]
84 lines
2.1 KiB
C++
84 lines
2.1 KiB
C++
//
|
|
// connection.hpp
|
|
// ~~~~~~~~~~~~~~
|
|
//
|
|
// Copyright (c) 2003-2008 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)
|
|
//
|
|
|
|
#ifndef HTTP_CONNECTION_HPP
|
|
#define HTTP_CONNECTION_HPP
|
|
|
|
#include <boost/asio.hpp>
|
|
#include <boost/array.hpp>
|
|
#include <boost/noncopyable.hpp>
|
|
#include <boost/shared_ptr.hpp>
|
|
#include <boost/enable_shared_from_this.hpp>
|
|
#include "reply.hpp"
|
|
#include "request.hpp"
|
|
#include "request_handler.hpp"
|
|
#include "request_parser.hpp"
|
|
|
|
namespace http {
|
|
namespace server {
|
|
|
|
class connection_manager;
|
|
|
|
/// Represents a single connection from a client.
|
|
class connection
|
|
: public boost::enable_shared_from_this<connection>,
|
|
private boost::noncopyable
|
|
{
|
|
public:
|
|
/// Construct a connection with the given io_service.
|
|
explicit connection(boost::asio::io_service& io_service,
|
|
connection_manager& manager, request_handler& handler);
|
|
|
|
/// Get the socket associated with the connection.
|
|
boost::asio::ip::tcp::socket& socket();
|
|
|
|
/// Start the first asynchronous operation for the connection.
|
|
void start();
|
|
|
|
/// Stop all asynchronous operations associated with the connection.
|
|
void stop();
|
|
|
|
private:
|
|
/// Handle completion of a read operation.
|
|
void handle_read(const boost::system::error_code& e,
|
|
std::size_t bytes_transferred);
|
|
|
|
/// Handle completion of a write operation.
|
|
void handle_write(const boost::system::error_code& e);
|
|
|
|
/// Socket for the connection.
|
|
boost::asio::ip::tcp::socket socket_;
|
|
|
|
/// The manager for this connection.
|
|
connection_manager& connection_manager_;
|
|
|
|
/// The handler used to process the incoming request.
|
|
request_handler& request_handler_;
|
|
|
|
/// Buffer for incoming data.
|
|
boost::array<char, 8192> buffer_;
|
|
|
|
/// The incoming request.
|
|
request request_;
|
|
|
|
/// The parser for the incoming request.
|
|
request_parser request_parser_;
|
|
|
|
/// The reply to be sent back to the client.
|
|
reply reply_;
|
|
};
|
|
|
|
typedef boost::shared_ptr<connection> connection_ptr;
|
|
|
|
} // namespace server
|
|
} // namespace http
|
|
|
|
#endif // HTTP_CONNECTION_HPP
|