Warn if CW have not been received.

Add --cw-warn-time to set how much time to wait before
starting to complain about code words.

camd.c

@@ -161,13 +161,18 @@ READ:
 	char cw_dump[16 * 6];
 	ts_hex_dump_buf(cw_dump, 16 * 6, cw, 16, 0);
 
-	c->key->is_valid_cw = memcmp(c->key->cw, invalid_cw, 16) != 0;
+	int valid_cw = memcmp(c->key->cw, invalid_cw, 16) != 0;
+	if (!c->key->is_valid_cw && valid_cw) {
+		ts_LOGf("CW  | +++ OK: Valid CW was received.");
+	}
+	c->key->is_valid_cw = valid_cw;
 
 	// At first ts_keyset is not initialized
 	last_ts_keyset = c->key->ts_keyset;
 	if (c->key->is_valid_cw) {
 		gettimeofday(&c->key->ts_keyset, NULL);
 		c->key->ts = c->key->ts_keyset.tv_sec;
+		ts->cw_last_warn = c->key->ts;
 
 		dvbcsa_key_set(c->key->cw    , c->key->csakey[0]);
 		dvbcsa_key_set(c->key->cw + 8, c->key->csakey[1]);

data.c

@@ -82,6 +82,8 @@ void data_init(struct ts *ts) {
 	ts->ecm_report_interval = 60;
 	ts->ecm_last_report     = time(NULL);
 
+	ts->cw_warn_sec = 20;
+
 	ts->input.fd    = 0; // STDIN
 	ts->input.type  = FILE_IO;
 

data.h

@@ -116,6 +116,9 @@ struct ts {
 	unsigned int		ecm_report_interval;
 	time_t				ecm_last_report;
 
+	unsigned int		cw_warn_sec;
+	time_t				cw_last_warn;
+
 	// CAMD handling
 	struct key			key;
 	struct camd35		camd35;

tsdecrypt.1

@@ -141,6 +141,10 @@ type is \fB0\fR.
 \fB\-K\fR, \fB\-\-ecm\-no\-log\fR
 Disable logging of ECMs and code words. Code word errors and stats
 reports are not affected by this option.
+.TP
+\fB\-J\fR, \fB\-\-cw\-warn\-time\fR <seconds>
+After how much seconds to warn if valid code word was not received.
+The default is \fB20\fR seconds. Set to \fB0\fR to disable the warning.
 .SH SEE ALSO
 See the README file for more information. If you have questions, remarks,
 problems or you just want to contact the developer, write to:

tsdecrypt.c

@@ -78,6 +78,7 @@ static const struct option long_options[] = {
 	{ "ecm-report-time",	required_argument, NULL, 'H' },
 	{ "ecm-irdeto-type",	required_argument, NULL, 'G' },
 	{ "ecm-no-log",			no_argument      , NULL, 'K' },
+	{ "cw-warn-time",		required_argument, NULL, 'J' },
 
 	{ "debug",				required_argument, NULL, 'D' },
 	{ "help",				no_argument,       NULL, 'h' },
@@ -141,6 +142,8 @@ static void show_help(struct ts *ts) {
 	printf("                            . the reports. Default: %d sec\n", ts->ecm_report_interval);
 	printf(" -G --ecm-irdeto-type <int> | Process IRDETO ECMs with type X /0..3/. Default: %d\n", ts->irdeto_ecm);
 	printf(" -K --ecm-no-log            | Disable ECM and code words logging.\n");
+	printf(" -J --cw-warn-time <sec>    | Warn if no valid code word has been received.\n");
+	printf("                            . Set <sec> to 0 to disable. Default: %d sec\n", ts->cw_warn_sec);
 	printf("\n");
 	printf("Misc options:\n");
 	printf(" -D --debug <level>         | Message debug level.\n");
@@ -178,7 +181,7 @@ static int parse_io_param(struct io *io, char *opt, int open_flags, mode_t open_
 
 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;
-	while ( (j = getopt_long(argc, argv, "i:d:l:L:I:RzO:o:t:pc:s:U:P:y:eZ:Ef:X:G:KD:h", long_options, NULL)) != -1 ) {
+	while ( (j = getopt_long(argc, argv, "i:d:l:L:I:RzO:o:t:pc:s:U:P:y:eZ:Ef:X:G:KJ:D:h", long_options, NULL)) != -1 ) {
 		char *p = NULL;
 		switch (j) {
 			case 'i':
@@ -301,6 +304,11 @@ static void parse_options(struct ts *ts, int argc, char **argv) {
 			case 'K':
 				ts->ecm_cw_log = 0;
 				break;
+			case 'J':
+				ts->cw_warn_sec = strtoul(optarg, NULL, 10);
+				if (ts->cw_warn_sec > 86400)
+					ts->cw_warn_sec = 86400;
+				break;
 
 			case 'D':
 				ts->debug_level = atoi(optarg);
@@ -391,6 +399,11 @@ static void parse_options(struct ts *ts, int argc, char **argv) {
 	if (!ts->emm_only && ts->ecm_report_interval == 0)
 		ts_LOGf("ECM report : disabled\n");
 
+	if (!ts->emm_only && ts->cw_warn_sec)
+		ts_LOGf("CW warning : %d sec\n", ts->cw_warn_sec);
+	if (!ts->emm_only && ts->cw_warn_sec)
+		ts_LOGf("CW warning : disabled\n");
+
 	if (!ts->ecm_cw_log)
 		ts_LOGf("ECM/CW log : disabled\n");
 
@@ -424,6 +437,11 @@ static void report_ecms(struct ts *ts, time_t now) {
 	ts->ecm_processed_count = 0;
 }
 
+static void report_cw_warn(struct ts *ts, time_t now) {
+	ts_LOGf("CW  | *** No valid CW was received for %lu seconds!\n", now - ts->cw_last_warn);
+	ts->cw_last_warn = now;
+}
+
 static void do_reports(struct ts *ts) {
 	static int first_emm_report = 1;
 	static int first_ecm_report = 1;
@@ -446,6 +464,10 @@ static void do_reports(struct ts *ts) {
 			report_ecms(ts, now);
 		}
 	}
+
+	if (!ts->emm_only && !ts->key.is_valid_cw) {
+		report_cw_warn(ts, now);
+	}
 }
 
 void signal_quit(int sig) {