aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/sliding_window/sliding_window_ut.cpp
diff options
context:
space:
mode:
authorAnton Samokhvalov <pg83@yandex.ru>2022-02-10 16:45:15 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:45:15 +0300
commit72cb13b4aff9bc9cf22e49251bc8fd143f82538f (patch)
treeda2c34829458c7d4e74bdfbdf85dff449e9e7fb8 /library/cpp/sliding_window/sliding_window_ut.cpp
parent778e51ba091dc39e7b7fcab2b9cf4dbedfb6f2b5 (diff)
downloadydb-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.cpp126
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);
}
}