| /packages/modules/StatsD/statsd/src/metrics/duration_helper/ |
| D | OringDurationTracker.cpp | 104 timestamp, mCurrentBucketNum, in noteStop()
133 timestamp, mCurrentBucketNum, in noteStopAll()
196 getCurrentStateKeyFullBucketDuration(), mCurrentBucketNum); in flushCurrentBucket()
215 addPastBucketToAnomalyTrackers(mEventKey, info.mDuration, mCurrentBucketNum + i); in flushCurrentBucket()
220 addPastBucketToAnomalyTrackers(mEventKey, 0, mCurrentBucketNum + numBucketsForward - 1); in flushCurrentBucket()
226 mCurrentBucketNum += numBucketsForward; in flushCurrentBucket()
282 timestamp, mCurrentBucketNum, in onSlicedConditionMayChange()
344 timestamp, mCurrentBucketNum, in onConditionChanged()
411 mCurrentBucketNum - anomalyTracker.getNumOfPastBuckets()); in predictAnomalyTimestampNs()
449 mCurrentBucketNum - anomalyTracker.getNumOfPastBuckets() + futureBucketIdx); in predictAnomalyTimestampNs()
|
| D | DurationTracker.h | 89 mCurrentBucketNum(currentBucketNum), in DurationTracker()
168 return mStartTimeNs + (mCurrentBucketNum + 1) * mBucketSizeNs; in getCurrentBucketEndTimeNs()
261 int64_t mCurrentBucketNum; variable
|
| D | MaxDurationTracker.cpp | 223 mCurrentBucketNum += numBucketsForward; in flushCurrentBucket()
|
| /packages/modules/StatsD/statsd/src/metrics/ |
| D | CountMetricProducer.cpp | 400 tracker->detectAndDeclareAnomaly(eventTimeNs, mCurrentBucketNum, mMetricId, eventKey, in onMatchedLogEventInternalLocked()
421 mCurrentBucketNum += numBucketsForward; in flushIfNeededLocked()
484 tracker->addPastBucket(mCurrentFullCounters, mCurrentBucketNum); in flushCurrentBucketLocked()
490 tracker->addPastBucket(mCurrentSlicedCounter, mCurrentBucketNum); in flushCurrentBucketLocked()
|
| D | NumericValueMetricProducer.cpp | 516 tracker->detectAndDeclareAnomaly(eventTimeNs, mCurrentBucketNum, mMetricId, eventKey, in aggregateFields()
598 tracker->addPastBucket(metricDimensionKey, value, mCurrentBucketNum); in appendToFullBucket()
613 mCurrentBucketNum); in appendToFullBucket()
|
| D | MetricProducer.h | 352 return mCurrentBucketNum; in getCurrentBucketNum()
482 return mTimeBaseNs + (mCurrentBucketNum + 1) * mBucketSizeNs; in getCurrentBucketEndTimeNs()
530 int64_t mCurrentBucketNum; variable
|
| D | GaugeMetricProducer.cpp | 605 tracker->detectAndDeclareAnomaly(eventTimeNs, mCurrentBucketNum, mMetricId, in onMatchedLogEventInternalLocked()
654 mCurrentBucketNum += numBucketsForward; in flushIfNeededLocked()
706 tracker->addPastBucket(mCurrentSlicedBucketForAnomaly, mCurrentBucketNum); in flushCurrentBucketLocked()
|
| D | DurationMetricProducer.cpp | 355 mCurrentBucketStartTimeNs, mCurrentBucketNum, mTimeBaseNs, mBucketSizeNs, in createDurationTracker()
360 mCurrentBucketStartTimeNs, mCurrentBucketNum, mTimeBaseNs, mBucketSizeNs, in createDurationTracker()
623 mCurrentBucketNum += numBucketsForward; in flushIfNeededLocked()
|
| D | ValueMetricProducer.cpp | 130 mCurrentBucketNum = numBucketsForward; in ValueMetricProducer()
801 mCurrentBucketNum += calcBucketsForwardCount(eventTimeNs); in flushCurrentBucketLocked()
|
| D | MetricProducer.cpp | 63 mCurrentBucketNum(0), in MetricProducer()
|
| /packages/modules/StatsD/statsd/tests/metrics/ |
| D | GaugeMetricProducer_test.cpp | 112 EXPECT_EQ(10, gaugeProducer.mCurrentBucketNum); in TEST()
265 EXPECT_EQ(0L, gaugeProducer.mCurrentBucketNum); in TEST_P()
274 EXPECT_EQ(0L, gaugeProducer.mCurrentBucketNum); in TEST_P()
289 EXPECT_EQ(1L, gaugeProducer.mCurrentBucketNum); in TEST_P()
298 EXPECT_EQ(2L, gaugeProducer.mCurrentBucketNum); in TEST_P()
361 EXPECT_EQ(0L, gaugeProducer.mCurrentBucketNum); in TEST_P()
421 EXPECT_EQ(0L, gaugeProducer.mCurrentBucketNum); in TEST()
|
| D | CountMetricProducer_test.cpp | 83 EXPECT_EQ(10, countProducer.mCurrentBucketNum); in TEST()
548 EXPECT_EQ(4, countProducer.mCurrentBucketNum); in TEST()
|
| D | DurationMetricProducer_test.cpp | 82 EXPECT_EQ(10, durationProducer.mCurrentBucketNum); in TEST()
|
| D | NumericValueMetricProducer_test.cpp | 291 EXPECT_EQ(10, valueProducer->mCurrentBucketNum); in TEST()
|