aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorkruall <kruall@ydb.tech>2023-09-08 12:28:12 +0300
committerkruall <kruall@ydb.tech>2023-09-08 13:20:40 +0300
commiteafbd0b11816ab46afdde411eb4ae97eda8c363a (patch)
tree192f028b145e0210ac74c969f76cc7bd34c0e6a6
parent5d91ce8329809af2787020c1acdb81266ff8cb6c (diff)
downloadydb-eafbd0b11816ab46afdde411eb4ae97eda8c363a.tar.gz
Add thread count metrics to io pool, KIKIMR-18214
-rw-r--r--library/cpp/actors/core/executor_pool_io.cpp6
1 files changed, 5 insertions, 1 deletions
diff --git a/library/cpp/actors/core/executor_pool_io.cpp b/library/cpp/actors/core/executor_pool_io.cpp
index 52cc25bed2..8fc0299169 100644
--- a/library/cpp/actors/core/executor_pool_io.cpp
+++ b/library/cpp/actors/core/executor_pool_io.cpp
@@ -136,7 +136,11 @@ namespace NActors {
Threads[i].Thread->Join();
}
- void TIOExecutorPool::GetCurrentStats(TExecutorPoolStats& /*poolStats*/, TVector<TExecutorThreadStats>& statsCopy) const {
+ void TIOExecutorPool::GetCurrentStats(TExecutorPoolStats& poolStats, TVector<TExecutorThreadStats>& statsCopy) const {
+ poolStats.CurrentThreadCount = PoolThreads;
+ poolStats.DefaultThreadCount = PoolThreads;
+ poolStats.MaxThreadCount = PoolThreads;
+ poolStats.PotentialMaxThreadCount = PoolThreads;
statsCopy.resize(PoolThreads + 1);
// Save counters from the pool object
statsCopy[0] = TExecutorThreadStats();