开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 多媒体 > DVD > 查看源码
kb_dc_sipsi.c
资源名称：ST_5105DTV.rar　[点击查看]
上传用户：fy98168
上传日期：2015-06-26
资源大小：13771k
文件大小：14k
源码类别：

DVD

开发平台：

C/C++

kb_dc_sipsi.c：源码内容
  1. //-----------------------------------------------------------------------------
  2. // Project include files:
  3. //-----------------------------------------------------------------------------
  4. #include "kb_dc_pub.h"
  6. static KBDsmccPat KBDsmccPAT;
  7. static KBDsmccPmts KBDsmccPMTs;
  8. static KBDsmccEsArray KBDsmccEsAry;
  9. static KBServiceCfgDesArry KBSerCfgDesAry;
  10. extern unsigned char byFilterBuf[];
  12. //用于存储DII version 结构
  13. static KBDSMCCDIIVERSIONARRAY curDiiVer;
  16. int KBDsmccGetPAT(unsigned int tsId, unsigned char *buf)
  17. {    
  18. int  sErr = Err_OK;
  19. unsigned short iDataSize = 0;
  21. tsId = tsId;
  22. if(KB_DC_FilterReSet(0x00, 0x00, UNSET_PARAM, UNSET_PARAM, 0)!=0)
  23. {
  24. DCDebug1("n KBDsmccGetPAT: KB_DC_FilterSet error!");
  25. return -1;
  26. }
  28. sErr  = KB_DC_GetSection(buf, &iDataSize);
  29. if(Err_OK != sErr)
  30. {
  31. DCDebug1("nrGet section error[%d].rn",sErr );
  32. return sErr;
  33. }
  35. return sErr;
  36. }
  38. int KBDsmccGetPMT(unsigned short pid, unsigned int proNo, unsigned char *buf)
  39. {
  40. //return KBDsmccGetTable(pid, 0x02, proNo, buf, 0);
  41. int  sErr = Err_OK;
  42. unsigned short iDataSize = 0;
  44. if(KB_DC_FilterReSet(pid, 0x02, proNo, UNSET_PARAM, 0)!=0)
  45. {
  46. DCDebug1("n KBDsmccGetPAT: KB_DC_FilterSet error!");
  47. return -3;
  48. }
  50. sErr  = KB_DC_GetSection(buf, &iDataSize);
  51. if(Err_OK != sErr)
  52. {
  53. DCDebug1("nrGet section error[%d].rn",sErr );
  54. return sErr;
  55. }
  57. return sErr;
  58. }
  60. int KBDsmccGetDIITable(unsigned short pid, unsigned short extId, unsigned char **buf)
  61. {
  62. return KBDcGetTable(pid, 0x3b, extId, buf, 0);
  63. //return KBDcGetTable(pid, 0x3b, PROGRAM_DONT_CARE, buf, 0);
  64. }
  66. int KBDsmccGetDDBTable(unsigned short pid, unsigned short moduleId, unsigned char **buf)
  67. {
  68. //return KBDsmccGetTable(pid, 0x3c, moduleId, buf, 0);
  69. return KBDcGetTable(pid, 0x3c, moduleId, buf, 0);
  70. }
  72. void KBFreeSectionBuffer(unsigned char * buf)
  73. {
  74. if(buf!=NULL)
  75. {
  76. KBDcFree(buf);
  77. buf=NULL;   
  78. } 
  79. }
  81. int KBDsmccSipsiProc(unsigned int tsId)
  82. {
  83. unsigned char *buf=NULL;
  84. int programCnt=0, esCnt=0, dsmccEsCnt=0;
  85. int i=0;
  86. UINT32  sErr = Err_OK;
  87. int res =0;
  89. //先初始化变量
  90. KB_DC_SipsiDataInit();
  92. buf = (unsigned char *)KBDcMalloc(PSI_SECTION_SIZE);
  93. if(buf==NULL) 
  94. {
  95.        return 0;
  96. }
  97. KBDcMemset(buf, 0x00, PSI_SECTION_SIZE);
  99. DCDebug3("n get PAT");
  100. sErr=KBDsmccGetPAT(tsId, buf);  
  101. if(Err_OK != sErr)
  102. {
  103. DCDebug1("nr KBDsmccGetPAT error[%d].rn",sErr );
  104. KBFreeSectionBuffer(buf);
  105. return 0;
  106. }
  107. programCnt=KBDsmccParsePAT(buf);
  108. DCDebug3("n got PAT");
  110. DCDebug2("n programCnt=%d",programCnt);
  111.        /*以防多次调用进行不必要的累加  shriek*/
  112. KBDcMemset(&KBDsmccPMTs, 0x00, sizeof(KBDsmccPmts));
  113. for(i=0; i<programCnt; i++)
  114. {
  115. KBDsmccPmt *pmt=NULL;
  116. KBDsmccPatInfo *patInfo=&KBDsmccPAT.pat_info[i];
  118. DCDebug3("nn---- patInfo->pmt_pid=%x,     patInfo->program_number=%x",patInfo->pmt_pid,patInfo->program_number);
  119. if(patInfo==NULL) 
  120. {
  121. KBFreeSectionBuffer(buf);
  122. return 0;
  123. }
  125. DCDebug3("n get PMT");
  127. sErr = KBDsmccGetPMT(patInfo->pmt_pid, patInfo->program_number, buf);
  128. if(Err_OK != sErr)
  129. {
  130. DCDebug1("nr KBDsmccGetPMT error[%d].rn",sErr );
  131. KBFreeSectionBuffer(buf);
  132. return 0;
  133. }
  134. DCDebug3("n got PMT");
  136. pmt = &KBDsmccPMTs.pmts[KBDsmccPMTs.count];
  137. esCnt=KBDsmccParsePMT(buf, pmt);
  138. if(esCnt<0)
  139. {
  140. KBFreeSectionBuffer(buf);
  141. KBDsmccReleaseAllPMTs();
  142. return 0;
  143. }
  145. KBDsmccPMTs.count++;
  146. }
  148. dsmccEsCnt=KBBuildDsmccEsArray();
  149. if(dsmccEsCnt==0) 
  150.     res = 0;
  151. else 
  152.     res =1;
  154. KBFreeSectionBuffer(buf);
  155. KBDsmccReleaseAllPMTs();
  157. return res;
  158. }
  161. int KBDsmccParsePAT(const unsigned char *pat_section)
  162. {
  163. const unsigned char *p=pat_section;
  164. KBDsmccPat *pat=&KBDsmccPAT;
  165. int cnt=0;
  166. int section_len=0, loop_len=0;
  167. unsigned short pid=0, number=0;
  169. p++;
  170. section_len=((unsigned short)(p[0]<<8)|p[1])&0x0fff;
  171. p+=2;
  172. pat->transport_stream_id=(unsigned short)(p[0]<<8)|p[1];
  173. p+=2;
  174. pat->version=(p[0]>>1)&0x1f;
  175. p++;
  176. p+=2;
  178. //info loop , no include nit 
  179. loop_len=section_len+3-8-4;
  180. while(loop_len>0)
  181. {
  182. number=(unsigned short)(p[0]<<8)|p[1];
  183. p+=2;
  184. pid=((unsigned short)(p[0]<<8)|p[1])&0x1fff;
  185. p+=2;
  186. if(number==0) 
  187. {
  188. loop_len-=2+2;
  189. continue;//skip nit
  190. }
  191. if((cnt+1)>KB_DSMCC_PAT_INFOS_MAX) break;
  192. pat->pat_info[cnt].pmt_pid=pid;
  193. pat->pat_info[cnt].program_number=number;
  194. cnt++;
  196. loop_len-=2+2;
  197. }
  198. //if(loop_len==0) DCDebug4("PAT loop length check OK=%d...n", loop_len);
  199. pat->pat_info_count=cnt;
  201. return cnt;
  202. }
  204. int KBDsmccParsePMT(const unsigned char *pmt_section, KBDsmccPmt *pPmt)
  205. {
  206. const unsigned char *p=pmt_section;
  207. KBDsmccPmt *pmt=pPmt;
  208. int section_len=0,  es_loop_len=0;
  209. int cnt=0;
  211.        DCDebug4("rn------KBDsmccParsePMT:%x %x %x %x %x %x %x %x %x ", p[0], p[1],p[2],p[3],p[4],p[5],p[6],p[7],p[8]);
  213. p++;
  214. section_len=((unsigned short)(p[0]<<8)|p[1])&0x0fff;
  215. p+=2;
  216. pmt->program_number=(unsigned short)(p[0]<<8)|p[1];
  217. p+=2;
  218. pmt->version=(p[0]>>1)&0x1f;
  219. p++;
  220. p+=2;
  221. pmt->pcr_pid=((unsigned short)(p[0]<<8)|p[1])&0x1fff;
  222. p+=2;
  224. pmt->info_length=((unsigned short)(p[0]<<8)|p[1])&0x0fff;
  225. p+=2;
  226. if(pmt->info_bytes!=NULL) 
  227. {
  228. KBDcFree(pmt->info_bytes); 
  229. pmt->info_bytes=NULL;
  230. }
  232. if(pmt->info_length!=0)
  233. {
  234. pmt->info_bytes=(unsigned char*)KBDcMalloc((UINT32)sizeof(unsigned char)*(UINT32)(pmt->info_length));
  235. if(pmt->info_bytes==NULL)
  236. {
  237. return -1;
  238. }
  239. KBDcMemset(pmt->info_bytes, 0x00, (UINT32)sizeof(unsigned char)*(UINT32)(pmt->info_length));
  240. KBDcMemcpy(pmt->info_bytes, p, pmt->info_length);
  241. }
  244. p+=pmt->info_length;
  246. es_loop_len=section_len+3-12-pmt->info_length-4;
  247. while(es_loop_len>0)
  248. {
  249. unsigned char stream_type=0;
  250. unsigned short es_pid=0;
  251. int len=0;
  252. unsigned char *temp=NULL;
  254. stream_type=*p++;
  255. es_pid=((unsigned short)(p[0]<<8)|p[1])&0x1fff;
  256. p+=2;
  257. if((cnt+1)>KB_DSMCC_PAT_INFOS_MAX) break;
  258. pmt->pmt_es[cnt].es_pid=es_pid;
  259. pmt->pmt_es[cnt].stream_type=stream_type;
  260. len=((unsigned short)(p[0]<<8)|p[1])&0x0fff;
  261. pmt->pmt_es[cnt].es_info_length=len;
  262. p+=2;
  263. if(temp!=NULL) 
  264. {
  265. KBDcFree(temp);
  266. temp=NULL;
  267. }
  269. if(len!=0)
  270. {
  271. temp=(unsigned char*)KBDcMalloc((UINT32)sizeof(unsigned char)*(UINT32)len);
  272. if(temp==NULL)
  273. {
  274. return -1;
  275. }
  276. KBDcMemcpy(temp, p, len);
  277. }
  278. pmt->pmt_es[cnt].es_info_bytes=temp;
  279. p+=len;
  280. cnt++;
  281. es_loop_len-=1+2+2+len;
  282. }
  284. pmt->pmt_es_count=cnt;
  285. return cnt;
  286. }
  288. const unsigned char*  KBGetDescriptor(unsigned char tag, const unsigned char *desBytes, int dlen)
  289. {
  290. const unsigned char *p=desBytes;
  292. while(dlen>0)
  293. {
  294. if(tag==p[0]) return p;
  295. dlen-=1+1+p[1];
  296. p+=1+1+p[1];
  297. }
  298. return NULL;
  299. }
  302. unsigned char KBParseDataBroadcastIdDescriptor(const unsigned char *dDes, int dLen, KBDsmccEs *es)
  303. {
  304. const unsigned char *p=dDes;
  306. if(p==NULL) return 0;
  308. es->data_broadcast_id=((unsigned short)(p[2]<<8))|p[3];
  309. p+=4;
  310. es->carousel_type_id=p[0]>>6;
  311. p++;
  312. es->transaction_id=((unsigned int)(p[0]<<24))|((unsigned int)(p[1]<<16))|((unsigned int)(p[2]<<8))|p[3];
  313. p+=4;
  314. es->DSI_timeout=((unsigned int)(p[0]<<24))|((unsigned int)(p[1]<<16))|((unsigned int)(p[2]<<8))|p[3];
  315. p+=4;
  316. es->DII_timeout=((unsigned int)(p[0]<<24))|((unsigned int)(p[1]<<16))|((unsigned int)(p[2]<<8))|p[3];
  317. p+=4;
  318. es->leak_rate=(((unsigned int)(p[1]<<16))|((unsigned int)(p[2]<<8))|p[3])&0x3fffff;
  319. p+=3;
  320. es->dii_version = *p;
  322. if(dLen==1+1+2+1+4*3+3+1) return 1;
  323. else return 0;
  324. }
  327. //parse private service configure descriptor
  328. unsigned char KBParseServCfgDescriptor(const unsigned char *dDes, int dLen, KBServiceCfgDes *servDes)
  329. {
  330. const unsigned char *p=dDes;
  331. unsigned int ctypelen =0, cnamelen=0;
  333. DCDebug3("n -[KBParseServCfgDescriptor]-: %x %x %x",dDes[0], dDes[1], dDes[2]);
  335. if(p==NULL) return 0;
  337. p+=2;
  338. ctypelen = p[0];
  339. if(ctypelen>KB_SERVICE_PRIVATEDES_NAME_MAX)
  340. {
  341. DCDebug1("n -[KBParseServCfgDescriptor]-ctypelen too overlong!");
  342. }
  343. KBDcMemcpy(servDes->CfgType, ++p, ctypelen);
  344. servDes->CfgType[ctypelen] = 0;
  345. p+=ctypelen;
  347. cnamelen = p[0];
  348. if(cnamelen>KB_SERVICE_PRIVATEDES_NAME_MAX)
  349. {
  350. DCDebug1("n -[KBParseServCfgDescriptor]-cnamelen too overlong!");
  351. }
  352. KBDcMemcpy(servDes->CfgName, ++p, cnamelen);
  353. servDes->CfgName[cnamelen] = 0;
  354. if(dLen == ctypelen+cnamelen+4)
  355. return 1;
  356. else
  357. {
  358. DCDebug1("n -[KBParseServCfgDescriptor]-dLen is error!");
  359. return 0;
  360. }
  361. }
  363. int KBBuildDsmccEsArray(void)
  364. {
  365. KBDsmccEsArray *ess=&KBDsmccEsAry;
  366. int i=0, j=0, k=-1,l =-1;
  368. for(i=0; i<KBDsmccPMTs.count; i++)
  369. {
  370. const KBDsmccPmt *pmt=&KBDsmccPMTs.pmts[i];
  371. for(j=0; j<pmt->pmt_es_count; j++)
  372. {
  373. const KBDsmccPmtEs *es=NULL;
  374. const unsigned char *dDes=NULL;
  375. es=&pmt->pmt_es[j];
  377. DCDebug3("n===es->stream_type=0x%02x", es->stream_type);
  378. if((es->stream_type==0x0C)||(es->stream_type==0x0B))
  379. {
  380. k++;
  381. ess->es[k].stream_type=es->stream_type;
  382. ess->es[k].es_pid=es->es_pid;
  383. ess->es[k].ts_id=KBDsmccPAT.transport_stream_id;
  385. //DataBroadcastIdDescriptor
  386. dDes=KBGetDescriptor(0x66, es->es_info_bytes, (int)es->es_info_length);
  387. if(dDes!=NULL)
  388. {
  389. KBParseDataBroadcastIdDescriptor(dDes, dDes[1]+2, &ess->es[k]);
  390. }
  391.     
  392. //service cfg descriptor in main frequency
  393. dDes=KBGetDescriptor(0x90, es->es_info_bytes, (int)es->es_info_length);
  394. if(dDes!=NULL)
  395. {
  396. l++;
  397. KBSerCfgDesAry.servDes[l].es_pid = ess->es[k].es_pid;
  398. KBSerCfgDesAry.servDes[l].transaction_id = ess->es[k].transaction_id;
  399. KBParseServCfgDescriptor(dDes, dDes[1]+2, &KBSerCfgDesAry.servDes[l]);
  400. KBSerCfgDesAry.count = l+1;
  402. DCDebug2("n --sercfgDes foud--!"); 
  403. DCDebug3("n es_pid=%d", KBSerCfgDesAry.servDes[l].es_pid);
  404. DCDebug3("n transaction_id=%d", KBSerCfgDesAry.servDes[l].transaction_id);
  405. DCDebug3("n CfgName=%s", KBSerCfgDesAry.servDes[l].CfgName);
  406. DCDebug3("n CfgType=%s", KBSerCfgDesAry.servDes[l].CfgType);
  407. }
  408. }
  409. }
  410. }
  411. ess->count=k+1;
  413. #if 1
  414. KBSerCfgDesAry.servDes[0].es_pid = 6200;
  415. strcpy((char *)KBSerCfgDesAry.servDes[0].CfgName, (const char *)"ServiceCfg.xml");
  416. strcpy((char *)KBSerCfgDesAry.servDes[0].CfgType, (const char *)"service_cfg_xml");
  417. KBSerCfgDesAry.count = 1;
  418. #endif
  420. DCDebug2("n Get dc data.dsmccEsCnt=%d", ess->count); 
  421. DCDebug2("n KBSerCfgDesAry.count=%d", KBSerCfgDesAry.count); 
  422. return (k+1);
  423. }
  425. #if 1
  426. /*-----------将ES DII version 信息存储--------*/
  427. int KB_DC_LoadCurDiiVerion(void)
  428. {
  429. int i,k=0;
  430. KBDSMCCDIIVERSIONARRAY KBDsmccDiiVersion; 
  432. DCDebug3("n ----KB_DC_LoadCurDiiVerion-----");
  433. KBDcMemset(&curDiiVer, 0x00, sizeof(KBDSMCCDIIVERSIONARRAY));
  435. //load
  436. for(i=0; i<KBDsmccEsAry.count; i++)
  437. {
  438. KBDsmccDiiVersion.esDiiVer[i].es_pid = KBDsmccEsAry.es[i].es_pid;
  439. KBDsmccDiiVersion.esDiiVer[i].dii_version =  KBDsmccEsAry.es[i].dii_version;
  440. KBDsmccDiiVersion.esDiiVer[i].ts_id =  KBDsmccEsAry.es[i].ts_id;
  441. k++;
  442. }
  443. KBDsmccDiiVersion.count = KBDsmccEsAry.count;
  444. //必须赋值为True，以标识不是开机第一次load
  445. KBDsmccDiiVersion.useFlag = True; 
  447. //store
  448. KBDcMemcpy(&curDiiVer, &KBDsmccDiiVersion , sizeof(KBDSMCCDIIVERSIONARRAY));
  450. return 1;
  451. }
  454. KBDSMCCDIIVERSIONARRAY *KB_DC_GetCurDiiVersionPtr(void)
  455. {
  456. return &curDiiVer;
  457. }
  459. // 功能:       监测DII 版本号是否更新，
  460. // 返回值:   是则返回1，
  461. //         否返回0
  462. //         错误返回-1
  463. int KB_DC_DiiVerCheck(unsigned int tsId)
  464. {
  465. int i=0;
  467. DCDebug3("n ---KB_DC_DiiVerCheck------");
  468.        //res = KBDsmccSipsiProc(0x00);
  469. //if(res<=0)
  470. //{
  471. // DCDebug4("n KB_DC_DiiVerCheck return error[%d]",res);
  472. // return -1;
  473. //}
  475. if(KBDsmccEsAry.count>=KB_DSMCC_ES_MAX)
  476. return -1;
  478. #if 1
  479. //开机第一次监测，应该返回1，强制去搜索配置文件
  480. if(curDiiVer.useFlag == False)
  481. {
  482. DCDebug3("n 开机第一次监测，所以返回1");
  483. curDiiVer.useFlag = True;
  484. return 1;
  485. }
  486. #endif
  488. DCDebug4("n ====KBDsmccEsAry.es[i].dii_version=%d", KBDsmccEsAry.es[0].dii_version);
  489. //判断DII version是否过期
  490. for(i=0; i<KBDsmccEsAry.count; i++)
  491. {
  492. DCDebug4("n KBDsmccEsAry: es_pid=%x, ts_id=%x", KBDsmccEsAry.es[i].es_pid, KBDsmccEsAry.es[i].ts_id);
  493. DCDebug4("n curDiiVer: es_pid=%x, ts_id=%x", curDiiVer.esDiiVer[i].es_pid, curDiiVer.esDiiVer[i].ts_id);
  494. if((curDiiVer.esDiiVer[i].es_pid==KBDsmccEsAry.es[i].es_pid)
  495. &&(curDiiVer.esDiiVer[i].ts_id==KBDsmccEsAry.es[i].ts_id))
  496. {
  497. DCDebug3("n cur_dii[%d]vs[%d]stream_dii", curDiiVer.esDiiVer[i].dii_version, KBDsmccEsAry.es[i].dii_version);
  498. if(curDiiVer.esDiiVer[i].dii_version!=KBDsmccEsAry.es[i].dii_version)
  499. {
  500. DCDebug3("n DII version is updated!!!!!!!!!!");
  501. //KB_DC_LoadCurDiiVerion();
  502. return 1;
  503. }
  504. else 
  505. {
  506. DCDebug3("n DII version not updated!");
  507. return 0;
  508. }
  509. }
  510. }
  512. return 1;
  513. }
  517. //--------------------------------end---------------------------------
  519. #endif
  522. void KB_DC_SipsiDataInit(void)
  523. {
  524. KBDcMemset(&KBDsmccEsAry, 0x00, sizeof(KBDsmccEsArray));
  525. KBDcMemset(&KBDsmccPMTs, 0x00, sizeof(KBDsmccPmts));
  526. KBDcMemset(&KBDsmccPAT, 0x00, sizeof(KBDsmccPat));
  527. KBDcMemset(&KBSerCfgDesAry, 0x00, sizeof(KBServiceCfgDesArry));
  528. }
  530. void KBDsmccReleasePMT(KBDsmccPmt *pmt)
  531. {
  532. int i=0;
  534. if(pmt==NULL) return;
  535. if(pmt->info_bytes!=NULL) 
  536. {
  537. KBDcFree(pmt->info_bytes);
  538. pmt->info_bytes=NULL;
  539. }
  540. for(i=0; i<pmt->pmt_es_count; i++)
  541. {
  542. KBDsmccPmtEs *es=&pmt->pmt_es[i];
  543. if(es==NULL) break;
  544. if(es->es_info_bytes!=NULL) 
  545. {
  546. KBDcFree(es->es_info_bytes);
  547. es->es_info_bytes=NULL;
  548. }
  549. }
  550. }
  552. void KBDsmccReleaseAllPMTs(void)
  553. {
  554. int i=0;
  555. for(i=0; i<KBDsmccPMTs.count; i++)
  556. KBDsmccReleasePMT(&KBDsmccPMTs.pmts[i]);
  557. }
  560. KBDsmccEsArray *KBGetDsmccEsArrayPtr(void)
  561. {
  562. KBDsmccEsArray *ess=&KBDsmccEsAry;
  563. return ess;
  564. }
  567. KBServiceCfgDes *KBGetSerCfgDesPtr( char *typeString)
  568. {
  569. int i;
  571. if(KBSerCfgDesAry.count==0)
  572. return NULL;
  574. for(i=0; i<KBSerCfgDesAry.count; i++)
  575. {
  576. if(0==strcmp((const char*)KBSerCfgDesAry.servDes[i].CfgType, (const char*)typeString))
  577. {
  578. return &KBSerCfgDesAry.servDes[i];
  579. }
  580. }
  582. return NULL;
  583. }
  585. //printf the content of EsArray
  586. int KBPrintDsmccEsArray(void)
  587. {
  588. KBDsmccEsArray *ess=&KBDsmccEsAry;
  589. int i;
  591.        DCDebug4("nn--------------------------------------------");
  592. for(i=0; i<ess->count; i++)
  593. {
  594.     DCDebug4("n   es_pid=%d",ess->es[i].es_pid);
  595. }
  597. DCDebug4("n--------------------------------------------nn");
  598. return (i+1);
  599. }