Lines Matching refs:bucket
74 TimeUnitToBucketSizeInMillisGuardrailed(key.GetUid(), metric.bucket()) * 1000000;
104 VLOG("metric %lld created. bucket size %lld start_time: %lld", (long long)metric.id(),
207 for (const auto& bucket : counter.second) {
210 // Partial bucket.
211 if (bucket.mBucketEndNs - bucket.mBucketStartNs != mBucketSizeNs) {
213 (long long)NanoToMillis(bucket.mBucketStartNs));
215 (long long)NanoToMillis(bucket.mBucketEndNs));
218 (long long)(getBucketNumFromEndTimeNs(bucket.mBucketEndNs)));
220 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_COUNT, (long long)bucket.mCount);
222 VLOG("\t bucket [%lld - %lld] count: %lld", (long long)bucket.mBucketStartNs,
223 (long long)bucket.mBucketEndNs, (long long)bucket.mCount);
303 // bucket. If not, flush the old counter to past buckets and initialize the new bucket.
311 // Setup the bucket start time and number.
315 VLOG("metric %lld: new bucket start time: %lld", (long long)mMetricId,
337 // If we have finished a full bucket, then send this to anomaly tracker.
349 // Skip aggregating the partial buckets since there's no previous partial bucket.
355 // Accumulate partial bucket.