Lines Matching refs:eventProducer
85 EventMetricProducer eventProducer(kConfigKey, metric, -1 /*-1 meaning no condition*/, {}, in TEST_F() local
88 eventProducer.onMatchedLogEvent(1 /*matcher index*/, event1); in TEST_F()
89 eventProducer.onMatchedLogEvent(1 /*matcher index*/, event2); in TEST_F()
94 eventProducer.onDumpReport(bucketStartTimeNs + 20, true /*include current partial bucket*/, in TEST_F()
123 EventMetricProducer eventProducer(kConfigKey, metric, 0 /*condition index*/, in TEST_F() local
127 eventProducer.onConditionChanged(true /*condition*/, bucketStartTimeNs); in TEST_F()
128 eventProducer.onMatchedLogEvent(1 /*matcher index*/, event1); in TEST_F()
130 eventProducer.onConditionChanged(false /*condition*/, bucketStartTimeNs + 2); in TEST_F()
132 eventProducer.onMatchedLogEvent(1 /*matcher index*/, event2); in TEST_F()
137 eventProducer.onDumpReport(bucketStartTimeNs + 20, true /*include current partial bucket*/, in TEST_F()
181 EventMetricProducer eventProducer(kConfigKey, metric, 0 /*condition index*/, in TEST_F() local
185 eventProducer.onMatchedLogEvent(1 /*matcher index*/, event1); in TEST_F()
186 eventProducer.onMatchedLogEvent(1 /*matcher index*/, event2); in TEST_F()
191 eventProducer.onDumpReport(bucketStartTimeNs + 20, true /*include current partial bucket*/, in TEST_F()
220 EventMetricProducer eventProducer(kConfigKey, metric, -1 /*-1 meaning no condition*/, {}, in TEST_F() local
223 eventProducer.onMatchedLogEvent(1 /*matcher index*/, event1); in TEST_F()
224 eventProducer.onMatchedLogEvent(1 /*matcher index*/, event2); in TEST_F()
225 eventProducer.onMatchedLogEvent(1 /*matcher index*/, event3); in TEST_F()
226 eventProducer.onMatchedLogEvent(1 /*matcher index*/, event4); in TEST_F()
231 eventProducer.onDumpReport(bucketStartTimeNs + 50, true /*include current partial bucket*/, in TEST_F()
273 EventMetricProducer eventProducer(kConfigKey, metric, -1 /*-1 meaning no condition*/, {}, in TEST_F() local
276 eventProducer.onMatchedLogEvent(1 /*matcher index*/, event1); in TEST_F()
277 eventProducer.onMatchedLogEvent(1 /*matcher index*/, event2); in TEST_F()
278 eventProducer.onMatchedLogEvent(1 /*matcher index*/, event3); in TEST_F()
279 eventProducer.onMatchedLogEvent(1 /*matcher index*/, event4); in TEST_F()
284 eventProducer.onDumpReport(bucketStartTimeNs + 50, true /*include current partial bucket*/, in TEST_F()
323 EventMetricProducer eventProducer(kConfigKey, metric, -1 /*-1 meaning no condition*/, {}, in TEST_F() local
326 eventProducer.onMatchedLogEvent(1 /*matcher index*/, event1); in TEST_F()
327 eventProducer.onMatchedLogEvent(1 /*matcher index*/, event2); in TEST_F()
328 eventProducer.onMatchedLogEvent(1 /*matcher index*/, event3); in TEST_F()
333 eventProducer.onDumpReport(bucketStartTimeNs + 50, true /*include current partial bucket*/, in TEST_F()
364 EventMetricProducer eventProducer(kConfigKey, metric, -1 /*-1 meaning no condition*/, {}, in TEST_F() local
367 eventProducer.onMatchedLogEvent(1 /*matcher index*/, event1); in TEST_F()
368 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
370 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
372 eventProducer.onMatchedLogEventLost(tagId, DATA_CORRUPTED_SOCKET_LOSS, in TEST_F()
374 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
376 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
382 eventProducer.onDumpReport(bucketStartTimeNs + 50, true /*include current partial bucket*/, in TEST_F()
390 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
392 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
396 eventProducer.onMatchedLogEvent(1 /*matcher index*/, event1); in TEST_F()
397 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
399 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
401 eventProducer.onMatchedLogEventLost(tagId, DATA_CORRUPTED_EVENT_QUEUE_OVERFLOW, in TEST_F()
403 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
405 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
412 eventProducer.onDumpReport(bucketStartTimeNs + 150, true /*include current partial bucket*/, in TEST_F()
420 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
422 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
426 eventProducer.onMatchedLogEvent(1 /*matcher index*/, event1); in TEST_F()
427 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
429 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
431 eventProducer.onMatchedLogEventLost(tagId, DATA_CORRUPTED_SOCKET_LOSS, in TEST_F()
433 eventProducer.onMatchedLogEventLost(tagId, DATA_CORRUPTED_EVENT_QUEUE_OVERFLOW, in TEST_F()
435 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
437 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
444 eventProducer.onDumpReport(bucketStartTimeNs + 250, true /*include current partial bucket*/, in TEST_F()
453 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
455 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
471 EventMetricProducer eventProducer(kConfigKey, metric, -1 /*-1 meaning no condition*/, {}, in TEST_F() local
473 eventProducer.onMatchedLogEvent(1 /*matcher index*/, event1); in TEST_F()
475 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
477 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
480 eventProducer.onMatchedLogEventLost(tagId, DATA_CORRUPTED_SOCKET_LOSS, in TEST_F()
483 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
485 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
488 eventProducer.dropData(bucketStartTimeNs + 100); in TEST_F()
490 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
492 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
495 eventProducer.onMatchedLogEventLost(tagId, DATA_CORRUPTED_EVENT_QUEUE_OVERFLOW, in TEST_F()
498 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
500 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
503 eventProducer.dropData(bucketStartTimeNs + 200); in TEST_F()
505 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
507 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
510 eventProducer.onMatchedLogEventLost(tagId, DATA_CORRUPTED_SOCKET_LOSS, in TEST_F()
512 eventProducer.onMatchedLogEventLost(tagId, DATA_CORRUPTED_EVENT_QUEUE_OVERFLOW, in TEST_F()
515 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
517 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
520 eventProducer.dropData(bucketStartTimeNs + 300); in TEST_F()
522 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
524 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
527 eventProducer.onMatchedLogEventLost(tagId, DATA_CORRUPTED_SOCKET_LOSS, in TEST_F()
530 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
532 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
535 eventProducer.dropData(bucketStartTimeNs + 400); in TEST_F()
537 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
539 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
542 eventProducer.onMatchedLogEventLost(tagId, DATA_CORRUPTED_EVENT_QUEUE_OVERFLOW, in TEST_F()
545 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
547 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
550 eventProducer.dropData(bucketStartTimeNs + 500); in TEST_F()
552 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
554 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
569 EventMetricProducer eventProducer(kConfigKey, metric, -1 /*-1 meaning no condition*/, {}, in TEST_F() local
571 eventProducer.onMatchedLogEvent(1 /*matcher index*/, event1); in TEST_F()
573 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
575 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
578 eventProducer.onMatchedLogEventLost(tagId, DATA_CORRUPTED_SOCKET_LOSS, in TEST_F()
581 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
583 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
586 eventProducer.clearPastBuckets(bucketStartTimeNs + 100); in TEST_F()
588 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
590 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
593 eventProducer.onMatchedLogEventLost(tagId, DATA_CORRUPTED_EVENT_QUEUE_OVERFLOW, in TEST_F()
596 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
598 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
601 eventProducer.clearPastBuckets(bucketStartTimeNs + 200); in TEST_F()
603 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
605 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
608 eventProducer.onMatchedLogEventLost(tagId, DATA_CORRUPTED_SOCKET_LOSS, in TEST_F()
610 eventProducer.onMatchedLogEventLost(tagId, DATA_CORRUPTED_EVENT_QUEUE_OVERFLOW, in TEST_F()
613 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
615 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
618 eventProducer.clearPastBuckets(bucketStartTimeNs + 300); in TEST_F()
620 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
622 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
625 eventProducer.onMatchedLogEventLost(tagId, DATA_CORRUPTED_SOCKET_LOSS, in TEST_F()
628 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
630 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
633 eventProducer.clearPastBuckets(bucketStartTimeNs + 400); in TEST_F()
635 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
637 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
640 eventProducer.onMatchedLogEventLost(tagId, DATA_CORRUPTED_EVENT_QUEUE_OVERFLOW, in TEST_F()
643 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
645 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
648 eventProducer.clearPastBuckets(bucketStartTimeNs + 500); in TEST_F()
650 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
652 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
664 EventMetricProducer eventProducer(kConfigKey, metric, -1 /*-1 meaning no condition*/, {}, in TEST_F() local
669 eventProducer.onMatchedLogEvent(1 /*matcher index*/, event1); in TEST_F()
670 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
672 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
675 eventProducer.onMatchedLogEventLost(tagId, DATA_CORRUPTED_SOCKET_LOSS, in TEST_F()
677 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
679 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
685 eventProducer.onDumpReport(bucketStartTimeNs + 50, true /*include current partial bucket*/, in TEST_F()
694 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
696 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
700 eventProducer.onMatchedLogEvent(1 /*matcher index*/, event1); in TEST_F()
701 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
703 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
705 eventProducer.onMatchedLogEventLost(tagId, DATA_CORRUPTED_EVENT_QUEUE_OVERFLOW, in TEST_F()
707 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
709 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
715 eventProducer.onDumpReport(bucketStartTimeNs + 150, true /*include current partial bucket*/, in TEST_F()
725 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
728 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
732 eventProducer.onMatchedLogEvent(1 /*matcher index*/, event1); in TEST_F()
733 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
735 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
737 eventProducer.onMatchedLogEventLost(tagId, DATA_CORRUPTED_EVENT_QUEUE_OVERFLOW, in TEST_F()
739 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
741 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()
747 eventProducer.onDumpReport(bucketStartTimeNs + 150, true /*include current partial bucket*/, in TEST_F()
757 EXPECT_EQ(eventProducer.mDataCorruptedDueToSocketLoss, in TEST_F()
759 EXPECT_EQ(eventProducer.mDataCorruptedDueToQueueOverflow, in TEST_F()