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

源码开发语言/平台
当前位置：首页 > 源码/资料 > 多媒体 > mpeg/mp3 > 查看源码
PatParse.cpp
资源名称：PSParse.rar　[点击查看]
上传用户：thjx518
上传日期：2022-03-16
资源大小：179k
文件大小：7k
源码类别：

mpeg/mp3

开发平台：

Visual C++

PatParse.cpp：源码内容
  1. // PatParse.cpp: implementation of the CPatParse class.
  2. //
  3. //////////////////////////////////////////////////////////////////////
  5. #include "stdafx.h"
  6. #include "PSParse.h"
  7. #include "PatParse.h"
  11. //////////////////////////////////////////////////////////////////////
  12. // Construction/Destruction
  13. //////////////////////////////////////////////////////////////////////
  14. int ParsePat(CTSParse*ts,PATType*pat)
  15. {
  16. CPrivateSection ps(ts,0);
  17. UCHAR buf[1024];
  18. memset(buf,0,1024);
  19. ps.GetSections(buf,0);
  20. pat->tableId =GET_8(buf,0);
  21. pat->streamId =GET_16(buf,3);
  22. pat->versionNo =GET_5(buf,5,5);
  23. pat->sectionLength =GET_12((buf+1),0);
  24. int len=pat->sectionLength-4-5;
  25. UCHAR *p=buf+8;
  26. pat->numProgs=0;
  27. for(int i=0;len>0;i++){
  28. pat->programs[i].programNumber=GET_16(p,0);
  29. pat->programs[i].programMapPID=GET_13(p,2);
  30. pat->numProgs++;
  31. len-=4;p+=4;
  32. }
  33. return pat->numProgs;
  34. }
  35. int ParsePmt(CTSParse*ts,PMTType*pmt,USHORT pmtpid)
  36. {
  37. CPrivateSection ps(ts,pmtpid);
  38. UCHAR buf[102400];
  39. ps.GetSections(buf,2);
  40. pmt->tableId=GET_8(buf,0);
  41. pmt->programNumber =GET_16(buf,3);
  42. pmt->versionNo =GET_5(buf,5,1);
  43. pmt->tableId = GET_8(buf, 0);
  44. pmt->sectionLength = GET_12(buf, 1);
  45. pmt->programNumber = GET_16(buf, 3);
  46. pmt->versionNo = GET_5(buf, 5, 5);
  47. pmt->pcrPid = GET_13(buf, 8);
  48. int len=GET_12(buf,10);
  49. int offset=12;
  50. int i;
  51. pmt->numDescriptors=0;
  52. for(i=0;len>0;i++){
  53. pmt->descriptor[i].tag=GET_8(buf,offset++);
  54. int dsclen=GET_8(buf,offset++);
  55. pmt->descriptor[i].length=dsclen;
  56. memcpy(pmt->descriptor[i].data,buf+offset,dsclen);
  57. len-=dsclen+2;
  58. offset+=dsclen;
  59. pmt->numDescriptors++;
  60. }
  61. pmt->numStreams=0;
  62. for(i=0;offset<pmt->sectionLength-4;i++)
  63. {
  64. pmt->stream[i].typeOfStream=GET_8(buf,offset++);
  65. pmt->stream[i].pid=GET_13(buf,offset);
  66. offset+=2;
  67. len=GET_12(buf,offset);
  68. offset+=2;
  69. pmt->stream[i].numDescriptors=0;
  70. for(int j=0;len>0;j++){
  71. pmt->stream[i].descriptor[i].tag=GET_8(buf,offset++);
  72. int dsclen=GET_8(buf,offset++);
  73. pmt->stream[i].descriptor[i].length=dsclen;
  74. memcpy(pmt->stream[i].descriptor[i].data,buf+offset,dsclen);
  75. len-=dsclen+2;
  76. offset+=dsclen;
  77. pmt->stream[i].numDescriptors++;
  78. }
  79. pmt->numStreams++;
  80. }
  81. return 0;
  82. }
  84. int ParseNit(CTSParse*ts,NITType*nit,bool actual)
  85. {
  86. CPrivateSection ps(ts,0x10);
  87. UCHAR buf[102400];
  88. ps.GetSections(buf,actual?0x40:0x41);
  89. nit->tableId=GET_8(buf,0);
  90. nit->networkId =GET_16(buf,3);
  91. nit->versionNo =GET_5(buf,5,1);
  92. nit->tableId = GET_8(buf, 0);
  93. nit->sectionLength = GET_12(buf, 1);
  94. nit->versionNo = GET_5(buf, 5, 5);
  95. int len=GET_12(buf,8);//get network descriptor length 
  96. int offset=10;
  97. int i;
  98. nit->numDescriptors=0;
  99. for(i=0;len>0;i++){
  100. nit->descriptor[i].tag=GET_8(buf,offset++);
  101. int dsclen=GET_8(buf,offset++);
  102. nit->descriptor[i].length=dsclen;
  103. memcpy(nit->descriptor[i].data,buf+offset,dsclen);
  104. len-=dsclen+2;
  105. offset+=dsclen;
  106. nit->numDescriptors++;
  107. }
  108. len=GET_12(buf,offset);
  109. offset+=2;
  110. nit->numStreams=0;
  111. for(i=0;offset<nit->sectionLength-4;i++)
  112. {
  113. nit->stream[i].streamId=GET_16(buf,offset);
  114. nit->stream[i].networkId=GET_16(buf,offset+2);
  115. int len=GET_12(buf,offset+4);
  116. offset+=6;
  117. nit->stream[i].numDescriptors=0;
  118. for(int j=0;len>0;j++)
  119. {
  120. nit->stream[i].descriptor[j].tag=GET_8(buf,offset++);
  121. int dsclen=GET_8(buf,offset++);
  122. nit->stream[i].descriptor[j].length=dsclen;
  123. memcpy(nit->stream[i].descriptor[j].data,buf+offset,dsclen);
  124. offset+=dsclen;
  125. len-=2+dsclen;
  126. nit->stream[i].numDescriptors++;
  127. }
  128. nit->numStreams++;
  129. }
  130. return 0;
  131. }
  132. int ParseSdt(CTSParse*ts,SDTType*sdt,bool actual)
  133. {
  134. CPrivateSection ps(ts,0x11);
  135. UCHAR buf[102400];
  136. ps.GetSections(buf,actual?0x42:0x46);
  137. sdt->tableId=GET_8(buf,0);
  138. sdt->streamId =GET_16(buf,3);
  139. sdt->versionNo =GET_5(buf,5,1);
  140. sdt->tableId =GET_8(buf, 0);
  141. sdt->sectionLength =GET_12(buf, 1);
  142. sdt->versionNo =GET_5(buf, 5, 5);
  143. sdt->origNetId =GET_16(buf,8);//get original network id
  144. int offset=11;
  145. sdt->numServices=0;
  146. for(int i=0;offset<sdt->sectionLength-4;i++)
  147. {
  148. sdt->service[i].serviceId=GET_16(buf,offset);
  149. offset+=2;
  150. sdt->service[i].eitSchedule=GET_1(buf, offset, 1);
  151. sdt->service[i].eitPresent= GET_1(buf, offset, 0);
  152. offset++;
  153. sdt->service[i].runningStatus= GET_3(buf, offset, 7);
  154. sdt->service[i].freeCAMode = GET_1(buf, offset, 4);
  155. int len=GET_12(buf,offset);
  156. offset+=2;
  157. sdt->service[i].numDescriptors=0;
  158. for(int j=0;len>0;j++){
  159. sdt->service[i].descriptor[j].tag=GET_8(buf,offset++);
  160. int dsclen=GET_8(buf,offset++);
  161. sdt->service[i].descriptor[j].length=dsclen;
  162. memcpy(sdt->service[i].descriptor[j].data,buf+offset,dsclen);
  163. len-=2+dsclen;
  164. offset+=dsclen;
  165. sdt->service[i].numDescriptors++;
  166. }
  167. sdt->numServices++;
  168. }
  169. return 0;
  170. }
  171. int ParseEit(CTSParse*ts,EITType*eit,UCHAR tableid,USHORT serviceid)
  172. {
  173. CPrivateSection ps(ts,0x12);
  174. UCHAR buf[102400];
  175. ps.GetSections(buf,tableid,serviceid);
  176. eit->tableId=GET_8(buf,0);
  177. eit->serviceId =GET_16(buf,3);
  178. eit->versionNo =GET_5(buf,5,1);
  179. eit->tableId =GET_8(buf, 0);
  180. eit->sectionLength =GET_12(buf, 1);
  181. eit->versionNo =GET_5(buf, 5, 5);
  182. eit->streamId =GET_16(buf,8);//get original network id
  183. eit->numEvents=0;
  184. int offset=14;
  185. eit->numEvents=0;
  186. for(int i=0;offset<eit->sectionLength-4;i++)
  187. {
  188. eit->event[i].eventId=GET_16(buf,offset);
  189. offset+=2;
  190. eit->event[i].startTimeHi=GET_32(buf,offset);
  191. offset+=4;
  192. eit->event[i].startTimeLo=GET_8(buf,offset++);
  193. eit->event[i].duration=GET_24(buf,offset);
  194. offset+=3;
  195. eit->event[i].runningStatus=(RunStatusType)GET_3(buf,offset,5);
  196. eit->event[i].caMode=(CAModeType)GET_1(buf,offset,4);
  197. int len=GET_12(buf,offset);
  198. offset+=2;
  199. eit->event[i].numDescriptors=0;
  200. for(int j=0;len>0;j++)
  201. {
  202. eit->event[i].descriptor[j].tag=GET_8(buf,offset++);
  203. int dsclen=GET_8(buf,offset++);
  204. eit->event[i].descriptor[j].length=dsclen;
  205. memcpy(eit->event[i].descriptor[j].data,buf+offset,dsclen);
  206. offset+=dsclen;
  207. len-=2+dsclen;
  208. eit->event[i].numDescriptors++;
  209. }
  210. eit->numEvents++;
  211. }
  212. return 0;
  213. }
  214. void GetDateTimeFromMJD(__int64 mjd,char*tmstr)
  215. {
  216. UINT y1,m1,yy,mm,dd;
  217. USHORT k,hh,min,sec;
  218. UINT utc=mjd&0xffffff;
  219. mjd=mjd>>24;
  220. y1=(int)((mjd-15078.2)/365.25);
  221. m1=(int)((mjd-14956.1-(int)(y1*365.25))/30.6001);
  222. dd=mjd-14956-(int)(y1*365.25)-(int)(m1*30.6001);
  223. k=(m1==14||m1==15)?1:0;
  224. yy=y1+k;
  225. mm=m1-1-k*12;
  226. hh=(utc>>16)&0xff;
  227. min=(utc>>8)&0xff;
  228. sec=utc&0xff;
  229. sprintf(tmstr,"%04d-%02d-%02d %02x:%02x:%02x",
  230. 1900+yy,mm,dd,hh,min,sec);
  231. }