diff options
author | Dmitry Kardymon <kardymon-d@ydb.tech> | 2025-04-09 08:32:57 +0300 |
---|---|---|
committer | GitHub <noreply@github.com> | 2025-04-09 08:32:57 +0300 |
commit | e30884e7c80f5fe50760de64246f8f4d36713f61 (patch) | |
tree | cdc62e5b1527982a51df0a517454cf50604ef115 | |
parent | 974186e89fb713c12bed34c21a8fccd099be7fe9 (diff) | |
download | ydb-e30884e7c80f5fe50760de64246f8f4d36713f61.tar.gz |
Check ActorLibCollectUsageStats to reduce utils metric count (#15992)
-rw-r--r-- | ydb/library/actors/core/mailbox_lockfree.cpp | 2 | ||||
-rw-r--r-- | ydb/library/actors/helpers/collector_counters.cpp | 12 |
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); + } } } |