aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorDmitry Kardymon <kardymon-d@ydb.tech>2025-04-09 08:32:57 +0300
committerGitHub <noreply@github.com>2025-04-09 08:32:57 +0300
commite30884e7c80f5fe50760de64246f8f4d36713f61 (patch)
treecdc62e5b1527982a51df0a517454cf50604ef115
parent974186e89fb713c12bed34c21a8fccd099be7fe9 (diff)
downloadydb-e30884e7c80f5fe50760de64246f8f4d36713f61.tar.gz
Check ActorLibCollectUsageStats to reduce utils metric count (#15992)
-rw-r--r--ydb/library/actors/core/mailbox_lockfree.cpp2
-rw-r--r--ydb/library/actors/helpers/collector_counters.cpp12
2 files changed, 9 insertions, 5 deletions
diff --git a/ydb/library/actors/core/mailbox_lockfree.cpp b/ydb/library/actors/core/mailbox_lockfree.cpp
index f1f4a6b9d9d..872367021c9 100644
--- a/ydb/library/actors/core/mailbox_lockfree.cpp
+++ b/ydb/library/actors/core/mailbox_lockfree.cpp
@@ -361,7 +361,7 @@ namespace NActors {
Y_DEBUG_ABORT_UNLESS(GetNextPtr(tail) == nullptr);
#ifdef ACTORSLIB_COLLECT_EXEC_STATS
// Mark events as enqueued when usage stats are enabled
- if (ActorLibCollectUsageStats) {
+ if constexpr (ActorLibCollectUsageStats) {
for (IEventHandle* ev = head; ev; ev = GetNextPtr(ev)) {
if (IActor* actor = FindActor(ev->GetRecipientRewrite().LocalId())) {
actor->OnEnqueueEvent(ev->SendTime);
diff --git a/ydb/library/actors/helpers/collector_counters.cpp b/ydb/library/actors/helpers/collector_counters.cpp
index 9dc8d471ef7..a5ff0e9fc2d 100644
--- a/ydb/library/actors/helpers/collector_counters.cpp
+++ b/ydb/library/actors/helpers/collector_counters.cpp
@@ -70,8 +70,10 @@ void TActivityStats::Set(const TExecutorThreadStats& stats) {
*ScheduledEventsByActivityBuckets[i] = scheduled;
*StuckActorsByActivityBuckets[i] = stuck;
- for (ui32 j = 0; j < 10; ++j) {
- *UsageByActivityBuckets[i][j] = stats.UsageByActivity[i][j];
+ if constexpr (ActorLibCollectUsageStats) {
+ for (ui32 j = 0; j < 10; ++j) {
+ *UsageByActivityBuckets[i][j] = stats.UsageByActivity[i][j];
+ }
}
}
@@ -117,8 +119,10 @@ void TActivityStats::InitCountersForActivity(ui32 activityType) {
StuckActorsByActivityBuckets[activityType] =
Group->GetSubgroup("sensor", "StuckActorsByActivity")->GetNamedCounter("activity", bucketName, false);
- for (ui32 i = 0; i < 10; ++i) {
- UsageByActivityBuckets[activityType][i] = Group->GetSubgroup("sensor", "UsageByActivity")->GetSubgroup("bin", ToString(i))->GetNamedCounter("activity", bucketName, false);
+ if constexpr (ActorLibCollectUsageStats) {
+ for (ui32 i = 0; i < 10; ++i) {
+ UsageByActivityBuckets[activityType][i] = Group->GetSubgroup("sensor", "UsageByActivity")->GetSubgroup("bin", ToString(i))->GetNamedCounter("activity", bucketName, false);
+ }
}
}