Add --pid-report option.

ChangeLog

 next : Version next
  * Add --output-tos (-g) option used to set output TOS value.
  * Add --input-dump (-W) option used save input stream in file.
+ * Add --pid-report (-j) option used to turn on PID reporting.
 
 2011-12-23 : Version 5.0
  * Add --bench (-b) option that benchmarks libdvbcsa decryption.

README

                             .    3 = show duplicate ECMs
                             .    4 = packet debug
                             .    5 = packet debug + packet dump
+ -j --pid-report            | Report how much packets were received.
  -b --bench                 | Benchmark decrypton.
  -h --help                  | Show help screen.
  -V --version               | Show program version.

data.h

 	struct in_addr		intf;
 };
 
+#define MAX_PIDS 8192
+
 struct ts {
 	// Stream handling
 	struct ts_pat		*pat, *curpat;
 	unsigned int		cw_warn_sec;
 	time_t				cw_last_warn;
 
+	unsigned int		pid_report;
+	unsigned int		pid_stats[MAX_PIDS];
+
 	// CAMD handling
 	struct key			key;
 	struct camd			camd;

process.c

 static unsigned long ts_pack;
 static int ts_pack_shown;
 
-static char *get_pid_desc(struct ts *ts, uint16_t pid) {
+char *get_pid_desc(struct ts *ts, uint16_t pid) {
 	int i;
 	uint16_t nitpid = 0x0010, pmtpid = 0xffff, pcrpid = 0xffff;
 
 		uint8_t *ts_packet = data + i;
 		uint16_t pid = ts_packet_get_pid(ts_packet);
 
+		if (ts->pid_report)
+			ts->pid_stats[pid]++;
+
 		ts_pack_shown = 0;
 
 		process_pat(ts, pid, ts_packet);
 		ts_pack++;
 	}
 }
+
+void show_pid_report(struct ts *ts) {
+	int i;
+	if (!ts->pid_report)
+		return;
+
+	for (i = 0; i < MAX_PIDS; i++) {
+		if (ts->pid_stats[i]) {
+			ts_LOGf("PID | %8u packets with PID 0x%04x (%4u) %s\n",
+					ts->pid_stats[i], i, i, get_pid_desc(ts, i));
+		}
+	}
+}

process.h

 void *decode_thread(void *_ts);
 void *write_thread(void *_ts);
 void process_packets(struct ts *ts, uint8_t *data, ssize_t data_len);
+void show_pid_report(struct ts *ts);
 
 #endif

tsdecrypt.1

 dump.
 Setting higher level enables the levels bellow.
 .TP
+\fB\-j\fR, \fB\-\-pid\-report\fR
+When this option is used, tsdecrypt on exit reports how much packets
+were received on each PID.
+.TP
 \fB\-b\fR, \fB\-\-bench\fR
 Bechmark libdvbcsa decryption. The benchmark is single threaded.
 If you want to fully test your CPU, run couple of tsdecrypts in parallel.

tsdecrypt.c

 	puts("* Done *");
 }
 
-// Unused short options: FQTYajkmnqruv0123456789
+// Unused short options: FQTYakmnqruv0123456789
 static const struct option long_options[] = {
 	{ "ident",				required_argument, NULL, 'i' },
 	{ "daemon",				required_argument, NULL, 'd' },
 	{ "cw-warn-time",		required_argument, NULL, 'J' },
 
 	{ "debug",				required_argument, NULL, 'D' },
+	{ "pid-report",			no_argument,       NULL, 'j' },
 	{ "bench",				no_argument,       NULL, 'b' },
 	{ "help",				no_argument,       NULL, 'h' },
 	{ "version",			no_argument,       NULL, 'V' },
 	printf("                            .    3 = show duplicate ECMs\n");
 	printf("                            .    4 = packet debug\n");
 	printf("                            .    5 = packet debug + packet dump\n");
+	printf(" -j --pid-report            | Report how much packets were received.\n");
 	printf(" -b --bench                 | Benchmark decrypton.\n");
 	printf(" -h --help                  | Show help screen.\n");
 	printf(" -V --version               | Show program version.\n");
 
 static void parse_options(struct ts *ts, int argc, char **argv) {
 	int j, i, ca_err = 0, server_err = 1, input_addr_err = 0, output_addr_err = 0, output_intf_err = 0, ident_err = 0, port_set = 0;
-	while ( (j = getopt_long(argc, argv, "i:d:N:Sl:L:I:RzM:W:O:o:t:g:pwxyc:C:A:s:U:P:B:eZ:Ef:X:H:G:KJ:D:bhV", long_options, NULL)) != -1 ) {
+	while ( (j = getopt_long(argc, argv, "i:d:N:Sl:L:I:RzM:W:O:o:t:g:pwxyc:C:A:s:U:P:B:eZ:Ef:X:H:G:KJ:D:jbhV", long_options, NULL)) != -1 ) {
 		char *p = NULL;
 		switch (j) {
 			case 'i':
 			case 'D':
 				ts->debug_level = atoi(optarg);
 				break;
-
+			case 'j':
+				ts->pid_report = 1;
+				break;
 			case 'b':
 				run_benchmark();
 				exit(EXIT_SUCCESS);
 			pthread_join(ts.write_thread, NULL);
 	}
 
+	show_pid_report(&ts);
+
 	notify_sync(&ts, "STOP", "Stopping %s", program_id);
 	ts_LOGf("Stop %s\n", program_id);