Lines Matching refs:bucketStartTimeNs
88 int64_t bucketStartTimeNs = 10000000000; in TEST() local
98 makeLogEvent(&event1, bucketStartTimeNs + 1, tagId); in TEST()
100 makeLogEvent(&event2, bucketStartTimeNs + bucketSizeNs + 2, tagId); in TEST()
108 wizard, protoHash, dimensions, bucketStartTimeNs, bucketStartTimeNs, provider); in TEST()
112 durationProducer.flushIfNeededLocked(bucketStartTimeNs + 2 * bucketSizeNs + 1); in TEST()
118 EXPECT_EQ(bucketStartTimeNs, buckets[0].mBucketStartNs); in TEST()
119 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs, buckets[0].mBucketEndNs); in TEST()
121 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs, buckets[1].mBucketStartNs); in TEST()
122 EXPECT_EQ(bucketStartTimeNs + 2 * bucketSizeNs, buckets[1].mBucketEndNs); in TEST()
128 int64_t bucketStartTimeNs = 10000000000; in TEST() local
138 makeLogEvent(&event1, bucketStartTimeNs + 1, tagId); in TEST()
140 makeLogEvent(&event2, bucketStartTimeNs + 2, tagId); in TEST()
142 makeLogEvent(&event3, bucketStartTimeNs + bucketSizeNs + 1, tagId); in TEST()
144 makeLogEvent(&event4, bucketStartTimeNs + bucketSizeNs + 3, tagId); in TEST()
153 bucketStartTimeNs, bucketStartTimeNs, provider); in TEST()
162 durationProducer.flushIfNeededLocked(bucketStartTimeNs + bucketSizeNs + 1); in TEST()
165 int64_t conditionStartTimeNs = bucketStartTimeNs + bucketSizeNs + 2; in TEST()
166 int64_t bucket2EndTimeNs = bucketStartTimeNs + 2 * bucketSizeNs; in TEST()
179 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs, buckets2[0].mBucketStartNs); in TEST()
187 int64_t bucketStartTimeNs = 10000000000; in TEST() local
197 makeLogEvent(&event1, bucketStartTimeNs + 1, tagId); in TEST()
199 makeLogEvent(&event2, bucketStartTimeNs + 2, tagId); in TEST()
201 makeLogEvent(&event3, bucketStartTimeNs + bucketSizeNs + 1, tagId); in TEST()
203 makeLogEvent(&event4, bucketStartTimeNs + bucketSizeNs + 3, tagId); in TEST()
212 bucketStartTimeNs, bucketStartTimeNs, provider); in TEST()
219 durationProducer.flushIfNeededLocked(bucketStartTimeNs + bucketSizeNs + 1); in TEST()
223 durationProducer.onConditionChanged(true /* condition */, bucketStartTimeNs + bucketSizeNs + 2); in TEST()
225 durationProducer.flushIfNeededLocked(bucketStartTimeNs + 2 * bucketSizeNs + 1); in TEST()
229 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs, buckets2[0].mBucketStartNs); in TEST()
230 EXPECT_EQ(bucketStartTimeNs + 2 * bucketSizeNs, buckets2[0].mBucketEndNs); in TEST()
244 int64_t bucketStartTimeNs = 10000000000; in TEST_P() local
260 wizard, protoHash, dimensions, bucketStartTimeNs, bucketStartTimeNs, provider); in TEST_P()
262 int64_t startTimeNs = bucketStartTimeNs + 1 * NS_PER_SEC; in TEST_P()
267 EXPECT_EQ(bucketStartTimeNs, durationProducer.mCurrentBucketStartTimeNs); in TEST_P()
269 int64_t partialBucketSplitTimeNs = bucketStartTimeNs + 15 * NS_PER_SEC; in TEST_P()
281 EXPECT_EQ(bucketStartTimeNs, buckets[0].mBucketStartNs); in TEST_P()
295 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs, buckets[1].mBucketEndNs); in TEST_P()
296 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs - partialBucketSplitTimeNs, buckets[1].mDuration); in TEST_P()
297 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs, buckets[2].mBucketStartNs); in TEST_P()
298 EXPECT_EQ(bucketStartTimeNs + 2 * bucketSizeNs, buckets[2].mBucketEndNs); in TEST_P()
309 int64_t bucketStartTimeNs = 10000000000; in TEST_P() local
325 wizard, protoHash, dimensions, bucketStartTimeNs, bucketStartTimeNs, provider); in TEST_P()
327 int64_t startTimeNs = bucketStartTimeNs + 1 * NS_PER_SEC; in TEST_P()
332 EXPECT_EQ(bucketStartTimeNs, durationProducer.mCurrentBucketStartTimeNs); in TEST_P()
334 int64_t partialBucketSplitTimeNs = bucketStartTimeNs + 65 * NS_PER_SEC; in TEST_P()
346 EXPECT_EQ(bucketStartTimeNs, buckets[0].mBucketStartNs); in TEST_P()
347 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs, buckets[0].mBucketEndNs); in TEST_P()
348 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs - startTimeNs, buckets[0].mDuration); in TEST_P()
349 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs, buckets[1].mBucketStartNs); in TEST_P()
351 EXPECT_EQ(partialBucketSplitTimeNs - (bucketStartTimeNs + bucketSizeNs), buckets[1].mDuration); in TEST_P()
363 EXPECT_EQ(bucketStartTimeNs + 2 * bucketSizeNs, buckets[2].mBucketEndNs); in TEST_P()
364 EXPECT_EQ(bucketStartTimeNs + 2 * bucketSizeNs - partialBucketSplitTimeNs, in TEST_P()
370 int64_t bucketStartTimeNs = 10000000000; in TEST_P() local
391 wizard, protoHash, dimensions, bucketStartTimeNs, bucketStartTimeNs, provider); in TEST_P()
394 durationProducer.addAnomalyTracker(alert, alarmMonitor, UPDATE_NEW, bucketStartTimeNs); in TEST_P()
397 int64_t startTimeNs = bucketStartTimeNs + 1; in TEST_P()
402 int64_t partialBucketSplitTimeNs = bucketStartTimeNs + 15 * NS_PER_SEC; in TEST_P()
418 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs - startTimeNs, in TEST_P()
423 int64_t bucketStartTimeNs = 10000000000; in TEST_P() local
440 wizard, protoHash, dimensions, bucketStartTimeNs, bucketStartTimeNs, provider); in TEST_P()
442 int64_t startTimeNs = bucketStartTimeNs + 1; in TEST_P()
447 EXPECT_EQ(bucketStartTimeNs, durationProducer.mCurrentBucketStartTimeNs); in TEST_P()
449 int64_t partialBucketSplitTimeNs = bucketStartTimeNs + 15 * NS_PER_SEC; in TEST_P()
469 durationProducer.flushIfNeededLocked(bucketStartTimeNs + 3 * bucketSizeNs + 1); in TEST_P()
473 EXPECT_EQ(bucketStartTimeNs + 2 * bucketSizeNs, buckets[0].mBucketStartNs); in TEST_P()
474 EXPECT_EQ(bucketStartTimeNs + 3 * bucketSizeNs, buckets[0].mBucketEndNs); in TEST_P()
479 int64_t bucketStartTimeNs = 10000000000; in TEST_P() local
496 wizard, protoHash, dimensions, bucketStartTimeNs, bucketStartTimeNs, provider); in TEST_P()
498 int64_t startTimeNs = bucketStartTimeNs + 1; in TEST_P()
503 EXPECT_EQ(bucketStartTimeNs, durationProducer.mCurrentBucketStartTimeNs); in TEST_P()
505 int64_t partialBucketSplitTimeNs = bucketStartTimeNs + 65 * NS_PER_SEC; in TEST_P()
526 durationProducer.flushIfNeededLocked(bucketStartTimeNs + 2 * bucketSizeNs + 1); in TEST_P()
531 EXPECT_EQ(bucketStartTimeNs + 2 * bucketSizeNs, buckets[0].mBucketEndNs); in TEST_P()
543 int64_t bucketStartTimeNs = 10000000000; in TEST() local
559 wizard, protoHash, dimensions, bucketStartTimeNs, bucketStartTimeNs, provider); in TEST()
561 int64_t startTimeNs = bucketStartTimeNs + 1 * NS_PER_SEC; in TEST()
566 EXPECT_EQ(bucketStartTimeNs, durationProducer.mCurrentBucketStartTimeNs); in TEST()
568 int64_t appUpgradeTimeNs = bucketStartTimeNs + 15 * NS_PER_SEC; in TEST()
581 EXPECT_EQ(bucketStartTimeNs, bucket.mBucketStartNs); in TEST()
582 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs, bucket.mBucketEndNs); in TEST()
588 int64_t bucketStartTimeNs = 10000000000; in TEST() local
601 makeLogEvent(&event1, bucketStartTimeNs + 50, tagId); in TEST()
603 makeLogEvent(&event2, bucketStartTimeNs + 100, tagId); in TEST()
605 makeLogEvent(&event3, bucketStartTimeNs + 150, tagId); in TEST()
607 makeLogEvent(&event4, bucketStartTimeNs + bucketSizeNs + 5, tagId); in TEST()
613 bucketStartTimeNs, bucketStartTimeNs, provider); in TEST()
615 durationProducer.onConditionChanged(true /* condition */, bucketStartTimeNs + 5); in TEST()
619 durationProducer.onConditionChanged(false /* condition */, bucketStartTimeNs + 200); in TEST()
620 durationProducer.flushIfNeededLocked(bucketStartTimeNs + bucketSizeNs + 1); in TEST()