thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-19 16:20:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

style

Browse Source
This commit is contained in:
serxa 2024-06-18 11:52:40 +00:00
parent ea21f61f19
commit a9bfaf6454
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/Common/HTTPConnectionPool.cpp
View File

@ -383,16 +383,15 @@ private:
auto idle = idleTime();
// Reset data hooks for IO scheduling
if (ResourceLink link = CurrentThread::getReadResourceLink()) {
if (ResourceLink link = CurrentThread::getReadResourceLink())
Session::setReceiveDataHooks(std::make_shared<ResourceGuardSessionDataHooks>(ResourceGuard::Metrics::getIORead(), link));
} else {
else
Session::setReceiveDataHooks();
}
if (ResourceLink link = CurrentThread::getWriteResourceLink()) {
if (ResourceLink link = CurrentThread::getWriteResourceLink())
Session::setSendDataHooks(std::make_shared<ResourceGuardSessionDataHooks>(ResourceGuard::Metrics::getIOWrite(), link));
} else {
else
Session::setSendDataHooks();
}
std::ostream & result = Session::sendRequest(request);
result.exceptions(std::ios::badbit);