diff options
Diffstat (limited to '3rdparty/asio/src/examples/cpp11/http/server3/connection.hpp')
-rw-r--r-- | 3rdparty/asio/src/examples/cpp11/http/server3/connection.hpp | 71 |
1 files changed, 71 insertions, 0 deletions
diff --git a/3rdparty/asio/src/examples/cpp11/http/server3/connection.hpp b/3rdparty/asio/src/examples/cpp11/http/server3/connection.hpp new file mode 100644 index 00000000000..878cd45d366 --- /dev/null +++ b/3rdparty/asio/src/examples/cpp11/http/server3/connection.hpp @@ -0,0 +1,71 @@ +// +// connection.hpp +// ~~~~~~~~~~~~~~ +// +// Copyright (c) 2003-2024 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_SERVER3_CONNECTION_HPP +#define HTTP_SERVER3_CONNECTION_HPP + +#include <asio.hpp> +#include <array> +#include <memory> +#include "reply.hpp" +#include "request.hpp" +#include "request_handler.hpp" +#include "request_parser.hpp" + +namespace http { +namespace server3 { + +/// Represents a single connection from a client. +class connection + : public std::enable_shared_from_this<connection> +{ +public: + connection(const connection&) = delete; + connection& operator=(const connection&) = delete; + + /// Construct a connection with the given socket. + explicit connection(asio::ip::tcp::socket socket, + request_handler& handler); + + /// Start the first asynchronous operation for the connection. + void start(); + +private: + /// Perform an asynchronous read operation. + void do_read(); + + /// Perform an asynchronous write operation. + void do_write(); + + /// Socket for the connection. + asio::ip::tcp::socket socket_; + + /// The handler used to process the incoming request. + request_handler& request_handler_; + + /// Buffer for incoming data. + std::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 std::shared_ptr<connection> connection_ptr; + +} // namespace server3 +} // namespace http + +#endif // HTTP_SERVER3_CONNECTION_HPP |