source: svn/newcon3bcm2_21bu/dst/app/src/Function/App_Fnc_EPG.c

/****************************************************************************
* NAME: App_Fnc_EPG.c
*----------------------------------------------------------------------------
* Copyright (c) DIGITAL STREAM Technology Inc.
*----------------------------------------------------------------------------
* CREATED_BY: Do Gon Lee
* CREATION_DATE: 2009/08/20
* $Author: foxhunt $
* $Revision: 1.0 $
* $Date: 2009/08/20 11:32:07 $
*----------------------------------------------------------------------------
* PURPOSE:
* - EPG Init, update start/cancel, delete wrapping.
* - program change envent procedure implement.
*****************************************************************************/

/*_____ I N C L U D E __________________________________________*/

#include "App_Main.h"

#if SUPPORT_EPG

#include "DMW_CodeConv.h"

#include "App_Fnc_Common.h"

#include "App_Fnc_Time.h"
#include "App_Fnc_EPG.h"
#include "App_Fnc_ChTune.h"

#include "App_Fnc_Rating.h"
#include "App_Fnc_RRT.h"
#include "App_Fnc_CC.h"
#include "App_Fnc_Sdds.h"

#include "App_Res_Resources.h"






/*_____ D E F I N I T I O N ____________________________________*/

#if COMMENT
____DbgPrint____(){}
#endif

DHL_MODULE("@f_epg", 0);





#if COMMENT
____Config____(){}
#endif





#if COMMENT
____Types____(){}
#endif





#if COMMENT
____Variables____(){}
#endif

BOOLEAN g_EPG_ScreenUpdate = FALSE;     /* iskang */
BOOLEAN g_bEPGGet_OneEIT = FALSE;       /* iskang */
BOOLEAN g_bEPGGet_OneSTT = FALSE;       /* kjkam */

//neverdai.
static UINT32 p_eit_count=0;
static UINT32 p_ett_count=0;


/*_____ F U N C T I O N ________________________________________*/

#if COMMENT
____Function____(){}
#endif

/******************************************************************************************
FUNCTION:
  - _App_ProgramChangeEventProc

Purpose:
  - 
******************************************************************************************/
void _App_ProgramChangeEventProc(UINT32 nIDTimer, DmcEpgProgramChangeCbParam *param)
{
        if (nIDTimer != TIMER_ID_PGM_CHANGE)
                return;
        
        dprint(2, "ProgramChangeEventProc:\n");
        
        /* daylightsaving¿¡ ÀÇÇØ ½Ã°£ÀÌ º¯°æÀÌ µÇ´Â program change event¸é
           daylightsavingÀÌ ¹Ý¿µµÈ stt¸¦ Àû¿ëÇÏÀÚ. */
        App_SetTimeBySTT();
        
        /* cafrii 060609 */
        /* rating check ¼öÇàÇϱâ */
        AppRating_CheckRatingBlock(3000);       /* ¹Ù·Î Áï½Ã ¼öÇà. */

        /* cafrii 070907 add */
        App_CC_SetScreenRatio();
}


/******************************************************************************************
FUNCTION:
  - App_CancelProgramChangeTimer

Purpose:
  - 
******************************************************************************************/
void App_CancelProgramChangeTimer()
{
        DMW_SYS_KillTimer(TIMER_ID_PGM_CHANGE);
}


/******************************************************************************************
FUNCTION:
  - _AppEpg2EventProc

Purpose:
  - 
******************************************************************************************/
void _AppEpg2EventProc(DmcEpgEventType evt, UINT32 param1, UINT32 param2)
{
        /* New EPG (v1.5 alpha) ¸¦ »ç¿ëÇϱâ À§ÇÑ EpgEventProc */

        if (evt == epgEventStarted) {
                /* param 1 : update start reason..
                   param 2 : none
                */
                dprint(2, "******** epgEventStarted: by %s\n",
                                param1 == EpgUpdateStartByUserCall ? "Tune" : "MgtChange");
        }
        
        else if (evt == epgEventChannelStarted) {       /* cafrii 041123 add */
                /* ÇØ´ç ä³ÎÀÇ Epg °Ë»öÀÌ ½ÃÀ۵ǾúÀ½À» ¾Ë¸°´Ù. */
                /* param 1 : DmcEpgChannelCbParam *
                   param 2 : none
                */

                DmcEpgChannelCbParam *cb = (DmcEpgChannelCbParam *) param1;
                dprint(2, "******** epgEventChannelStart: rf %d\n", cb->id);

                // trigger checking dynamic channel update..
                dprint(0, "############## vct rx\n");
                App_CheckDynamicChUpdate();
        }
        
        else if (evt == epgEventSubChannelStarted) {    /* cafrii 041123 add */
        
                /* ÇØ´ç subchannelÀÇ epg °Ë»öÀÌ ½ÃÀ۵ǾúÀ½À» ¾Ë¸°´Ù. */
                /* param 1 : DmcEpgSubChannelCbParam *
                   param 2 : none
                */

                DmcEpgSubChannelCbParam *cb = (DmcEpgSubChannelCbParam *) param1;
                dprint(3, "******** epgEventSubChannelStart: [%d] source_id %d, '%s' %d-%d #%d\n",
                                        cb->index, cb->source_id,
                                        DMW_Unicode2Ks(cb->vct_info.short_name, 7, 0),
                                        cb->vct_info.major_channel_number, 
                                        cb->vct_info.minor_channel_number, 
                                        cb->vct_info.program_number);
        }
        
        else if (evt == epgEventEitReceived) {
                /* param 1 : EpgStatus
                   param 2 : Eit index
                */
                DmcEpgStatus *pStat = (DmcEpgStatus *) param1;
                
                g_bEPGGet_OneEIT = TRUE;        /* iskang 2006.6.2 */
                
                p_eit_count++;

                dprint(3, "******** epgEventEitReceived, Eit[%d], %d/%d tables\n",
                                (int)param2, pStat->nEitReceived, pStat->nEitTotal);

                /* cafrii 070907 add. if eit-0 is updated, re-update cc ratio setting */
                if (param2 == 0)
                        App_CC_SetScreenRatio();
        }
        
        else if (evt == epgEventEttReceived) {
                /* param 1 : EpgStatus
                   param 2 : Ett index code (MSB: ett-index, LSB: event-index)
                */
                DmcEpgStatus *pStat = (DmcEpgStatus *) param1;
                char buf[20];
                if ((param2 & 0xffff) == 0xffff)
                        sprintf(buf, "Ett-V");
                else
                        sprintf(buf, "Ett[%d][%d]", (param2 & 0xffff), (param2 >> 16));
                dprint(3, "******** epgEventEttReceived, %s, %d/%d tables\n",
                                buf, pStat->nEttReceived, pStat->nEttTotal);
                
                p_ett_count++;
        }
        
        /* cafrii 041129 add */
        else if (evt == epgEventChannelEttUpdated) {
                dprint(2, "******** epgEventChannelEttUpdated\n");
        }
        
        else if (evt == epgEventCompleteInfo) {
                /* param 1 : epgEventEitComplete/SubchannelComplete/ChannelComplete Áß Çϳª
                   param 2 : DmcEpgCompleteCbParam *
                */
        
                DmcEpgCompleteCbParam *cb = (DmcEpgCompleteCbParam *) param2;
                if (param1 == epgEventEitComplete)
                        dprint(3, "******** epgEventEitComplete, rf %d, subch [%d] source id %d\n",
                                        cb->id, cb->index, cb->source_id);
                else if (param1 == epgEventSubchannelComplete)
                        dprint(3, "******** epgEventSubchannelComplete, rf %d, subch [%d] source id %d\n",
                                        cb->id, cb->index, cb->source_id);
                else {
                        dprint(3, "******** epgEventChannelComplete, rf %d\n", cb->id);
                
                /* iskang 071116. add. rating check. */
                /* rating Á¤º¸¸¦ eit¿¡¼­ ¾ò¾î¿À¹Ç·Î eit updateµÇ¸é rating check.. */
                AppRating_CheckRatingBlock(3000);
                }
        }
        
        else if (evt == epgEventError) {
                /* param 1 : error value
                   param 2 : error description if non-null
                */
                dprint(0, "******** epgEventError: err %d, (%s)\n", param1, param2 ? (char *)param2 : "??");
        }
        
        else if (evt == epgEventNotifyStt) {
                /* »õ·Î¿î STT°¡ µµÂø, ¶Ç´Â STT °ªÀÇ Jump µî.
                   param 1 : sttSection_t
                   param 2 : age of system_time recpetion (in seconds)
                */
        
                sttSection_t *stt = (sttSection_t *) param1;
                int gap = (int) param2;
                
                g_bEPGGet_OneSTT        = TRUE;                 /* kjkam 2011.5.16 */

                dprint(3, "******** epgEventNotifyStt: gps 0x%x, gap %d\n", stt->system_time, gap);
                
                App_SetTimeBySTT();
                        /* cafrii 050721, update to host time if autochron channel */
        }
        
        else if (evt == epgEventNotifyProgramChange) {
                /* ÇöÀç Program Event°¡ º¯°æµÇ¾úÀ½À» ¾Ë¸².
                   param 1 : new event_id
                   param 2 : eitEvent_t Á¤º¸¸¦ Æ÷ÇÔÇÏ´Â ¾î¶² µ¥ÀÌÅÍ..
                */
                DmcEpgProgramChangeCbParam *param = (DmcEpgProgramChangeCbParam *) param2;
                
                p_eit_count++; //ÀÌ À̺¥Æ®°¡ ¹ß»ýÇصµ eit_count¸¦ Áõ°¡½ÃÅ´

                dprint(3, "******** epgEventNotifyProgramChange: evid 0x%x, GPS 0x%x\n", 
                                                param1, param->system_time);

                /* cafrii 050729 change
                   ´Ù¸¥ task¿¡¼­ ¼öÇàÇÏ´Â°Ô ±ÇÀåµÊ. ´ë½Å paramÀ» ÂüÁ¶ÇÒ ¼ö ¾øÀ½.
                   rating check ÀÚü´Â »ó°ü ¾ø´Âµ¥, CC Á¤º¸ °¡Á®¿À´Â Äڵ尡 ¹®Á¦µÉ ¼ö ÀÖÀ½. */
                DMW_SYS_SetTimer(TIMER_ID_PGM_CHANGE, 0,
                                (DMW_TIMER_PROC)_App_ProgramChangeEventProc, 0, TRUE);
        }

        else if (evt == epgEventRrtUpdated) {
                rrtSectionPtr_t rrt;
                dprint(2, "******** epgEventRrtUpdated: \n");

                /* ÇöÀç ÀÌ task´Â epg event taskÀÌ°í core DB lockÀÌ °É·Á ÀÖ´Â »óÅÂÀ̹ǷÎ
                   dead-lockÀÌ ¹ß»ýÇÏÁö ¾Êµµ·Ï À¯ÀÇÇÏÀÚ. */

                /* ´Ù¸¥ Ãß°¡ÀÇ mutex¸¦ takeÇÏÁö ¾Êµµ·Ï.. (¿¹: channel db mutex) */

                rrt = (rrtSectionPtr_t) param1;
                
                dprint(2, "rrt : 0x%x\n", rrt);

                AppRrt_PrintRrt(FALSE);
                AppRrt_SaveRrt();
        
                AppRating_CheckRatingBlock(3000);
        }

#if SUPPORT_SDDS
        else if (evt == epgEventSddsFound) {
                // À̺¥Æ®¸¦ ±×³É ±×´ë·Î sdds fnc ¸ðµâ·Î pass ÇÔ.
                App_SddsServiceFound((UINT32)param1, (DmcEpgSddsProgramInfo *)param2);
        }
#endif // SUPPORT_SDDS


}


/******************************************************************************************
FUNCTION:
  - _AppEpg2IdleEventProc

Purpose:
  - 
******************************************************************************************/
void _AppEpg2IdleEventProc(DmcEpgEventType evt, UINT32 param1, UINT32 param2)
{
        /* Idle »óÅÂ(S2)¿¡¼­, ij·¯¼¿ º¯È­¸¦ °¨½ÃÇϱâ À§ÇÑ EpgEventProc */

#if SUPPORT_SDDS
        if (evt == epgEventNotifyStt) {
                /* »õ·Î¿î STT°¡ µµÂø, ¶Ç´Â STT °ªÀÇ Jump µî.
                   param 1 : sttSection_t
                   param 2 : age of system_time recpetion (in seconds)
                */
        
                sttSection_t *stt = (sttSection_t *) param1;
                int gap = (int) param2;
                
                g_bEPGGet_OneSTT        = TRUE;                 /* kjkam 2011.5.16 */

                dprint(3, "******** epgEventNotifyStt: gps 0x%x, gap %d\n", stt->system_time, gap);

                        /* cafrii 050721, update to host time if autochron channel */
        }
        else if (evt == epgEventSddsFound) {
                // À̺¥Æ®¸¦ ±×³É ±×´ë·Î sdds fnc ¸ðµâ·Î pass ÇÔ.
                App_SddsServiceFound((UINT32)param1, (DmcEpgSddsProgramInfo *)param2);
        }
#endif // SUPPORT_SDDS


}


/******************************************************************************************
FUNCTION:
  - App_EpgUpdateStart

Purpose:
  - 
******************************************************************************************/
void App_EpgUpdateStart(void)
{
        UINT32 flag = 0;
        UINT32 source_id;
        DST_CURCHANNEL ChannelInfo;
        App_Ucm_GetCurChInfo(&ChannelInfo);

        if(ChannelInfo.nRF > 0)
        {
                dprint(3, "EPG Update start, RF %d, sid %d\n", ChannelInfo.nRF, ChannelInfo.nSourceId);

                /* flag |= epgScanFlag_EitFirst; */
                flag |= epgScanFlag_SkipAnalog;                 /* cafrii 060711 add */
                
                source_id = ChannelInfo.nSourceId;      /* cafrii 060718 add */

                g_bEPGGet_OneSTT        = FALSE;                        /* kjkam 2011.5.16 */
                g_bEPGGet_OneEIT        = FALSE;                        /* iskang 2006.6.2 */
                g_EPG_ScreenUpdate = FALSE;                             /* iskang 2006.6.2 */
                
                Dmc_EpgUpdateStart(ChannelInfo.nRF, Dmc_GetCurrentTsd(), _AppEpg2EventProc, source_id, flag);
                                /* no preferred source_id, no flag.. */

                /* cafrii 060718 add
                   program change notify±â´ÉÀ» »ç¿ëÇÏ·Á¸é source_id ÁöÁ¤ÇØ¾ß ÇÔ.
                */ 
                /* cafrii 070801 delete, ±×³É epg start Çϸ鼭 source id ÁöÁ¤ÇÏ¸é µÊ. */
                /* Dmc_EpgSetMonitorSourceId(source_id); */
        }
        else
                dprint(1, "!! Cannot start Epg Update, Uid %d/RF %d\n", ChannelInfo.nUid, ChannelInfo.nRF);
}


/******************************************************************************************
FUNCTION:
  - App_EpgIdleUpdateStart

Purpose:
  - 
******************************************************************************************/
void App_EpgIdleUpdateStart(int rf)
{
        UINT32 flag = 0;
        UINT32 source_id;
        DST_CURCHANNEL ChannelInfo;
        
        // idle ½ÃÀÇ sdds¿ëÀ¸·Î epg task¸¦ »ç¿ëÇÒ ¶§¿¡´Â App_Ucm_GetCurChInfo()ÀÇ
        // Á¤º¸°¡ À¯È¿ÇÏÁö ¾ÊÀ¸¹Ç·Î »ç¿ëÇÏÁö ¾Ê´Â´Ù.
        ChannelInfo.nRF = rf;
        ChannelInfo.nSourceId = 0;
        if(ChannelInfo.nRF > 0)
        {
                dprint(3, "EPG Idle Update start, RF %d, sid %d\n", ChannelInfo.nRF, ChannelInfo.nSourceId);

                /* flag |= epgScanFlag_EitFirst; */
                flag |= epgScanFlag_SkipAnalog;                 /* cafrii 060711 add */
                
                source_id = ChannelInfo.nSourceId;      /* cafrii 060718 add */

                g_bEPGGet_OneSTT        = FALSE;                        /* kjkam 2011.5.16 */
                g_bEPGGet_OneEIT        = FALSE;                        /* iskang 2006.6.2 */
                g_EPG_ScreenUpdate = FALSE;                             /* iskang 2006.6.2 */
                
                Dmc_EpgUpdateStart(ChannelInfo.nRF, Dmc_GetCurrentTsd(), _AppEpg2IdleEventProc, source_id, flag);
                                /* no preferred source_id, no flag.. */

                /* cafrii 060718 add
                   program change notify±â´ÉÀ» »ç¿ëÇÏ·Á¸é source_id ÁöÁ¤ÇØ¾ß ÇÔ.
                */ 
                /* cafrii 070801 delete, ±×³É epg start Çϸ鼭 source id ÁöÁ¤ÇÏ¸é µÊ. */
                /* Dmc_EpgSetMonitorSourceId(source_id); */
        }
        else
                dprint(1, "!! Cannot start Epg Idle Update, Uid %d/RF %d\n", ChannelInfo.nUid, ChannelInfo.nRF);
}


/******************************************************************************************
FUNCTION:
  - App_EpgUpdateCancel

Purpose:
  - EPG update cancel function
******************************************************************************************/
void App_EpgUpdateCancel(void)
{
        App_CancelProgramChangeTimer();

        Dmc_EpgUpdateCancel();
}


/******************************************************************************************
FUNCTION:
  - App_EpgDeleteAll

Purpose:
  - EPG delete function
******************************************************************************************/
void App_EpgDeleteAll(void)
{
        App_CancelProgramChangeTimer();

        Dmc_EpgDeleteAll();
}


/******************************************************************************************
FUNCTION:
  - App_EpgInit

Purpose:
  - EPG initialize function
******************************************************************************************/
void App_EpgInit(void)
{
        DMW_EPG_Init();
        
        DHL_DBG_RegisterFunctionSymbol("epg_start", (void *)App_EpgUpdateStart);
        DHL_DBG_RegisterFunctionSymbol("epg_stop", (void *)App_EpgUpdateCancel);
        DHL_DBG_RegisterFunctionSymbol("epg_delete", (void *)App_EpgDeleteAll);
        DHL_DBG_RegisterFunctionSymbol("epg_list", (void *)Dmc_EpgPrintAllTables);

}


UINT32 App_EpgGetEitCount()
{
        return p_eit_count;
}

UINT32 App_EpgGetEttCount()
{
        return p_ett_count;
}


#endif /* SUPPORT_EPG */


/* end of file */