Home
last modified time | relevance | path

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

/frameworks/base/cmds/statsd/src/metrics/duration_helper/
DOringDurationTracker.cpp151 numBucketsForward = 1 + (eventTimeNs - fullBucketEnd) / mBucketSizeNs; in flushCurrentBucket()
180 info.mBucketStartNs = fullBucketEnd + mBucketSizeNs * (i - 1); in flushCurrentBucket()
181 info.mBucketEndNs = info.mBucketStartNs + mBucketSizeNs; in flushCurrentBucket()
182 info.mDuration = mBucketSizeNs; in flushCurrentBucket()
198 mCurrentBucketStartTimeNs = fullBucketEnd + (numBucketsForward - 1) * mBucketSizeNs; in flushCurrentBucket()
377 const int64_t bucketEndNs = currentBucketEndNs + futureBucketIdx * mBucketSizeNs; in predictAnomalyTimestampNs()
379 std::max(bucketEndNs - mBucketSizeNs + thresholdNs - pastNs, refractoryPeriodEndNs); in predictAnomalyTimestampNs()
389 pastNs += mBucketSizeNs; in predictAnomalyTimestampNs()
DDurationTracker.h72 mBucketSizeNs(bucketSizeNs), in DurationTracker()
121 return mStartTimeNs + (mCurrentBucketNum + 1) * mBucketSizeNs; in getCurrentBucketEndTimeNs()
167 return mStartTimeNs + (mCurrentBucketNum + 1) * mBucketSizeNs; in getCurrentBucketEndTimeNs()
181 const int64_t mBucketSizeNs; variable
DMaxDurationTracker.cpp198 numBucketsForward = 1 + (eventTimeNs - fullBucketEnd) / mBucketSizeNs; in flushCurrentBucket()
229 mCurrentBucketStartTimeNs = fullBucketEnd + (numBucketsForward - 1) * mBucketSizeNs; in flushCurrentBucket()
/frameworks/base/cmds/statsd/src/metrics/
DCountMetricProducer.cpp74 mBucketSizeNs = in CountMetricProducer()
77 mBucketSizeNs = LLONG_MAX; in CountMetricProducer()
110 (long long)mBucketSizeNs, (long long)mTimeBaseNs); in CountMetricProducer()
164 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_BUCKET_SIZE, (long long)mBucketSizeNs); in onDumpReportLocked()
220 if (bucket.mBucketEndNs - bucket.mBucketStartNs != mBucketSizeNs) { in onDumpReportLocked()
323 int64_t numBucketsForward = 1 + (eventTimeNs - currentBucketEndTimeNs) / mBucketSizeNs; in flushIfNeededLocked()
324 int64_t nextBucketNs = currentBucketEndTimeNs + (numBucketsForward - 1) * mBucketSizeNs; in flushIfNeededLocked()
DMetricProducer.h196 return mBucketSizeNs; in getBuckeSizeInNs()
201 mBucketSizeNs = bucketSize; in setBucketSize()
316 return mTimeBaseNs + (mCurrentBucketNum + 1) * mBucketSizeNs; in getCurrentBucketEndTimeNs()
320 return (endNs - mTimeBaseNs) / mBucketSizeNs - 1; in getBucketNumFromEndTimeNs()
341 int64_t mBucketSizeNs; variable
DDurationMetricProducer.cpp81 mBucketSizeNs = in DurationMetricProducer()
84 mBucketSizeNs = LLONG_MAX; in DurationMetricProducer()
136 (long long)mBucketSizeNs, (long long)mTimeBaseNs); in DurationMetricProducer()
147 if (alert.trigger_if_sum_gt() > alert.num_buckets() * mBucketSizeNs) { in addAnomalyTracker()
149 alert.trigger_if_sum_gt(), alert.num_buckets(), (long long)mBucketSizeNs); in addAnomalyTracker()
168 mTimeBaseNs, mBucketSizeNs, mConditionSliced, in createDurationTracker()
174 mTimeBaseNs, mBucketSizeNs, mConditionSliced, in createDurationTracker()
520 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_BUCKET_SIZE, (long long)mBucketSizeNs); in onDumpReportLocked()
575 if (bucket.mBucketEndNs - bucket.mBucketStartNs != mBucketSizeNs) { in onDumpReportLocked()
606 int numBucketsForward = 1 + (eventTimeNs - currentBucketEndTimeNs) / mBucketSizeNs; in flushIfNeededLocked()
[all …]
DGaugeMetricProducer.cpp106 mBucketSizeNs = bucketSizeMills * 1000000; in GaugeMetricProducer()
139 mBucketSizeNs); in GaugeMetricProducer()
146 (long long)metric.id(), (long long)mBucketSizeNs, (long long)mTimeBaseNs, in GaugeMetricProducer()
202 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_BUCKET_SIZE, (long long)mBucketSizeNs); in onDumpReportLocked()
268 if (bucket.mBucketEndNs - bucket.mBucketStartNs != mBucketSizeNs) { in onDumpReportLocked()
546 (long long)eventTimeNs, (long long)(mCurrentBucketStartTimeNs + mBucketSizeNs)); in flushIfNeededLocked()
551 int64_t numBucketsForward = 1 + (eventTimeNs - currentBucketEndTimeNs) / mBucketSizeNs; in flushIfNeededLocked()
552 int64_t nextBucketNs = currentBucketEndTimeNs + (numBucketsForward - 1) * mBucketSizeNs; in flushIfNeededLocked()
DValueMetricProducer.cpp121 mBucketSizeNs = bucketSizeMills * 1000000; in ValueMetricProducer()
155 mBucketSizeNs); in ValueMetricProducer()
164 (long long)mBucketSizeNs, (long long)mTimeBaseNs); in ValueMetricProducer()
237 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_BUCKET_SIZE, (long long)mBucketSizeNs); in onDumpReportLocked()
300 if (bucket.mBucketEndNs - bucket.mBucketStartNs != mBucketSizeNs) { in onDumpReportLocked()
474 return mTimeBaseNs + ((currentTimeNs - mTimeBaseNs) / mBucketSizeNs) * mBucketSizeNs; in calcPreviousBucketEndTime()
836 … int64_t nextBucketStartTimeNs = currentBucketEndTimeNs + (numBucketsForward - 1) * mBucketSizeNs; in flushIfNeededLocked()
845 return 1 + (eventTimeNs - currentBucketEndTimeNs) / mBucketSizeNs; in calcBucketsForwardCount()
DEventMetricProducer.cpp71 (long long)mBucketSizeNs, (long long)mTimeBaseNs); in EventMetricProducer()