Lines Matching refs:bucket2StartTimeNs
53 const int64_t bucket2StartTimeNs = bucketStartTimeNs + bucketSizeNs; variable
294 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 11)); in TEST()
296 valueProducer->onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs); in TEST()
355 int64_t partialBucketSplitTimeNs = bucket2StartTimeNs + 2; in TEST_P()
382 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 10, 2)); in TEST_P()
383 valueProducer->onDataPulled(allData, /** success */ true, bucket2StartTimeNs); in TEST_P()
398 {bucketSizeNs, partialBucketSplitTimeNs - bucket2StartTimeNs}, in TEST_P()
399 {bucketStartTimeNs, bucket2StartTimeNs}, in TEST_P()
400 {bucket2StartTimeNs, partialBucketSplitTimeNs}); in TEST_P()
434 allData.push_back(CreateTwoValueLogEvent(tagId, bucket2StartTimeNs + 1, 3, 11)); in TEST()
436 valueProducer->onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs); in TEST()
498 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 11)); in TEST()
500 valueProducer->onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs); in TEST()
559 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 11)); in TEST()
561 valueProducer->onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs); in TEST()
619 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 1); // Second condition change. in TEST()
621 data->push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 130)); in TEST()
652 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 110)); in TEST()
653 valueProducer->onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs); in TEST()
655 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
666 valueProducer->onConditionChanged(false, bucket2StartTimeNs + 1); in TEST()
668 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
680 {bucketStartTimeNs, bucket2StartTimeNs}, in TEST()
681 {bucket2StartTimeNs, bucket3StartTimeNs}); in TEST()
730 CreateRepeatedValueLogEvent(&event3, tagId, bucket2StartTimeNs + 5 * NS_PER_SEC, 10); in TEST_P()
734 bucket2StartTimeNs - partialBucketSplitTimeNs}, in TEST_P()
736 {partialBucketSplitTimeNs, bucket2StartTimeNs}); in TEST_P()
748 int64_t partialBucketSplitTimeNs = bucket2StartTimeNs + 150; in TEST_P()
769 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 100)); in TEST_P()
771 valueProducer.onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs); in TEST_P()
784 assertPastBucketValuesSingleKey(valueProducer.mPastBuckets, {20}, {150}, {bucket2StartTimeNs}, in TEST_P()
793 {bucket2StartTimeNs, partialBucketSplitTimeNs}, in TEST_P()
817 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 100)); in TEST()
819 valueProducer.onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs); in TEST()
822 valueProducer.notifyAppUpgrade(bucket2StartTimeNs + 150); in TEST()
824 EXPECT_EQ(bucket2StartTimeNs, valueProducer.mCurrentBucketStartTimeNs); in TEST()
842 bucket2StartTimeNs - 100); // Condition change to false time. in TEST_P()
844 data->push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs - 100, 120)); in TEST_P()
853 valueProducer->onConditionChanged(false, bucket2StartTimeNs - 100); in TEST_P()
856 int64_t partialBucketSplitTimeNs = bucket2StartTimeNs - 50; in TEST_P()
869 {(bucket2StartTimeNs - 100) - (bucketStartTimeNs + 1)}, in TEST_P()
910 valueProducer.flushIfNeededLocked(bucket2StartTimeNs); in TEST()
912 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
968 valueProducer.flushIfNeededLocked(bucket2StartTimeNs); in TEST()
970 {bucket2StartTimeNs}); in TEST()
1104 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 11)); in TEST()
1106 valueProducer->onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs); in TEST()
1133 {bucket2StartTimeNs}, {bucket3StartTimeNs}); in TEST()
1150 {bucket2StartTimeNs}, {bucket3StartTimeNs}); in TEST()
1156 EXPECT_EQ(bucket2StartTimeNs, valueProducer->mSkippedBuckets[0].bucketEndTimeNs); in TEST()
1159 EXPECT_EQ(bucket2StartTimeNs, valueProducer->mSkippedBuckets[0].dropEvents[0].dropTimeNs); in TEST()
1188 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 1); // Second condition change. in TEST()
1190 data->push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 120)); in TEST()
1211 valueProducer->onConditionChanged(false, bucket2StartTimeNs + 1); in TEST()
1215 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
1221 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 30, 110)); in TEST()
1222 valueProducer->onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs); in TEST()
1225 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
1252 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 1); in TEST()
1254 data->push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 120)); in TEST()
1260 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 25); in TEST()
1262 data->push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 25, 130)); in TEST()
1285 valueProducer->onConditionChanged(false, bucket2StartTimeNs + 1); in TEST()
1287 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
1295 valueProducer->onConditionChanged(true, bucket2StartTimeNs + 25); in TEST()
1297 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
1307 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 50, 140)); in TEST()
1308 valueProducer->onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs + 50); in TEST()
1317 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
1324 {bucketStartTimeNs, bucket2StartTimeNs}, {bucket2StartTimeNs, bucket3StartTimeNs}); in TEST()
1362 valueProducer.flushIfNeededLocked(bucket2StartTimeNs); in TEST()
1364 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
1401 valueProducer.flushIfNeededLocked(bucket2StartTimeNs); in TEST()
1403 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
1442 valueProducer.flushIfNeededLocked(bucket2StartTimeNs); in TEST()
1484 valueProducer.flushIfNeededLocked(bucket2StartTimeNs); in TEST()
1486 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
1530 CreateRepeatedValueLogEvent(&event3, tagId, bucket2StartTimeNs + 10, 15); in TEST()
1542 CreateRepeatedValueLogEvent(&event4, tagId, bucket2StartTimeNs + 15, 15); in TEST()
1554 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
1609 CreateThreeValueLogEvent(&event3, tagId, bucket2StartTimeNs + 10, 1, 15, 25); in TEST()
1626 CreateThreeValueLogEvent(&event4, tagId, bucket2StartTimeNs + 15, 1, 15, 29); in TEST()
1694 allData.push_back(CreateTwoValueLogEvent(tagId, bucket2StartTimeNs + 1, 2, 4)); in TEST()
1695 allData.push_back(CreateTwoValueLogEvent(tagId, bucket2StartTimeNs + 1, 1, 11)); in TEST()
1697 valueProducer->onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs); in TEST()
1771 allData.push_back(CreateTwoValueLogEvent(tagId, bucket2StartTimeNs + 1, 2, 4)); in TEST()
1772 allData.push_back(CreateTwoValueLogEvent(tagId, bucket2StartTimeNs + 1, 1, 11)); in TEST()
1774 valueProducer->onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs); in TEST()
1878 allData.push_back(CreateTwoValueLogEvent(tagId, bucket2StartTimeNs + 1, 2, 4)); in TEST()
1879 allData.push_back(CreateTwoValueLogEvent(tagId, bucket2StartTimeNs + 1, 1, 11)); in TEST()
1880 valueProducer->onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs); in TEST()
1889 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
1927 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
1947 EXPECT_EQ(bucket2StartTimeNs, iterator->second[0].mBucketEndNs); in TEST()
1981 valueProducer->onDataPulled(allData, /** succeed */ false, bucket2StartTimeNs); in TEST()
2105 bucket2StartTimeNs, bucket2StartTimeNs, pullerManager); in TEST()
2181 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 140)); in TEST()
2182 valueProducer->onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs); in TEST()
2184 valueProducer->flushIfNeededLocked(bucket2StartTimeNs + 1); in TEST()
2201 valueProducer->onDumpReport(bucket2StartTimeNs + 10, false /* include partial bucket */, true, in TEST()
2211 EXPECT_EQ(NanoToMillis(bucket2StartTimeNs), in TEST()
2252 allData.push_back(CreateTwoValueLogEvent(tagId, bucket2StartTimeNs + 1, 1, 10)); in TEST()
2253 valueProducer->onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs); in TEST()
2261 valueProducer->onDumpReport(bucket2StartTimeNs + 10000, false /* include recent buckets */, in TEST()
2271 EXPECT_EQ(NanoToMillis(bucket2StartTimeNs), in TEST()
2320 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 140)); in TEST()
2321 valueProducer->onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs); in TEST()
2323 valueProducer->flushIfNeededLocked(bucket2StartTimeNs + 1); in TEST()
2340 valueProducer->onDumpReport(bucket2StartTimeNs + 10000, false /* include recent buckets */, in TEST()
2350 EXPECT_EQ(NanoToMillis(bucket2StartTimeNs), in TEST()
2400 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 140)); in TEST()
2401 valueProducer->onDataPulled(allData, /** succeed */ false, bucket2StartTimeNs); in TEST()
2403 valueProducer->flushIfNeededLocked(bucket2StartTimeNs + 1); in TEST()
2419 valueProducer->onDumpReport(bucket2StartTimeNs + 10000, false /* include recent buckets */, in TEST()
2429 EXPECT_EQ(NanoToMillis(bucket2StartTimeNs), in TEST()
2435 EXPECT_EQ(NanoToMillis(bucket2StartTimeNs), dropEvent.drop_time_millis()); in TEST()
2456 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 110)); in TEST()
2457 valueProducer->onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs); in TEST()
2561 valueProducer->onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs); in TEST()
2573 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
2602 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 2)); in TEST()
2603 valueProducer->onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs); in TEST()
2686 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 10); in TEST()
2688 data->push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 10, 5)); in TEST()
2709 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 4)); in TEST()
2710 valueProducer->onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs + 1); in TEST()
2713 valueProducer->onConditionChanged(true, bucket2StartTimeNs + 10); in TEST()
2725 {bucket2StartTimeNs}, {bucket3StartTimeNs}); in TEST()
2741 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs, 20)); in TEST()
2742 valueProducer->onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs); in TEST()
2746 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
2770 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs, 20)); in TEST()
2771 valueProducer->onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs); in TEST()
2775 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
2781 int64_t partialBucketSplitTimeNs = bucket2StartTimeNs + 2; in TEST_P()
2816 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST_P()
2856 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 10)); in TEST()
2857 valueProducer->onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs + 1); in TEST()
2860 {bucket2StartTimeNs}); in TEST()
2872 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 10); in TEST()
2880 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 8); in TEST()
2882 data->push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs, 1)); in TEST()
2888 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 10); in TEST()
2890 data->push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs, 1)); in TEST()
2897 valueProducer->onConditionChanged(true, bucket2StartTimeNs + 10); in TEST()
2904 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs, 20)); in TEST()
2905 valueProducer->onDataPulled(allData, /** succeed */ false, bucket2StartTimeNs); in TEST()
2907 valueProducer->onConditionChanged(false, bucket2StartTimeNs + 8); in TEST()
2908 valueProducer->onConditionChanged(true, bucket2StartTimeNs + 10); in TEST()
2912 valueProducer->onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs); in TEST()
2978 allData.push_back(CreateThreeValueLogEvent(tagId, bucket2StartTimeNs + 1, tagId, 2, 2)); in TEST()
2979 valueProducer.onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs); in TEST()
3045 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 30, 10)); in TEST()
3046 valueProducer->onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs + 30); in TEST()
3050 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
3093 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 30, 110)); in TEST()
3094 valueProducer->onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs); in TEST()
3097 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
3125 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 30, 30)); in TEST()
3126 valueProducer->onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs); in TEST()
3129 {bucketStartTimeNs}, {bucket2StartTimeNs}); in TEST()
3149 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 30, 30)); in TEST()
3150 valueProducer->onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs); in TEST()
3180 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 30, 30)); in TEST()
3181 valueProducer->onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs); in TEST()
3265 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs, 15)); in TEST()
3266 valueProducer->onDataPulled(allData, /** succeeds */ true, bucket2StartTimeNs + 1); in TEST()
3269 valueProducer->onConditionChanged(false, bucket2StartTimeNs - 100); in TEST()
3274 valueProducer->onDumpReport(bucket2StartTimeNs + 100, true /* include recent buckets */, true, in TEST()
3282 EXPECT_EQ(NanoToMillis(bucket2StartTimeNs), in TEST()
3284 EXPECT_EQ(NanoToMillis(bucket2StartTimeNs + 100), in TEST()
3290 EXPECT_EQ(NanoToMillis(bucket2StartTimeNs - 100), dropEvent.drop_time_millis()); in TEST()
3294 EXPECT_EQ(NanoToMillis(bucket2StartTimeNs + 100), dropEvent.drop_time_millis()); in TEST()
3317 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 100); in TEST()
3319 data->push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 100, 15)); in TEST()
3332 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs, 15)); in TEST()
3333 valueProducer->onDataPulled(allData, /** succeeds */ true, bucket2StartTimeNs + 1); in TEST()
3336 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs - 100, 20)); in TEST()
3339 valueProducer->accumulateEvents(allData, bucket2StartTimeNs - 100, bucket2StartTimeNs - 100); in TEST()
3344 valueProducer->onDumpReport(bucket2StartTimeNs + 100, true /* include recent buckets */, true, in TEST()
3352 EXPECT_EQ(NanoToMillis(bucket2StartTimeNs), in TEST()
3354 EXPECT_EQ(NanoToMillis(bucket2StartTimeNs + 100), in TEST()
3360 EXPECT_EQ(NanoToMillis(bucket2StartTimeNs - 100), dropEvent.drop_time_millis()); in TEST()
3646 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 10 * NS_PER_SEC); in TEST()
3649 tagId, bucket2StartTimeNs + 10 * NS_PER_SEC, 10)); in TEST()
3655 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 15 * NS_PER_SEC); in TEST()
3658 tagId, bucket2StartTimeNs + 15 * NS_PER_SEC, 15)); in TEST()
3673 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 3)); in TEST()
3674 valueProducer->onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs); in TEST()
3677 int64_t conditionChangeTimeNs = bucket2StartTimeNs + 10 * NS_PER_SEC; in TEST()
3683 int64_t dumpReportTimeNs = bucket2StartTimeNs + 15 * NS_PER_SEC; // 15 seconds in TEST()
3704 EXPECT_EQ(NanoToMillis(bucket2StartTimeNs), in TEST()
3710 EXPECT_EQ(NanoToMillis(bucket2StartTimeNs), dropEvent.drop_time_millis()); in TEST()
3712 EXPECT_EQ(NanoToMillis(bucket2StartTimeNs), in TEST()
3743 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 1000); in TEST()
3746 CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1000, 15)); in TEST()
3759 int64_t appUpdateTimeNs = bucket2StartTimeNs + 1000; in TEST()
3765 int64_t dumpReportTimeNs = bucket2StartTimeNs + 10000000000; // 10 seconds in TEST()
3779 EXPECT_EQ(NanoToMillis(bucket2StartTimeNs), in TEST()
4556 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 20 * NS_PER_SEC); in TEST()
4558 data->push_back(CreateTwoValueLogEvent(tagId, bucket2StartTimeNs + 20 * NS_PER_SEC, in TEST()
4562 data->push_back(CreateTwoValueLogEvent(tagId, bucket2StartTimeNs + 20 * NS_PER_SEC, in TEST()
4569 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 40 * NS_PER_SEC); in TEST()
4571 data->push_back(CreateTwoValueLogEvent(tagId, bucket2StartTimeNs + 40 * NS_PER_SEC, in TEST()
4575 data->push_back(CreateTwoValueLogEvent(tagId, bucket2StartTimeNs + 40 * NS_PER_SEC, in TEST()
4582 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 50 * NS_PER_SEC); in TEST()
4584 data->push_back(CreateTwoValueLogEvent(tagId, bucket2StartTimeNs + 50 * NS_PER_SEC, in TEST()
4586 data->push_back(CreateTwoValueLogEvent(tagId, bucket2StartTimeNs + 50 * NS_PER_SEC, in TEST()
4756 allData.push_back(CreateTwoValueLogEvent(tagId, bucket2StartTimeNs, 1 /*uid*/, 10)); in TEST()
4757 allData.push_back(CreateTwoValueLogEvent(tagId, bucket2StartTimeNs, 2 /*uid*/, 15)); in TEST()
4758 valueProducer->onDataPulled(allData, /** succeeds */ true, bucket2StartTimeNs + 1); in TEST()
4782 assertConditionTimer(it->second.conditionTimer, true, 0, bucket2StartTimeNs); in TEST()
4812 assertConditionTimer(it->second.conditionTimer, true, 0, bucket2StartTimeNs); in TEST()
4828 CreateUidProcessStateChangedEvent(bucket2StartTimeNs + 20 * NS_PER_SEC, 1 /* uid */, in TEST()
4851 assertConditionTimer(it->second.conditionTimer, true, 0, bucket2StartTimeNs); in TEST()
4878 assertConditionTimer(it->second.conditionTimer, true, 0, bucket2StartTimeNs + 20 * NS_PER_SEC); in TEST()
4890 bucket2StartTimeNs + 20 * NS_PER_SEC); in TEST()
4904 CreateUidProcessStateChangedEvent(bucket2StartTimeNs + 40 * NS_PER_SEC, 1 /* uid */, in TEST()
4926 assertConditionTimer(it->second.conditionTimer, true, 0, bucket2StartTimeNs); in TEST()
4956 bucket2StartTimeNs + 40 * NS_PER_SEC); in TEST()
4968 bucket2StartTimeNs + 40 * NS_PER_SEC); in TEST()
4982 valueProducer->onDumpReport(bucket2StartTimeNs + 50 * NS_PER_SEC, in TEST()
5399 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 30 * NS_PER_SEC); in TEST()
5402 tagId, bucket2StartTimeNs + 30 * NS_PER_SEC, 10)); in TEST()
5408 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 50 * NS_PER_SEC); in TEST()
5411 tagId, bucket2StartTimeNs + 50 * NS_PER_SEC, 15)); in TEST()
5511 CreateBatterySaverOnEvent(/*timestamp=*/bucket2StartTimeNs + 30 * NS_PER_SEC); in TEST()
5527 bucket2StartTimeNs + 30 * NS_PER_SEC); in TEST()
5535 assertConditionTimer(it->second.conditionTimer, true, 0, bucket2StartTimeNs + 30 * NS_PER_SEC); in TEST()
5548 valueProducer->onDumpReport(bucket2StartTimeNs + 50 * NS_PER_SEC, in TEST()
5883 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 30 * NS_PER_SEC); in TEST()
5886 tagId, bucket2StartTimeNs + 30 * NS_PER_SEC, 2 /*uid*/, 18, 8 /*tag*/)); in TEST()
5890 tagId, bucket2StartTimeNs + 30 * NS_PER_SEC, 1 /*uid*/, 18, 14 /* tag */)); in TEST()
5893 tagId, bucket2StartTimeNs + 30 * NS_PER_SEC, 1 /*uid*/, 18, 16 /* tag */)); in TEST()
5900 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 50 * NS_PER_SEC); in TEST()
5903 tagId, bucket2StartTimeNs + 50 * NS_PER_SEC, 1 /*uid*/, 21, 14 /* tag */)); in TEST()
5905 tagId, bucket2StartTimeNs + 50 * NS_PER_SEC, 1 /*uid*/, 21, 16 /* tag */)); in TEST()
5907 tagId, bucket2StartTimeNs + 50 * NS_PER_SEC, 2 /*uid*/, 21, 8 /*tag*/)); in TEST()
6372 CreateThreeValueLogEvent(tagId, bucket2StartTimeNs, 1 /*uid*/, 13, 14 /* tag */)); in TEST()
6374 CreateThreeValueLogEvent(tagId, bucket2StartTimeNs, 1 /*uid*/, 13, 16 /* tag */)); in TEST()
6376 CreateThreeValueLogEvent(tagId, bucket2StartTimeNs, 2 /*uid*/, 13, 8 /*tag*/)); in TEST()
6377 valueProducer->onDataPulled(allData, /** succeeds */ true, bucket2StartTimeNs + 1); in TEST()
6397 assertConditionTimer(it->second.conditionTimer, true, 0, bucket2StartTimeNs); in TEST()
6424 assertConditionTimer(it->second.conditionTimer, true, 0, bucket2StartTimeNs); in TEST()
6440 assertConditionTimer(it->second.conditionTimer, true, 0, bucket2StartTimeNs); in TEST()
6490 CreateUidProcessStateChangedEvent(bucket2StartTimeNs + 30 * NS_PER_SEC, 2 /* uid */, in TEST()
6509 assertConditionTimer(it->second.conditionTimer, true, 0, bucket2StartTimeNs + 30 * NS_PER_SEC); in TEST()
6520 bucket2StartTimeNs + 30 * NS_PER_SEC); in TEST()
6545 assertConditionTimer(it->second.conditionTimer, true, 0, bucket2StartTimeNs); in TEST()
6560 assertConditionTimer(it->second.conditionTimer, true, 0, bucket2StartTimeNs); in TEST()
6605 valueProducer->onDumpReport(bucket2StartTimeNs + 50 * NS_PER_SEC, in TEST()
6692 EXPECT_EQ(eventTimeNs, bucket2StartTimeNs + 10 * NS_PER_SEC); in TEST()
6695 tagId, bucket2StartTimeNs + 10 * NS_PER_SEC, 15)); in TEST()
6789 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs, 11)); in TEST()
6790 valueProducer->onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs); in TEST()
6805 assertConditionTimer(it->second.conditionTimer, true, 0, bucket2StartTimeNs); in TEST()
6814 valueProducer->onConditionChanged(false, bucket2StartTimeNs + 10 * NS_PER_SEC); in TEST()
6833 bucket2StartTimeNs + 10 * NS_PER_SEC); in TEST()
6849 valueProducer->onDumpReport(bucket2StartTimeNs + 50 * NS_PER_SEC, in TEST()
6941 data->push_back(CreateThreeValueLogEvent(tagId, bucket2StartTimeNs + 10000000000, in TEST()
6943 data->push_back(CreateThreeValueLogEvent(tagId, bucket2StartTimeNs + 10000000000, in TEST()
6955 allData.push_back(CreateThreeValueLogEvent(tagId, bucket2StartTimeNs + 1, 1 /*uid*/, 21, 21)); in TEST()
6956 allData.push_back(CreateThreeValueLogEvent(tagId, bucket2StartTimeNs + 1, 2 /*uid*/, 20, 5)); in TEST()
6957 valueProducer->onDataPulled(allData, /** succeed */ true, bucket2StartTimeNs); in TEST()
6962 int64_t dumpReportTimeNs = bucket2StartTimeNs + 10000000000; in TEST()
6981 ValidateValueBucket(data.bucket_info(0), bucketStartTimeNs, bucket2StartTimeNs, {16, 16}, -1); in TEST()
6988 EXPECT_EQ(bucket2StartTimeNs, report.value_metrics().skipped(0).start_bucket_elapsed_nanos()); in TEST()