thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-09 17:14:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

revert wrong data race fix

Browse Source
This commit is contained in:
serxa 2024-08-30 19:26:59 +00:00
parent 3bff7ddcf8
commit 30dd82324a
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/Common/HTTPConnectionPool.cpp
View File

@ -391,15 +391,11 @@ private:
{
auto idle = idleTime();
// Reset data hooks for IO scheduling
// Set data hooks for IO scheduling
if (ResourceLink link = CurrentThread::getReadResourceLink())
Session::setReceiveDataHooks(std::make_shared<ResourceGuardSessionDataHooks>(link, ResourceGuard::Metrics::getIORead(), log, request.getMethod(), request.getURI()));
else
Session::setReceiveDataHooks();
if (ResourceLink link = CurrentThread::getWriteResourceLink())
Session::setSendDataHooks(std::make_shared<ResourceGuardSessionDataHooks>(link, ResourceGuard::Metrics::getIOWrite(), log, request.getMethod(), request.getURI()));
else
Session::setSendDataHooks();
std::ostream & result = Session::sendRequest(request);
result.exceptions(std::ios::badbit);
@ -457,6 +453,8 @@ private:
}
}
response_stream = nullptr;
Session::setSendDataHooks();
Session::setReceiveDataHooks();
group->atConnectionDestroy();