Home
last modified time | relevance | path

Searched refs:numBucketsForward (Results 1 – 7 of 7) sorted by relevance

/packages/modules/StatsD/statsd/src/metrics/duration_helper/
DOringDurationTracker.cpp142 int numBucketsForward = 0; in flushCurrentBucket() local
148 numBucketsForward = 1 + (eventTimeNs - fullBucketEnd) / mBucketSizeNs; in flushCurrentBucket()
192 for (int i = 1; i < numBucketsForward; i++) { in flushCurrentBucket()
205 if (numBucketsForward >= 2) { in flushCurrentBucket()
206 addPastBucketToAnomalyTrackers(mEventKey, 0, mCurrentBucketNum + numBucketsForward - 1); in flushCurrentBucket()
210 if (numBucketsForward > 0) { in flushCurrentBucket()
211 mCurrentBucketStartTimeNs = fullBucketEnd + (numBucketsForward - 1) * mBucketSizeNs; in flushCurrentBucket()
212 mCurrentBucketNum += numBucketsForward; in flushCurrentBucket()
DMaxDurationTracker.cpp170 int numBucketsForward = 0; in flushCurrentBucket() local
174 numBucketsForward = 1 + (eventTimeNs - fullBucketEnd) / mBucketSizeNs; in flushCurrentBucket()
206 if (numBucketsForward > 0) { in flushCurrentBucket()
207 mCurrentBucketStartTimeNs = fullBucketEnd + (numBucketsForward - 1) * mBucketSizeNs; in flushCurrentBucket()
208 mCurrentBucketNum += numBucketsForward; in flushCurrentBucket()
/packages/modules/StatsD/statsd/src/metrics/
DValueMetricProducer.cpp162 int64_t numBucketsForward = calcBucketsForwardCount(startTimeNs); in ValueMetricProducer() local
163 mCurrentBucketNum += numBucketsForward; in ValueMetricProducer()
820 bool ValueMetricProducer::multipleBucketsSkipped(const int64_t numBucketsForward) { in multipleBucketsSkipped() argument
822 return numBucketsForward > 1 && (mIsPulled || mUseDiff); in multipleBucketsSkipped()
1043 int64_t numBucketsForward = calcBucketsForwardCount(eventTimeNs); in flushIfNeededLocked() local
1044 … int64_t nextBucketStartTimeNs = currentBucketEndTimeNs + (numBucketsForward - 1) * mBucketSizeNs; in flushIfNeededLocked()
1068 int64_t numBucketsForward = calcBucketsForwardCount(eventTimeNs); in flushCurrentBucketLocked() local
1070 if (multipleBucketsSkipped(numBucketsForward)) { in flushCurrentBucketLocked()
1071 VLOG("Skipping forward %lld buckets", (long long)numBucketsForward); in flushCurrentBucketLocked()
1143 mCurrentBucketNum += numBucketsForward; in flushCurrentBucketLocked()
DCountMetricProducer.cpp372 int64_t numBucketsForward = 1 + (eventTimeNs - currentBucketEndTimeNs) / mBucketSizeNs; in flushIfNeededLocked() local
373 int64_t nextBucketNs = currentBucketEndTimeNs + (numBucketsForward - 1) * mBucketSizeNs; in flushIfNeededLocked()
376 mCurrentBucketNum += numBucketsForward; in flushIfNeededLocked()
DGaugeMetricProducer.cpp606 int64_t numBucketsForward = 1 + (eventTimeNs - currentBucketEndTimeNs) / mBucketSizeNs; in flushIfNeededLocked() local
607 int64_t nextBucketNs = currentBucketEndTimeNs + (numBucketsForward - 1) * mBucketSizeNs; in flushIfNeededLocked()
610 mCurrentBucketNum += numBucketsForward; in flushIfNeededLocked()
DDurationMetricProducer.cpp582 int numBucketsForward = 1 + (eventTimeNs - currentBucketEndTimeNs) / mBucketSizeNs; in flushIfNeededLocked() local
583 int64_t nextBucketNs = currentBucketEndTimeNs + (numBucketsForward - 1) * mBucketSizeNs; in flushIfNeededLocked()
586 mCurrentBucketNum += numBucketsForward; in flushIfNeededLocked()
DValueMetricProducer.h265 bool multipleBucketsSkipped(const int64_t numBucketsForward);