diff options
author | kruall <kruall@ydb.tech> | 2023-09-08 12:28:12 +0300 |
---|---|---|
committer | kruall <kruall@ydb.tech> | 2023-09-08 13:20:40 +0300 |
commit | eafbd0b11816ab46afdde411eb4ae97eda8c363a (patch) | |
tree | 192f028b145e0210ac74c969f76cc7bd34c0e6a6 | |
parent | 5d91ce8329809af2787020c1acdb81266ff8cb6c (diff) | |
download | ydb-eafbd0b11816ab46afdde411eb4ae97eda8c363a.tar.gz |
Add thread count metrics to io pool, KIKIMR-18214
-rw-r--r-- | library/cpp/actors/core/executor_pool_io.cpp | 6 |
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(); |