thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-24 08:32:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix stored_count metric

Browse Source
This commit is contained in:
Sema Checherinda 2024-04-03 15:33:35 +02:00
parent 8e6cbc8b31
commit 922a14eaf1
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/Common/HTTPConnectionPool.cpp
View File

@ -560,6 +560,11 @@ public:
size_t wipeExpiredImpl(std::vector<ConnectionPtr> & expired_connections) TSA_REQUIRES(mutex) size_t wipeExpiredImpl(std::vector<ConnectionPtr> & expired_connections) TSA_REQUIRES(mutex)
{ {
SCOPE_EXIT({
CurrentMetrics::sub(getMetrics().stored_count, expired_connections.size());
ProfileEvents::increment(getMetrics().expired, expired_connections.size());
});
auto isSoftLimitReached = group->isSoftLimitReached(); auto isSoftLimitReached = group->isSoftLimitReached();
while (!stored_connections.empty()) while (!stored_connections.empty())
{ {
@ -573,9 +578,6 @@ public:
expired_connections.push_back(connection); expired_connections.push_back(connection);
} }
CurrentMetrics::sub(getMetrics().stored_count, expired_connections.size());
ProfileEvents::increment(getMetrics().expired, expired_connections.size());
return stored_connections.size(); return stored_connections.size();
} }