|
@@ -800,7 +800,9 @@ static void parse_options(struct ts *ts, int argc, char **argv) {
|
800
|
800
|
}
|
801
|
801
|
|
802
|
802
|
static void report_emms(struct ts *ts, time_t now) {
|
803
|
|
- ts_LOGf("EMM | Received %u and processed %u in %lu seconds.\n",
|
|
803
|
+ ts_LOGf("EMM | Received %u, Skipped %u, Sent %u, Processed %u in %lu seconds.\n",
|
|
804
|
+ ts->emm_input_count,
|
|
805
|
+ ts->emm_skipped_count,
|
804
|
806
|
ts->emm_seen_count,
|
805
|
807
|
ts->emm_processed_count,
|
806
|
808
|
now - ts->emm_last_report);
|
|
@@ -809,7 +811,9 @@ static void report_emms(struct ts *ts, time_t now) {
|
809
|
811
|
now - ts->emm_last_report);
|
810
|
812
|
}
|
811
|
813
|
ts->emm_last_report = now;
|
|
814
|
+ ts->emm_input_count = 0;
|
812
|
815
|
ts->emm_seen_count = 0;
|
|
816
|
+ ts->emm_skipped_count = 0;
|
813
|
817
|
ts->emm_processed_count = 0;
|
814
|
818
|
}
|
815
|
819
|
|