source: svn/zas_dstar/hal/platform/dstdddtv.c @ 76

Last change on this file since 76 was 76, checked in by megakiss, 10 years ago

1W 대기전력을 만족시키기 위하여 POWEROFF시 튜너를 Standby 상태로 함

File size: 35.1 KB
Line 
1/******************************************************************************
2 *_Copyright (c) 2009 Digital Stream Technology Inc. All Rights Reserved.
3 *
4 * Module: dstdddtv.c
5 *
6 * Description
7 *      Platform/Vendor specific device driver for DTV Audio/Video.
8 *
9 * @author
10 * @version $Revision: 1.1 $
11 *
12 ******************************************************************************/
13
14#include <stdlib.h>
15#include <fcntl.h>
16#include <getopt.h>
17#include <sys/ioctl.h>
18#include <sys/time.h>
19#include <string.h>
20#include <errno.h>
21#include <stdio.h>
22
23#include "dsthalcommon.h"
24#include "dstoslayer.h"
25
26#include "dstdddtv.h"
27#include "dstddaud.h"
28#include "dstddsys.h"
29#include "dstdddmx.h"
30#include "dstdddisp.h"
31#include "dstddcap.h"
32
33#include "dstddgpio.h"
34#include "pd_dmx.h"
35
36#ifdef DMALLOC
37#include <dmalloc.h>
38#endif
39#include <stdint.h>
40#include "mpeg2.h"
41
42/******************************************************************************
43 * Global variable declaration
44 ******************************************************************************/
45int gddAvDbgLvl = 2;
46int g_PcrStarted = 0;
47int g_PcrPid = -1;
48int g_PreSPDIFDelay = 800;              // SPDIF AC3-PCM º¯°æÇϱâ ÀüÀÇ Delay
49int g_AftSPDIFDelay = 200;              // SPDIF AC3-PCM º¯°æÇÑ ÈÄÀÇ Delay
50DS_U16 g_PESFilter = 0;
51int g_PESFilterStarted = 0;
52
53/******************************************************************************
54 * Imported variable declaration
55 ******************************************************************************/
56extern DHL_CAP_CONFIG   g_dhlcap;
57extern DHL_DTV_CONFIG   g_dhldtv;
58static P_DHL_PRG_INFO   pPrgInfo = &g_dhldtv.PrgInfo;
59extern void PreInitSplashScreen(DS_U32 *arg);
60extern DS_BOOL g_DTVCCEnable;
61
62/******************************************************************************
63 * Imported function declaration
64 ******************************************************************************/
65
66/******************************************************************************
67 * Local definitions
68 ******************************************************************************/
69#define VIDEO_ALIVE_CHECK_INTERVAL      1200            // 12000 mSec
70#define AUDIO_ALIVE_CHECK_INTERVAL      150                     // 1500 mSec
71#define USE_CC_Q                                        1
72#define MAX_CC_MESSAGES                         120     
73#define NULL_PID                0x1FFE
74
75/******************************************************************************
76 * Local typedefs
77 ******************************************************************************/
78#define DEBUG_PES_FILTER            0
79    // PES_filter debug dump »ç¿ë ¿©ºÎ.
80    //
81   
82/******************************************************************************
83 * Local variables declaration
84 ******************************************************************************/
85static DS_BOOL g_VideoStarted = _FALSE_;
86static DS_BOOL g_AudioStarted = _FALSE_;
87
88static int s_AVInit = 0;
89
90/******************************************************************************
91 * Local function prototypes
92 ******************************************************************************/
93static DHL_RESULT DD_DTV_IsAVAlive(DS_BOOL *bVideo, DS_BOOL *bAudio);
94static DHL_RESULT CCMonitorInit(void);
95static DHL_RESULT CCMonitorStart(void);
96static DHL_RESULT CCMonitorStop(void);
97void _CCUserDataCallback(unsigned char *data, unsigned long size, void *pInfo);
98
99//////////////////////////////////////////////////////////////////////////////
100// Global Variables
101//////////////////////////////////////////////////////////////////////////////
102int fsCod, Lfeon, acmod;
103DS_U32 lastAudioTime = 0;                       // ¸¶Áö¸· AC3 Info ¿Ã¶ó¿Â ½ÃÁ¡.
104
105//////////////////////////////////////////////////////////////////////////////
106// Global Functions
107//////////////////////////////////////////////////////////////////////////////
108DS_BOOL DD_DTV_IsVideoStarted(void);
109DS_BOOL DD_DTV_IsAudioStarted(void);
110DS_BOOL DD_DTV_IsAVStarted(void);
111
112#if 0
113___Common_Functions___()
114#endif
115
116DHL_RESULT DD_DTV_Init(void)
117{
118        DHL_RESULT dhlResult = DHL_OK;
119    extern int init_mpeg2dec(int width, int height);
120
121    dhlResult = CCMonitorInit();
122    SysASSERT( dhlResult == DHL_OK );
123   
124    dhlResult = CCMonitorStart();
125    SysASSERT( dhlResult == DHL_OK );
126
127        DD_CAP_SetSyncLock(1);
128    init_mpeg2dec(0, 0);
129   
130        s_AVInit = 1;
131
132        return dhlResult;
133}
134
135DHL_RESULT DD_DTV_Connect(void)
136{
137        DHL_RESULT dhlResult = DHL_OK;
138
139        return dhlResult;
140}
141
142DHL_RESULT DD_DTV_Close(void)
143{
144        DHL_RESULT dhlResult = DHL_OK;
145       
146        dhlResult = CCMonitorStop();
147        SysASSERT( dhlResult == DHL_OK );
148       
149        return dhlResult;
150}
151
152DHL_RESULT DD_DTV_Pause(void)
153{
154        DHL_RESULT dhlResult = DHL_OK;
155
156        return dhlResult;
157}
158
159DHL_RESULT DD_DTV_Resume(void)
160{
161        DHL_RESULT dhlResult = DHL_OK;
162
163        return dhlResult;
164}
165
166#if 0
167___DTVCC_Functions___()
168#endif
169
170#define PECC_TASK_PRIORITY              90
171#define PECC_TASK_STACKSIZE             16384
172
173static OS_MESSAGEQUEUE_ID PeCCQ;
174static OS_TASK_ID PECCMonitorSlaveId;
175
176static int tPECCMonitorStarted = 0;                                             // PE CC Monitor Thread°¡ ½ÃÀ۵Ǿú´ÂÁö?
177static int tCCMonitorSlave(DS_U32 *dmstartup);
178
179static DHL_RESULT CCMonitorInit(void)
180{
181        DHL_RESULT dhlResult = DHL_OK;
182       
183        mpeg_set_userdata_callback( _CCUserDataCallback );
184       
185        PeCCQ = OS_CreateMessageQueue("q_PeCC", 0, MAX_CC_MESSAGES, sizeof(DS_U32));
186        if ( PeCCQ == (OS_MESSAGEQUEUE_ID)NULL )
187        {
188            dhlResult = DHL_FAIL_OUT_OF_RESOURCE;
189            goto done;
190        }
191   
192        PECCMonitorSlaveId = OS_SpawnTask((void (*) (DS_U32))tCCMonitorSlave, "tPECCMonitorSlave", PECC_TASK_PRIORITY, PECC_TASK_STACKSIZE, 0);
193        if ( PECCMonitorSlaveId == (OS_TASK_ID)NULL )
194        {
195            dhlResult = DHL_FAIL_OUT_OF_RESOURCE;
196            goto done;
197        }
198   
199done:
200        return dhlResult;
201}
202
203static DHL_RESULT CCMonitorStart(void)
204{
205        DHL_RESULT dhlResult = DHL_OK;
206       
207        if ( tPECCMonitorStarted == 1 ) 
208        {
209                return dhlResult;
210        }
211               
212        tPECCMonitorStarted = 1;
213
214        return dhlResult;
215}
216
217static DHL_RESULT CCMonitorStop(void)
218{
219        DHL_RESULT dhlResult = DHL_OK;
220
221        return dhlResult;
222}
223
224void _CCUserDataCallback(unsigned char *data, unsigned long size, void *pInfo)
225{
226    DS_U32 *ccBuf;
227    DS_U8 *msgToSlave;
228    DS_U32 flag = (DS_U32)pInfo;
229    //pCCCallbackInfo_t pCallbackInfo = (pCCCallbackInfo_t)pInfo;
230
231        if ( g_DTVCCEnable == DS_FALSE )
232                return;
233
234    if((data == NULL) || (size <= 0) || (pInfo == NULL))
235    {
236        printf("ERROR: invalid CC userdata 0x%lx %d 0x%lx\n", (DS_U32)data, (int)size, (DS_U32)pInfo);
237        return;
238    }
239
240    //fprintf(stderr, "CC userdata 0x%lx %d 0x%lx\n", (DS_U32)data, (int)size, (DS_U32)pInfo);
241
242        ccBuf = malloc(size+2*sizeof(DS_U32));
243        if ( !ccBuf ) {
244                printf("%s| ERROR, Out of resource.\n", __FUNCTION__);
245                return;
246        }
247       
248        ((DS_U32 *)ccBuf)[0] = 0;
249        ((DS_U32 *)ccBuf)[0] |= (flag & PIC_FLAG_PROGRESSIVE_FRAME) ? (1<<DHL_CC_PRGFR_SHIFT) : 0;
250        ((DS_U32 *)ccBuf)[0] |= (flag & PIC_FLAG_TOP_FIELD_FIRST) ? (1<<DHL_CC_TOPFL_SHIFT) : 0;
251        ((DS_U32 *)ccBuf)[0] |= (flag & PIC_FLAG_REPEAT_FIRST_FIELD) ? (1<<DHL_CC_RPTFL_SHIFT) : 0;
252        ((DS_U32 *)ccBuf)[0] |= (((flag>>16)&0x03)<<DHL_CC_PIC_SHIFT);
253    ((DS_U32 *)ccBuf)[0] |= ((flag & PIC_MASK_CODING_TYPE)<<DHL_CC_CODE_SHIFT);
254        ((DS_U32 *)ccBuf)[1] = size;
255        memcpy( &ccBuf[2], data, size );
256
257        msgToSlave = (DS_U8 *)ccBuf;
258        if ( OS_SendMessage(PeCCQ, (DS_U32 *)&msgToSlave, sizeof(DS_U32)) ) {
259                DHL_DbgPrintf(0,DDDBG_AV,"Cannot send msg q to CC slave.\n");
260                DstCore_QueueReset(PeCCQ);
261        }
262}
263
264int cc_test_flag = 0;
265static int cc_total_count=0;
266static int cc_error_count=0;
267static void test_cc_function(DS_U8 *Buffer)
268{
269        int i;
270        int cur_offset = 0, cc_count = 0;
271        static int old_offset = -1;
272        unsigned char *ptr;
273        DS_U8 *buffer;
274        DS_U16 picStruct, curField, repeat1st;
275        //int size = Buffer[1];
276       
277        if ( cc_test_flag == 0 )
278                return;
279
280        buffer = Buffer+sizeof(DS_U32)*2;
281        if ( cc_test_flag > 2 ) {
282                for (i=0; i<70; i++) {
283                        if ( !(i%16) )
284                                printf("\n");
285                        printf("%02X ", Buffer[i] );
286                }
287        }
288       
289        if ( cc_test_flag > 1 ) {
290                picStruct = (((DS_U32 *)Buffer)[0] >> DHL_CC_PIC_SHIFT) & DHL_CC_PIC_MASK;
291                curField = (((DS_U32 *)Buffer)[0] >> DHL_CC_TOPFL_SHIFT) & DHL_CC_TOPFL_MASK;
292                repeat1st = (((DS_U32 *)Buffer)[0] >> DHL_CC_RPTFL_SHIFT) & DHL_CC_RPTFL_MASK;
293                printf("picStruct = %2d, curField = %d, repeatFirstField = %d\n", picStruct, curField, repeat1st );
294        }
295       
296        //
297        // ATSC Identifier
298        //
299        if ( !(buffer[0] == 0x47 && buffer[1] == 0x41 && 
300                buffer[2] == 0x39 && buffer[3] == 0x34) ) 
301                return;
302       
303        //
304        // user_data_type_code
305        //
306        if ( buffer[4] != 0x03 )
307                return;
308       
309        //
310        // cc_count
311        //
312        cc_count = buffer[5] & 0x1F;
313        ptr = (unsigned char *)&buffer[7];
314        for (i=0; i<cc_count; i++) {
315                if ( (ptr[(i*3)+0] & 0x04 ) && ( (ptr[(i*3)+0] & 0x3) == 0x3) ) {
316                        cur_offset = (ptr[(i*3)+1]>>6) & 0x3;
317                        if ( cc_test_flag > 1 )
318                                printf("[CC] SeqNo=0x%02X\n", cur_offset );
319                        if ( old_offset >= 0 ) {
320                                if ( cur_offset != ((old_offset+1)&3) ) {
321                                        //#if DEBUG_CC
322                                        printf("   lost packet! %d => %d\n", old_offset, cur_offset );
323                                        //#endif
324                                        cc_error_count++;
325                                }
326                        }
327                        old_offset = cur_offset;
328                        cc_total_count++;
329                }
330        }
331}
332
333static int tCCMonitorSlave(DS_U32 *arg)
334{
335        DS_U32 msgLen;
336        static DS_U32 msg;
337        DS_U32 ret;
338    DHL_RESULT dhlResult = DHL_OK;
339   
340        DHL_DbgPrintf(0,DDDBG_AV,"entry.\n");
341       
342        while(1) 
343        {
344                msg = 0;
345                ret = OS_ReceiveMessage(PeCCQ, &msg, sizeof(msg), &msgLen);
346                if ( ret != 0 )
347                {
348                        DHL_DbgPrintf(0,DDDBG_AV,"ERROR, LINE=%d\n", __LINE__);
349                        continue;
350                }
351               
352                if ( msgLen )
353                {
354                    dhlResult = DHL_DTV_DoCallback( DHL_CB_VDC_CCUDP, (void *)msg );
355                    SysASSERT( dhlResult == DHL_OK );
356                }
357
358                test_cc_function( (DS_U8 *)msg );
359
360                free( (void *)msg );
361        }
362       
363        DHL_DbgPrintf(gddAvDbgLvl,DDDBG_AV,"exit.\n");
364}
365
366#if 0
367___Video_Functions___()
368#endif
369
370//////////////////////////////////////////////////////////////////////
371//
372// DD_DTV_VideoStart(), DD_DTV_VideoStop()
373// DD_DTV_AudioStart(), DD_DTV_AudioStop()
374//
375/////////////////////////////////////////////////////////////////////
376DHL_RESULT DD_DTV_VideoStart(DS_U16 uVidPID, DS_U16 uPcrPID)
377{
378        DHL_RESULT dhlResult = DHL_OK;
379
380    dhlResult = DD_DTV_Connect();
381    SysASSERT( dhlResult == DHL_OK );
382       
383        SysASSERT( DD_DTV_IsVideoStarted() == _FALSE_ );
384       
385        if ( g_PcrStarted == 0 || g_PcrPid != uPcrPID ) 
386        {
387                //
388                // Here call the vendor-supplied PCR start API.
389                //
390        //SysCHECK( PD_DMX_CreatePIDFilter( uVidPID, MPEG2_VIDEO_STREAM, DS_FALSE ) == PD_DMX_SUCCESS );
391
392                g_PcrStarted = 1;
393                g_PcrPid = uPcrPID;     
394        }
395
396    //
397    // Here call the vendor-supplied Video start API.
398    //
399        g_VideoStarted = 1;
400               
401        return dhlResult;
402}
403
404
405DHL_RESULT DD_DTV_VideoStartEx2(DS_U16 uVidPID, DS_U16 uPcrPID, DS_U8 Stream_Type)
406{
407        return DD_DTV_VideoStart( uVidPID,  uPcrPID);
408}
409
410DHL_RESULT DD_DTV_VideoStop(void)
411{
412        DHL_RESULT dhlResult = DHL_OK;
413
414        //
415        // Here call the vendor-supplied VIDEO-STOP API.
416        //
417    //SysCHECK( PD_DMX_DeletePIDFilter(pPrgInfo->VidPID) == PD_DMX_SUCCESS );
418   
419        g_VideoStarted = 0;
420       
421        //close_mpeg2dec();
422   
423    //
424    // If audio is also stopped, then stop PCR also.
425    //   
426        if ( !DD_DTV_IsAudioStarted() ) 
427        {
428            //
429            // Call the PCR STOP API here.
430            //
431       
432                g_PcrStarted = 0;
433                g_PcrPid = -1;
434        }
435
436        return dhlResult;
437}
438
439
440DS_BOOL DD_DTV_IsVideoStarted(void)
441{
442        return g_VideoStarted;
443}
444
445DS_BOOL DD_DTV_IsAVStarted(void)
446{
447        return (DD_DTV_IsVideoStarted() || DD_DTV_IsAudioStarted());
448}
449
450DHL_RESULT DD_DTV_IsVideoAlive(DS_BOOL *bVideo, DS_U32 uWatingTicks)
451{
452        DHL_RESULT      dhlResult = DHL_OK;
453        DS_BOOL audio, video;
454        static DS_U32 lastTickCount = 0;
455        static DS_BOOL lastIsAlive = 0;
456
457        if ( uWatingTicks == 0 )
458                uWatingTicks = VIDEO_ALIVE_CHECK_INTERVAL;
459               
460        //
461        // Video°¡ ½ÃÀÛµÇÁö ¾Ê¾ÒÀ¸¸é, ¹«Á¶°Ç Video Alive = 0.
462        //
463        if ( DD_DTV_IsVideoStarted() == 0 ) 
464        {
465                *bVideo = 0;
466                return dhlResult;
467        }
468       
469        dhlResult = DD_DTV_IsAVAlive( &video, &audio );
470        if ( video == 0 ) 
471        {
472                if ( (OS_GetTickCount() - lastTickCount) < uWatingTicks ) 
473                {
474                        *bVideo = lastIsAlive;
475                        return dhlResult;
476                } 
477                else 
478                {
479                        *bVideo = video;
480                        lastIsAlive = video;
481                        lastTickCount = OS_GetTickCount();
482                        return dhlResult;
483                }
484        } 
485        else 
486    {
487                lastTickCount = OS_GetTickCount();
488                lastIsAlive = video;
489                *bVideo = video;
490        }               
491                       
492        *bVideo = video;
493
494        return dhlResult;
495}
496
497#if 0         
498___Audio_Functions___()
499#endif
500DHL_RESULT DD_DTV_AudioStart(DS_U16 uAudPID, DS_U16 uPcrPID, DHL_AUD_STREAMTYPE AudStreamType, DS_BOOL bAudOnlyCh)
501{
502        DHL_RESULT dhlResult = DHL_OK;
503    int i_audio_stream_type = AC3_AUDIO_STREAM;
504   
505    SysASSERT( DD_DTV_IsAudioStarted() == DS_FALSE );
506
507    switch(AudStreamType)
508    {
509        case DHL_STREAM_AUDIO_AC3:
510            i_audio_stream_type = AC3_AUDIO_STREAM;
511            break;
512       
513        case DHL_STREAM_AUDIO_MPEG2:
514            i_audio_stream_type = MPEG2_AUDIO_STREAM;
515            break;
516       
517        default:
518            printf("!!! Cannot support 0x%x or invalid format.\n", AudStreamType);
519            return DHL_FAIL;
520            break;
521    }
522   
523    //
524    // Call the AUDIO START API here.
525    //
526    //SysCHECK( PD_DMX_CreatePIDFilter( uAudPID, i_audio_stream_type, DS_FALSE ) == PD_DMX_SUCCESS );
527
528    //
529    // Some plaform need to set SPDIF output mode just after AUDIO-START.
530    // If so, then call the appropriate API here.
531    //
532        if ( DHL_AUD_IsSpdifMuted() == _FALSE_ )
533        {
534            dhlResult = DD_AUD_ChangeAudOutFormat(DHL_AUD_GetAudOutFormat());
535            SysASSERT( dhlResult == DHL_OK );
536        }
537        g_AudioStarted = 1;
538
539    //
540    // If PCR is not started or PCR is not same as before, in that case call the PCR start here again.
541    //
542        if ( g_PcrStarted == 0 || g_PcrPid != uPcrPID ) 
543        {
544            //
545            // Call the PCR START API here.
546            //
547
548                g_PcrStarted = 1;
549                g_PcrPid = uPcrPID;     
550        }       
551   
552        return dhlResult;
553}
554
555DHL_RESULT DD_DTV_AudioStop(void)
556{
557        DHL_RESULT dhlResult = DHL_OK;
558
559    //
560    // Call the vendor-supplied AUDIO-STOP API here.
561    // 
562    //SysCHECK( PD_DMX_DeletePIDFilter(pPrgInfo->AudPID) == PD_DMX_SUCCESS );
563    pPrgInfo->AudPID = pPrgInfo->AudPID;
564   
565        g_AudioStarted = 0;
566
567    //
568    // If video is not started, in that case we have to stop PCR also here.
569    //
570        if ( DD_DTV_IsVideoStarted() == 0 ) 
571        {
572            //
573            // Call the vendor-supplied PCR-STOP API here.
574            //
575
576                g_PcrStarted = 0;
577                g_PcrPid = -1;
578        }
579       
580        return dhlResult;
581}
582
583DHL_RESULT DD_DTV_SetAudioDynamicRange(DS_BOOL On)
584{
585        return DHL_OK;
586} 
587
588static DHL_RESULT DD_DTV_IsAVAlive(DS_BOOL *bVideo, DS_BOOL *bAudio)
589{
590        DHL_RESULT      dhlResult = DHL_OK;
591       
592        //
593        // Here we have to check incoming video is valid or not.
594        // For example, checks whether PTS/DTS is changing.
595        // Just for test purpose, just we return video is started.
596        //
597       
598        *bVideo = (DS_BOOL)DD_DTV_IsVideoStarted();
599        *bAudio = (DS_BOOL)0;
600         
601        return dhlResult;
602}
603       
604DHL_RESULT DD_DTV_IsAudioAlive(DS_BOOL *bAudio, DS_U32 uWatingTicks)
605{
606        DHL_RESULT      dhlResult = DHL_OK;
607       
608        if ( DD_DTV_IsAudioStarted() == _FALSE_ ) 
609        {
610                *bAudio = 0;
611                return dhlResult;
612        }
613   
614    //
615    // Check Audio data availability here and get back until uWaitingTicks timeout.
616    //
617   
618        return dhlResult;
619}
620
621DS_BOOL DD_DTV_IsAudioStarted(void)
622{
623        return g_AudioStarted;
624}
625
626DHL_RESULT DD_DTV_GetAC3Info(P_DHL_DTV_AC3_STATUS pAC3Status)
627{
628        DHL_RESULT dhlResult = DHL_OK;
629
630        return dhlResult;
631}
632
633#if 0
634___CC_Functions___()
635#endif
636static DHL_DTV_PES_CALLBACK s_cbPESFilterFunc = (DHL_DTV_PES_CALLBACK)NULL;
637
638#if 0
639void _arib_process_statement_body(DS_U8 *p_buffer, int size, PESInfo_t *p_info)
640{
641    int i;
642//    DS_U16 p_decoded_text[4096];
643    int decodedLength;
644   
645#ifndef CONV_TO_ASCII
646#define CONV_TO_ASCII(x)    ( ((x) >= ' ' && (x) <= '~') ? (x) : '.' )
647#endif
648
649    //decodedLength=DMW_Decode_AribCCString(size, p_buffer, 4096, p_decoded_text);
650    printf("Decoded ARIB-CC: ");
651    for (i=0; i<decodedLength; i++)
652    {
653        //if ((p_decoded_text[i]) >= ' ' && (p_decoded_text[i]) <= '~')
654            //printf("%c", CONV_TO_ASCII(p_decoded_text[i]&0xFF));
655        //else
656            printf("{%02X}", p_buffer[i]);
657    }
658    printf("\n");
659}
660
661void _arib_process_data_unit(int i_lang, DS_U8 *p_buffer, int size, PESInfo_t *p_info)
662{
663    DS_U8 unit_seperator;
664    DS_U8 data_unit_parameter;
665    DS_U32 data_unit_size;
666   
667//    if ( i_lang_select == -1 )
668//        return;
669   
670//    if ( i_lang != -1 && i_lang_select != i_lang )
671//        return;
672    //i_lang_select = i_lang_select;
673   
674    if ( size < 0 )
675        return;
676       
677    unit_seperator = p_buffer[0];
678    if ( unit_seperator != 0x1F )
679    {
680        printf("invalid unit_seperator 0x%x\n", unit_seperator);
681        return;
682    }
683   
684    data_unit_parameter = p_buffer[1];
685    data_unit_size = (p_buffer[2] << 16) + (p_buffer[3]<<8) + (p_buffer[4]);
686   
687    if ( size < (data_unit_size+5))
688    {
689        printf("!! %s:%d too short length %ld / %d\n", __func__, __LINE__, data_unit_size, size );
690        return;
691    }
692   
693    switch( data_unit_parameter )
694    {
695        case 0x20:
696            _arib_process_statement_body( &p_buffer[5], data_unit_size, p_info );
697            break;
698       
699        default:
700            printf("unsupported data_unit_parameter 0x%x\n", data_unit_parameter);
701            break;
702    }
703}
704
705void _arib_process_caption_statement(int i_lang, DS_U8 *p_buffer, int size, PESInfo_t *p_info)
706{
707    DS_U8 TMD;
708    DS_U32 STMHigh, STMLow;
709    int off = 0;
710    DS_U32 data_unit_size;
711   
712    printf("%s:%d\n", __func__, __LINE__);
713   
714    TMD = (p_buffer[0] >> 6) & 0x03;
715    off += 1;
716    if (TMD == 2 || TMD == 1)
717    {
718        STMHigh  = (p_buffer[1]>>(36-32)) & 0x0F;
719        STMLow   = (p_buffer[1]<<(32-4))  & 0xF0000000;
720        STMLow  += (p_buffer[2]<<(32-12)) & 0x0FF00000;
721        STMLow  += (p_buffer[3]<<(32-20)) & 0x000FF000;
722        STMLow  += (p_buffer[4]<<(32-28)) & 0x00000FF0;
723        STMLow  += (p_buffer[5]<<(32-32)) & 0x0000000F;
724        off+=5;
725    }
726
727    printf("%s:%d\n", __func__, __LINE__);
728   
729    data_unit_size = (p_buffer[off]<<16)+(p_buffer[off+1]<<8)+(p_buffer[off+2]<<0);
730    if ( size < off+data_unit_size )
731    {
732        printf("!! %s:%d too short length %ld / %d\n", __func__, __LINE__, data_unit_size, size );
733        return;
734    }
735    off += 3;
736
737    printf("%s:%d data_unit_size: %ld\n", __func__, __LINE__, data_unit_size);
738   
739    _arib_process_data_unit( i_lang, &p_buffer[off], data_unit_size, p_info );
740}
741
742void _arib_process_caption_management(DS_U8 *p_buffer, int size, PESInfo_t *p_info)
743{
744    int TMD;
745    DS_U32 OTMHigh, OTMLow;
746    int off=0;
747    int numLang;
748    int i;
749   
750    DS_U8 language_tag;
751    DS_U8 DMF;
752    DS_U8 DC;
753    DS_U32 langcode;
754    DS_U8 Format;
755    DS_U8 TCS;
756    DS_U8 rollup_mode;
757   
758    int data_unit_loop_length;
759   
760    printf("%s:%d\n", __func__, __LINE__);
761    //
762    // TO DO: utilize caption management information.
763    //
764    TMD = (p_buffer[0] >> 6) & 0x03;
765    if (TMD == 2)
766    {
767        OTMHigh  = (p_buffer[1]>>(36-32)) & 0x0F;
768        OTMLow   = (p_buffer[1]<<(32-4))  & 0xF0000000;
769        OTMLow  += (p_buffer[2]<<(32-12)) & 0x0FF00000;
770        OTMLow  += (p_buffer[3]<<(32-20)) & 0x000FF000;
771        OTMLow  += (p_buffer[4]<<(32-28)) & 0x00000FF0;
772        OTMLow  += (p_buffer[5]<<(32-32)) & 0x0000000F;
773        off+=5;
774    }
775   
776    if (size < off)
777        return;
778   
779    printf("%s:%d\n", __func__, __LINE__);
780    numLang = p_buffer[1+off];
781    off += 2;
782    for (i=0; i<numLang; i++)
783    {
784        language_tag = (p_buffer[off]>>5) & 0x07;
785        DMF = (p_buffer[off] & 0x0F);
786        if ( DMF == 0x0C || DMF == 0x0D || DMF == 0x0E )
787        {
788            DC = p_buffer[off+1];
789            off += 1;
790        }
791        langcode = (p_buffer[off+2]<<16)+(p_buffer[off+3]<<8)+(p_buffer[off+4]);
792        Format = (p_buffer[off+5]>>4) & 0x0F;
793        TCS = (p_buffer[off+5]>>2) & 0x03;
794        rollup_mode = p_buffer[off+5] & 0x03;
795       
796        off += 6;
797       
798        printf("Language %d: tag[%d] DMF %x, langcode %lx, format %d, TCS %d, rollup %d\n",
799            i, language_tag, DMF, langcode, Format, TCS, rollup_mode );
800    }
801   
802    if (size < off)
803        return;
804   
805    printf("%s:%d\n", __func__, __LINE__);
806    data_unit_loop_length = (p_buffer[off]<<16)+(p_buffer[off+1]<<8)+p_buffer[off+2];
807    off += 3;
808   
809    if (size < (off+data_unit_loop_length))
810        return;
811   
812    if ( data_unit_loop_length )
813        _arib_process_data_unit(-1/*-1=caption_management*/, &p_buffer[off], data_unit_loop_length, p_info);
814}
815
816void _arib_process_data_group(DS_U8 *p_buffer, int size, PESInfo_t *p_info)
817{
818    int data_group_id;
819    int data_group_version;
820    int data_group_size;
821    int i_lang;
822   
823    data_group_id = (p_buffer[0]>>2) & 0x3F;
824    data_group_version = p_buffer[0] & 0x03;
825    data_group_size = (p_buffer[3]<<8)+p_buffer[4];
826    i_lang = data_group_id & 0x0F;
827   
828    if ( size < (data_group_size+5+2) )
829    {
830        printf("!! invalid data_group size %d / %d\n", data_group_size, size);
831        return;
832    }
833   
834    if (data_group_id == 0x00 || data_group_id == 0x20)
835        _arib_process_caption_management( &p_buffer[5], data_group_size, p_info );
836    else
837        _arib_process_caption_statement( i_lang, &p_buffer[5], data_group_size, p_info );
838}
839
840void _arib_process_PES_data(DS_U8 *p_buffer, int size, PESInfo_t *p_info)
841{
842    int PES_packet_header_length;
843    int PES_data_byte_length;
844   
845    printf("%s:%d, p_buffer 0x%lx, size 0x%x\n", __func__, __LINE__, (DS_U32)p_buffer, size);
846   
847    if ( p_buffer[0] != 0x80 || p_buffer[1] != 0xFF )
848        return;
849   
850    PES_packet_header_length = p_buffer[2] & 0x0F;
851   
852    PES_data_byte_length = size - PES_packet_header_length - 3;
853    if ( PES_data_byte_length > 0 )
854        _arib_process_data_group( &p_buffer[PES_packet_header_length+3], PES_data_byte_length, p_info );
855#if 1//DEBUG_PES_FILTER
856    else
857        printf("!! No valid data_group byte: %d\n", PES_data_byte_length);
858#endif
859}
860#endif
861
862#if 0
863__ARIB_CC_Test_String_From_FUJI__()
864#endif
865const unsigned char ccCount0[] = {
8660x80, 0xFF, 0xF0, 0x04, 0x00, 0x00, 0x00, 0x32, 0x3F, 0x00, 0x00, 0x2E, 0x1F, 0x20, 0x00, 0x00, 
8670x29, 0x0C, 0x8A, 0x87, 0xA4, 0xE4, 0xA4, 0xC3, 0xA4, 0xD1, 0x89, 0xA1, 0xA1, 0x8A, 0xB9, 0xE1, 
8680xA4, 0xEA, 0xA4, 0xC8, 0xA4, 0xAB, 0x89, 0xA1, 0xA1, 0x8A, 0xA4, 0xB9, 0xA4, 0xB4, 0xA4, 0xAF, 
8690xCC, 0xEE, 0xC0, 0xB8, 0xC5, 0xAA, 0xA4, 0xC7, 0xFC, 0xA1, 0x75, 0x7B, 0xA0, 0x1F, 0xEE, 0xD1, 
8700x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,             
871};
872
873const unsigned char ccCount1[] = {
8740x80, 0xFF, 0xF0, 0x04, 0x00, 0x00, 0x00, 0x4B, 0x3F, 0x00, 0x00, 0x47, 0x1F, 0x20, 0x00, 0x00, 
8750x42, 0x0C, 0x8A, 0x87, 0xA4, 0xBD, 0xA4, 0xEC, 0xA4, 0xF2, 0x89, 0xA1, 0xA1, 0x8A, 0xC3, 0xCB, 
8760xC0, 0xAD, 0xC5, 0xAA, 0xA4, 0xC3, 0xA4, 0xC6, 0xA4, 0xA4, 0xA4, 0xA6, 0xC9, 0xBD, 0xB8, 0xBD, 
8770x89, 0xA1, 0xA1, 0x8A, 0xA4, 0xB9, 0xA4, 0xEB, 0xA4, 0xCE, 0xA4, 0xAB, 0xA4, 0xE2, 0xA4, 0xB7, 
8780xA4, 0xEC, 0xA4, 0xCA, 0xA4, 0xA4, 0xA4, 0xF3, 0xA4, 0xC7, 0xA4, 0xB9, 0xA4, 0xB1, 0xA4, 0xC9, 
8790x89, 0xA1, 0xA3, 0xB4, 0xFD, 0xA0, 0x1F, 0xE3, 0x9C, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 
8800x00, 0x00, 0x00, 0x00, 0x00,                                 
881};
882
883const unsigned char ccCount2[] = {
8840x80, 0xFF, 0xF0, 0x04, 0x00, 0x00, 0x00, 0x4C, 0x3F, 0x00, 0x00, 0x48, 0x1F, 0x20, 0x00, 0x00, 
8850x43, 0x0C, 0x8A, 0x83, 0xA5, 0xD6, 0xA5, 0xEB, 0xA5, 0xB4, 0xA1, 0xBC, 0xA5, 0xCB, 0xA5, 0xE5, 
8860xA4, 0xD0, 0xA4, 0xC3, 0xA4, 0xAB, 0xB0, 0xFB, 0xA4, 0xF3, 0xA4, 0xC7, 0xA4, 0xEB, 0x89, 0xA1, 
8870xA3, 0xA1, 0xA1, 0x87, 0xA1, 0xCA, 0x8A, 0xB0, 0xF0, 0xB3, 0xC0, 0x89, 0xA1, 0xCB, 0x8A, 0xB0, 
8880xFB, 0xA4, 0xDF, 0xA4, 0xE4, 0xA4, 0xB9, 0xA4, 0xA4, 0xA4, 0xC7, 0xA4, 0xB9, 0xA4, 0xE8, 0xA4, 
8890xCD, 0x89, 0xA1, 0xA3, 0x75, 0xF9, 0xA0, 0x1F, 0xEA, 0xEF, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 
8900x00, 0x00, 0x00, 0x00, 0x00, 0x00,                               
891};
892
893const unsigned char ccCount3[] = {
8940x80, 0xFF, 0xF0, 0x04, 0x00, 0x00, 0x00, 0x27, 0x3F, 0x00, 0x00, 0x23, 0x1F, 0x20, 0x00, 0x00, 
8950x15, 0x0C, 0x8A, 0x82, 0xB0, 0xFB, 0xA4, 0xDF, 0xA4, 0xE4, 0xA4, 0xB9, 0xA4, 0xA4, 0xA4, 0xF3, 
8960xA4, 0xCA, 0xA4, 0xE9, 0xA1, 0xC4, 0x1F, 0x20, 0x00, 0x00, 0x04, 0x9D, 0x20, 0x50, 0x0C, 0x7A, 
8970x54, 0xA1, 0x1F, 0xE4, 0x24, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 
8980x00,                                             
899};
900
901const unsigned char ccCount4[] = {
9020x80, 0xFF, 0xF0, 0x04, 0x00, 0x00, 0x00, 0x1F, 0x3F, 0x00, 0x00, 0x1B, 0x1F, 0x20, 0x00, 0x00, 
9030x16, 0x0C, 0x8A, 0x82, 0xB7, 0xDA, 0xB0, 0xE6, 0xC2, 0xF4, 0xA4, 0xC8, 0xA4, 0xAB, 0xA4, 0xCB, 
9040xA4, 0xA2, 0xA4, 0xEB, 0x89, 0xA1, 0xA3, 0x2C, 0x76, 0xA0, 0x1F, 0xE9, 0xC9, 0x00, 0x00, 0x00, 
9050x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,                     
906};
907
908const unsigned char ccCount5[] = {
9090x80, 0xFF, 0xF0, 0x04, 0x00, 0x00, 0x00, 0x35, 0x3F, 0x00, 0x00, 0x31, 0x1F, 0x20, 0x00, 0x00, 
9100x2C, 0x0C, 0x8A, 0x83, 0xA4, 0xC8, 0xA4, 0xAD, 0xA4, 0xBF, 0xA4, 0xDE, 0x89, 0xA1, 0xA1, 0x8A, 
9110xB8, 0xC0, 0xA4, 0xC3, 0xA4, 0xC6, 0xA4, 0xEB, 0xA4, 0xB3, 0xA4, 0xC8, 0xA4, 0xAC, 0xCA, 0xAC, 
9120xA4, 0xAB, 0xA4, 0xF3, 0xA4, 0xCA, 0xA4, 0xA4, 0xA4, 0xE8, 0x89, 0xA1, 0xA3, 0x9E, 0xCC, 0xA1, 
9130x1F, 0xEC, 0xE0, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,   
914};
915
916const unsigned char ccCount6[] = {
9170x80, 0xFF, 0xF0, 0x04, 0x00, 0x00, 0x00, 0x30, 0x3F, 0x00, 0x00, 0x2C, 0x1F, 0x20, 0x00, 0x00, 
9180x27, 0x0C, 0x8A, 0x87, 0xB9, 0xE2, 0xB8, 0xB6, 0xA4, 0xC7, 0xA4, 0xB9, 0xA4, 0xAB, 0xA1, 0xA9, 
9190x0D, 0x83, 0xB7, 0xAF, 0xA4, 0xCE, 0xCF, 0xC3, 0xA4, 0xCF, 0xC4, 0xB9, 0xA4, 0xAF, 0xA4, 0xCA, 
9200xA4, 0xEB, 0xA4, 0xAB, 0xA4, 0xE9, 0xA1, 0xAA, 0x69, 0x91, 0xA0, 0x1F, 0xED, 0x24, 0x00, 0x00, 
9210x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,                   
922};
923
924const unsigned char ccCount7[] = {
9250x80, 0xFF, 0xF0, 0x04, 0x00, 0x00, 0x00, 0x2F, 0x3F, 0x00, 0x00, 0x2B, 0x1F, 0x20, 0x00, 0x00, 
9260x1D, 0x0C, 0x89, 0x87, 0xA1, 0xCA, 0x8A, 0xB0, 0xF0, 0xB3, 0xC0, 0x89, 0xA1, 0xCB, 0x8A, 0xA4, 
9270xA4, 0xA4, 0xBF, 0xA4, 0xC0, 0xA4, 0xAD, 0xA4, 0xDE, 0xA4, 0xB9, 0x89, 0xA1, 0xA3, 0x1F, 0x20, 
9280x00, 0x00, 0x04, 0x9D, 0x20, 0x50, 0x0C, 0x1F, 0x9D, 0xA1, 0x1F, 0xF1, 0x60, 0x00, 0x00, 0x00, 
9290x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,                     
930};
931
932const unsigned char ccCount8[] = {
9330x80, 0xFF, 0xF0, 0x04, 0x00, 0x00, 0x00, 0x1B, 0x3F, 0x00, 0x00, 0x17, 0x1F, 0x20, 0x00, 0x00, 
9340x12, 0x0C, 0x8A, 0x83, 0xA3, 0xB2, 0xA4, 0xC4, 0xA4, 0xC8, 0xA4, 0xE2, 0xBB, 0xB3, 0xCD, 0xD3, 
9350x89, 0xA1, 0xA3, 0x88, 0x3B, 0xA1, 0x1F, 0xEA, 0x0D, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 
9360x00, 0x00, 0x00, 0x00, 0x00,                                 
937};
938
939const unsigned char ccCount9[] = {
9400x80, 0xFF, 0xF0, 0x04, 0x00, 0x00, 0x00, 0x54, 0x3F, 0x00, 0x00, 0x50, 0x1F, 0x20, 0x00, 0x00, 
9410x42, 0x0C, 0x8A, 0x87, 0xA4, 0xBD, 0xA4, 0xA6, 0xA4, 0xC7, 0xA4, 0xB9, 0xA4, 0xCD, 0x89, 0xA1, 
9420xA1, 0x8A, 0xA5, 0xBF, 0xA5, 0xA4, 0xA5, 0xD7, 0xA4, 0xAC, 0xB0, 0xE3, 0xA4, 0xA6, 0x89, 0xA1, 
9430xA1, 0x8A, 0xA4, 0xB3, 0xA4, 0xC3, 0xA4, 0xC1, 0xA4, 0xAC, 0x89, 0xA1, 0xA1, 0x8A, 0xA5, 0xA6, 
9440xA5, 0xA9, 0xA5, 0xC3, 0xA5, 0xB7, 0xA5, 0xE5, 0xA5, 0xBF, 0xA5, 0xA4, 0xA5, 0xD7, 0xA4, 0xC7, 
9450x89, 0xA1, 0xA3, 0x1F, 0x20, 0x00, 0x00, 0x04, 0x9D, 0x20, 0x61, 0x0C, 0x9D, 0x1C, 0xA1, 0x1F, 
9460xE6, 0xF7, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,       
947};
948
949const unsigned char ccCount10[] = {
9500x80, 0xFF, 0xF0, 0x04, 0x00, 0x00, 0x00, 0x4B, 0x3F, 0x00, 0x00, 0x47, 0x1F, 0x20, 0x00, 0x00, 
9510x42, 0x0C, 0x8A, 0x87, 0xC2, 0xE7, 0xBE, 0xE6, 0xC9, 0xD7, 0xA4, 0xC7, 0xA4, 0xB9, 0xA4, 0xCD, 
9520x89, 0xA1, 0xA1, 0x8A, 0xB5, 0xD5, 0xA4, 0xCB, 0xB9, 0xC5, 0xA4, 0xE1, 0xA4, 0xC0, 0xA4, 0xC8, 
9530x89, 0xA1, 0xA1, 0x8A, 0xBE, 0xAF, 0xA4, 0xB7, 0x89, 0xA1, 0xA1, 0x8A, 0xA5, 0xEC, 0xA5, 0xF3, 
9540xA5, 0xB8, 0xA4, 0xC7, 0xA5, 0xC1, 0xA5, 0xF3, 0xA4, 0xB7, 0xA4, 0xDE, 0xA4, 0xB9, 0xA4, 0xCD, 
9550x89, 0xA1, 0xA3, 0x42, 0x05, 0xA1, 0x1F, 0xEE, 0xD1, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 
9560x00, 0x00, 0x00, 0x00, 0x00,                                 
957};
958
959const unsigned char ccCount11[] = {
9600x80, 0xFF, 0xF0, 0x04, 0x00, 0x00, 0x00, 0x1E, 0x3F, 0x00, 0x00, 0x1A, 0x1F, 0x20, 0x00, 0x00, 
9610x15, 0x0C, 0x8A, 0x87, 0xA4, 0xAA, 0xC5, 0xB9, 0xA4, 0xC7, 0xC7, 0xE4, 0xA4, 0xC3, 0xA4, 0xC6, 
9620xA4, 0xC6, 0xA4, 0xE2, 0xFC, 0xA1, 0x93, 0xF3, 0xA1, 0x1F, 0xE4, 0x68, 0x00, 0x00, 0x00, 0x00, 
9630x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,                         
964};
965
966const unsigned char ccCount12[] = {
9670x80, 0xFF, 0xF0, 0x04, 0x00, 0x00, 0x00, 0x3D, 0x3F, 0x00, 0x00, 0x39, 0x1F, 0x20, 0x00, 0x00, 
9680x34, 0x0C, 0x89, 0x87, 0xA1, 0xD6, 0x8A, 0xBF, 0xA8, 0xA4, 0xF3, 0xA4, 0xCA, 0xA4, 0xA4, 0xA4, 
9690xC7, 0xA4, 0xAF, 0xA4, 0xC0, 0xA4, 0xB5, 0xA4, 0xA4, 0x89, 0xA1, 0xD7, 0x8A, 0xA4, 0xC3, 0xA4, 
9700xC6, 0x89, 0xA1, 0xA1, 0x8A, 0xBD, 0xF1, 0xA4, 0xA4, 0xA4, 0xC6, 0xA4, 0xA2, 0xA4, 0xEB, 0xA4, 
9710xCE, 0xA4, 0xCB, 0xFC, 0xA1, 0x36, 0x18, 0xA1, 0x1F, 0xE8, 0x1C, 0x00, 0x00, 0x00, 0x00, 0x00, 
9720x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,                           
973};
974
975const unsigned char ccCount13[] = {
9760x80, 0xFF, 0xF0, 0x04, 0x00, 0x00, 0x00, 0x32, 0x3F, 0x00, 0x00, 0x2E, 0x1F, 0x20, 0x00, 0x00, 
9770x20, 0x0C, 0x8A, 0x87, 0xB9, 0xC5, 0xA4, 0xB5, 0xA4, 0xF2, 0x89, 0xA1, 0xA1, 0x8A, 0xA5, 0xC1, 
9780xA5, 0xA7, 0xA5, 0xC3, 0xA5, 0xAF, 0xA4, 0xB7, 0xA4, 0xDE, 0xA4, 0xB9, 0xA4, 0xCD, 0x89, 0xA1, 
9790xA3, 0x1F, 0x20, 0x00, 0x00, 0x04, 0x9D, 0x20, 0x54, 0x0C, 0x0D, 0x00, 0xA1, 0x1F, 0xEA, 0x0D, 
9800x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,             
981};
982
983const unsigned char ccCount14[] = {
9840x80, 0xFF, 0xF0, 0x04, 0x00, 0x00, 0x00, 0x40, 0x3F, 0x00, 0x00, 0x3C, 0x1F, 0x20, 0x00, 0x00, 
9850x37, 0x0C, 0x8A, 0x87, 0xA5, 0xD0, 0xA5, 0xEB, 0xA5, 0xB5, 0xA5, 0xDF, 0xA5, 0xB3, 0xA4, 0xC8, 
9860xA4, 0xAB, 0x89, 0xA1, 0xA1, 0x8A, 0xA4, 0xAB, 0xA4, 0xB1, 0xA4, 0xEB, 0xA4, 0xC0, 0xA4, 0xB1, 
9870xA4, 0xC7, 0xA4, 0xE2, 0x89, 0xA1, 0xA1, 0x8A, 0xA4, 0xAA, 0xA4, 0xA4, 0xA4, 0xB7, 0xA4, 0xA4, 
9880xA4, 0xC7, 0xA4, 0xB9, 0xA4, 0xB7, 0xFC, 0xA1, 0xB9, 0x00, 0xA1, 0x1F, 0xED, 0x68, 0x00, 0x00, 
9890x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,                   
990};
991
992const unsigned char ccCount15[] = {
9930x80, 0xFF, 0xF0, 0x04, 0x00, 0x00, 0x00, 0x43, 0x3F, 0x00, 0x00, 0x3F, 0x1F, 0x20, 0x00, 0x00, 
9940x3A, 0x0C, 0x8A, 0x87, 0xA4, 0xE2, 0xA4, 0xC1, 0xA4, 0xED, 0xA4, 0xF3, 0x89, 0xA1, 0xA1, 0x8A, 
9950xA4, 0xBD, 0xA4, 0xCE, 0xA4, 0xDE, 0xA4, 0xDE, 0xA4, 0xC7, 0xA4, 0xE2, 0xA4, 0xA4, 0xA4, 0xA4, 
9960xA4, 0xB7, 0x89, 0xA1, 0xA1, 0x8A, 0xA5, 0xEF, 0xA5, 0xA4, 0xA5, 0xF3, 0xA4, 0xCB, 0xB9, 0xE7, 
9970xA4, 0xA4, 0xA4, 0xDE, 0xA4, 0xB9, 0xA4, 0xCD, 0x89, 0xA1, 0xA3, 0x83, 0x93, 0xA0, 0x1F, 0xE4, 
9980xC1, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,         
999};
1000
1001const unsigned char ccCount16[] = {
10020x80, 0xFF, 0xF0, 0x04, 0x00, 0x00, 0x00, 0x3F, 0x3F, 0x00, 0x00, 0x3B, 0x1F, 0x20, 0x00, 0x00, 
10030x36, 0x0C, 0x8A, 0x82, 0xBC, 0xAB, 0xCA, 0xAC, 0xB2, 0xC8, 0xA4, 0xCF, 0x89, 0xA1, 0xA1, 0x8A, 
10040xA4, 0xC7, 0xA4, 0xAB, 0xA4, 0xA4, 0xA5, 0xEF, 0xA5, 0xA4, 0xA5, 0xF3, 0xA4, 0xCE, 0xCE, 0xE4, 
10050xC2, 0xA2, 0xB8, 0xCB, 0xA4, 0xAC, 0x89, 0xA1, 0xA1, 0x8A, 0xA4, 0xBD, 0xA4, 0xED, 0xA4, 0xC3, 
10060xA4, 0xC6, 0xA4, 0xC6, 0x89, 0xA1, 0xA3, 0x85, 0x6A, 0xA1, 0x1F, 0xEA, 0x0D, 0x00, 0x00, 0x00, 
10070x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,                     
1008};
1009
1010const unsigned char ccCount17[] = {
10110x80, 0xFF, 0xF0, 0x04, 0x00, 0x00, 0x00, 0x20, 0x3F, 0x00, 0x00, 0x1C, 0x1F, 0x20, 0x00, 0x00, 
10120x17, 0x0C, 0x8A, 0x87, 0xA5, 0xEF, 0xA5, 0xA4, 0xA5, 0xF3, 0xA5, 0xBB, 0xA5, 0xE9, 0xA1, 0xBC, 
10130xA4, 0xC7, 0xA4, 0xB9, 0xA4, 0xAB, 0xA1, 0xA9, 0xF3, 0x2B, 0xA1, 0x1F, 0xE6, 0x2B, 0x00, 0x00, 
10140x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,                   
1015};
1016
1017const unsigned char ccCount18[] = {
10180x80, 0xFF, 0xF0, 0x04, 0x00, 0x00, 0x00, 0x2E, 0x3F, 0x00, 0x00, 0x2A, 0x1F, 0x20, 0x00, 0x00, 
10190x1C, 0x0C, 0x8A, 0x82, 0xA5, 0xEF, 0xA5, 0xA4, 0xA5, 0xF3, 0xCE, 0xE4, 0xC2, 0xA2, 0xB8, 0xCB, 
10200xA4, 0xAC, 0xA1, 0xA9, 0x0D, 0x87, 0xA4, 0xCF, 0xA4, 0xA4, 0x89, 0xA1, 0xA3, 0x1F, 0x20, 0x00, 
10210x00, 0x04, 0x9D, 0x20, 0x54, 0x0C, 0x21, 0x82, 0xA0, 0x1F, 0xEE, 0x8D, 0x00, 0x00, 0x00, 0x00, 
10220x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,                         
1023};
1024
1025const unsigned char ccCount19[] = {
10260x80, 0xFF, 0xF0, 0x04, 0x00, 0x00, 0x00, 0x31, 0x3F, 0x00, 0x00, 0x2D, 0x1F, 0x20, 0x00, 0x00, 
10270x28, 0x0C, 0x8A, 0x82, 0xA4, 0xB3, 0xA4, 0xCE, 0xC8, 0xD6, 0xC1, 0xC8, 0xA4, 0xCE, 0x89, 0xA1, 
10280xA1, 0x8A, 0xC0, 0xD0, 0xC5, 0xC4, 0xA5, 0xD7, 0xA5, 0xED, 0xA5, 0xC7, 0xA5, 0xE5, 0xA1, 0xBC, 
10290xA5, 0xB5, 0xA1, 0xBC, 0xA4, 0xCB, 0x89, 0xA1, 0xA3, 0xA3, 0xFC, 0xA1, 0x1F, 0xE4, 0xC1, 0x00, 
10300x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,               
1031};
1032
1033const unsigned char ccCount20[] = {
10340x80, 0xFF, 0xF0, 0x04, 0x00, 0x00, 0x00, 0x58, 0x3F, 0x00, 0x00, 0x54, 0x1F, 0x20, 0x00, 0x00, 
10350x4F, 0x0C, 0x8A, 0x87, 0xBD, 0xC5, 0xA4, 0xBF, 0xA4, 0xB5, 0xA4, 0xC8, 0xA4, 0xAB, 0x89, 0xA1, 
10360xA1, 0xA5, 0xD5, 0xA5, 0xEB, 0xA5, 0xDC, 0xA5, 0xC7, 0xA5, 0xA3, 0xA1, 0xBC, 0x8A, 0xA4, 0xDF, 
10370xA4, 0xBF, 0xA4, 0xA4, 0xA4, 0xCA, 0x89, 0xA1, 0xA1, 0x8A, 0xB8, 0xC0, 0xA4, 0xA4, 0xCA, 0xFD, 
10380xA4, 0xC0, 0xA4, 0xC8, 0x89, 0xA1, 0xA1, 0xA5, 0xDC, 0xA5, 0xEB, 0xA5, 0xC9, 0xA1, 0xBC, 0x8A, 
10390xA4, 0xCA, 0xA4, 0xF3, 0xA4, 0xC7, 0xA4, 0xB9, 0xA4, 0xB1, 0xA4, 0xEC, 0xA4, 0xC9, 0xFC, 0xA1, 
10400xF8, 0x47, 0xA1, 0x1F, 0x60, 0x41, 0xFF, 0xFF, 0xFF, 0xFF, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 
10410x00, 0x00,                                           
1042};
1043
1044const unsigned char *ccTestString[21] = {
1045    ccCount0, ccCount1, ccCount2, ccCount3, ccCount4, ccCount5, ccCount6, ccCount7, ccCount8, ccCount9,
1046    ccCount10, ccCount11, ccCount12, ccCount13, ccCount14, ccCount15, ccCount16, ccCount17, ccCount18, ccCount19, ccCount20, 
1047};
1048
1049const int ccTestSize[21] = {
1050    sizeof(ccCount0), sizeof(ccCount1), sizeof(ccCount2), sizeof(ccCount3), sizeof(ccCount4), sizeof(ccCount5), sizeof(ccCount6), sizeof(ccCount7), sizeof(ccCount8), sizeof(ccCount9),
1051    sizeof(ccCount10), sizeof(ccCount11), sizeof(ccCount12), sizeof(ccCount13), sizeof(ccCount14), sizeof(ccCount15), sizeof(ccCount16), sizeof(ccCount17), sizeof(ccCount18), sizeof(ccCount19), sizeof(ccCount20)
1052};
1053
1054void feed_cc(void)
1055{
1056    static int idx = 0;
1057   
1058   
1059    if (s_cbPESFilterFunc)
1060    {
1061    //    s_cbPESFilterFunc(Pid, p_buffer, size, p_info);
1062        s_cbPESFilterFunc( 0x154, (unsigned char *)ccTestString[idx], ccTestSize[idx], (PESInfo_t *)NULL );
1063        idx++;
1064    }
1065}
1066
1067static void _cbPESFilter(int Pid, DS_U8 *p_buffer, int size, PESInfo_t *p_info)
1068{
1069#if (DEBUG_PES_FILTER>2)
1070    static int ccCount = 0;
1071    int i, j;
1072
1073#ifndef CONV_TO_ASCII
1074#define CONV_TO_ASCII(x)    ( ((x) >= ' ' && (x) <= '~') ? (x) : '.' )
1075#endif
1076
1077    //printf("Pid=0x%04X, PTS/DTS: %llx-%llx, flags=0x%08lX\n", Pid, p_info->i_pts, p_info->i_dts, p_info->i_flags);
1078   
1079    printf("const char ccCount%d[] = {\n", ccCount++);
1080    for (i=0; i<((size/16)+1); i++)
1081    {
1082        for (j=0; j<16; j++)
1083        {
1084            if ((i*16+j)<size)
1085                printf("0x%02X, ", p_buffer[i*16+j]);
1086            else
1087                printf("   ");
1088        }
1089       
1090///        for (j=0; j<16 && (i*16+j)<size; j++)
1091///        {
1092///            printf("%c", CONV_TO_ASCII(p_buffer[i*16+j]));
1093///        }
1094       
1095        printf("\n");
1096    }
1097    printf("};\n");
1098#endif
1099
1100    if (s_cbPESFilterFunc)
1101        s_cbPESFilterFunc(Pid, p_buffer, size, p_info);
1102   
1103    //_arib_process_PES_data(p_buffer, size, p_info);
1104}
1105
1106DHL_RESULT DD_DTV_PresetPESCallback( DHL_DTV_PES_CALLBACK cbFunc )
1107{
1108    DHL_RESULT  dhlResult = DHL_OK;
1109   
1110    s_cbPESFilterFunc = cbFunc;
1111   
1112    return dhlResult;
1113}
1114
1115DHL_RESULT DD_DTV_StartPESFilter(DS_U16 uPESPid, DHL_PESFILTER *filter)
1116{
1117    DHL_RESULT  dhlResult = DHL_OK;
1118   
1119    SysCHECK( PD_DMX_SetPidFilterCallback( (PD_DMX_PID_CALLBACK)_cbPESFilter ) == PD_DMX_SUCCESS );
1120    SysCHECK( PD_DMX_CreatePIDFilter( uPESPid, SUBTITLE_STREAM, DS_FALSE ) == PD_DMX_SUCCESS );
1121
1122    return dhlResult;
1123}
1124
1125DHL_RESULT DD_DTV_StopPESFilter(DS_U16 uPESPid)
1126{
1127    DHL_RESULT  dhlResult = DHL_OK;
1128   
1129    SysCHECK( PD_DMX_DeletePIDFilter(uPESPid) == PD_DMX_SUCCESS );
1130   
1131    return dhlResult;
1132}
Note: See TracBrowser for help on using the repository browser.