diff options
Diffstat (limited to 'src/zenhttp/transports/asiotransport.cpp')
| -rw-r--r-- | src/zenhttp/transports/asiotransport.cpp | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/src/zenhttp/transports/asiotransport.cpp b/src/zenhttp/transports/asiotransport.cpp index 23ac1bc8b..d5413b9af 100644 --- a/src/zenhttp/transports/asiotransport.cpp +++ b/src/zenhttp/transports/asiotransport.cpp @@ -47,10 +47,10 @@ private: uint16_t m_BasePort = 8558; int m_ThreadCount = 0; - asio::io_service m_IoService; - asio::io_service::work m_Work{m_IoService}; - std::unique_ptr<AsioTransportAcceptor> m_Acceptor; - std::vector<std::thread> m_ThreadPool; + asio::io_context m_IoService; + asio::executor_work_guard<asio::io_context::executor_type> m_Work{m_IoService.get_executor()}; + std::unique_ptr<AsioTransportAcceptor> m_Acceptor; + std::vector<std::thread> m_ThreadPool; }; struct AsioTransportConnection : public TransportConnection, std::enable_shared_from_this<AsioTransportConnection> @@ -85,7 +85,7 @@ private: struct AsioTransportAcceptor { - AsioTransportAcceptor(TransportServer* ServerInterface, asio::io_service& IoService, uint16_t BasePort); + AsioTransportAcceptor(TransportServer* ServerInterface, asio::io_context& IoService, uint16_t BasePort); ~AsioTransportAcceptor(); void Start(); @@ -95,7 +95,7 @@ struct AsioTransportAcceptor private: TransportServer* m_ServerInterface = nullptr; - asio::io_service& m_IoService; + asio::io_context& m_IoService; asio::ip::tcp::acceptor m_Acceptor; std::atomic<bool> m_IsStopped{false}; @@ -104,7 +104,7 @@ private: ////////////////////////////////////////////////////////////////////////// -AsioTransportAcceptor::AsioTransportAcceptor(TransportServer* ServerInterface, asio::io_service& IoService, uint16_t BasePort) +AsioTransportAcceptor::AsioTransportAcceptor(TransportServer* ServerInterface, asio::io_context& IoService, uint16_t BasePort) : m_ServerInterface(ServerInterface) , m_IoService(IoService) , m_Acceptor(m_IoService, asio::ip::tcp::v6()) |