Lines Matching refs:bucketStartTimeNs
54 const int64_t bucketStartTimeNs = 10000000000; variable
56 const int64_t bucket2StartTimeNs = bucketStartTimeNs + bucketSizeNs;
57 const int64_t bucket3StartTimeNs = bucketStartTimeNs + 2 * bucketSizeNs;
58 const int64_t bucket4StartTimeNs = bucketStartTimeNs + 3 * bucketSizeNs;
59 const int64_t bucket5StartTimeNs = bucketStartTimeNs + 4 * bucketSizeNs;
60 const int64_t bucket6StartTimeNs = bucketStartTimeNs + 5 * bucketSizeNs;
156 /*slicedStateAtoms=*/{}, /*stateGroupMap=*/{}, bucketStartTimeNs, bucketStartTimeNs, in createValueProducerWithSampling()
180 /*slicedStateAtoms=*/{}, /*stateGroupMap=*/{}, bucketStartTimeNs, in createValueProducerWithEventMatcherWizard()
181 bucketStartTimeNs, eventMatcherWizard); in createValueProducerWithEventMatcherWizard()
189 const int64_t timeBaseNs = bucketStartTimeNs,
190 const int64_t startTimeNs = bucketStartTimeNs,
311 EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _)) in TEST()
315 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs, 3)); in TEST()
337 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
352 {bucketStartTimeNs, bucket2StartTimeNs}, {bucket2StartTimeNs, bucket3StartTimeNs}); in TEST()
367 {bucketStartTimeNs, bucket2StartTimeNs, bucket3StartTimeNs}, in TEST()
379 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST_P()
381 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 1, 1)); in TEST_P()
419 {0, 0}, {bucketStartTimeNs, bucket2StartTimeNs}, in TEST_P()
436 EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _)) in TEST()
440 data->push_back(CreateTwoValueLogEvent(tagId, bucketStartTimeNs, 3, 3)); in TEST()
462 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
482 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
493 EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _)) in TEST()
546 EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _)) in TEST()
601 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 8); // First condition change. in TEST()
603 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 8, 100)); in TEST()
625 valueProducer->onConditionChanged(true, bucketStartTimeNs + 8); in TEST()
644 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
654 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
667 {0, 0}, {bucketStartTimeNs, bucket2StartTimeNs}, in TEST()
684 CreateRepeatedValueLogEvent(&event1, tagId, bucketStartTimeNs + 10, 10); in TEST_P()
688 int64_t partialBucketSplitTimeNs = bucketStartTimeNs + 150; in TEST_P()
698 {partialBucketSplitTimeNs - bucketStartTimeNs}, {0}, in TEST_P()
699 {bucketStartTimeNs}, {partialBucketSplitTimeNs}); in TEST_P()
705 CreateRepeatedValueLogEvent(&event2, tagId, bucketStartTimeNs + 59 * NS_PER_SEC, 20); in TEST_P()
709 {partialBucketSplitTimeNs - bucketStartTimeNs}, {0}, in TEST_P()
710 {bucketStartTimeNs}, {partialBucketSplitTimeNs}); in TEST_P()
719 {partialBucketSplitTimeNs - bucketStartTimeNs, in TEST_P()
722 {bucketStartTimeNs, partialBucketSplitTimeNs}, in TEST_P()
724 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs, valueProducer->mCurrentBucketStartTimeNs); in TEST_P()
790 EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _)) in TEST()
817 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 1); // Condition change to true time. in TEST_P()
819 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 1, 100)); in TEST_P()
834 valueProducer->onConditionChanged(true, bucketStartTimeNs + 1); in TEST_P()
852 {(bucket2StartTimeNs - 100) - (bucketStartTimeNs + 1)}, {0}, in TEST_P()
853 {bucketStartTimeNs}, {partialBucketSplitTimeNs}); in TEST_P()
870 CreateRepeatedValueLogEvent(&event1, tagId, bucketStartTimeNs + 10, 10); in TEST()
873 CreateRepeatedValueLogEvent(&event2, tagId, bucketStartTimeNs + 20, 20); in TEST()
903 EXPECT_EQ(bucketStartTimeNs, data.bucket_info(0).start_bucket_elapsed_nanos()); in TEST()
923 CreateRepeatedValueLogEvent(&event1, tagId, bucketStartTimeNs + 10, 10); in TEST()
928 valueProducer->onConditionChangedLocked(true, bucketStartTimeNs + 15); in TEST()
931 CreateRepeatedValueLogEvent(&event2, tagId, bucketStartTimeNs + 20, 20); in TEST()
942 CreateRepeatedValueLogEvent(&event3, tagId, bucketStartTimeNs + 30, 30); in TEST()
950 valueProducer->onConditionChangedLocked(false, bucketStartTimeNs + 35); in TEST()
953 CreateRepeatedValueLogEvent(&event4, tagId, bucketStartTimeNs + 40, 40); in TEST()
974 EXPECT_EQ(bucketStartTimeNs, data.bucket_info(0).start_bucket_elapsed_nanos()); in TEST()
1003 valueProducer->addAnomalyTracker(alert, alarmMonitor, UPDATE_NEW, bucketStartTimeNs); in TEST()
1006 CreateRepeatedValueLogEvent(&event1, tagId, bucketStartTimeNs + 1 * NS_PER_SEC, 10); in TEST()
1009 CreateRepeatedValueLogEvent(&event2, tagId, bucketStartTimeNs + 2 + NS_PER_SEC, 20); in TEST()
1013 bucketStartTimeNs + 2 * bucketSizeNs + 1 * NS_PER_SEC, 130); in TEST()
1017 bucketStartTimeNs + 3 * bucketSizeNs + 1 * NS_PER_SEC, 1); in TEST()
1021 bucketStartTimeNs + 3 * bucketSizeNs + 2 * NS_PER_SEC, 150); in TEST()
1025 bucketStartTimeNs + 3 * bucketSizeNs + 10 * NS_PER_SEC, 160); in TEST()
1070 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 1); // Condition change to true time. in TEST()
1072 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 1, 0)); in TEST()
1087 valueProducer->addAnomalyTracker(alert, alarmMonitor, UPDATE_NEW, bucketStartTimeNs); in TEST()
1089 valueProducer->onConditionChanged(true, bucketStartTimeNs + 1); in TEST()
1102 EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _)) in TEST()
1157 EXPECT_EQ(bucketStartTimeNs, valueProducer->mSkippedBuckets[0].bucketStartTimeNs); in TEST()
1163 EXPECT_EQ(bucket3StartTimeNs, valueProducer->mSkippedBuckets[1].bucketStartTimeNs); in TEST()
1182 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 8); // First condition change. in TEST()
1184 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 8, 100)); in TEST()
1199 valueProducer->onConditionChanged(true, bucketStartTimeNs + 8); in TEST()
1218 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
1228 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
1247 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 8); in TEST()
1249 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 8, 100)); in TEST()
1273 valueProducer->onConditionChanged(true, bucketStartTimeNs + 8); in TEST()
1289 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
1298 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
1322 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
1330 {bucketStartTimeNs, bucket2StartTimeNs}, {bucket2StartTimeNs, bucket3StartTimeNs}); in TEST()
1347 CreateRepeatedValueLogEvent(&event1, tagId, bucketStartTimeNs + 10, 10); in TEST()
1350 CreateRepeatedValueLogEvent(&event2, tagId, bucketStartTimeNs + 20, 20); in TEST()
1370 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
1387 CreateRepeatedValueLogEvent(&event1, tagId, bucketStartTimeNs + 10, 10); in TEST()
1398 CreateRepeatedValueLogEvent(&event2, tagId, bucketStartTimeNs + 20, 20); in TEST()
1408 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
1427 CreateRepeatedValueLogEvent(&event1, tagId, bucketStartTimeNs + 10, 10); in TEST()
1430 CreateRepeatedValueLogEvent(&event2, tagId, bucketStartTimeNs + 20, 15); in TEST()
1473 CreateRepeatedValueLogEvent(&event1, tagId, bucketStartTimeNs + 10, 10); in TEST()
1476 CreateRepeatedValueLogEvent(&event2, tagId, bucketStartTimeNs + 20, 15); in TEST()
1494 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
1512 CreateRepeatedValueLogEvent(&event1, tagId, bucketStartTimeNs + 10, 10); in TEST()
1526 CreateRepeatedValueLogEvent(&event2, tagId, bucketStartTimeNs + 15, 15); in TEST()
1567 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
1586 CreateThreeValueLogEvent(&event1, tagId, bucketStartTimeNs + 10, 1, 10, 20); in TEST()
1589 CreateThreeValueLogEvent(&event2, tagId, bucketStartTimeNs + 15, 1, 15, 22); in TEST()
1689 EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _)) in TEST()
1693 data->push_back(CreateTwoValueLogEvent(tagId, bucketStartTimeNs, 1, 3)); in TEST()
1755 EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _)) in TEST()
1759 data->push_back(CreateTwoValueLogEvent(tagId, bucketStartTimeNs, 1, 3)); in TEST()
1847 EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _)) in TEST()
1851 data->push_back(CreateTwoValueLogEvent(tagId, bucketStartTimeNs, 1, 3)); in TEST()
1883 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
1911 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
1948 EXPECT_EQ(bucketStartTimeNs, iterator->second[0].mBucketStartNs); in TEST()
1963 EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs + 8, _)) in TEST()
1967 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 8, 100)); in TEST()
1975 valueProducer->onConditionChanged(true, bucketStartTimeNs + 8); in TEST()
2002 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 8); // Condition change to true. in TEST()
2004 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 8, 100)); in TEST()
2013 valueProducer->onConditionChanged(true, bucketStartTimeNs + 8); in TEST()
2026 valueProducer->onConditionChanged(false, bucketStartTimeNs + 20); in TEST()
2043 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST()
2045 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs, 50)); in TEST()
2050 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 1); // Condition change to false. in TEST()
2052 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 8, 100)); in TEST()
2060 valueProducer->onConditionChanged(true, bucketStartTimeNs); in TEST()
2064 valueProducer->onConditionChanged(false, bucketStartTimeNs + 1); in TEST()
2081 EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs + 1, _)) in TEST()
2085 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 1, 120)); in TEST()
2094 valueProducer->onConditionChanged(true, bucketStartTimeNs + 1); in TEST()
2115 valueProducer->onConditionChanged(true, bucketStartTimeNs); in TEST()
2123 EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs + 1, _)) in TEST()
2127 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 1, 100)); in TEST()
2135 valueProducer->onConditionChanged(true, bucketStartTimeNs + 1); in TEST()
2160 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 3); in TEST()
2162 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 8, 130)); in TEST()
2173 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 1, 110)); in TEST()
2174 valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucketStartTimeNs); in TEST()
2178 valueProducer->onConditionChanged(false, bucketStartTimeNs + 2); in TEST()
2179 valueProducer->onConditionChanged(true, bucketStartTimeNs + 3); in TEST()
2204 EXPECT_EQ(NanoToMillis(bucketStartTimeNs), in TEST()
2212 EXPECT_EQ(NanoToMillis(bucketStartTimeNs + 2), dropEvent.drop_time_millis()); in TEST()
2225 EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs + 2, _)) in TEST()
2230 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 1, i)); in TEST()
2240 valueProducer->onConditionChanged(true, bucketStartTimeNs + 2); in TEST()
2264 EXPECT_EQ(NanoToMillis(bucketStartTimeNs), in TEST()
2272 EXPECT_EQ(NanoToMillis(bucketStartTimeNs + 2), dropEvent.drop_time_millis()); in TEST()
2286 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 2); in TEST()
2288 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 8, 120)); in TEST()
2294 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 3); in TEST()
2296 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 8, 130)); in TEST()
2307 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 1, 110)); in TEST()
2308 valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_FAIL, bucketStartTimeNs); in TEST()
2310 valueProducer->onConditionChanged(false, bucketStartTimeNs + 2); in TEST()
2311 valueProducer->onConditionChanged(true, bucketStartTimeNs + 3); in TEST()
2336 EXPECT_EQ(NanoToMillis(bucketStartTimeNs), in TEST()
2344 EXPECT_EQ(NanoToMillis(bucketStartTimeNs + 2), dropEvent.drop_time_millis()); in TEST()
2359 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 2); in TEST()
2361 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 8, 120)); in TEST()
2367 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 3); in TEST()
2369 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 8, 130)); in TEST()
2380 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 1, 110)); in TEST()
2381 valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucketStartTimeNs); in TEST()
2383 valueProducer->onConditionChanged(false, bucketStartTimeNs + 2); in TEST()
2384 valueProducer->onConditionChanged(true, bucketStartTimeNs + 3); in TEST()
2408 EXPECT_EQ(NanoToMillis(bucketStartTimeNs), in TEST()
2422 EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _)) in TEST()
2427 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs, 3)); in TEST()
2471 {bucketStartTimeNs, bucket4StartTimeNs}, {bucket2StartTimeNs, bucket5StartTimeNs}); in TEST()
2485 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10); in TEST()
2487 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs, 3)); in TEST()
2493 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 20); in TEST()
2499 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 30); in TEST()
2501 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 30, 10)); in TEST()
2509 valueProducer->onConditionChanged(true, bucketStartTimeNs + 10); in TEST()
2520 valueProducer->onConditionChanged(false, bucketStartTimeNs + 20); in TEST()
2527 valueProducer->onConditionChanged(true, bucketStartTimeNs + 30); in TEST()
2547 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
2558 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10); in TEST()
2560 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs, 1)); in TEST()
2565 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 11); in TEST()
2567 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs, 2)); in TEST()
2572 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 12); in TEST()
2574 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs, 5)); in TEST()
2582 valueProducer->onConditionChanged(true, bucketStartTimeNs + 10); in TEST()
2583 valueProducer->onConditionChanged(false, bucketStartTimeNs + 11); in TEST()
2584 valueProducer->onConditionChanged(true, bucketStartTimeNs + 12); in TEST()
2603 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
2613 EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs + 10, _)) in TEST()
2618 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs, 1)); in TEST()
2626 valueProducer->onConditionChanged(true, bucketStartTimeNs + 10); in TEST()
2650 int64_t partialBucketSplitTimeNs = bucketStartTimeNs + bucketSizeNs / 2; in TEST_P()
2655 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST_P()
2657 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs, 1)); in TEST_P()
2681 valueProducer->addAnomalyTracker(alert, alarmMonitor, UPDATE_NEW, bucketStartTimeNs); in TEST_P()
2695 {partialBucketSplitTimeNs - bucketStartTimeNs}, {0}, in TEST_P()
2696 {bucketStartTimeNs}, {partialBucketSplitTimeNs}); in TEST_P()
2704 {partialBucketSplitTimeNs - bucketStartTimeNs}, {0}, in TEST_P()
2705 {bucketStartTimeNs}, {partialBucketSplitTimeNs}); in TEST_P()
2710 EXPECT_EQ(partialBucketSplitTimeNs, valueProducer->mSkippedBuckets[0].bucketStartTimeNs); in TEST_P()
2740 valueProducer->onConditionChanged(false, bucketStartTimeNs); in TEST()
2777 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 30, 10)); in TEST()
2778 valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucketStartTimeNs + 30); in TEST()
2786 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
2793 EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _)) in TEST()
2798 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs, 1)); in TEST()
2807 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 30, 10)); in TEST()
2808 valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucketStartTimeNs + 30); in TEST()
2816 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
2828 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST_P()
2830 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs, 1)); in TEST_P()
2858 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST_P()
2869 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 8); in TEST()
2871 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs, 1)); in TEST()
2877 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10); in TEST()
2879 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs, 3)); in TEST()
2887 valueProducer->onConditionChanged(true, bucketStartTimeNs + 8); in TEST()
2888 valueProducer->onConditionChanged(false, bucketStartTimeNs + 10); in TEST()
2889 valueProducer->onConditionChanged(false, bucketStartTimeNs + 12); in TEST()
2901 assertPastBucketValuesSingleKey(valueProducer->mPastBuckets, {2}, {2}, {0}, {bucketStartTimeNs}, in TEST()
2916 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs, 1)); in TEST()
2942 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 3, 10)); in TEST()
2943 valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_FAIL, bucketStartTimeNs + 3); in TEST()
2967 EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _)) in TEST()
2972 data->push_back(CreateThreeValueLogEvent(tagId, bucketStartTimeNs, tagId, 1, 1)); in TEST()
3004 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST()
3006 data->push_back(CreateThreeValueLogEvent(tagId, bucketStartTimeNs, tagId, 1, 1)); in TEST()
3011 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10); in TEST()
3014 CreateThreeValueLogEvent(tagId, bucketStartTimeNs + 10, tagId, 3, 3)); in TEST()
3022 StatsLogReport report = onDumpReport(valueProducer, bucketStartTimeNs + 10, in TEST()
3044 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
3059 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 8); in TEST()
3061 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 30, 10)); in TEST()
3067 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 50); in TEST()
3069 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 50, 20)); in TEST()
3076 valueProducer->onConditionChanged(true, bucketStartTimeNs + 8); in TEST()
3077 valueProducer->onConditionChanged(false, bucketStartTimeNs + 50); in TEST()
3094 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
3106 EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs + 8, _)) in TEST()
3111 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 30, 10)); in TEST()
3118 valueProducer->onConditionChanged(true, bucketStartTimeNs + 8); in TEST()
3126 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
3160 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 8); in TEST()
3162 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 30, 10)); in TEST()
3170 valueProducer->onConditionChanged(true, bucketStartTimeNs + 8); in TEST()
3171 valueProducer->onConditionChanged(false, bucketStartTimeNs + 50); in TEST()
3201 EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs + 20, _)) in TEST()
3206 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 20, 10)); in TEST()
3215 valueProducer->onConditionChanged(true, bucketStartTimeNs + 20); in TEST()
3218 StatsLogReport report = onDumpReport(valueProducer, bucketStartTimeNs + 40, in TEST()
3227 EXPECT_EQ(NanoToMillis(bucketStartTimeNs), in TEST()
3229 EXPECT_EQ(NanoToMillis(bucketStartTimeNs + 40), in TEST()
3235 EXPECT_EQ(NanoToMillis(bucketStartTimeNs + 40), dropEvent.drop_time_millis()); in TEST()
3246 EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs + 50, _)) in TEST()
3251 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 50, 10)); in TEST()
3260 valueProducer->onConditionChanged(true, bucketStartTimeNs + 50); in TEST()
3300 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 50); in TEST()
3302 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 50, 10)); in TEST()
3319 valueProducer->onConditionChanged(true, bucketStartTimeNs + 50); in TEST()
3363 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 50); in TEST()
3365 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 50, 10)); in TEST()
3371 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10000); in TEST()
3373 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 100, 15)); in TEST()
3382 valueProducer->onConditionChanged(true, bucketStartTimeNs + 50); in TEST()
3385 int64_t dumpReportTimeNs = bucketStartTimeNs + 10000; in TEST()
3392 EXPECT_EQ(NanoToMillis(bucketStartTimeNs), in TEST()
3415 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 50); in TEST()
3417 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 50, 10)); in TEST()
3428 valueProducer->onConditionChanged(true, bucketStartTimeNs + 50); in TEST()
3431 int64_t dumpReportTimeNs = bucketStartTimeNs + 10000; in TEST()
3438 EXPECT_EQ(NanoToMillis(bucketStartTimeNs), in TEST()
3461 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10); in TEST()
3463 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 10, 10)); in TEST()
3480 valueProducer->onConditionChanged(true, bucketStartTimeNs + 10); in TEST()
3497 EXPECT_EQ(NanoToMillis(bucketStartTimeNs), in TEST()
3534 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10); in TEST()
3536 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 10, 10)); in TEST()
3542 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 9000000); in TEST()
3545 CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 9000000, 15)); in TEST()
3554 valueProducer->onConditionChanged(true, bucketStartTimeNs + 10); in TEST()
3557 int64_t dumpReportTimeNs = bucketStartTimeNs + 9000000; in TEST()
3564 EXPECT_EQ(NanoToMillis(bucketStartTimeNs), in TEST()
3588 int64_t dumpReportTimeNs = bucketStartTimeNs + 10000000000; // 10 seconds in TEST()
3595 EXPECT_EQ(NanoToMillis(bucketStartTimeNs), in TEST()
3638 int64_t appUpgradeTimeNs = bucketStartTimeNs + 5 * NS_PER_SEC; in TEST()
3659 EXPECT_EQ(NanoToMillis(bucketStartTimeNs), in TEST()
3703 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10); in TEST()
3705 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 10, 10)); in TEST()
3722 int64_t conditionChangeTimeNs = bucketStartTimeNs + 10; in TEST()
3760 EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs + 10, _)) in TEST()
3765 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 10, 10)); in TEST()
3774 valueProducer->onConditionChanged(true, bucketStartTimeNs + 10); in TEST()
3777 int64_t dumpReportTimeNs = bucketStartTimeNs + 1000; in TEST()
3784 EXPECT_EQ(NanoToMillis(bucketStartTimeNs), in TEST()
3792 EXPECT_EQ(NanoToMillis(bucketStartTimeNs + 10), dropEvent.drop_time_millis()); in TEST()
3811 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10); in TEST()
3813 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 1, i)); in TEST()
3828 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 220); in TEST()
3830 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 220, 10)); in TEST()
3839 valueProducer->onConditionChanged(true, bucketStartTimeNs + 10); in TEST()
3842 valueProducer->onConditionChanged(false, bucketStartTimeNs + 30); in TEST()
3843 valueProducer->onConditionChanged(true, bucketStartTimeNs + 50); in TEST()
3844 valueProducer->onConditionChanged(false, bucketStartTimeNs + 70); in TEST()
3845 valueProducer->onConditionChanged(true, bucketStartTimeNs + 90); in TEST()
3846 valueProducer->onConditionChanged(false, bucketStartTimeNs + 100); in TEST()
3847 valueProducer->onConditionChanged(true, bucketStartTimeNs + 150); in TEST()
3848 valueProducer->onConditionChanged(false, bucketStartTimeNs + 170); in TEST()
3849 valueProducer->onConditionChanged(true, bucketStartTimeNs + 190); in TEST()
3850 valueProducer->onConditionChanged(false, bucketStartTimeNs + 200); in TEST()
3853 valueProducer->onConditionChanged(true, bucketStartTimeNs + 220); in TEST()
3856 int64_t dumpReportTimeNs = bucketStartTimeNs + 1000; in TEST()
3866 EXPECT_EQ(NanoToMillis(bucketStartTimeNs), in TEST()
3874 EXPECT_EQ(NanoToMillis(bucketStartTimeNs + 10), dropEvent.drop_time_millis()); in TEST()
3878 EXPECT_EQ(NanoToMillis(bucketStartTimeNs + 30), dropEvent.drop_time_millis()); in TEST()
3882 EXPECT_EQ(NanoToMillis(bucketStartTimeNs + 50), dropEvent.drop_time_millis()); in TEST()
3886 EXPECT_EQ(NanoToMillis(bucketStartTimeNs + 70), dropEvent.drop_time_millis()); in TEST()
3890 EXPECT_EQ(NanoToMillis(bucketStartTimeNs + 90), dropEvent.drop_time_millis()); in TEST()
3894 EXPECT_EQ(NanoToMillis(bucketStartTimeNs + 100), dropEvent.drop_time_millis()); in TEST()
3898 EXPECT_EQ(NanoToMillis(bucketStartTimeNs + 150), dropEvent.drop_time_millis()); in TEST()
3902 EXPECT_EQ(NanoToMillis(bucketStartTimeNs + 170), dropEvent.drop_time_millis()); in TEST()
3906 EXPECT_EQ(NanoToMillis(bucketStartTimeNs + 190), dropEvent.drop_time_millis()); in TEST()
3910 EXPECT_EQ(NanoToMillis(bucketStartTimeNs + 200), dropEvent.drop_time_millis()); in TEST()
3928 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST()
3930 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs, 3)); in TEST()
3936 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 5 * NS_PER_SEC); in TEST()
3939 CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 5 * NS_PER_SEC, 5)); in TEST()
3945 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10 * NS_PER_SEC); in TEST()
3948 CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 10 * NS_PER_SEC, 9)); in TEST()
3954 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 15 * NS_PER_SEC); in TEST()
3957 tagId, bucketStartTimeNs + 15 * NS_PER_SEC, 21)); in TEST()
3963 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 50 * NS_PER_SEC); in TEST()
3966 tagId, bucketStartTimeNs + 50 * NS_PER_SEC, 30)); in TEST()
3999 assertConditionTimer(it->second.conditionTimer, true, 0, bucketStartTimeNs); in TEST()
4003 bucketStartTimeNs + 5 * NS_PER_SEC, android::view::DisplayStateEnum::DISPLAY_STATE_ON); in TEST()
4022 assertConditionTimer(it->second.conditionTimer, true, 0, bucketStartTimeNs + 5 * NS_PER_SEC); in TEST()
4032 bucketStartTimeNs + 5 * NS_PER_SEC); in TEST()
4035 screenEvent = CreateScreenStateChangedEvent(bucketStartTimeNs + 10 * NS_PER_SEC, in TEST()
4054 assertConditionTimer(it->second.conditionTimer, true, 0, bucketStartTimeNs + 10 * NS_PER_SEC); in TEST()
4064 bucketStartTimeNs + 10 * NS_PER_SEC); in TEST()
4074 bucketStartTimeNs + 5 * NS_PER_SEC); in TEST()
4077 screenEvent = CreateScreenStateChangedEvent(bucketStartTimeNs + 15 * NS_PER_SEC, in TEST()
4099 bucketStartTimeNs + 15 * NS_PER_SEC); in TEST()
4109 bucketStartTimeNs + 15 * NS_PER_SEC); in TEST()
4119 bucketStartTimeNs + 5 * NS_PER_SEC); in TEST()
4122 StatsLogReport report = onDumpReport(valueProducer, bucketStartTimeNs + 50 * NS_PER_SEC, in TEST()
4142 assertConditionTimer(it->second.conditionTimer, true, 0, bucketStartTimeNs + 50 * NS_PER_SEC); in TEST()
4190 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST()
4192 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs, 3)); in TEST()
4198 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 5 * NS_PER_SEC); in TEST()
4201 CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 5 * NS_PER_SEC, 5)); in TEST()
4213 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 15 * NS_PER_SEC); in TEST()
4216 tagId, bucketStartTimeNs + 15 * NS_PER_SEC, 21)); in TEST()
4222 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 50 * NS_PER_SEC); in TEST()
4225 tagId, bucketStartTimeNs + 50 * NS_PER_SEC, 30)); in TEST()
4269 assertConditionTimer(it->second.conditionTimer, true, 0, bucketStartTimeNs); in TEST()
4273 bucketStartTimeNs + 5 * NS_PER_SEC, android::view::DisplayStateEnum::DISPLAY_STATE_ON); in TEST()
4291 assertConditionTimer(it->second.conditionTimer, true, 0, bucketStartTimeNs + 5 * NS_PER_SEC); in TEST()
4301 bucketStartTimeNs + 5 * NS_PER_SEC); in TEST()
4305 screenEvent = CreateScreenStateChangedEvent(bucketStartTimeNs + 10 * NS_PER_SEC, in TEST()
4324 assertConditionTimer(it->second.conditionTimer, true, 0, bucketStartTimeNs + 5 * NS_PER_SEC); in TEST()
4334 bucketStartTimeNs + 5 * NS_PER_SEC); in TEST()
4338 screenEvent = CreateScreenStateChangedEvent(bucketStartTimeNs + 12 * NS_PER_SEC, in TEST()
4357 assertConditionTimer(it->second.conditionTimer, true, 0, bucketStartTimeNs + 5 * NS_PER_SEC); in TEST()
4367 bucketStartTimeNs + 5 * NS_PER_SEC); in TEST()
4370 screenEvent = CreateScreenStateChangedEvent(bucketStartTimeNs + 15 * NS_PER_SEC, in TEST()
4389 assertConditionTimer(it->second.conditionTimer, true, 0, bucketStartTimeNs + 15 * NS_PER_SEC); in TEST()
4399 bucketStartTimeNs + 15 * NS_PER_SEC); in TEST()
4409 bucketStartTimeNs + 5 * NS_PER_SEC); in TEST()
4412 StatsLogReport report = onDumpReport(valueProducer, bucketStartTimeNs + 50 * NS_PER_SEC, in TEST()
4431 assertConditionTimer(it->second.conditionTimer, true, 0, bucketStartTimeNs + 50 * NS_PER_SEC); in TEST()
4519 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST()
4521 data->push_back(CreateTwoValueLogEvent(tagId, bucketStartTimeNs, 1 /*uid*/, 3)); in TEST()
4522 data->push_back(CreateTwoValueLogEvent(tagId, bucketStartTimeNs, 2 /*uid*/, 7)); in TEST()
4528 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 20 * NS_PER_SEC); in TEST()
4530 data->push_back(CreateTwoValueLogEvent(tagId, bucketStartTimeNs + 20 * NS_PER_SEC, in TEST()
4533 data->push_back(CreateTwoValueLogEvent(tagId, bucketStartTimeNs + 20 * NS_PER_SEC, in TEST()
4540 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 40 * NS_PER_SEC); in TEST()
4543 data->push_back(CreateTwoValueLogEvent(tagId, bucketStartTimeNs + 40 * NS_PER_SEC, in TEST()
4545 data->push_back(CreateTwoValueLogEvent(tagId, bucketStartTimeNs + 40 * NS_PER_SEC, in TEST()
4602 CreateUidProcessStateChangedEvent(bucketStartTimeNs + 20 * NS_PER_SEC, 1 /* uid */, in TEST()
4610 CreateUidProcessStateChangedEvent(bucketStartTimeNs + 40 * NS_PER_SEC, 2 /* uid */, in TEST()
4673 ValidateValueBucket(data.bucket_info(0), bucketStartTimeNs, bucket2StartTimeNs, {3}, in TEST()
4682 ValidateValueBucket(data.bucket_info(0), bucketStartTimeNs, bucket2StartTimeNs, {4}, in TEST()
4702 ValidateValueBucket(data.bucket_info(0), bucketStartTimeNs, bucket2StartTimeNs, {2}, in TEST()
4711 ValidateValueBucket(data.bucket_info(0), bucketStartTimeNs, bucket2StartTimeNs, {6}, in TEST()
4746 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST()
4748 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs, 3)); in TEST()
4754 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10 * NS_PER_SEC); in TEST()
4757 CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 10 * NS_PER_SEC, 5)); in TEST()
4764 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 30 * NS_PER_SEC); in TEST()
4771 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 40 * NS_PER_SEC); in TEST()
4774 CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 40 * NS_PER_SEC, 7)); in TEST()
4780 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 50 * NS_PER_SEC); in TEST()
4783 tagId, bucketStartTimeNs + 50 * NS_PER_SEC, 15)); in TEST()
4815 assertConditionTimer(it->second.conditionTimer, true, 0, bucketStartTimeNs); in TEST()
4819 CreateBatterySaverOnEvent(/*timestamp=*/bucketStartTimeNs + 10 * NS_PER_SEC); in TEST()
4837 assertConditionTimer(it->second.conditionTimer, true, 0, bucketStartTimeNs + 10 * NS_PER_SEC); in TEST()
4846 bucketStartTimeNs + 10 * NS_PER_SEC); in TEST()
4851 CreateBatterySaverOffEvent(/*timestamp=*/bucketStartTimeNs + 30 * NS_PER_SEC); in TEST()
4864 bucketStartTimeNs + 30 * NS_PER_SEC); in TEST()
4873 bucketStartTimeNs + 10 * NS_PER_SEC); in TEST()
4877 CreateBatterySaverOnEvent(/*timestamp=*/bucketStartTimeNs + 40 * NS_PER_SEC); in TEST()
4894 bucketStartTimeNs + 40 * NS_PER_SEC); in TEST()
4903 bucketStartTimeNs + 10 * NS_PER_SEC); in TEST()
4906 StatsLogReport report = onDumpReport(valueProducer, bucketStartTimeNs + 50 * NS_PER_SEC, in TEST()
4918 ValidateValueBucket(data.bucket_info(0), bucketStartTimeNs, bucketStartTimeNs + 50 * NS_PER_SEC, in TEST()
4926 ValidateValueBucket(data.bucket_info(0), bucketStartTimeNs, bucketStartTimeNs + 50 * NS_PER_SEC, in TEST()
4957 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST()
4965 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10 * NS_PER_SEC); in TEST()
4972 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 50 * NS_PER_SEC); in TEST()
4975 tagId, bucketStartTimeNs + 50 * NS_PER_SEC, 15)); in TEST()
4999 CreateBatterySaverOnEvent(/*timestamp=*/bucketStartTimeNs + 10 * NS_PER_SEC); in TEST()
5006 StatsLogReport report = onDumpReport(valueProducer, bucketStartTimeNs + 50 * NS_PER_SEC, in TEST()
5037 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST()
5039 data->push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs, 3)); in TEST()
5045 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10 * NS_PER_SEC); in TEST()
5048 CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 10 * NS_PER_SEC, 5)); in TEST()
5054 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 20 * NS_PER_SEC); in TEST()
5057 CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 20 * NS_PER_SEC, 7)); in TEST()
5106 assertConditionTimer(it->second.conditionTimer, true, 0, bucketStartTimeNs); in TEST()
5110 CreateBatterySaverOnEvent(/*timestamp=*/bucketStartTimeNs + 10 * NS_PER_SEC); in TEST()
5125 assertConditionTimer(it->second.conditionTimer, true, 0, bucketStartTimeNs + 10 * NS_PER_SEC); in TEST()
5134 bucketStartTimeNs + 10 * NS_PER_SEC); in TEST()
5138 CreateBatterySaverOffEvent(/*timestamp=*/bucketStartTimeNs + 20 * NS_PER_SEC); in TEST()
5153 assertConditionTimer(it->second.conditionTimer, true, 0, bucketStartTimeNs + 20 * NS_PER_SEC); in TEST()
5162 bucketStartTimeNs + 20 * NS_PER_SEC); in TEST()
5171 bucketStartTimeNs + 10 * NS_PER_SEC); in TEST()
5210 ValidateValueBucket(data.bucket_info(0), bucketStartTimeNs, bucket2StartTimeNs, {2}, in TEST()
5218 ValidateValueBucket(data.bucket_info(0), bucketStartTimeNs, bucket2StartTimeNs, {2}, in TEST()
5228 ValidateValueBucket(data.bucket_info(0), bucketStartTimeNs, bucket2StartTimeNs, {3}, in TEST()
5258 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10 * NS_PER_SEC); in TEST()
5261 CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 10 * NS_PER_SEC, 3)); in TEST()
5267 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 30 * NS_PER_SEC); in TEST()
5270 CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 30 * NS_PER_SEC, 5)); in TEST()
5277 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 40 * NS_PER_SEC); in TEST()
5284 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 45 * NS_PER_SEC); in TEST()
5287 tagId, bucketStartTimeNs + 45 * NS_PER_SEC, 14)); in TEST()
5293 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 50 * NS_PER_SEC); in TEST()
5296 tagId, bucketStartTimeNs + 50 * NS_PER_SEC, 20)); in TEST()
5316 CreateBatterySaverOnEvent(/*timestamp=*/bucketStartTimeNs + 10 * NS_PER_SEC); in TEST()
5332 assertConditionTimer(it->second.conditionTimer, true, 0, bucketStartTimeNs + 10 * NS_PER_SEC); in TEST()
5343 valueProducer->onConditionChanged(false, bucketStartTimeNs + 30 * NS_PER_SEC); in TEST()
5359 bucketStartTimeNs + 30 * NS_PER_SEC); in TEST()
5370 CreateBatterySaverOffEvent(/*timestamp=*/bucketStartTimeNs + 35 * NS_PER_SEC); in TEST()
5376 valueProducer->onConditionChanged(true, bucketStartTimeNs + 40 * NS_PER_SEC); in TEST()
5387 bucketStartTimeNs + 30 * NS_PER_SEC); in TEST()
5398 CreateBatterySaverOnEvent(/*timestamp=*/bucketStartTimeNs + 45 * NS_PER_SEC); in TEST()
5409 StatsLogReport report = onDumpReport(valueProducer, bucketStartTimeNs + 50 * NS_PER_SEC, in TEST()
5424 ValidateValueBucket(data.bucket_info(0), bucketStartTimeNs, bucketStartTimeNs + 50 * NS_PER_SEC, in TEST()
5483 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10 * NS_PER_SEC); in TEST()
5485 data->push_back(CreateThreeValueLogEvent(tagId, bucketStartTimeNs + 10 * NS_PER_SEC, in TEST()
5487 data->push_back(CreateThreeValueLogEvent(tagId, bucketStartTimeNs + 10 * NS_PER_SEC, in TEST()
5491 data->push_back(CreateThreeValueLogEvent(tagId, bucketStartTimeNs + 10 * NS_PER_SEC, in TEST()
5498 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 20 * NS_PER_SEC); in TEST()
5500 data->push_back(CreateThreeValueLogEvent(tagId, bucketStartTimeNs + 20 * NS_PER_SEC, in TEST()
5502 data->push_back(CreateThreeValueLogEvent(tagId, bucketStartTimeNs + 20 * NS_PER_SEC, in TEST()
5506 data->push_back(CreateThreeValueLogEvent(tagId, bucketStartTimeNs + 20 * NS_PER_SEC, in TEST()
5514 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 25 * NS_PER_SEC); in TEST()
5516 data->push_back(CreateThreeValueLogEvent(tagId, bucketStartTimeNs + 25 * NS_PER_SEC, in TEST()
5520 data->push_back(CreateThreeValueLogEvent(tagId, bucketStartTimeNs + 25 * NS_PER_SEC, in TEST()
5524 data->push_back(CreateThreeValueLogEvent(tagId, bucketStartTimeNs + 25 * NS_PER_SEC, in TEST()
5532 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 40 * NS_PER_SEC); in TEST()
5534 data->push_back(CreateThreeValueLogEvent(tagId, bucketStartTimeNs + 40 * NS_PER_SEC, in TEST()
5536 data->push_back(CreateThreeValueLogEvent(tagId, bucketStartTimeNs + 40 * NS_PER_SEC, in TEST()
5538 data->push_back(CreateThreeValueLogEvent(tagId, bucketStartTimeNs + 40 * NS_PER_SEC, in TEST()
5546 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 45 * NS_PER_SEC); in TEST()
5548 data->push_back(CreateThreeValueLogEvent(tagId, bucketStartTimeNs + 45 * NS_PER_SEC, in TEST()
5550 data->push_back(CreateThreeValueLogEvent(tagId, bucketStartTimeNs + 45 * NS_PER_SEC, in TEST()
5552 data->push_back(CreateThreeValueLogEvent(tagId, bucketStartTimeNs + 45 * NS_PER_SEC, in TEST()
5600 CreateUidProcessStateChangedEvent(bucketStartTimeNs + 10 * NS_PER_SEC, 1 /* uid */, in TEST()
5607 CreateUidProcessStateChangedEvent(bucketStartTimeNs + 20 * NS_PER_SEC, 1 /* uid */, in TEST()
5614 CreateUidProcessStateChangedEvent(bucketStartTimeNs + 25 * NS_PER_SEC, 2 /* uid */, in TEST()
5620 valueProducer->onConditionChanged(false, bucketStartTimeNs + 40 * NS_PER_SEC); in TEST()
5624 valueProducer->onConditionChanged(true, bucketStartTimeNs + 45 * NS_PER_SEC); in TEST()
5725 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 20 * NS_PER_SEC); in TEST()
5728 CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 20 * NS_PER_SEC, 3)); in TEST()
5734 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 30 * NS_PER_SEC); in TEST()
5737 CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 30 * NS_PER_SEC, 5)); in TEST()
5767 CreateBatterySaverOnEvent(/*timestamp=*/bucketStartTimeNs + 10 * NS_PER_SEC); in TEST()
5773 valueProducer->onConditionChanged(true, bucketStartTimeNs + 20 * NS_PER_SEC); in TEST()
5793 assertConditionTimer(it->second.conditionTimer, true, 0, bucketStartTimeNs + 20 * NS_PER_SEC); in TEST()
5805 CreateBatterySaverOffEvent(/*timestamp=*/bucketStartTimeNs + 30 * NS_PER_SEC); in TEST()
5823 assertConditionTimer(it->second.conditionTimer, true, 0, bucketStartTimeNs + 30 * NS_PER_SEC); in TEST()
5833 bucketStartTimeNs + 30 * NS_PER_SEC); in TEST()
5916 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 20 * NS_PER_SEC); in TEST()
5919 CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 20 * NS_PER_SEC, 3)); in TEST()
5925 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 30 * NS_PER_SEC); in TEST()
5928 CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 30 * NS_PER_SEC, 5)); in TEST()
5934 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 40 * NS_PER_SEC); in TEST()
5937 CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 40 * NS_PER_SEC, 9)); in TEST()
5976 CreateBatterySaverOnEvent(/*timestamp=*/bucketStartTimeNs + 10 * NS_PER_SEC); in TEST()
5982 valueProducer->onConditionChanged(true, bucketStartTimeNs + 20 * NS_PER_SEC); in TEST()
5988 CreateBatterySaverOffEvent(/*timestamp=*/bucketStartTimeNs + 30 * NS_PER_SEC); in TEST()
5994 valueProducer->onConditionChanged(false, bucketStartTimeNs + 40 * NS_PER_SEC); in TEST()
6038 ValidateValueBucket(data.bucket_info(0), bucketStartTimeNs, bucket2StartTimeNs, {2}, in TEST()
6048 ValidateValueBucket(data.bucket_info(0), bucketStartTimeNs, bucket2StartTimeNs, {4}, in TEST()
6104 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST()
6106 data->push_back(CreateThreeValueLogEvent(tagId, bucketStartTimeNs, 1 /*uid*/, 1, in TEST()
6108 data->push_back(CreateThreeValueLogEvent(tagId, bucketStartTimeNs, 1 /*uid*/, 1, in TEST()
6110 data->push_back(CreateThreeValueLogEvent(tagId, bucketStartTimeNs, 2 /*uid*/, 1, in TEST()
6117 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 20 * NS_PER_SEC); in TEST()
6119 data->push_back(CreateThreeValueLogEvent(tagId, bucketStartTimeNs + 20 * NS_PER_SEC, in TEST()
6122 data->push_back(CreateThreeValueLogEvent(tagId, bucketStartTimeNs + 20 * NS_PER_SEC, in TEST()
6129 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 25 * NS_PER_SEC); in TEST()
6131 data->push_back(CreateThreeValueLogEvent(tagId, bucketStartTimeNs + 25 * NS_PER_SEC, in TEST()
6134 data->push_back(CreateThreeValueLogEvent(tagId, bucketStartTimeNs + 25 * NS_PER_SEC, in TEST()
6137 data->push_back(CreateThreeValueLogEvent(tagId, bucketStartTimeNs + 25 * NS_PER_SEC, in TEST()
6186 CreateUidProcessStateChangedEvent(bucketStartTimeNs + 20 * NS_PER_SEC, 1 /* uid */, in TEST()
6193 CreateUidProcessStateChangedEvent(bucketStartTimeNs + 25 * NS_PER_SEC, 2 /* uid */, in TEST()
6247 ValidateValueBucket(data.bucket_info(0), bucketStartTimeNs, bucket2StartTimeNs, {4}, in TEST()
6261 ValidateValueBucket(data.bucket_info(0), bucketStartTimeNs, bucket2StartTimeNs, {8}, in TEST()
6291 ValidateValueBucket(data.bucket_info(0), bucketStartTimeNs, bucket2StartTimeNs, {7}, in TEST()
6322 int64_t appUpdateTimeNs = bucketStartTimeNs + 1000; in TEST()
6326 int64_t dumpReportTimeNs = bucketStartTimeNs + 10000000000; // 10 seconds in TEST()
6333 EXPECT_EQ(NanoToMillis(bucketStartTimeNs), in TEST()
6360 CreateThreeValueLogEvent(tagId, bucketStartTimeNs + 1, 1 /*uid*/, 5, 5)); in TEST()
6362 CreateThreeValueLogEvent(tagId, bucketStartTimeNs + 1, 2 /*uid*/, 5, 5)); in TEST()
6405 ValidateValueBucket(data.bucket_info(0), bucketStartTimeNs, bucket2StartTimeNs, {16, 16}, -1, in TEST()
6443 valueProducer->onConditionChanged(true, bucketStartTimeNs); in TEST()
6455 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
6465 {bucketStartTimeNs, bucket2StartTimeNs}, in TEST()
6496 valueProducer->onConditionChanged(true, bucketStartTimeNs); in TEST()
6497 valueProducer->onConditionChanged(false, bucketStartTimeNs + conditionDurationNs); in TEST()
6507 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
6521 {bucketStartTimeNs, bucket2StartTimeNs}, {bucket2StartTimeNs, bucket3StartTimeNs}); in TEST()
6552 valueProducer->onConditionChanged(true, bucketStartTimeNs); in TEST()
6560 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
6579 {pullDelayNs, -pullDelayNs}, {bucketStartTimeNs, bucket2StartTimeNs}, in TEST()
6611 valueProducer->onConditionChanged(true, bucketStartTimeNs); in TEST()
6615 valueProducer->onConditionChanged(false, bucketStartTimeNs + conditionDurationNs); in TEST()
6622 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
6633 {bucketStartTimeNs, bucket2StartTimeNs}, {bucket2StartTimeNs, bucket3StartTimeNs}); in TEST()
6669 valueProducer->onConditionChanged(true, bucketStartTimeNs); in TEST()
6680 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
6696 {bucketStartTimeNs, bucket2StartTimeNs}, in TEST()
6713 {bucketStartTimeNs, bucket2StartTimeNs, bucket3StartTimeNs}, in TEST()
6748 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
6758 {bucketStartTimeNs, bucket2StartTimeNs}, in TEST()
6770 {bucketStartTimeNs, bucket2StartTimeNs, bucket3StartTimeNs}, in TEST()
6784 EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _)) in TEST()
6863 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
6915 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
6969 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
6979 {bucketStartTimeNs, bucket2StartTimeNs}, in TEST()
7036 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
7090 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
7136 bucketStartTimeNs + 5 * NS_PER_SEC, android::view::DisplayStateEnum::DISPLAY_STATE_OFF); in TEST()
7144 assertConditionTimer(it->second.conditionTimer, true, 0, bucketStartTimeNs + 5 * NS_PER_SEC); in TEST()
7199 ValidateValueBucket(data.bucket_info(0), bucketStartTimeNs, bucket2StartTimeNs, {1}, in TEST()
7206 ValidateValueBucket(data.bucket_info(0), bucketStartTimeNs, bucket2StartTimeNs, {1}, in TEST()
7226 CreateThreeValueLogEvent(tagId, bucketStartTimeNs + 1, 1 /*uid*/, 5, 5)); in TEST()
7228 CreateThreeValueLogEvent(tagId, bucketStartTimeNs + 1, 1 /*uid*/, 5, 7)); in TEST()
7230 CreateThreeValueLogEvent(tagId, bucketStartTimeNs + 1, 2 /*uid*/, 6, 5)); in TEST()
7232 CreateThreeValueLogEvent(tagId, bucketStartTimeNs + 1, 2 /*uid*/, 6, 7)); in TEST()
7284 ValidateValueBucket(data.bucket_info(0), bucketStartTimeNs, bucket2StartTimeNs, {11}, -1, 0); in TEST()
7291 ValidateValueBucket(data.bucket_info(0), bucketStartTimeNs, bucket2StartTimeNs, {5}, -1, 0); in TEST()
7313 makeRepeatedUidLogEvent(tagId, bucketStartTimeNs + 1, {1, 10}, 5, {2, 3})); in TEST_GUARDED()
7315 makeRepeatedUidLogEvent(tagId, bucketStartTimeNs + 1, {2, 10}, 5, {3, 4})); in TEST_GUARDED()
7356 ValidateValueBucket(data.bucket_info(0), bucketStartTimeNs, bucket2StartTimeNs, {3}, -1, in TEST_GUARDED()
7365 ValidateValueBucket(data.bucket_info(0), bucketStartTimeNs, bucket2StartTimeNs, {4}, -1, in TEST_GUARDED()
7400 CreateRepeatedValueLogEvent(&event1, tagId, bucketStartTimeNs + 10, 10); in TEST()
7401 CreateRepeatedValueLogEvent(&event2, tagId, bucketStartTimeNs + 20, 15); in TEST()
7402 CreateRepeatedValueLogEvent(&event3, tagId, bucketStartTimeNs + 20, 20); in TEST()
7481 data->push_back(makeUidLogEvent(tagId, bucketStartTimeNs + 1, 1001, 5, 10)); in TEST()
7482 data->push_back(makeUidLogEvent(tagId, bucketStartTimeNs + 1, 1002, 10, 10)); in TEST()
7483 data->push_back(makeUidLogEvent(tagId, bucketStartTimeNs + 1, 1003, 15, 10)); in TEST()
7491 makeUidLogEvent(tagId, bucketStartTimeNs + 10000000000, 1001, 6, 10)); in TEST()
7493 makeUidLogEvent(tagId, bucketStartTimeNs + 10000000000, 1002, 12, 10)); in TEST()
7495 makeUidLogEvent(tagId, bucketStartTimeNs + 10000000000, 1003, 18, 10)); in TEST()
7504 int64_t dumpReportTimeNs = bucketStartTimeNs + 10000000000; in TEST()
7519 ValidateValueBucket(data.bucket_info(0), bucketStartTimeNs, bucketStartTimeNs + 10000000000, in TEST()
7526 ValidateValueBucket(data.bucket_info(0), bucketStartTimeNs, bucketStartTimeNs + 10000000000, in TEST()
7552 CreateTwoValueLogEvent(tagId, bucketStartTimeNs + 30 * NS_PER_SEC, 1, 2)); in TEST()
7554 CreateTwoValueLogEvent(tagId, bucketStartTimeNs + 30 * NS_PER_SEC, 2, 4)); in TEST()
7562 CreateTwoValueLogEvent(tagId, bucketStartTimeNs + 40 * NS_PER_SEC, 3, 5)); in TEST()
7564 CreateTwoValueLogEvent(tagId, bucketStartTimeNs + 40 * NS_PER_SEC, 4, 9)); in TEST()
7572 CreateTwoValueLogEvent(tagId, bucketStartTimeNs + 50 * NS_PER_SEC, 5, 10)); in TEST()
7574 CreateTwoValueLogEvent(tagId, bucketStartTimeNs + 50 * NS_PER_SEC, 6, 20)); in TEST()
7603 valueProducer->onConditionChanged(true, bucketStartTimeNs + 30 * NS_PER_SEC); in TEST()
7606 valueProducer->onConditionChanged(false, bucketStartTimeNs + 40 * NS_PER_SEC); in TEST()
7609 valueProducer->onConditionChanged(true, bucketStartTimeNs + 50 * NS_PER_SEC); in TEST()
7650 ValidateValueBucket(data.bucket_info(0), bucketStartTimeNs, bucket2StartTimeNs, in TEST()
7697 CreateThreeValueLogEvent(&event1, tagId, bucketStartTimeNs + 10, 1, 5, 10); in TEST()
7700 CreateThreeValueLogEvent(&event2, tagId, bucketStartTimeNs + 20, 1, 6, 8); in TEST()
7703 CreateThreeValueLogEvent(&event3, tagId, bucketStartTimeNs + 40, 2, 3, 10); in TEST()
7706 CreateThreeValueLogEvent(&event4, tagId, bucketStartTimeNs + 50, 2, 4, 6); in TEST()
7709 CreateThreeValueLogEvent(&event5, tagId, bucketStartTimeNs + 30, 1, 19, 9); in TEST()
7712 CreateThreeValueLogEvent(&event6, tagId, bucketStartTimeNs + 60, 2, 20, 8); in TEST()
7780 ValidateValueBucket(data.bucket_info(0), bucketStartTimeNs, bucket2StartTimeNs, in TEST()
7787 ValidateValueBucket(data.bucket_info(0), bucketStartTimeNs, bucket2StartTimeNs, in TEST()
7812 StatsLogReport report = onDumpReport(valueProducer, bucketStartTimeNs + 50, in TEST()
7821 StatsLogReport report = onDumpReport(valueProducer, bucketStartTimeNs + 150, in TEST()
7841 StatsLogReport report = onDumpReport(valueProducer, bucketStartTimeNs + 50, in TEST()
7850 StatsLogReport report = onDumpReport(valueProducer, bucketStartTimeNs + 150, in TEST()
7872 StatsLogReport report = onDumpReport(valueProducer, bucketStartTimeNs + 50, in TEST()
7881 StatsLogReport report = onDumpReport(valueProducer, bucketStartTimeNs + 150, in TEST()
7902 StatsLogReport report = onDumpReport(valueProducer, bucketStartTimeNs + 50, in TEST()
7910 StatsLogReport report = onDumpReport(valueProducer, bucketStartTimeNs + 150, in TEST()