pt1: recpt1/tssplitter_lite.c comparison

comparison recpt1/tssplitter_lite.c @ 132:9783d247d1c9

imported Shaolin-san's NIT fix patch. The original patch can be obtained at http://microgroove.jp/shaolin/2010/09/a_tiny_patch_for_recpt1tssplitter_litec.html

author	Yoshiki Yazawa <yaz@honeyplanet.jp>
date	Wed, 27 Jun 2012 06:51:23 +0900
parents	9e9dbb17b70f
children	550ee373afbc

comparison

equal deleted inserted replaced

-:2dc994610477
+:9783d247d1c9
 *
 * PAT を解析し、出力対象チャンネルが含まれているかチェックを行い、PAT を再構築する
 */
 static int AnalyzePat(splitter *sp, unsigned char *buf)
 #if 0
+	splitter *sp
+		unsigned char** pat,				// [out]	PAT 情報（再構築後）
+		unsigned char* pids,				// [out]	出力対象 PID 情報
+		char** sid_list,					// [in]		出力対象サービス ID のリスト
+		unsigned char* pmt_pids,			// [out]	サービス ID に対応する PMT の PID
+		int* pmt_retain						// [out]	残すPMTの数
 	unsigned char* buf,					// [in]		読み込んだバッファ
-	unsigned char** pat,				// [out]	PAT 情報（再構築後）
-	unsigned char* pids,				// [out]	出力対象 PID 情報
-	char** sid_list,					// [in]		出力対象サービス ID のリスト
-	unsigned char* pmt_pids,			// [out]	サービス ID に対応する PMT の PID
-	int* pmt_retain						// [out]	残すPMTの数
 #endif
 {
 	int pos[MAX_PID];
 	int service_id;
 	int i, j, k;
 		sp->pmt_retain = 0;
 		memset(pos, 0, sizeof(pos));
 		size = buf[7];
 		/* prescan SID/PMT */
-		for(i = 17, j = 0; i < (size + 8) - 4; i = i + 4, j++) {
+		for(i = 13, j = 0; i < (size + 8) - 4; i = i + 4) {
+			pid = GetPid(&buf[i+2]);
+			if(pid == 0x0010)
+				continue;
 			avail_sids[j] = (buf[i] << 8) + buf[i+1];
-			sp->avail_pmts[j] = GetPid(&buf[i+2]);
+			sp->avail_pmts[j] = pid;
+			j++;
 		}
 		sp->num_pmts = j;
 		// 対象チャンネル判定
 		/* size + 8 = パケット全長 */
 		/* 最終 4 バイトはCRCなので飛ばす */
-		for(i = 17; i < (size + 8) - 4; i = i + 4) {
+		for(i = 13; i < (size + 8) - 4; i = i + 4) {
+			pid = GetPid(&buf[i+2]);
+			if(pid == 0x0010)
+				continue;
 			service_id = (buf[i] << 8) + buf[i+1];
 			p = sid_list;
 			while(*p) {
 			} /* while */
 		}
 		/* if sid has been specified but no sid found, fall back to all */
 		if(*sid_list && !sid_found) {
-			for(i = 17; i < (size + 8) - 4; i = i + 4) {
+			for(i = 13; i < (size + 8) - 4; i = i + 4) {
+				pid = GetPid(&buf[i+2]);
+				if(pid==0x0010)
+					continue;
 				service_id = (buf[i] << 8) + buf[i+1];
 				pid = GetPid(&buf[i + 2]);
 				*(pmt_pids+pid) = 1;
 				*(pids+pid) = 1;
 				pos[pid] = i;
 		for(k=0; k < sp->num_pmts; k++)
 			fprintf(stderr, "%d ", avail_sids[k]);
 		fprintf(stderr, "\n");
 		fprintf(stderr, "Chosen sid    =%s\n", chosen_sid);
-#if 0
+#if 1
 		/* print PMTs */
 		fprintf(stderr, "Available PMT = ");
 		for(k=0; k < sp->num_pmts; k++)
-			fprintf(stderr, "%d ", sp->avail_pmts[k].pid);
+			fprintf(stderr, "0x%x ", sp->avail_pmts[k]);
 		fprintf(stderr, "\n");
 #endif
 		// PAT 再構築
 		result = RecreatePat(sp, buf, pos);
 #if 0
 		int tc;
 		for(tc=0; tc<188; tc++)
-			fprintf(stderr, "%02x ", *(pat+tc));
+			fprintf(stderr, "%02x ", *(sp->pat+tc));
 #endif
 	}
 	return(result);
 }
 *
 * PMT から出力対象チャンネル以外のチャンネル情報を削除し、PAT を再構築する
 */
 static int RecreatePat(splitter *sp, unsigned char *buf, int *pos)
 #if 0
+	splitter *sp						// [in/out]
+		unsigned char** pat,			// [out]	PAT 情報（再構築後）
+		unsigned char* pids,			// [out]	出力対象 PID 情報
 	unsigned char* buf,					// [in]		読み込んだバッファ
-	unsigned char** pat,				// [out]	PAT 情報（再構築後）
-	unsigned char* pids,				// [out]	出力対象 PID 情報
 	int *pos							// [in]		取得対象 PMT のバッファ中の位置
 #endif
 {
 	unsigned char y[LENGTH_CRC_DATA];
 	int crc;
 	int pid_num = 0;
 	// CRC 計算のためのデータ
 	{
 		// チャンネルによって変わらない部分
-		for (i = 0; i < LENGTH_PAT_HEADER; i++)
+		for (i = 0; i < LENGTH_PAT_HEADER - 4; i++)
 		{
 			y[i] = buf[i + 5];
 		}
+		// NIT
+		y[LENGTH_PAT_HEADER-4] = 0x00;
+		y[LENGTH_PAT_HEADER-3] = 0x00;
+		y[LENGTH_PAT_HEADER-2] = 0xe0;
+		y[LENGTH_PAT_HEADER-1] = 0x10;
 		// チャンネルによって変わる部分
 		for (i = 0; i < MAX_PID; i++)
 		{
 			if(pos[i] != 0)
 			{

Mercurial > pt1

comparison recpt1/tssplitter_lite.c @ 132:9783d247d1c9