Home
last modified time | relevance | path

Searched refs:mCurrentBucketNum (Results 1 – 14 of 14) sorted by relevance

/packages/modules/StatsD/statsd/src/metrics/duration_helper/
DOringDurationTracker.cpp95 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()
DDurationTracker.h85 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
DMaxDurationTracker.cpp208 mCurrentBucketNum += numBucketsForward; in flushCurrentBucket()
/packages/modules/StatsD/statsd/src/metrics/
DCountMetricProducer.cpp355 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()
DMetricProducer.h341 return mCurrentBucketNum; in getCurrentBucketNum()
461 return mTimeBaseNs + (mCurrentBucketNum + 1) * mBucketSizeNs; in getCurrentBucketEndTimeNs()
508 int64_t mCurrentBucketNum; variable
DNumericValueMetricProducer.cpp499 tracker->detectAndDeclareAnomaly(eventTimeNs, mCurrentBucketNum, mMetricId, eventKey, in aggregateFields()
578 tracker->addPastBucket(metricDimensionKey, value, mCurrentBucketNum); in appendToFullBucket()
593 mCurrentBucketNum); in appendToFullBucket()
DGaugeMetricProducer.cpp563 tracker->detectAndDeclareAnomaly(eventTimeNs, mCurrentBucketNum, mMetricId, in onMatchedLogEventInternalLocked()
611 mCurrentBucketNum += numBucketsForward; in flushIfNeededLocked()
658 tracker->addPastBucket(mCurrentSlicedBucketForAnomaly, mCurrentBucketNum); in flushCurrentBucketLocked()
DDurationMetricProducer.cpp334 mCurrentBucketStartTimeNs, mCurrentBucketNum, mTimeBaseNs, mBucketSizeNs, in createDurationTracker()
339 mCurrentBucketStartTimeNs, mCurrentBucketNum, mTimeBaseNs, mBucketSizeNs, in createDurationTracker()
586 mCurrentBucketNum += numBucketsForward; in flushIfNeededLocked()
DValueMetricProducer.cpp128 mCurrentBucketNum = numBucketsForward; in ValueMetricProducer()
756 mCurrentBucketNum += calcBucketsForwardCount(eventTimeNs); in flushCurrentBucketLocked()
DMetricProducer.cpp63 mCurrentBucketNum(0), in MetricProducer()
/packages/modules/StatsD/statsd/tests/metrics/
DGaugeMetricProducer_test.cpp111 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()
DCountMetricProducer_test.cpp81 EXPECT_EQ(10, countProducer.mCurrentBucketNum); in TEST()
537 EXPECT_EQ(4, countProducer.mCurrentBucketNum); in TEST()
DDurationMetricProducer_test.cpp81 EXPECT_EQ(10, durationProducer.mCurrentBucketNum); in TEST()
DNumericValueMetricProducer_test.cpp326 EXPECT_EQ(10, valueProducer->mCurrentBucketNum); in TEST()