Lines Matching refs:bucketStartTimeNs
95 int64_t bucketStartTimeNs = 10000000000; in TEST() local
97 int64_t bucket2StartTimeNs = bucketStartTimeNs + bucketSizeNs; in TEST()
98 int64_t bucket3StartTimeNs = bucketStartTimeNs + 2 * bucketSizeNs; in TEST()
108 wizard, protoHash, bucketStartTimeNs, bucketStartTimeNs, in TEST()
113 makeLogEvent(&event1, bucketStartTimeNs + 1, tagId); in TEST()
115 makeLogEvent(&event2, bucketStartTimeNs + 2, tagId); in TEST()
121 countProducer.flushIfNeededLocked(bucketStartTimeNs + 2); in TEST()
125 countProducer.flushIfNeededLocked(bucketStartTimeNs + bucketSizeNs + 1); in TEST()
131 EXPECT_EQ(bucketStartTimeNs, buckets[0].mBucketStartNs); in TEST()
132 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs, buckets[0].mBucketEndNs); in TEST()
137 makeLogEvent(&event3, bucketStartTimeNs + bucketSizeNs + 2, tagId); in TEST()
141 countProducer.flushIfNeededLocked(bucketStartTimeNs + 2 * bucketSizeNs + 1); in TEST()
152 countProducer.flushIfNeededLocked(bucketStartTimeNs + 3 * bucketSizeNs + 1); in TEST()
161 int64_t bucketStartTimeNs = 10000000000; in TEST() local
173 protoHash, bucketStartTimeNs, bucketStartTimeNs, provider); in TEST()
176 countProducer.onConditionChanged(true, bucketStartTimeNs); in TEST()
177 assertConditionTimer(countProducer.mConditionTimer, true, 0, bucketStartTimeNs); in TEST()
180 makeLogEvent(&event1, bucketStartTimeNs + 1, /*atomId=*/1); in TEST()
185 countProducer.onConditionChanged(false /*new condition*/, bucketStartTimeNs + 2); in TEST()
186 assertConditionTimer(countProducer.mConditionTimer, false, 2, bucketStartTimeNs + 2); in TEST()
190 makeLogEvent(&event2, bucketStartTimeNs + 10, /*atomId=*/1); in TEST()
194 countProducer.flushIfNeededLocked(bucketStartTimeNs + bucketSizeNs + 1); in TEST()
202 EXPECT_EQ(bucketStartTimeNs, bucketInfo.mBucketStartNs); in TEST()
203 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs, bucketInfo.mBucketEndNs); in TEST()
208 int64_t bucketStartTimeNs = 10000000000; in TEST() local
224 makeLogEvent(&event1, bucketStartTimeNs + 1, tagId, /*uid=*/"111"); in TEST()
227 makeLogEvent(&event2, bucketStartTimeNs + 10, tagId, /*uid=*/"222"); in TEST()
246 bucketStartTimeNs, bucketStartTimeNs, provider); in TEST()
249 countProducer.flushIfNeededLocked(bucketStartTimeNs + 1); in TEST()
253 countProducer.flushIfNeededLocked(bucketStartTimeNs + bucketSizeNs + 1); in TEST()
260 EXPECT_EQ(bucketStartTimeNs, bucketInfo.mBucketStartNs); in TEST()
261 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs, bucketInfo.mBucketEndNs); in TEST()
267 int64_t bucketStartTimeNs = 10000000000; in TEST_P() local
269 int64_t eventTimeNs = bucketStartTimeNs + 15 * NS_PER_SEC; in TEST_P()
285 protoHash, bucketStartTimeNs, bucketStartTimeNs, provider); in TEST_P()
288 countProducer.addAnomalyTracker(alert, alarmMonitor, UPDATE_NEW, bucketStartTimeNs); in TEST_P()
293 makeLogEvent(&event1, bucketStartTimeNs + 1, tagId, /*uid=*/"111"); in TEST_P()
309 EXPECT_EQ(bucketStartTimeNs, in TEST_P()
321 makeLogEvent(&event2, bucketStartTimeNs + 59 * NS_PER_SEC + 10, tagId, /*uid=*/"222"); in TEST_P()
330 makeLogEvent(&event3, bucketStartTimeNs + 62 * NS_PER_SEC + 10, tagId, /*uid=*/"333"); in TEST_P()
339 int64_t bucketStartTimeNs = 10000000000; in TEST_P() local
341 int64_t eventTimeNs = bucketStartTimeNs + 65 * NS_PER_SEC; in TEST_P()
354 protoHash, bucketStartTimeNs, bucketStartTimeNs, provider); in TEST_P()
358 makeLogEvent(&event1, bucketStartTimeNs + 1, tagId, /*uid=*/"111"); in TEST_P()
374 EXPECT_EQ(bucketStartTimeNs, in TEST_P()
376 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs, in TEST_P()
382 makeLogEvent(&event2, bucketStartTimeNs + 70 * NS_PER_SEC + 10, tagId, /*uid=*/"222"); in TEST_P()
388 makeLogEvent(&event3, bucketStartTimeNs + 121 * NS_PER_SEC + 10, tagId, /*uid=*/"333"); in TEST_P()
393 EXPECT_EQ(bucketStartTimeNs + 2 * bucketSizeNs, in TEST_P()
399 int64_t bucketStartTimeNs = 10000000000; in TEST() local
401 int64_t eventTimeNs = bucketStartTimeNs + 15 * NS_PER_SEC; in TEST()
416 protoHash, bucketStartTimeNs, bucketStartTimeNs, provider); in TEST()
419 countProducer.addAnomalyTracker(alert, alarmMonitor, UPDATE_NEW, bucketStartTimeNs); in TEST()
423 makeLogEvent(&event1, bucketStartTimeNs + 1, tagId, /*uid=*/"111"); in TEST()
434 EXPECT_EQ(bucketStartTimeNs, countProducer.mCurrentBucketStartTimeNs); in TEST()
444 EXPECT_EQ(bucketStartTimeNs, countProducer.mCurrentBucketStartTimeNs); in TEST()
450 makeLogEvent(&event3, bucketStartTimeNs + 62 * NS_PER_SEC + 10, tagId, /*uid=*/"333"); in TEST()
453 EXPECT_EQ(bucketStartTimeNs, in TEST()
455 EXPECT_EQ(bucketStartTimeNs + 60 * NS_PER_SEC, in TEST()
458 EXPECT_EQ(bucketStartTimeNs + 60 * NS_PER_SEC, countProducer.mCurrentBucketStartTimeNs); in TEST()
473 int64_t bucketStartTimeNs = 10000000000; in TEST() local
475 int64_t bucket2StartTimeNs = bucketStartTimeNs + bucketSizeNs; in TEST()
476 int64_t bucket3StartTimeNs = bucketStartTimeNs + 2 * bucketSizeNs; in TEST()
485 wizard, protoHash, bucketStartTimeNs, bucketStartTimeNs, in TEST()
489 countProducer.addAnomalyTracker(alert, alarmMonitor, UPDATE_NEW, bucketStartTimeNs); in TEST()
493 makeLogEvent(&event1, bucketStartTimeNs + 1, tagId); in TEST()
495 makeLogEvent(&event2, bucketStartTimeNs + 2, tagId); in TEST()
497 makeLogEvent(&event3, bucketStartTimeNs + 2 * bucketSizeNs + 1, tagId); in TEST()
499 makeLogEvent(&event4, bucketStartTimeNs + 3 * bucketSizeNs + 1, tagId); in TEST()
501 makeLogEvent(&event5, bucketStartTimeNs + 3 * bucketSizeNs + 2, tagId); in TEST()
503 makeLogEvent(&event6, bucketStartTimeNs + 3 * bucketSizeNs + 3, tagId); in TEST()
505 makeLogEvent(&event7, bucketStartTimeNs + 3 * bucketSizeNs + 2 * NS_PER_SEC, tagId); in TEST()
560 const int64_t bucketStartTimeNs = 10000000000; in TEST() local
572 bucketStartTimeNs, bucketStartTimeNs, provider); in TEST()
578 StatsLogReport report = onDumpReport(countProducer, bucketStartTimeNs + 50); in TEST()
586 StatsLogReport report = onDumpReport(countProducer, bucketStartTimeNs + 150); in TEST()
597 StatsLogReport report = onDumpReport(countProducer, bucketStartTimeNs + 250); in TEST()
604 const int64_t bucketStartTimeNs = 10000000000; in TEST() local
615 bucketStartTimeNs, bucketStartTimeNs, provider); in TEST()
621 StatsLogReport report = onDumpReport(countProducer, bucketStartTimeNs + 50); in TEST()
629 StatsLogReport report = onDumpReport(countProducer, bucketStartTimeNs + 150); in TEST()
636 const int64_t bucketStartTimeNs = 10000000000; in TEST() local
647 bucketStartTimeNs, bucketStartTimeNs, provider); in TEST()
653 StatsLogReport report = onDumpReport(countProducer, bucketStartTimeNs + 50); in TEST()
660 StatsLogReport report = onDumpReport(countProducer, bucketStartTimeNs + 150); in TEST()