Lines Matching refs:bucketStartTimeNs
77 int64_t bucketStartTimeNs = 10000000000; in TEST_F() local
78 int64_t eventStartTimeNs = bucketStartTimeNs + 1; in TEST_F()
85 CreateNoValuesLogEvent(&event1, 1 /*tagId*/, bucketStartTimeNs + 1); in TEST_F()
88 CreateNoValuesLogEvent(&event2, 1 /*tagId*/, bucketStartTimeNs + 2); in TEST_F()
94 wizard, protoHash, bucketStartTimeNs, provider); in TEST_F()
100 StatsLogReport report = onDumpReport(eventProducer, bucketStartTimeNs + 20); in TEST_F()
104 EXPECT_EQ(bucketStartTimeNs + 1, report.event_metrics().data(0).elapsed_timestamp_nanos()); in TEST_F()
105 EXPECT_EQ(bucketStartTimeNs + 2, report.event_metrics().data(1).elapsed_timestamp_nanos()); in TEST_F()
109 int64_t bucketStartTimeNs = 10000000000; in TEST_F() local
110 int64_t eventStartTimeNs = bucketStartTimeNs + 1; in TEST_F()
118 CreateNoValuesLogEvent(&event1, 1 /*tagId*/, bucketStartTimeNs + 1); in TEST_F()
121 CreateNoValuesLogEvent(&event2, 1 /*tagId*/, bucketStartTimeNs + 10); in TEST_F()
128 bucketStartTimeNs, provider); in TEST_F()
130 eventProducer.onConditionChanged(true /*condition*/, bucketStartTimeNs); in TEST_F()
133 eventProducer.onConditionChanged(false /*condition*/, bucketStartTimeNs + 2); in TEST_F()
138 StatsLogReport report = onDumpReport(eventProducer, bucketStartTimeNs + 20); in TEST_F()
142 EXPECT_EQ(bucketStartTimeNs + 1, report.event_metrics().data(0).elapsed_timestamp_nanos()); in TEST_F()
146 int64_t bucketStartTimeNs = 10000000000; in TEST_F() local
161 makeLogEvent(&event1, 1 /*tagId*/, bucketStartTimeNs + 1, "111"); in TEST_F()
167 makeLogEvent(&event2, 1 /*tagId*/, bucketStartTimeNs + 10, "222"); in TEST_F()
181 bucketStartTimeNs, provider); in TEST_F()
187 StatsLogReport report = onDumpReport(eventProducer, bucketStartTimeNs + 20); in TEST_F()
191 EXPECT_EQ(bucketStartTimeNs + 10, report.event_metrics().data(0).elapsed_timestamp_nanos()); in TEST_F()
195 int64_t bucketStartTimeNs = 10000000000; in TEST_F() local
202 makeLogEvent(&event1, tagId, bucketStartTimeNs + 10, "111"); in TEST_F()
204 makeLogEvent(&event2, tagId, bucketStartTimeNs + 20, "111"); in TEST_F()
206 makeLogEvent(&event3, tagId, bucketStartTimeNs + 30, "111"); in TEST_F()
209 makeLogEvent(&event4, tagId, bucketStartTimeNs + 40, "222"); in TEST_F()
214 wizard, protoHash, bucketStartTimeNs, provider); in TEST_F()
222 StatsLogReport report = onDumpReport(eventProducer, bucketStartTimeNs + 50); in TEST_F()
229 EXPECT_EQ(atomInfo.elapsed_timestamp_nanos(0), bucketStartTimeNs + 40); in TEST_F()
231 EXPECT_EQ(atomInfo.elapsed_timestamp_nanos(0), bucketStartTimeNs + 10); in TEST_F()
232 EXPECT_EQ(atomInfo.elapsed_timestamp_nanos(1), bucketStartTimeNs + 20); in TEST_F()
233 EXPECT_EQ(atomInfo.elapsed_timestamp_nanos(2), bucketStartTimeNs + 30); in TEST_F()
241 int64_t bucketStartTimeNs = 10000000000; in TEST_F() local
250 makeLogEvent(&event1, tagId, bucketStartTimeNs + 10, "111", &bytesField1); in TEST_F()
252 makeLogEvent(&event2, tagId, bucketStartTimeNs + 20, "111", &bytesField1); in TEST_F()
254 makeLogEvent(&event3, tagId, bucketStartTimeNs + 30, "111", &bytesField1); in TEST_F()
257 makeLogEvent(&event4, tagId, bucketStartTimeNs + 40, "111", &bytesField2); in TEST_F()
262 wizard, protoHash, bucketStartTimeNs, provider); in TEST_F()
270 StatsLogReport report = onDumpReport(eventProducer, bucketStartTimeNs + 50); in TEST_F()
277 EXPECT_EQ(atomInfo.elapsed_timestamp_nanos(0), bucketStartTimeNs + 40); in TEST_F()
279 EXPECT_EQ(atomInfo.elapsed_timestamp_nanos(0), bucketStartTimeNs + 10); in TEST_F()
280 EXPECT_EQ(atomInfo.elapsed_timestamp_nanos(1), bucketStartTimeNs + 20); in TEST_F()
281 EXPECT_EQ(atomInfo.elapsed_timestamp_nanos(2), bucketStartTimeNs + 30); in TEST_F()
289 int64_t bucketStartTimeNs = 10000000000; in TEST_F() local
297 makeLogEvent(&event1, tagId, bucketStartTimeNs + 10, "111"); in TEST_F()
299 makeLogEvent(&event2, tagId, bucketStartTimeNs + 20, "111"); in TEST_F()
302 makeLogEvent(&event3, tagId2, bucketStartTimeNs + 40, "222"); in TEST_F()
307 wizard, protoHash, bucketStartTimeNs, provider); in TEST_F()
314 StatsLogReport report = onDumpReport(eventProducer, bucketStartTimeNs + 50); in TEST_F()
322 EXPECT_EQ(atomInfo.elapsed_timestamp_nanos(0), bucketStartTimeNs + 40); in TEST_F()
324 EXPECT_EQ(atomInfo.elapsed_timestamp_nanos(0), bucketStartTimeNs + 10); in TEST_F()
325 EXPECT_EQ(atomInfo.elapsed_timestamp_nanos(1), bucketStartTimeNs + 20); in TEST_F()
333 int64_t bucketStartTimeNs = 10000000000; in TEST_F() local
340 makeLogEvent(&event1, tagId, bucketStartTimeNs + 10, "111"); in TEST_F()
344 nullptr, protoHash, bucketStartTimeNs, provider); in TEST_F()
360 StatsLogReport report = onDumpReport(eventProducer, bucketStartTimeNs + 50); in TEST_F()
386 StatsLogReport report = onDumpReport(eventProducer, bucketStartTimeNs + 150); in TEST_F()
414 StatsLogReport report = onDumpReport(eventProducer, bucketStartTimeNs + 250); in TEST_F()
429 int64_t bucketStartTimeNs = 10000000000; in TEST_F() local
436 makeLogEvent(&event1, tagId, bucketStartTimeNs + 10, "111"); in TEST_F()
440 nullptr, protoHash, bucketStartTimeNs, provider); in TEST_F()
456 eventProducer.dropData(bucketStartTimeNs + 100); in TEST_F()
471 eventProducer.dropData(bucketStartTimeNs + 200); in TEST_F()
488 eventProducer.dropData(bucketStartTimeNs + 300); in TEST_F()
503 eventProducer.dropData(bucketStartTimeNs + 400); in TEST_F()
518 eventProducer.dropData(bucketStartTimeNs + 500); in TEST_F()
527 int64_t bucketStartTimeNs = 10000000000; in TEST_F() local
534 makeLogEvent(&event1, tagId, bucketStartTimeNs + 10, "111"); in TEST_F()
538 nullptr, protoHash, bucketStartTimeNs, provider); in TEST_F()
554 eventProducer.clearPastBuckets(bucketStartTimeNs + 100); in TEST_F()
569 eventProducer.clearPastBuckets(bucketStartTimeNs + 200); in TEST_F()
586 eventProducer.clearPastBuckets(bucketStartTimeNs + 300); in TEST_F()
601 eventProducer.clearPastBuckets(bucketStartTimeNs + 400); in TEST_F()
616 eventProducer.clearPastBuckets(bucketStartTimeNs + 500); in TEST_F()
625 const int64_t bucketStartTimeNs = 10000000000; in TEST_F() local
633 nullptr, protoHash, bucketStartTimeNs, provider); in TEST_F()
636 makeLogEvent(&event1, tagId, bucketStartTimeNs + 10, "111"); in TEST_F()
652 StatsLogReport report = onDumpReport(eventProducer, bucketStartTimeNs + 50); in TEST_F()
679 StatsLogReport report = onDumpReport(eventProducer, bucketStartTimeNs + 150); in TEST_F()
707 StatsLogReport report = onDumpReport(eventProducer, bucketStartTimeNs + 150); in TEST_F()