diff --git a/lib/base/io-engine.cpp b/lib/base/io-engine.cpp index 3938d58e4..140ea2ecf 100644 --- a/lib/base/io-engine.cpp +++ b/lib/base/io-engine.cpp @@ -16,7 +16,7 @@ using namespace icinga; -CpuBoundWork::CpuBoundWork(boost::asio::yield_context yc, boost::asio::io_context::strand&) +CpuBoundWork::CpuBoundWork(boost::asio::yield_context yc) : m_Done(false) { auto& ioEngine (IoEngine::Get()); diff --git a/lib/base/io-engine.hpp b/lib/base/io-engine.hpp index 0662df3c7..0097f92d5 100644 --- a/lib/base/io-engine.hpp +++ b/lib/base/io-engine.hpp @@ -17,7 +17,6 @@ #include #include #include -#include #include namespace icinga @@ -31,7 +30,7 @@ namespace icinga class CpuBoundWork { public: - CpuBoundWork(boost::asio::yield_context yc, boost::asio::io_context::strand&); + CpuBoundWork(boost::asio::yield_context yc); CpuBoundWork(const CpuBoundWork&) = delete; CpuBoundWork(CpuBoundWork&&) = delete; CpuBoundWork& operator=(const CpuBoundWork&) = delete; diff --git a/lib/remote/httpserverconnection.cpp b/lib/remote/httpserverconnection.cpp index 5612e5305..ed14fb30a 100644 --- a/lib/remote/httpserverconnection.cpp +++ b/lib/remote/httpserverconnection.cpp @@ -345,8 +345,7 @@ bool EnsureValidBody( ApiUser::Ptr& authenticatedUser, boost::beast::http::response& response, bool& shuttingDown, - boost::asio::yield_context& yc, - boost::asio::io_context::strand& strand + boost::asio::yield_context& yc ) { namespace http = boost::beast::http; @@ -437,14 +436,13 @@ bool ProcessRequest( HttpServerConnection& server, CpuBoundWork*& m_HandlingRequest, bool& hasStartedStreaming, - boost::asio::yield_context& yc, - boost::asio::io_context::strand& strand + boost::asio::yield_context& yc ) { namespace http = boost::beast::http; try { - CpuBoundWork handlingRequest (yc, strand); + CpuBoundWork handlingRequest (yc); Defer resetHandlingRequest ([&m_HandlingRequest] { m_HandlingRequest = nullptr; }); m_HandlingRequest = &handlingRequest; @@ -554,13 +552,13 @@ void HttpServerConnection::ProcessMessages(boost::asio::yield_context yc) break; } - if (!EnsureValidBody(*m_Stream, buf, parser, authenticatedUser, response, m_ShuttingDown, yc, m_IoStrand)) { + if (!EnsureValidBody(*m_Stream, buf, parser, authenticatedUser, response, m_ShuttingDown, yc)) { break; } m_Seen = std::numeric_limits::max(); - if (!ProcessRequest(*m_Stream, request, authenticatedUser, response, *this, m_HandlingRequest, m_HasStartedStreaming, yc, m_IoStrand)) { + if (!ProcessRequest(*m_Stream, request, authenticatedUser, response, *this, m_HandlingRequest, m_HasStartedStreaming, yc)) { break; } diff --git a/lib/remote/jsonrpcconnection.cpp b/lib/remote/jsonrpcconnection.cpp index 50d0976b7..cd684af6e 100644 --- a/lib/remote/jsonrpcconnection.cpp +++ b/lib/remote/jsonrpcconnection.cpp @@ -78,7 +78,7 @@ void JsonRpcConnection::HandleIncomingMessages(boost::asio::yield_context yc) m_Seen = Utility::GetTime(); try { - CpuBoundWork handleMessage (yc, m_IoStrand); + CpuBoundWork handleMessage (yc); MessageHandler(message);