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

/*
        DMW_PsiLinkedList.c

        DST TV MW PSI Scan Module

        PSI Database entry linked list implementation

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

*/


#include "DMW_Platform.h"

#include "DMW_PsiLinkedList.h"



#if COMMENT
____DbgPrint____(){}
#endif

DHL_MODULE("psils", 0);


#if COMMENT
____List____(){}
#endif


//extern 
S_PSIM_CHINFO *g_PsiDB;



S_PSIM_CHINFO *PSI_FirstChInfo(void)
{
        return g_PsiDB;
}

/*
        ¸µÅ© ¸®½ºÆ®·Î ¿¬°áµÈ ChInfo ¸®½ºÆ® Áß¿¡¼­ ÇØ´ç id¸¦ °®´Â node¸¦ ã¾Æ¼­ ¸®ÅÏÇÏ´Â ÇÔ¼ö

        @start °¡ NULL ÀÌ¸é ¸Ç Ã³À½ CHINFO ¸®ÅÏ.
*/
S_PSIM_CHINFO *PSI_SearchChInfo(S_PSIM_CHINFO *start, int id)
{
        // Note!!
        // this function should be called in Mutex Locked State if current task is not EpgTask
        
        S_PSIM_CHINFO *chInfo = start;
        
        while (chInfo && chInfo->id != id)
                chInfo = chInfo->next;
                
        return chInfo;
}

S_PSIM_CHINFO *PSI_GetChInfo(int id)
{
        return PSI_SearchChInfo(PSI_FirstChInfo(), id);
}

S_PSIM_CHINFO *PSI_NextChInfo(S_PSIM_CHINFO *cur)
{
        return cur ? cur->next : NULL;
}

void PSI_InsertChInfo(S_PSIM_CHINFO *chInfo)
{
        // insert epg db list chain.. id ¼ø¼­·Î sorting ÇÑ´Ù.
        int id = chInfo->id;
        S_PSIM_CHINFO *node, *prev;

        if (chInfo->prev || chInfo->next) {
                dprint(0, "!! inserting non-orphan node?\n");
                //chInfo->prev = chInfo->next = 0;
                return;
        }
        
        node = g_PsiDB;
        prev = NULL;
        dprint(3, "traverse chanInfo chain from 0x%x\n", node);
        while (node && node->id < id) {
                prev = node;
                node = node->next;
        }
        // node°¡ NULL À̰ųª node->id > id ÀÎ °æ¿ì.. ÀÌ node ¾ÕºÎºÐ¿¡ ³ÖÀ¸¸é µÈ´Ù.
        //  prev  ¿Í   node »çÀÌ¿¡ Ãß°¡.
        dprint(3, "insert new chanInfo between 0x%x and 0x%x\n", prev, node);
        chInfo->prev = prev;
        chInfo->next = node;
        
        if (prev) prev->next = chInfo;
        if (node) node->prev = chInfo;
        
        if (prev == NULL) 
                g_PsiDB = chInfo;

}

void PSI_RemoveChInfo(S_PSIM_CHINFO *chInfo)
{
        if (chInfo->prev)
                chInfo->prev->next = chInfo->next;
        else
                g_PsiDB = chInfo->next;
        
        if (chInfo->next)
                chInfo->next->prev = chInfo->prev;
}

S_PSIM_CHINFO *PSI_NewChInfo(int id)
{
        // search if same rf DB exist..
        S_PSIM_CHINFO *chInfo;

        chInfo = PSI_GetChInfo(id);
        if (chInfo)
                return chInfo;

        // id°¡ ÀÏÄ¡ÇÏ´Â DB°¡ ÇöÀç Á¸ÀçÇÏÁö ¾Ê´Â´Ù. »õ·Î ¸¸µé¾î¾ß ÇÑ´Ù.
        // create new channel Info..
        dprint(1, "alloc new channInfo for id %d\n", id);
        chInfo = DHL_OS_Malloc(sizeof(S_PSIM_CHINFO));
        if (chInfo == NULL) {
                dprint(0, "!! chanInfo out of memory\n");
                // call eventproc
                //Dmc_EpgSendUserEvent(context, epgEventError, (UINT32)statusOutOfMemory, (UINT32) DMW_CDB_ErrString(statusOutOfMemory));
                
                // epg stop..
                //OS_GiveSemaphore(gDmcEpgCommandAckSema4);
                //break;
                return NULL;
        }
        
        dprint(3, "new chanInfo created..\n");
        chInfo->id = id;
        chInfo->magic = CHANNEL_INFO_MAGIC;

#if DMW_PSI_SUPPORT_ELAPSED_TIMER
        // cafrii 060814 add
        DMW_ResetCounter(&chInfo->counter);
        DMW_HoldCounter(&chInfo->counter);
#endif
        return chInfo;
}