Parse SDT and display provider and service name.

ChangeLog

@@ -4,6 +4,7 @@ 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.
+ * Parse SDT and display provider and service name.
 
 2011-11-18 : Version 4.0
  * Set CAMD sockets NODELAY to avoid OSCAM errors when many packets are sent.

data.c

@@ -33,6 +33,9 @@ void data_init(struct ts *ts) {
 	ts->pmt      = ts_pmt_alloc();
 	ts->curpmt   = ts_pmt_alloc();
 
+	ts->sdt      = ts_sdt_alloc();
+	ts->cursdt   = ts_sdt_alloc();
+
 	ts->emm      = ts_privsec_alloc();
 	ts->last_emm = ts_privsec_alloc();
 	ts->tmp_emm  = ts_privsec_alloc();

data.h

@@ -107,6 +107,7 @@ struct ts {
 	struct ts_pat		*pat, *curpat;
 	struct ts_cat		*cat, *curcat;
 	struct ts_pmt		*pmt, *curpmt;
+	struct ts_sdt		*sdt, *cursdt;
 	struct ts_privsec	*emm, *last_emm;
 	struct ts_privsec	*ecm, *last_ecm;
 	struct ts_privsec	*tmp_emm;

process.c

@@ -271,6 +271,7 @@ void process_packets(struct ts *ts, uint8_t *data, ssize_t data_len) {
 		process_pat(ts, pid, ts_packet);
 		process_cat(ts, pid, ts_packet);
 		process_pmt(ts, pid, ts_packet);
+		process_sdt(ts, pid, ts_packet);
 		process_emm(ts, pid, ts_packet);
 		process_ecm(ts, pid, ts_packet);
 

tables.c

@@ -159,6 +159,74 @@ void process_pmt(struct ts *ts, uint16_t pid, uint8_t *ts_packet) {
 	}
 }
 
+static int sdt_parse_service_name_desc(
+	int desc_len, uint8_t *desc,
+	uint8_t *pname_len, uint8_t **pname,
+	uint8_t *sname_len, uint8_t **sname)
+{
+	int ofs = 0;
+	*pname_len = 0;
+	*sname_len = 0;
+	*pname = NULL;
+	*sname = NULL;
+	while (ofs + 2 < desc_len) {
+		uint8_t tag = desc[ofs++];
+		uint8_t len = desc[ofs++];
+		if (tag != 0x48) {
+			ofs += len;
+			continue;
+		}
+		// Parse descriptor 0x48 - Service name descriptor
+		// +3 == +1 for service type, +1 for provider len, +1 for service len
+		if (ofs + 3 > desc_len)
+			break;
+
+		ofs++; // Skip service type
+
+		*pname_len = desc[ofs++];
+		if (*pname_len)
+			*pname = desc + ofs;
+		ofs += *pname_len;
+		if (ofs > desc_len)
+			break;
+
+		*sname_len = desc[ofs++];
+		if (*sname_len)
+			*sname = desc + ofs;
+		ofs += *sname_len;
+
+		return 1;
+	}
+	return 0;
+}
+
+void process_sdt(struct ts *ts, uint16_t pid, uint8_t *ts_packet) {
+	int i;
+
+	if (pid != 0x11)
+		return;
+
+	handle_table_changes(sdt);
+
+	for(i=0;i<ts->sdt->streams_num;i++) {
+		struct ts_sdt_stream *stream = ts->sdt->streams[i];
+		uint8_t *pname, *sname;
+		uint8_t pname_len, sname_len;
+		if (sdt_parse_service_name_desc(
+			stream->descriptor_size, stream->descriptor_data,
+			&pname_len, &pname, &sname_len, &sname))
+		{
+			ts_LOGf("SDT | Service 0x%04x (%5d) Provider: \"%.*s\" Service: \"%.*s\"\n",
+				stream->service_id, stream->service_id,
+				pname_len, (char *)pname,
+				sname_len, (char *)sname);
+		} else {
+			ts_LOGf("SDT | Service 0x%04x (%5d)\n",
+				stream->service_id, stream->service_id);
+		}
+	}
+}
+
 #define dump_sz      (16)
 #define dump_buf_sz  (dump_sz * 6)
 

tables.h

@@ -23,6 +23,7 @@
 void process_pat(struct ts *ts, uint16_t pid, uint8_t *ts_packet);
 void process_cat(struct ts *ts, uint16_t pid, uint8_t *ts_packet);
 void process_pmt(struct ts *ts, uint16_t pid, uint8_t *ts_packet);
+void process_sdt(struct ts *ts, uint16_t pid, uint8_t *ts_packet);
 void process_emm(struct ts *ts, uint16_t pid, uint8_t *ts_packet);
 void process_ecm(struct ts *ts, uint16_t pid, uint8_t *ts_packet);