From 184292b730f4236bd4840e780fdad97ee060ec84 Mon Sep 17 00:00:00 2001 From: Vas Crabb Date: Mon, 22 Apr 2024 08:04:58 +1000 Subject: 3rdparty/asio: Updated to 1.30.2 --- .../examples/cpp11/tutorial/daytime3/server.cpp | 118 +++++++++++++++++++++ 1 file changed, 118 insertions(+) create mode 100644 3rdparty/asio/src/examples/cpp11/tutorial/daytime3/server.cpp (limited to '3rdparty/asio/src/examples/cpp11/tutorial/daytime3/server.cpp') diff --git a/3rdparty/asio/src/examples/cpp11/tutorial/daytime3/server.cpp b/3rdparty/asio/src/examples/cpp11/tutorial/daytime3/server.cpp new file mode 100644 index 00000000000..339de72d4a7 --- /dev/null +++ b/3rdparty/asio/src/examples/cpp11/tutorial/daytime3/server.cpp @@ -0,0 +1,118 @@ +// +// server.cpp +// ~~~~~~~~~~ +// +// 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) +// + +#include +#include +#include +#include +#include +#include + +using asio::ip::tcp; + +std::string make_daytime_string() +{ + using namespace std; // For time_t, time and ctime; + time_t now = time(0); + return ctime(&now); +} + +class tcp_connection + : public std::enable_shared_from_this +{ +public: + typedef std::shared_ptr pointer; + + static pointer create(asio::io_context& io_context) + { + return pointer(new tcp_connection(io_context)); + } + + tcp::socket& socket() + { + return socket_; + } + + void start() + { + message_ = make_daytime_string(); + + asio::async_write(socket_, asio::buffer(message_), + std::bind(&tcp_connection::handle_write, shared_from_this(), + asio::placeholders::error, + asio::placeholders::bytes_transferred)); + } + +private: + tcp_connection(asio::io_context& io_context) + : socket_(io_context) + { + } + + void handle_write(const std::error_code& /*error*/, + size_t /*bytes_transferred*/) + { + } + + tcp::socket socket_; + std::string message_; +}; + +class tcp_server +{ +public: + tcp_server(asio::io_context& io_context) + : io_context_(io_context), + acceptor_(io_context, tcp::endpoint(tcp::v4(), 13)) + { + start_accept(); + } + +private: + void start_accept() + { + tcp_connection::pointer new_connection = + tcp_connection::create(io_context_); + + acceptor_.async_accept(new_connection->socket(), + std::bind(&tcp_server::handle_accept, this, new_connection, + asio::placeholders::error)); + } + + void handle_accept(tcp_connection::pointer new_connection, + const std::error_code& error) + { + if (!error) + { + new_connection->start(); + } + + start_accept(); + } + + asio::io_context& io_context_; + tcp::acceptor acceptor_; +}; + +int main() +{ + try + { + asio::io_context io_context; + tcp_server server(io_context); + io_context.run(); + } + catch (std::exception& e) + { + std::cerr << e.what() << std::endl; + } + + return 0; +} -- cgit v1.2.3-70-g09d2