/******************************************************************* * DMW_ChannelScan.c * * Channel Auto Scan Module * * Copyright 2003 Digital STREAM Technology, Inc. * All Rights Reserved * * $Id: DMW_ChannelScan.c,v 1.09 2004/01/14 cafrii Exp $ * ********************************************************************/ #include "DMW_Platform.h" #include "DHL_OSAL.h" #include "DHL_AVCAP.h" #include "DHL_DBG.h" #include "DMW_Config.h" #include "DMW_Status.h" #include "../System/DMW_MsgQue.h" #include "DMW_DebugUtil.h" #include "DMW_Channel.h" // cafrii 031230. for OnePartChannel APIs. #include "DMW_ChannelAPI.h" #include "DMW_ChannelDemux.h" // cafrii 041130 add for Table Download #include "DMW_ChannelUtil.h" #include "dmw_channel_priv.h" #include "dmw_mcm_priv.h" #include "dmw_ucm_priv.h" //#include DHL_MODULE("$scn", 1); #define max(a,b) (((a) > (b)) ? (a) : (b)) #define min(a,b) (((a) < (b)) ? (a) : (b)) //=========================================================================== // // Design Notes // // //=========================================================================== // // Configuration parameters // // 각종 옵션 기능의 On/Off 설정, 컴파일러 옵션 설정, // 드라이버 관련 환경 설정 등.. // #define USE_PSI_INDEX_FOR_MINOR 0 // cafrii 060630 add // 1이면 PSI 채널 튜닝시 index를 minor로 사용. // 일반적으로는 index 대신 program number를 사용한다. #define SUPPORT_CSD_UPDATE 0 // 특정 platform 에서 CSD 기능이 필요치 않는 경우에는 이 flag를 0으로 reset 한다. // #define USE_DMW_EPGX_LIB 0 // 1 이면 EPGX LIB 에서 사용하는 MSS 관련 함수들을 사용한다. #define TEST_AUTOSCAN 1 // 테스트 코드 포함 여부 #define USE_PSI_RX_RETRY 0 // cafrii 070117 add // 처음에 download_tables에서 충분한 시간동안 모든 table을 받기 때문에 // 나중에 다시 retry를 할 필요는 없을 듯 하여 skip하도록 한다. #define USE_RESOLUTION_GATHERING 1 // neverdai add 101018. scan시 video 해상도 정보를 얻어낸다. int g_Timeout_PesPidCheck = 100; // // PES packet PID monitor timeout. 단위는 millisecond // Video/Audio PID를 수집한 다음 TSC bit check를 위해 이 시간 만큼 packet 수신을 기다린다. // BOOL g_TestAutoscanWithoutVct = FALSE; // TRUE 이면 VCT가 없는 채널과 같은 상황을 가정하여 동작한다. // #define CHANNEL_BMP_SIZE 5 // channel bitmap array size (in bytes) #define TEST_LARGE_PROGRAM_NUMBER 0 // cafrii 060728 test #define USE_UNIQUE_PSI_NUMBERING 1 // cafrii 070130 add for APRO-1 // //=========================================================================== // // Constants, Variables, Function declarations // // program number는 16 bit로 큰 범위이므로 적당히 assign을 하자. // 서로 다른 프로그램이 동일한 minor 번호를 가질 수도 있음에 유의. // Minor 0번은 air에서 analog program이라는 의미로 사용되므로 0의 값은 피한다. // #define PROG_NUM_TO_MINOR(pn) \ ((pn <= 999) ? (pn) : ((((pn) - 1000) % 999) + 1)) //((pn <= 1023) ? (pn) : ((((pn) - 1024) % 1023) + 1)) // cafrii 060630, restrict to 3 digits. #if TEST_LARGE_PROGRAM_NUMBER int g_TestLargeProgramNumber = 0; // cafrii 060728 test #endif #define USE_DEFAULT_CB_FN 0 // // 새로운 mw 구조에서는 // scan 과정 중에 tuner 설정 부분은 application에서 수행하는 것을 원칙으로 재설계됨. // 그런데 여러가지 이유로 application에서 이 코드를 구현할 수 없는 경우 // mw의 디폴트 구현을 사용할 수 있음. // 이 디폴트 콜백 함수는 코드 크기가 작지 않기 때문에 // 필요한 경우에만 compile/link 될 수 있도록 조건부로 compile 됨. #if USE_DEFAULT_CB_FN void SCB_ScanStart(ScanStartedCbParam *param); void SCB_ScanEnd(ScanCompleteCbParam *param); void SCB_TunerSet(ScanTunerSetCbParam *param); #endif // USE_DEFAULT_CB_FN void SCB_SkipTunerSet(ScanTunerSetCbParam *param); // 이 함수는 Default CB가 아니라 // 항상 compile 되어야 한다. //=========================================================================== // // Debugging Aids // //=========================================================================== // // 채널스캔 컨텍스트.. // 채널 검색 작업중에 필요한 여러가지 정보를 모아놓은 구조체. // 현재 검색중인 채널 번호, 현재 FSM의 상태 등등.. typedef enum { CTS_IDLE, // 채널 검색 태스크가 쉬는 중. CTS_RUNNING, // 채널 검색 작업이 진행 중. // analog / digital 분리해서 scan하는 경우에는 아래 state를 가진다. CTS_RUNNING_ANALOG, CTS_RUNNING_DIGITAL, } ChannelScanState; // 채널 검색 태스크의 상태. typedef struct { //------------------------------ // input variables // tDHL_TSD tsd; // TS source UINT32 original_flag; // StartScan() API에서 넘어온 플래그. CBTF_XXX 상수들의 조합. UINT32 flag; // 각 상황에 맞게 실제 적용할 플래그. // cafrii 060628, change to UINT32. bit flag 개수 늘어남.. int start_channel; // channel RF number to start to scan.. int end_channel; // last channel RF number to scan.. int total_channel; // number of channels to scan.. UINT32 channel_bmp[CHANNEL_BMP_SIZE]; // channel bitmap to scan BOOL quick_scan; // 현재 진행 중인 scan 작업이 normal scan 인지 quick scan 인지. // normal scan의 경우 scan start, scan end callback 이 호출되지만, // quick scan의 경우 이러한 callback 없이 호출된다. ChannelScanCallback fnCallback; // callback function pointer. ChannelScanCancelCheckFn fnCheck; // cancel check function // return TRUE if autoscan cancel is requested. //------------------------------ // state variables int cur_channel; // current channel.. 현재 채널 혹은 다음 단계에서 검색할 채널. // 이상 모두 RF 번호임. int channel_index; // 몇번째 수행하는 채널인지 표시.. 0 ~ total_channel-1 의 값을 갖는다. int freq_offset; // 현재 채널의 frequncy offset (in Hz) int signal_strength; // 현재 채널의 signal_strength; int tuner_modulation_mode; // ,, mod mode ChannelScanState state; // CTS_IDLE, CTS_RUNNING, ... tDHL_FreqStd cable_system; // 원래의 cable system //-------------------------------- // 작업중인 PSIP/PSI table pointers // 사용이 끝나면 반드시 Free를 시키고 NULL로 만들어줘야 한다. // xvctPtr_t xvct; MPEG_PAT *pat; int num_programs; MPEG_PMT **pmtList; } ChannelScanContext; typedef struct { UINT32 flag; ChannelScanCallback pfnCallback; // 한 채널만 scan하는 경우에는 rf 필드를 이용하고, // 둘 이상의 채널을 scan할 때에는 bitmap을 사용한다. int rf; UINT32 bitmap[CHANNEL_BMP_SIZE]; //UINT32 userparam; // userparam은 one channel scan에서 사용되고 있음. // 이 parameter는 memory pointer이면 안됨. // command가 cancel 될 경우에 대한 대응이 없으므로.. } ChannelScanCmdParam; typedef enum { eScanStop_Completed = 0, // scan 구간을 모두 검색하고 정상 종료. eScanStop_StopByUser, // StopScan API가 호출되어 정상 종료. // API의 인자에 따라서 검색된 정보가 cancel 될 수도 있다. eScanStop_Abnormal, // StopScan에 의하지 않고 비정상적인 종료. 그러나 DB 구성까지는 마무리한다. } ScanStopMode; #define STATIC #if COMMENT _____A_P_I_________(){} #endif //---------------------------------------------- // M/W APIs STATUS DMW_ASC_StartScan(int flag, ChannelScanCallback fn, int chStart, int chEnd) { ChannelScanSparseMap map; map.num_seg = 1; map.seg[0].ch_start = min(chStart, chEnd); map.seg[0].ch_num = max(chStart, chEnd) - min(chStart, chEnd) + 1; return DMW_ASC_StartSparseScan(flag, fn, &map); } /* scan할 rf 번호를 직접 인자로 넘겨서 해당 rf만 scan하도록 한다. 이 때 rfMap의 rf 번호는 오름차순으로 정렬이 되어 있어야 한다. */ STATUS DMW_ASC_StartScanEx(int flag, ChannelScanCallback fn, UINT8 *rfMap, int numRf) { ChannelScanSparseMap map; int i, idx; //mode 0 new, 1 normal for(i=0, idx=0; inum_seg = 1; if ((flag & CBTF_ChannelTypeMask) == CBTF_Air) { map->seg[0].ch_start = 2; map->seg[0].ch_num = 68; // 2 ~ 69 } else { map->seg[0].ch_start = 1; map->seg[0].ch_num = 135; // 1 ~ 135 } } param = Dmc_ParamHeapAllocator(sizeof(ChannelScanCmdParam)); if (param == NULL) { return statusOutOfMemory; } param->flag = flag; param->pfnCallback = fn; bmpChannel = ¶m->bitmap[0]; for (i=0; inum_seg; i++) { // ch_start 와 ch_num range가 0 ~ 159 사이에 들어와야 함. if (map->seg[i].ch_start < 0 || map->seg[i].ch_start + map->seg[i].ch_num - 1 >= 160) { dprint(0, "!! seg[%d] (%d, %d) invalid range. skip\n", i, map->seg[i].ch_start, map->seg[i].ch_num); continue; } for (k=0; kseg[i].ch_num; k++) { ch = map->seg[i].ch_start + k; if (ch >= 0 && ch < 160) // 5 dword로 표시 가능한 크기는 0 ~ 160 bmpChannel[ch/32] |= (0x80000000 >> (ch % 32)); // 동일한 채널이 여러 segment에 중복 되어도 상관 없다 } } status = Dmc_SendCommandEx(cmdScanStart, (UINT32)param, Dmc_ParamHeapDeallocator, //DMC_FN_CANCELFREE pfnFree, FALSE, //BOOL bWaitForComplete, NULL, 0, //DMC_FN_COMPLETED fn, UINT32 userparam, FALSE); //BOOL bCancelPrevCommand // jump to SCN_ScanStart if (status) { Dmc_ParamHeapDeallocator((UINT32)param); } return status; } // // 자동 채널 검색을 종료한다. // STATUS DMW_ASC_StopScan(BOOL bUpdate) { // bUpdate가 TRUE이면 지금까지의 결과를 update한다. STATUS status; dprint(1, "DMW_ASC_StopScan(%s)\n", bUpdate ? "update" : "cancel"); status = Dmc_SendCommandEx(cmdScanStop, (UINT32)bUpdate, NULL, //DMC_FN_CANCELFREE pfnFree, TRUE, //BOOL bWaitForComplete, NULL, 0, //DMC_FN_COMPLETED fn, UINT32 userparam, FALSE); //BOOL bCancelPrevCommand // jump to SCN_ScanStop return status; } //STATUS DMW_ASC_ScanChannel(int rf, int flag, ChannelScanCallback eventcb, UINT32 userparam) STATUS DMW_ASC_ScanChannel(int rf, int flag, BOOL bWaitComplete, ChannelScanCallback eventcb, DMC_FN_COMPLETED pfnComplete, UINT32 userParam, BOOL bCancelPrevCmds) { STATUS status; ChannelScanCmdParam *param; dprint(1, "DMW_ASC_ScanChannel rf %d, flag 0x%x\n", rf, flag); // cafrii 040920 // Air/Cable 플래그가 내부 함수인 ScanDigitalCableChannel 안에서 // 검사 용도로 사용되고 있다! 따라서 적절한 설정을 해주자.. // flag = (flag & ~CBTF_ChannelTypeMask) | // 먼저 channel_type bit들을 없애고.. (g_CurChannelType == ChannelType_Air ? CBTF_Air : CBTF_Cable); Dmc_StopVideo(); // 원래 caller가 stop을 해야 하는게 맞음. // caller는 모든 background 작업 (CC, EPG, EA, Rating)을 stop한 다음에 // 이 함수를 호출해야 한다. param = Dmc_ParamHeapAllocator(sizeof(ChannelScanCmdParam)); if (param == NULL) { return statusOutOfMemory; } param->flag = flag; param->pfnCallback = eventcb; param->rf = rf; //param->userparam = userParam; status = Dmc_SendCommandEx(cmdScanChannel, (UINT32)param, Dmc_ParamHeapDeallocator, //DMC_FN_CANCELFREE pfnFree, bWaitComplete, pfnComplete, userParam, bCancelPrevCmds); // jump to SCN_ScanOneChannel if (status) { Dmc_ParamHeapDeallocator((UINT32)param); } return status; } /* background로 현재 채널 검색을 수행한다. 이 함수는 Dmc task에서 동작하는 update이다. dmc task 내에서 새롭게 vct, psi 등을 수신하기 때문에 EPG 및 PsiMonitor가 중단되어 있어야 한다. 안그러면 하드웨어 동작에 따라 모두 timeout 에러가 발생할 수 있다. DMW_CDB_UpdateChannel 함수와는 사용 목적이 좀 다르다. */ STATUS DMW_ASC_UpdateChannel(int rf, int flag, BOOL bWaitComplete, DMC_FN_COMPLETED pfnComplete, UINT32 userParam, BOOL bCancelPrevCmds) { STATUS status; ChannelScanCmdParam *param; dprint(1, "DMW_ASC_UpdateChannel rf %d, flag 0x%x\n", rf, flag); // cafrii 040920 // Air/Cable 플래그가 내부 함수인 ScanDigitalCableChannel 안에서 // 검사 용도로 사용되고 있다! 따라서 적절한 설정을 해주자.. // flag = (flag & ~CBTF_ChannelTypeMask) | // 먼저 channel_type bit들을 없애고.. (g_CurChannelType == ChannelType_Air ? CBTF_Air : CBTF_Cable); flag |= CBTF_SkipTunerSet; //flag &= ~CBTF_CheckScrambleByVideoContext; // 이 flag는 caller가 유의해서 불러야 한다. // update mode에서 scramble check는 안하는게 좋다. // 현재 디코딩 동작 중에 이루어짐에 유의.. param = Dmc_ParamHeapAllocator(sizeof(ChannelScanCmdParam)); if (param == NULL) { return statusOutOfMemory; } param->flag = flag; param->pfnCallback = NULL; param->rf = rf; //param->userparam = 0; status = Dmc_SendCommandEx(cmdScanChannel, (UINT32)param, Dmc_ParamHeapDeallocator, //DMC_FN_CANCELFREE pfnFree, bWaitComplete, pfnComplete, userParam, bCancelPrevCmds); if (status) { Dmc_ParamHeapDeallocator((UINT32)param); } return status; } // // MW 내부에서 사용되는 // program_number --> minor 변환 식이다. // int DMW_ASC_ProgramNumberToMinor(UINT16 program_number) { return PROG_NUM_TO_MINOR(program_number); } #if COMMENT ___________________(){} #endif ChannelScanContext g_ScanContext; ChannelScanContext *get_scan_context(void) { return &g_ScanContext; } void send_event_message(ChannelScanEventType evt, UINT32 param) { ChannelScanContext *ctx = get_scan_context(); if (ctx->fnCallback) (ctx->fnCallback)(evt, param); } #if 0 // cafrii 100128 comment // DHL_AV_VideoStart 함수가 seqhdr 수신 체크까지 담당하지 않고 그냥 start만 시키는 것으로 변경되었으므로 // 이 함수는 제대로 동작하지 않는다. // 이 내부에서 DHL_AV_GetSequenceHeader 를 이용한 wait code가 들어가지 않는 한 별 의미 없는 함수임. STATUS check_pes_scramble(tDHL_TSD tsd, MPEG_PMT *pmt, int vPid, int pPid) { DHL_RESULT dhlResult = DHL_OK; STATUS status = statusOK; tDHL_VideoCodingType vidType; dprint(0, "\n!! %s not working. check!!\n\n", __func__); vidType=doDmc_SelectVideoStream(pmt, vPid); // zooyouny 100701 : tDHL_VDID를 0으로 간주, 다를 경우 문제 될 수 있음 dhlResult = DHL_AV_VideoStart(0, vPid, pPid, (tDHL_VideoCodingType)vidType); if (dhlResult == DHL_OK) status = statusOK; else if (dhlResult == DHL_WARN_SCRAMBLED) status = statusScrambled; else if (dhlResult == DHL_FAIL_CANCELLED_BY_USER) status = statusCancelled; else if (dhlResult == DHL_FAIL_TIMEOUT) status = statusTimeout; else status = statusError; dhlResult = DHL_AV_VideoStop(0); if (dhlResult) dprint(0, "!! Video Stop err %d\n", dhlResult); return status; } #endif #if COMMENT ___________________(){} #endif //======================================================================= // MCM 관리 루틴. // // MCM 관련 편의 함수들.. // MCM의 구조는 헤더 파일에 공개되어 있지만, MCM DB 자체는 AutoScan 과정에서만 필요한 // 임시 데이터이기 때문에 DB 자체의 access는 application에서는 금지된다. // // 검색된 채널 정보는 중간중간에 callback 함수를 이용하여 application으로 보고된다. // 이때 전달되는 데이터는 MCM DB item의 번지이다. // 그러나 callback 함수 안에서만 사용해야 한다는 제약조건이 있으므로 // "임시 데이터"로서의 MCM이라는 원래 정책을 위반하지는 않게된다. // // MCM의 자료 구조는 별도 모듈에서 구현하고, 그 구조는 차후 변경이 가능하다. // 1차원 array 또는 linked list 등.. // 해당 api를 통해서 사용하도록 한다. // MCM은 필요에 따라 처음 할당된 크기 이상으로 증가될 수 있다. (메모리 재할당) // static STATUS update_mcm_analog(int rfchannel, int strength, INT32 freq_offset, MCM_DB_T **ppmcm) { // MCM DB table에 해당 채널 정보를 추가한다. // 아날로그 채널 검색에서 검색된 정보일 경우에만 사용한다. // VCT에 포함되어 있는 아날로그 채널 정보는 다른 함수 이용. // strength: 신호 세기, 0~100 MCM_DB_T *m; if (strength == 0) strength = 1; // 0 값은 특별한 의미로 사용되므로 피한다. m = find_mcm_major_minor_rf_vf(rfchannel, 0, rfchannel, FALSE); // VCT에 등록되어 있는 analog 채널 정보는 update_mcm_xvct() 함수에서 처리된다. // todo.. // find_mcm_major_minor_rf_vf(rfchannel, 0, rfchannel, TRUE);를 먼저 찾아야 한다. // 이게 있으면 update를 하면 안된다. (방침에 따라) if (m == NULL) { m = new_mcm(); if (m == NULL) return statusOutOfMemory; } m->Major = rfchannel; // RF_channel을 major 번호로 등록함. m->Minor = 0; m->RF = rfchannel; m->Service_type = Modulation_NTSC; // cafrii 041122 change, from '0' m->signal_strength = strength; m->Skipped = 0; m->SurfIndex = 0; m->VctFlag = FALSE; m->freqOffset = freq_offset; // frequency offset 추가. m->Uid = get_new_mcm_id(); // cafrii 060726 add if (ppmcm) *ppmcm = m; return statusOK; } static STATUS update_psi_program(ChannelScanContext *ctx, UINT16 tsid, MPEG_PMT *pmt, int programIndex, MCM_DB_T **ppmcm) { // MCM DB table에 해당 채널 정보를 추가한다. // PSI정보는 VSB/QAM 등의 modulation 방식과는 무관하므로 // 현재의 ChannelType에 맞는 값을 ServiceType으로 간주한다. // programIndex는 minor 번호 부여를 할 때 혹시 필요할 수 있으므로 가져온다. // ppmcm은 생성된 mcm 포인터를 caller에게 넘겨주기위한 place holer int psiRF; int psiFreqOffset; // cafrii 050817 add MCM_DB_T *m, *target, tmp; STATUS status; //DHL_RESULT err; int k, strength; BOOL bScrambled = FALSE; // cafrii 101206, // m 초기화 코드 위치를 맨 처음으로 이동. m = &tmp; // 임시로 하나 준비한 다음 다 초기화를 하고 나서 MCM에 복사한다. memset(m, 0, sizeof(MCM_DB_T)); psiRF = ctx->cur_channel; psiFreqOffset = ctx->freq_offset; // cafrii 050817 add strength = ctx->signal_strength; if (strength == 0) strength = 1; // 0 값은 특별한 의미로 사용되므로 피한다. if (pmt == NULL) return statusInvalidArgument; dprint(2, "update_psi_program: pmt [idx %d] #%d, rf %d, tsid %d, str %d\n", programIndex, pmt->program_number, psiRF, tsid, strength); #if 0 // cafrii 041130 add // rf, tsid, program_number 등이 동일하면서 vct flag 1인 채널을 찾는다. // 이런 채널이 이미 존재한다면 새로 채널을 추가할 필요가 없다. // target = find_mcm_rf_prognum_vf(psiRF, pmt->program_number, 1); if (target) { dprint(2, "\tsame vct mcm already exist. no need to update..\n"); if (ppmcm) *ppmcm = NULL; //return statusOK; return statusChannelDuplicated; // cafrii 060725 bugfix } #else // cafrii 060725 change // fresh field가 추가되었으므로 이를 활용한다. // MCM에서 일치하는 정보를 발견했어도 Scan하기 전 옛날 데이터이면 // 새롭게 overwrite해준다. pid 등의 정보도 있기 때문. // if (check_mcm_if_rf_prognum_exist(psiRF, pmt->program_number)) { dprint(2, "\tsame vct mcm already exist. no need to update..\n"); if (ppmcm) *ppmcm = NULL; return statusChannelDuplicated; // cafrii 060725 bugfix } #endif //------------- PID 정보 추출 ----------------- // 이제 pid 정보 추출 작업은 ignore 할 수 없다. // psip의 경우 vct recover기능을 위해서 항상 수행한다. #if 0 if (ctx->flag & CBTF_IgnorePidsInfo) // PID 정보가 필요 없는 경우. { } else #endif { // cafrii 060728 change PidInfo psiPid; memset(&psiPid, 0, sizeof(psiPid)); // cafrii 041126 add // get pid and stream type, using MW default decision logic. status = Dmc_DecidePidInfo(pmt, NULL, &psiPid, 0); // give application change to override settings. doDmc_SelectAudioStream(pmt, NULL, &psiPid.audio, &psiPid.audioType); doDmc_SelectVideoStream(pmt, NULL, &psiPid.video, &psiPid.videoType); // PCR pid 값은 반드시 있어야 하며, Video pid 또는 Audio pid 둘 중 하나가 있어야 한다. // if (status == statusOK && psiPid.bValid && psiPid.pcr && (psiPid.video || psiPid.audio)) { m->Pcr_pid = psiPid.pcr; m->Video_pid = psiPid.video; m->Audio_pid = psiPid.audio; m->Video_type = psiPid.videoType; m->Audio_type = psiPid.audioType; dprint(2, " pid(pva): 0x%x 0x%x 0x%x, pmt0x%x, vt%d at%d\n", m->Pcr_pid, m->Video_pid, m->Audio_pid, pmt->PID, m->Video_type, m->Audio_type); } else { dprint(0, "!! cannot get pids in pmt[%d] #%d, err %s\n", programIndex, pmt->program_number, DMW_CDB_ErrString(status)); // cafrii 070117, too verbose.. remove //if (dprintable(3)) // PrintPMT(pmt); return statusPSIPError; } } // ------------ 암호화 여부 체크 ----------------- if (g_CurChannelType == ChannelType_Cable) { #if 0 // cafrii 050124 fix // // Motorolla HE 에서는 거의 대부분의 채널이 CA descriptor가 있기 때문에 // 이 방법을 사용하기가 어렵다. // // 1: CA descriptor를 찾아보기 if (GetMpegDescriptor(pmt->descriptors,pmt->descriptor_length, CA_tag, 0, NULL) == DHL_OK) { dprint(2, " !! PMT main descriptor has CA descriptor\n"); bScrambled = TRUE; } // 2: TSC bit를 검사하기 if (m->Video_pid || m->Audio_pid) // PID 정보가 있어야 이 방법을 사용할 수 있다. { int pidArray[2] = {0, }; // video and audio.. int tscArray[2] = {0, }; int nPid = 0; if (m->Video_pid) pidArray[nPid++] = m->Video_pid; if (m->Audio_pid && m->Audio_pid != m->Video_pid) pidArray[nPid++] = m->Audio_pid; status = Dmc_GetMultipleTscBits(ctx->tsd, nPid, pidArray, tscArray, g_Timeout_PesPidCheck*1000/1000, ctx->fnCheck); // cafrii 041202, add cancel check function // cafrii 050305, timeout to 100ms // cafrii 050315, change timeout value to variables // statusCancelled, timeoutError, outOfCPUMemoryError, ... if (status == statusCancelled) { return statusCancelled; } else if (status == statusOK) { // cafrii 050228, remove tsc bit 255 case, which is not_found.. if (tscArray[0] == 1 || tscArray[0] == 2 || tscArray[0] == 3 || tscArray[1] == 1 || tscArray[1] == 2 || tscArray[1] == 3 ) { dprint(2, " !! one of stream is scrambled bit checked. 0x%x:%d, 0x%x:%d\n", pidArray[0], tscArray[0], pidArray[1], tscArray[1]); bScrambled = TRUE; } } else dprint(0, "!! scrmabled bit check err %d\n", status); } // 3: Video context를 직접 생성해보기.. if (1) { // cafrii 031110 add // PSIP/PSI table로부터 scramble 정보를 얻는 방법이 신뢰할 수 없는 경우를 대비하여 // 직접 decoding을 시도해 보고 나서 scramble 여부를 결정한다. // if ((ctx->flag & CBTF_CheckScrambleByVideoContext) && m->Video_pid) { // cafrii 040114 bugfix #AudioOnlyChannelMissing // 이때 AudioOnly 채널의 경우 VideoDecoding이 항상 fail이 나서 항상 scramble로 간주되는 문제가 있으므로 // Audio only 채널의 경우에는 그냥 unscramble로 간주한다. status = check_pes_scramble(ctx->tsd, pmt, m->Video_pid, m->Pcr_pid); if (status == statusScrambled) { if(ctx->flag &CBTF_IgnoreScrambledChannel) { return status; } bScrambled = TRUE; dprint(1, "!! [ClearOnlyMode] PSI: PID v %d/p %d seems scrambled.\n", m->Video_pid, m->Pcr_pid); //return statusPSIPError; // statusOK만 아니면 됨. // // cafrii 050614 remove 'return' // scramble 채널도 DB에 넣고 scramble 표시를 해야 한다. // 따라서 여기서 return하지 않고 계속 진행하도록 한다. } else if (status == statusOK) { // good channel.. } else { dprint(0, "!! video ES seems invalid, status %d\n", status); } } } #endif } m->Major = psiRF; // PMT로부터 얻은 채널 정보에는 Major/Minor가 없다. // cafrii 050614 change numbering policy // program number를 Minor 번호로 할당한다. // #if USE_PSI_INDEX_FOR_MINOR m->Minor = programIndex+1; // 따라서 RF-index 값을 사용하도록 하자. index는 1,2,3... #else m->Minor = PROG_NUM_TO_MINOR(pmt->program_number); #endif m->Prog_number = pmt->program_number; #if USE_UNIQUE_PSI_NUMBERING // cafrii 070130 add // minor 번호가 겹치지 않도록 조정한다. 어짜피 PSI channel에서는 minor는 별 의미가 없다. #if 0 // Fake overlapped program number test dprint(0, "\n****** program number overlapping test\n\n"); m->Prog_number = 3 + programIndex*999; m->Minor = PROG_NUM_TO_MINOR(pmt->program_number); #endif // program number가 999 보다 큰 경우는 임의 할당을 한다. if (m->Prog_number > 999) { for (k=0; k<999; k++) // to avoid infinite loop, in case of all 1~999 is full. { if (find_mcm_major_minor(m->Major, m->Minor) == 0) break; // already some channel has same M-m. increase minor number.. if (k == 0) dprint(0, "!! minor ch %d (#%d) overlapped. adjusted\n", m->Minor, m->Prog_number); m->Minor = m->Minor < 998 ? m->Minor+1 : 1; } if (k >= 999) { // all 1~999 minor number is reserved??? dprint(0, "!! full 1~999 minor reserved?\n"); return statusPSIPError; } else if (k != 0) { dprint(0, " minor adjusted to %d --> %d-%d\n", m->Minor, m->Major, m->Minor); } } #endif #if 0 // USE_RESOLUTION_GATHERING //sequence 정보를 얻어야 함 do { #define MAX_SEQ_WAIT 5000 // 최대 5초를 기다림 tDHL_VideoSeqHdr seq; tDHL_DispFormat disp=eDHL_DISP_720x480i; UINT32 ms_start; if(m->Video_pid==0) break; DHL_AV_VideoHide(0, TRUE); DMC_RegisterVideoCallback(FALSE); DHL_AV_VideoStart(0, m->Video_pid, m->Pcr_pid, m->Video_type); for(ms_start=DHL_OS_GetMsCount(); DHL_AV_VideoSeqInfo(0, &seq)!=DHL_OK && DHL_OS_GetMsCount()-ms_start < MAX_SEQ_WAIT; DHL_OS_Delay(100)); if(DHL_OS_GetMsCount()-ms_start >=MAX_SEQ_WAIT) { //timeout ; } else { if(seq.vertical_size>=1080) disp=eDHL_DISP_1920x1080i; else if(seq.vertical_size>=720) disp=eDHL_DISP_1280x720p; else disp=eDHL_DISP_720x480i; } DHL_AV_VideoStop(0); DMC_RegisterVideoCallback(TRUE); m->video_format=disp; } while(0); #endif // cafrii 041122 add more conditions. if (ctx->tuner_modulation_mode == Modulation_8VSB) { m->Service_type = ctx->tuner_modulation_mode; } else if (ctx->tuner_modulation_mode == Modulation_64QAM || ctx->tuner_modulation_mode == Modulation_256QAM) { if (g_CurChannelType == ChannelType_Air) { dprint(0, "!! QAM modulation detected in Air mode scan\n"); m->Service_type = Modulation_8VSB; } else m->Service_type = ctx->tuner_modulation_mode; } else { dprint(0, "!! wrong tuner modulation %d in psi scan\n", ctx->tuner_modulation_mode); m->Service_type = g_CurChannelType == ChannelType_Air ? Modulation_8VSB : Modulation_64QAM; } m->RF = psiRF; m->freqOffset = psiFreqOffset; // cafrii 050817 add m->signal_strength = strength; // pid 정보 및 codec 정보는 위에서 이미 정리 완료. m->pmt_pid = pmt->PID; // cafrii 070201 add m->TSID = tsid; // 현재 튜닝된 채널 (이 DB를 포함하고 있는 채널)의 TSID m->source_id = 0; m->channel_tsid = tsid; // 이 프로그램의 TSID m->Skipped = 0; // 이 두가지는 나중에 여러 채널 중에서 선택하여 결정할 문제이다. m->SurfIndex = 0; m->hidden = FALSE; // VCT의 hidden 정보를 보관한다. 여기서는 알수 없음. m->VctFlag = 0; // cafrii, add. 030313. m->scrambled = bScrambled; // 이제 tmp가 다 준비되었다. dprint(2, " ====== found psichannel: %d-%d, rf %d, %s, #%d %s\n", m->Major, m->Minor, m->RF, ServiceTypeString(m->Service_type), m->Prog_number, m->scrambled ? "scrambled " : ""); // cafrii 060808, minor 중복 가능성 때문에 prog num을 사용하여 검사한다. // psi 채널에서 minor는 중요한 정보가 아니다. // //target = find_mcm_major_minor_rf_vf(m->Major, m->Minor, m->RF, 0); target = find_mcm_rf_prognum_vf(m->RF, m->Prog_number, 0); if (target) { // cafrii 060808 use 'fresh' field to determin overlapped channel // if (target->fresh == 0) { // 이 target은 예전 DB이므로 그냥 overwrit 해버리자. dprint(2, " same psi mcm found. overwrite to old mcm.\n"); // 기존 정보가 있으면 그 MCM에다 update한다. } else { // target은 방금 전에 추가된 신규 채널이므로 이번 정보를 버리자. dprint(2, " overlapped channel (#d) ignored\n", m->Prog_number); // pat에 똑같은 program number가 두개 이상 존재하는 경우 // 첫번째 것만 반영되고 나머지는 버린다. return statusChannelDuplicated; } } else { target = new_mcm(); // 기존 MCM 정보가 없으면 새로 MCM item을 하나 할당하고 등록한다. if (target == NULL) return statusOutOfMemory; } *target = *m; // 복사.. memcpy(target, m, sizeof(MCM_DB_T)); target->Uid = get_new_mcm_id(); // cafrii 060726 add target->fresh = 1; // cafrii 060808 add // 이번에 새롭게 update된 DB entry임을 나타낸다. if (ppmcm) *ppmcm = target; return statusOK; } // // update_psi // // VCT가 수신이 안된 상태이거나, VCT가 있더라도 CBTF_ForcePSI 옵션이 사용된 경우, // PsiOnlyMode 인 경우에 이 함수가 수행된다. // // VCT만으로 채널 DB 구성에 실패한 경우에 PSI 정보로 채널 DB를 구성하거나, // VCT의 정보에 PSI 정보를 추가로 보완하여 채널 DB를 추가 구성한다. // STATUS update_psi(ChannelScanContext *ctx) { int i, k; STATUS status = statusOK; int _second = 1000; int program_index; // sequencial program index. MPEG_PAT_program *program; // temporary.. MCM_DB_T *pmcm = NULL; BOOL bMinorNumberAutoAdjust = FALSE; // cafrii 060808 add // cafrii 070130 make false. // APRO1에서는 report 할 시점이 벌서 adjust가 되어 있어야 하므로 // 이 방법을 사용할 수 없다. // 대신 2-pass 방법을 사용한다. int pass; // cafrii 070130 add ScanNewChannelCbParam cbparam; typedef struct { UINT16 pn; // program number UINT16 id; // mcm id UINT16 minor; } _MinorAdjustParam; _MinorAdjustParam *param2 = NULL; int n_param2 = 0; if (ctx->pat == NULL || ctx->num_programs <= 0) { dprint(0, "!! no psi tables\n"); return statusPSIPError; } // cafrii 070130 add for new callback prototype memset(&cbparam, 0, sizeof(cbparam)); cbparam.fn_lookup_mj_mn = (BOOL (*)(int, int))find_mcm_major_minor; //------ PAT 처리. // cafrii 060724 change 1->0 // PMT의 index라는 의미로 0부터 시작한 값을 건네주자. // 필요하면 내부에서 non-zero interger로 변환하면 된다. program_index = 0; dprint(2, "total %d programs in PAT\n", ctx->num_programs); // cafrii 070130 add 2-pass scan.. // // for (pass=0; pass<2; pass++) // pass = 0; label_pass_start: if (pass >= 2) goto label_pass_end; for (i=0; inum_programs; i++) { pmcm = NULL; program = &ctx->pat->programs[i]; // cafrii 070130 add // 1st scan, #1~999 processed. 2nd scan, #1000+ processed // if (pass == 0 && program->program_number > 999) continue; if (pass == 1 && program->program_number <= 999) continue; // 만약 이미 VCT에 의해서 Channel DB가 update되어있다면 굳이 받을 필요는 없는데.... // MCM에 존재하는 DB가 이번 autoscan 에서 새로 받은 것인지, // 옛날 것인지 구분하는 flag가 없다... // // if (find_mcm_xx(rf, program->program_number)) // continue;; // // 그러나 해당 program number의 VCT channel이 존재한다고 해서 // 그 정보가 DB에 추가되었다고 볼 수는 없다!! // 왜냐하면 VCT channel의 정보가 완벽하지 못해서 skip되었을 수도 있기 때문.. // // 따라서 vct의 processed flag를 참조하여 DB에 적용된것인지 알아낸다. // #if 0 // cafrii 060725 delete if (ctx->xvct) { // 운나쁘게 analog 채널정보에 program number가 있는데 값이 일치하거나 // 또는 잘못된 vct channel 정보가 있었다면 비교가 정확하지 않게 된다. // for (k=0; kxvct->numChannels; k++) { if (ctx->xvct->channel[k].program_number == program->program_number) break; } if (k < ctx->xvct->numChannels && ctx->xvct->channel[k].processed) { dprint(2, "**** same program number channel (#%d) exist. skip updating psi..\n", program->program_number); continue; } } #else // cafrii 060725 change // cafrii 060808 comment: fresh mcm만 검색하도록 한다. // if (check_mcm_if_rf_prognum_exist(ctx->cur_channel, program->program_number)) { dprint(2, "**** same program number channel (#%d) exist. skip updating psi..\n", program->program_number); continue; } #endif if (ctx->fnCheck && ctx->fnCheck()) { status = statusCancelled; goto label_end_scan; } if (ctx->pmtList[i] == NULL) { // 현재 이 PMT는 아직 수신이 안되었음.. 이전 수신할 때 timeout 실패했을 가능성이 크다. #if USE_PSI_RX_RETRY // cafrii 050429 add // 앞에서 TVCT/CVCT/PAT/PMT를 한꺼번에 수신할 때에 어떠한 이유로든 PMT를 모두 수신하지 // 못했을 경우가 있을 수 있다. // 이 경우를 보완하기 위해서 수신하지 못한 PMT는 여기서 다시 한번 추가로 수신시도한다. dprint(2, "retry getting pmt[%d], pid 0x%x, #%d\n", i, program->program_map_PID, program->program_number); status = Dmc_GetPMT(ctx->tsd, program->program_map_PID, program->program_number, &ctx->pmtList[i], g_Timeout_PmtLoading*_second/1000, ctx->fnCheck); if (status == statusCancelled) { goto label_end_scan; } if (status) { dprint(0, "!! pmt[%d] pid 0x%x, #%d not loaded\n", i, program->program_map_PID, program->program_number); continue; // 다음 PMT로 진행.. } #else _second = _second; // to avoid warning.. dprint(0, "!! pmt[%d] program number #%d not loaded\n", i, program->program_number); continue; #endif } #if TEST_LARGE_PROGRAM_NUMBER // cafrii 060728 add for test // if (g_TestLargeProgramNumber) { if (i > 0 && ctx->pmtList[i-1] && ctx->pmtList[i]) { ctx->pmtList[i]->program_number = ctx->pmtList[i-1]->program_number+999; dprint(0, "!!!! large PN test: -> #%d\n", ctx->pmtList[i]->program_number); } else dprint(0, "!!!! large PN test: \n"); } #endif status = update_psi_program(ctx, ctx->pat->transport_stream_id, ctx->pmtList[i], program_index++, &pmcm); if (status == statusCancelled) { //return status; goto label_end_scan; } if (pmcm == NULL && status == statusOK) status = statusError; if (status) { // 그밖의 다른 에러.. 일단 멈추지 말고 계속 진행하자. } else // no error and pmcm valid { if (bMinorNumberAutoAdjust) { param2[n_param2].pn = pmcm->Prog_number; param2[n_param2].id = pmcm->Uid; param2[n_param2].minor = pmcm->Minor; n_param2++; } if (bMinorNumberAutoAdjust == FALSE) { if (pmcm) { // 새로 발견된 채널이 없을 수도 있다. 그럴 경우 pmcm 은 NULL 이다. //print_mcm(); cbparam.ucm = pmcm; send_event_message(evtNewChannel, (UINT32) &cbparam); // 새로 update한 mcm item 포인터를 넘겨준다. } } } } if (++pass < 2) goto label_pass_start; label_pass_end: if (bMinorNumberAutoAdjust && n_param2 > 0) { _MinorAdjustParam tmp; int free_minor_number; int nAdjustedChannel = 0; int pn_threshold = 1000; // 이 값 이상인 pn은 adjust를 한다. // program number로 sorting.. 오름 차순.. // for (i=0; i param2[k].pn) { tmp = param2[k]; param2[k] = param2[i]; param2[i] = tmp; } } } // threshold 보다 큰 pn은 일단 모두 minor 0으로 임시 할당. for (i=0; i= pn_threshold) ? 0 : param2[i].pn; // minor 0인 임시 채널을 순서대로 중복 안되게 할당.. free_minor_number = 1; for (i=0; iMinor = param2[i].minor; dprint(2, "\t[%d] %d - %3d, #%d %s\n", i, pmcm->Major, pmcm->Minor, pmcm->Prog_number, pmcm->Minor != pmcm->Prog_number ? "<---" : ""); } } } } if (1) { if (bMinorNumberAutoAdjust) { for (i=0; iMajor, pmcm->Minor, pmcm->Prog_number, pmcm->scrambled); cbparam.ucm = pmcm; send_event_message(evtNewChannel, (UINT32)&cbparam); } } } } label_end_scan: if (param2) DHL_OS_Free((void**)¶m2); return status; } // // // pat가 수신이 안되면 statusNoPSI // STATUS get_pmt_by_program_number(ChannelScanContext *ctx, xvctChannelPtr_t p, int *pIndex) { STATUS status = statusOK; int i; int idx = -1; // matched_pmt_index if (ctx->pat == NULL) { #if USE_PSI_RX_RETRY dprint(2, "\t no pat. get pat again..\n"); status = Dmc_GetPAT(ctx->tsd, &(ctx->pat), g_Timeout_PatLoading*1000/1000, ctx->fnCheck); if (status == statusCancelled) // cafrii 070117 add for bugfix return statusCancelled; if (status || ctx->pat == NULL) { dprint(0, "!! no pat..\n"); return statusNoPSI; } #else if (ctx->pat == NULL) { dprint(0, "!! no pat..\n"); return statusNoPSI; } #endif } // matched pmt index를 찾는다. // for (i=0; inum_programs; i++) { if (ctx->pat->programs[i].program_number == p->program_number) { idx = i; break; } } if (idx >= 0) { // 주의!! pmtList[i] 가 NULL 일 수도 있다!! // PAT에는 등록되어 있으나 실제로는 존재하지 않는 경우, // 또는 timeout되어서 PMT를 수신하지 못한 경우.. // if (ctx->pmtList[idx] && ctx->pmtList[idx]->program_number != p->program_number) { dprint(0, "!! received pmt[%d]'s pn #%d != vct ch pn#%d\n", idx, ctx->pmtList[idx]->program_number, p->program_number); FreePMT(ctx->pmtList[idx]); ctx->pmtList[idx] = NULL; } if (ctx->pmtList[idx] == NULL) { #if USE_PSI_RX_RETRY dprint(2, "\t no pmt yet. get pmt[%d] again..\n", idx); status = Dmc_GetPmtByProgramNumber(&(ctx->pat), &(ctx->pmtList[idx]), p->program_number, ctx->fnCheck); if (status == statusCancelled) // cafrii 070117 add for bugfix return statusCancelled; if (status) dprint(2, "\t pmt[%d] load failed %d\n", idx, status); #else if (ctx->pmtList[idx] == NULL) dprint(2, "!! no pmt[%d] loaded..\n", idx); #endif } *pIndex = idx; return status; } dprint(0, "!! pn #%d pmt not found. try recover vct..\n", p->program_number); // recover vct!! status = Dmc_RecoverVctProgramNumber(p, ctx->pat, // IN ctx->pmtList, // INOUT &idx, // OUT ctx->fnCheck); if (status == statusCancelled) return status; if (status) dprint(2, "!! recover failed, %d\n", status); else { // recover 성공.. *pIndex = idx; status = statusOK; } return status; } #if 0 // cafrii 060728 delete. no more used. // 새로운 pid selection rule을 사용하기 때문. // STATUS find_pids_from_psi(ChannelScanContext *ctx, MPEG_PMT *pmt, UINT16 *pPid, UINT16 *vPid, UINT16 *aPid) { int err = DHL_OK; UINT32 vidPid, audPid, pcrPid; if (pmt == NULL) { return statusNotFound; } //----- PMT 처리. err = GetElementaryPIDs(pmt, &vidPid, &audPid, &pcrPid, NULL, NULL, NULL); // 가능한 에러.. scrambledWarning, or notFoundError.. if (IsError(err)) { // cafrii, 030506 dprint(0, "!! cannot get pids in PMT #%d, err %s\n", pmt->program_number, ErrorString((DHL_RESULT)err)); // cafrii 050707 fix, i -> pmt->program_number if (dprintable(3)) PrintPMT(pmt); return statusPSIPError; } if (pPid) *pPid = (UINT16) pcrPid; if (vPid) *vPid = (UINT16) vidPid; if (aPid) *aPid = (UINT16) audPid; return err; // scrambledWarning 결과가 그대로 전달될 수 있도록.. } #endif // 0 static STATUS update_vct_subchannel(ChannelScanContext *ctx, UINT16 tsid, xvctChannelPtr_t p, BOOL is_cvct, MCM_DB_T **ppmcm) { // 새로 받은 VCT 테이블을 채널 DB에 추가하기 위해서 특정 minor 채널을 선택한 후 (p) // 이 함수를 불러 MCM DB에 등록한다. // // VCT의 해당 minor 채널 테이블에서 발견되는 모든 정보를 기록한다. // 기존 채널 DB에 (Mj/Mn/Rf/VctFlag)가 일치하는 항목이 있으면 update한다. // // 각 채널 타입 환경에 맞춰 update를 다르게 한다. // // MCM DB에 등록한 후 새로 등록된 MCM entry의 pointer는 ppmcm을 통해 caller에게 참조용으로 넘겨진다. // caller는 이 포인터를 이용하여 어떤 MCM이 등록되었는지 알 수 있다. // 단순히 참조용이며, caller는 필요한 경우 MCM 정보를 복사해서 사용할 수 있다. // // Note: leon 2003.9.2 // ETM_location,access_controlled,hidden,hide_guide도 고려할 필요가 있다. // 메이저 채널 DB를 사용할 경우(rf도 다를 때 ), // 이전에 등록되어 있던 메이저 채널(10-1,10-2,10-3,10-4)와 새로 추가된 채널 // 같은 메이저 번호 사용(10-1,10-2)일 경우,App가 이럴 경우, 메이저 번호 10을 두개 가지게 해야됨 // 다른 채널이니깐 ,,, 다른 메이저 DB에 등록할 수 있도록 구분 필요?? 어떻게 구분하지?? // // int strength; int vctRF; // vctRF는 vct를 수신한 채널, channelRF는 VCT에 기재된 virtual channel의 RF int vctFreqOffset; // cafrii 050603 add MCM_DB_T *m, m_0, *target = NULL; STATUS status; extendedChannelNameDescriptorPtr_t xcnd = NULL; // cafrii 041126 add BOOL is_cable = g_CurChannelType != ChannelType_Cable ? FALSE : TRUE; BOOL bScrambled = FALSE; // TRUE program is scrambled.. UINT32 audioPID32 = 0; // cafrii 060804 add vctRF = ctx->cur_channel; // 이 VCT를 수신했던 PTC의 RF번호 vctFreqOffset = ctx->freq_offset; // 이 VCT를 수신한 채널의 FreqOffset // cafrii 050603 add strength = ctx->signal_strength; // 현재 이 채널의 신호 세기 if (strength == 0) strength = 1; // 0 값은 특별한 의미로 사용되므로 피한다. dprint(2, "update_vct_subchannel: %s, rf %d, tsid %d, str %d\n", is_cvct ? "CVCT" : "TVCT", vctRF, tsid, strength); // A65B spec의 내용을 보면 Air에서도 CVCT의 사용이 금지된 것은 아닌것 같다. // 단, Air에서는 TVCT가 CVCT 보다 우선되는 것 뿐이다. // caller는 동시에 두개의 VCT가 수신될 경우 적당한 VCT를 선택해서 이 함수를 호출해야 한다. // // cafrii 041130 add comment // MCM 관리 규칙: // 먼저 local stack에 임시 mcm 을 만들고 초기화를 하고 나서 실제 MCM list에 추가하는 방식으로 한다. m = &m_0; memset(m, 0, sizeof(MCM_DB_T)); m->Major = p->major_channel_number; m->Minor = p->minor_channel_number; m->Prog_number = p->program_number; if (is_cvct && IsOnePartChannelNumber(m->Major)) { if (!is_cable) dprint(0, "!! OnePartChannel number in CVCT/Air.. maybe wrong\n"); m->Major = ConvertToOnePartChannelNumber(m->Major, m->Minor); m->Minor = ONE_PART_CHANNEL_INDICATOR; // 이 Minor 값으로부터 우리는 이 채널이 OnePartChannel이라는 것을 알 수 있다. dprint(2, "====== %d-%d (%d), #%d, mm 0x%x, st 0x%x, ch_tsid 0x%x\n", p->major_channel_number, p->minor_channel_number, m->Major, // OnePart number m->Prog_number, p->modulation_mode, p->service_type, p->channel_TSID); } else { // cafrii 060630 add // // for air TVCT, // major number range: 1 ~ 99 // minor number range: 0 ~ 999 // for analog service, 0 is used. // for digital or audio only, 1 ~ 99 is used. // for databroadcasting and etc, 1 ~ 999 is used. // we restrict minor number to 3 digits.. // // for cable CVCT, // major number range: 1 ~ 999 // minor number range: 0 ~ 999 // // cable에서 1000 ~ 1007 까지의 major, // air에서 1000 이상의 major는 어떻게 처리할 것인가? --> 에러 처리. // if (!is_cable && m->Major > 99) { // air 이면 tvct든 cvct든 99초과 금지. dprint(0, "!! air mode, major %d invalid!\n", m->Major); status = statusPSIPError; goto label_exit; } if (is_cable && m->Major > 999) { // cable이면 tvct든 cvct든 999 초과 금지. dprint(0, "!! cable mode, major %d invalid!\n", m->Major); status = statusPSIPError; goto label_exit; } // cafrii 060804, major 0 금지 // if (m->Minor != ONE_PART_CHANNEL_INDICATOR && m->Major <= 0) { dprint(0, "!! two part channel major 0 invalid\n"); status = statusPSIPError; goto label_exit; } if (m->Minor > 999) { dprint(0, "!! minor %d invalid!\n", m->Minor); status = statusPSIPError; goto label_exit; } dprint(2, "====== %d-%d, #%d, mm %d, st %d, ch_tsid 0x%x\n", m->Major, m->Minor, m->Prog_number, p->modulation_mode, p->service_type, p->channel_TSID); } //-------------------------------------------------------- // service_type을 결정. // modulation mode summary: // 00 : reserved // 01 : analog // 02 : SCTE_mode_1, 64QAM // 03 : SCTE_mode_2, 256QAM // 04 : ATSC 8VSB // 05 : ATSC 16VSB // // service type summary: // 00 : reserved // 01 : analog TV // 02 : ATSC digital TV // 03 : ATSC audio // 04 : ATSC data // 05 : ATSC sdds // if (p->modulation_mode == 1) // analog { // // 아날로그의 경우, minor가 0이 아니면 버린다. // if (p->minor_channel_number != 0) { dprint(0, "!! Err! Analog channel's minor is non-zero? ignore it!\n"); status = statusPSIPError; goto label_exit; } if (p->service_type != 1) { // 1: analog service dprint(0, "!! Err! modulation %d, service %d mismatch! ignore it!\n", p->modulation_mode, p->service_type); status = statusPSIPError; goto label_exit; } m->Service_type = Modulation_NTSC; // NTSC. } else if (p->modulation_mode == 2 || p->modulation_mode == 3 || // 64QAM / 256QAM p->modulation_mode == 4) // 8VSB { // 주의! TVCT에서도 QAM modulation이 가능하도록 해야 함.. (CableLab ATP 항목) // 따라서 TVCT/CVCT 의 여부가 중요한게 아니라 Air/Cable 여부가 더 중요하다. // if (!is_cable && // Air 모드에서 (p->modulation_mode == 2 || p->modulation_mode == 3)) { // QAM 인 경우.. dprint(0, "!! QAM modulation in Air.. ignore!\n"); status = statusPSIPError; goto label_exit; } // cafrii 060630 change, allow minor 0 for cable cvct.. // we just check cvct or not.. do not check air/cable. // because retransmission of terrestrial (tvct) is actually air case. // if (!is_cable && // Air 이고, (tvct든, cvct든..) m->Minor == 0) { // minor가 0인 경우.. dprint(0, "!! Err! in air, digital minor is zero.. ignore!\n"); status = statusPSIPError; goto label_exit; } if (p->service_type == 1) // Digital Modulation 이면서 analog service? dprint(0, "!! Warning! modulation is 8VSB, but analog service? assume Digital!\n"); #if 0 // VCT값을 사용하지 않고 detect 된 값을 사용하자. m->Service_type = p->modulation_mode == 2 ? Modulation_64QAM : // 2 ATSC-64QAM p->modulation_mode == 3 ? Modulation_256QAM : // 3 ATSC-256QAM Modulation_8VSB ; // ATSC-VSB #else // cafrii 041122 add more conditions. if (ctx->tuner_modulation_mode == Modulation_8VSB) { m->Service_type = ctx->tuner_modulation_mode; } else if (ctx->tuner_modulation_mode == Modulation_64QAM || ctx->tuner_modulation_mode == Modulation_256QAM) { if (g_CurChannelType == ChannelType_Air) { dprint(0, "!! QAM modulation detected in Air mode scan\n"); m->Service_type = Modulation_8VSB; } else m->Service_type = ctx->tuner_modulation_mode; } else { dprint(0, "!! wrong tuner modulation %d in psi scan\n", ctx->tuner_modulation_mode); m->Service_type = g_CurChannelType == ChannelType_Air ? Modulation_8VSB : Modulation_64QAM; } #endif } else // exceptions.. 지원하지 않는 modulation mode. 다른 값들을 이용해서 추정한다. { dprint(0, "!! Err! unknown modulation mode %d in vct\n", p->modulation_mode); // invalid VCT 정보를 버리지 않고 최대한 사용하려고 시도함. // modulation mode 값이 정확하지 않다면, service type 값으로부터 추정을 하자.. // if (p->service_type == 1) { // NTSC.. m->Service_type = Modulation_NTSC; } else { // 2, 3, 4, ... all digital services.. // Table에 제대로 된 ModulationMode 정보가 없으니 아무 값이나 사용하자.. // // todo.. // --> cafrii 041122, tuner의 modulation mode를 사용하는 것은 어떤가? // self channel 인 경우에는 가능하겠지만 remote channel 인 경우에는 문제가 된다. if (is_cable) { // TVCT가 온 경우 8VSB로 하는게 나을까? m->Service_type = Modulation_64QAM; } else // Air 인 경우.. m->Service_type = Modulation_8VSB; } } //-------------------------------------------------------- // 각 service_type 별로 처리.. // VCT의 service_type 은 다음과 같다. // 1: analog, 2: ATSC, 3: ATSC audio only, 4: ATSC data // // VCT의 modulation_mode // 1: analog, 2: 64QAM, 3: 256QAM, 4: 8VSB, 5: 16VSB // // MCM의 service type은 modulation mode에 더 가까운 개념이다. // // NTSC의 경우는 RF, freqOffset 을 결정. // Digial의 경우는 Pids, scrambled, RF, freqOffset 을 결정. // // dprint(2, " service type %d (%s) decided\n", m->Service_type, ServiceTypeString(m->Service_type)); if (m->Service_type == Modulation_NTSC) // NTSC { // cafrii 050902 change. no more support analog channel info in VCT dprint(0, "!! analog channel in VCT not support!\n"); status = statusPSIPError; goto label_exit; } else // digital.. ATSC_XXX. 8VSB/64QAM/256QAM { PidInfo vctPid; // cafrii 041125 add int matched_pmt_index = -1; //dprint(3, " pmtList 0x%x, num program %d\n", ctx->pmtList, ctx->num_programs); //--------------- RF 번호 결정 ---------------------- // // cafrii 050817 change // tsid 정보를 완전히 무시하고, 항상 현재 PTC에 포함된 채널로 간주한다. // m->RF = vctRF; // 이 VCT를 수신한 RF 채널 번호를 사용한다. m->freqOffset = vctFreqOffset; // //------------- PID 및 CodingType 정보 추출 ----------------- status = get_pmt_by_program_number(ctx, p, &matched_pmt_index); if (status == statusCancelled) // cafrii 070117 add for bugfix goto label_exit; memset(&vctPid, 0, sizeof(vctPid)); // cafrii 041126 add // cafrii 060727 add matched_pmt_index check code if (status == statusOK && matched_pmt_index >= 0) { status = Dmc_DecidePidInfo2(ctx->pmtList[matched_pmt_index], p->descriptors, p->descriptor_length, &vctPid, 0); doDmc_SelectAudioStream(ctx->pmtList[matched_pmt_index], p, &vctPid.audio, &vctPid.audioType); doDmc_SelectVideoStream(ctx->pmtList[matched_pmt_index], p, &vctPid.video, &vctPid.videoType); } else { // pmt에 문제가 있으면 vct만으로 수행. status = Dmc_DecidePidInfo2(NULL, p->descriptors, p->descriptor_length, &vctPid, 0); doDmc_SelectAudioStream(NULL, p, &vctPid.audio, &vctPid.audioType); doDmc_SelectVideoStream(NULL, p, &vctPid.video, &vctPid.videoType); } // PCR pid 값은 반드시 있어야 하며, Video pid 또는 Audio pid 둘 중 하나가 있어야 한다. // if (status == statusOK && vctPid.bValid && vctPid.pcr && (vctPid.video || vctPid.audio)) { // 성공적으로 PID 값이 추출되었음. // m->Pcr_pid = vctPid.pcr; m->Video_pid = vctPid.video; m->Audio_pid = vctPid.audio; m->Video_type = vctPid.videoType; m->Audio_type = vctPid.audioType; //neverdai 081002 && ctx->pmtList[matched_pmt_index] 추가. //논리적으로 ctx->pmtList[matched_pmt_index]는 NULL 값이 될 수 있기 때문에 체크해야 함. if (matched_pmt_index >= 0 && matched_pmt_index < ctx->num_programs && ctx->pmtList[matched_pmt_index]) m->pmt_pid = ctx->pmtList[matched_pmt_index]->PID; else m->pmt_pid = DMW_PID_NO_INFO; // vct recover 기능에 의해 program number가 바뀌었을 수 있다. m->Prog_number = p->program_number; dprint(2, " pid(pva): 0x%x 0x%x 0x%x, pmt 0x%x, vt%d at%d\n", m->Pcr_pid, m->Video_pid, m->Audio_pid, m->pmt_pid, m->Video_type, m->Audio_type); } else { dprint(0, "!! invalid pid info.. skip this subchannel\n"); // cafrii 060728 add // 유효한 pid가 없으면 DB에 넣지 않는다. status = statusPSIPError; goto label_exit; } // ------------ 채널 Long Name ----------------- #if USE_DMW_EPGX_LIB status = Dmc_GetInfoFromVctDesc(p->descriptors, p->descriptor_length, NULL, &xcnd); if (xcnd) { dprint(2, " extended channel name: \n"); if (dprintable(2)) { //memdump(xcnd->long_channel_name, xcnd->long_channel_name_length, "LongName"); Dmc_PrintMultipleString(xcnd->long_channel_name, xcnd->long_channel_name_length, 10, 0); // indent 10 } } #endif // ------------ 암호화 여부 체크 ----------------- // if (is_cable) { #if 0 // cafrii 050124 fix // // Motorolla HE 에서는 거의 대부분의 채널이 CA descriptor가 있기 때문에 // 이 방법을 사용하기가 어렵다. // // 1: CA descriptor를 찾아보기 if (matched_pmt_index >= 0) { // by MPEG system spec: // If any elementary stream is scrambled, a CA descriptor shall be // present for the program containing that elementary stream. MPEG_PMT *pmt = ctx->pmtList[matched_pmt_index]; if (GetMpegDescriptor(pmt->descriptors,pmt->descriptor_length, CA_tag, 0, NULL) == DHL_OK) { dprint(2, " !! PMT main descriptor has CA descriptor\n"); bScrambled = TRUE; } } // 2: TSC bit를 검사하기 if (m->Video_pid || m->Audio_pid) // PID 정보가 있어야 이 방법을 사용할 수 있다. { int pidArray[2] = {0, }; // video and audio.. int tscArray[2] = {0, }; int nPid = 0; if (m->Video_pid) pidArray[nPid++] = m->Video_pid; if (m->Audio_pid && m->Audio_pid != m->Video_pid) pidArray[nPid++] = m->Audio_pid; status = Dmc_GetMultipleTscBits(ctx->tsd, nPid, pidArray, tscArray, g_Timeout_PesPidCheck*1000/1000, ctx->fnCheck); // cafrii 041202, add cancel check function // cafrii 050305, timeout to 100ms // cafrii 050315, change timeout value to variables // statusCancelled, timeoutError, outOfCPUMemoryError, ... if (status == statusCancelled) { goto label_exit; } else if (status == statusOK) { //dprint(2, " tsc bit of pid %d, %d : %d, %d\n", // pidArray[0], pidArray[1], tscArray[0], tscArray[1]); // cafrii 050228, remove tsc bit 255 case, which is not_found.. if (tscArray[0] == 1 || tscArray[0] == 2 || tscArray[0] == 3 || tscArray[1] == 1 || tscArray[1] == 2 || tscArray[1] == 3 ) { dprint(2, " !! one of stream is scrambled bit checked. 0x%x:%d, 0x%x:%d\n", pidArray[0], tscArray[0], pidArray[1], tscArray[1]); bScrambled = TRUE; } } else dprint(0, "!! scrmabled bit check err %d\n", status); } // 3: Video context를 직접 생성해보기.. if (1) { if ((ctx->flag & CBTF_CheckScrambleByVideoContext) && m->Video_pid) { // cafrii 040114 bugfix #AudioOnlyChannelMissing // 이때 AudioOnly 채널의 경우 VideoDecoding이 항상 fail이 나서 항상 scramble로 간주되는 문제가 있으므로 // Audio only 채널의 경우에는 그냥 unscramble로 간주한다. if (matched_pmt_index >= 0) { // by MPEG system spec: // If any elementary stream is scrambled, a CA descriptor shall be // present for the program containing that elementary stream. status = check_pes_scramble(ctx->tsd, ctx->pmtList[matched_pmt_index], m->Video_pid, m->Pcr_pid); } else status = check_pes_scramble(ctx->tsd, NULL, m->Video_pid, m->Pcr_pid); if (status == statusScrambled) { if(ctx->flag &CBTF_IgnoreScrambledChannel) { return status; } bScrambled = TRUE; dprint(1, " !! video context (pid v %d/p %d) creation err. scrambled\n", m->Video_pid, m->Pcr_pid); } else if (status == statusOK) { // good channel.. } else { dprint(0, "!! video ES seems invalid.. status %d\n", status); } } } #endif } } // end if Service_type #if 0 // USE_RESOLUTION_GATHERING //sequence 정보를 얻어야 함 do { #define MAX_SEQ_WAIT 5000 // 최대 5초를 기다림 tDHL_VideoSeqHdr seq; tDHL_DispFormat disp=eDHL_DISP_720x480i; UINT32 ms_start; if(m->Video_pid==0) break; //video pid가 존재해야 아래 코드를 실행함. DHL_AV_VideoHide(0, TRUE); DMC_RegisterVideoCallback(FALSE); DHL_AV_VideoStart(0, m->Video_pid, m->Pcr_pid, m->Video_type); for(ms_start=DHL_OS_GetMsCount(); DHL_AV_VideoSeqInfo(0, &seq)!=DHL_OK && DHL_OS_GetMsCount()-ms_start < MAX_SEQ_WAIT; DHL_OS_Delay(100)); if(DHL_OS_GetMsCount()-ms_start >=MAX_SEQ_WAIT) { //timeout ; } else { if(seq.vertical_size>=1080) disp=eDHL_DISP_1920x1080i; else if(seq.vertical_size>=720) disp=eDHL_DISP_1280x720p; else disp=eDHL_DISP_720x480i; } DHL_AV_VideoStop(0); DMC_RegisterVideoCallback(TRUE); m->video_format=disp; } while(0); #endif m->signal_strength = m->RF == vctRF ? strength : 0; // 현재 TS의 채널 정보일 경우에만 신호 세기 기억. // 0 : 측정 안된 데이터. // analog의 경우도 0. m->TSID = tsid; // 현재 튜닝된 채널 (이 VCT를 포함하고 있는 채널)의 TSID m->source_id = p->source_id; m->channel_tsid = p->channel_TSID; // 이 프로그램의 TSID m->Skipped = 0; // 이 두가지는 나중에 여러 채널 중에서 선택하여 결정할 문제이다. m->SurfIndex = 0; m->hidden = p->hidden; // VCT의 hidden 정보를 보관한다. m->VctFlag = 1; // analog, digital 공히 VctFlag 1. m->scrambled = bScrambled; memcpy(m->ShortName, p->short_name, 14); dprint(2, " found subchannel: %d-%d, rf %d, %s(%d), $%d, #%d %s%s\n", m->Major, m->Minor, m->RF, ServiceTypeString(m->Service_type), m->Service_type, m->source_id, m->Prog_number, m->hidden ? "hidden " : "", m->scrambled ? "scrambled " : ""); // cafrii 060724 delete // 뒤에서 완전히 DB에 update하고 나서 flag 설정한다. //p->processed = TRUE; // 이 vct channel 정보는 제대로 DB에 반영 되었음을 표시.. //------------------------------------------------------------------ // 이제 local stack의 임시 MCM이 모두 준비되었다. // update 정책에 따라 update한다. 중복되는 정보가 있을 경우 아래 조건을 적용한다. // // 1. Analog 채널 정보의 경우는 VCT flag를 우선한다. 직접 검색한 채널 정보보다 정보가 많기 때문. // RF != major인 VctFlag=1의 채널도 허용한다. // 2. 디지털의 경우: [030317 cafrii, 삭제..] // // ASSERT (m->Service_type != Modulation_NTSC) // NTSC target = find_mcm_major_minor_rf_vf(m->Major, m->Minor, m->RF, 1); if (target == NULL) { target = new_mcm(); // 기존 MCM 정보가 없으면 새로 MCM item을 하나 할당하고 등록한다. if (target == NULL) { status = statusOutOfMemory; goto label_exit; } *target = *m; target->Uid = get_new_mcm_id(); // cafrii 060726 add } else { // cafrii 060724 comment // 사실 M,m,R,V 가 모두 동일하면서 program number가 다른 경우는 서로 구분이 안되므로 // 구분 튜닝이 불가능하고, DB에 추가하는 것이 의미가 없게 된다. // // 이번에 추가된 채널인지, 이전에 추가되었던 채널인지 구분할 수 있으면 좋음. // fresh field를 활용한다. if (target->Prog_number == m->Prog_number) { dprint(2, " previous ch found. overwrite to old one.\n"); } else { if (target->fresh == 0) { // 이 target은 예전 DB이므로 그냥 overwrit 해버리자. dprint(2, " pn# mismatch, %d!=%d, but overwrite with new info\n", target->Prog_number, m->Prog_number); } else { // target은 방금 전에 추가된 신규 채널이므로 이번 정보를 버리자. dprint(2, " pn# mismatch. %d != %d, ignore this subchannel\n", target->Prog_number, m->Prog_number); status = statusChannelDuplicated; goto label_exit; } } m->csd = target->csd; m->num_csd = target->num_csd; m->max_csd = target->max_csd; *target = *m; target->Uid = get_new_mcm_id(); // cafrii 060726 add } #if SUPPORT_CSD_UPDATE if (xcnd) // cafrii 041126 add { dprint(2, " update_csd_entry: size %d\n", xcnd->long_channel_name_length); status = DMW_CDB_UpdateCsdEntry(&target->csd, &target->num_csd, &target->max_csd, CSD_TAG_EXTENDED_NAME, xcnd->long_channel_name_length, xcnd->long_channel_name); if (status) { if (status != statusNotChanged) dprint(0, "!! update_vct_subchannel: long name tag update err %d\n", status); } } #endif // SUPPORT_CSD_UPDATE target->fresh = 1; // cafrii 060724 add // 이번에 새롭게 update된 DB entry임을 나타낸다. p->processed = TRUE; // cafrii 060724 move position here if (ppmcm) *ppmcm = target; status = statusOK; label_exit: if (xcnd) FreeMpegDescriptor(xcnd); return status; } //------------------------------------------------------ STATUS update_vct(ChannelScanContext *ctx) { STATUS status = statusOK; int i = 0; MCM_DB_T *pmcm; xvctPtr_t vct = ctx->xvct; int pass; ScanNewChannelCbParam cbparam; // cafrii 070130 add for new callback prototype memset(&cbparam, 0, sizeof(cbparam)); cbparam.fn_lookup_mj_mn = (BOOL (*)(int, int))find_mcm_major_minor; if (vct == NULL) return statusPSIPError; if (vct->numChannels <= 0) { dprint(0, "!! VCT has 0 channel!\n"); return statusPSIPError; } if (vct->channel == NULL) { dprint(0, "!! [%d] NULL channel in VCT!\n", i); return statusPSIPError; } dprint(2, "update VCT. total %d channel. signal %d\n", vct->numChannels, ctx->signal_strength); if (ctx->pat && ctx->pat->transport_stream_id != vct->transport_stream_id) { dprint(0, "!! pat tsid 0x%x != vct tsid 0x%x\n", ctx->pat->transport_stream_id, vct->transport_stream_id); } // cafrii 050802 add for (i=0; inumChannels; i++) vct->channel[i].processed = FALSE; // 각 subchannel 별로 process 여부를 기억하는 flag. // 처음에는 default로 FALSE이고, 처리되면 TRUE로 설정된다. // ---------- first pass -------------- // VCT의 모든 채널을 MCM에 모두 update한다. // // cafrii 070130 add, use 2-pass mode // for (pass=0; pass<2; pass++) { for (i=0; inumChannels; i++) { pmcm = 0; // user에게 event callback을 하기 위해, 현재 수집된 mcm 정보가 필요하다. if (ctx->fnCheck && ctx->fnCheck()) { //dprint(2, "\t channel scan cancelled!!\n"); status = statusCancelled; goto label_end_scan; // cafrii 060617 fix memory leak } // cafrii 070130 add // 1st scan, #1~999 processed. 2nd scan, #1000+ processed // if (pass == 0 && vct->channel[i].program_number > 999) continue; if (pass == 1 && vct->channel[i].program_number <= 999) continue; if ((ctx->flag & CBTF_IgnoreNtscInVct) && vct->channel[i].modulation_mode == 1) { // 1:Analog if (!pass) dprint(1, " [%d] analog channel! ignored by user\n", i); continue; // If this channel is analog, skip it. } status = update_vct_subchannel(ctx, vct->transport_stream_id, &(vct->channel[i]), vct->is_cvct, &pmcm); if (status == statusCancelled) // cafrii 081006 add goto label_end_scan; if (1) { if (status == statusOK) { //print_mcm(); cbparam.ucm = pmcm; send_event_message(evtNewChannel, (UINT32)&cbparam); // 새로 update한 mcm item 포인터를 넘겨준다. } else { // 설령 한 채널이 잘못되었다고 하더라도 // 다음 채널은 괜찮을 수 있으므로 계속 진행해야 한다. } } } // for } label_end_scan: return status; } #if COMMENT ___________________(){} #endif // // ChannelScanContext 내의 각종 테이블들을 모두 free시킨다. // // static void free_tables_in_context(ChannelScanContext *ctx) { int i; Dmc_FreeAtscTable(&ctx->xvct); Dmc_FreeAtscTable(&ctx->pat); if (ctx->pmtList) { for (i=0; inum_programs; i++) { Dmc_FreeAtscTable(&ctx->pmtList[i]); } DHL_OS_Free((void**)&ctx->pmtList); ctx->num_programs = 0; } } static STATUS download_tables(ChannelScanContext *ctx) { DmcMainTables tbls; xvctPtr_t vct = NULL; STATUS status; int _second = 1000; memset(&tbls, 0, sizeof(tbls)); // todo.. // CBTF_PsiOnlyMode 에서는 VCT를 전혀 사용하지 않을 것이기 때문에 // 다운로드 시도를 할 필요조차도 없다. // 그러나 현재 PAT/PMT만 다운로드 받는 함수가 없음.. // status = Dmc_GetMainChannelTables(ctx->tsd, &tbls, g_Timeout_VctLoading*_second/1000, ctx->fnCheck); if (status == statusCancelled) { // 도중에 취소가 된 경우라 하더라도 // 일부 수신된 table이 있을 수 있음. 해제시켜야 한다. Dmc_FreeMainChannelTables(&tbls); return statusCancelled; } if (g_TestAutoscanWithoutVct) { dprint(0, "**** test mode: NO VCT case, only psi available ****\n"); Dmc_FreeAtscTable(&tbls.tvct); Dmc_FreeAtscTable(&tbls.cvct); } // Antenna 모드에서는 CVCT가 수신이 되었어도 이것을 사용하지 않도록 한다. if (tbls.cvct && g_CurChannelType == ChannelType_Cable) { status = Dmc_TranslateCvct(tbls.cvct, &vct); dprint(2, "\tCVCT found. total %d channels\n", vct->numChannels); } else if (tbls.tvct) { status = Dmc_TranslateTvct(tbls.tvct, &vct); dprint(2, "\tTVCT found. total %d channels\n", vct->numChannels); } if (tbls.tvct) FreeAtscTable(tbls.tvct); if (tbls.cvct) FreeAtscTable(tbls.cvct); // context에 필요한 table 모두 이동.. ctx->xvct = vct; ctx->pat = tbls.pat; ctx->num_programs = tbls.num_programs; ctx->pmtList = tbls.pmtList; if (dprintable(2)) // cafrii 070117 add { char buf[100]; int i, n_pmt = 0, n; n = ctx->num_programs; for (i=0; ipmtList[i]) n_pmt++; dprint(2, "\t pat %d, pmt %d/%d\n", ctx->pat ? 1 : 0, n_pmt, ctx->num_programs); buf[0] = 0; n = min(80, ctx->num_programs); // print max 80 pmts.. for (i=0; ipmtList[i] ? '1' : '.'); // print each pmt's existance.. dprint(2, "\t rx map: %s\n", buf); } return statusOK; } //----------------------------------------------------- // ScanCableChannel // // 케이블 모드에서 한 채널을 검색한다. // // bSetTuner 가 FALSE이면 Tuner set을 하지 않는다. // caller 측에서 이미 튜닝을 한 경우에 사용된다. // static STATUS scan_one_channel(ChannelScanContext *ctx) { // Table의 우선순위는 CVCT -> TVCT -> PSI 이다. // // 옵션에 따라서 Cable 환경에서는 TVCT를 무시할 수도 있다. // Antenna 모드에서는 CVCT는 무시된다. // STATUS status = statusOK; ScanTunerSetCbParam param; BOOL bCable; ScanNewChannelCbParam cbparam; memset(&cbparam, 0, sizeof(cbparam)); bCable = (ctx->flag & CBTF_ChannelTypeMask) == CBTF_Cable ? TRUE : FALSE; dprint(1, "scan_one_channel (%s %d)\n", bCable ? "cable" : "air", ctx->cur_channel); //------------------------------------------- // user에게 callback을 보내서 튜너/Demod 설정을 하도록 한다. // flag에 따라 skip할 수도 있음. // memset(¶m, 0, sizeof(param)); if ((ctx->flag & CBTF_SkipTunerSet) == 0) { // skip option이 아닌 경우, callback을 불러서 tuner 설정을 수행한다. param.channel = ctx->cur_channel; // cafrii 061219 add // analog separate scan 지원.. // if (ctx->state == CTS_RUNNING_ANALOG) // analog only scan stage param.flag = (ctx->flag & ~(CBTF_8VSB | CBTF_QAM)); // remove digital flag else if (ctx->state == CTS_RUNNING_DIGITAL) // digital only scan stage param.flag = (ctx->flag & ~CBTF_NTSC); // remove analog flag else param.flag = ctx->flag; // pass all flag untouched param.one_channel_scan = ctx->quick_scan; // app 에서 적절한 대응을 할 수 있도록 quick scan 임을 알려줌. param.chkfn = ctx->fnCheck; param.return_value = statusNotImpl; send_event_message(evtScanTunerSet, (UINT32)¶m); // execute tuner set if (param.return_value == statusCancelled) goto label_cancelled; if (param.return_value == statusNotImpl) { dprint(0, " !! scan tune callback not implemented\n"); #if USE_DEFAULT_CB_FN SCB_TunerSet(¶m); if (param.return_value == statusCancelled) goto label_cancelled; #else status = statusNotImpl; goto label_end_scan; #endif } } else { SCB_SkipTunerSet(¶m); } if (param.return_value == statusCancelled) goto label_cancelled; if (! param.locked) { dprint(3, " !! rf signal unlocked..\n"); goto label_end_scan; } // cafrii 060814 add // analog를 지정하지 않았는데 analog라면 unlock과 같음. if ((ctx->flag & CBTF_NTSC) == 0 && param.mode == Modulation_NTSC) { dprint(3, " !! ntsc detected..\n"); goto label_end_scan; } // 아날로그 채널인지 먼저 체크 // if (param.mode == Modulation_NTSC) { MCM_DB_T *pmcm = NULL; dprint(2, " Analog signal locked. offset %d, strength %d\n", param.freq_offset, param.strength); status = update_mcm_analog(ctx->cur_channel, param.strength, param.freq_offset, &pmcm); // possible err: statusOutOfMemory if (status == statusOK) { //print_mcm(); cbparam.ucm = pmcm; send_event_message(evtNewChannel, (UINT32)&cbparam); } goto label_end_scan; } // 이하 디지털 채널임. ctx->freq_offset = param.freq_offset; ctx->tuner_modulation_mode = param.mode; ctx->signal_strength = param.strength; dprint(2, " digital signal locked! offset %d, mode %d, strength %d\n", param.freq_offset, param.mode, param.strength); if (ctx->fnCheck && ctx->fnCheck()) goto label_cancelled; //------------------------------------------- dprint(2, " Start loading VCT, PSI..\n"); status = download_tables(ctx); if (status == statusCancelled) goto label_cancelled; if (ctx->flag & CBTF_PsiOnlyMode) goto label_psi_scan; status = update_vct(ctx); if (status == statusCancelled) goto label_cancelled; // cafrii 060808, vct에서 fail이면 flag에 상관 없이 psi scan을 수행. if (status) goto label_psi_scan; if (ctx->flag & CBTF_ForcePSI) // CVCT를 성공적으로 수신했더라도 flag에 따라 PSI를 추가하기도 한다. goto label_psi_scan; else goto label_end_scan; label_psi_scan: if (ctx->fnCheck && ctx->fnCheck()) goto label_cancelled; status = update_psi(ctx); goto label_end_scan; label_cancelled: dprint(2, "\tchannel scan cancelled!!\n"); status = statusCancelled; label_end_scan: free_tables_in_context(ctx); return status; } static STATUS process_mcm(BOOL bSelectMaxChannel) { // MCM 정보를 이용하여 UCM을 만든다. // 이 함수는 항상 ChannelScan 태스크에서만 불리도록 되어 있으며, static이다. // 이 함수와 비슷한 역할을 하는 함수로 update_current_scan() 함수가 있다. // 이것은 현재 채널에 대해서 background에서 채널 스캔을 하여 update를 하는 함수이다. // // 중복되는 채널은 signal strength 값을 비교하여 하나만 선택한다. "대표채널선택" // // // 주의! UCM에도 모든 채널 정보가 들어가야 한다. // UCM은 Major/Minor를 기준으로 오름차순으로 정렬되어야 한다. print_mcm(); // 1. MCM을 정렬한다. update하면서 정렬이 되어 있는 상태라면 여기서 할 필요는 없다. dprint(2, "*** Sort MCM..\n"); sort_mcm(); print_mcm(); // cafrii 050721 add condition if (bSelectMaxChannel) { // 2. 동일한 Mj/Mn/Vf 조합이 있으면 신호 세기가 가장 큰 것을 선택하고, // 나머지는 skip flag를 세팅한다. dprint(2, "*** Select favorite channels.\n"); select_max_mcms(); print_mcm(); } // 3. UCM으로 복사한다. (skip flag 세팅된 것 포함) dprint(2, "*** Generate UCM.\n"); copy_to_ucm(); // 4. mcm 제거. free_all_mcm(); return statusOK; } void post_process_ucm(int flag) { int i; DMW_MSC_LockUcm(); for (i=0; i