Lines Matching refs:mCurrentSlicedBucket

89     mCurrentSlicedBucket = std::make_shared<DimToGaugeAtomsMap>();  in GaugeMetricProducer()
156     if (mCurrentSlicedBucket == nullptr ||  in dumpStatesLocked()
157         mCurrentSlicedBucket->size() == 0) {  in dumpStatesLocked()
162             (unsigned long)mCurrentSlicedBucket->size());  in dumpStatesLocked()
164         for (const auto& it : *mCurrentSlicedBucket) {  in dumpStatesLocked()
320             triggerPuller = mCondition && mCurrentSlicedBucket->empty();  in pullLocked()
394     if (mCurrentSlicedBucket->find(newKey) != mCurrentSlicedBucket->end()) {  in hitGuardRailLocked()
398     if (mCurrentSlicedBucket->size() > mDimensionSoftLimit - 1) {  in hitGuardRailLocked()
399         size_t newTupleCount = mCurrentSlicedBucket->size() + 1;  in hitGuardRailLocked()
430     if (mCurrentSlicedBucket->find(eventKey) != mCurrentSlicedBucket->end() &&  in onMatchedLogEventInternalLocked()
437     if ((*mCurrentSlicedBucket)[eventKey].size() >= mGaugeAtomsPerDimensionLimit) {  in onMatchedLogEventInternalLocked()
441     (*mCurrentSlicedBucket)[eventKey].push_back(gaugeAtom);  in onMatchedLogEventInternalLocked()
462     for (const auto& slice : *mCurrentSlicedBucket) {  in updateCurrentSlicedBucketForAnomaly()
518         for (const auto& slice : *mCurrentSlicedBucket) {  in flushCurrentBucketLocked()
542     mCurrentSlicedBucket = std::make_shared<DimToGaugeAtomsMap>();  in flushCurrentBucketLocked()