source: svn/newcon3bcm2_21bu/dst/dmw/src/psi/DMW_PsiAPI.c

/*
        DMW_PsiAPI.c

        DST TV MW PSI Scan Module

        PSI Scan API implementation

        Copyright 2006~2009 Digital STREAM Technology, Inc.
        All Rights Reserved
        
*/



#include "DMW_Platform.h"

#define __DEFINE_PSIM_STRING__
#include "DMW_PsiAPI.h"
#undef __DEFINE_PSIM_STRING__

#include "DMW_PsiEngine.h"
#include "DMW_PsiDatabase.h"






#if COMMENT
____API____(){}
#endif


/*
        PSI moduleÀ» ÃʱâÈ­ ÇÑ´Ù.
*/
STATUS DMW_PSI_Init(void)
{
        STATUS status = statusOK;
        S_PSIM_CONTEXT *module;

        module = PSIE_InitEngine();
        DHL_ASSERT(module != NULL, "psiengine_init err");

        status = PSITASK_Init(module);
        DHL_ASSERT(status == statusOK, "psitask_init err");

        return status;
}

/*
        ƯÁ¤ ts portÀÇ PSI/PSIP µ¥ÀÌÅÍ scanÀ» ½ÃÀÛÇÑ´Ù.
        ¿©±â¼­ ÁöÁ¤ÇÏ´Â @rf´Â ´Ü¼øÈ÷ id ¿ëµµ·Î¸¸ »ç¿ëÀÌ µÇ¸ç, ½ÇÁ¦ FrontEnd ¼³Á¤Àº caller°¡ ´ã´ç.

        @tsd Çϳª´ç ÇϳªÀÇ scan ÀÛ¾÷ÀÌ °¡´ÉÇÏ´Ù. N°³ÀÇ tsd°¡ µ¿½Ã¿¡ scan µÉ ¼ö ÀÖ´Ù.
        ÃÖ´ë tsd °¹¼ö´Â hardware ¸¶´Ù ´Ù¸¥µ¥, SW ³»ºÎÀûÀ¸·Î´Â MAX_TS_INPUT À¸·Î Á¦ÇѵǾî ÀÖ´Ù.

        flags: PSI_FLAGS_XXX °ªÀÇ Á¶ÇÕ.
        
        @program_number, @source_id ´Â PSI_FLAGS_AUTOSCAN °ú °°Àº ƯÁ¤ ¸ðµå¿¡¼­´Â »ç¿ëµÇÁö ¾Ê´Â´Ù.
        ±× ¿Ü¿¡´Â Á¤È®ÇÑ °ªÀ» ÁöÁ¤ÇØ Áà¾ß ÇÑ´Ù.

*/
STATUS DMW_PSI_StartUpdate(tDHL_TSD tsd, int rf, int program_number, int source_id, 
                                                        UINT32 flags, F_PSIM_EVENT_PROC userproc, UINT32 userparam)
{

        S_PSIM_USER_INPUT input;

        input.rf = rf;
        input.program_number = program_number;
        input.source_id = source_id;
        input.flags = flags;
        input.userproc = userproc;
        input.userparam = userparam;

        // we can use local variable because we use sync'ed call.
        // bWait should be "TRUE".
        
        return PSITASK_SendCommand(ePSIM_CMD_ScanStart, (UINT32)tsd, (UINT32)&input, TRUE);
                // jump to PsiMsgHandler_ScanStart
}

/*
        ÁöÁ¤ÇÑ @tsd Æ÷Æ®ÀÇ µ¿ÀÛ ÁßÀÎ psi scan ÀÛ¾÷À» Áß´ÜÇÑ´Ù.

        ±× ¿ÜÀÇ tsd Æ÷Æ® scan ÀÛ¾÷Àº ¿µÇâ ¹ÞÁö ¾Ê°í °è¼Ó µÈ´Ù.
        
*/
void DMW_PSI_CancelUpdate(tDHL_TSD tsd)
{
        PSITASK_SendCommand(ePSIM_CMD_ScanStop, (UINT32)tsd, 0, TRUE);
                // jump to PsiMsgHandler_ScanStop
}


/*
        PSI DBÀÇ °¢Á¾ Å×À̺íÀ» Á¦°Å.

        @rf ¸¦ ÁöÁ¤Çϸé ÇØ´ç rfÀÇ Tables ¸¸ »èÁ¦ÇÏ°í,
        @rf ·Î 0À» ÁöÁ¤ÇÏ¸é ¸ðµç TableµéÀ» »èÁ¦ÇÑ´Ù.
        
*/
void DMW_PSI_DeleteTables(int rf)
{
        PSITASK_SendCommand(ePSIM_CMD_DeleteTables, rf, 0, TRUE);
                // jump to PsiMsgHandler_DeleteTables
}

/*
        PSI DB¿¡ Á¢±ÙÇϱâ À§Çؼ­ »ç¿ëÇÏ´Â mutex lock API.

        Rule:
                PsiTask ¿¡¼­ DB´Â ÀÚÀ¯·Ó°Ô ÀÐÀ» ¼ö ÀÖÀ½.
                PsiTask ¿¡¼­´Â Lock ÈÄ DB ¼öÁ¤ °¡´É.
                
                ÀÓÀÇ task¿¡¼­´Â Lock ÈÄ DB Àб⠰¡´É.
                ÀÓÀÇ task¿¡¼­ DBÀÇ º¯°æÀº Àý´ë ±ÝÁö.
                
*/
void DMW_PSI_LockDB(BOOL bLock)
{
        PSIDB_LockDB(bLock);
}

S_PSIM_CHINFO *DMW_PSI_GetChInfo(int rf)
{
        return PSIDB_GetPsiChInfo(rf);
}

S_PSIM_SUBCHINFO *DMW_PSI_GetSubChInfo(int rf, int source_id)
{
        return PSIDB_GetPsiSubChInfo(rf, source_id);
}


#if 0
STATUS DMW_PSI_GetCurrentProgramInfo (TSD *tsd, DPG_ProgramInfo *info)
{


}


STATUS DMW_PSI_FreeProgramInfo (DPG_ProgramInfo *info)
{


}
#endif


const char *DMW_PSI_ScanStatusString(E_PSIM_SCAN_STATUS e)
{
        return PSIM_SCAN_STATUS_STRING(e);
}

const char *DMW_PSI_EventString(E_PSIM_EVENT e)
{
        return PSIM_EVENT_STRING(e);
}



#if COMMENT
____Test____(){}
#endif

#define OS_DbgPrintf DHL_OS_Printf

void TEST_PSI_TryTune(int rf, int pn, int sid)
{
        S_PSIM_CHINFO *chInfo;
        int i;
        MPEG_PMT *pmt = NULL;
        
        DMW_PSI_LockDB(TRUE);
        
        chInfo = DMW_PSI_GetChInfo(rf);
        if (chInfo) {
                OS_DbgPrintf("### pat %x, vct %x\n", chInfo->pat, chInfo->vct);
                if (chInfo->pat && chInfo->pmts) {
                        for (i=0; i<chInfo->pat->numPrograms; i++) {
                                if (chInfo->pmts[i]->program_number == pn) {
                                        pmt = chInfo->pmts[i];
                                        OS_DbgPrintf("### pmt[%d] %x\n", i, pmt);
                                        break;
                                }
                        }
                        
                        if (pmt && chInfo->vct) {
                                // get pid info using chInfo->vct and pmt..
                                // 
                                // vpid = xx, apid = xx..
                                OS_DbgPrintf("### ready for AV start..\n");
                        }
                }
        }
        DMW_PSI_LockDB(FALSE);

        // tune!
        
}


void TEST_PSI_EventProc(tDHL_TSD tsd, E_PSIM_EVENT evt, UINT32 param)
{
        if (0);
        else if (evt == ePSIM_EVENT_PatReceived) {
                //MPEG_PAT *pat = (MPEG_PAT *)status;
                //OS_DbgPrintf("\n\n ######## event, pat %x received, user %x\n\n\n",
                //      pat, param->userparam);
        }

        //--------------------------------------
        // belows are for viewing & recording
        
        else if (evt == ePSIM_EVENT_PmtReceived) {
                MPEG_PMT *pmt = (MPEG_PMT *)param;
                OS_DbgPrintf("\n\n ######## event, pmt %x received, user %x\n", pmt);

                //TEST_PSI_TryTune(param->rf, param->program_number, param->source_id);

                OS_DbgPrintf("\n\n");
        }
        else if (evt == ePSIM_EVENT_VctReceived) {
                xvctPtr_t vct = (xvctPtr_t)param;
                OS_DbgPrintf("\n\n ######## event, vct %x received\n", vct);

                //TEST_PSI_TryTune(param->rf, param->program_number, param->source_id);

                OS_DbgPrintf("\n\n");
        }

        //--------------------------------------
        // belows are for autoscan..
        
        else if (evt == ePSIM_EVENT_BasePsipReceived) {
                OS_DbgPrintf("\n\n ######## event, base psip received\n");

                OS_DbgPrintf("\n\n");
        }
        else if (evt == ePSIM_EVENT_AllPmtsReceived) {
                OS_DbgPrintf("\n\n ######## event, all pmts received\n");

                OS_DbgPrintf("\n\n");
        }
}



void TEST_PSI_Init(void)
{
        //extern STATUS Dmc_PausePsiMonitor(UINT32 bPause);
        //extern UINT8 g_Trace_PsiFilter, g_Trace_PsiFilterTidCount;
        
        Dmc_PausePsiMonitor(TRUE); // compiler warning will be removed later..

        //g_Trace_PsiFilter = 4;
        //g_Trace_PsiFilterTidCount = 20;

        DHL_DBG_SetModuleLevel("psieng", 3);
        DHL_DBG_SetModuleLevel("psitsk", 3);
        
        DMW_PSI_Init();
}

void TEST_PSI_Scan(int rf)
{
        tDHL_TSD *tsd = DHL_DMX_GetTsd();

        DMW_PSI_StartUpdate(tsd, rf, 0, 0, PSI_FLAGS_AUTOSCAN, TEST_PSI_EventProc, 0x11);
}

void TEST_PSI_Start(int rf, int pn, int si)
{
        tDHL_TSD *tsd = DHL_DMX_GetTsd();

        DMW_PSI_StartUpdate(tsd, rf, pn, si, PSI_FLAGS_NORMAL, TEST_PSI_EventProc, ((pn & 0xffff)<<16) | (si & 0xffff));
}

void TEST_PSI_Stop(int rf)
{
        tDHL_TSD *tsd = DHL_DMX_GetTsd();

        DMW_PSI_CancelUpdate(tsd);
}

#if 0
// Dmc_GetMainChannelTables(TSD * tsd, DmcMainTables * tbls, int timeOut, BOOL(* ckfn)(UINT32))

STATUS DMW_XXX_GetTablesForAutoScan (tsd, rf, timeout, cancelchk, tbls [out])
{

}
#endif