Searched refs:numBucketsForward (Results 1 – 6 of 6) sorted by relevance
146 int numBucketsForward = 0; in flushCurrentBucket() local151 numBucketsForward = 1 + (eventTimeNs - fullBucketEnd) / mBucketSizeNs; in flushCurrentBucket()178 for (int i = 1; i < numBucketsForward; i++) { in flushCurrentBucket()190 if (numBucketsForward >= 2) { in flushCurrentBucket()191 addPastBucketToAnomalyTrackers(0, mCurrentBucketNum + numBucketsForward - 1); in flushCurrentBucket()197 if (numBucketsForward > 0) { in flushCurrentBucket()198 mCurrentBucketStartTimeNs = fullBucketEnd + (numBucketsForward - 1) * mBucketSizeNs; in flushCurrentBucket()199 mCurrentBucketNum += numBucketsForward; in flushCurrentBucket()
194 int numBucketsForward = 0; in flushCurrentBucket() local198 numBucketsForward = 1 + (eventTimeNs - fullBucketEnd) / mBucketSizeNs; in flushCurrentBucket()228 if (numBucketsForward > 0) { in flushCurrentBucket()229 mCurrentBucketStartTimeNs = fullBucketEnd + (numBucketsForward - 1) * mBucketSizeNs; in flushCurrentBucket()230 mCurrentBucketNum += numBucketsForward; in flushCurrentBucket()
143 int64_t numBucketsForward = calcBucketsForwardCount(startTimeNs); in ValueMetricProducer() local144 mCurrentBucketNum += numBucketsForward; in ValueMetricProducer()830 int64_t numBucketsForward = calcBucketsForwardCount(eventTimeNs); in flushIfNeededLocked() local831 … int64_t nextBucketStartTimeNs = currentBucketEndTimeNs + (numBucketsForward - 1) * mBucketSizeNs; in flushIfNeededLocked()849 int64_t numBucketsForward = calcBucketsForwardCount(eventTimeNs); in flushCurrentBucketLocked() local850 if (numBucketsForward > 1) { in flushCurrentBucketLocked()851 VLOG("Skipping forward %lld buckets", (long long)numBucketsForward); in flushCurrentBucketLocked()884 mCurrentBucketNum += numBucketsForward; in flushCurrentBucketLocked()
323 int64_t numBucketsForward = 1 + (eventTimeNs - currentBucketEndTimeNs) / mBucketSizeNs; in flushIfNeededLocked() local324 int64_t nextBucketNs = currentBucketEndTimeNs + (numBucketsForward - 1) * mBucketSizeNs; in flushIfNeededLocked()327 mCurrentBucketNum += numBucketsForward; in flushIfNeededLocked()
549 int64_t numBucketsForward = 1 + (eventTimeNs - currentBucketEndTimeNs) / mBucketSizeNs; in flushIfNeededLocked() local550 int64_t nextBucketNs = currentBucketEndTimeNs + (numBucketsForward - 1) * mBucketSizeNs; in flushIfNeededLocked()553 mCurrentBucketNum += numBucketsForward; in flushIfNeededLocked()
606 int numBucketsForward = 1 + (eventTimeNs - currentBucketEndTimeNs) / mBucketSizeNs; in flushIfNeededLocked() local607 int64_t nextBucketNs = currentBucketEndTimeNs + (numBucketsForward - 1) * mBucketSizeNs; in flushIfNeededLocked()610 mCurrentBucketNum += numBucketsForward; in flushIfNeededLocked()