Lines Matching refs:eventTimeNs
158 const int64_t& eventTimeNs) { in onStatsdInitCompleted() argument
164 pullAndMatchEventsLocked(eventTimeNs); in onStatsdInitCompleted()
166 flushCurrentBucketLocked(eventTimeNs, eventTimeNs); in onStatsdInitCompleted()
171 const int64_t eventTimeNs) { in notifyAppUpgradeInternalLocked() argument
174 pullAndMatchEventsLocked(eventTimeNs); in notifyAppUpgradeInternalLocked()
176 flushCurrentBucketLocked(eventTimeNs, eventTimeNs); in notifyAppUpgradeInternalLocked()
227 int64_t eventTimeNs, int32_t atomId, const HashableDimensionKey& primaryKey, in onStateChanged() argument
231 (long long)mMetricId, (long long)eventTimeNs, atomId, primaryKey.toString().c_str(), in onStateChanged()
251 if (isEventLateLocked(eventTimeNs)) { in onStateChanged()
252 VLOG("Skip event due to late arrival: %lld vs %lld", (long long)eventTimeNs, in onStateChanged()
254 invalidateCurrentBucket(eventTimeNs, BucketDropReason::EVENT_IN_WRONG_BUCKET); in onStateChanged()
263 pullAndMatchEventsLocked(eventTimeNs); in onStateChanged()
267 flushIfNeededLocked(eventTimeNs); in onStateChanged()
467 const int64_t eventTimeNs) { in onActiveStateChangedLocked() argument
468 const bool eventLate = isEventLateLocked(eventTimeNs); in onActiveStateChangedLocked()
472 invalidateCurrentBucket(eventTimeNs, BucketDropReason::EVENT_IN_WRONG_BUCKET); in onActiveStateChangedLocked()
476 MetricProducer::onActiveStateChangedLocked(eventTimeNs); in onActiveStateChangedLocked()
485 pullAndMatchEventsLocked(eventTimeNs); in onActiveStateChangedLocked()
488 onActiveStateChangedInternalLocked(eventTimeNs); in onActiveStateChangedLocked()
491 flushIfNeededLocked(eventTimeNs); in onActiveStateChangedLocked()
494 mConditionTimer.onConditionChanged(mIsActive, eventTimeNs); in onActiveStateChangedLocked()
496 updateCurrentSlicedBucketConditionTimers(mIsActive, eventTimeNs); in onActiveStateChangedLocked()
501 const bool condition, const int64_t eventTimeNs) { in onConditionChangedLocked() argument
502 const bool eventLate = isEventLateLocked(eventTimeNs); in onConditionChangedLocked()
516 VLOG("Skip event due to late arrival: %lld vs %lld", (long long)eventTimeNs, in onConditionChangedLocked()
520 invalidateCurrentBucket(eventTimeNs, BucketDropReason::EVENT_IN_WRONG_BUCKET); in onConditionChangedLocked()
522 mConditionTimer.onConditionChanged(newCondition, eventTimeNs); in onConditionChangedLocked()
523 updateCurrentSlicedBucketConditionTimers(newCondition, eventTimeNs); in onConditionChangedLocked()
533 invalidateCurrentBucket(eventTimeNs, BucketDropReason::CONDITION_UNKNOWN); in onConditionChangedLocked()
548 pullAndMatchEventsLocked(eventTimeNs); in onConditionChangedLocked()
551 onConditionChangedInternalLocked(oldCondition, newCondition, eventTimeNs); in onConditionChangedLocked()
556 flushIfNeededLocked(eventTimeNs); in onConditionChangedLocked()
558 mConditionTimer.onConditionChanged(newCondition, eventTimeNs); in onConditionChangedLocked()
559 updateCurrentSlicedBucketConditionTimers(newCondition, eventTimeNs); in onConditionChangedLocked()
564 bool newCondition, int64_t eventTimeNs) { in updateCurrentSlicedBucketConditionTimers() argument
579 newCondition && dimensionInWhatInfo.hasCurrentState, eventTimeNs); in updateCurrentSlicedBucketConditionTimers()
647 const int64_t eventTimeNs = event.GetElapsedTimestampNs(); in onMatchedLogEventInternalLocked() local
648 if (isEventLateLocked(eventTimeNs)) { in onMatchedLogEventInternalLocked()
649 VLOG("Skip event due to late arrival: %lld vs %lld", (long long)eventTimeNs, in onMatchedLogEventInternalLocked()
659 flushIfNeededLocked(eventTimeNs); in onMatchedLogEventInternalLocked()
662 if (canSkipLogEventLocked(eventKey, condition, eventTimeNs, statePrimaryKeys)) { in onMatchedLogEventInternalLocked()
691 dimensionsInWhatInfo.seenNewData |= aggregateFields(eventTimeNs, eventKey, event, intervals, in onMatchedLogEventInternalLocked()
697 currentBucket.conditionTimer.onConditionChanged(false, eventTimeNs); in onMatchedLogEventInternalLocked()
701 .conditionTimer.onConditionChanged(true, eventTimeNs); in onMatchedLogEventInternalLocked()
709 const int64_t& eventTimeNs) { in flushIfNeededLocked() argument
711 if (eventTimeNs < currentBucketEndTimeNs) { in flushIfNeededLocked()
712 VLOG("eventTime is %lld, less than current bucket end time %lld", (long long)eventTimeNs, in flushIfNeededLocked()
716 int64_t numBucketsForward = calcBucketsForwardCount(eventTimeNs); in flushIfNeededLocked()
719 flushCurrentBucketLocked(eventTimeNs, nextBucketStartTimeNs); in flushIfNeededLocked()
724 const int64_t eventTimeNs) const { in calcBucketsForwardCount()
726 if (eventTimeNs < currentBucketEndTimeNs) { in calcBucketsForwardCount()
729 return 1 + (eventTimeNs - currentBucketEndTimeNs) / mBucketSizeNs; in calcBucketsForwardCount()
734 const int64_t& eventTimeNs, const int64_t& nextBucketStartTimeNs) { in flushCurrentBucketLocked() argument
737 invalidateCurrentBucket(eventTimeNs, BucketDropReason::CONDITION_UNKNOWN); in flushCurrentBucketLocked()
743 closeCurrentBucket(eventTimeNs, nextBucketStartTimeNs); in flushCurrentBucketLocked()
747 mConditionTimer.newBucketStart(eventTimeNs, nextBucketStartTimeNs); in flushCurrentBucketLocked()
753 currentBucket.conditionTimer.newBucketStart(eventTimeNs, nextBucketStartTimeNs); in flushCurrentBucketLocked()
756 mCurrentBucketNum += calcBucketsForwardCount(eventTimeNs); in flushCurrentBucketLocked()
761 const int64_t eventTimeNs, const int64_t nextBucketStartTimeNs) { in closeCurrentBucket() argument
764 int64_t numBucketsForward = calcBucketsForwardCount(eventTimeNs); in closeCurrentBucket()
771 invalidateCurrentBucket(eventTimeNs, BucketDropReason::MULTIPLE_BUCKETS_SKIPPED); in closeCurrentBucket()
775 } else if (eventTimeNs < fullBucketEndTimeNs) { in closeCurrentBucket()
776 bucketEndTimeNs = eventTimeNs; in closeCurrentBucket()
781 mConditionTimer.newBucketStart(eventTimeNs, bucketEndTimeNs); in closeCurrentBucket()
785 skipCurrentBucket(eventTimeNs, BucketDropReason::BUCKET_TOO_SMALL); in closeCurrentBucket()
799 currentBucket.conditionTimer.newBucketStart(eventTimeNs, bucketEndTimeNs); in closeCurrentBucket()
811 skipCurrentBucket(eventTimeNs, BucketDropReason::NO_DATA); in closeCurrentBucket()
829 bucketInGap.dropEvents.emplace_back(buildDropEvent(eventTimeNs, BucketDropReason::NO_DATA)); in closeCurrentBucket()