mirror/oatpp
2
0
Fork 0
mirror of https://github.com/oatpp/oatpp.git synced 2025-02-23 17:40:28 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #444 from samarai-jk/master

Browse Source 
ClientConnectionPool: close pool-connection if server has closed it
This commit is contained in:
Leonid Stryzhevskyi 2021-07-20 08:35:20 +03:00 committed by GitHub
commit 6c504bfb47
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/oatpp/web/client/HttpRequestExecutor.cpp
View File

@ -141,13 +141,19 @@ HttpRequestExecutor::executeOnce(const String& method,
throw RequestExecutionError(RequestExecutionError::ERROR_CODE_CANT_PARSE_STARTING_LINE, throw RequestExecutionError(RequestExecutionError::ERROR_CODE_CANT_PARSE_STARTING_LINE,
"[oatpp::web::client::HttpRequestExecutor::executeOnce()]: Failed to read response."); "[oatpp::web::client::HttpRequestExecutor::executeOnce()]: Failed to read response.");
} }
auto con_hdr = result.headers.getAsMemoryLabel<oatpp::data::share::StringKeyLabelCI>("Connection");
if (con_hdr == "close")
{
invalidateConnection(connectionHandle);
}
auto bodyStream = oatpp::data::stream::InputStreamBufferedProxy::createShared(connection, auto bodyStream = oatpp::data::stream::InputStreamBufferedProxy::createShared(connection,
buffer, buffer,
result.bufferPosStart, result.bufferPosStart,
result.bufferPosEnd, result.bufferPosEnd,
result.bufferPosStart != result.bufferPosEnd); result.bufferPosStart != result.bufferPosEnd);
return Response::createShared(result.startingLine.statusCode, return Response::createShared(result.startingLine.statusCode,
result.startingLine.description.toString(), result.startingLine.description.toString(),
result.headers, bodyStream, m_bodyDecoder); result.headers, bodyStream, m_bodyDecoder);