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

fix mixed read and write links

Browse Source
This commit is contained in:
serxa 2024-06-13 14:27:39 +00:00
parent 19c2f7109f
commit eb3c61915d
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/Common/HTTPConnectionPool.cpp
View File

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