Fix PUSI check.

cat.c

@@ -48,7 +48,7 @@ struct ts_cat *ts_cat_push_packet(struct ts_cat *cat, uint8_t *ts_packet) {
 
 	if (ts_packet_header_parse(ts_packet, &ts_header)) {
 		// Received PUSI packet before table END, clear the table to start gathering new one
-		if (cat->ts_header.pusi)
+		if (ts_header.pusi && cat->ts_header.pusi)
 			ts_cat_clear(cat);
 		if (!cat->ts_header.pusi)
 			cat->ts_header = ts_header;

eit.c

@@ -68,7 +68,7 @@ struct ts_eit *ts_eit_push_packet(struct ts_eit *eit, uint8_t *ts_packet) {
 		if (ts_header.pid != 0x12)
 			goto OUT;
 		// Received PUSI packet before table END, clear the table to start gathering new one
-		if (eit->ts_header.pusi)
+		if (ts_header.pusi && eit->ts_header.pusi)
 			ts_eit_clear(eit);
 		if (!eit->ts_header.pusi)
 			eit->ts_header = ts_header;

nit.c

@@ -70,7 +70,7 @@ struct ts_nit *ts_nit_push_packet(struct ts_nit *nit, uint8_t *ts_packet) {
 		if (ts_header.pid != 0x10)
 			goto OUT;
 		// Received PUSI packet before table END, clear the table to start gathering new one
-		if (nit->ts_header.pusi)
+		if (ts_header.pusi && nit->ts_header.pusi)
 			ts_nit_clear(nit);
 		if (!nit->ts_header.pusi)
 			nit->ts_header = ts_header;

pat.c

@@ -67,7 +67,7 @@ struct ts_pat *ts_pat_push_packet(struct ts_pat *pat, uint8_t *ts_packet) {
 		if (ts_header.pid != 0x00)
 			goto OUT;
 		// Received PUSI packet before table END, clear the table to start gathering new one
-		if (pat->ts_header.pusi)
+		if (ts_header.pusi && pat->ts_header.pusi)
 			ts_pat_clear(pat);
 		if (!pat->ts_header.pusi)
 			pat->ts_header = ts_header;

pmt.c

@@ -68,7 +68,7 @@ struct ts_pmt *ts_pmt_push_packet(struct ts_pmt *pmt, uint8_t *ts_packet) {
 
 	if (ts_packet_header_parse(ts_packet, &ts_header)) {
 		// Received PUSI packet before table END, clear the table to start gathering new one
-		if (pmt->ts_header.pusi)
+		if (ts_header.pusi && pmt->ts_header.pusi)
 			ts_pmt_clear(pmt);
 		if (!pmt->ts_header.pusi)
 			pmt->ts_header = ts_header;

privsec.c

@@ -54,7 +54,7 @@ struct ts_privsec *ts_privsec_push_packet(struct ts_privsec *privsec, uint8_t *t
 
 	if (ts_packet_header_parse(ts_packet, &ts_header)) {
 		// Received PUSI packet before table END, clear the table to start gathering new one
-		if (privsec->ts_header.pusi)
+		if (ts_header.pusi && privsec->ts_header.pusi)
 			ts_privsec_clear(privsec);
 		if (!privsec->ts_header.pusi)
 			privsec->ts_header = ts_header;

sdt.c

@@ -68,7 +68,7 @@ struct ts_sdt *ts_sdt_push_packet(struct ts_sdt *sdt, uint8_t *ts_packet) {
 		if (ts_header.pid != 0x11)
 			goto OUT;
 		// Received PUSI packet before table END, clear the table to start gathering new one
-		if (sdt->ts_header.pusi)
+		if (ts_header.pusi && sdt->ts_header.pusi)
 			ts_sdt_clear(sdt);
 		if (!sdt->ts_header.pusi)
 			sdt->ts_header = ts_header;

tdt.c

@@ -52,7 +52,7 @@ struct ts_tdt *ts_tdt_push_packet(struct ts_tdt *tdt, uint8_t *ts_packet) {
 		if (ts_header.pid != 0x14)
 			goto OUT;
 		// Received PUSI packet before table END, clear the table to start gathering new one
-		if (tdt->ts_header.pusi)
+		if (ts_header.pusi && tdt->ts_header.pusi)
 			ts_tdt_clear(tdt);
 		if (!tdt->ts_header.pusi)
 			tdt->ts_header = ts_header;