diff --git a/examples/ace/ttcp/ttcp_asio_async.cc b/examples/ace/ttcp/ttcp_asio_async.cc index d6867dab2..7fb681e02 100644 --- a/examples/ace/ttcp/ttcp_asio_async.cc +++ b/examples/ace/ttcp/ttcp_asio_async.cc @@ -25,8 +25,8 @@ class TtcpServerConnection : public std::enable_shared_from_this(acceptor.get_executor().context()))); #endif acceptor.async_accept( new_connection->socket(), @@ -170,10 +170,19 @@ void receive(const Options& opt) { try { +#if BOOST_VERSION < 107000L boost::asio::io_service io_service; tcp::acceptor acceptor(io_service, tcp::endpoint(tcp::v4(), opt.port)); +#else + boost::asio::io_context io_context; + tcp::acceptor acceptor(io_context, tcp::endpoint(tcp::v4(), opt.port)); +#endif doAccept(acceptor); +#if BOOST_VERSION < 107000L io_service.run(); +#else + io_context.run(); +#endif } catch (std::exception& e) { diff --git a/examples/ace/ttcp/ttcp_asio_sync.cc b/examples/ace/ttcp/ttcp_asio_sync.cc index 96c53d040..d5de3be1f 100644 --- a/examples/ace/ttcp/ttcp_asio_sync.cc +++ b/examples/ace/ttcp/ttcp_asio_sync.cc @@ -21,9 +21,16 @@ void receive(const Options& opt) { try { +#if BOOST_VERSION < 107000L boost::asio::io_service io_service; tcp::acceptor acceptor(io_service, tcp::endpoint(tcp::v4(), opt.port)); tcp::socket socket(io_service); +#else + boost::asio::io_context io_context; + tcp::acceptor acceptor(io_context, tcp::endpoint(tcp::v4(), opt.port)); + tcp::socket socket(io_context); +#endif + acceptor.accept(socket); struct SessionMessage sessionMessage = { 0, 0 };