171 void CountMetricProducer::onStateChanged(const int64_t eventTimeNs, const int32_t atomId,  in onStateChanged()  argument
175          (long long)mMetricId, (long long)eventTimeNs, atomId, primaryKey.toString().c_str(),  in onStateChanged()
329     int64_t eventTimeNs = event.GetElapsedTimestampNs();  in onMatchedLogEventInternalLocked()  local
330     flushIfNeededLocked(eventTimeNs);  in onMatchedLogEventInternalLocked()
355         tracker->detectAndDeclareAnomaly(eventTimeNs, mCurrentBucketNum, mMetricId, eventKey,  in onMatchedLogEventInternalLocked()
365 void CountMetricProducer::flushIfNeededLocked(const int64_t& eventTimeNs) {  in flushIfNeededLocked()  argument
367     if (eventTimeNs < currentBucketEndTimeNs) {  in flushIfNeededLocked()
372     int64_t numBucketsForward = 1 + (eventTimeNs - currentBucketEndTimeNs) / mBucketSizeNs;  in flushIfNeededLocked()
374     flushCurrentBucketLocked(eventTimeNs, nextBucketNs);  in flushIfNeededLocked()
401 void CountMetricProducer::flushCurrentBucketLocked(const int64_t& eventTimeNs,  in flushCurrentBucketLocked()  argument
406     if (eventTimeNs < fullBucketEndTimeNs) {  in flushCurrentBucketLocked()
407         info.mBucketEndNs = eventTimeNs;  in flushCurrentBucketLocked()
422     if (eventTimeNs > fullBucketEndTimeNs) {  in flushCurrentBucketLocked()