diff options
author | Anton Samokhvalov <pg83@yandex.ru> | 2022-02-10 16:45:15 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:45:15 +0300 |
commit | 72cb13b4aff9bc9cf22e49251bc8fd143f82538f (patch) | |
tree | da2c34829458c7d4e74bdfbdf85dff449e9e7fb8 /library/cpp/sliding_window/sliding_window_ut.cpp | |
parent | 778e51ba091dc39e7b7fcab2b9cf4dbedfb6f2b5 (diff) | |
download | ydb-72cb13b4aff9bc9cf22e49251bc8fd143f82538f.tar.gz |
Restoring authorship annotation for Anton Samokhvalov <pg83@yandex.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/sliding_window/sliding_window_ut.cpp')
-rw-r--r-- | library/cpp/sliding_window/sliding_window_ut.cpp | 126 |
1 files changed, 63 insertions, 63 deletions
diff --git a/library/cpp/sliding_window/sliding_window_ut.cpp b/library/cpp/sliding_window/sliding_window_ut.cpp index 1e7343a8d3..35f04b21b2 100644 --- a/library/cpp/sliding_window/sliding_window_ut.cpp +++ b/library/cpp/sliding_window/sliding_window_ut.cpp @@ -9,40 +9,40 @@ Y_UNIT_TEST_SUITE(TSlidingWindowTest) { TSlidingWindow<TMaxOperation<unsigned>> w(TDuration::Minutes(5), 5); TInstant start = TInstant::MicroSeconds(TDuration::Hours(1).MicroSeconds()); TInstant now = start; - w.Update(5, start); // ~ ~ ~ ~ 5 - UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 5); // ^ + w.Update(5, start); // ~ ~ ~ ~ 5 + UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 5); // ^ now += TDuration::Minutes(1) + TDuration::Seconds(1); - w.Update(5, now); // 5 ~ ~ ~ 5 - UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 5); // ^ + w.Update(5, now); // 5 ~ ~ ~ 5 + UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 5); // ^ now += TDuration::Minutes(1); - w.Update(3, now); // 5 3 ~ ~ 5 - UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 5); // ^ + w.Update(3, now); // 5 3 ~ ~ 5 + UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 5); // ^ now += TDuration::Minutes(3); - w.Update(2, now); // 5 3 ~ ~ 2 - UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 5); // ^ + w.Update(2, now); // 5 3 ~ ~ 2 + UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 5); // ^ now += TDuration::Minutes(1); - w.Update(2, now); // 2 3 ~ ~ 2 - UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 3); // ^ + w.Update(2, now); // 2 3 ~ ~ 2 + UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 3); // ^ now += TDuration::Minutes(1); - w.Update(2, now); // 2 2 ~ ~ 2 - UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 2); // ^ + w.Update(2, now); // 2 2 ~ ~ 2 + UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 2); // ^ now += TDuration::Minutes(5); - w.Update(1, now); // ~ 1 ~ ~ ~ - UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 1); // ^ + w.Update(1, now); // ~ 1 ~ ~ ~ + UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 1); // ^ // update current bucket - w.Update(2, now); // ~ 2 ~ ~ ~ - UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 2); // ^ + w.Update(2, now); // ~ 2 ~ ~ ~ + UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 2); // ^ - w.Update(1, now + TDuration::Seconds(30)); // ~ 2 ~ ~ ~ - UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 2); // ^ + w.Update(1, now + TDuration::Seconds(30)); // ~ 2 ~ ~ ~ + UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 2); // ^ // test idle now += TDuration::Minutes(1); - w.Update(now); // ~ 2 ~ ~ ~ - UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 2); // ^ + w.Update(now); // ~ 2 ~ ~ ~ + UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 2); // ^ - now += TDuration::Minutes(5); // ~ ~ ~ ~ ~ + now += TDuration::Minutes(5); // ~ ~ ~ ~ ~ UNIT_ASSERT_VALUES_EQUAL(w.Update(now), 0); } @@ -50,40 +50,40 @@ Y_UNIT_TEST_SUITE(TSlidingWindowTest) { TSlidingWindow<TMinOperation<unsigned>> w(TDuration::Minutes(5), 5); TInstant start = TInstant::MicroSeconds(TDuration::Hours(1).MicroSeconds()); TInstant now = start; - w.Update(5, start); // ~ ~ ~ ~ 5 - UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 5); // ^ + w.Update(5, start); // ~ ~ ~ ~ 5 + UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 5); // ^ now += TDuration::Minutes(1) + TDuration::Seconds(1); - w.Update(5, now); // 5 ~ ~ ~ 5 - UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 5); // ^ + w.Update(5, now); // 5 ~ ~ ~ 5 + UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 5); // ^ now += TDuration::Minutes(1); - w.Update(7, now); // 5 7 ~ ~ 5 - UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 5); // ^ + w.Update(7, now); // 5 7 ~ ~ 5 + UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 5); // ^ now += TDuration::Minutes(3); - w.Update(8, now); // 5 7 ~ ~ 8 - UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 5); // ^ + w.Update(8, now); // 5 7 ~ ~ 8 + UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 5); // ^ now += TDuration::Minutes(1); - w.Update(8, now); // 8 7 ~ ~ 8 - UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 7); // ^ + w.Update(8, now); // 8 7 ~ ~ 8 + UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 7); // ^ now += TDuration::Minutes(1); - w.Update(8, now); // 8 8 ~ ~ 8 - UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 8); // ^ + w.Update(8, now); // 8 8 ~ ~ 8 + UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 8); // ^ now += TDuration::Minutes(5); - w.Update(6, now); // ~ 6 ~ ~ ~ - UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 6); // ^ + w.Update(6, now); // ~ 6 ~ ~ ~ + UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 6); // ^ // update current bucket - w.Update(5, now); // ~ 5 ~ ~ ~ - UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 5); // ^ + w.Update(5, now); // ~ 5 ~ ~ ~ + UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 5); // ^ - w.Update(6, now + TDuration::Seconds(30)); // ~ 5 ~ ~ ~ - UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 5); // ^ + w.Update(6, now + TDuration::Seconds(30)); // ~ 5 ~ ~ ~ + UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 5); // ^ // test idle now += TDuration::Minutes(1); - w.Update(now); // ~ 5 ~ ~ ~ - UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 5); // ^ + w.Update(now); // ~ 5 ~ ~ ~ + UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 5); // ^ - now += TDuration::Minutes(5); // ~ ~ ~ ~ ~ + now += TDuration::Minutes(5); // ~ ~ ~ ~ ~ UNIT_ASSERT_VALUES_EQUAL(w.Update(now), std::numeric_limits<unsigned>::max()); } @@ -93,40 +93,40 @@ Y_UNIT_TEST_SUITE(TSlidingWindowTest) { TInstant start = TInstant::MicroSeconds(TDuration::Hours(1).MicroSeconds()); TInstant now = start; - w.Update(5, start); // 0 0 0 0 5 - UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 5); // ^ + w.Update(5, start); // 0 0 0 0 5 + UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 5); // ^ now += TDuration::Minutes(1) + TDuration::Seconds(1); - w.Update(5, now); // 5 0 0 0 5 - UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 10); // ^ + w.Update(5, now); // 5 0 0 0 5 + UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 10); // ^ now += TDuration::Minutes(1); - w.Update(3, now); // 5 3 0 0 5 - UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 13); // ^ + w.Update(3, now); // 5 3 0 0 5 + UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 13); // ^ now += TDuration::Minutes(3); - w.Update(2, now); // 5 3 0 0 2 - UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 10); // ^ + w.Update(2, now); // 5 3 0 0 2 + UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 10); // ^ now += TDuration::Minutes(1); - w.Update(2, now); // 2 3 0 0 2 - UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 7); // ^ + w.Update(2, now); // 2 3 0 0 2 + UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 7); // ^ now += TDuration::Minutes(1); - w.Update(2, now); // 2 2 0 0 2 - UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 6); // ^ + w.Update(2, now); // 2 2 0 0 2 + UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 6); // ^ now += TDuration::Minutes(5); - w.Update(1, now); // 0 1 0 0 0 - UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 1); // ^ + w.Update(1, now); // 0 1 0 0 0 + UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 1); // ^ // update current bucket - w.Update(2, now); // 0 3 0 0 0 - UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 3); // ^ + w.Update(2, now); // 0 3 0 0 0 + UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 3); // ^ - w.Update(1, now + TDuration::Seconds(30)); // 0 4 0 0 0 - UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 4); // ^ + w.Update(1, now + TDuration::Seconds(30)); // 0 4 0 0 0 + UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 4); // ^ // test idle now += TDuration::Minutes(1); - w.Update(now); // 0 4 0 0 0 - UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 4); // ^ + w.Update(now); // 0 4 0 0 0 + UNIT_ASSERT_VALUES_EQUAL(w.GetValue(), 4); // ^ - now += TDuration::Minutes(5); // 0 0 0 0 0 + now += TDuration::Minutes(5); // 0 0 0 0 0 UNIT_ASSERT_VALUES_EQUAL(w.Update(now), 0); } } |