Lines Matching defs:eventTimeNs
350 const int64_t eventTimeNs) {
352 flushIfNeededLocked(eventTimeNs);
356 pullLocked(eventTimeNs);
361 const int64_t eventTimeNs) {
364 flushIfNeededLocked(eventTimeNs);
369 pullLocked(eventTimeNs);
419 int64_t eventTimeNs = event.GetElapsedTimestampNs();
421 if (eventTimeNs < mCurrentBucketStartTimeNs) {
422 VLOG("Gauge Skip event due to late arrival: %lld vs %lld", (long long)eventTimeNs,
426 flushIfNeededLocked(eventTimeNs);
440 GaugeAtom gaugeAtom(getGaugeFields(event), eventTimeNs, getWallClockNs());
454 tracker->detectAndDeclareAnomaly(eventTimeNs, mCurrentBucketNum, eventKey,
487 void GaugeMetricProducer::flushIfNeededLocked(const int64_t& eventTimeNs) {
490 if (eventTimeNs < currentBucketEndTimeNs) {
492 (long long)eventTimeNs, (long long)(mCurrentBucketStartTimeNs + mBucketSizeNs));
496 flushCurrentBucketLocked(eventTimeNs);
499 int64_t numBucketsForward = 1 + (eventTimeNs - currentBucketEndTimeNs) / mBucketSizeNs;
506 void GaugeMetricProducer::flushCurrentBucketLocked(const int64_t& eventTimeNs) {
511 if (eventTimeNs < fullBucketEndTimeNs) {
512 info.mBucketEndNs = eventTimeNs;
533 if (eventTimeNs > fullBucketEndTimeNs) {
