diff options
author | Sergey Polovko <sergey@polovko.me> | 2022-02-10 16:47:03 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:47:03 +0300 |
commit | 2e714b5ebd40a1f4cc31c27f1ad6e49ca6d895f5 (patch) | |
tree | b83306b6e37edeea782e9eed673d89286c4fef35 /library/cpp/monlib/metrics/histogram_collector_linear.cpp | |
parent | 3e0b762a82514bac89c1dd6ea7211e381d8aa248 (diff) | |
download | ydb-2e714b5ebd40a1f4cc31c27f1ad6e49ca6d895f5.tar.gz |
Restoring authorship annotation for Sergey Polovko <sergey@polovko.me>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/monlib/metrics/histogram_collector_linear.cpp')
-rw-r--r-- | library/cpp/monlib/metrics/histogram_collector_linear.cpp | 106 |
1 files changed, 53 insertions, 53 deletions
diff --git a/library/cpp/monlib/metrics/histogram_collector_linear.cpp b/library/cpp/monlib/metrics/histogram_collector_linear.cpp index c0afa29241..f8ad86f3a4 100644 --- a/library/cpp/monlib/metrics/histogram_collector_linear.cpp +++ b/library/cpp/monlib/metrics/histogram_collector_linear.cpp @@ -1,67 +1,67 @@ -#include "histogram_collector.h" -#include "atomics_array.h" - -#include <util/generic/algorithm.h> -#include <util/generic/vector.h> -#include <util/generic/yexception.h> -#include <util/generic/ylimits.h> - -#include <cmath> - -namespace NMonitoring { - /////////////////////////////////////////////////////////////////////////// - // TLinearHistogramCollector - /////////////////////////////////////////////////////////////////////////// - class TLinearHistogramCollector: public IHistogramCollector { - public: - TLinearHistogramCollector( +#include "histogram_collector.h" +#include "atomics_array.h" + +#include <util/generic/algorithm.h> +#include <util/generic/vector.h> +#include <util/generic/yexception.h> +#include <util/generic/ylimits.h> + +#include <cmath> + +namespace NMonitoring { + /////////////////////////////////////////////////////////////////////////// + // TLinearHistogramCollector + /////////////////////////////////////////////////////////////////////////// + class TLinearHistogramCollector: public IHistogramCollector { + public: + TLinearHistogramCollector( ui32 bucketsCount, TBucketBound startValue, TBucketBound bucketWidth) - : Values_(bucketsCount) - , StartValue_(startValue) - , BucketWidth_(bucketWidth) - , MaxValue_(startValue + bucketWidth * (bucketsCount - 2)) - { - } - + : Values_(bucketsCount) + , StartValue_(startValue) + , BucketWidth_(bucketWidth) + , MaxValue_(startValue + bucketWidth * (bucketsCount - 2)) + { + } + void Collect(double value, ui32 count) override { - ui32 index = Max<ui32>(); - if (value <= StartValue_) { - index = 0; - } else if (value > MaxValue_) { - index = Values_.Size() - 1; - } else { + ui32 index = Max<ui32>(); + if (value <= StartValue_) { + index = 0; + } else if (value > MaxValue_) { + index = Values_.Size() - 1; + } else { double buckets = (value - StartValue_) / BucketWidth_; - index = static_cast<ui32>(std::ceil(buckets)); - } - Values_.Add(index, count); - } - + index = static_cast<ui32>(std::ceil(buckets)); + } + Values_.Add(index, count); + } + void Reset() override { Values_.Reset(); } - IHistogramSnapshotPtr Snapshot() const override { - return new TLinearHistogramSnapshot( - StartValue_, BucketWidth_, Values_.Copy()); - } - - private: - TAtomicsArray Values_; + IHistogramSnapshotPtr Snapshot() const override { + return new TLinearHistogramSnapshot( + StartValue_, BucketWidth_, Values_.Copy()); + } + + private: + TAtomicsArray Values_; TBucketBound StartValue_; double BucketWidth_; TBucketBound MaxValue_; - }; - - IHistogramCollectorPtr LinearHistogram( + }; + + IHistogramCollectorPtr LinearHistogram( ui32 bucketsCount, TBucketBound startValue, TBucketBound bucketWidth) - { - Y_ENSURE(bucketsCount >= 2, - "linear histogram must contain at least two buckets"); + { + Y_ENSURE(bucketsCount >= 2, + "linear histogram must contain at least two buckets"); Y_ENSURE(bucketsCount <= HISTOGRAM_MAX_BUCKETS_COUNT, "buckets count must be <=" << HISTOGRAM_MAX_BUCKETS_COUNT - << ", but got: " << bucketsCount); - Y_ENSURE(bucketWidth >= 1, "bucketWidth must be >= 1, got: " << bucketWidth); - + << ", but got: " << bucketsCount); + Y_ENSURE(bucketWidth >= 1, "bucketWidth must be >= 1, got: " << bucketWidth); + return MakeHolder<TLinearHistogramCollector>(bucketsCount, startValue, bucketWidth); - } -} + } +} |