Home
last modified time | relevance | path

Searched refs:mBucketSizeNs (Results 1 – 9 of 9) sorted by relevance

/packages/modules/StatsD/statsd/src/metrics/duration_helper/
DOringDurationTracker.cpp148 numBucketsForward = 1 + (eventTimeNs - fullBucketEnd) / mBucketSizeNs; in flushCurrentBucket()
194 info.mBucketStartNs = fullBucketEnd + mBucketSizeNs * (i - 1); in flushCurrentBucket()
195 info.mBucketEndNs = info.mBucketStartNs + mBucketSizeNs; in flushCurrentBucket()
196 info.mDuration = mBucketSizeNs; in flushCurrentBucket()
211 mCurrentBucketStartTimeNs = fullBucketEnd + (numBucketsForward - 1) * mBucketSizeNs; in flushCurrentBucket()
408 const int64_t bucketEndNs = currentBucketEndNs + futureBucketIdx * mBucketSizeNs; in predictAnomalyTimestampNs()
410 std::max(bucketEndNs - mBucketSizeNs + thresholdNs - pastNs, refractoryPeriodEndNs); in predictAnomalyTimestampNs()
420 pastNs += mBucketSizeNs; in predictAnomalyTimestampNs()
DDurationTracker.h81 mBucketSizeNs(bucketSizeNs), in DurationTracker()
158 return mStartTimeNs + (mCurrentBucketNum + 1) * mBucketSizeNs; in getCurrentBucketEndTimeNs()
205 return mStartTimeNs + (mCurrentBucketNum + 1) * mBucketSizeNs; in getCurrentBucketEndTimeNs()
248 const int64_t mBucketSizeNs; variable
DMaxDurationTracker.cpp174 numBucketsForward = 1 + (eventTimeNs - fullBucketEnd) / mBucketSizeNs; in flushCurrentBucket()
207 mCurrentBucketStartTimeNs = fullBucketEnd + (numBucketsForward - 1) * mBucketSizeNs; in flushCurrentBucket()
/packages/modules/StatsD/statsd/src/metrics/
DDurationMetricProducer.cpp88 mBucketSizeNs = in DurationMetricProducer()
91 mBucketSizeNs = LLONG_MAX; in DurationMetricProducer()
160 (long long)mBucketSizeNs, (long long)mTimeBaseNs); in DurationMetricProducer()
269 if (alert.trigger_if_sum_gt() > alert.num_buckets() * mBucketSizeNs) { in addAnomalyTracker()
271 alert.trigger_if_sum_gt(), alert.num_buckets(), (long long)mBucketSizeNs); in addAnomalyTracker()
334 mCurrentBucketStartTimeNs, mCurrentBucketNum, mTimeBaseNs, mBucketSizeNs, in createDurationTracker()
339 mCurrentBucketStartTimeNs, mCurrentBucketNum, mTimeBaseNs, mBucketSizeNs, in createDurationTracker()
508 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_BUCKET_SIZE, (long long)mBucketSizeNs); in onDumpReportLocked()
551 if (bucket.mBucketEndNs - bucket.mBucketStartNs != mBucketSizeNs) { in onDumpReportLocked()
582 int numBucketsForward = 1 + (eventTimeNs - currentBucketEndTimeNs) / mBucketSizeNs; in flushIfNeededLocked()
[all …]
DCountMetricProducer.cpp82 mBucketSizeNs = in CountMetricProducer()
85 mBucketSizeNs = LLONG_MAX; in CountMetricProducer()
123 (long long)mBucketSizeNs, (long long)mTimeBaseNs); in CountMetricProducer()
225 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_BUCKET_SIZE, (long long)mBucketSizeNs); in onDumpReportLocked()
268 if (bucket.mBucketEndNs - bucket.mBucketStartNs != mBucketSizeNs) { in onDumpReportLocked()
372 int64_t numBucketsForward = 1 + (eventTimeNs - currentBucketEndTimeNs) / mBucketSizeNs; in flushIfNeededLocked()
373 int64_t nextBucketNs = currentBucketEndTimeNs + (numBucketsForward - 1) * mBucketSizeNs; in flushIfNeededLocked()
DGaugeMetricProducer.cpp113 mBucketSizeNs = bucketSizeMills * 1000000;
141 mBucketSizeNs);
148 (long long)metric.id(), (long long)mBucketSizeNs, (long long)mTimeBaseNs,
261 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_BUCKET_SIZE, (long long)mBucketSizeNs); in onDumpReportLocked()
316 if (bucket.mBucketEndNs - bucket.mBucketStartNs != mBucketSizeNs) { in onDumpReportLocked()
601 (long long)eventTimeNs, (long long)(mCurrentBucketStartTimeNs + mBucketSizeNs)); in flushIfNeededLocked()
606 int64_t numBucketsForward = 1 + (eventTimeNs - currentBucketEndTimeNs) / mBucketSizeNs; in flushIfNeededLocked()
607 int64_t nextBucketNs = currentBucketEndTimeNs + (numBucketsForward - 1) * mBucketSizeNs; in flushIfNeededLocked()
DValueMetricProducer.cpp129 mBucketSizeNs = bucketSizeMills * 1000000; in ValueMetricProducer()
169 mBucketSizeNs); in ValueMetricProducer()
183 (long long)mBucketSizeNs, (long long)mTimeBaseNs); in ValueMetricProducer()
326 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_BUCKET_SIZE, (long long)mBucketSizeNs); in onDumpReportLocked()
387 if (bucket.mBucketEndNs - bucket.mBucketStartNs != mBucketSizeNs) { in onDumpReportLocked()
618 return mTimeBaseNs + ((currentTimeNs - mTimeBaseNs) / mBucketSizeNs) * mBucketSizeNs; in calcPreviousBucketEndTime()
1044 … int64_t nextBucketStartTimeNs = currentBucketEndTimeNs + (numBucketsForward - 1) * mBucketSizeNs; in flushIfNeededLocked()
1053 return 1 + (eventTimeNs - currentBucketEndTimeNs) / mBucketSizeNs; in calcBucketsForwardCount()
DMetricProducer.h331 return mBucketSizeNs; in getBucketSizeInNs()
442 return mTimeBaseNs + (mCurrentBucketNum + 1) * mBucketSizeNs; in getCurrentBucketEndTimeNs()
446 return (endNs - mTimeBaseNs) / mBucketSizeNs - 1; in getBucketNumFromEndTimeNs()
491 int64_t mBucketSizeNs; variable
DEventMetricProducer.cpp80 (long long)mBucketSizeNs, (long long)mTimeBaseNs); in EventMetricProducer()