Lines Matching refs:eventTimeNs

358             .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs,  in TEST_P()
360 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST_P()
367 const int64_t eventTimeNs, in TEST_P() argument
369 EXPECT_EQ(eventTimeNs, partialBucketSplitTimeNs); in TEST_P()
610 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
612 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 8); // First condition change. in TEST()
617 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
619 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 1); // Second condition change. in TEST()
624 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
626 EXPECT_EQ(eventTimeNs, bucket3StartTimeNs + 1); // Third condition change. in TEST()
754 const int64_t eventTimeNs, in TEST_P()
756 EXPECT_EQ(eventTimeNs, partialBucketSplitTimeNs); in TEST_P()
832 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST_P()
834 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 1); // Condition change to true time. in TEST_P()
839 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST_P() argument
841 EXPECT_EQ(eventTimeNs, in TEST_P()
1062 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
1064 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 1); // Condition change to true time. in TEST()
1069 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
1071 EXPECT_EQ(eventTimeNs, in TEST()
1178 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
1180 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 8); // First condition change. in TEST()
1186 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
1188 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 1); // Second condition change. in TEST()
1242 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
1244 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 8); in TEST()
1250 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
1252 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 1); in TEST()
1258 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
1260 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 25); in TEST()
1993 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
1995 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 8); // Condition change to true. in TEST()
2033 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
2035 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST()
2040 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
2042 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 1); // Condition change to false. in TEST()
2156 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
2158 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 3); in TEST()
2289 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
2291 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 2); in TEST()
2297 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
2299 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 3); in TEST()
2369 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
2371 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 2); in TEST()
2377 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
2379 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 3); in TEST()
2476 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
2478 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10); in TEST()
2483 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
2485 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10); in TEST()
2520 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
2522 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10); in TEST()
2527 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
2529 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 11); in TEST()
2534 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
2536 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 12); in TEST()
2628 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST_P()
2630 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST_P()
2637 const int64_t eventTimeNs, in TEST_P() argument
2639 EXPECT_EQ(eventTimeNs, partialBucketSplitTimeNs); in TEST_P()
2684 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
2686 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 10); in TEST()
2692 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
2694 EXPECT_EQ(eventTimeNs, bucket3StartTimeNs + 10); in TEST()
2785 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST_P()
2787 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST_P()
2794 const int64_t eventTimeNs, in TEST_P() argument
2796 EXPECT_EQ(eventTimeNs, partialBucketSplitTimeNs); in TEST_P()
2825 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
2827 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 8); in TEST()
2833 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
2835 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10); in TEST()
2870 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
2872 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 10); in TEST()
2878 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
2880 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 8); in TEST()
2886 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
2888 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 10); in TEST()
3004 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
3006 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST()
3011 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
3013 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10); in TEST()
3060 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
3062 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 8); in TEST()
3068 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
3070 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 50); in TEST()
3163 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
3165 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 8); in TEST()
3307 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
3309 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 50); in TEST()
3315 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
3317 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 100); in TEST()
3373 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
3375 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 50); in TEST()
3381 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
3383 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10000); in TEST()
3429 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
3431 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 50); in TEST()
3479 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
3481 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10); in TEST()
3487 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
3489 EXPECT_EQ(eventTimeNs, bucket4StartTimeNs + 10); in TEST()
3553 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
3555 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10); in TEST()
3561 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
3563 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 9000000); in TEST()
3644 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
3646 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 10 * NS_PER_SEC); in TEST()
3653 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
3655 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 15 * NS_PER_SEC); in TEST()
3733 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
3735 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10); in TEST()
3741 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
3743 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 1000); in TEST()
3850 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
3852 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10); in TEST()
3867 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
3869 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 220); in TEST()
3969 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
3971 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST()
3977 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
3979 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 5 * NS_PER_SEC); in TEST()
3986 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
3988 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10 * NS_PER_SEC); in TEST()
3995 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
3997 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 15 * NS_PER_SEC); in TEST()
4004 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
4006 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 50 * NS_PER_SEC); in TEST()
4211 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
4213 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST()
4219 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
4221 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 5 * NS_PER_SEC); in TEST()
4234 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
4236 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 15 * NS_PER_SEC); in TEST()
4243 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
4245 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 50 * NS_PER_SEC); in TEST()
4519 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
4521 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST()
4528 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
4530 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 20 * NS_PER_SEC); in TEST()
4541 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
4543 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 40 * NS_PER_SEC); in TEST()
4554 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
4556 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 20 * NS_PER_SEC); in TEST()
4567 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
4569 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 40 * NS_PER_SEC); in TEST()
4580 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
4582 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 50 * NS_PER_SEC); in TEST()
5070 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
5072 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST()
5078 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
5080 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10 * NS_PER_SEC); in TEST()
5088 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
5090 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 30 * NS_PER_SEC); in TEST()
5095 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
5097 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 40 * NS_PER_SEC); in TEST()
5104 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
5106 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 50 * NS_PER_SEC); in TEST()
5286 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
5288 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST()
5294 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
5296 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10 * NS_PER_SEC); in TEST()
5301 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
5303 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 50 * NS_PER_SEC); in TEST()
5371 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
5373 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST()
5379 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
5381 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10 * NS_PER_SEC); in TEST()
5388 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
5390 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 20 * NS_PER_SEC); in TEST()
5397 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
5399 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 30 * NS_PER_SEC); in TEST()
5406 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
5408 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 50 * NS_PER_SEC); in TEST()
5602 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
5604 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10 * NS_PER_SEC); in TEST()
5611 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
5613 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 30 * NS_PER_SEC); in TEST()
5621 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
5623 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 40 * NS_PER_SEC); in TEST()
5628 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
5630 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 50 * NS_PER_SEC); in TEST()
5805 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
5807 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10 * NS_PER_SEC); in TEST()
5820 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
5822 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 20 * NS_PER_SEC); in TEST()
5836 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
5838 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 25 * NS_PER_SEC); in TEST()
5854 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
5856 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 40 * NS_PER_SEC); in TEST()
5868 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
5870 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 45 * NS_PER_SEC); in TEST()
5881 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
5883 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 30 * NS_PER_SEC); in TEST()
5898 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
5900 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 50 * NS_PER_SEC); in TEST()
6672 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
6674 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 20 * NS_PER_SEC); in TEST()
6681 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
6683 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 30 * NS_PER_SEC); in TEST()
6690 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument
6692 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 10 * NS_PER_SEC); in TEST()
6928 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST()
6938 .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs, in TEST() argument