library/cpp/messagebus/duration_histogram_ut.cpp


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

#include <library/cpp/testing/unittest/registar.h>
 
#include "duration_histogram.h" 
 
Y_UNIT_TEST_SUITE(TDurationHistogramTest) {
    Y_UNIT_TEST(BucketFor) {
        UNIT_ASSERT_VALUES_EQUAL(0u, TDurationHistogram::BucketFor(TDuration::MicroSeconds(0)));
        UNIT_ASSERT_VALUES_EQUAL(0u, TDurationHistogram::BucketFor(TDuration::MicroSeconds(1)));
        UNIT_ASSERT_VALUES_EQUAL(0u, TDurationHistogram::BucketFor(TDuration::MicroSeconds(900)));
        UNIT_ASSERT_VALUES_EQUAL(1u, TDurationHistogram::BucketFor(TDuration::MicroSeconds(1500))); 
        UNIT_ASSERT_VALUES_EQUAL(2u, TDurationHistogram::BucketFor(TDuration::MicroSeconds(2500))); 
 
        unsigned sb = TDurationHistogram::SecondBoundary; 
 
        UNIT_ASSERT_VALUES_EQUAL(sb - 1, TDurationHistogram::BucketFor(TDuration::MilliSeconds(999)));
        UNIT_ASSERT_VALUES_EQUAL(sb, TDurationHistogram::BucketFor(TDuration::MilliSeconds(1000))); 
        UNIT_ASSERT_VALUES_EQUAL(sb, TDurationHistogram::BucketFor(TDuration::MilliSeconds(1001))); 
 
        UNIT_ASSERT_VALUES_EQUAL(TDurationHistogram::Buckets - 1, TDurationHistogram::BucketFor(TDuration::Hours(1))); 
    } 
 
    Y_UNIT_TEST(Simple) {
        TDurationHistogram h1; 
        h1.AddTime(TDuration::MicroSeconds(1)); 
        UNIT_ASSERT_VALUES_EQUAL(1u, h1.Times.front()); 
 
        TDurationHistogram h2; 
        h1.AddTime(TDuration::Hours(1)); 
        UNIT_ASSERT_VALUES_EQUAL(1u, h1.Times.back()); 
    } 
 
    Y_UNIT_TEST(LabelFor) {
        for (unsigned i = 0; i < TDurationHistogram::Buckets; ++i) { 
            TDurationHistogram::LabelBefore(i); 
            //Cerr << TDurationHistogram::LabelBefore(i) << "\n"; 
        } 
    } 
}