Home
last modified time | relevance | path

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

/frameworks/base/cmds/statsd/tests/metrics/
DGaugeMetricProducer_test.cpp159 ASSERT_EQ(1UL, gaugeProducer.mCurrentSlicedBucket->size()); in TEST()
160 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()
193 ASSERT_EQ(0UL, gaugeProducer.mCurrentSlicedBucket->size()); in TEST()
239 EXPECT_EQ(1UL, (*gaugeProducer.mCurrentSlicedBucket).count(DEFAULT_METRIC_DIMENSION_KEY)); in TEST_P()
249 EXPECT_EQ(0UL, (*gaugeProducer.mCurrentSlicedBucket).count(DEFAULT_METRIC_DIMENSION_KEY)); in TEST_P()
331 ASSERT_EQ(1UL, gaugeProducer.mCurrentSlicedBucket->size()); in TEST_P()
332 EXPECT_EQ(1, gaugeProducer.mCurrentSlicedBucket->begin() in TEST_P()
352 ASSERT_EQ(1UL, gaugeProducer.mCurrentSlicedBucket->size()); in TEST_P()
[all …]
DValueMetricProducer_test.cpp314 ASSERT_EQ(1UL, valueProducer->mCurrentSlicedBucket.size()); in TEST()
316 valueProducer->mCurrentSlicedBucket.begin()->second[0]; in TEST()
331 ASSERT_EQ(1UL, valueProducer->mCurrentSlicedBucket.size()); in TEST()
332 curInterval = valueProducer->mCurrentSlicedBucket.begin()->second[0]; in TEST()
349 ASSERT_EQ(1UL, valueProducer->mCurrentSlicedBucket.size()); in TEST()
350 curInterval = valueProducer->mCurrentSlicedBucket.begin()->second[0]; in TEST()
456 ASSERT_EQ(1UL, valueProducer->mCurrentSlicedBucket.size()); in TEST()
458 valueProducer->mCurrentSlicedBucket.begin()->second[0]; in TEST()
473 ASSERT_EQ(0UL, valueProducer->mCurrentSlicedBucket.size()); in TEST()
486 ASSERT_EQ(1UL, valueProducer->mCurrentSlicedBucket.size()); in TEST()
[all …]
/frameworks/base/cmds/statsd/src/metrics/
DGaugeMetricProducer.cpp102 mCurrentSlicedBucket = std::make_shared<DimToGaugeAtomsMap>();
157 if (mCurrentSlicedBucket == nullptr || in dumpStatesLocked()
158 mCurrentSlicedBucket->size() == 0) { in dumpStatesLocked()
163 (unsigned long)mCurrentSlicedBucket->size()); in dumpStatesLocked()
165 for (const auto& it : *mCurrentSlicedBucket) { in dumpStatesLocked()
307 triggerPuller = mCondition == ConditionState::kTrue && mCurrentSlicedBucket->empty(); in pullAndMatchEventsLocked()
434 if (mCurrentSlicedBucket->find(newKey) != mCurrentSlicedBucket->end()) { in hitGuardRailLocked()
438 if (mCurrentSlicedBucket->size() > mDimensionSoftLimit - 1) { in hitGuardRailLocked()
439 size_t newTupleCount = mCurrentSlicedBucket->size() + 1; in hitGuardRailLocked()
475 if (mCurrentSlicedBucket->find(eventKey) != mCurrentSlicedBucket->end() && in onMatchedLogEventInternalLocked()
[all …]
DValueMetricProducer.cpp620 for (auto& slice : mCurrentSlicedBucket) { in accumulateEvents()
642 mCurrentSlicedBucket.clear(); in accumulateEvents()
647 if (mCurrentSlicedBucket.size() == 0) { in dumpStatesLocked()
652 (unsigned long)mCurrentSlicedBucket.size()); in dumpStatesLocked()
654 for (const auto& it : mCurrentSlicedBucket) { in dumpStatesLocked()
666 return mCurrentSlicedBucket.size() >= mDimensionHardLimit; in hasReachedGuardRailLimit()
672 if (mCurrentSlicedBucket.find(newKey) != mCurrentSlicedBucket.end()) { in hitGuardRailLocked()
675 if (mCurrentSlicedBucket.size() > mDimensionSoftLimit - 1) { in hitGuardRailLocked()
676 size_t newTupleCount = mCurrentSlicedBucket.size() + 1; in hitGuardRailLocked()
802 vector<Interval>& intervals = mCurrentSlicedBucket[MetricDimensionKey(whatKey, oldStateKey)]; in onMatchedLogEventInternalLocked()
[all …]
DGaugeMetricProducer.h161 std::shared_ptr<DimToGaugeAtomsMap> mCurrentSlicedBucket; variable
DValueMetricProducer.h202 std::unordered_map<MetricDimensionKey, std::vector<Interval>> mCurrentSlicedBucket; variable