diff options
author | danibw <danibw@yandex-team.ru> | 2022-02-10 16:50:12 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:50:12 +0300 |
commit | e8fdd1e6c0645bf1702aaf85cc7460dbd09977cb (patch) | |
tree | d96a47e62e16b199f4ffbf41f6848e9fad7dfa21 /library/cpp/monlib/metrics | |
parent | df6eb5b163c763cd9633a4850cfae72f8d742996 (diff) | |
download | ydb-e8fdd1e6c0645bf1702aaf85cc7460dbd09977cb.tar.gz |
Restoring authorship annotation for <danibw@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/monlib/metrics')
8 files changed, 55 insertions, 55 deletions
diff --git a/library/cpp/monlib/metrics/atomics_array.h b/library/cpp/monlib/metrics/atomics_array.h index f19aebf291..e044f14b00 100644 --- a/library/cpp/monlib/metrics/atomics_array.h +++ b/library/cpp/monlib/metrics/atomics_array.h @@ -31,12 +31,12 @@ namespace NMonitoring { Values_[index].fetch_add(count, std::memory_order_relaxed); } - void Reset() noexcept { - for (size_t i = 0; i < Size_; i++) { - Values_[i].store(0, std::memory_order_relaxed); - } - } - + void Reset() noexcept { + for (size_t i = 0; i < Size_; i++) { + Values_[i].store(0, std::memory_order_relaxed); + } + } + TVector<ui64> Copy() const { TVector<ui64> copy(Reserve(Size_)); for (size_t i = 0; i < Size_; i++) { diff --git a/library/cpp/monlib/metrics/histogram_collector.h b/library/cpp/monlib/metrics/histogram_collector.h index 9f6bbbdfb7..5afbf63c8e 100644 --- a/library/cpp/monlib/metrics/histogram_collector.h +++ b/library/cpp/monlib/metrics/histogram_collector.h @@ -33,11 +33,11 @@ namespace NMonitoring { } /** - * Reset collector values - */ - virtual void Reset() = 0; - - /** + * Reset collector values + */ + virtual void Reset() = 0; + + /** * @return snapshot of the state of this collector. */ virtual IHistogramSnapshotPtr Snapshot() const = 0; diff --git a/library/cpp/monlib/metrics/histogram_collector_explicit.cpp b/library/cpp/monlib/metrics/histogram_collector_explicit.cpp index 377fc233ef..7684468a2d 100644 --- a/library/cpp/monlib/metrics/histogram_collector_explicit.cpp +++ b/library/cpp/monlib/metrics/histogram_collector_explicit.cpp @@ -27,10 +27,10 @@ namespace NMonitoring { Values_.Add(index, count); } - void Reset() override { - Values_.Reset(); - } - + void Reset() override { + Values_.Reset(); + } + IHistogramSnapshotPtr Snapshot() const override { auto values = Values_.Copy(); return ExplicitHistogramSnapshot(Bounds_, values); diff --git a/library/cpp/monlib/metrics/histogram_collector_exponential.cpp b/library/cpp/monlib/metrics/histogram_collector_exponential.cpp index 2f8a50a5f9..e4dc327dff 100644 --- a/library/cpp/monlib/metrics/histogram_collector_exponential.cpp +++ b/library/cpp/monlib/metrics/histogram_collector_exponential.cpp @@ -35,10 +35,10 @@ namespace NMonitoring { Values_.Add(index, count); } - void Reset() override { - Values_.Reset(); - } - + void Reset() override { + Values_.Reset(); + } + IHistogramSnapshotPtr Snapshot() const override { return new TExponentialHistogramSnapshot(Base_, Scale_, Values_.Copy()); } diff --git a/library/cpp/monlib/metrics/histogram_collector_linear.cpp b/library/cpp/monlib/metrics/histogram_collector_linear.cpp index f8ad86f3a4..8cd6aafcb7 100644 --- a/library/cpp/monlib/metrics/histogram_collector_linear.cpp +++ b/library/cpp/monlib/metrics/histogram_collector_linear.cpp @@ -36,10 +36,10 @@ namespace NMonitoring { Values_.Add(index, count); } - void Reset() override { - Values_.Reset(); - } - + void Reset() override { + Values_.Reset(); + } + IHistogramSnapshotPtr Snapshot() const override { return new TLinearHistogramSnapshot( StartValue_, BucketWidth_, Values_.Copy()); diff --git a/library/cpp/monlib/metrics/metric.h b/library/cpp/monlib/metrics/metric.h index b8ce12d753..725d4fecef 100644 --- a/library/cpp/monlib/metrics/metric.h +++ b/library/cpp/monlib/metrics/metric.h @@ -379,8 +379,8 @@ namespace NMonitoring { } void Reset() override { - Collector_->Reset(); - } + Collector_->Reset(); + } private: IHistogramCollectorPtr Collector_; diff --git a/library/cpp/monlib/metrics/metric_registry.cpp b/library/cpp/monlib/metrics/metric_registry.cpp index b083163a7b..d1bb063aab 100644 --- a/library/cpp/monlib/metrics/metric_registry.cpp +++ b/library/cpp/monlib/metrics/metric_registry.cpp @@ -124,34 +124,34 @@ namespace NMonitoring { return Metric<THistogram, EMetricType::HIST_RATE>(std::move(labels), std::move(collector), true); } - void TMetricRegistry::Reset() { - TWriteGuard g{Lock_}; - for (auto& [label, metric] : Metrics_) { - switch (metric->Type()) { - case EMetricType::GAUGE: - static_cast<TGauge*>(metric.Get())->Set(.0); - break; - case EMetricType::IGAUGE: - static_cast<TIntGauge*>(metric.Get())->Set(0); - break; - case EMetricType::COUNTER: - static_cast<TCounter*>(metric.Get())->Reset(); - break; - case EMetricType::RATE: - static_cast<TRate*>(metric.Get())->Reset(); - break; - case EMetricType::HIST: - case EMetricType::HIST_RATE: - static_cast<THistogram*>(metric.Get())->Reset(); - break; - case EMetricType::UNKNOWN: - case EMetricType::DSUMMARY: - case EMetricType::LOGHIST: - break; - } - } - } - + void TMetricRegistry::Reset() { + TWriteGuard g{Lock_}; + for (auto& [label, metric] : Metrics_) { + switch (metric->Type()) { + case EMetricType::GAUGE: + static_cast<TGauge*>(metric.Get())->Set(.0); + break; + case EMetricType::IGAUGE: + static_cast<TIntGauge*>(metric.Get())->Set(0); + break; + case EMetricType::COUNTER: + static_cast<TCounter*>(metric.Get())->Reset(); + break; + case EMetricType::RATE: + static_cast<TRate*>(metric.Get())->Reset(); + break; + case EMetricType::HIST: + case EMetricType::HIST_RATE: + static_cast<THistogram*>(metric.Get())->Reset(); + break; + case EMetricType::UNKNOWN: + case EMetricType::DSUMMARY: + case EMetricType::LOGHIST: + break; + } + } + } + void TMetricRegistry::Clear() { TWriteGuard g{Lock_}; Metrics_.clear(); diff --git a/library/cpp/monlib/metrics/metric_registry.h b/library/cpp/monlib/metrics/metric_registry.h index 670cf8651e..ade57cfef3 100644 --- a/library/cpp/monlib/metrics/metric_registry.h +++ b/library/cpp/monlib/metrics/metric_registry.h @@ -82,12 +82,12 @@ namespace NMonitoring { /** * Set all registered metrics to zero */ - void Reset(); + void Reset(); /** * Remove all registered metrics from registry */ void Clear(); - + void Accept(TInstant time, IMetricConsumer* consumer) const override; void Append(TInstant time, IMetricConsumer* consumer) const override; |