Add another error NO_PROGRAM error when PMT is missing from the input

camd.c

@@ -185,7 +185,7 @@ static int camd_send_ecm(struct ts *ts, struct camd_msg *msg) {
 		ts->is_cw_error = 1;
 		if (ts->key.ts && now - ts->key.ts > KEY_VALID_TIME) {
 			if (c->key->is_valid_cw) {
-				if (!ts->stream_is_not_scrambled) {
+				if (!ts->stream_is_not_scrambled || !ts->have_valid_pmt) {
 					notify(ts, "NO_CODE_WORD", "No code word was set in %ld sec. Decryption is disabled.",
 						now - ts->key.ts);
 					ts_LOGf("CW  | *ERR* No valid code word was received in %ld seconds. Decryption is disabled.\n",

data.c

@@ -48,6 +48,9 @@ void data_init(struct ts *ts) {
 	pidmap_clear(&ts->cc);
 	pidmap_clear(&ts->pid_seen);
 
+	ts->have_valid_pmt = 1;
+	ts->last_pmt_ts = time(NULL);
+
 	// Key
 	memset(&ts->key, 0, sizeof(ts->key));
 	ts->key.csakey = csa_key_alloc();

data.h

@@ -257,6 +257,11 @@ struct ts {
 	pidmap_t			cc; // Continuity counters
 	pidmap_t			pid_seen;
 
+	// PMT tracking
+	time_t				last_pmt_ts;
+	unsigned int		have_valid_pmt;
+	unsigned int		no_input;
+
 	// Stats
 	unsigned int		emm_input_count;
 	unsigned int		emm_seen_count;

process.c

@@ -132,7 +132,7 @@ static void decode_buffer(struct ts *ts, uint8_t *data, int data_len) {
 		uint16_t pid = ts_packet_get_pid(ts_packet);
 		bool in_pidmap = pidmap_get(&ts->pidmap, pid);
 		bool is_scrambled = ts_packet_is_scrambled(ts_packet);
-		if (in_pidmap) {
+		if (in_pidmap && ts->have_valid_pmt) {
 			if (is_scrambled) {
 				if (ts->last_scrambled_packet_ts < now) {
 					ts->stream_is_not_scrambled = 0;
@@ -262,6 +262,8 @@ void *decode_thread(void *_ts) {
 static inline void output_write(struct ts *ts, uint8_t *data, unsigned int data_size) {
 	if (!data)
 		return;
+	if (!ts->have_valid_pmt)
+		return;
 	if (ts->no_output_on_error && !ts->camd.key->is_valid_cw)
 		return;
 	if (!ts->rtp_output) {

tables.c

@@ -131,6 +131,10 @@ void process_pmt(struct ts *ts, uint16_t pid, uint8_t *ts_packet) {
 	if (!pid || pid != ts->pmt_pid)
 		return;
 
+	// Mark PMT as valid and the received timestamp
+	ts->last_pmt_ts = time(NULL);
+	ts->have_valid_pmt = 1;
+
 	handle_table_changes(pmt);
 
 	pidmap_clear(&ts->pidmap);

tsdecrypt.1

@@ -335,6 +335,12 @@ currently defined events are:
 
   \fBSTART\fR           tsdecrypt was started.
 
+  \fBNO_PROGRAM\fR    There is an input but there is no valid program
+                  in the input (PMT table is missing). This error is
+                  reported when there 15 seconds have passed since
+                  last valid PMT was received. When this error is
+                  active tsdecrypt stops outputing the stream.
+
   \fBCODE_WORD_OK\fR    Valid code word was received and decryption is
                   working ok.
 

tsdecrypt.c

@@ -861,7 +861,7 @@ static void report_emms(struct ts *ts, time_t now) {
 }
 
 static void report_ecms(struct ts *ts, time_t now) {
-	if (ts->stream_is_not_scrambled && ts->ecm_seen_count == 0)
+	if ((ts->stream_is_not_scrambled || !ts->have_valid_pmt) && ts->ecm_seen_count == 0)
 		return;
 	ts_LOGf("ECM | Received %u (%u dup) and processed %u in %lu seconds.\n",
 		ts->ecm_seen_count,
@@ -875,7 +875,7 @@ static void report_ecms(struct ts *ts, time_t now) {
 }
 
 static void report_cw_warn(struct ts *ts, time_t now) {
-	if (ts->stream_is_not_scrambled)
+	if (ts->stream_is_not_scrambled || !ts->have_valid_pmt)
 		return;
 	if (now - ts->key.ts > 1) {
 		notify(ts, "NO_CODE_WORD", "No valid code word was received in %ld sec.",
@@ -919,6 +919,15 @@ static void do_reports(struct ts *ts) {
 			report_cw_warn(ts, now);
 		}
 	}
+	if (!ts->no_input) {
+		if (ts->last_pmt_ts <= now - 3) {
+			if (ts->have_valid_pmt) {
+				ts_LOGf("MIS | There is no valid PMT in the input.\n");
+				notify(ts, "NO_PROGRAM", "The input is missing valid program.");
+				ts->have_valid_pmt = 0;
+			}
+		}
+	}
 }
 
 static struct ts ts;
@@ -1051,6 +1060,7 @@ int main(int argc, char **argv) {
 							ts.rtp_input ? "rtp" : "udp",
 							ts.input.hostname, ts.input.service);
 				}
+				ts.no_input = 1;
 				ntimeouts++;
 			} else {
 				if (ntimeouts && readen > 0) {
@@ -1060,6 +1070,7 @@ int main(int argc, char **argv) {
 							ts.rtp_input ? "rtp" : "udp",
 							ts.input.hostname, ts.input.service,
 							(now - timeout_start) + 2); // Timeout is detected when ~2 seconds there is no incoming data
+					ts.no_input = 0;
 					ntimeouts = 0;
 				}
 			}