diff options
author | ienkovich <ienkovich@yandex-team.ru> | 2022-02-10 16:47:49 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:47:49 +0300 |
commit | 5bd76e73fa8dd777999be2668ff56928cc3dbecb (patch) | |
tree | cee73b6c84f7566d11209bd978e29a7fd9ccec54 /library/cpp/monlib/dynamic_counters/counters.cpp | |
parent | b031b9d140bcd39f4ef2764e24d37bee317aaf23 (diff) | |
download | ydb-5bd76e73fa8dd777999be2668ff56928cc3dbecb.tar.gz |
Restoring authorship annotation for <ienkovich@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/monlib/dynamic_counters/counters.cpp')
-rw-r--r-- | library/cpp/monlib/dynamic_counters/counters.cpp | 54 |
1 files changed, 27 insertions, 27 deletions
diff --git a/library/cpp/monlib/dynamic_counters/counters.cpp b/library/cpp/monlib/dynamic_counters/counters.cpp index 3635d87d0d..9e7a970267 100644 --- a/library/cpp/monlib/dynamic_counters/counters.cpp +++ b/library/cpp/monlib/dynamic_counters/counters.cpp @@ -102,17 +102,17 @@ THistogramPtr TDynamicCounters::FindNamedHistogram(const TString& name,const TSt return AsHistogramRef(FindNamedCounterImpl<THistogramCounter>(name, value)); } -void TDynamicCounters::RemoveCounter(const TString &value) { - RemoveNamedCounter("sensor", value); -} - -void TDynamicCounters::RemoveNamedCounter(const TString& name, const TString &value) { +void TDynamicCounters::RemoveCounter(const TString &value) { + RemoveNamedCounter("sensor", value); +} + +void TDynamicCounters::RemoveNamedCounter(const TString& name, const TString &value) { auto g = LockForUpdate("RemoveNamedCounter", name, value); if (const auto it = Counters.find({name, value}); it != Counters.end() && AsCounter(it->second)) { - Counters.erase(it); + Counters.erase(it); } -} - +} + TIntrusivePtr<TDynamicCounters> TDynamicCounters::GetSubgroup(const TString& name, const TString& value) { auto res = FindSubgroup(name, value); if (!res) { @@ -134,21 +134,21 @@ TIntrusivePtr<TDynamicCounters> TDynamicCounters::FindSubgroup(const TString& na return it != Counters.end() ? AsDynamicCounters(it->second) : nullptr; } -void TDynamicCounters::RemoveSubgroup(const TString& name, const TString& value) { +void TDynamicCounters::RemoveSubgroup(const TString& name, const TString& value) { auto g = LockForUpdate("RemoveSubgroup", name, value); if (const auto it = Counters.find({name, value}); it != Counters.end() && AsDynamicCounters(it->second)) { - Counters.erase(it); + Counters.erase(it); } -} - +} + void TDynamicCounters::ReplaceSubgroup(const TString& name, const TString& value, TIntrusivePtr<TDynamicCounters> subgroup) { auto g = LockForUpdate("ReplaceSubgroup", name, value); const auto it = Counters.find({name, value}); Y_VERIFY(it != Counters.end() && AsDynamicCounters(it->second)); it->second = std::move(subgroup); -} - -void TDynamicCounters::MergeWithSubgroup(const TString& name, const TString& value) { +} + +void TDynamicCounters::MergeWithSubgroup(const TString& name, const TString& value) { auto g = LockForUpdate("MergeWithSubgroup", name, value); auto it = Counters.find({name, value}); Y_VERIFY(it != Counters.end()); @@ -159,30 +159,30 @@ void TDynamicCounters::MergeWithSubgroup(const TString& name, const TString& val AtomicAdd(ExpiringCount, AtomicSwap(&subgroup->ExpiringCount, 0)); } -void TDynamicCounters::ResetCounters(bool derivOnly) { +void TDynamicCounters::ResetCounters(bool derivOnly) { TReadGuard g(Lock); for (auto& [key, value] : Counters) { if (auto counter = AsCounter(value)) { if (!derivOnly || counter->ForDerivative()) { - *counter = 0; + *counter = 0; } } else if (auto subgroup = AsDynamicCounters(value)) { - subgroup->ResetCounters(derivOnly); - } - } -} - + subgroup->ResetCounters(derivOnly); + } + } +} + void TDynamicCounters::RegisterCountable(const TString& name, const TString& value, TCountablePtr countable) { Y_VERIFY(countable); auto g = LockForUpdate("RegisterCountable", name, value); const bool inserted = Counters.emplace(TChildId(name, value), std::move(countable)).second; Y_VERIFY(inserted); -} - -void TDynamicCounters::RegisterSubgroup(const TString& name, const TString& value, TIntrusivePtr<TDynamicCounters> subgroup) { +} + +void TDynamicCounters::RegisterSubgroup(const TString& name, const TString& value, TIntrusivePtr<TDynamicCounters> subgroup) { RegisterCountable(name, value, subgroup); -} - +} + void TDynamicCounters::OutputHtml(IOutputStream& os) const { HTML(os) { PRE() { |