Lines Matching refs:bucketStartTimeNs
96 int64_t bucketStartTimeNs = 10000000000; in TEST() local
106 makeLogEvent(&event1, bucketStartTimeNs + 1, tagId); in TEST()
108 makeLogEvent(&event2, bucketStartTimeNs + bucketSizeNs + 2, tagId); in TEST()
116 wizard, protoHash, dimensions, bucketStartTimeNs, bucketStartTimeNs, provider); in TEST()
120 durationProducer.flushIfNeededLocked(bucketStartTimeNs + 2 * bucketSizeNs + 1); in TEST()
126 EXPECT_EQ(bucketStartTimeNs, buckets[0].mBucketStartNs); in TEST()
127 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs, buckets[0].mBucketEndNs); in TEST()
129 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs, buckets[1].mBucketStartNs); in TEST()
130 EXPECT_EQ(bucketStartTimeNs + 2 * bucketSizeNs, buckets[1].mBucketEndNs); in TEST()
136 int64_t bucketStartTimeNs = 10000000000; in TEST() local
146 makeLogEvent(&event1, bucketStartTimeNs + 1, tagId); in TEST()
148 makeLogEvent(&event2, bucketStartTimeNs + 2, tagId); in TEST()
150 makeLogEvent(&event3, bucketStartTimeNs + bucketSizeNs + 1, tagId); in TEST()
152 makeLogEvent(&event4, bucketStartTimeNs + bucketSizeNs + 3, tagId); in TEST()
161 bucketStartTimeNs, bucketStartTimeNs, provider); in TEST()
170 durationProducer.flushIfNeededLocked(bucketStartTimeNs + bucketSizeNs + 1); in TEST()
173 int64_t conditionStartTimeNs = bucketStartTimeNs + bucketSizeNs + 2; in TEST()
174 int64_t bucket2EndTimeNs = bucketStartTimeNs + 2 * bucketSizeNs; in TEST()
187 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs, buckets2[0].mBucketStartNs); in TEST()
195 int64_t bucketStartTimeNs = 10000000000; in TEST() local
205 makeLogEvent(&event1, bucketStartTimeNs + 1, tagId); in TEST()
207 makeLogEvent(&event2, bucketStartTimeNs + 2, tagId); in TEST()
209 makeLogEvent(&event3, bucketStartTimeNs + bucketSizeNs + 1, tagId); in TEST()
211 makeLogEvent(&event4, bucketStartTimeNs + bucketSizeNs + 3, tagId); in TEST()
220 bucketStartTimeNs, bucketStartTimeNs, provider); in TEST()
227 durationProducer.flushIfNeededLocked(bucketStartTimeNs + bucketSizeNs + 1); in TEST()
231 durationProducer.onConditionChanged(true /* condition */, bucketStartTimeNs + bucketSizeNs + 2); in TEST()
233 durationProducer.flushIfNeededLocked(bucketStartTimeNs + 2 * bucketSizeNs + 1); in TEST()
237 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs, buckets2[0].mBucketStartNs); in TEST()
238 EXPECT_EQ(bucketStartTimeNs + 2 * bucketSizeNs, buckets2[0].mBucketEndNs); in TEST()
252 int64_t bucketStartTimeNs = 10000000000; in TEST_P() local
268 wizard, protoHash, dimensions, bucketStartTimeNs, bucketStartTimeNs, provider); in TEST_P()
270 int64_t startTimeNs = bucketStartTimeNs + 1 * NS_PER_SEC; in TEST_P()
275 EXPECT_EQ(bucketStartTimeNs, durationProducer.mCurrentBucketStartTimeNs); in TEST_P()
277 int64_t partialBucketSplitTimeNs = bucketStartTimeNs + 15 * NS_PER_SEC; in TEST_P()
289 EXPECT_EQ(bucketStartTimeNs, buckets[0].mBucketStartNs); in TEST_P()
303 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs, buckets[1].mBucketEndNs); in TEST_P()
304 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs - partialBucketSplitTimeNs, buckets[1].mDuration); in TEST_P()
305 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs, buckets[2].mBucketStartNs); in TEST_P()
306 EXPECT_EQ(bucketStartTimeNs + 2 * bucketSizeNs, buckets[2].mBucketEndNs); in TEST_P()
317 int64_t bucketStartTimeNs = 10000000000; in TEST_P() local
333 wizard, protoHash, dimensions, bucketStartTimeNs, bucketStartTimeNs, provider); in TEST_P()
335 int64_t startTimeNs = bucketStartTimeNs + 1 * NS_PER_SEC; in TEST_P()
340 EXPECT_EQ(bucketStartTimeNs, durationProducer.mCurrentBucketStartTimeNs); in TEST_P()
342 int64_t partialBucketSplitTimeNs = bucketStartTimeNs + 65 * NS_PER_SEC; in TEST_P()
354 EXPECT_EQ(bucketStartTimeNs, buckets[0].mBucketStartNs); in TEST_P()
355 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs, buckets[0].mBucketEndNs); in TEST_P()
356 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs - startTimeNs, buckets[0].mDuration); in TEST_P()
357 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs, buckets[1].mBucketStartNs); in TEST_P()
359 EXPECT_EQ(partialBucketSplitTimeNs - (bucketStartTimeNs + bucketSizeNs), buckets[1].mDuration); in TEST_P()
371 EXPECT_EQ(bucketStartTimeNs + 2 * bucketSizeNs, buckets[2].mBucketEndNs); in TEST_P()
372 EXPECT_EQ(bucketStartTimeNs + 2 * bucketSizeNs - partialBucketSplitTimeNs, in TEST_P()
378 int64_t bucketStartTimeNs = 10000000000; in TEST_P() local
399 wizard, protoHash, dimensions, bucketStartTimeNs, bucketStartTimeNs, provider); in TEST_P()
402 durationProducer.addAnomalyTracker(alert, alarmMonitor, UPDATE_NEW, bucketStartTimeNs); in TEST_P()
405 int64_t startTimeNs = bucketStartTimeNs + 1; in TEST_P()
410 int64_t partialBucketSplitTimeNs = bucketStartTimeNs + 15 * NS_PER_SEC; in TEST_P()
426 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs - startTimeNs, in TEST_P()
431 int64_t bucketStartTimeNs = 10000000000; in TEST_P() local
448 wizard, protoHash, dimensions, bucketStartTimeNs, bucketStartTimeNs, provider); in TEST_P()
450 int64_t startTimeNs = bucketStartTimeNs + 1; in TEST_P()
455 EXPECT_EQ(bucketStartTimeNs, durationProducer.mCurrentBucketStartTimeNs); in TEST_P()
457 int64_t partialBucketSplitTimeNs = bucketStartTimeNs + 15 * NS_PER_SEC; in TEST_P()
477 durationProducer.flushIfNeededLocked(bucketStartTimeNs + 3 * bucketSizeNs + 1); in TEST_P()
481 EXPECT_EQ(bucketStartTimeNs + 2 * bucketSizeNs, buckets[0].mBucketStartNs); in TEST_P()
482 EXPECT_EQ(bucketStartTimeNs + 3 * bucketSizeNs, buckets[0].mBucketEndNs); in TEST_P()
487 int64_t bucketStartTimeNs = 10000000000; in TEST_P() local
504 wizard, protoHash, dimensions, bucketStartTimeNs, bucketStartTimeNs, provider); in TEST_P()
506 int64_t startTimeNs = bucketStartTimeNs + 1; in TEST_P()
511 EXPECT_EQ(bucketStartTimeNs, durationProducer.mCurrentBucketStartTimeNs); in TEST_P()
513 int64_t partialBucketSplitTimeNs = bucketStartTimeNs + 65 * NS_PER_SEC; in TEST_P()
534 durationProducer.flushIfNeededLocked(bucketStartTimeNs + 2 * bucketSizeNs + 1); in TEST_P()
539 EXPECT_EQ(bucketStartTimeNs + 2 * bucketSizeNs, buckets[0].mBucketEndNs); in TEST_P()
551 int64_t bucketStartTimeNs = 10000000000; in TEST() local
567 wizard, protoHash, dimensions, bucketStartTimeNs, bucketStartTimeNs, provider); in TEST()
569 int64_t startTimeNs = bucketStartTimeNs + 1 * NS_PER_SEC; in TEST()
574 EXPECT_EQ(bucketStartTimeNs, durationProducer.mCurrentBucketStartTimeNs); in TEST()
576 int64_t appUpgradeTimeNs = bucketStartTimeNs + 15 * NS_PER_SEC; in TEST()
589 EXPECT_EQ(bucketStartTimeNs, bucket.mBucketStartNs); in TEST()
590 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs, bucket.mBucketEndNs); in TEST()
596 int64_t bucketStartTimeNs = 10000000000; in TEST() local
609 makeLogEvent(&event1, bucketStartTimeNs + 50, tagId); in TEST()
611 makeLogEvent(&event2, bucketStartTimeNs + 100, tagId); in TEST()
613 makeLogEvent(&event3, bucketStartTimeNs + 150, tagId); in TEST()
615 makeLogEvent(&event4, bucketStartTimeNs + bucketSizeNs + 5, tagId); in TEST()
621 bucketStartTimeNs, bucketStartTimeNs, provider); in TEST()
623 durationProducer.onConditionChanged(true /* condition */, bucketStartTimeNs + 5); in TEST()
627 durationProducer.onConditionChanged(false /* condition */, bucketStartTimeNs + 200); in TEST()
628 durationProducer.flushIfNeededLocked(bucketStartTimeNs + bucketSizeNs + 1); in TEST()
637 const int64_t bucketStartTimeNs = 10000000000; in TEST() local
652 bucketStartTimeNs, bucketStartTimeNs, provider); in TEST()
658 StatsLogReport report = onDumpReport(durationProducer, bucketStartTimeNs + 50); in TEST()
666 StatsLogReport report = onDumpReport(durationProducer, bucketStartTimeNs + 150); in TEST()
673 const int64_t bucketStartTimeNs = 10000000000; in TEST() local
688 bucketStartTimeNs, bucketStartTimeNs, provider); in TEST()
694 StatsLogReport report = onDumpReport(durationProducer, bucketStartTimeNs + 50); in TEST()
702 StatsLogReport report = onDumpReport(durationProducer, bucketStartTimeNs + 150); in TEST()
709 const int64_t bucketStartTimeNs = 10000000000; in TEST() local
724 bucketStartTimeNs, bucketStartTimeNs, provider); in TEST()
729 StatsLogReport report = onDumpReport(durationProducer, bucketStartTimeNs + 50); in TEST()
736 StatsLogReport report = onDumpReport(durationProducer, bucketStartTimeNs + 150); in TEST()