Lines Matching refs:bucketStartTimeNs
69 int64_t bucketStartTimeNs = 10000000000; in TEST_F() local
70 int64_t eventStartTimeNs = bucketStartTimeNs + 1; in TEST_F()
77 CreateNoValuesLogEvent(&event1, 1 /*tagId*/, bucketStartTimeNs + 1); in TEST_F()
80 CreateNoValuesLogEvent(&event2, 1 /*tagId*/, bucketStartTimeNs + 2); in TEST_F()
86 wizard, protoHash, bucketStartTimeNs, provider); in TEST_F()
94 eventProducer.onDumpReport(bucketStartTimeNs + 20, true /*include current partial bucket*/, in TEST_F()
101 EXPECT_EQ(bucketStartTimeNs + 1, report.event_metrics().data(0).elapsed_timestamp_nanos()); in TEST_F()
102 EXPECT_EQ(bucketStartTimeNs + 2, report.event_metrics().data(1).elapsed_timestamp_nanos()); in TEST_F()
106 int64_t bucketStartTimeNs = 10000000000; in TEST_F() local
107 int64_t eventStartTimeNs = bucketStartTimeNs + 1; in TEST_F()
115 CreateNoValuesLogEvent(&event1, 1 /*tagId*/, bucketStartTimeNs + 1); in TEST_F()
118 CreateNoValuesLogEvent(&event2, 1 /*tagId*/, bucketStartTimeNs + 10); in TEST_F()
125 bucketStartTimeNs, provider); in TEST_F()
127 eventProducer.onConditionChanged(true /*condition*/, bucketStartTimeNs); in TEST_F()
130 eventProducer.onConditionChanged(false /*condition*/, bucketStartTimeNs + 2); in TEST_F()
137 eventProducer.onDumpReport(bucketStartTimeNs + 20, true /*include current partial bucket*/, in TEST_F()
144 EXPECT_EQ(bucketStartTimeNs + 1, report.event_metrics().data(0).elapsed_timestamp_nanos()); in TEST_F()
148 int64_t bucketStartTimeNs = 10000000000; in TEST_F() local
163 makeLogEvent(&event1, 1 /*tagId*/, bucketStartTimeNs + 1, "111"); in TEST_F()
169 makeLogEvent(&event2, 1 /*tagId*/, bucketStartTimeNs + 10, "222"); in TEST_F()
183 bucketStartTimeNs, provider); in TEST_F()
191 eventProducer.onDumpReport(bucketStartTimeNs + 20, true /*include current partial bucket*/, in TEST_F()
198 EXPECT_EQ(bucketStartTimeNs + 10, report.event_metrics().data(0).elapsed_timestamp_nanos()); in TEST_F()
202 int64_t bucketStartTimeNs = 10000000000; in TEST_F() local
209 makeLogEvent(&event1, tagId, bucketStartTimeNs + 10, "111"); in TEST_F()
211 makeLogEvent(&event2, tagId, bucketStartTimeNs + 20, "111"); in TEST_F()
213 makeLogEvent(&event3, tagId, bucketStartTimeNs + 30, "111"); in TEST_F()
216 makeLogEvent(&event4, tagId, bucketStartTimeNs + 40, "222"); in TEST_F()
221 wizard, protoHash, bucketStartTimeNs, provider); in TEST_F()
231 eventProducer.onDumpReport(bucketStartTimeNs + 50, true /*include current partial bucket*/, in TEST_F()
241 EXPECT_EQ(atomInfo.elapsed_timestamp_nanos(0), bucketStartTimeNs + 40); in TEST_F()
243 EXPECT_EQ(atomInfo.elapsed_timestamp_nanos(0), bucketStartTimeNs + 10); in TEST_F()
244 EXPECT_EQ(atomInfo.elapsed_timestamp_nanos(1), bucketStartTimeNs + 20); in TEST_F()
245 EXPECT_EQ(atomInfo.elapsed_timestamp_nanos(2), bucketStartTimeNs + 30); in TEST_F()
253 int64_t bucketStartTimeNs = 10000000000; in TEST_F() local
262 makeLogEvent(&event1, tagId, bucketStartTimeNs + 10, "111", &bytesField1); in TEST_F()
264 makeLogEvent(&event2, tagId, bucketStartTimeNs + 20, "111", &bytesField1); in TEST_F()
266 makeLogEvent(&event3, tagId, bucketStartTimeNs + 30, "111", &bytesField1); in TEST_F()
269 makeLogEvent(&event4, tagId, bucketStartTimeNs + 40, "111", &bytesField2); in TEST_F()
274 wizard, protoHash, bucketStartTimeNs, provider); in TEST_F()
284 eventProducer.onDumpReport(bucketStartTimeNs + 50, true /*include current partial bucket*/, in TEST_F()
294 EXPECT_EQ(atomInfo.elapsed_timestamp_nanos(0), bucketStartTimeNs + 40); in TEST_F()
296 EXPECT_EQ(atomInfo.elapsed_timestamp_nanos(0), bucketStartTimeNs + 10); in TEST_F()
297 EXPECT_EQ(atomInfo.elapsed_timestamp_nanos(1), bucketStartTimeNs + 20); in TEST_F()
298 EXPECT_EQ(atomInfo.elapsed_timestamp_nanos(2), bucketStartTimeNs + 30); in TEST_F()
306 int64_t bucketStartTimeNs = 10000000000; in TEST_F() local
314 makeLogEvent(&event1, tagId, bucketStartTimeNs + 10, "111"); in TEST_F()
316 makeLogEvent(&event2, tagId, bucketStartTimeNs + 20, "111"); in TEST_F()
319 makeLogEvent(&event3, tagId2, bucketStartTimeNs + 40, "222"); in TEST_F()
324 wizard, protoHash, bucketStartTimeNs, provider); in TEST_F()
333 eventProducer.onDumpReport(bucketStartTimeNs + 50, true /*include current partial bucket*/, in TEST_F()
343 EXPECT_EQ(atomInfo.elapsed_timestamp_nanos(0), bucketStartTimeNs + 40); in TEST_F()
345 EXPECT_EQ(atomInfo.elapsed_timestamp_nanos(0), bucketStartTimeNs + 10); in TEST_F()
346 EXPECT_EQ(atomInfo.elapsed_timestamp_nanos(1), bucketStartTimeNs + 20); in TEST_F()
354 int64_t bucketStartTimeNs = 10000000000; in TEST_F() local
361 makeLogEvent(&event1, tagId, bucketStartTimeNs + 10, "111"); in TEST_F()
365 nullptr, protoHash, bucketStartTimeNs, provider); in TEST_F()
382 eventProducer.onDumpReport(bucketStartTimeNs + 50, true /*include current partial bucket*/, in TEST_F()
412 eventProducer.onDumpReport(bucketStartTimeNs + 150, true /*include current partial bucket*/, in TEST_F()
444 eventProducer.onDumpReport(bucketStartTimeNs + 250, true /*include current partial bucket*/, in TEST_F()
461 int64_t bucketStartTimeNs = 10000000000; in TEST_F() local
468 makeLogEvent(&event1, tagId, bucketStartTimeNs + 10, "111"); in TEST_F()
472 nullptr, protoHash, bucketStartTimeNs, provider); in TEST_F()
488 eventProducer.dropData(bucketStartTimeNs + 100); in TEST_F()
503 eventProducer.dropData(bucketStartTimeNs + 200); in TEST_F()
520 eventProducer.dropData(bucketStartTimeNs + 300); in TEST_F()
535 eventProducer.dropData(bucketStartTimeNs + 400); in TEST_F()
550 eventProducer.dropData(bucketStartTimeNs + 500); in TEST_F()
559 int64_t bucketStartTimeNs = 10000000000; in TEST_F() local
566 makeLogEvent(&event1, tagId, bucketStartTimeNs + 10, "111"); in TEST_F()
570 nullptr, protoHash, bucketStartTimeNs, provider); in TEST_F()
586 eventProducer.clearPastBuckets(bucketStartTimeNs + 100); in TEST_F()
601 eventProducer.clearPastBuckets(bucketStartTimeNs + 200); in TEST_F()
618 eventProducer.clearPastBuckets(bucketStartTimeNs + 300); in TEST_F()
633 eventProducer.clearPastBuckets(bucketStartTimeNs + 400); in TEST_F()
648 eventProducer.clearPastBuckets(bucketStartTimeNs + 500); in TEST_F()
657 const int64_t bucketStartTimeNs = 10000000000; in TEST_F() local
665 nullptr, protoHash, bucketStartTimeNs, provider); in TEST_F()
668 makeLogEvent(&event1, tagId, bucketStartTimeNs + 10, "111"); in TEST_F()
685 eventProducer.onDumpReport(bucketStartTimeNs + 50, true /*include current partial bucket*/, in TEST_F()
715 eventProducer.onDumpReport(bucketStartTimeNs + 150, true /*include current partial bucket*/, in TEST_F()
747 eventProducer.onDumpReport(bucketStartTimeNs + 150, true /*include current partial bucket*/, in TEST_F()