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

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

DVD

开发平台：

C/C++

kb_dc_task.c：源码内容
  2. #include "kb_dc_pub.h"
  3. #include "kb_dc_task.h"
  4. #include "kb_dc.h"
  5. #include "kb_machblue_client.h"
  6. #include "kb_machblue_client_task.h"
  7. #include "swf.h"
  9. static UINT32 kb_dc_queueID;
  10. static UINT32 _realtime_adver_timer = 0xffffffff;
  11. static unsigned short curCfgTsID = 0x1fff;
  13. extern mb_error_t kb_machblue_movie_close(BOOL Menu_Exit);
  14. void AdverTimerCallback(void);
  15. void movieInfoPrint(KB_MovieInfoNode *Info)
  16. {
  17. DCDebug2("n movieInfoPrint:Infoaddr=%x", Info);
  18. DCDebug2("n InfoPrint]: pid=[%d], fMid=[%d], name=[%s], size=[%d]...n", Info->st_MovieInfo.m_nPid, Info->st_MovieInfo.m_nFirstModuleId, Info->st_MovieInfo.m_strName, Info->st_MovieInfo.m_nSize);
  19. }
  21. BOOL KB_DcDataGet(KB_MovieInfoNode *pInfo)
  22. {
  23.      pInfo->st_MovieInfo.m_pData=KBDcMalloc((mb_size_t)pInfo->st_MovieInfo.m_nSize);
  24.      if(pInfo->st_MovieInfo.m_pData==NULL)
  25.      {
  26.      if(pInfo->st_MovieInfo.m_dataGet==kb_dc_data_searching)
  27. pInfo->st_MovieInfo.m_dataGet=kb_dc_data_no;
  29.         return FALSE;
  30.      }
  32.      if(kb_dc_getMovie(pInfo)==FALSE)
  33.      {
  34.      if(pInfo->st_MovieInfo.m_dataGet==kb_dc_data_searching)
  35. pInfo->st_MovieInfo.m_dataGet=kb_dc_data_no;
  37. mb_free(pInfo->st_MovieInfo.m_pData);
  39.          DCDebug1("n[Machblue]:Client get movie adver data error.");
  40.          return FALSE;
  41.      }   
  43.      KB_XmlParse((char*)pInfo->st_MovieInfo.m_pData, pInfo->st_MovieInfo.m_nSize);
  45.      mb_free(pInfo->st_MovieInfo.m_pData);
  47.      pInfo->st_MovieInfo.m_dataGet=kb_dc_data_searched;
  49.      return TRUE;
  50. }
  54. BOOL KB_DcMovieGet(KB_MovieInfoNode *pInfo)
  55. {
  56. pInfo->st_MovieInfo.m_pData=mb_malloc((mb_size_t)pInfo->st_MovieInfo.m_nSize);
  57. if(kb_dc_getMovie(pInfo)==FALSE)
  58. {
  59. if(pInfo->st_MovieInfo.m_dataGet==kb_dc_data_searching)
  60. pInfo->st_MovieInfo.m_dataGet=kb_dc_data_no;
  62. mb_free(pInfo->st_MovieInfo.m_pData);
  64. DCDebug1("n[Machblue]:Client get movie adver data error.");
  65. return FALSE;
  66. }   
  68. pInfo->st_MovieInfo.m_dataGet=kb_dc_data_searched;
  70. return TRUE;
  71. }
  73. void KB_DcMsgSend(KB_OSPMsgNode *msg)
  74. {
  75. KB_OSPRet ret;
  77.   ret=KB_OSPMsgSend(kb_dc_queueID,msg);
  78. if(ret!=RET_OK)
  79. DCDebug1("nKB_DcMsgSend error.");
  80. }
  81. void KB_DcTask(void)
  82. {
  83. time_t curTime, end_time, last_check_time=0;
  84. KB_OSPRet status;
  85. KB_OSPMsgNode msg;
  86. KB_MovieInfoNode *movieInfo=NULL;
  87. unsigned short curTSID,curServiceID;
  88. BOOL playret;
  89. static bool updateInfo=false,update=false;
  90. unsigned char verSTB=0,verDC=0;
  91. unsigned long year,month,day,hour,minter,second;
  92. int testCnt =0;
  93. int x;
  95. _realtime_adver_timer = KB_TimerCreate(KB_TIMER_REPEAT, (KB_TIMER_FUNC_POINTER)AdverTimerCallback, NULL);
  96. KB_TimeGetCurTime(&curTime);
  97. last_check_time = curTime;
  98. while(1)
  99. {
  100. KB_OSPTaskDelay(2000);
  101. KB_TimeGetCurTime(&curTime);
  102. #if 0
  103. ConvertTimeStampToDate(curTime,&year,&month,&day);
  104. ConvertTimeStampToTime(curTime,&hour,&minter,&second);
  105. DCDebug2("n KB_DcTask:current time[%d],year[%d],month[%d],day[%d],hour[%d],minter[%d],second[%d]",curTime,year,month,day,hour,minter,second);
  106. #endif
  108. //定时去激活版本的监测
  109. if(curTime-last_check_time > 60)
  110. {
  111. DCDebug2("nnn*******it is time to check configure file version!*****nnn");
  112. last_check_time = curTime;
  114. #ifdef KB_DC_TEST_2
  115. {
  116. if((++testCnt)%4==0)
  117. kb_dc_CfgVerSaveTest();
  118. }
  119. #endif
  121. msg.Word1=kb_dc_version_check;
  122. goto SWITCH;
  123. }
  125. status=KB_OSPMsgGet(kb_dc_queueID, KD_NoWait,0, &msg);
  126. if(status!=Ret_OK) KBDcMemset(&msg, 0x00, sizeof(KB_OSPMsgNode));
  128. movieInfo=KB_GetXmlMovieInfoHead();
  129. while(movieInfo!=NULL)
  130. {
  131. DCDebug3("n m_dataGet=%d m_cfgType=%d      name=%s", movieInfo->st_MovieInfo.m_dataGet, movieInfo->st_MovieInfo.m_cfgType, movieInfo->st_MovieInfo.m_strName);
  132. //数据广播数据文件
  133. if(((movieInfo->st_MovieInfo.m_cfgType==kb_dc_data_broadcast)||
  134.      (movieInfo->st_MovieInfo.m_cfgType==kb_dc_data_vote))&&
  135.    (movieInfo->st_MovieInfo.m_dataGet==kb_dc_data_no))
  136. {
  137. movieInfo->st_MovieInfo.m_dataGet=kb_dc_data_searching;
  138. msg.Word1=kb_db_data_get;
  139. msg.Word2=(UINT32)movieInfo;
  140. break;
  141. }
  142. //交互广告影片文件
  143. else if((movieInfo->st_MovieInfo.m_cfgType==kb_dc_adv_alter)&&
  144.          (movieInfo->st_MovieInfo.m_dataGet==kb_dc_data_no))
  145. {
  146. movieInfo->st_MovieInfo.m_dataGet=kb_dc_data_searching;
  147. msg.Word1=kb_dc_movie_get;
  148. msg.Word2=(UINT32)movieInfo;
  149. break;
  150. }
  151. //界面更新影片文件
  152. else if((movieInfo->st_MovieInfo.m_cfgType==kb_dc_swf_update)&&
  153.          (movieInfo->st_MovieInfo.m_dataGet==kb_dc_data_no))
  154. {
  155. verDC=movieInfo->st_MovieInfo.m_reserve2;
  157. //下发的版本号无效
  158. if((verDC==0)||(verDC==255))
  159. {
  160. movieInfo->st_MovieInfo.m_dataGet=kb_dc_data_searched;
  161. }
  162. else
  163. {
  164. if(movieInfo->st_MovieInfo.m_reserve1==kb_movie_adve_logo)
  165. verSTB=KB_SWF_VersionGet(0);
  166. else
  167. verSTB=KB_SWF_VersionGet(1);
  169. //if(((verSTB>=250)&&(verSTB!=verDC))||(verSTB<verDC))
  170. if(verSTB!=verDC)
  171. {
  172. update=true;
  173. movieInfo->st_MovieInfo.m_dataGet=kb_dc_data_searching;
  174. msg.Word1=kb_dc_movie_get;
  175. msg.Word2=(UINT32)movieInfo;
  176. break;
  177. }
  178. else
  179. {
  180. DCDebug2("n 无效版本: verSTB=%d   verDC=%d", verSTB, verDC);
  181. movieInfo->st_MovieInfo.m_dataGet=kb_dc_data_searched;
  182. }
  183. }
  184. }
  185. //插播广告
  186. else if(movieInfo->st_MovieInfo.m_cfgType==kb_dc_adv_rt)
  187. {
  188. if(KB_DTVGetCurPrgInfo(&curTSID,&curServiceID)==FALSE)
  189. {
  190. DCDebug1("nKB_DcTask get current program information error.");
  191. }
  192. else
  193. {
  194. DCDebug2("n curTSID=%x   curServiceID=%x   m_serviceID=%x   m_tsID=%x", curTSID,curServiceID,  movieInfo->st_MovieInfo.m_serviceID, movieInfo->st_MovieInfo.m_tsID);
  195. //if((movieInfo->st_MovieInfo.m_tsID==curTSID)&&(movieInfo->st_MovieInfo.m_serviceID==curServiceID))
  196. if(movieInfo->st_MovieInfo.m_serviceID==curServiceID&&movieInfo->st_MovieInfo.m_tsID==curTSID)
  197. {
  198. end_time = movieInfo->st_MovieInfo.m_nStartTime + (movieInfo->st_MovieInfo.m_nTimeStep*(movieInfo->st_MovieInfo.m_nTimesPlayed-1) + 10);
  199. DCDebug2("n curTime[%d] vs [%d]st_MovieInfo.m_nStartTime----end_time[%d]", curTime,  movieInfo->st_MovieInfo.m_nStartTime, end_time);
  200. if( (curTime>movieInfo->st_MovieInfo.m_nStartTime)&&(curTime<=end_time) )
  201. {
  202. x =  (curTime - movieInfo->st_MovieInfo.m_nStartTime)%(movieInfo->st_MovieInfo.m_nTimeStep);
  204. DCDebug2("n x=%d",x);
  205. if((x>=0)&&(x<=10))
  206. {
  207. msg.Word1 = kb_dc_movie_play;
  208. msg.Word2=(UINT32)movieInfo;
  209. break;
  210. }
  211. }
  212. }
  213. }
  214. }
  216. movieInfo=movieInfo->m_pNext;
  218. }
  220. SWITCH:
  222. if(KB_DC_FilterStatGet()==FILTER_COLSED)
  223. {
  224. DCDebug2("n FilterStat is FILTER_COLSED, continue!!!");
  225. continue;
  226. }
  228. switch(msg.Word1)
  229. {
  230. //搜索业务配置文件
  231. case kb_dc_servcfg_get:
  232. DCDebug2("n ---kb_dc_servcfg_get recieved----");
  233. KB_DC_FilterStatSet(FILTER_RUNNING);
  234. if(kb_dc_getMainFreqCfg()==0)
  235. {
  236. DCDebug1("n kb_dc_getMainFreqCfg failure!");
  237. break;
  238. }
  239. KB_DC_FilterStatSet(FILTER_READY);
  240. break;
  242. case kb_dc_version_check:
  243. DCDebug2("n -----kb_dc_version_check received!-----");
  244. {
  245. unsigned char *xmlBuf=NULL;
  246. unsigned long xmlLen=0;
  248. KB_DC_FilterStatSet(FILTER_RUNNING);
  249. if(kb_dc_CfgDiiCheck()<=0)
  250. {
  251. DCDebug2("n dii version not changed , break!");
  252. break;
  253. }
  255. updateInfo=false;
  256. update=false;
  257. ResetXmlStbInfo(); /*先清空*/
  258. xmlBuf = kb_dc_getCfgXml(&xmlLen);
  259. if(xmlBuf!=NULL) 
  260. {
  261. KB_XmlParse((char*)xmlBuf, xmlLen);
  262. KBDcFree(xmlBuf);
  263. xmlBuf=NULL;
  264. }
  265. }
  266. break;
  268. case kb_dc_movie_play:
  269. DCDebug2("n -----kb_dc_movie_play received!-----");
  270.        if(kb_movie_playStatusGet()==kb_movie_closed)
  271. {
  272. playret =kb_machblue_TSMovie2((KB_MovieInfoNode*)msg.Word2);
  273. if(playret)
  274. {
  275. KB_MovieInfoNode *pInfo=NULL;
  276. int duration;
  278. pInfo = (KB_MovieInfoNode *)msg.Word2;
  279. duration = pInfo->st_MovieInfo.m_nDuration;
  280. DCDebug4("nr -----duration=%d", duration);
  281. KB_TimerEnable(_realtime_adver_timer, duration*1000);
  282. }
  283. }
  284. break;
  286. case kb_dc_movie_get:
  287. DCDebug2("n -----kb_dc_movie_get received!-----");
  288. KB_DcMovieGet((KB_MovieInfoNode*)msg.Word2);
  289. break;
  291. case kb_db_data_get:
  292. DCDebug2("n #####kb_db_data_get received!msg.Word2=%x#####", msg.Word2);
  293. KB_DcDataGet((KB_MovieInfoNode*)msg.Word2);
  294. break;
  296. case kb_dc_filter_close:
  297. KB_DC_FilterStop();
  298. KB_DC_FilterStatSet(FILTER_COLSED);
  299. break;
  301. case kb_dc_filter_start:
  302. KB_DC_FilterStart();
  303. break;
  304. }
  306. if((!updateInfo)&&update)
  307. {
  308. movieInfo=KB_GetXmlMovieInfoHead();
  309. if(movieInfo!=NULL)
  310. updateInfo=true;
  312. while(movieInfo!=NULL)
  313. {
  314. if((movieInfo->st_MovieInfo.m_cfgType==kb_dc_swf_update)&&
  315.    (movieInfo->st_MovieInfo.m_dataGet!=kb_dc_data_searched))
  316. {
  317. updateInfo=false;
  318. break;
  319. }
  321. movieInfo=movieInfo->m_pNext;
  322. }
  324. if(updateInfo)
  325. {
  326. KB_MovieInfoNode *tmpInfo=NULL,*p1=tmpInfo,*p2;
  327. KB_DBRET updateRet;
  329. movieInfo=KB_GetXmlMovieInfoHead();
  330. while(movieInfo!=NULL)
  331. {
  332. //生成链表
  333. if((movieInfo->st_MovieInfo.m_cfgType==kb_dc_swf_update)&&
  334.    (movieInfo->st_MovieInfo.m_pData!=NULL))
  335. {
  336. p2 = (KB_MovieInfoNode*)KBDcMalloc(sizeof(KB_MovieInfoNode));
  337. KBDcMemcpy(p2, movieInfo, sizeof(KB_MovieInfoNode));
  338. //p2->st_MovieInfo.m_pData=(unsigned char*)mb_malloc(p2->st_MovieInfo.m_nSize);
  339. //mb_memcpy(p2->st_MovieInfo.m_pData,movieInfo->st_MovieInfo.m_pData,p2->st_MovieInfo.m_nSize);
  340. if(tmpInfo==NULL)
  341. {
  342. tmpInfo=p2;
  343. p1=tmpInfo;
  344. p1->m_pNext=NULL;
  345. }
  346. else
  347. {
  348. p1->m_pNext=p2;
  349. p1=p2;
  350. p1->m_pNext=NULL;
  351. }
  352. }
  354. movieInfo=movieInfo->m_pNext;
  355. }
  357. kb_machblue_updatePlay();
  358. updateRet=KB_SWF_Update(tmpInfo);
  359. if(kb_movie_playStatusGet()==kb_movie_playing)
  360. {
  361. if(updateRet==RET_OK)
  362. KB_MB_lc_2_movie_word_Post_Task(1);
  363. else
  364. KB_MB_lc_2_movie_word_Post_Task(0);
  365. }
  367. while(tmpInfo!=NULL)
  368. {
  369. KBDcFree(tmpInfo->st_MovieInfo.m_pData);
  370. tmpInfo->st_MovieInfo.m_pData = NULL;
  371. p1=tmpInfo;
  372. tmpInfo=tmpInfo->m_pNext;
  373. KBDcFree(p1);
  374. }
  375. }
  376. }
  377. }
  379. }
  383. void KB_DcTaskInit(void)
  384. {
  385. UINT32 TaskId;
  387. KB_OSPTaskInit("KB_DcTask", 8*1024,
  388.  (void(*)(void *))KB_DcTask, 1*16,
  389.  NULL, &TaskId);
  391. KB_OSPQueInit("kb_dc_queueID", 128, &kb_dc_queueID);
  392. }
  395. void AdverTimerCallback(void)
  396. {
  397. DCDebug4("rnn ----------------_realtime_adver_timer expired-------------------n");
  398. KB_TimerDisable(_realtime_adver_timer );
  399. kb_machblue_movie_close(TRUE);
  400. }
  403. void Kb_clearAderTimer(void)
  404. {
  405. KB_TimerDisable(_realtime_adver_timer );
  406. }
  408. void KB_DCStop_Service(void)
  409. {
  410. KB_DC_FilterStop();
  411. KB_DC_FilterStatSet(FILTER_COLSED);
  412. }
  415. void KB_DCStart_Service(void)
  416. {
  417. KB_DC_FilterStart();
  418. KB_DC_FilterStatSet(FILTER_RUNNING);
  420. }
  422. void kb_dc_LoadCurTs(void)
  423. {
  424. unsigned short curTSID,curServiceID;
  426. KB_DTVGetCurPrgInfo(&curTSID,&curServiceID);
  427. curCfgTsID=curTSID;
  428. }
  431. unsigned short kb_dc_GetCurTS(void)
  432. {
  433. return curCfgTsID;
  434. }
  436. BOOL kb_dc_FreqIsChanged(void)
  437. {
  438. unsigned short curTSID,curServiceID;
  440. KB_DTVGetCurPrgInfo(&curTSID,&curServiceID);
  441. if(curCfgTsID!=curTSID)
  442. return TRUE;
  443. else 
  444. return FALSE;
  445. }
  447. //activate service configure xml info
  448. void kb_dc_ServCfgGetActivate(void)
  449. {
  450. KB_OSPMsgNode msg;
  452. msg.Word1=kb_dc_servcfg_get;
  453. KB_DcMsgSend(&msg);
  454. }