Lines Matching refs:tracker
65 OringDurationTracker tracker(kConfigKey, metricId, eventKey, wizard, 1, false, in TEST() local
69 tracker.noteStart(kEventKey1, true, eventStartTimeNs, ConditionKey()); in TEST()
70 EXPECT_EQ((long long)eventStartTimeNs, tracker.mLastStartTime); in TEST()
71 tracker.noteStart(kEventKey1, true, eventStartTimeNs + 10, ConditionKey()); // overlapping wl in TEST()
72 EXPECT_EQ((long long)eventStartTimeNs, tracker.mLastStartTime); in TEST()
74 tracker.noteStop(kEventKey1, eventStartTimeNs + durationTimeNs, false); in TEST()
75 tracker.flushIfNeeded(eventStartTimeNs + bucketSizeNs + 1, emptyThreshold, &buckets); in TEST()
96 OringDurationTracker tracker(kConfigKey, metricId, eventKey, wizard, 1, true, bucketStartTimeNs, in TEST() local
99 tracker.noteStart(kEventKey1, true, eventStartTimeNs, ConditionKey()); in TEST()
100 tracker.noteStart(kEventKey1, true, eventStartTimeNs + 10, ConditionKey()); // overlapping wl in TEST()
102 tracker.noteStop(kEventKey1, eventStartTimeNs + 2000, false); in TEST()
103 tracker.noteStop(kEventKey1, eventStartTimeNs + 2003, false); in TEST()
105 tracker.flushIfNeeded(bucketStartTimeNs + bucketSizeNs + 1, emptyThreshold, &buckets); in TEST()
127 OringDurationTracker tracker(kConfigKey, metricId, eventKey, wizard, 1, true, bucketStartTimeNs, in TEST() local
130 tracker.noteStart(kEventKey1, true, eventStartTimeNs, ConditionKey()); in TEST()
131 tracker.noteStart(kEventKey2, true, eventStartTimeNs + 10, ConditionKey()); // overlapping wl in TEST()
133 tracker.noteStopAll(eventStartTimeNs + 2003); in TEST()
135 tracker.flushIfNeeded(bucketStartTimeNs + bucketSizeNs + 1, emptyThreshold, &buckets); in TEST()
156 OringDurationTracker tracker(kConfigKey, metricId, eventKey, wizard, 1, true, bucketStartTimeNs, in TEST() local
159 tracker.noteStart(kEventKey1, true, eventStartTimeNs, ConditionKey()); in TEST()
160 EXPECT_EQ((long long)eventStartTimeNs, tracker.mLastStartTime); in TEST()
161 tracker.flushIfNeeded(eventStartTimeNs + 2 * bucketSizeNs, emptyThreshold, &buckets); in TEST()
162 tracker.noteStart(kEventKey1, true, eventStartTimeNs + 2 * bucketSizeNs, ConditionKey()); in TEST()
163 EXPECT_EQ((long long)(bucketStartTimeNs + 2 * bucketSizeNs), tracker.mLastStartTime); in TEST()
169 tracker.noteStop(kEventKey1, eventStartTimeNs + 2 * bucketSizeNs + 10, false); in TEST()
170 tracker.noteStop(kEventKey1, eventStartTimeNs + 2 * bucketSizeNs + 12, false); in TEST()
171 tracker.flushIfNeeded(eventStartTimeNs + 2 * bucketSizeNs + 12, emptyThreshold, &buckets); in TEST()
199 OringDurationTracker tracker(kConfigKey, metricId, eventKey, wizard, 1, false, in TEST() local
203 tracker.noteStart(kEventKey1, true, eventStartTimeNs, key1); in TEST()
205 tracker.onSlicedConditionMayChange(true, eventStartTimeNs + 5); in TEST()
207 tracker.noteStop(kEventKey1, eventStartTimeNs + durationTimeNs, false); in TEST()
209 tracker.flushIfNeeded(bucketStartTimeNs + bucketSizeNs + 1, emptyThreshold, &buckets); in TEST()
238 OringDurationTracker tracker(kConfigKey, metricId, eventKey, wizard, 1, false, in TEST() local
242 tracker.noteStart(kEventKey1, true, eventStartTimeNs, key1); in TEST()
244 tracker.onSlicedConditionMayChange(true, eventStartTimeNs + 5); in TEST()
246 tracker.onSlicedConditionMayChange(true, eventStartTimeNs + 1000); in TEST()
248 tracker.noteStop(kEventKey1, eventStartTimeNs + durationTimeNs, false); in TEST()
250 tracker.flushIfNeeded(bucketStartTimeNs + bucketSizeNs + 1, emptyThreshold, &buckets); in TEST()
276 OringDurationTracker tracker(kConfigKey, metricId, eventKey, wizard, 1, true, bucketStartTimeNs, in TEST() local
279 tracker.noteStart(kEventKey1, true, eventStartTimeNs, key1); in TEST()
280 tracker.noteStart(kEventKey1, true, eventStartTimeNs + 2, key1); in TEST()
282 tracker.noteStop(kEventKey1, eventStartTimeNs + 3, false); in TEST()
284 tracker.onSlicedConditionMayChange(true, eventStartTimeNs + 15); in TEST()
286 tracker.noteStop(kEventKey1, eventStartTimeNs + 2003, false); in TEST()
288 tracker.flushIfNeeded(bucketStartTimeNs + bucketSizeNs + 1, emptyThreshold, &buckets); in TEST()
316 OringDurationTracker tracker(kConfigKey, metricId, eventKey, wizard, 1, true, bucketStartTimeNs, in TEST() local
321 tracker.noteStart(DEFAULT_DIMENSION_KEY, true, eventStartTimeNs, ConditionKey()); in TEST()
323 tracker.predictAnomalyTimestampNs(*anomalyTracker, eventStartTimeNs)); in TEST()
325 tracker.noteStop(DEFAULT_DIMENSION_KEY, eventStartTimeNs + 3, false); in TEST()
329 tracker.noteStart(kEventKey1, true, event1StartTimeNs, ConditionKey()); in TEST()
332 tracker.predictAnomalyTimestampNs(*anomalyTracker, event1StartTimeNs)); in TEST()
335 tracker.flushIfNeeded(event1StopTimeNs, emptyThreshold, &buckets); in TEST()
336 tracker.noteStop(kEventKey1, event1StopTimeNs, false); in TEST()
348 tracker.noteStart(kEventKey1, true, event2StartTimeNs, ConditionKey()); in TEST()
351 tracker.predictAnomalyTimestampNs(*anomalyTracker, event2StartTimeNs)); in TEST()
352 tracker.noteStop(kEventKey1, event2StartTimeNs + 1, false); in TEST()
357 tracker.noteStart(kEventKey1, true, event3StartTimeNs, ConditionKey()); in TEST()
359 tracker.predictAnomalyTimestampNs(*anomalyTracker, event3StartTimeNs)); in TEST()
377 OringDurationTracker tracker(kConfigKey, metricId, DEFAULT_METRIC_DIMENSION_KEY, wizard, 1, in TEST() local
383 tracker.noteStart(DEFAULT_DIMENSION_KEY, true, eventStartTimeNs, ConditionKey()); in TEST()
386 tracker.predictAnomalyTimestampNs(*anomalyTracker, eventStartTimeNs)); in TEST()
388 tracker.noteStop(DEFAULT_DIMENSION_KEY, bucketStartTimeNs + 14 * NS_PER_SEC, false); in TEST()
397 tracker.predictAnomalyTimestampNs(*anomalyTracker, event2StartTimeNs)); in TEST()
422 OringDurationTracker tracker(kConfigKey, metricId, DEFAULT_METRIC_DIMENSION_KEY, wizard, in TEST() local
427 tracker.noteStart(DEFAULT_DIMENSION_KEY, true, eventStartTimeNs, ConditionKey()); in TEST()
429 tracker.predictAnomalyTimestampNs(*anomalyTracker, eventStartTimeNs)); in TEST()
431 tracker.noteStop(DEFAULT_DIMENSION_KEY, eventStopTimeNs, false); in TEST()
440 tracker.noteStart(DEFAULT_DIMENSION_KEY, true, event2StartTimeNs, ConditionKey()); in TEST()
442 tracker.noteStop(DEFAULT_DIMENSION_KEY, event2StopTimeNs, false); in TEST()
448 tracker.predictAnomalyTimestampNs(*anomalyTracker, event3StartTimeNs); in TEST()
480 OringDurationTracker tracker(kConfigKey, metricId, eventKey, wizard, 1, true /*nesting*/, in TEST() local
484 tracker.noteStart(kEventKey1, true, eventStartTimeNs, ConditionKey()); in TEST()
485 tracker.noteStop(kEventKey1, eventStartTimeNs + 10, false); in TEST()
487 EXPECT_TRUE(tracker.mStarted.empty()); in TEST()
488 EXPECT_EQ(10LL, tracker.mStateKeyDurationMap[DEFAULT_DIMENSION_KEY].mDuration); // 10ns in TEST()
490 ASSERT_EQ(0u, tracker.mStarted.size()); in TEST()
492 tracker.noteStart(kEventKey1, true, eventStartTimeNs + 20, ConditionKey()); in TEST()
499 tracker.flushIfNeeded(eventStartTimeNs + 2 * bucketSizeNs + 25, emptyThreshold, &buckets); in TEST()
500 tracker.noteStop(kEventKey1, eventStartTimeNs + 2 * bucketSizeNs + 25, false); in TEST()
529 OringDurationTracker tracker(kConfigKey, metricId, eventKey, wizard, 1, true /*nesting*/, in TEST() local
533 tracker.noteStart(kEventKey1, true, 15 * NS_PER_SEC, conkey); // start key1 in TEST()
539 tracker.noteStop(kEventKey1, 17 * NS_PER_SEC, false); // stop key1 (2 seconds later) in TEST()
543 tracker.noteStart(kEventKey1, true, 22 * NS_PER_SEC, conkey); // start key1 again in TEST()
549 tracker.noteStart(kEventKey2, true, 32 * NS_PER_SEC, conkey); // start key2 in TEST()
555 tracker.noteStop(kEventKey1, 47 * NS_PER_SEC, false); // stop key1 in TEST()
567 tracker.noteStop(kEventKey2, 69 * NS_PER_SEC, false); // stop key2 in TEST()
587 OringDurationTracker tracker(kConfigKey, metricId, eventKey, wizard, 1, false, in TEST() local
592 tracker.noteStart(kEventKey1, true, eventStartTimeNs, ConditionKey()); in TEST()
593 tracker.noteStop(kEventKey1, eventStartTimeNs + thresholdDurationNs, false); in TEST()
594 tracker.flushIfNeeded(eventStartTimeNs + bucketSizeNs + 1, threshold, &buckets); in TEST()
598 tracker.noteStart(kEventKey1, true, event2StartTimeNs, ConditionKey()); in TEST()
599 tracker.noteStop(kEventKey1, event2StartTimeNs + thresholdDurationNs + 1, false); in TEST()
600 tracker.flushIfNeeded(event2StartTimeNs + bucketSizeNs + 1, threshold, &buckets); in TEST()