Lines Matching refs:mCurrentSlicedBucket

109     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()
586     if ((*mCurrentSlicedBucket)[eventKey].size() >= mGaugeAtomsPerDimensionLimit) {  in onMatchedLogEventInternalLocked()
592     (*mCurrentSlicedBucket)[eventKey].push_back(gaugeAtom);  in onMatchedLogEventInternalLocked()
613     for (const auto& slice : *mCurrentSlicedBucket) {  in updateCurrentSlicedBucketForAnomaly()
672         for (const auto& slice : *mCurrentSlicedBucket) {  in flushCurrentBucketLocked()
713     mCurrentSlicedBucket = std::make_shared<DimToGaugeAtomsMap>();  in flushCurrentBucketLocked()