Searched refs:mCurrentSlicedBucket (Results 1 – 6 of 6) sorted by relevance
/aosp12/packages/modules/StatsD/statsd/tests/metrics/ |
H A D | GaugeMetricProducer_test.cpp | 154 ASSERT_EQ(1UL, gaugeProducer.mCurrentSlicedBucket->size()); in TEST() 170 ASSERT_EQ(1UL, gaugeProducer.mCurrentSlicedBucket->size()); in TEST() 188 ASSERT_EQ(0UL, gaugeProducer.mCurrentSlicedBucket->size()); in TEST() 321 ASSERT_EQ(1UL, gaugeProducer.mCurrentSlicedBucket->size()); in TEST_P() 322 EXPECT_EQ(1, gaugeProducer.mCurrentSlicedBucket->begin() in TEST_P() 343 EXPECT_EQ(2, gaugeProducer.mCurrentSlicedBucket->begin() in TEST_P() 353 EXPECT_EQ(3, gaugeProducer.mCurrentSlicedBucket->begin() in TEST_P() 390 EXPECT_EQ(1, gaugeProducer.mCurrentSlicedBucket->begin() in TEST() 400 EXPECT_EQ(1, gaugeProducer.mCurrentSlicedBucket->begin() in TEST() 442 EXPECT_EQ(100, gaugeProducer.mCurrentSlicedBucket->begin() in TEST() [all …]
|
H A D | ValueMetricProducer_test.cpp | 4049 it = valueProducer->mCurrentSlicedBucket.begin(); in TEST() 4081 it = valueProducer->mCurrentSlicedBucket.begin(); in TEST() 4122 it = valueProducer->mCurrentSlicedBucket.begin(); in TEST() 4299 it = valueProducer->mCurrentSlicedBucket.begin(); in TEST() 4331 it = valueProducer->mCurrentSlicedBucket.begin(); in TEST() 4363 it = valueProducer->mCurrentSlicedBucket.begin(); in TEST() 4394 it = valueProducer->mCurrentSlicedBucket.begin(); in TEST() 4645 it = valueProducer->mCurrentSlicedBucket.begin(); in TEST() 4697 it = valueProducer->mCurrentSlicedBucket.begin(); in TEST() 4766 it = valueProducer->mCurrentSlicedBucket.begin(); in TEST() [all …]
|
/aosp12/packages/modules/StatsD/statsd/src/metrics/ |
H A D | GaugeMetricProducer.cpp | 105 mCurrentSlicedBucket = std::make_shared<DimToGaugeAtomsMap>(); 218 if (mCurrentSlicedBucket == nullptr || in dumpStatesLocked() 219 mCurrentSlicedBucket->size() == 0) { in dumpStatesLocked() 224 (unsigned long)mCurrentSlicedBucket->size()); in dumpStatesLocked() 226 for (const auto& it : *mCurrentSlicedBucket) { in dumpStatesLocked() 495 if (mCurrentSlicedBucket->find(newKey) != mCurrentSlicedBucket->end()) { in hitGuardRailLocked() 500 size_t newTupleCount = mCurrentSlicedBucket->size() + 1; in hitGuardRailLocked() 536 if (mCurrentSlicedBucket->find(eventKey) != mCurrentSlicedBucket->end() && in onMatchedLogEventInternalLocked() 549 (*mCurrentSlicedBucket)[eventKey].push_back(gaugeAtom); in onMatchedLogEventInternalLocked() 570 for (const auto& slice : *mCurrentSlicedBucket) { in updateCurrentSlicedBucketForAnomaly() [all …]
|
H A D | ValueMetricProducer.cpp | 726 mCurrentSlicedBucket.clear(); in accumulateEvents() 731 if (mCurrentSlicedBucket.size() == 0) { in dumpStatesLocked() 736 (unsigned long)mCurrentSlicedBucket.size()); in dumpStatesLocked() 738 for (const auto& it : mCurrentSlicedBucket) { in dumpStatesLocked() 756 if (mCurrentSlicedBucket.find(newKey) != mCurrentSlicedBucket.end()) { in hitGuardRailLocked() 1064 (int)mCurrentSlicedBucket.size()); in flushCurrentBucketLocked() 1173 for (auto it = mCurrentSlicedBucket.begin(); it != mCurrentSlicedBucket.end();) { in initCurrentSlicedBucket() 1196 it = mCurrentSlicedBucket.erase(it); in initCurrentSlicedBucket() 1229 for (const auto& slice : mCurrentSlicedBucket) { in appendToFullBucket() 1249 for (const auto& slice : mCurrentSlicedBucket) { in appendToFullBucket() [all …]
|
H A D | GaugeMetricProducer.h | 182 std::shared_ptr<DimToGaugeAtomsMap> mCurrentSlicedBucket; variable
|
H A D | ValueMetricProducer.h | 244 std::unordered_map<MetricDimensionKey, CurrentValueBucket> mCurrentSlicedBucket; variable
|