Lines Matching refs:bucketStartTimeNs
52 const int64_t bucketStartTimeNs = 10 * NS_PER_SEC; variable
54 const int64_t bucket2StartTimeNs = bucketStartTimeNs + bucketSizeNs;
55 const int64_t bucket3StartTimeNs = bucketStartTimeNs + 2 * bucketSizeNs;
56 const int64_t bucket4StartTimeNs = bucketStartTimeNs + 3 * bucketSizeNs;
57 const int64_t partialBucketSplitTimeNs = bucketStartTimeNs + 15 * NS_PER_SEC;
143 EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _)) in TEST()
146 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST()
156 tagId, -1, tagId, bucketStartTimeNs, bucketStartTimeNs, in TEST()
245 -1 /* -1 means no pulling */, -1, tagId, bucketStartTimeNs, in TEST_P()
246 bucketStartTimeNs, pullerManager, provider); in TEST_P()
250 gaugeProducer.addAnomalyTracker(alert, alarmMonitor, UPDATE_NEW, bucketStartTimeNs); in TEST_P()
254 CreateTwoValueLogEvent(&event1, tagId, bucketStartTimeNs + 10, 1, 10); in TEST_P()
268 EXPECT_EQ(bucketStartTimeNs, in TEST_P()
279 CreateTwoValueLogEvent(&event2, tagId, bucketStartTimeNs + 59 * NS_PER_SEC, 1, 10); in TEST_P()
283 EXPECT_EQ(bucketStartTimeNs, in TEST_P()
294 CreateTwoValueLogEvent(&event3, tagId, bucketStartTimeNs + 65 * NS_PER_SEC, 1, 10); in TEST_P()
298 EXPECT_EQ((int64_t)bucketStartTimeNs + bucketSizeNs, gaugeProducer.mCurrentBucketStartTimeNs); in TEST_P()
303 CreateTwoValueLogEvent(&event4, tagId, bucketStartTimeNs + 125 * NS_PER_SEC, 1, 10); in TEST_P()
342 tagId, -1, tagId, bucketStartTimeNs, bucketStartTimeNs, in TEST_P()
347 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 1, 1)); in TEST_P()
348 gaugeProducer.onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucketStartTimeNs); in TEST_P()
364 EXPECT_EQ(bucketStartTimeNs, in TEST_P()
377 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + bucketSizeNs + 1, 3)); in TEST_P()
379 bucketStartTimeNs + bucketSizeNs); in TEST_P()
406 EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _)) in TEST()
413 tagId, -1, tagId, bucketStartTimeNs, bucketStartTimeNs, in TEST()
418 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 1, 1)); in TEST()
419 gaugeProducer.onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucketStartTimeNs); in TEST()
429 EXPECT_EQ(bucketStartTimeNs, gaugeProducer.mCurrentBucketStartTimeNs); in TEST()
452 int64_t conditionChangeNs = bucketStartTimeNs + 8; in TEST()
470 bucketStartTimeNs, bucketStartTimeNs, pullerManager, provider); in TEST()
541 int64_t sliceConditionChangeNs = bucketStartTimeNs + 8; in TEST()
559 bucketStartTimeNs, bucketStartTimeNs, pullerManager, provider); in TEST()
587 EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _)) in TEST()
605 tagId, -1, tagId, bucketStartTimeNs, bucketStartTimeNs, in TEST()
617 gaugeProducer.addAnomalyTracker(alert, alarmMonitor, UPDATE_NEW, bucketStartTimeNs); in TEST()
622 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 1, 13)); in TEST()
623 gaugeProducer.onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucketStartTimeNs); in TEST()
632 CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + bucketSizeNs + 20, 15); in TEST()
637 bucketStartTimeNs + bucketSizeNs); in TEST()
648 CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 2 * bucketSizeNs + 10, 26)); in TEST()
661 allData.push_back(CreateNoValuesLogEvent(tagId, bucketStartTimeNs + 3 * bucketSizeNs + 10)); in TEST()
663 bucketStartTimeNs + 3 * bucketSizeNs); in TEST()
687 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10); in TEST()
694 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 20); in TEST()
706 tagId, triggerId, tagId, bucketStartTimeNs, bucketStartTimeNs, in TEST()
713 CreateNoValuesLogEvent(&triggerEvent, triggerId, bucketStartTimeNs + 10); in TEST()
716 triggerEvent.setElapsedTimestampNs(bucketStartTimeNs + 20); in TEST()
753 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST()
766 tagId, /*triggerId=*/-1, tagId, bucketStartTimeNs, in TEST()
767 bucketStartTimeNs, pullerManager, provider); in TEST()
812 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 3); in TEST()
819 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10); in TEST()
826 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 20); in TEST()
838 tagId, triggerId, tagId, bucketStartTimeNs, bucketStartTimeNs, in TEST()
843 CreateNoValuesLogEvent(&triggerEvent, triggerId, bucketStartTimeNs + 3); in TEST()
846 triggerEvent.setElapsedTimestampNs(bucketStartTimeNs + 10); in TEST()
850 triggerEvent.setElapsedTimestampNs(bucketStartTimeNs + 20); in TEST()
896 EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs + 3, _)) in TEST()
910 tagId, triggerId, tagId, bucketStartTimeNs, bucketStartTimeNs, in TEST()
915 CreateNoValuesLogEvent(&triggerEvent, triggerId, bucketStartTimeNs + 3); in TEST()
919 StatsLogReport report = onDumpReport(gaugeProducer, bucketStartTimeNs + 9000000); in TEST()
924 EXPECT_EQ(NanoToMillis(bucketStartTimeNs), in TEST()
926 EXPECT_EQ(NanoToMillis(bucketStartTimeNs + 9000000), in TEST()
932 EXPECT_EQ(NanoToMillis(bucketStartTimeNs + 9000000), dropEvent.drop_time_millis()); in TEST()
962 data->push_back(makeUidLogEvent(tagId, bucketStartTimeNs + 10, 1001, 5, 10)); in TEST()
963 data->push_back(makeUidLogEvent(tagId, bucketStartTimeNs + 10, 1002, 10, 10)); in TEST()
964 data->push_back(makeUidLogEvent(tagId, bucketStartTimeNs + 10, 1003, 15, 10)); in TEST()
970 data->push_back(makeUidLogEvent(tagId, bucketStartTimeNs + 20, 1001, 6, 10)); in TEST()
971 data->push_back(makeUidLogEvent(tagId, bucketStartTimeNs + 20, 1002, 12, 10)); in TEST()
972 data->push_back(makeUidLogEvent(tagId, bucketStartTimeNs + 20, 1003, 18, 10)); in TEST()
978 logEventMatcherIndex, eventMatcherWizard, tagId, triggerId, tagId, bucketStartTimeNs, in TEST()
979 bucketStartTimeNs, pullerManager, provider); in TEST()
988 CreateRepeatedValueLogEvent(&triggerEvent, triggerId, bucketStartTimeNs + 10, 5); in TEST()
991 triggerEvent.setElapsedTimestampNs(bucketStartTimeNs + 20); in TEST()
995 int64_t dumpReportTimeNs = bucketStartTimeNs + 10000000000; in TEST()
1010 ValidateGaugeBucketTimes(data.bucket_info(0), bucketStartTimeNs, dumpReportTimeNs, in TEST()
1011 {bucketStartTimeNs + 10, bucketStartTimeNs + 20}); in TEST()
1015 ValidateGaugeBucketTimes(data.bucket_info(0), bucketStartTimeNs, dumpReportTimeNs, in TEST()
1016 {bucketStartTimeNs + 10, bucketStartTimeNs + 20}); in TEST()
1039 bucketStartTimeNs, bucketStartTimeNs, pullerManager, provider); in TEST()
1045 StatsLogReport report = onDumpReport(gaugeProducer, bucketStartTimeNs + 50); in TEST()
1053 StatsLogReport report = onDumpReport(gaugeProducer, bucketStartTimeNs + 150); in TEST()
1064 StatsLogReport report = onDumpReport(gaugeProducer, bucketStartTimeNs + 250); in TEST()
1090 bucketStartTimeNs, bucketStartTimeNs, pullerManager, provider); in TEST()
1096 StatsLogReport report = onDumpReport(gaugeProducer, bucketStartTimeNs + 50); in TEST()
1104 StatsLogReport report = onDumpReport(gaugeProducer, bucketStartTimeNs + 150); in TEST()
1115 StatsLogReport report = onDumpReport(gaugeProducer, bucketStartTimeNs + 250); in TEST()
1141 bucketStartTimeNs, bucketStartTimeNs, pullerManager, provider); in TEST()
1147 StatsLogReport report = onDumpReport(gaugeProducer, bucketStartTimeNs + 50); in TEST()
1155 StatsLogReport report = onDumpReport(gaugeProducer, bucketStartTimeNs + 150); in TEST()