/packages/modules/StatsD/statsd/src/metrics/duration_helper/ |
D | OringDurationTracker.cpp | 95 timestamp, mCurrentBucketNum, in noteStop() 124 timestamp, mCurrentBucketNum, in noteStopAll() 185 getCurrentStateKeyFullBucketDuration(), mCurrentBucketNum); in flushCurrentBucket() 201 addPastBucketToAnomalyTrackers(mEventKey, info.mDuration, mCurrentBucketNum + i); in flushCurrentBucket() 206 addPastBucketToAnomalyTrackers(mEventKey, 0, mCurrentBucketNum + numBucketsForward - 1); in flushCurrentBucket() 212 mCurrentBucketNum += numBucketsForward; in flushCurrentBucket() 267 timestamp, mCurrentBucketNum, in onSlicedConditionMayChange() 329 timestamp, mCurrentBucketNum, in onConditionChanged() 391 mCurrentBucketNum - anomalyTracker.getNumOfPastBuckets()); in predictAnomalyTimestampNs() 429 mCurrentBucketNum - anomalyTracker.getNumOfPastBuckets() + futureBucketIdx); in predictAnomalyTimestampNs()
|
D | DurationTracker.h | 85 mCurrentBucketNum(currentBucketNum), in DurationTracker() 158 return mStartTimeNs + (mCurrentBucketNum + 1) * mBucketSizeNs; in getCurrentBucketEndTimeNs() 205 return mStartTimeNs + (mCurrentBucketNum + 1) * mBucketSizeNs; in getCurrentBucketEndTimeNs() 259 int64_t mCurrentBucketNum; variable
|
D | MaxDurationTracker.cpp | 208 mCurrentBucketNum += numBucketsForward; in flushCurrentBucket()
|
/packages/modules/StatsD/statsd/src/metrics/ |
D | CountMetricProducer.cpp | 355 tracker->detectAndDeclareAnomaly(eventTimeNs, mCurrentBucketNum, mMetricId, eventKey, in onMatchedLogEventInternalLocked() 376 mCurrentBucketNum += numBucketsForward; in flushIfNeededLocked() 431 tracker->addPastBucket(mCurrentFullCounters, mCurrentBucketNum); in flushCurrentBucketLocked() 437 tracker->addPastBucket(mCurrentSlicedCounter, mCurrentBucketNum); in flushCurrentBucketLocked()
|
D | MetricProducer.h | 341 return mCurrentBucketNum; in getCurrentBucketNum() 461 return mTimeBaseNs + (mCurrentBucketNum + 1) * mBucketSizeNs; in getCurrentBucketEndTimeNs() 508 int64_t mCurrentBucketNum; variable
|
D | NumericValueMetricProducer.cpp | 499 tracker->detectAndDeclareAnomaly(eventTimeNs, mCurrentBucketNum, mMetricId, eventKey, in aggregateFields() 578 tracker->addPastBucket(metricDimensionKey, value, mCurrentBucketNum); in appendToFullBucket() 593 mCurrentBucketNum); in appendToFullBucket()
|
D | GaugeMetricProducer.cpp | 563 tracker->detectAndDeclareAnomaly(eventTimeNs, mCurrentBucketNum, mMetricId, in onMatchedLogEventInternalLocked() 611 mCurrentBucketNum += numBucketsForward; in flushIfNeededLocked() 658 tracker->addPastBucket(mCurrentSlicedBucketForAnomaly, mCurrentBucketNum); in flushCurrentBucketLocked()
|
D | DurationMetricProducer.cpp | 334 mCurrentBucketStartTimeNs, mCurrentBucketNum, mTimeBaseNs, mBucketSizeNs, in createDurationTracker() 339 mCurrentBucketStartTimeNs, mCurrentBucketNum, mTimeBaseNs, mBucketSizeNs, in createDurationTracker() 586 mCurrentBucketNum += numBucketsForward; in flushIfNeededLocked()
|
D | ValueMetricProducer.cpp | 128 mCurrentBucketNum = numBucketsForward; in ValueMetricProducer() 756 mCurrentBucketNum += calcBucketsForwardCount(eventTimeNs); in flushCurrentBucketLocked()
|
D | MetricProducer.cpp | 63 mCurrentBucketNum(0), in MetricProducer()
|
/packages/modules/StatsD/statsd/tests/metrics/ |
D | GaugeMetricProducer_test.cpp | 111 EXPECT_EQ(10, gaugeProducer.mCurrentBucketNum); in TEST() 260 EXPECT_EQ(0L, gaugeProducer.mCurrentBucketNum); in TEST_P() 269 EXPECT_EQ(0L, gaugeProducer.mCurrentBucketNum); in TEST_P() 284 EXPECT_EQ(1L, gaugeProducer.mCurrentBucketNum); in TEST_P() 293 EXPECT_EQ(2L, gaugeProducer.mCurrentBucketNum); in TEST_P() 354 EXPECT_EQ(0L, gaugeProducer.mCurrentBucketNum); in TEST_P() 411 EXPECT_EQ(0L, gaugeProducer.mCurrentBucketNum); in TEST()
|
D | CountMetricProducer_test.cpp | 81 EXPECT_EQ(10, countProducer.mCurrentBucketNum); in TEST() 537 EXPECT_EQ(4, countProducer.mCurrentBucketNum); in TEST()
|
D | DurationMetricProducer_test.cpp | 81 EXPECT_EQ(10, durationProducer.mCurrentBucketNum); in TEST()
|
D | NumericValueMetricProducer_test.cpp | 326 EXPECT_EQ(10, valueProducer->mCurrentBucketNum); in TEST()
|