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()
148 int64_t numBucketsForward = calcBucketsForwardCount(startTimeNs); in ValueMetricProducer() local149 mCurrentBucketNum += numBucketsForward; in ValueMetricProducer()835 int64_t numBucketsForward = calcBucketsForwardCount(eventTimeNs); in flushIfNeededLocked() local836 … int64_t nextBucketStartTimeNs = currentBucketEndTimeNs + (numBucketsForward - 1) * mBucketSizeNs; in flushIfNeededLocked()854 int64_t numBucketsForward = calcBucketsForwardCount(eventTimeNs); in flushCurrentBucketLocked() local855 if (numBucketsForward > 1) { in flushCurrentBucketLocked()856 VLOG("Skipping forward %lld buckets", (long long)numBucketsForward); in flushCurrentBucketLocked()889 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()
551 int64_t numBucketsForward = 1 + (eventTimeNs - currentBucketEndTimeNs) / mBucketSizeNs; in flushIfNeededLocked() local552 int64_t nextBucketNs = currentBucketEndTimeNs + (numBucketsForward - 1) * mBucketSizeNs; in flushIfNeededLocked()555 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()