diff options
| author | danibw <[email protected]> | 2022-02-10 16:50:12 +0300 | 
|---|---|---|
| committer | Daniil Cherednik <[email protected]> | 2022-02-10 16:50:12 +0300 | 
| commit | 4b28e15652a7672062edb6804bc985eedc333257 (patch) | |
| tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/monlib/metrics | |
| parent | e8fdd1e6c0645bf1702aaf85cc7460dbd09977cb (diff) | |
Restoring authorship annotation for <[email protected]>. Commit 2 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 e044f14b00f..f19aebf2915 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 5afbf63c8e9..9f6bbbdfb73 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 7684468a2d5..377fc233eff 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 e4dc327dffe..2f8a50a5f9d 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 8cd6aafcb7f..f8ad86f3a48 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 725d4feceff..b8ce12d7533 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 d1bb063aab4..b083163a7b2 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 ade57cfef3f..670cf8651e1 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; | 
