Home
last modified time | relevance | path

Searched refs:anomalyTracker (Results 1 – 20 of 20) sorted by relevance

/packages/modules/StatsD/statsd/tests/anomaly/
DAnomalyTracker_test.cpp132 AnomalyTracker anomalyTracker(alert, kConfigKey); in TEST() local
154 ASSERT_EQ(anomalyTracker.mSumOverPastBuckets.size(), 0u); in TEST()
155 EXPECT_EQ(anomalyTracker.mMostRecentBucketNum, -1LL); in TEST()
158 EXPECT_TRUE(detectAnomaliesPass(anomalyTracker, 0, bucket0, {}, {keyA, keyB, keyC})); in TEST()
159 detectAndDeclareAnomalies(anomalyTracker, 0, bucket0, eventTimestamp1); in TEST()
160 checkRefractoryTimes(anomalyTracker, eventTimestamp0, refractoryPeriodSec, in TEST()
164 anomalyTracker.addPastBucket(bucket0, 0); in TEST()
165 ASSERT_EQ(anomalyTracker.mSumOverPastBuckets.size(), 3u); in TEST()
166 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyA), 1LL); in TEST()
167 EXPECT_EQ(anomalyTracker.getSumOverPastBuckets(keyB), 2LL); in TEST()
[all …]
/packages/modules/StatsD/statsd/tests/e2e/
DAnomaly_duration_sum_e2e_test.cpp120 sp<AnomalyTracker> anomalyTracker = in TEST_F() local
135 anomalyTracker->getAlarmTimestampSec(dimensionKey1)); in TEST_F()
136 EXPECT_EQ(0u, anomalyTracker->getRefractoryPeriodEndsSec(dimensionKey1)); in TEST_F()
142 EXPECT_EQ(0u, anomalyTracker->getAlarmTimestampSec(dimensionKey1)); in TEST_F()
143 EXPECT_EQ(0u, anomalyTracker->getRefractoryPeriodEndsSec(dimensionKey1)); in TEST_F()
150 anomalyTracker->getAlarmTimestampSec(dimensionKey1)); in TEST_F()
151 EXPECT_EQ(0u, anomalyTracker->getRefractoryPeriodEndsSec(dimensionKey1)); in TEST_F()
157 EXPECT_EQ(0u, anomalyTracker->getAlarmTimestampSec(dimensionKey1)); in TEST_F()
159 anomalyTracker->getRefractoryPeriodEndsSec(dimensionKey1)); in TEST_F()
167 const int64_t alarmFiredTimestampSec0 = anomalyTracker->getAlarmTimestampSec(dimensionKey1); in TEST_F()
[all …]
DAnomaly_count_e2e_test.cpp72 sp<AnomalyTracker> anomalyTracker = in TEST() local
99 EXPECT_EQ(0u, anomalyTracker->getRefractoryPeriodEndsSec(dimensionKey1)); in TEST()
104 EXPECT_EQ(0u, anomalyTracker->getRefractoryPeriodEndsSec(dimensionKey2)); in TEST()
109 EXPECT_EQ(0u, anomalyTracker->getRefractoryPeriodEndsSec(dimensionKey1)); in TEST()
114 EXPECT_EQ(0u, anomalyTracker->getRefractoryPeriodEndsSec(dimensionKey2)); in TEST()
119 EXPECT_EQ(0u, anomalyTracker->getRefractoryPeriodEndsSec(dimensionKey1)); in TEST()
124 EXPECT_EQ(0u, anomalyTracker->getRefractoryPeriodEndsSec(dimensionKey2)); in TEST()
131 anomalyTracker->getRefractoryPeriodEndsSec(dimensionKey1)); in TEST()
137 anomalyTracker->getRefractoryPeriodEndsSec(dimensionKey1)); in TEST()
143 anomalyTracker->getRefractoryPeriodEndsSec(dimensionKey1)); in TEST()
[all …]
/packages/modules/StatsD/statsd/src/metrics/duration_helper/
DDurationTracker.h131 virtual int64_t predictAnomalyTimestampNs(const AnomalyTracker& anomalyTracker,
145 void addAnomalyTracker(sp<AnomalyTracker>& anomalyTracker, const UpdateStatus& updateStatus, in addAnomalyTracker() argument
147 mAnomalyTrackers.push_back(anomalyTracker); in addAnomalyTracker()
155 const int64_t alarmTimeNs = predictAnomalyTimestampNs(*anomalyTracker, updateTimeNs); in addAnomalyTracker()
157 anomalyTracker->startAlarm(mEventKey, std::max(alarmTimeNs, updateTimeNs)); in addAnomalyTracker()
173 for (auto& anomalyTracker : mAnomalyTrackers) { in startAnomalyAlarm()
174 if (anomalyTracker != nullptr) { in startAnomalyAlarm()
176 predictAnomalyTimestampNs(*anomalyTracker, eventTime); in startAnomalyAlarm()
178 anomalyTracker->startAlarm(mEventKey, alarmTimestampNs); in startAnomalyAlarm()
186 for (auto& anomalyTracker : mAnomalyTrackers) { in stopAnomalyAlarm()
[all …]
DOringDurationTracker.cpp378 int64_t OringDurationTracker::predictAnomalyTimestampNs(const AnomalyTracker& anomalyTracker, in predictAnomalyTimestampNs() argument
381 const int64_t thresholdNs = anomalyTracker.getAnomalyThreshold(); in predictAnomalyTimestampNs()
392 int64_t pastNs = currentStateBucketPastNs + anomalyTracker.getSumOverPastBuckets(mEventKey); in predictAnomalyTimestampNs()
396 anomalyTracker.getRefractoryPeriodEndsSec(mEventKey) * NS_PER_SEC; in predictAnomalyTimestampNs()
408 if (anomalyTracker.getNumOfPastBuckets() > 0) { in predictAnomalyTimestampNs()
409 pastNs -= anomalyTracker.getPastBucketValue( in predictAnomalyTimestampNs()
411 mCurrentBucketNum - anomalyTracker.getNumOfPastBuckets()); in predictAnomalyTimestampNs()
421 for (int futureBucketIdx = 1; futureBucketIdx <= anomalyTracker.getNumOfPastBuckets() + 1; in predictAnomalyTimestampNs()
434 if (anomalyTracker.getNumOfPastBuckets() <= 0) { in predictAnomalyTimestampNs()
446 if (futureBucketIdx < anomalyTracker.getNumOfPastBuckets()) { in predictAnomalyTimestampNs()
[all …]
DMaxDurationTracker.cpp310 int64_t MaxDurationTracker::predictAnomalyTimestampNs(const AnomalyTracker& anomalyTracker, in predictAnomalyTimestampNs() argument
324 int64_t anomalyTimeNs = currentTimestamp + anomalyTracker.getAnomalyThreshold() - maxElapsed; in predictAnomalyTimestampNs()
325 int64_t refractoryEndNs = anomalyTracker.getRefractoryPeriodEndsSec(mEventKey) * NS_PER_SEC; in predictAnomalyTimestampNs()
DMaxDurationTracker.h58 int64_t predictAnomalyTimestampNs(const AnomalyTracker& anomalyTracker,
DOringDurationTracker.h56 int64_t predictAnomalyTimestampNs(const AnomalyTracker& anomalyTracker,
/packages/modules/StatsD/statsd/tests/metrics/
DOringDurationTracker_test.cpp326 sp<DurationAnomalyTracker> anomalyTracker = in TEST() local
330 {anomalyTracker}); in TEST()
336 tracker.predictAnomalyTimestampNs(*anomalyTracker, eventStartTimeNs)); in TEST()
346 tracker.predictAnomalyTimestampNs(*anomalyTracker, event1StartTimeNs)); in TEST()
366 tracker.predictAnomalyTimestampNs(*anomalyTracker, event2StartTimeNs)); in TEST()
375 tracker.predictAnomalyTimestampNs(*anomalyTracker, event3StartTimeNs)); in TEST()
391 sp<DurationAnomalyTracker> anomalyTracker = in TEST() local
396 bucketSizeNs, true, false, {anomalyTracker}); in TEST()
403 tracker.predictAnomalyTimestampNs(*anomalyTracker, eventStartTimeNs)); in TEST()
408 anomalyTracker->getRefractoryPeriodEndsSec(DEFAULT_METRIC_DIMENSION_KEY)); in TEST()
[all …]
DMaxDurationTracker_test.cpp274 sp<DurationAnomalyTracker> anomalyTracker = in TEST() local
278 {anomalyTracker}); in TEST()
282 sp<const InternalAlarm> alarm = anomalyTracker->mAlarms.begin()->second; in TEST()
287 ASSERT_EQ(0U, anomalyTracker->mAlarms.size()); in TEST()
291 ASSERT_EQ(1U, anomalyTracker->mAlarms.size()); in TEST()
292 alarm = anomalyTracker->mAlarms.begin()->second; in TEST()
334 sp<DurationAnomalyTracker> anomalyTracker = in TEST() local
338 {anomalyTracker}); in TEST()
347 ASSERT_EQ(1U, anomalyTracker->mAlarms.size()); in TEST()
348 auto alarm = anomalyTracker->mAlarms.begin()->second; in TEST()
[all …]
DCountMetricProducer_test.cpp280 sp<AnomalyTracker> anomalyTracker = in TEST_P() local
282 EXPECT_TRUE(anomalyTracker != nullptr); in TEST_P()
289 EXPECT_EQ(0, anomalyTracker->getSumOverPastBuckets(DEFAULT_METRIC_DIMENSION_KEY)); in TEST_P()
309 EXPECT_EQ(0, anomalyTracker->getSumOverPastBuckets(DEFAULT_METRIC_DIMENSION_KEY)); in TEST_P()
319 EXPECT_EQ(0, anomalyTracker->getSumOverPastBuckets(DEFAULT_METRIC_DIMENSION_KEY)); in TEST_P()
328 EXPECT_EQ(2, anomalyTracker->getSumOverPastBuckets(DEFAULT_METRIC_DIMENSION_KEY)); in TEST_P()
411 sp<AnomalyTracker> anomalyTracker = in TEST() local
413 EXPECT_TRUE(anomalyTracker != nullptr); in TEST()
419 EXPECT_EQ(0, anomalyTracker->getSumOverPastBuckets(DEFAULT_METRIC_DIMENSION_KEY)); in TEST()
429 EXPECT_EQ(0, anomalyTracker->getSumOverPastBuckets(DEFAULT_METRIC_DIMENSION_KEY)); in TEST()
[all …]
DGaugeMetricProducer_test.cpp242 sp<AnomalyTracker> anomalyTracker = in TEST_P() local
244 EXPECT_TRUE(anomalyTracker != nullptr); in TEST_P()
268 EXPECT_EQ(0, anomalyTracker->getSumOverPastBuckets(DEFAULT_METRIC_DIMENSION_KEY)); in TEST_P()
282 EXPECT_EQ(0, anomalyTracker->getSumOverPastBuckets(DEFAULT_METRIC_DIMENSION_KEY)); in TEST_P()
292 EXPECT_EQ(1, anomalyTracker->getSumOverPastBuckets(DEFAULT_METRIC_DIMENSION_KEY)); in TEST_P()
300 EXPECT_EQ(2, anomalyTracker->getSumOverPastBuckets(DEFAULT_METRIC_DIMENSION_KEY)); in TEST_P()
610 sp<AnomalyTracker> anomalyTracker = in TEST() local
623 EXPECT_EQ(anomalyTracker->getRefractoryPeriodEndsSec(DEFAULT_METRIC_DIMENSION_KEY), 0U); in TEST()
637 EXPECT_EQ(anomalyTracker->getRefractoryPeriodEndsSec(DEFAULT_METRIC_DIMENSION_KEY), in TEST()
650 EXPECT_EQ(anomalyTracker->getRefractoryPeriodEndsSec(DEFAULT_METRIC_DIMENSION_KEY), in TEST()
DDurationMetricProducer_test.cpp393 sp<AnomalyTracker> anomalyTracker = in TEST_P() local
395 EXPECT_TRUE(anomalyTracker != nullptr); in TEST_P()
419 anomalyTracker->getSumOverPastBuckets(DEFAULT_METRIC_DIMENSION_KEY)); in TEST_P()
DNumericValueMetricProducer_test.cpp998 sp<AnomalyTracker> anomalyTracker = in TEST() local
1027 EXPECT_EQ(anomalyTracker->getRefractoryPeriodEndsSec(DEFAULT_METRIC_DIMENSION_KEY), 0U); in TEST()
1032 EXPECT_EQ(anomalyTracker->getRefractoryPeriodEndsSec(DEFAULT_METRIC_DIMENSION_KEY), 0U); in TEST()
1037 EXPECT_EQ(anomalyTracker->getRefractoryPeriodEndsSec(DEFAULT_METRIC_DIMENSION_KEY), in TEST()
1041 EXPECT_EQ(anomalyTracker->getRefractoryPeriodEndsSec(DEFAULT_METRIC_DIMENSION_KEY), in TEST()
1046 EXPECT_EQ(anomalyTracker->getRefractoryPeriodEndsSec(DEFAULT_METRIC_DIMENSION_KEY), in TEST()
1082 sp<AnomalyTracker> anomalyTracker = in TEST() local
1091 EXPECT_EQ(anomalyTracker->getRefractoryPeriodEndsSec(DEFAULT_METRIC_DIMENSION_KEY), 0U); in TEST()
2690 sp<AnomalyTracker> anomalyTracker = in TEST_P() local
/packages/modules/StatsD/statsd/src/metrics/
DDurationMetricProducer.cpp295 sp<AnomalyTracker> anomalyTracker = in addAnomalyTracker() local
298 addAnomalyTrackerLocked(anomalyTracker, updateStatus, updateTimeNs); in addAnomalyTracker()
299 return anomalyTracker; in addAnomalyTracker()
305 void DurationMetricProducer::addAnomalyTracker(sp<AnomalyTracker>& anomalyTracker, in addAnomalyTracker() argument
308 addAnomalyTrackerLocked(anomalyTracker, UpdateStatus::UPDATE_PRESERVE, updateTimeNs); in addAnomalyTracker()
311 void DurationMetricProducer::addAnomalyTrackerLocked(sp<AnomalyTracker>& anomalyTracker, in addAnomalyTrackerLocked() argument
314 mAnomalyTrackers.push_back(anomalyTracker); in addAnomalyTrackerLocked()
316 durationTracker->addAnomalyTracker(anomalyTracker, updateStatus, updateTimeNs); in addAnomalyTrackerLocked()
DMetricProducer.h370 sp<AnomalyTracker> anomalyTracker = new AnomalyTracker(alert, mConfigKey); in addAnomalyTracker() local
371 mAnomalyTrackers.push_back(anomalyTracker); in addAnomalyTracker()
372 return anomalyTracker; in addAnomalyTracker()
376 virtual void addAnomalyTracker(sp<AnomalyTracker>& anomalyTracker, int64_t updateTimeNs) { in addAnomalyTracker() argument
378 mAnomalyTrackers.push_back(anomalyTracker); in addAnomalyTracker()
DDurationMetricProducer.h60 void addAnomalyTracker(sp<AnomalyTracker>& anomalyTracker, int64_t updateTimeNs) override;
139 void addAnomalyTrackerLocked(sp<AnomalyTracker>& anomalyTracker,
DMetricsManager.cpp864 for (const auto& anomalyTracker : mAllAnomalyTrackers) { in writeMetadataToProto() local
866 bool alertWritten = anomalyTracker->writeAlertMetadataToProto( in writeMetadataToProto()
/packages/modules/StatsD/statsd/src/metrics/parsing_utils/
Dconfig_update_utils.cpp1155 sp<AnomalyTracker> anomalyTracker = oldAnomalyTrackers[oldAnomalyTrackerIt->second]; in updateAlerts() local
1156 anomalyTracker->onConfigUpdated(); in updateAlerts()
1166 allMetricProducers[metricProducerIt->second]->addAnomalyTracker(anomalyTracker, in updateAlerts()
1168 newAnomalyTrackers.push_back(anomalyTracker); in updateAlerts()
1173 optional<sp<AnomalyTracker>> anomalyTracker = createAnomalyTracker( in updateAlerts() local
1176 if (!anomalyTracker) { in updateAlerts()
1179 newAnomalyTrackers.push_back(anomalyTracker.value()); in updateAlerts()
Dmetrics_manager_util.cpp1428 sp<AnomalyTracker> anomalyTracker = in createAnomalyTracker() local
1430 if (anomalyTracker == nullptr) { in createAnomalyTracker()
1436 return {anomalyTracker}; in createAnomalyTracker()
1768 optional<sp<AnomalyTracker>> anomalyTracker = createAnomalyTracker( in initAlerts() local
1771 if (!anomalyTracker) { in initAlerts()
1774 allAnomalyTrackers.push_back(anomalyTracker.value()); in initAlerts()