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

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

DVD

开发平台：

C/C++

kb_dc_dataparse.c：源码内容
  2. //-----------------------------------------------------------------------------
  3. // Project include files:
  4. //-----------------------------------------------------------------------------
  5. #include "kb_dc_pub.h"
  8. DCDIR  *gDCDir = NULL;
  9. DCFILE *gDCFile = NULL;
  10. unsigned long gDcTimeOut = 0;
  14. void ResetTimeOut(void)
  15. {
  16. gDcTimeOut=0;
  17. }
  20. //-----------------------------------------------------------------------------
  21. // FUNCTION:    SetDCDIR
  22. //
  23. // DESCRIPTION: 设置当前DIR 
  24. //
  25. // RETURN:      
  26. //
  27. // NOTES:       None
  28. //-----------------------------------------------------------------------------
  29. void  SetDCDIR(DCDIR *dir)
  30. {
  31.     gDCDir=dir;
  32. }
  34. //-----------------------------------------------------------------------------
  35. // FUNCTION:    GetDCDIR
  36. //
  37. // DESCRIPTION: 获得当前DIR 
  38. //
  39. // RETURN:      
  40. //
  41. // NOTES:       None
  42. //-----------------------------------------------------------------------------
  43. pDCDIR  GetDCDIR()
  44. {
  45.    return gDCDir;
  46. }
  50. //-----------------------------------------------------------------------------
  51. // FUNCTION:    SetDCFILE
  52. //
  53. // DESCRIPTION: 设置当前文件指针
  54. //
  55. // RETURN:      
  56. //
  57. // NOTES:       None
  58. //-----------------------------------------------------------------------------
  59. void SetDCFILE(DCFILE *file)
  60. {
  61.     gDCFile=file;
  62. }
  63. //-----------------------------------------------------------------------------
  64. // FUNCTION:    GetDCFILE
  65. //
  66. // DESCRIPTION: 获得当前的文件指针
  67. //
  68. // RETURN:      
  69. //
  70. // NOTES:       None
  71. //-----------------------------------------------------------------------------
  72. pDCFILE GetDCFILE( )
  73. {
  74.    return  gDCFile;
  75. }
  79. //-----------------------------------------------------------------------------
  80. // FUNCTION:    ParseDIISection
  81. //
  82. // DESCRIPTION: DII section pareser
  83. //
  84. // RETURN:      None
  85. //
  86. // NOTES:        
  87. //-----------------------------------------------------------------------------
  88. int ParseDIISection(const char* fileName,unsigned char *buf,unsigned long length)
  89. {
  90.     DCFILE *file;
  91.     DCDIR *dir;
  92.   
  93.     // 获得dir 结构
  94.     dir = OpenDirectory(buf,(int)length);    
  95.     if(dir==NULL)   
  96.     {
  97.        DCDebug1("n OpenDirectory error");
  98.          return 0;
  99.     }
  101.     SetDCDIR(dir);
  102.     dir = GetDCDIR();   
  104.     //根据filename解析生成file
  105.     file=DcOpenFile(dir,fileName);
  106.     if(file==NULL)
  107.     {
  108.   DCDebug1("n DcOpenFile error");
  109.   return 0;
  110.     }
  111.     SetDCFILE(file);
  112.     
  113.     return 1; 
  114. }
  117. //-----------------------------------------------------------------------------
  118. // FUNCTION:    ParseModuleDDBSection
  119. //
  120. // DESCRIPTION: 解析一个module的所有DDB数据
  121. //
  122. // RETURN:      None
  123. //
  124. // NOTES:        
  125. //-
  126. int ParseModuleDDBSection(unsigned char *buf,unsigned int firstmodId)
  127. {
  128. DDBHead head;
  129. unsigned char *data,*pTemp;
  130. int length;   
  131. DCFILE *file;
  132. unsigned int modId, index;
  134. file=GetDCFILE();
  135. if(file==NULL) return 0;
  137. // get ddb data
  138. GetDDBHead(buf,&head);
  139. modId = head.moduleID;
  140. data = GetDDBData(buf,&length);   
  141. file->position+=length;     
  143. if(head.blockNumber>255||head.blockNumber>=file->BufStatus.modStat[index].blockCount)
  144. {
  145. DCDebug1("n head.blockNumber[%d] out of range", head.blockNumber);
  146. return 0;
  147. }
  149. DCDebug2("nnthe blockNumber is %d,the length is %d of moduleid:%d n",head.blockNumber,length,modId);
  150. DCDebug4("nnow the file.position is %dn",file->position); 
  152. //the data will be written into the file->section structure in cycle   
  153. pTemp=(file->section)  + (head.blockNumber)*(4066);
  155. KBDcMemcpy((void*)pTemp,(const void*)data,(size_t)length); 
  157. //填充buffer 状态
  158. index = modId - firstmodId;
  159. if(file->BufStatus.modcount>0&&file->BufStatus.modStat!=NULL)
  160. {
  161. if(file->BufStatus.modStat[index].blockCount>0&&file->BufStatus.modStat[index].blockStat!=NULL)
  162. {
  163. file->BufStatus.modStat[index].blockStat[head.blockNumber] = FILLED;
  164. }
  165. }
  167. return 1;
  169. #if 0
  170. PrintfDDBData(data,length,head.blockNumber);
  171. printf("nn------------------n");
  172. PrintfDDBData(((file->section)  + (head.blockNumber)*(4066)), length,  head.blockNumber);
  173. #endif
  174.    
  175. }
  177. //----------------------------------------------------------------------------
  178. // DESCRIPTION: 解析一个文件所包含的所有DDB数据，它调用ParseModuleDDBSection()
  179. //-
  180. int ParseALLDDBSection(unsigned char *buf,unsigned int firstModId)
  181. {
  182. unsigned int DDBOfmoduleId; 
  183. DCFILE *file;
  184. DDBHead head;   
  185. int filemodNum = 0;
  186. int index = 0;
  188. file = GetDCFILE();
  189. if(file==NULL)
  190. {
  191. DCDebug1("n  file or is NULL!!!");
  192. return -4;
  193. }
  195. GetDDBHead(buf,&head);
  196. DDBOfmoduleId = head.moduleID;
  197. filemodNum = DCGetModNumByFile(file);   
  198. if(filemodNum<0)
  199. {
  200. DCDebug1("n DCGetModNumByFile error!!!");
  201. return -3;
  202. }
  204. // 判断该DDB是否是在制定文件所包含的module范围内
  205. // 如果不是，则不作任何处理
  206. // 判断一个DDB是否已经接收，如果是，则不作任何处理。
  207. if(DDBOfmoduleId<firstModId
  208. ||DDBOfmoduleId>=firstModId+filemodNum)
  209. {
  210. DCDebug1("n block number[mod=%d] out of module range!!!", DDBOfmoduleId);
  211. DCDebug1("n firstModId=%d    filemodNum=%d",firstModId, filemodNum);
  212. return -1;   
  213. }
  215. index = DDBOfmoduleId-firstModId;
  216. if(index < 0) index = 0;
  218. if(head.blockNumber>255||head.blockNumber>=file->BufStatus.modStat[index].blockCount)
  219. {
  220. DCDebug1("n head.blockNumber[%d] out of range", head.blockNumber);
  221. return -5;
  222. }
  224. if(file->BufStatus.modcount>0&&file->BufStatus.modStat!=NULL)
  225. {
  226. if(file->BufStatus.modStat[index].blockCount>0&&file->BufStatus.modStat[index].blockStat!=NULL)
  227. {
  228. if(file->BufStatus.modStat[index].blockStat[head.blockNumber]==FILLED)
  229. {
  230. DCDebug3("n mod[%d]:  %d already  received!!!", index, head.blockNumber);
  231. // 记录重复收取section的次数，过多的重复收取被认为是
  232. // 可能存在错误，需要强制退出数据过滤以进行其它冗余处理
  233. gDcTimeOut++;
  234. if((gDcTimeOut/(file->BufStatus.modStat[index].blockCount))>=5)
  235. {
  236. gDcTimeOut=0;
  237. DCDebug2("n too many repeat, begin  one-by-one filter mode!");
  238. return -2;
  239. }
  240. else
  241. return 0;
  242. }
  243. }
  245. }
  247. //解析一个DDB
  248. if(ParseModuleDDBSection(buf,firstModId)==0)
  249. {    
  250. DCDebug1("n ParseModuleDDBSection return error!");
  251.        return -6;
  252. }     
  255. // 读取完一个file的所有module的所有DDB section
  256. if(file->position == file->fileLength)
  257. {    
  258. DCDebug2("nn all modules been parsed[%d]vs[%d]n", file->position, file->fileLength);
  259. //PrintfDCFileData(GetDCFILE());
  260.        return 1;
  261. }     
  263. return 0;
  264. }
  268. //-----------------------------------------------------------------------------
  269. // FUNCTION:    printfFileData
  270. //
  271. // DESCRIPTION: 打印文件数据
  272. //
  273. // RETURN:      None
  274. //
  275. // NOTES:        
  276. //-
  277. void PrintfDCFileData(DCFILE *file)
  278. {
  279. int i;
  280. unsigned int line = 0x00000000;
  282. DCDebug4("[%s]:[%ld]n", file->fileName, file->fileLength);
  283. for(i=0;i<file->fileLength;i++) 
  284. {   
  285. if(i==0)
  286. {
  287. DCDebug4("n");
  288. DCDebug4("%x: ",line);
  289. }
  291. DCDebug4("%4.2x",file->section[i]);  
  292. if((i+1)%16==0)
  293. {      
  294. line = line + 16;
  295. DCDebug4("n");
  296. DCDebug4("%x: ",line);   
  297. }  
  298. }  
  299. DCDebug4("n print endn");
  301. return;
  302. }
  304. void PrintfDDBData(unsigned char *data, int size,int blockNo)
  305. {
  306.        int i;
  307.       unsigned int line = 0x00000000;
  309.        DCDebug4("n--------------PrintfDDBData------------------");
  310.        for(i=0;i<size;i++) 
  311. {   
  312. if(i==0)
  313. {
  314. DCDebug4("n");
  315. DCDebug4("%x: ",line);
  316. }
  317.        
  318. DCDebug4("%4.2x",data[i]);  
  319. if((i+1)%16==0)
  320. {      
  321.   line = line + 16;
  322.   DCDebug4("n");
  323.   DCDebug4("%x: ",line);   
  324. }
  325. }          
  327. DCDebug4("n print ddb %d end",blockNo);
  328. return;
  329. }