- //Test expects bin width will be equal to 0.125s
-
- EXPECT_EQ_DOUBLE (1/125, latency_counter_get_rate (l,
- DOUBLE_TO_CDTIME_T(10),
- DOUBLE_TO_CDTIME_T(10),
- latency_counter_get_start_time(l) + TIME_T_TO_CDTIME_T(1)
- )
- );
- EXPECT_EQ_DOUBLE (0, latency_counter_get_rate (l,
- DOUBLE_TO_CDTIME_T(10.001),
- DOUBLE_TO_CDTIME_T(10.125),
- latency_counter_get_start_time(l) + TIME_T_TO_CDTIME_T(1)
- )
- );
- EXPECT_EQ_DOUBLE (1/125, latency_counter_get_rate (l,
- DOUBLE_TO_CDTIME_T(10.001),
- DOUBLE_TO_CDTIME_T(10.876),
- latency_counter_get_start_time(l) + TIME_T_TO_CDTIME_T(1)
- )
- );
- EXPECT_EQ_DOUBLE (2/125, latency_counter_get_rate (l,
- DOUBLE_TO_CDTIME_T(10.000),
- DOUBLE_TO_CDTIME_T(10.876),
- latency_counter_get_start_time(l) + TIME_T_TO_CDTIME_T(1)
- )
- );
- //Range
- EXPECT_EQ_DOUBLE (10.000 + 1.000/125, latency_counter_get_rate (l,
- DOUBLE_TO_CDTIME_T(10),
- DOUBLE_TO_CDTIME_T(20),
- latency_counter_get_start_time(l) + TIME_T_TO_CDTIME_T(1)
- )
- );
- //Range w/o interpolations
- EXPECT_EQ_DOUBLE (100, latency_counter_get_rate (l,
- DOUBLE_TO_CDTIME_T(0.001),
- DOUBLE_TO_CDTIME_T(100.0),
- latency_counter_get_start_time(l) + TIME_T_TO_CDTIME_T(1)
- )
- );
- //Full range
- EXPECT_EQ_DOUBLE (125.0, latency_counter_get_rate (l,
- DOUBLE_TO_CDTIME_T(0.001),
- 0,
- latency_counter_get_start_time(l) + TIME_T_TO_CDTIME_T(1)
- )
- );
- //Overflow test
- EXPECT_EQ_DOUBLE (125.0, latency_counter_get_rate (l,
- DOUBLE_TO_CDTIME_T(0.001),
- DOUBLE_TO_CDTIME_T(100000),
- latency_counter_get_start_time(l) + TIME_T_TO_CDTIME_T(1)
- )
- );
-
- //Split range to two parts
- EXPECT_EQ_DOUBLE (92.0, latency_counter_get_rate (l,
- DOUBLE_TO_CDTIME_T(0.001),
- DOUBLE_TO_CDTIME_T(92.00),
- latency_counter_get_start_time(l) + TIME_T_TO_CDTIME_T(1)
- )
- );
- EXPECT_EQ_DOUBLE (8, latency_counter_get_rate (l,
- DOUBLE_TO_CDTIME_T(92.001),
- DOUBLE_TO_CDTIME_T(100.00),
- latency_counter_get_start_time(l) + TIME_T_TO_CDTIME_T(1)
- )
- );
-
- //Sum of rates for latencies [0.876, 1.000]
- EXPECT_EQ_DOUBLE (1, latency_counter_get_rate (l,
- DOUBLE_TO_CDTIME_T(0.876),
- DOUBLE_TO_CDTIME_T(1.000),
- latency_counter_get_start_time(l) + TIME_T_TO_CDTIME_T(1)
- )
- );
- double sum = 0;
- for (i = 875 ; i < 1000 ; i += 5) {
- sum += latency_counter_get_rate (l,
- DOUBLE_TO_CDTIME_T((double)(i+1)/1000),
- DOUBLE_TO_CDTIME_T((double)(i+5)/1000),
- latency_counter_get_start_time(l) + TIME_T_TO_CDTIME_T(1)
- );
- printf("b: %.15g\n",sum);
+
+ /* We expect a bucket width of 125ms. */
+ EXPECT_EQ_UINT64(DOUBLE_TO_CDTIME_T(0.125), peek->bin_width);
+
+ struct {
+ size_t index;
+ int want;
+ } bucket_cases[] = {
+ {0, 0}, /* (0.000-0.125] */
+ {1, 0}, /* (0.125-0.250] */
+ {2, 0}, /* (0.250-0.375] */
+ {3, 0}, /* (0.375-0.500] */
+ {4, 0}, /* (0.500-0.625] */
+ {5, 0}, /* (0.625-0.750] */
+ {6, 0}, /* (0.750-0.875] */
+ {7, 1}, /* (0.875-1.000] */
+ {8, 0}, /* (1.000-1.125] */
+ {9, 0}, /* (1.125-1.250] */
+ {10, 0}, /* (1.250-1.375] */
+ {11, 0}, /* (1.375-1.500] */
+ {12, 0}, /* (1.500-1.625] */
+ {13, 0}, /* (1.625-1.750] */
+ {14, 0}, /* (1.750-1.875] */
+ {15, 1}, /* (1.875-2.000] */
+ {16, 0}, /* (2.000-2.125] */
+ };
+
+ for (size_t i = 0; i < STATIC_ARRAY_SIZE(bucket_cases); i++) {
+ size_t index = bucket_cases[i].index;
+ EXPECT_EQ_INT(bucket_cases[i].want, peek->histogram[index]);
+ }
+
+ struct {
+ cdtime_t lower_bound;
+ cdtime_t upper_bound;
+ double want;
+ } cases[] = {
+ {
+ // bucket 6 is zero
+ DOUBLE_TO_CDTIME_T_STATIC(0.750), DOUBLE_TO_CDTIME_T_STATIC(0.875),
+ 0.00,
+ },
+ {
+ // bucket 7 contains the t=1 update
+ DOUBLE_TO_CDTIME_T_STATIC(0.875), DOUBLE_TO_CDTIME_T_STATIC(1.000),
+ 1.00,
+ },
+ {
+ // range: bucket 7 - bucket 15; contains the t=1 and t=2 updates
+ DOUBLE_TO_CDTIME_T_STATIC(0.875), DOUBLE_TO_CDTIME_T_STATIC(2.000),
+ 2.00,
+ },
+ {
+ // lower bucket is only partially applied
+ DOUBLE_TO_CDTIME_T_STATIC(0.875 + (0.125 / 4)),
+ DOUBLE_TO_CDTIME_T_STATIC(2.000), 1.75,
+ },
+ {
+ // upper bucket is only partially applied
+ DOUBLE_TO_CDTIME_T_STATIC(0.875),
+ DOUBLE_TO_CDTIME_T_STATIC(2.000 - (0.125 / 4)), 1.75,
+ },
+ {
+ // both buckets are only partially applied
+ DOUBLE_TO_CDTIME_T_STATIC(0.875 + (0.125 / 4)),
+ DOUBLE_TO_CDTIME_T_STATIC(2.000 - (0.125 / 4)), 1.50,
+ },
+ {
+ // lower bound is unspecified
+ 0, DOUBLE_TO_CDTIME_T_STATIC(2.000), 2.00,
+ },
+ {
+ // upper bound is unspecified
+ DOUBLE_TO_CDTIME_T_STATIC(125.000 - 0.125), 0, 1.00,
+ },
+ {
+ // overflow test: upper >> longest latency
+ DOUBLE_TO_CDTIME_T_STATIC(1.000), DOUBLE_TO_CDTIME_T_STATIC(999999),
+ 124.00,
+ },
+ {
+ // overflow test: lower > longest latency
+ DOUBLE_TO_CDTIME_T_STATIC(130), 0, 0.00,
+ },
+ {
+ // lower > upper => error
+ DOUBLE_TO_CDTIME_T_STATIC(10), DOUBLE_TO_CDTIME_T_STATIC(9), NAN,
+ },
+ {
+ // lower == upper => zero
+ DOUBLE_TO_CDTIME_T_STATIC(9), DOUBLE_TO_CDTIME_T_STATIC(9), 0.00,
+ },