Lines Matching refs:mCurrentSlicedBucket

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()
368             triggerPuller = mCondition == ConditionState::kTrue && mCurrentSlicedBucket->empty();  in pullAndMatchEventsLocked()
495     if (mCurrentSlicedBucket->find(newKey) != mCurrentSlicedBucket->end()) {  in hitGuardRailLocked()
499     if (mCurrentSlicedBucket->size() > mDimensionSoftLimit - 1) {  in hitGuardRailLocked()
500         size_t newTupleCount = mCurrentSlicedBucket->size() + 1;  in hitGuardRailLocked()
536     if (mCurrentSlicedBucket->find(eventKey) != mCurrentSlicedBucket->end() &&  in onMatchedLogEventInternalLocked()
543     if ((*mCurrentSlicedBucket)[eventKey].size() >= mGaugeAtomsPerDimensionLimit) {  in onMatchedLogEventInternalLocked()
549     (*mCurrentSlicedBucket)[eventKey].push_back(gaugeAtom);  in onMatchedLogEventInternalLocked()
570     for (const auto& slice : *mCurrentSlicedBucket) {  in updateCurrentSlicedBucketForAnomaly()
628         for (const auto& slice : *mCurrentSlicedBucket) {  in flushCurrentBucketLocked()
659     mCurrentSlicedBucket = std::make_shared<DimToGaugeAtomsMap>();  in flushCurrentBucketLocked()