diff options
author | Igor Makunin <[email protected]> | 2022-02-10 16:49:35 +0300 |
---|---|---|
committer | Daniil Cherednik <[email protected]> | 2022-02-10 16:49:35 +0300 |
commit | c617191a3b33c0f5e1be6390361dbe540775d158 (patch) | |
tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/monlib/metrics/timer_ut.cpp | |
parent | f7a438035f19b364b5479caf536990e82b174f38 (diff) |
Restoring authorship annotation for Igor Makunin <[email protected]>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/monlib/metrics/timer_ut.cpp')
-rw-r--r-- | library/cpp/monlib/metrics/timer_ut.cpp | 206 |
1 files changed, 103 insertions, 103 deletions
diff --git a/library/cpp/monlib/metrics/timer_ut.cpp b/library/cpp/monlib/metrics/timer_ut.cpp index 9827edcda0d..c244a8c9e12 100644 --- a/library/cpp/monlib/metrics/timer_ut.cpp +++ b/library/cpp/monlib/metrics/timer_ut.cpp @@ -1,120 +1,120 @@ -#include "timer.h" - +#include "timer.h" + #include <library/cpp/testing/unittest/registar.h> #include <library/cpp/threading/future/async.h> #include <library/cpp/threading/future/future.h> - -using namespace NMonitoring; + +using namespace NMonitoring; using namespace NThreading; - -Y_UNIT_TEST_SUITE(TTimerTest) { - - using namespace std::chrono; - - struct TTestClock { - using time_point = time_point<high_resolution_clock>; - - static time_point TimePoint; - - static time_point now() { - return TimePoint; - } - }; - - TTestClock::time_point TTestClock::TimePoint; - - - Y_UNIT_TEST(Gauge) { - TTestClock::TimePoint = TTestClock::time_point::min(); - - TGauge gauge(0); - { + +Y_UNIT_TEST_SUITE(TTimerTest) { + + using namespace std::chrono; + + struct TTestClock { + using time_point = time_point<high_resolution_clock>; + + static time_point TimePoint; + + static time_point now() { + return TimePoint; + } + }; + + TTestClock::time_point TTestClock::TimePoint; + + + Y_UNIT_TEST(Gauge) { + TTestClock::TimePoint = TTestClock::time_point::min(); + + TGauge gauge(0); + { TMetricTimerScope<TGauge, milliseconds, TTestClock> t{&gauge}; - TTestClock::TimePoint += milliseconds(10); - } - UNIT_ASSERT_EQUAL(10, gauge.Get()); - - { + TTestClock::TimePoint += milliseconds(10); + } + UNIT_ASSERT_EQUAL(10, gauge.Get()); + + { TMetricTimerScope<TGauge, milliseconds, TTestClock> t{&gauge}; - TTestClock::TimePoint += milliseconds(20); - } - UNIT_ASSERT_EQUAL(20, gauge.Get()); - } - - Y_UNIT_TEST(IntGauge) { - TTestClock::TimePoint = TTestClock::time_point::min(); - - TIntGauge gauge(0); - { + TTestClock::TimePoint += milliseconds(20); + } + UNIT_ASSERT_EQUAL(20, gauge.Get()); + } + + Y_UNIT_TEST(IntGauge) { + TTestClock::TimePoint = TTestClock::time_point::min(); + + TIntGauge gauge(0); + { TMetricTimerScope<TIntGauge, milliseconds, TTestClock> t{&gauge}; - TTestClock::TimePoint += milliseconds(10); - } - UNIT_ASSERT_EQUAL(10, gauge.Get()); - - { + TTestClock::TimePoint += milliseconds(10); + } + UNIT_ASSERT_EQUAL(10, gauge.Get()); + + { TMetricTimerScope<TIntGauge, milliseconds, TTestClock> t{&gauge}; - TTestClock::TimePoint += milliseconds(20); - } - UNIT_ASSERT_EQUAL(20, gauge.Get()); - } - - Y_UNIT_TEST(CounterNew) { - TTestClock::TimePoint = TTestClock::time_point::min(); - + TTestClock::TimePoint += milliseconds(20); + } + UNIT_ASSERT_EQUAL(20, gauge.Get()); + } + + Y_UNIT_TEST(CounterNew) { + TTestClock::TimePoint = TTestClock::time_point::min(); + TCounter counter(0); - { + { TMetricTimerScope<TCounter, milliseconds, TTestClock> t{&counter}; - TTestClock::TimePoint += milliseconds(10); - } - UNIT_ASSERT_EQUAL(10, counter.Get()); - - { + TTestClock::TimePoint += milliseconds(10); + } + UNIT_ASSERT_EQUAL(10, counter.Get()); + + { TMetricTimerScope<TCounter, milliseconds, TTestClock> t{&counter}; - TTestClock::TimePoint += milliseconds(20); - } - UNIT_ASSERT_EQUAL(30, counter.Get()); - } - - Y_UNIT_TEST(Rate) { - TTestClock::TimePoint = TTestClock::time_point::min(); - - TRate rate(0); - { + TTestClock::TimePoint += milliseconds(20); + } + UNIT_ASSERT_EQUAL(30, counter.Get()); + } + + Y_UNIT_TEST(Rate) { + TTestClock::TimePoint = TTestClock::time_point::min(); + + TRate rate(0); + { TMetricTimerScope<TRate, milliseconds, TTestClock> t{&rate}; - TTestClock::TimePoint += milliseconds(10); - } - UNIT_ASSERT_EQUAL(10, rate.Get()); - - { + TTestClock::TimePoint += milliseconds(10); + } + UNIT_ASSERT_EQUAL(10, rate.Get()); + + { TMetricTimerScope<TRate, milliseconds, TTestClock> t{&rate}; - TTestClock::TimePoint += milliseconds(20); - } - UNIT_ASSERT_EQUAL(30, rate.Get()); - } - - Y_UNIT_TEST(Histogram) { - TTestClock::TimePoint = TTestClock::time_point::min(); - - auto assertHistogram = [](const TVector<ui64>& expected, IHistogramSnapshotPtr snapshot) { - UNIT_ASSERT_EQUAL(expected.size(), snapshot->Count()); - for (size_t i = 0; i < expected.size(); ++i) { - UNIT_ASSERT_EQUAL(expected[i], snapshot->Value(i)); - } - }; - - THistogram histogram(ExplicitHistogram({10, 20, 30}), true); - { + TTestClock::TimePoint += milliseconds(20); + } + UNIT_ASSERT_EQUAL(30, rate.Get()); + } + + Y_UNIT_TEST(Histogram) { + TTestClock::TimePoint = TTestClock::time_point::min(); + + auto assertHistogram = [](const TVector<ui64>& expected, IHistogramSnapshotPtr snapshot) { + UNIT_ASSERT_EQUAL(expected.size(), snapshot->Count()); + for (size_t i = 0; i < expected.size(); ++i) { + UNIT_ASSERT_EQUAL(expected[i], snapshot->Value(i)); + } + }; + + THistogram histogram(ExplicitHistogram({10, 20, 30}), true); + { TMetricTimerScope<THistogram, milliseconds, TTestClock> t{&histogram}; - TTestClock::TimePoint += milliseconds(5); - } - assertHistogram({1, 0, 0, 0}, histogram.TakeSnapshot()); - - { + TTestClock::TimePoint += milliseconds(5); + } + assertHistogram({1, 0, 0, 0}, histogram.TakeSnapshot()); + + { TMetricTimerScope<THistogram, milliseconds, TTestClock> t{&histogram}; - TTestClock::TimePoint += milliseconds(15); - } - assertHistogram({1, 1, 0, 0}, histogram.TakeSnapshot()); - } + TTestClock::TimePoint += milliseconds(15); + } + assertHistogram({1, 1, 0, 0}, histogram.TakeSnapshot()); + } Y_UNIT_TEST(Moving) { TTestClock::TimePoint = TTestClock::time_point::min(); @@ -154,4 +154,4 @@ Y_UNIT_TEST_SUITE(TTimerTest) { UNIT_ASSERT_EQUAL(counter.Get(), 5); } -} +} |