Lines Matching refs:bucketStartTimeNs
88 int64_t bucketStartTimeNs = 10000000000; in TEST() local
90 int64_t bucket2StartTimeNs = bucketStartTimeNs + bucketSizeNs; in TEST()
91 int64_t bucket3StartTimeNs = bucketStartTimeNs + 2 * bucketSizeNs; in TEST()
101 wizard, protoHash, bucketStartTimeNs, bucketStartTimeNs, in TEST()
106 makeLogEvent(&event1, bucketStartTimeNs + 1, tagId); in TEST()
108 makeLogEvent(&event2, bucketStartTimeNs + 2, tagId); in TEST()
114 countProducer.flushIfNeededLocked(bucketStartTimeNs + 2); in TEST()
118 countProducer.flushIfNeededLocked(bucketStartTimeNs + bucketSizeNs + 1); in TEST()
124 EXPECT_EQ(bucketStartTimeNs, buckets[0].mBucketStartNs); in TEST()
125 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs, buckets[0].mBucketEndNs); in TEST()
130 makeLogEvent(&event3, bucketStartTimeNs + bucketSizeNs + 2, tagId); in TEST()
134 countProducer.flushIfNeededLocked(bucketStartTimeNs + 2 * bucketSizeNs + 1); in TEST()
145 countProducer.flushIfNeededLocked(bucketStartTimeNs + 3 * bucketSizeNs + 1); in TEST()
154 int64_t bucketStartTimeNs = 10000000000; in TEST() local
166 protoHash, bucketStartTimeNs, bucketStartTimeNs, provider); in TEST()
169 countProducer.onConditionChanged(true, bucketStartTimeNs); in TEST()
170 assertConditionTimer(countProducer.mConditionTimer, true, 0, bucketStartTimeNs); in TEST()
173 makeLogEvent(&event1, bucketStartTimeNs + 1, /*atomId=*/1); in TEST()
178 countProducer.onConditionChanged(false /*new condition*/, bucketStartTimeNs + 2); in TEST()
179 assertConditionTimer(countProducer.mConditionTimer, false, 2, bucketStartTimeNs + 2); in TEST()
183 makeLogEvent(&event2, bucketStartTimeNs + 10, /*atomId=*/1); in TEST()
187 countProducer.flushIfNeededLocked(bucketStartTimeNs + bucketSizeNs + 1); in TEST()
195 EXPECT_EQ(bucketStartTimeNs, bucketInfo.mBucketStartNs); in TEST()
196 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs, bucketInfo.mBucketEndNs); in TEST()
201 int64_t bucketStartTimeNs = 10000000000; in TEST() local
217 makeLogEvent(&event1, bucketStartTimeNs + 1, tagId, /*uid=*/"111"); in TEST()
220 makeLogEvent(&event2, bucketStartTimeNs + 10, tagId, /*uid=*/"222"); in TEST()
239 bucketStartTimeNs, bucketStartTimeNs, provider); in TEST()
242 countProducer.flushIfNeededLocked(bucketStartTimeNs + 1); in TEST()
246 countProducer.flushIfNeededLocked(bucketStartTimeNs + bucketSizeNs + 1); in TEST()
253 EXPECT_EQ(bucketStartTimeNs, bucketInfo.mBucketStartNs); in TEST()
254 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs, bucketInfo.mBucketEndNs); in TEST()
260 int64_t bucketStartTimeNs = 10000000000; in TEST_P() local
262 int64_t eventTimeNs = bucketStartTimeNs + 15 * NS_PER_SEC; in TEST_P()
278 protoHash, bucketStartTimeNs, bucketStartTimeNs, provider); in TEST_P()
281 countProducer.addAnomalyTracker(alert, alarmMonitor, UPDATE_NEW, bucketStartTimeNs); in TEST_P()
286 makeLogEvent(&event1, bucketStartTimeNs + 1, tagId, /*uid=*/"111"); in TEST_P()
302 EXPECT_EQ(bucketStartTimeNs, in TEST_P()
314 makeLogEvent(&event2, bucketStartTimeNs + 59 * NS_PER_SEC + 10, tagId, /*uid=*/"222"); in TEST_P()
323 makeLogEvent(&event3, bucketStartTimeNs + 62 * NS_PER_SEC + 10, tagId, /*uid=*/"333"); in TEST_P()
332 int64_t bucketStartTimeNs = 10000000000; in TEST_P() local
334 int64_t eventTimeNs = bucketStartTimeNs + 65 * NS_PER_SEC; in TEST_P()
347 protoHash, bucketStartTimeNs, bucketStartTimeNs, provider); in TEST_P()
351 makeLogEvent(&event1, bucketStartTimeNs + 1, tagId, /*uid=*/"111"); in TEST_P()
367 EXPECT_EQ(bucketStartTimeNs, in TEST_P()
369 EXPECT_EQ(bucketStartTimeNs + bucketSizeNs, in TEST_P()
375 makeLogEvent(&event2, bucketStartTimeNs + 70 * NS_PER_SEC + 10, tagId, /*uid=*/"222"); in TEST_P()
381 makeLogEvent(&event3, bucketStartTimeNs + 121 * NS_PER_SEC + 10, tagId, /*uid=*/"333"); in TEST_P()
386 EXPECT_EQ(bucketStartTimeNs + 2 * bucketSizeNs, in TEST_P()
392 int64_t bucketStartTimeNs = 10000000000; in TEST() local
394 int64_t eventTimeNs = bucketStartTimeNs + 15 * NS_PER_SEC; in TEST()
409 protoHash, bucketStartTimeNs, bucketStartTimeNs, provider); in TEST()
412 countProducer.addAnomalyTracker(alert, alarmMonitor, UPDATE_NEW, bucketStartTimeNs); in TEST()
416 makeLogEvent(&event1, bucketStartTimeNs + 1, tagId, /*uid=*/"111"); in TEST()
427 EXPECT_EQ(bucketStartTimeNs, countProducer.mCurrentBucketStartTimeNs); in TEST()
437 EXPECT_EQ(bucketStartTimeNs, countProducer.mCurrentBucketStartTimeNs); in TEST()
443 makeLogEvent(&event3, bucketStartTimeNs + 62 * NS_PER_SEC + 10, tagId, /*uid=*/"333"); in TEST()
446 EXPECT_EQ(bucketStartTimeNs, in TEST()
448 EXPECT_EQ(bucketStartTimeNs + 60 * NS_PER_SEC, in TEST()
451 EXPECT_EQ(bucketStartTimeNs + 60 * NS_PER_SEC, countProducer.mCurrentBucketStartTimeNs); in TEST()
466 int64_t bucketStartTimeNs = 10000000000; in TEST() local
468 int64_t bucket2StartTimeNs = bucketStartTimeNs + bucketSizeNs; in TEST()
469 int64_t bucket3StartTimeNs = bucketStartTimeNs + 2 * bucketSizeNs; in TEST()
478 wizard, protoHash, bucketStartTimeNs, bucketStartTimeNs, in TEST()
482 countProducer.addAnomalyTracker(alert, alarmMonitor, UPDATE_NEW, bucketStartTimeNs); in TEST()
486 makeLogEvent(&event1, bucketStartTimeNs + 1, tagId); in TEST()
488 makeLogEvent(&event2, bucketStartTimeNs + 2, tagId); in TEST()
490 makeLogEvent(&event3, bucketStartTimeNs + 2 * bucketSizeNs + 1, tagId); in TEST()
492 makeLogEvent(&event4, bucketStartTimeNs + 3 * bucketSizeNs + 1, tagId); in TEST()
494 makeLogEvent(&event5, bucketStartTimeNs + 3 * bucketSizeNs + 2, tagId); in TEST()
496 makeLogEvent(&event6, bucketStartTimeNs + 3 * bucketSizeNs + 3, tagId); in TEST()
498 makeLogEvent(&event7, bucketStartTimeNs + 3 * bucketSizeNs + 2 * NS_PER_SEC, tagId); in TEST()