409 void GaugeMetricProducer::onActiveStateChangedLocked(const int64_t eventTimeNs) {  in onActiveStateChangedLocked()  argument
410     MetricProducer::onActiveStateChangedLocked(eventTimeNs);  in onActiveStateChangedLocked()
415         pullAndMatchEventsLocked(eventTimeNs);  in onActiveStateChangedLocked()
420                                                    const int64_t eventTimeNs) {  in onConditionChangedLocked()  argument
428     flushIfNeededLocked(eventTimeNs);  in onConditionChangedLocked()
430         pullAndMatchEventsLocked(eventTimeNs);  in onConditionChangedLocked()
435                                                            const int64_t eventTimeNs) {  in onSlicedConditionMayChangeLocked()  argument
443     flushIfNeededLocked(eventTimeNs);  in onSlicedConditionMayChangeLocked()
447         pullAndMatchEventsLocked(eventTimeNs);  in onSlicedConditionMayChangeLocked()
522     int64_t eventTimeNs = event.GetElapsedTimestampNs();  in onMatchedLogEventInternalLocked()  local
523     if (eventTimeNs < mCurrentBucketStartTimeNs) {  in onMatchedLogEventInternalLocked()
524         VLOG("Gauge Skip event due to late arrival: %lld vs %lld", (long long)eventTimeNs,  in onMatchedLogEventInternalLocked()
528     flushIfNeededLocked(eventTimeNs);  in onMatchedLogEventInternalLocked()
531         pullAndMatchEventsLocked(eventTimeNs);  in onMatchedLogEventInternalLocked()
563                 tracker->detectAndDeclareAnomaly(eventTimeNs, mCurrentBucketNum, mMetricId,  in onMatchedLogEventInternalLocked()
597 void GaugeMetricProducer::flushIfNeededLocked(const int64_t& eventTimeNs) {  in flushIfNeededLocked()  argument
600     if (eventTimeNs < currentBucketEndTimeNs) {  in flushIfNeededLocked()
602              (long long)eventTimeNs, (long long)(mCurrentBucketStartTimeNs + mBucketSizeNs));  in flushIfNeededLocked()
607     int64_t numBucketsForward = 1 + (eventTimeNs - currentBucketEndTimeNs) / mBucketSizeNs;  in flushIfNeededLocked()
609     flushCurrentBucketLocked(eventTimeNs, nextBucketNs);  in flushIfNeededLocked()
616 void GaugeMetricProducer::flushCurrentBucketLocked(const int64_t& eventTimeNs,  in flushCurrentBucketLocked()  argument
619     int64_t bucketEndTime = eventTimeNs < fullBucketEndTimeNs ? eventTimeNs : fullBucketEndTimeNs;  in flushCurrentBucketLocked()
646                     buildDropEvent(eventTimeNs, BucketDropReason::BUCKET_TOO_SMALL));  in flushCurrentBucketLocked()
655         if (eventTimeNs > fullBucketEndTimeNs) {  in flushCurrentBucketLocked()