Lines Matching refs:durationProducer
76 DurationMetricProducer durationProducer( in TEST() local
81 EXPECT_EQ(600500000000, durationProducer.mCurrentBucketStartTimeNs); in TEST()
82 EXPECT_EQ(10, durationProducer.mCurrentBucketNum); in TEST()
83 EXPECT_EQ(660000000005, durationProducer.getCurrentBucketEndTimeNs()); in TEST()
105 DurationMetricProducer durationProducer( in TEST() local
110 durationProducer.onMatchedLogEvent(1 /* start index*/, event1); in TEST()
111 durationProducer.onMatchedLogEvent(2 /* stop index*/, event2); in TEST()
112 durationProducer.flushIfNeededLocked(bucketStartTimeNs + 2 * bucketSizeNs + 1); in TEST()
113 ASSERT_EQ(1UL, durationProducer.mPastBuckets.size()); in TEST()
114 EXPECT_TRUE(durationProducer.mPastBuckets.find(DEFAULT_METRIC_DIMENSION_KEY) != in TEST()
115 durationProducer.mPastBuckets.end()); in TEST()
116 const auto& buckets = durationProducer.mPastBuckets[DEFAULT_METRIC_DIMENSION_KEY]; in TEST()
149 DurationMetricProducer durationProducer( in TEST() local
154 durationProducer.mCondition = ConditionState::kFalse; in TEST()
156 assertConditionTimer(durationProducer.mConditionTimer, false, 0, 0); in TEST()
157 EXPECT_FALSE(durationProducer.mCondition); in TEST()
158 EXPECT_FALSE(durationProducer.isConditionSliced()); in TEST()
160 durationProducer.onMatchedLogEvent(1 /* start index*/, event1); in TEST()
161 durationProducer.onMatchedLogEvent(2 /* stop index*/, event2); in TEST()
162 durationProducer.flushIfNeededLocked(bucketStartTimeNs + bucketSizeNs + 1); in TEST()
163 ASSERT_EQ(0UL, durationProducer.mPastBuckets.size()); in TEST()
167 durationProducer.onMatchedLogEvent(1 /* start index*/, event3); in TEST()
168 durationProducer.onConditionChanged(true /* condition */, conditionStartTimeNs); in TEST()
169 assertConditionTimer(durationProducer.mConditionTimer, true, 0, conditionStartTimeNs); in TEST()
170 durationProducer.onMatchedLogEvent(2 /* stop index*/, event4); in TEST()
171 durationProducer.flushIfNeededLocked(bucket2EndTimeNs + 1); in TEST()
172 assertConditionTimer(durationProducer.mConditionTimer, true, 0, bucket2EndTimeNs, in TEST()
174 ASSERT_EQ(1UL, durationProducer.mPastBuckets.size()); in TEST()
175 EXPECT_TRUE(durationProducer.mPastBuckets.find(DEFAULT_METRIC_DIMENSION_KEY) != in TEST()
176 durationProducer.mPastBuckets.end()); in TEST()
177 const auto& buckets2 = durationProducer.mPastBuckets[DEFAULT_METRIC_DIMENSION_KEY]; in TEST()
208 DurationMetricProducer durationProducer( in TEST() local
214 EXPECT_EQ(ConditionState::kUnknown, durationProducer.mCondition); in TEST()
215 EXPECT_FALSE(durationProducer.isConditionSliced()); in TEST()
217 durationProducer.onMatchedLogEvent(1 /* start index*/, event1); in TEST()
218 durationProducer.onMatchedLogEvent(2 /* stop index*/, event2); in TEST()
219 durationProducer.flushIfNeededLocked(bucketStartTimeNs + bucketSizeNs + 1); in TEST()
220 ASSERT_EQ(0UL, durationProducer.mPastBuckets.size()); in TEST()
222 durationProducer.onMatchedLogEvent(1 /* start index*/, event3); in TEST()
223 durationProducer.onConditionChanged(true /* condition */, bucketStartTimeNs + bucketSizeNs + 2); in TEST()
224 durationProducer.onMatchedLogEvent(2 /* stop index*/, event4); in TEST()
225 durationProducer.flushIfNeededLocked(bucketStartTimeNs + 2 * bucketSizeNs + 1); in TEST()
226 ASSERT_EQ(1UL, durationProducer.mPastBuckets.size()); in TEST()
227 const auto& buckets2 = durationProducer.mPastBuckets[DEFAULT_METRIC_DIMENSION_KEY]; in TEST()
257 DurationMetricProducer durationProducer( in TEST_P() local
265 durationProducer.onMatchedLogEvent(1 /* start index*/, event1); in TEST_P()
266 ASSERT_EQ(0UL, durationProducer.mPastBuckets.size()); in TEST_P()
267 EXPECT_EQ(bucketStartTimeNs, durationProducer.mCurrentBucketStartTimeNs); in TEST_P()
272 durationProducer.notifyAppUpgrade(partialBucketSplitTimeNs); in TEST_P()
275 durationProducer.onStatsdInitCompleted(partialBucketSplitTimeNs); in TEST_P()
278 ASSERT_EQ(1UL, durationProducer.mPastBuckets[DEFAULT_METRIC_DIMENSION_KEY].size()); in TEST_P()
280 durationProducer.mPastBuckets[DEFAULT_METRIC_DIMENSION_KEY]; in TEST_P()
284 EXPECT_EQ(partialBucketSplitTimeNs, durationProducer.mCurrentBucketStartTimeNs); in TEST_P()
285 EXPECT_EQ(0, durationProducer.getCurrentBucketNum()); in TEST_P()
291 durationProducer.onMatchedLogEvent(2 /* stop index*/, event2); in TEST_P()
292 buckets = durationProducer.mPastBuckets[DEFAULT_METRIC_DIMENSION_KEY]; in TEST_P()
322 DurationMetricProducer durationProducer( in TEST_P() local
330 durationProducer.onMatchedLogEvent(1 /* start index*/, event1); in TEST_P()
331 ASSERT_EQ(0UL, durationProducer.mPastBuckets.size()); in TEST_P()
332 EXPECT_EQ(bucketStartTimeNs, durationProducer.mCurrentBucketStartTimeNs); in TEST_P()
337 durationProducer.notifyAppUpgrade(partialBucketSplitTimeNs); in TEST_P()
340 durationProducer.onStatsdInitCompleted(partialBucketSplitTimeNs); in TEST_P()
343 ASSERT_EQ(2UL, durationProducer.mPastBuckets[DEFAULT_METRIC_DIMENSION_KEY].size()); in TEST_P()
345 durationProducer.mPastBuckets[DEFAULT_METRIC_DIMENSION_KEY]; in TEST_P()
352 EXPECT_EQ(partialBucketSplitTimeNs, durationProducer.mCurrentBucketStartTimeNs); in TEST_P()
353 EXPECT_EQ(1, durationProducer.getCurrentBucketNum()); in TEST_P()
359 durationProducer.onMatchedLogEvent(2 /* stop index*/, event2); in TEST_P()
360 buckets = durationProducer.mPastBuckets[DEFAULT_METRIC_DIMENSION_KEY]; in TEST_P()
388 DurationMetricProducer durationProducer( in TEST_P() local
394 durationProducer.addAnomalyTracker(alert, alarmMonitor, UPDATE_NEW, bucketStartTimeNs); in TEST_P()
400 durationProducer.onMatchedLogEvent(1 /* start index*/, event1); in TEST_P()
405 durationProducer.notifyAppUpgrade(partialBucketSplitTimeNs); in TEST_P()
408 durationProducer.onStatsdInitCompleted(partialBucketSplitTimeNs); in TEST_P()
416 durationProducer.onMatchedLogEvent(2 /* stop index*/, event2); in TEST_P()
437 DurationMetricProducer durationProducer( in TEST_P() local
445 durationProducer.onMatchedLogEvent(1 /* start index*/, event1); in TEST_P()
446 ASSERT_EQ(0UL, durationProducer.mPastBuckets.size()); in TEST_P()
447 EXPECT_EQ(bucketStartTimeNs, durationProducer.mCurrentBucketStartTimeNs); in TEST_P()
452 durationProducer.notifyAppUpgrade(partialBucketSplitTimeNs); in TEST_P()
455 durationProducer.onStatsdInitCompleted(partialBucketSplitTimeNs); in TEST_P()
458 ASSERT_EQ(0UL, durationProducer.mPastBuckets[DEFAULT_METRIC_DIMENSION_KEY].size()); in TEST_P()
459 EXPECT_EQ(partialBucketSplitTimeNs, durationProducer.mCurrentBucketStartTimeNs); in TEST_P()
460 EXPECT_EQ(0, durationProducer.getCurrentBucketNum()); in TEST_P()
466 durationProducer.onMatchedLogEvent(2 /* stop index*/, event2); in TEST_P()
467 ASSERT_EQ(0UL, durationProducer.mPastBuckets[DEFAULT_METRIC_DIMENSION_KEY].size()); in TEST_P()
469 durationProducer.flushIfNeededLocked(bucketStartTimeNs + 3 * bucketSizeNs + 1); in TEST_P()
471 durationProducer.mPastBuckets[DEFAULT_METRIC_DIMENSION_KEY]; in TEST_P()
493 DurationMetricProducer durationProducer( in TEST_P() local
501 durationProducer.onMatchedLogEvent(1 /* start index*/, event1); in TEST_P()
502 ASSERT_EQ(0UL, durationProducer.mPastBuckets.size()); in TEST_P()
503 EXPECT_EQ(bucketStartTimeNs, durationProducer.mCurrentBucketStartTimeNs); in TEST_P()
508 durationProducer.notifyAppUpgrade(partialBucketSplitTimeNs); in TEST_P()
511 durationProducer.onStatsdInitCompleted(partialBucketSplitTimeNs); in TEST_P()
514 ASSERT_EQ(0UL, durationProducer.mPastBuckets[DEFAULT_METRIC_DIMENSION_KEY].size()); in TEST_P()
515 EXPECT_EQ(partialBucketSplitTimeNs, durationProducer.mCurrentBucketStartTimeNs); in TEST_P()
516 EXPECT_EQ(1, durationProducer.getCurrentBucketNum()); in TEST_P()
522 durationProducer.onMatchedLogEvent(2 /* stop index*/, event2); in TEST_P()
523 ASSERT_EQ(0UL, durationProducer.mPastBuckets[DEFAULT_METRIC_DIMENSION_KEY].size()); in TEST_P()
524 EXPECT_EQ(partialBucketSplitTimeNs, durationProducer.mCurrentBucketStartTimeNs); in TEST_P()
526 durationProducer.flushIfNeededLocked(bucketStartTimeNs + 2 * bucketSizeNs + 1); in TEST_P()
528 durationProducer.mPastBuckets[DEFAULT_METRIC_DIMENSION_KEY]; in TEST_P()
556 DurationMetricProducer durationProducer( in TEST() local
564 durationProducer.onMatchedLogEvent(1 /* start index*/, event1); in TEST()
565 ASSERT_EQ(0UL, durationProducer.mPastBuckets.size()); in TEST()
566 EXPECT_EQ(bucketStartTimeNs, durationProducer.mCurrentBucketStartTimeNs); in TEST()
569 durationProducer.notifyAppUpgrade(appUpgradeTimeNs); in TEST()
571 ASSERT_EQ(0UL, durationProducer.mPastBuckets.size()); in TEST()
572 EXPECT_EQ(0, durationProducer.getCurrentBucketNum()); in TEST()
578 durationProducer.onMatchedLogEvent(2 /* stop index*/, event2); in TEST()
579 ASSERT_EQ(1UL, durationProducer.mPastBuckets[DEFAULT_METRIC_DIMENSION_KEY].size()); in TEST()
580 DurationBucket bucket = durationProducer.mPastBuckets[DEFAULT_METRIC_DIMENSION_KEY][0]; in TEST()
584 EXPECT_EQ(1, durationProducer.getCurrentBucketNum()); in TEST()
609 DurationMetricProducer durationProducer( in TEST() local
615 durationProducer.onConditionChanged(true /* condition */, bucketStartTimeNs + 5); in TEST()
616 durationProducer.onMatchedLogEvent(1 /* start index*/, event1); in TEST()
617 durationProducer.onMatchedLogEvent(2 /* stop index*/, event2); in TEST()
618 durationProducer.onMatchedLogEvent(1 /* start index*/, event3); in TEST()
619 durationProducer.onConditionChanged(false /* condition */, bucketStartTimeNs + 200); in TEST()
620 durationProducer.flushIfNeededLocked(bucketStartTimeNs + bucketSizeNs + 1); in TEST()
621 durationProducer.onMatchedLogEvent(2 /* stop index*/, event4); in TEST()
623 ASSERT_TRUE(durationProducer.mCurrentSlicedDurationTrackerMap.empty()); in TEST()
624 EXPECT_EQ(1UL, durationProducer.mPastBuckets.size()); in TEST()
625 EXPECT_EQ(1, durationProducer.getCurrentBucketNum()); in TEST()