TS流解析源码.docx

1、TS流解析源码非常实用的解析TS流源码废话不说，直接上传源码。TsParser.cpp：#include stdafx.h#include crc.h#include log.h#include xstring.h#include Xml.h#include osfile.h#include TsParser.h#include OcgMem.h#include MptsTransfer.h#include main.h#include osfile.h#include osdir.h/* TS流分析器 */CTsParser:CTsParser() m_pat_filter = NULL;

2、m_pat_buf = NULL; m_pat_size = 0; m_sdt_filter = NULL; m_bufsize = 12*188*1024; m_head = 0; m_tail = 0; m_buf = (unsigned char*)OCG_MALLOC( m_bufsize );CTsParser:CTsParser() uint16_t pmt_pid, serv_id; SProgInfo spi; TSSDTInfo sdt; void *position; if( m_pat_filter ) m_demux.DestroyFilter( m_pat_filte

3、r ); m_pat_filter = NULL; if( m_pat_buf ) OCG_FREE( m_pat_buf ); m_pat_buf = NULL; if( m_sdt_filter ) m_demux.DestroyFilter( m_sdt_filter ); m_sdt_filter = NULL; if( m_buf ) OCG_FREE( m_buf ); m_buf = NULL; position = m_pmtmap.GetFirst( &pmt_pid, &spi ); while( position ) if( spi.filter ) m_demux.De

4、stroyFilter( spi.filter ); if( spi.pmt_buf ) OCG_FREE( spi.pmt_buf ); position = m_pmtmap.GetNext( &pmt_pid, &spi, position ); m_pmtmap.RemoveAll(); /* 清除SDT信息 */ position = m_sdtmap.GetFirst( &serv_id, &sdt ); while( position ) if( sdt.sdt_service_node ) TSSDTServiceInfo *serv_del, *serv_tmp = sdt.

5、sdt_service_node; while( serv_tmp ) serv_del = serv_tmp; serv_tmp = serv_tmp-next; serv_del-next = NULL; OCG_FREE( serv_del ); if( sdt.sdt_multilingual_node ) TSSDTMultilingualInfo *multi_del, *multi_tmp = sdt.sdt_multilingual_node; while( multi_tmp ) multi_del = multi_tmp; multi_tmp = multi_tmp-nex

6、t; multi_del-next = NULL; OCG_FREE( multi_del ); position = m_sdtmap.GetNext( &serv_id, &sdt, position ); m_sdtmap.RemoveAll();/* PAT/PMT-SECTION输出回调函数 */void CTsParser:FilterProc( void* filter, unsigned char *buf, int32_t size, uint32_t lParam ) if( filter = (CTsParser*)lParam)-m_pat_filter ) (CTsP

7、arser*)lParam)-OnPatSection( filter, buf, size ); else if( filter = (CTsParser*)lParam)-m_sdt_filter ) (CTsParser*)lParam)-OnSdtSection( filter, buf, size ); else (CTsParser*)lParam)-OnPmtSection( filter, buf, size );/* SDT-SECTION处理函数 */bool CTsParser:OnSdtSection( void* filter, unsigned char *buf,

8、 int32_t size ) unsigned char *p, *q, *q1; int32_t len, mutili_len; uint16_t service_id, sdt_service_id; uint32_t crc32, ival; unsigned char version_number, section_number, last_section_number; void *position; TSSDTInfo* sdt_info = NULL; TSSDTServiceInfo* sdt_service_des = NULL, *serv_tmp = NULL; TS

9、SDTMultilingualInfo* sdt_multilingual_des = NULL, *multi_tmp = NULL; /* pat/pmt的尺寸不可能超过1024字节 */ if( 1024 1) & 0x1f; section_number = buf6; last_section_number = buf7; if( last_section_number section_number ) return false; p = buf; p += 11; while( p buf + (size - 4) ) /* service_id */ service_id = (

10、p08) | p1; p += 2; /* EIT. */ p += 1; /* descriptor_loop_length */ len = (p0&0xf)sdt_service_id = service_id ) sdt_info-bIsSucceed = true; break; else sdt_info = NULL; position = m_sdtmap.GetNext( &sdt_service_id, NULL, position ); /* 或许当前pat信息还没解析出来，存储结构还未建立好 */ if( !sdt_info ) return false; /* des

11、criptors: descriptor_tag(1)+descriptor_length(1)+. */ q = p; while( p q + len & p sdt_service_type = *p; p += 1; memcpy( &sdt_service_des-sdt_service_provider_name, p + 1, *p ); sdt_service_des-sdt_service_provider_name *p = 0; p += *p; p += 1; memcpy( &sdt_service_des-sdt_service_name, p + 1, *p );

12、 sdt_service_des-sdt_service_name *p = 0; p += *p; p += 1; /* 建立链表关系 */ if( !sdt_info-sdt_service_node ) sdt_info-sdt_service_node = sdt_service_des; else serv_tmp = sdt_info-sdt_service_node; while( serv_tmp ) if( !serv_tmp-next ) break; serv_tmp = serv_tmp-next; serv_tmp-next = sdt_service_des; se

13、rv_tmp-next-next = NULL; break; case 0x5d:/* multilingul_service_name_descriptor */ mutili_len = p1; p += 2; q1 = p; while( p q1 + mutili_len & p sdt_ISO_639_language_code, p, 4 ); sdt_multilingual_des-sdt_ISO_639_language_code sdt_ISO_639_language_code = htonl( sdt_multilingual_des-sdt_ISO_639_lang

14、uage_code ); p += 3; memcpy( &sdt_multilingual_des-sdt_service_provider_name, p + 1, *p ); sdt_multilingual_des-sdt_service_provider_name *p = 0; p += *p; p += 1; memcpy( &sdt_multilingual_des-sdt_service_name, p + 1, *p ); sdt_multilingual_des-sdt_service_name *p = 0; p += *p; p += 1; /* 建立链表关系 */

15、if( !sdt_info-sdt_multilingual_node ) sdt_info-sdt_multilingual_node = sdt_multilingual_des; else multi_tmp = sdt_info-sdt_multilingual_node; while( multi_tmp ) if( !multi_tmp-next ) break; multi_tmp = multi_tmp-next; multi_tmp-next = sdt_multilingual_des; multi_tmp-next-next = NULL; break; default:

16、 /* others descriptor_tag */ p += 2 + p1; break; return true;/* PAT-SECTION处理函数 */bool CTsParser:OnPatSection( void* filter, unsigned char *buf, int32_t size ) unsigned char *p, *q; uint16_t service_id; uint16_t pmt_pid; SProgInfo spi; void *position; uint32_t crc32, ival; unsigned char version_numb

17、er, section_number, last_section_number; TSSDTInfo sdt; /* pat/pmt的尺寸不可能超过1024字节 */ if( 1024 1) & 0x1f; section_number = buf6; last_section_number = buf7; if( last_section_number 1) & 0x1f) | last_section_number != m_pat_buf7 ) ) OCG_FREE( m_pat_buf ); m_pat_buf = NULL; m_pat_size = 0; position = m_

18、pmtmap.GetFirst( &pmt_pid, &spi ); while( position ) if( spi.filter ) m_demux.DestroyFilter( spi.filter ); if( spi.pmt_buf ) OCG_FREE( spi.pmt_buf ); position = m_pmtmap.GetNext( &pmt_pid, &spi, position ); m_pmtmap.RemoveAll(); if( m_pat_buf = NULL ) m_pat_size = ( last_section_number + 1 ) * 1024;

19、 m_pat_buf = (unsigned char*)OCG_MALLOC( m_pat_size ); if( m_pat_buf = NULL ) return false; memset( m_pat_buf, 0xff, m_pat_size ); /* 如果SECTION已经存在，则不必再次处理 */ p = m_pat_buf; while( *p != 0xff & p m_pat_buf + m_pat_size ) if( p6 = section_number ) return false; p += 3 + (p1&0xf)8) + p2; /* BUFFER不够大:

20、 不可能出现 */ if( m_pat_buf + m_pat_size p + size ) OCG_ASSERT( false ); return false; /* 保存PAT-SECTION */ memcpy( p, buf, size ); /* 提取PMT信息 */ q = p; p += 8; while( p + 4 = q + size - 4 ) service_id = (p08) | p1; p += 2; if( service_id != 0 ) pmt_pid = (p0&0x1f)8) | p1; /* 如果是第一次找到该PMT，则添加 */ if( m_pm

21、tmap.Search( pmt_pid, &spi ) = NULL ) memset( &spi, 0, sizeof(spi) ); /* 开始过滤PMT */ spi.filter = m_demux.CreateFilterExt( pmt_pid, 0x02, 0xff, service_id, 0xffff, 1024, CTsParser:FilterProc, (uint32_t)this ); /* 添加 */ m_pmtmap.Insert( pmt_pid, spi ); /* 如果是第一次找到该SDT，则添加 */ if( NULL = m_sdtmap.Search

22、( service_id, &sdt ) ) memset( &sdt, 0, sizeof(sdt) ); sdt.sdt_service_id = service_id; sdt.bIsSucceed = false; /* 添加 */ m_sdtmap.Insert( service_id, sdt ); p += 2; return true;/* PMT-SECTION处理函数 */bool CTsParser:OnPmtSection( void* filter, unsigned char *buf, int32_t size ) uint16_t pmt_pid; SProgInfo *pspi; void *position; uint32_t crc32, ival; int32_t len; unsigned char *p; /* pat/pmt的尺寸不可能超过1024字节 */ if( 1024 filter = filter ) /* 保存 */ if( pspi-pmt_buf & pspi-pmt_size size