If the input is MPTS rewrite output PAT.

When the input is MPTS and output filtering is enabled, rewrite output
PAT to include only the single program that is decoded.

ChangeLog

@@ -4,6 +4,8 @@ xxxx-xx-xx : Version next
  * Fix payload offset detection, a bug which broke packets that have
    adaptation with whole packet size (libtsfuncs).
  * Add --input-service option, to choose service id (program) in MPTS input.
+ * When the input is MPTS and output filtering is enabled, rewrite output
+   PAT to include only the single program that is decoded.
  * Parse SDT and display provider and service name.
 
 2011-11-18 : Version 4.0

data.c

@@ -26,6 +26,7 @@ void data_init(struct ts *ts) {
 	// Stream
 	ts->pat	     = ts_pat_alloc();
 	ts->curpat   = ts_pat_alloc();
+	ts->genpat   = ts_pat_alloc();
 
 	ts->cat      = ts_cat_alloc();
 	ts->curcat   = ts_cat_alloc();
@@ -100,6 +101,7 @@ void data_init(struct ts *ts) {
 void data_free(struct ts *ts) {
 	ts_pat_free(&ts->pat);
 	ts_pat_free(&ts->curpat);
+	ts_pat_free(&ts->genpat);
 	ts_cat_free(&ts->cat);
 	ts_cat_free(&ts->curcat);
 	ts_pmt_free(&ts->pmt);

data.h

@@ -105,6 +105,8 @@ struct io {
 struct ts {
 	// Stream handling
 	struct ts_pat		*pat, *curpat;
+	struct ts_pat		*genpat;
+	uint8_t				genpat_cc;
 	struct ts_cat		*cat, *curcat;
 	struct ts_pmt		*pmt, *curpmt;
 	struct ts_sdt		*sdt, *cursdt;

libtsfuncs

@@ -1 +1 @@
-Subproject commit f36a478d2d9f849ece86da566b52ded75b836864
+Subproject commit 968352d1ecf5270c788e8d21f520cb05c1689da5

process.c

@@ -283,6 +283,16 @@ void process_packets(struct ts *ts, uint8_t *data, ssize_t data_len) {
 		if (ts->emm_only)
 			continue;
 
+		// Return rewritten PAT
+		if (pid == 0x00 && ts->pid_filter && ts->genpat->initialized) {
+			if (!ts_packet_is_pusi(ts_packet))
+				continue;
+			ts_packet_set_cont(ts->genpat->section_header->packet_data, ts->genpat_cc);
+			ts->genpat->ts_header.continuity = ts->genpat_cc;
+			ts_packet = ts->genpat->section_header->packet_data;
+			ts->genpat_cc = (ts->genpat_cc + 1) & 0x0f;
+		}
+
 		if (ts->threaded) {
 			// Add to decode buffer. The decoder thread will handle it
 			if (cbuf_fill(ts->decode_buf, ts_packet, 188) != 0) {

tables.c

@@ -84,6 +84,12 @@ void process_pat(struct ts *ts, uint16_t pid, uint8_t *ts_packet) {
 	ts_LOGf("PAT | Using service 0x%04x (%d), PMT pid: %04x (%d)\n",
 		ts->service_id, ts->service_id,
 		ts->pmt_pid, ts->pmt_pid);
+
+	if (num_services > 1) {
+		ts_pat_clear(ts->genpat);
+		ts->genpat = ts_pat_init(ts->genpat, ts->pat->section_header->ts_id_number);
+		ts_pat_add_program(ts->genpat, ts->service_id, ts->pmt_pid);
+	}
 }
 
 void process_cat(struct ts *ts, uint16_t pid, uint8_t *ts_packet) {