mirrors/oatpp
1
0
Fork 0
mirror of https://gitee.com/zyjblog/oatpp.git synced 2025-01-05 17:42:23 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Revert "Rebased this branch from v1.3.0 branch"

Browse Source 
This reverts commit f1b55ea625.
This commit is contained in:
MHaselmaier 2021-05-15 12:18:52 +02:00
parent d2c38cc740
commit 81601cb4b3
3 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/oatpp/web/server/HttpConnectionHandler.cpp
View File

@ -77,7 +77,7 @@ void HttpConnectionHandler::handleConnection(const std::shared_ptr<oatpp::data::
if(concurrency > 1) { if(concurrency > 1) {
concurrency -= 1; concurrency -= 1;
} }
/* Set thread affinity group CPUs [0..cpu_count - 1]. Leave one cpu free of workers */ /* 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 */); oatpp::concurrency::setThreadAffinityToCpuRange(thread.native_handle(), 0, concurrency - 1 /* -1 because 0-based index */);

1
src/oatpp/web/server/HttpProcessor.cpp
View File

@ -260,6 +260,7 @@ HttpProcessor::Coroutine::Coroutine(const std::shared_ptr<Components>& component
, m_connectionState(ConnectionState::ALIVE) , m_connectionState(ConnectionState::ALIVE)
{} {}
HttpProcessor::Coroutine::Action HttpProcessor::Coroutine::act() { HttpProcessor::Coroutine::Action HttpProcessor::Coroutine::act() {
return m_connection->initContextsAsync().next(yieldTo(&HttpProcessor::Coroutine::parseHeaders)); return m_connection->initContextsAsync().next(yieldTo(&HttpProcessor::Coroutine::parseHeaders));
} }

4
src/oatpp/web/server/HttpProcessor.hpp
View File

@ -236,7 +236,7 @@ public:
*/ */
Coroutine(const std::shared_ptr<Components>& components, Coroutine(const std::shared_ptr<Components>& components,
const std::shared_ptr<oatpp::data::stream::IOStream>& connection); const std::shared_ptr<oatpp::data::stream::IOStream>& connection);
Action act() override; Action act() override;
Action parseHeaders(); Action parseHeaders();
@ -249,7 +249,7 @@ public:
Action onRequestDone(); Action onRequestDone();
Action handleError(Error* error) override; Action handleError(Error* error) override;
}; };
}; };