Home
last modified time | relevance | path

Searched refs:mCurrentSlicedBucket (Results 1 – 8 of 8) sorted by relevance

/packages/modules/StatsD/statsd/tests/metrics/
DGaugeMetricProducer_test.cpp157 ASSERT_EQ(1UL, gaugeProducer.mCurrentSlicedBucket->size()); in TEST()
158 auto it = gaugeProducer.mCurrentSlicedBucket->begin()->second.front().mFields->begin(); in TEST()
175 ASSERT_EQ(1UL, gaugeProducer.mCurrentSlicedBucket->size()); in TEST()
176 it = gaugeProducer.mCurrentSlicedBucket->begin()->second.front().mFields->begin(); in TEST()
198 ASSERT_EQ(0UL, gaugeProducer.mCurrentSlicedBucket->size()); in TEST()
249 EXPECT_EQ(1UL, (*gaugeProducer.mCurrentSlicedBucket).count(DEFAULT_METRIC_DIMENSION_KEY)); in TEST_P()
259 EXPECT_EQ(0UL, (*gaugeProducer.mCurrentSlicedBucket).count(DEFAULT_METRIC_DIMENSION_KEY)); in TEST_P()
342 ASSERT_EQ(1UL, gaugeProducer.mCurrentSlicedBucket->size()); in TEST_P()
343 EXPECT_EQ(1, gaugeProducer.mCurrentSlicedBucket->begin() in TEST_P()
363 ASSERT_EQ(1UL, gaugeProducer.mCurrentSlicedBucket->size()); in TEST_P()
[all …]
DNumericValueMetricProducer_test.cpp319 ASSERT_EQ(0UL, valueProducer->mCurrentSlicedBucket.size()); in TEST()
333 ASSERT_EQ(0UL, valueProducer->mCurrentSlicedBucket.size()); in TEST()
348 ASSERT_EQ(0UL, valueProducer->mCurrentSlicedBucket.size()); in TEST()
444 ASSERT_EQ(0UL, valueProducer->mCurrentSlicedBucket.size()); in TEST()
458 ASSERT_EQ(0UL, valueProducer->mCurrentSlicedBucket.size()); in TEST()
464 ASSERT_EQ(0UL, valueProducer->mCurrentSlicedBucket.size()); in TEST()
495 ASSERT_EQ(0UL, valueProducer->mCurrentSlicedBucket.size()); in TEST()
509 ASSERT_EQ(0UL, valueProducer->mCurrentSlicedBucket.size()); in TEST()
520 ASSERT_EQ(0UL, valueProducer->mCurrentSlicedBucket.size()); in TEST()
548 ASSERT_EQ(0UL, valueProducer->mCurrentSlicedBucket.size()); in TEST()
[all …]
DKllMetricProducer_test.cpp185 ASSERT_EQ(1UL, kllProducer->mCurrentSlicedBucket.size()); in TEST_P()
239 ASSERT_EQ(1UL, kllProducer->mCurrentSlicedBucket.size()); in TEST()
241 kllProducer->mCurrentSlicedBucket.begin()->second.intervals[0]; in TEST()
248 ASSERT_EQ(1UL, kllProducer->mCurrentSlicedBucket.size()); in TEST()
265 ASSERT_EQ(0UL, kllProducer->mCurrentSlicedBucket.size()); in TEST()
274 ASSERT_EQ(1UL, kllProducer->mCurrentSlicedBucket.size()); in TEST()
276 kllProducer->mCurrentSlicedBucket.begin()->second.intervals[0]; in TEST()
284 ASSERT_EQ(1UL, kllProducer->mCurrentSlicedBucket.size()); in TEST()
294 ASSERT_EQ(1UL, kllProducer->mCurrentSlicedBucket.size()); in TEST()
/packages/modules/StatsD/statsd/src/metrics/
DGaugeMetricProducer.cpp109 mCurrentSlicedBucket = std::make_shared<DimToGaugeAtomsMap>();
227 if (mCurrentSlicedBucket == nullptr || in dumpStatesLocked()
228 mCurrentSlicedBucket->size() == 0) { in dumpStatesLocked()
233 (unsigned long)mCurrentSlicedBucket->size()); in dumpStatesLocked()
235 for (const auto& it : *mCurrentSlicedBucket) { in dumpStatesLocked()
395 triggerPuller = mCurrentSlicedBucket->empty(); in pullAndMatchEventsLocked()
525 if (mCurrentSlicedBucket->find(newKey) != mCurrentSlicedBucket->end()) { in hitGuardRailLocked()
529 if (mCurrentSlicedBucket->size() >= mDimensionSoftLimit) { in hitGuardRailLocked()
530 size_t newTupleCount = mCurrentSlicedBucket->size() + 1; in hitGuardRailLocked()
579 if (mCurrentSlicedBucket->find(eventKey) != mCurrentSlicedBucket->end() && in onMatchedLogEventInternalLocked()
[all …]
DValueMetricProducer.cpp618 mCurrentSlicedBucket[MetricDimensionKey(dimensionInWhatKey, in updateCurrentSlicedBucketConditionTimers()
628 if (mCurrentSlicedBucket.size() == 0) { in dumpStatesLocked()
633 (unsigned long)mCurrentSlicedBucket.size()); in dumpStatesLocked()
635 for (const auto& [metricDimensionKey, currentBucket] : mCurrentSlicedBucket) { in dumpStatesLocked()
648 return mCurrentSlicedBucket.size() >= mDimensionHardLimit; in hasReachedGuardRailLimit()
656 if (mCurrentSlicedBucket.find(newKey) != mCurrentSlicedBucket.end()) { in hitGuardRailLocked()
659 if (mCurrentSlicedBucket.size() > mDimensionSoftLimit - 1) { in hitGuardRailLocked()
660 size_t newTupleCount = mCurrentSlicedBucket.size() + 1; in hitGuardRailLocked()
718 CurrentBucket& currentBucket = mCurrentSlicedBucket[MetricDimensionKey(whatKey, oldStateKey)]; in onMatchedLogEventInternalLocked()
745 mCurrentSlicedBucket[MetricDimensionKey(whatKey, stateKey)] in onMatchedLogEventInternalLocked()
[all …]
DNumericValueMetricProducer.cpp320 for (auto& [metricDimensionKey, currentValueBucket] : mCurrentSlicedBucket) { in accumulateEvents()
346 mCurrentSlicedBucket.clear(); in accumulateEvents()
584 for (const auto& [metricDimensionKey, currentBucket] : mCurrentSlicedBucket) { in appendToFullBucket()
605 for (const auto& [metricDimensionKey, currentBucket] : mCurrentSlicedBucket) { in appendToFullBucket()
621 for (const auto& [metricDimensionKey, currentBucket] : mCurrentSlicedBucket) { in appendToFullBucket()
DGaugeMetricProducer.h199 std::shared_ptr<DimToGaugeAtomsMap> mCurrentSlicedBucket; variable
DValueMetricProducer.h301 std::unordered_map<MetricDimensionKey, CurrentBucket> mCurrentSlicedBucket; variable