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;
135 EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _)) in TEST()
138 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST()
148 tagId, -1, tagId, bucketStartTimeNs, bucketStartTimeNs, in TEST()
238 -1 /* -1 means no pulling */, -1, tagId, bucketStartTimeNs, in TEST_P()
239 bucketStartTimeNs, pullerManager, provider); in TEST_P()
243 gaugeProducer.addAnomalyTracker(alert, alarmMonitor, UPDATE_NEW, bucketStartTimeNs); in TEST_P()
247 CreateTwoValueLogEvent(&event1, tagId, bucketStartTimeNs + 10, 1, 10); in TEST_P()
261 EXPECT_EQ(bucketStartTimeNs, in TEST_P()
272 CreateTwoValueLogEvent(&event2, tagId, bucketStartTimeNs + 59 * NS_PER_SEC, 1, 10); in TEST_P()
276 EXPECT_EQ(bucketStartTimeNs, in TEST_P()
287 CreateTwoValueLogEvent(&event3, tagId, bucketStartTimeNs + 65 * NS_PER_SEC, 1, 10); in TEST_P()
291 EXPECT_EQ((int64_t)bucketStartTimeNs + bucketSizeNs, gaugeProducer.mCurrentBucketStartTimeNs); in TEST_P()
296 CreateTwoValueLogEvent(&event4, tagId, bucketStartTimeNs + 125 * NS_PER_SEC, 1, 10); in TEST_P()
335 tagId, -1, tagId, bucketStartTimeNs, bucketStartTimeNs, in TEST_P()
340 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 1, 1)); in TEST_P()
341 gaugeProducer.onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucketStartTimeNs); in TEST_P()
357 EXPECT_EQ(bucketStartTimeNs, in TEST_P()
370 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + bucketSizeNs + 1, 3)); in TEST_P()
372 bucketStartTimeNs + bucketSizeNs); in TEST_P()
399 EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _)) in TEST()
406 tagId, -1, tagId, bucketStartTimeNs, bucketStartTimeNs, in TEST()
411 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 1, 1)); in TEST()
412 gaugeProducer.onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucketStartTimeNs); in TEST()
422 EXPECT_EQ(bucketStartTimeNs, gaugeProducer.mCurrentBucketStartTimeNs); in TEST()
445 int64_t conditionChangeNs = bucketStartTimeNs + 8; in TEST()
463 bucketStartTimeNs, bucketStartTimeNs, pullerManager, provider); in TEST()
535 int64_t sliceConditionChangeNs = bucketStartTimeNs + 8; in TEST()
553 bucketStartTimeNs, bucketStartTimeNs, pullerManager, provider); in TEST()
581 EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _)) in TEST()
599 tagId, -1, tagId, bucketStartTimeNs, bucketStartTimeNs, in TEST()
611 gaugeProducer.addAnomalyTracker(alert, alarmMonitor, UPDATE_NEW, bucketStartTimeNs); in TEST()
616 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 1, 13)); in TEST()
617 gaugeProducer.onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucketStartTimeNs); in TEST()
626 CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + bucketSizeNs + 20, 15); in TEST()
631 bucketStartTimeNs + bucketSizeNs); in TEST()
642 CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 2 * bucketSizeNs + 10, 26)); in TEST()
655 allData.push_back(CreateNoValuesLogEvent(tagId, bucketStartTimeNs + 3 * bucketSizeNs + 10)); in TEST()
657 bucketStartTimeNs + 3 * bucketSizeNs); in TEST()
682 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10); in TEST()
689 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 20); in TEST()
701 tagId, triggerId, tagId, bucketStartTimeNs, bucketStartTimeNs, in TEST()
708 CreateNoValuesLogEvent(&triggerEvent, triggerId, bucketStartTimeNs + 10); in TEST()
711 triggerEvent.setElapsedTimestampNs(bucketStartTimeNs + 20); in TEST()
748 EXPECT_EQ(eventTimeNs, bucketStartTimeNs); in TEST()
761 tagId, /*triggerId=*/-1, tagId, bucketStartTimeNs, in TEST()
762 bucketStartTimeNs, pullerManager, provider); in TEST()
808 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 3); in TEST()
815 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10); in TEST()
822 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 20); in TEST()
834 tagId, triggerId, tagId, bucketStartTimeNs, bucketStartTimeNs, in TEST()
839 CreateNoValuesLogEvent(&triggerEvent, triggerId, bucketStartTimeNs + 3); in TEST()
842 triggerEvent.setElapsedTimestampNs(bucketStartTimeNs + 10); in TEST()
846 triggerEvent.setElapsedTimestampNs(bucketStartTimeNs + 20); in TEST()
892 EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs + 3, _)) in TEST()
906 tagId, triggerId, tagId, bucketStartTimeNs, bucketStartTimeNs, in TEST()
911 CreateNoValuesLogEvent(&triggerEvent, triggerId, bucketStartTimeNs + 3); in TEST()
917 gaugeProducer.onDumpReport(bucketStartTimeNs + 9000000, true /* include recent buckets */, true, in TEST()
925 EXPECT_EQ(NanoToMillis(bucketStartTimeNs), in TEST()
927 EXPECT_EQ(NanoToMillis(bucketStartTimeNs + 9000000), in TEST()
933 EXPECT_EQ(NanoToMillis(bucketStartTimeNs + 9000000), dropEvent.drop_time_millis()); in TEST()
963 data->push_back(makeUidLogEvent(tagId, bucketStartTimeNs + 10, 1001, 5, 10)); in TEST()
964 data->push_back(makeUidLogEvent(tagId, bucketStartTimeNs + 10, 1002, 10, 10)); in TEST()
965 data->push_back(makeUidLogEvent(tagId, bucketStartTimeNs + 10, 1003, 15, 10)); in TEST()
971 data->push_back(makeUidLogEvent(tagId, bucketStartTimeNs + 20, 1001, 6, 10)); in TEST()
972 data->push_back(makeUidLogEvent(tagId, bucketStartTimeNs + 20, 1002, 12, 10)); in TEST()
973 data->push_back(makeUidLogEvent(tagId, bucketStartTimeNs + 20, 1003, 18, 10)); in TEST()
979 logEventMatcherIndex, eventMatcherWizard, tagId, triggerId, tagId, bucketStartTimeNs, in TEST()
980 bucketStartTimeNs, pullerManager, provider); in TEST()
989 CreateRepeatedValueLogEvent(&triggerEvent, triggerId, bucketStartTimeNs + 10, 5); in TEST()
992 triggerEvent.setElapsedTimestampNs(bucketStartTimeNs + 20); in TEST()
998 int64_t dumpReportTimeNs = bucketStartTimeNs + 10000000000; in TEST()
1016 ValidateGaugeBucketTimes(data.bucket_info(0), bucketStartTimeNs, dumpReportTimeNs, in TEST()
1017 {bucketStartTimeNs + 10, bucketStartTimeNs + 20}); in TEST()
1021 ValidateGaugeBucketTimes(data.bucket_info(0), bucketStartTimeNs, dumpReportTimeNs, in TEST()
1022 {bucketStartTimeNs + 10, bucketStartTimeNs + 20}); in TEST()