diff --git a/src/oatpp/web/server/HttpConnectionHandler.cpp b/src/oatpp/web/server/HttpConnectionHandler.cpp index 3816e089..55835506 100644 --- a/src/oatpp/web/server/HttpConnectionHandler.cpp +++ b/src/oatpp/web/server/HttpConnectionHandler.cpp @@ -77,7 +77,7 @@ void HttpConnectionHandler::handleConnection(const std::shared_ptr 1) { concurrency -= 1; } - + /* Set thread affinity group CPUs [0..cpu_count - 1]. Leave one cpu free of workers */ oatpp::concurrency::setThreadAffinityToCpuRange(thread.native_handle(), 0, concurrency - 1 /* -1 because 0-based index */); diff --git a/src/oatpp/web/server/HttpProcessor.cpp b/src/oatpp/web/server/HttpProcessor.cpp index 8c24a78f..3e4044d1 100644 --- a/src/oatpp/web/server/HttpProcessor.cpp +++ b/src/oatpp/web/server/HttpProcessor.cpp @@ -260,6 +260,7 @@ HttpProcessor::Coroutine::Coroutine(const std::shared_ptr& component , m_connectionState(ConnectionState::ALIVE) {} + HttpProcessor::Coroutine::Action HttpProcessor::Coroutine::act() { return m_connection->initContextsAsync().next(yieldTo(&HttpProcessor::Coroutine::parseHeaders)); } diff --git a/src/oatpp/web/server/HttpProcessor.hpp b/src/oatpp/web/server/HttpProcessor.hpp index faf5f18a..51f18133 100644 --- a/src/oatpp/web/server/HttpProcessor.hpp +++ b/src/oatpp/web/server/HttpProcessor.hpp @@ -236,7 +236,7 @@ public: */ Coroutine(const std::shared_ptr& components, const std::shared_ptr& connection); - + Action act() override; Action parseHeaders(); @@ -249,7 +249,7 @@ public: Action onRequestDone(); Action handleError(Error* error) override; - + }; };