Lines Matching refs:eventTimeNs
273 const int64_t eventTimeNs) {
276 if (eventTimeNs < mCurrentBucketStartTimeNs) {
277 VLOG("Skip event due to late arrival: %lld vs %lld", (long long)eventTimeNs,
282 flushIfNeededLocked(eventTimeNs);
286 if (mStatsPullerManager->Pull(mPullTagId, eventTimeNs, &allData)) {
366 int64_t eventTimeNs = event.GetElapsedTimestampNs();
367 if (eventTimeNs < mCurrentBucketStartTimeNs) {
368 VLOG("Skip event due to late arrival: %lld vs %lld", (long long)eventTimeNs,
373 flushIfNeededLocked(eventTimeNs);
430 tracker->detectAndDeclareAnomaly(eventTimeNs, mCurrentBucketNum, eventKey, wholeBucketVal);
434 void ValueMetricProducer::flushIfNeededLocked(const int64_t& eventTimeNs) {
437 if (eventTimeNs < currentBucketEndTimeNs) {
438 VLOG("eventTime is %lld, less than next bucket start time %lld", (long long)eventTimeNs,
443 flushCurrentBucketLocked(eventTimeNs);
445 int64_t numBucketsForward = 1 + (eventTimeNs - currentBucketEndTimeNs) / mBucketSizeNs;
456 void ValueMetricProducer::flushCurrentBucketLocked(const int64_t& eventTimeNs) {
463 if (eventTimeNs < fullBucketEndTimeNs) {
464 info.mBucketEndNs = eventTimeNs;
487 if (eventTimeNs > fullBucketEndTimeNs) { // If full bucket, send to anomaly tracker.