407 void GaugeMetricProducer::onActiveStateChangedLocked(const int64_t& eventTimeNs) {  in onActiveStateChangedLocked()  argument
408     MetricProducer::onActiveStateChangedLocked(eventTimeNs);  in onActiveStateChangedLocked()
413         pullAndMatchEventsLocked(eventTimeNs);  in onActiveStateChangedLocked()
419                                                    const int64_t eventTimeNs) {  in onConditionChangedLocked()  argument
427     flushIfNeededLocked(eventTimeNs);  in onConditionChangedLocked()
429         pullAndMatchEventsLocked(eventTimeNs);  in onConditionChangedLocked()
434                                                            const int64_t eventTimeNs) {  in onSlicedConditionMayChangeLocked()  argument
442     flushIfNeededLocked(eventTimeNs);  in onSlicedConditionMayChangeLocked()
446         pullAndMatchEventsLocked(eventTimeNs);  in onSlicedConditionMayChangeLocked()
521     int64_t eventTimeNs = event.GetElapsedTimestampNs();  in onMatchedLogEventInternalLocked()  local
522     if (eventTimeNs < mCurrentBucketStartTimeNs) {  in onMatchedLogEventInternalLocked()
523         VLOG("Gauge Skip event due to late arrival: %lld vs %lld", (long long)eventTimeNs,  in onMatchedLogEventInternalLocked()
527     flushIfNeededLocked(eventTimeNs);  in onMatchedLogEventInternalLocked()
530         pullAndMatchEventsLocked(eventTimeNs);  in onMatchedLogEventInternalLocked()
562                 tracker->detectAndDeclareAnomaly(eventTimeNs, mCurrentBucketNum, mMetricId,  in onMatchedLogEventInternalLocked()
596 void GaugeMetricProducer::flushIfNeededLocked(const int64_t& eventTimeNs) {  in flushIfNeededLocked()  argument
599     if (eventTimeNs < currentBucketEndTimeNs) {  in flushIfNeededLocked()
601              (long long)eventTimeNs, (long long)(mCurrentBucketStartTimeNs + mBucketSizeNs));  in flushIfNeededLocked()
606     int64_t numBucketsForward = 1 + (eventTimeNs - currentBucketEndTimeNs) / mBucketSizeNs;  in flushIfNeededLocked()
608     flushCurrentBucketLocked(eventTimeNs, nextBucketNs);  in flushIfNeededLocked()
615 void GaugeMetricProducer::flushCurrentBucketLocked(const int64_t& eventTimeNs,  in flushCurrentBucketLocked()  argument
618     int64_t bucketEndTime = eventTimeNs < fullBucketEndTimeNs ? eventTimeNs : fullBucketEndTimeNs;  in flushCurrentBucketLocked()
640                     buildDropEvent(eventTimeNs, BucketDropReason::BUCKET_TOO_SMALL));  in flushCurrentBucketLocked()
649         if (eventTimeNs > fullBucketEndTimeNs) {  in flushCurrentBucketLocked()