/packages/modules/StatsD/statsd/src/metrics/ |
D | ValueMetricProducer.cpp | 144 mCurrentBucketStartTimeNs = bucketOptions.startTimeNs; in ValueMetricProducer() 145 mConditionTimer.newBucketStart(mCurrentBucketStartTimeNs, mCurrentBucketStartTimeNs); in ValueMetricProducer() 149 mCurrentBucketStartTimeNs); in ValueMetricProducer() 283 (long long)mCurrentBucketStartTimeNs); in onStateChanged() 576 (long long)mCurrentBucketStartTimeNs); in onConditionChangedLocked() 712 (long long)mCurrentBucketStartTimeNs); in onMatchedLogEventInternalLocked() 802 VLOG("finalizing bucket for %ld, dumping %d slices", (long)mCurrentBucketStartTimeNs, in flushCurrentBucketLocked() 845 bool isBucketLargeEnough = bucketEndTimeNs - mCurrentBucketStartTimeNs >= mMinBucketSizeNs; in closeCurrentBucket() 881 mCurrentSkippedBucket.bucketStartTimeNs = mCurrentBucketStartTimeNs; in closeCurrentBucket() 941 mCurrentBucketStartTimeNs = nextBucketStartTimeNs; in initNextSlicedBucket() [all …]
|
D | GaugeMetricProducer.cpp | 159 mCurrentBucketStartTimeNs = startTimeNs; in GaugeMetricProducer() 232 pullAndMatchEventsLocked(mCurrentBucketStartTimeNs); in onConfigUpdatedLocked() 422 pullAndMatchEventsLocked(mCurrentBucketStartTimeNs); in prepareFirstBucketLocked() 595 if (eventTimeNs < mCurrentBucketStartTimeNs) { in onMatchedLogEventInternalLocked() 597 (long long)mCurrentBucketStartTimeNs); in onMatchedLogEventInternalLocked() 679 (long long)eventTimeNs, (long long)(mCurrentBucketStartTimeNs + mBucketSizeNs)); in flushIfNeededLocked() 690 (long long)mCurrentBucketStartTimeNs); in flushIfNeededLocked() 699 info.mBucketStartNs = mCurrentBucketStartTimeNs; in flushCurrentBucketLocked() 704 bool isBucketLargeEnough = info.mBucketEndNs - mCurrentBucketStartTimeNs >= mMinBucketSizeNs; in flushCurrentBucketLocked() 723 mCurrentSkippedBucket.bucketStartTimeNs = mCurrentBucketStartTimeNs; in flushCurrentBucketLocked() [all …]
|
D | CountMetricProducer.cpp | 128 mCurrentBucketStartTimeNs = startTimeNs; in CountMetricProducer() 129 mConditionTimer.newBucketStart(mCurrentBucketStartTimeNs, mCurrentBucketStartTimeNs); in CountMetricProducer() 131 mCurrentBucketStartTimeNs); in CountMetricProducer() 437 (long long)mCurrentBucketStartTimeNs); in flushIfNeededLocked() 464 info.mBucketStartNs = mCurrentBucketStartTimeNs; in flushCurrentBucketLocked() 519 mCurrentBucketStartTimeNs = nextBucketStartTimeNs; in flushCurrentBucketLocked()
|
D | DurationMetricProducer.cpp | 168 mCurrentBucketStartTimeNs = startTimeNs; in DurationMetricProducer() 173 mConditionTimer.newBucketStart(mCurrentBucketStartTimeNs, mCurrentBucketStartTimeNs); in DurationMetricProducer() 175 mCurrentBucketStartTimeNs); in DurationMetricProducer() 356 mCurrentBucketStartTimeNs, mCurrentBucketNum, mTimeBaseNs, mBucketSizeNs, in createDurationTracker() 361 mCurrentBucketStartTimeNs, mCurrentBucketNum, mTimeBaseNs, mBucketSizeNs, in createDurationTracker() 658 mCurrentBucketStartTimeNs = nextBucketStartTimeNs; in flushCurrentBucketLocked()
|
D | NumericValueMetricProducer.cpp | 187 pullAndMatchEventsLocked(mCurrentBucketStartTimeNs); in prepareFirstBucketLocked() 268 (long long)eventElapsedTimeNs, (long long)mCurrentBucketStartTimeNs); in accumulateEvents() 627 bucket.mBucketStartNs = mCurrentBucketStartTimeNs; in buildPartialBucket()
|
D | KllMetricProducer.cpp | 143 bucket.mBucketStartNs = mCurrentBucketStartTimeNs; in buildPartialBucket()
|
D | ValueMetricProducer.h | 370 return eventTimeNs < mCurrentBucketStartTimeNs; in isEventLateLocked()
|
D | MetricProducer.cpp | 62 mCurrentBucketStartTimeNs(timeBaseNs), in MetricProducer()
|
D | MetricProducer.h | 539 int64_t mCurrentBucketStartTimeNs; variable
|
/packages/modules/StatsD/statsd/tests/metrics/ |
D | DurationMetricProducer_test.cpp | 89 EXPECT_EQ(600500000000, durationProducer.mCurrentBucketStartTimeNs); in TEST() 275 EXPECT_EQ(bucketStartTimeNs, durationProducer.mCurrentBucketStartTimeNs); in TEST_P() 292 EXPECT_EQ(partialBucketSplitTimeNs, durationProducer.mCurrentBucketStartTimeNs); in TEST_P() 340 EXPECT_EQ(bucketStartTimeNs, durationProducer.mCurrentBucketStartTimeNs); in TEST_P() 360 EXPECT_EQ(partialBucketSplitTimeNs, durationProducer.mCurrentBucketStartTimeNs); in TEST_P() 455 EXPECT_EQ(bucketStartTimeNs, durationProducer.mCurrentBucketStartTimeNs); in TEST_P() 467 EXPECT_EQ(partialBucketSplitTimeNs, durationProducer.mCurrentBucketStartTimeNs); in TEST_P() 511 EXPECT_EQ(bucketStartTimeNs, durationProducer.mCurrentBucketStartTimeNs); in TEST_P() 523 EXPECT_EQ(partialBucketSplitTimeNs, durationProducer.mCurrentBucketStartTimeNs); in TEST_P() 532 EXPECT_EQ(partialBucketSplitTimeNs, durationProducer.mCurrentBucketStartTimeNs); in TEST_P() [all …]
|
D | CountMetricProducer_test.cpp | 89 EXPECT_EQ(600500000000, countProducer.mCurrentBucketStartTimeNs); in TEST() 314 EXPECT_EQ(eventTimeNs, countProducer.mCurrentBucketStartTimeNs); in TEST_P() 324 EXPECT_EQ(eventTimeNs, countProducer.mCurrentBucketStartTimeNs); in TEST_P() 333 EXPECT_EQ(lastEndTimeNs, countProducer.mCurrentBucketStartTimeNs); in TEST_P() 378 EXPECT_EQ(eventTimeNs, countProducer.mCurrentBucketStartTimeNs); in TEST_P() 434 EXPECT_EQ(bucketStartTimeNs, countProducer.mCurrentBucketStartTimeNs); in TEST() 444 EXPECT_EQ(bucketStartTimeNs, countProducer.mCurrentBucketStartTimeNs); in TEST() 458 EXPECT_EQ(bucketStartTimeNs + 60 * NS_PER_SEC, countProducer.mCurrentBucketStartTimeNs); in TEST() 554 EXPECT_EQ(fiveWeeksNs, countProducer.mCurrentBucketStartTimeNs); in TEST()
|
D | KllMetricProducer_test.cpp | 208 EXPECT_EQ(partialBucketSplitTimeNs, kllProducer->mCurrentBucketStartTimeNs); in TEST_P() 219 EXPECT_EQ(partialBucketSplitTimeNs, kllProducer->mCurrentBucketStartTimeNs); in TEST_P() 231 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs, kllProducer->mCurrentBucketStartTimeNs); in TEST_P()
|
D | GaugeMetricProducer_test.cpp | 120 EXPECT_EQ(600500000000, gaugeProducer.mCurrentBucketStartTimeNs); in TEST() 273 EXPECT_EQ(partialBucketSplitTimeNs, gaugeProducer.mCurrentBucketStartTimeNs); in TEST_P() 287 EXPECT_EQ((int64_t)partialBucketSplitTimeNs, gaugeProducer.mCurrentBucketStartTimeNs); in TEST_P() 298 EXPECT_EQ((int64_t)bucketStartTimeNs + bucketSizeNs, gaugeProducer.mCurrentBucketStartTimeNs); in TEST_P() 369 EXPECT_EQ(partialBucketSplitTimeNs, gaugeProducer.mCurrentBucketStartTimeNs); in TEST_P() 429 EXPECT_EQ(bucketStartTimeNs, gaugeProducer.mCurrentBucketStartTimeNs); in TEST()
|
D | NumericValueMetricProducer_test.cpp | 300 EXPECT_EQ(600500000000, valueProducer->mCurrentBucketStartTimeNs); in TEST() 414 EXPECT_EQ(partialBucketSplitTimeNs, valueProducer->mCurrentBucketStartTimeNs); in TEST_P() 700 EXPECT_EQ(partialBucketSplitTimeNs, valueProducer->mCurrentBucketStartTimeNs); in TEST_P() 711 EXPECT_EQ(partialBucketSplitTimeNs, valueProducer->mCurrentBucketStartTimeNs); in TEST_P() 724 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs, valueProducer->mCurrentBucketStartTimeNs); in TEST_P() 766 EXPECT_EQ(partialBucketSplitTimeNs, valueProducer->mCurrentBucketStartTimeNs); in TEST_P() 774 EXPECT_EQ(bucket3StartTimeNs, valueProducer->mCurrentBucketStartTimeNs); in TEST_P() 807 EXPECT_EQ(bucket2StartTimeNs, valueProducer->mCurrentBucketStartTimeNs); in TEST() 849 EXPECT_EQ(partialBucketSplitTimeNs, valueProducer->mCurrentBucketStartTimeNs); in TEST_P() 2692 EXPECT_EQ(partialBucketSplitTimeNs, valueProducer->mCurrentBucketStartTimeNs); in TEST_P()
|
/packages/modules/StatsD/statsd/src/metrics/duration_helper/ |
D | OringDurationTracker.cpp | 180 current_info.mBucketStartNs = mCurrentBucketStartTimeNs; in flushCurrentBucket() 225 mCurrentBucketStartTimeNs = fullBucketEnd + (numBucketsForward - 1) * mBucketSizeNs; in flushCurrentBucket() 228 mCurrentBucketStartTimeNs = eventTimeNs; in flushCurrentBucket() 230 mLastStartTime = mCurrentBucketStartTimeNs; in flushCurrentBucket()
|
D | MaxDurationTracker.cpp | 212 info.mBucketStartNs = mCurrentBucketStartTimeNs; in flushCurrentBucket() 223 mCurrentBucketStartTimeNs = fullBucketEnd + (numBucketsForward - 1) * mBucketSizeNs; in flushCurrentBucket() 226 mCurrentBucketStartTimeNs = eventTimeNs; in flushCurrentBucket()
|
D | DurationTracker.h | 88 mCurrentBucketStartTimeNs(currentBucketStartNs), in DurationTracker() 252 int64_t mCurrentBucketStartTimeNs; variable
|