/* DMW_ChannelUtil.c */ #include "DMW_Platform.h" #include "DHL_SYS.h" #include "DHL_AVCAP.h" #include "DHL_DBG.h" #include "DMW_Config.h" #include "DMW_Channel.h" #include "dmw_channel_priv.h" #include "DMW_ChannelUtil.h" #include "DMW_Status.h" #include "DMW_DebugUtil.h" //#include //#include DHL_MODULE("$dmc", 1); #define max(a,b) (((a) > (b)) ? (a) : (b)) #define min(a,b) (((a) < (b)) ? (a) : (b)) // cafrii 100705 // 새로운 DHL API 인터페이스에 따른 변경 // #define NEW_DHL_API 1 #if COMMENT ______UserMsgQueue______(){} #endif #include "../System/DMW_MsgQue.h" DMW_MSGQUE g_DmcMsgQue = { NULL, // msg pool buffer. should be NULL. 0, //sizeof(DmcMessage), // sizeof each message 0, //MAX_DECODE_MESSAGES, // que size 0, // current number of messages 0, // mutex 0, // semaphore NULL, // pfn name }; char *dmc_cmd_name(DmcMessage *pmsg) { return Dmc_MsgString(pmsg->type); } STATUS doDmc_InitUserMsgQue(int nSizeOfMsg, int nMaxNumMsgInQue) { if (nSizeOfMsg == 0 || nMaxNumMsgInQue == 0) { return statusInvalidArgument; } return DMW_SYS_InitMsgQue(&g_DmcMsgQue, nSizeOfMsg, nMaxNumMsgInQue, (DMW_FN_MSG_NAME) dmc_cmd_name); } void doDmc_DeleteUserMsgQue(void) { // todo.. // 리소스를 삭제할 수 있는 API? } STATUS doDmc_AddUserMsg(DmcMessage *pmsg) { return DMW_SYS_AddUserMsg(&g_DmcMsgQue, pmsg); } STATUS doDmc_GetUserMsg(DmcMessage *pmsg, UINT32 timeout) { return DMW_SYS_GetUserMsg(&g_DmcMsgQue, pmsg, timeout); } BOOL doDmc_UserMsgExist() { return DMW_SYS_UserMsgExist(&g_DmcMsgQue); } BOOL dmc_cmd_is_event(DmcMessage *pmsg, UINT32 param) { if (pmsg && !Dmc_IsCommand(pmsg->type)) return TRUE; // this is event.. return FALSE; } // cafrii 060831 add void dmc_cmd_delete_event(DmcMessage *pmsg) { // 어짜피 event라면 status report를 하지 않을 것이므로 어떤 값을 지정해도 무관. // Dmc_DeleteDmcMessage(pmsg, statusCancelled); } void doDmc_DeleteAllEventMsg() { DMW_SYS_DeleteMsgConditionally(&g_DmcMsgQue, (DMW_FN_MSG_CHECK) dmc_cmd_is_event, 0, (DMW_FN_MSG_DELETE) dmc_cmd_delete_event); } BOOL dmc_cmd_is_matched(DmcMessage *pmsg, UINT32 param) { if (pmsg && pmsg->type == (DmcMsgType) param) return TRUE; return FALSE; } void doDmc_DeleteMsg(DmcMsgType msgtype) { DMW_SYS_DeleteMsgConditionally(&g_DmcMsgQue, (DMW_FN_MSG_CHECK) dmc_cmd_is_matched, msgtype, (DMW_FN_MSG_DELETE) dmc_cmd_delete_event); } BOOL doDmc_CheckMsgExist(DmcMsgType msgtype) { return DMW_SYS_CheckSpecificMsgExist(&g_DmcMsgQue, (DMW_FN_MSG_CHECK) dmc_cmd_is_matched, msgtype); } char *dmc_cmd_cid_name(DmcMessage *pmsg) { static char buf[10]; sprintf(buf, "%d", pmsg->cancelId); return buf; } void doDmc_PrintUserMsgs() { DMW_SYS_PrintUserMsgs(&g_DmcMsgQue, (DMW_FN_MSG_NAME) dmc_cmd_cid_name); } #if COMMENT _____CancelQue______(){} #endif //--------------------------------------------------------------- // Command cancel 관련.. // #define NUM_CANCEL_ID 10000000 // cancel ID 번호 매김을 할때 사용되는 범위. 0 ~ NUM_CANCEL_ID-1 // cafrii 030701 // I increase this value upto 1000 times larger. // There was bugs about event cancel. this number is not the reason of error, // but this fix will minimize occurence of overwrap. // If events occurs at every seconds, this number correspond to 115 days. int dmc_lastCancelId = -1; int dmc_currentCancelId = -1; // -1 means not-initialized. // normal range is 0 ~ MAX_CANCEL_ID-1 #define NEXT_CANCEL_ID(c, step) (((c) + (step)) % NUM_CANCEL_ID) // // 사용 가능한 cancel ID range 내에서 step 갯수만큼을 skip한 후의 다음 cancel ID를 // 계산하는 매크로. DHL_OS_MSGQ_ID dmc_cancelQ; int doDmc_GetLastCancelId() { return dmc_lastCancelId; } void doDmc_SetLastCancelId(int id) { dmc_lastCancelId = id; } int doDmc_GetNextCancelId(int c, int step) { return NEXT_CANCEL_ID(c, step); } int doDmc_GetNewCancelId() { // Cancel ID를 하나 새롭게 부여하는 함수. // // Dmc Task로 message를 보낼때에는 항상 cancel ID를 하나 부여 받아 같이 함께 보낸다. // Dmc Task에서는 이 cancel ID를 이용하여 수신된 message가 이미 cancel 된 것인지 알수 있다. // // 이 함수는 DMC task에서 call될수도 있고 임의의 태스크에서 call 될수도 있다. int cancelId; if (1) { UINT32 mask = DHL_OS_DisableInterrupts(); dmc_currentCancelId = NEXT_CANCEL_ID (dmc_currentCancelId, 1); cancelId = dmc_currentCancelId; DHL_OS_RestoreInterrupts(mask); } return cancelId; } int doDmc_GetNewMultipleCancelIds(UINT32 count) { // Cancel ID를 'count' 갯수만큼 부여하는 함수. // 준비한 cancel ID는 일련번호이며, 맨 처음 cancel ID값을 리턴한다. // caller는 리턴되는 cancel ID의 시작부터 총 'count' 갯수만큼의 ID를 사용할 수 있다. // // caller는 DMC에 보낼 message에 기록하는 cancel ID와, cancel command에 보내는 cancel ID를 // 연속된 값으로 얻기를 원한다. 이때 이 함수를 사용한다. // // 이 함수는 DMC task에서 call될수도 있고 임의의 태스크에서 call 될수도 있다. // count 0 is ignored. (set to 1 forcefully) // int cancelIdStart; if (count <= 1) return doDmc_GetNewCancelId(); if (1) { UINT32 mask = DHL_OS_DisableInterrupts(); cancelIdStart = NEXT_CANCEL_ID (dmc_currentCancelId, 1); dmc_currentCancelId = NEXT_CANCEL_ID (cancelIdStart, count-1); DHL_OS_RestoreInterrupts(mask); } return cancelIdStart; // cancelIdStart 부터 시작해서 count 갯수만큼 사용이 가능하다. } BOOL doDmc_IsCancelledMsg(int msgId) { int lastCancelId = dmc_lastCancelId; // 두 ID값을 비교한다. // // lastCancelId: 가장 마지막으로 입력된 cancel ID. // // msgId: 현재 수신된 메시지의 ID if (abs(msgId - lastCancelId) > NUM_CANCEL_ID/2) { // ! it is wrapped state. // 정당한 비교를 위해서 작은 값에 NUM_CANCEL_ID를 더한다. // if (msgId < lastCancelId) msgId += NUM_CANCEL_ID; else lastCancelId += NUM_CANCEL_ID; } if (msgId <= lastCancelId) return TRUE; // cancelled!! else return FALSE; } /* return true if new cancel id is updated. */ BOOL doDmc_RefreshCancelQue() { // clear cancel queue. // 가장 마지막 cancel_number를 리턴한다. // 만약 cancel queue가 비어있으면 cancel_num은 손대지 않는다. int rc; int msg, msgLen; BOOL bNewCancelRefreshed = FALSE; rc = DHL_OS_ReceiveMessage(dmc_cancelQ, (char *)&msg, 0); while (rc == DHL_OK) { doDmc_SetLastCancelId(msg); bNewCancelRefreshed = TRUE; //OS_Delay(1); rc = DHL_OS_ReceiveMessage(dmc_cancelQ, (char *)&msg, 0); } return bNewCancelRefreshed; } BOOL doDmc_CheckCancel() { int rc; int msg, msgLen; // 030613 // // cancel Q에 메시지가 있다고 해서 현재 메시지가 cancel되었다고 볼수는 없다. // 이 cancel msg의 cid가 현재 메시지의 cid보다 나중의 값인지 비교해 봐야 하지 않을까? // // --> message를 받은 직후에 cancel 체크를 한번 하게 되어 있는데, // 이때 OK라면 그 이후에는 cancel Q의 emptyness 만 체크하는 것으로도 충분하다. // // 그리고 cancel Q를 여기서 empty로 만들 필요는 없다. // 다음 message를 받기 전에 ClearCancelQ를 불러 청소를 하기 때문. // // 즉, 아래 코드는 전혀 문제 없는 코드임. // // cafrii 041110 add comment // 단순히 message queue에서 msg가 있는지의 여부만으로 cancel 체크를 수행하기 때문에 // 일단 cancel msg를 받았으면 그 정보를 무시하면 안된다. // 다시 이 함수를 또 부르면 그때는 not_cancel 이라고 리턴할 것이다. (msg que 가 비었으므로) // rc = DHL_OS_ReceiveMessage(dmc_cancelQ, (char *)&msg, 0); if (rc == 0) { dprint(1, "!! cancel requested. cid %d\n", msg); doDmc_SetLastCancelId(msg); return TRUE; // cancel message received. } else return FALSE; // something err or not canceled. } //----------------------------------------------------------- // STATUS Dmc_SendCancelCommand(int cancelId) { UINT32 msg; //msg = doDmc_GetNewCancelId(); msg = cancelId; dprint(3, "Send cancel command, cid %d\n", msg); if (dmc_cancelQ) { return (STATUS)DHL_OS_SendMessage(dmc_cancelQ, &msg, sizeof(msg)); } return statusOutOfResource; // no cancel Q?? } STATUS Dmc_InitCancelQue(int nSizeQue) { if (dmc_cancelQ) return statusOK; dmc_cancelQ = DHL_OS_CreateMessageQueue("DmcCancelQ", 0, nSizeQue, sizeof(UINT32)); return dmc_cancelQ ? statusOK : statusOutOfResource; } void Dmc_DeleteCancelQue(void) { DHL_OS_DeleteMessageQueue(dmc_cancelQ); dmc_cancelQ = 0; } #if COMMENT _______PSI_Util________(){} #endif BOOL Dmc_CheckIfSamePat(MPEG_PAT *pat1, MPEG_PAT *pat2) { #if 0 // for reference typedef struct MPEG_PAT_program { UINT16 program_number; UINT16 program_map_PID; } MPEG_PAT_program; typedef struct MPEG_PAT { UINT16 transport_stream_id; UINT8 version_number; BOOLEAN current_next_indicator; UINT8 section_number; UINT8 last_section_number; BOOLEAN isWholePAT; /* FALSE if only a singe section of a PAT */ UINT16 numPrograms; BOOLEAN networkPIDPresent; /* TRUE if network_pid is valid */ UINT16 network_PID; MPEG_PAT_program *programs; } MPEG_PAT; #endif int i; if (!pat1 || !pat2 || pat1->transport_stream_id != pat2->transport_stream_id || pat1->numPrograms != pat2->numPrograms) return FALSE; // todo.. // 순서만 달라진 경우는 equivalent pat로 볼 수 있는데 // 그것에 대한 체크 필요. for (i=0; inumPrograms; i++) if (pat1->programs[i].program_number != pat2->programs[i].program_number || pat1->programs[i].program_map_PID != pat2->programs[i].program_map_PID) return FALSE; return TRUE; } BOOL Dmc_CheckIfSamePmt(MPEG_PMT *pmt1, MPEG_PMT *pmt2) { // 두 PMT를 비교해서 같은 것인지 아닌지 비교한다. // todo.. // 주로 PsiEventProc에서 불릴 것인데, tDHL_PSI_DataArray를 직접 비교하는 것은 어떨까? // // 같으면 TRUE를 리턴한다. // 버전 번호 (CRC도?) 는 비교하지 않는다. int i; if (!pmt1 || !pmt2 || pmt1->PID != pmt2->PID || pmt1->program_number != pmt2->program_number || pmt1->PCR_PID != pmt2->PCR_PID || pmt1->descriptor_length != pmt2->descriptor_length || pmt1->numStreams != pmt2->numStreams) return FALSE; if (pmt1->descriptors && pmt2->descriptors && pmt1->descriptor_length > 0) { if (memcmp(pmt1->descriptors, pmt2->descriptors, pmt1->descriptor_length)) return FALSE; } for (i=0; inumStreams; i++) { MPEG_PMT_stream *st1 = &pmt1->streams[i], *st2 = &pmt2->streams[i]; if (st1->stream_type != st2->stream_type || st1->elementary_PID != st2->elementary_PID || st1->descriptor_length != st2->descriptor_length) return FALSE; if (st1->descriptors && st2->descriptors && st1->descriptor_length > 0 && memcmp(st1->descriptors, st2->descriptors, st1->descriptor_length)) return FALSE; } return TRUE; } // Dmc_CheckPmtDifference // 두개의 PMT를 비교한다. // 두 PMT를 비교한 결과, 서로 동일하지 않으면 non-Zero를 리턴. // int Dmc_CheckPmtDifference(MPEG_PMT *pmt1, MPEG_PMT *pmt2) { MPEG_PMT_stream *str1, *str2; int i, errbase; // if invalid PMTs are passed to this function, return valus is meaningless. if (pmt1 == NULL || pmt2 == NULL) return 1; if (pmt1->PID != pmt2->PID) return 2; if (pmt1->program_number != pmt2->program_number) return 3; if (pmt1->PCR_PID != pmt2->PCR_PID) return 4; if (pmt1->descriptor_length != pmt2->descriptor_length) return 5; if (pmt1->descriptor_length && memcmp(pmt1->descriptors, pmt2->descriptors, pmt1->descriptor_length)) return 6; if (pmt1->numStreams != pmt2->numStreams) return 7; for (i=0; inumStreams; i++) { str1 = &(pmt1->streams[i]); str2 = &(pmt2->streams[i]); errbase = (i+1)*10; if (str1->stream_type != str2->stream_type) return errbase+1; if (str1->elementary_PID != str2->elementary_PID) return errbase+2; if (str1->descriptor_length != str2->descriptor_length) return errbase+3; if (str1->descriptor_length && memcmp(str1->descriptors, str2->descriptors, str1->descriptor_length)) return errbase+4; // videoStreamDescriptor is NULL if not present if ((str1->videoStreamDescriptor && !str2->videoStreamDescriptor) || (!str1->videoStreamDescriptor && str2->videoStreamDescriptor)) // if only one of the two is NULL return errbase+5; if (str1->videoStreamDescriptor && // if both are non-NULL and, memcmp(str1->videoStreamDescriptor, str2->videoStreamDescriptor, sizeof(VideoStreamDescriptor))) // if contents are different return errbase+6; // VideoDecodeControlDescriptor has valid flag.. // compare whole contents including valid flag if (memcmp(&str1->videoDecodeControlDescriptor, &str2->videoDecodeControlDescriptor, sizeof(VideoDecodeControlDescriptor))) return errbase+7; } return FALSE; // meaning that two PMTs are same.. } #if COMMENT _______PSI_Util2_________(){} #endif // // VCT channel pointer로부터 major/minor 값을 추출하는 함수 // // major 값의 범위를 체크해서 One Part 형식일 경우 해당 형식에 맞게 변환한다. // UINT16 Dmc_GetMajorNumber(BOOL is_cvct, xvctChannelPtr_t ch) { if (is_cvct && IsOnePartChannelNumber(ch->major_channel_number)) { return ConvertToOnePartChannelNumber( (ch)->major_channel_number, (ch)->minor_channel_number); } return (ch)->major_channel_number; } UINT16 Dmc_GetMinorNumber(BOOL is_cvct, xvctChannelPtr_t ch) { if (is_cvct && IsOnePartChannelNumber(ch->major_channel_number)) { return ONE_PART_CHANNEL_INDICATOR; } return (ch)->minor_channel_number; } //=========================================================================== // // Debug // // from $6.7, Table 6.16 from ATSC A-65.A document // const char *Dmc_PsipDescriptorString(UINT8 d) { if (d == 0x80) return "Stuffing descriptor"; if (d == 0x81) return "AC-3 audio descriptor"; if (d == 0x86) return "Caption service descriptor"; if (d == 0x87) return "Content advisory descriptor"; if (d == 0xA0) return "Extended channel name descriptor"; if (d == 0xA1) return "Service location descriptor"; if (d == 0xA2) return "Time-shifted service descriptor"; if (d == 0xA3) return "Component name descriptor"; if (d >= 0xC0 && d <= 0xFE) return "User private"; return "Unknown"; } #if COMMENT ____PSILoad____(){} #endif // // 해당 program number에 해당하는 PAT/PMT를 수신한다. // // [IN] program_number, fnCheck // [INOUT] ppat, ppmt // // return value: // statusOK // statusInvalidPSI // statusNoPSI // statusCancelled // STATUS Dmc_GetPmtByProgramNumber(MPEG_PAT **ppat, MPEG_PMT **ppmt, UINT16 program_number, BOOL (*fnCheck)(void)) { // TVCT, CVCT 처리 중에 불린다. // VCT를 수신하면서 동시에 PAT는 받아져 있는 경우가 대부분이지만, // 못받은 경우에는 다시 받는다. // PMT는 안받아져 있는게 보통이다. 지정된 program_number에 해당하는 것을 받는다. // 받은 table은 ctx 저장되어 리턴된다. // STATUS status, returnStatus = statusOK; int i; int _second = 1000; MPEG_PAT *pat; MPEG_PMT *pmt; if (ppat == NULL || ppmt == NULL) return statusInvalidArgument; pat = *ppat; pmt = *ppmt; dprint(2, "Dmc_GetPmtByProgramNumber(#%d):\n", program_number); if (pat && pmt) { if (pmt->program_number == program_number) { dprint(2, "\talready program number %d PMT received\n"); return statusOK; } else { dprint(2, "\tfree previous PMT.. program num %d\n", pmt->program_number); FreePMT(pmt); pmt = NULL; } } // PAT를 수신한다. // if (pat == NULL) { dprint(2, "\tget new pat..\n"); status = Dmc_GetPAT(Dmc_GetCurrentTsd(), &pat, g_Timeout_PatLoading*_second/1000, fnCheck); if (status == statusCancelled) goto label_cancelled; else if (status) { dprint(1, "!! PAT load failed, %d\n", status); returnStatus = statusNoPSI; goto label_end_function; } if (fnCheck && fnCheck()) goto label_cancelled; dprint(2, "\tpat found. TSID %d, total %d programs\n", pat->transport_stream_id, pat->numPrograms); // MPEG_PAT } else { dprint(2, "\tpat %x already exist. TSID %d, %d programs\n", pat, pat->transport_stream_id, pat->numPrograms); } if (pat->numPrograms == 0 || pat->programs == NULL) { dprint(1, "!! invalid PSI.. no program in pat?\n"); returnStatus = statusInvalidPSI; goto label_end_function; } // 원하는 프로그램을 찾는다. // find 'the program' whose program number is 'progNumber'. // if not found, we report error directly. // for (i=0; inumPrograms; ++i) { if (pat->programs[i].program_number == program_number) break; } if (i >= pat->numPrograms) { dprint(1, "!! program number %d not found!\n", program_number); returnStatus = statusChannelNotFound; goto label_end_function; } dprint(2, "\tget pmt of program number #%d\n", pat->programs[i].program_number); status = Dmc_GetPMT(Dmc_GetCurrentTsd(), pat->programs[i].program_map_PID, pat->programs[i].program_number, &pmt, g_Timeout_PmtLoading*_second/1000, fnCheck); if (status == statusCancelled) goto label_cancelled; else if (status) { dprint(1, "!! PMT (#%d, pid %x) load failed, err %d\n", pat->programs[i].program_number, pat->programs[i].program_map_PID, status); returnStatus = statusNoPSI; goto label_end_function; } returnStatus = statusOK; goto label_end_function; label_cancelled: returnStatus = statusCancelled; label_end_function: *ppat = pat; *ppmt = pmt; return returnStatus; } // cafrii 060710 add // // vct의 program number에 해당하는 프로그램이 PAT에 없는 경우, // vct의 program number의 PMT가 수신이 안되는 경우, // vct의 program number 정보가 잘못된 것으로 가정하고 복구를 수행한다. // 등록된 모든 PMT를 수신해서 가장 비슷한 PMT의 program number로 교체한다. // // [IN] xvctChannelPtr_t channel : 복구할 vct channel. // pat : 반드시 있어야 하며, 제대로 된 것이어야 함. // cancel check fn // // [INOUT] pmt list // STATUS Dmc_RecoverVctProgramNumber(xvctChannelPtr_t channel, MPEG_PAT *pat, // IN MPEG_PMT **pmtList, // INOUT int *pIndex, // OUT BOOL (*fnCheck)(void)) { STATUS status = statusError; int k; int _second = 1000; PidInfo pid1, pid2; if (channel == NULL) return statusInvalidArgument; dprint(2, "Dmc_RecoverVctProgramNumber(vct #%d):\n", channel->program_number); if (pat == NULL) return statusInvalidPSI; // PAT 수신을 더이상 시도하지 않는다. // 이 함수가 불리는 단계라면 이미 몇 번 PAT 수신에 실패한 경우일 것임. // if (pat->numPrograms == 0 || pat->programs == NULL) { dprint(1, "!! invalid PSI.. no program in pat?\n"); status = statusInvalidPSI; goto label_end_function; } memset(&pid1, 0, sizeof(pid1)); status = Dmc_GetInfoFromVctDesc(channel->descriptors, channel->descriptor_length, &pid1, NULL); if (status) { dprint(2, "!! vct pid info invalid. cannot recover\n"); return statusInvalidVCT; } for (k=0; knumPrograms; k++) { if (pmtList[k] && pat->programs[k].program_number == pmtList[k]->program_number) { // already downloaded. } else { dprint(2, "\t[%d] load pmt #%d..\n", k, pat->programs[k].program_number); if (pmtList[k]) FreePMT(pmtList[k]); // pn이 pat것과 다른 것이므로 삭제후 다시 받음. status = Dmc_GetPMT(Dmc_GetCurrentTsd(), pat->programs[k].program_map_PID, pat->programs[k].program_number, &pmtList[k], g_Timeout_PmtLoading*_second/1000, fnCheck); if (status == statusCancelled) goto label_cancelled; else if (status) { dprint(2, "\t PMT[%d] load failed, %d\n", k, status); continue; } } // pmt의 pid 정보와, vct의 pid 정보가 일치하면 서로 같은 program으로 보고 // vct의 program number를 수정하자! status = Dmc_GetPidInfoFromPMT(pmtList[k], &pid2); if (status) { dprint(2, "\t PMT[%d] pid info err %d\n", k, status); continue; } if (pid1.pcr == pid2.pcr && pid1.video == pid2.video && pid1.audio == pid2.audio) { dprint(2, "\tcorrect pmt found. recover vct #%d -> #%d\n", channel->program_number, pmtList[k]->program_number); channel->program_number = pmtList[k]->program_number; if (pIndex) *pIndex = k; status = statusOK; goto label_end_function; } } dprint(2, "\tproper pmt not found.\n"); status = statusNotFound; goto label_end_function; label_cancelled: status = statusCancelled; label_end_function: return status; } #if COMMENT ____PID____(){} #endif #define IS_VALID_PES_PID(p) ((p)>=0x10 && (p)<=0x1ffe) #define IS_VALID_PCR_PID(p) ((p)>=0x10 && (p)<=0x1ffe) STATUS Dmc_GetPidInfoFromSLD(serviceLocationDescriptorPtr_t sld, PidInfo *pPidInfo) { int i; BOOL bAudioPidFound = FALSE; // audio pid는 처음 발견되는 것 하나만 사용. if (pPidInfo == NULL) return statusInvalidArgument; pPidInfo->pcr = sld->PCR_PID; for(i=0; inumber_elements; i++) { if(sld->element[i].stream_type == StreamType_MPEG2Video) // MPEG-2 video { // ITU-T Rec.H.262 | ISO/IEC 13818-2 Video or // ISO/IEC 11172-2 constrained parameter video stream pPidInfo->video = sld->element[i].elementary_PID; dprint(3, " [%d] sld video pid %d (0x%x)\n", i, pPidInfo->video, pPidInfo->video); } else if (sld->element[i].stream_type == StreamType_AC3Audio) // ATSC A/53 audio { // ATSC A/53 Audio UINT32 lanCode; if (bAudioPidFound == FALSE) // 맨 처음 발견되는 audio만 처리하도록 한다. pPidInfo->audio = sld->element[i].elementary_PID; lanCode = sld->element[i].ISO639_language_code; dprint(3, " [%d] sld audio pid %d (0x%x), Lang code (%c%c%c) %s\n", i, sld->element[i].elementary_PID, sld->element[i].elementary_PID, (lanCode>>16) & 0xff, (lanCode>>8) & 0xff, lanCode & 0xff, bAudioPidFound ? "ignored" : ""); bAudioPidFound = TRUE; } // cafrii 041203 add.. 강동 케이블 채널에서 MPEG-2 Audio 스트림이 나오고 있음. else if (sld->element[i].stream_type == StreamType_MPEG1Audio || sld->element[i].stream_type == StreamType_MPEG2Audio) // MPEG audio { // MPEG 1 Audio, MPEG 2 Audio UINT32 lanCode; if (bAudioPidFound == FALSE) // 맨 처음 발견되는 audio만 처리하도록 한다. pPidInfo->audio = sld->element[i].elementary_PID; lanCode = sld->element[i].ISO639_language_code; dprint(3, " [%d] sld audio pid %d (0x%x), MPEG%d audio, Lang code (%c%c%c) %s\n", i, sld->element[i].elementary_PID, sld->element[i].elementary_PID, sld->element[i].stream_type == StreamType_MPEG1Audio ? 1 : 2, (lanCode>>16) & 0xff, (lanCode>>8) & 0xff, lanCode & 0xff, bAudioPidFound ? "ignored" : ""); bAudioPidFound = TRUE; } else { dprint(3, " [%d] !! unknown stream type: 0x%x\n", i, sld->element[i].stream_type); } } return statusOK; } // PidInfo 는 caller에서 할당된 메모리 영역의 포인터이고, // pXcnd 는 이 함수 내부에서 새로 동적으로 할당된 descriptor structure pointer 이다. // // 주의: // 발견되지 않는 stream type에 대해서는 pid update를 하지 않고 있다. // 따라서 caller에서 초기값을 먼저 할당한 상태에서 불러야 한다. (ex: 0) // STATUS Dmc_GetInfoFromVctDesc(UINT8 *desc, int desc_len, PidInfo *pPidInfo, extendedChannelNameDescriptorPtr_t *pXcnd) { UINT8* ptr; serviceLocationDescriptorPtr_t sld = NULL; //extendedChannelNameDescriptorPtr_t xcnd; // cafrii 050315 delete unused var. STATUS rval; int this_descriptor_len; int offset; dprint(2, "Dmc_GetInfoFromVctDesc:\n"); if (desc == NULL || desc_len == 0) { dprint(0, "!! GetInfoFromVctDesc: invalid desc\n"); return statusPSIPError; } if (pPidInfo) pPidInfo->bValid = FALSE; if (pXcnd) *pXcnd = NULL; ptr = desc; offset = 0; // 지금까지 parsing된 데이터 길이. while (TRUE) { // ptr[0] : descriptor tag. // ptr[1] : descriptor length. if (offset + 2 >= desc_len) // we need at least two bytes more to parse descriptor. break; this_descriptor_len = ptr[1] + 2; // include 'tag' and 'length' // cafrii 060707, remove unproper 'unsupported desc..' message if (ptr[0] == 0xA0) // extended channel name descriptor tag. { if (pXcnd) { rval = (STATUS)ParseExtendedChannelNameDescriptor (ptr, pXcnd); //if (rval != noError) if (IsError(rval)) // cafrii 050315 change { dprint(0, "!! parse ExtChNameDesc error %d\n", rval); *pXcnd = NULL; // cafrii 050315 add } else { dprint(2, " found ext.ch.name desc\n"); // descriptor는 여기서 free 시키지 않고, caller 가 free 시키도록 한다. } } } else if (ptr[0] == 0xA1) // SLD descriptor tag. { if (pPidInfo) { rval = (STATUS)ParseServiceLocationDescriptor(ptr, &sld); //if (rval != noError) if (IsError(rval)) // cafrii 050315 change { dprint(0, "!! parse sld error %d\n", rval); sld = NULL; // cafrii 050315 add } else { dprint(2, " found sld, pcr pid %d, %d streams\n", sld->PCR_PID, sld->number_elements); Dmc_GetPidInfoFromSLD(sld, pPidInfo); if (sld) FreeMpegDescriptor(sld); // cafrii 030716 sld = NULL; pPidInfo->bValid = TRUE; } } } else { // cafrii 030716, print more detail information.. // dprint(3, " unsupported descriptor, '%s' 0x%02x, len %d, skip!\n", Dmc_PsipDescriptorString(ptr[0]), ptr[0], this_descriptor_len); if (dprintable(3)) memdump(ptr, min(this_descriptor_len, desc_len - offset), 0); } // goto next descriptor. ptr += this_descriptor_len; offset += this_descriptor_len; } // while return statusOK; } // cafrii 060710 add // driver의 함수에 의존하지 않고 MW에서 별도로 제공한다. // GetElementaryPIDs 대신 사용. // STATUS Dmc_GetPidInfoFromPMT(MPEG_PMT *pmt, PidInfo *pPidInfo) { int i; if (pmt == NULL || pPidInfo == NULL) return statusInvalidArgument; memset(pPidInfo, 0, sizeof(PidInfo)); pPidInfo->pcr = IS_VALID_PCR_PID(pmt->PCR_PID) ? pmt->PCR_PID : 0; for (i=0; inumStreams; i++) { if (pmt->streams[i].stream_type == StreamType_MPEG2Video && pPidInfo->video == 0) { if (!IS_VALID_PES_PID(pmt->streams[i].elementary_PID)) { dprint(0, "!! pmt video pes pid %x invalid\n", pmt->streams[i].elementary_PID); continue; } pPidInfo->video = pmt->streams[i].elementary_PID; } // todo // StreamType_MPEG1Video 지원은 flag에 따라서.. if (pmt->streams[i].stream_type == StreamType_AC3Audio && pPidInfo->audio == 0) { if (!IS_VALID_PES_PID(pmt->streams[i].elementary_PID)) { dprint(0, "!! pmt audio pes pid %x invalid\n", pmt->streams[i].elementary_PID); continue; } pPidInfo->audio = pmt->streams[i].elementary_PID; } // todo // StreamType_MPEG1Audio, StreamType_MPEG2Audio, // StreamType_AACAudio 지원은 flag에 따라서.. } pPidInfo->bValid = TRUE; return statusOK; } STATUS Dmc_DecidePidInfo3(MPEG_PMT *pmt, xvctChannelPtr_t channel, PidInfo *pPidInfo, UINT32 flag) { if (channel == NULL) return Dmc_DecidePidInfo(pmt, NULL, pPidInfo, flag); else return Dmc_DecidePidInfo2(pmt, channel->descriptors, channel->descriptor_length, pPidInfo, flag); } STATUS Dmc_DecidePidInfo2(MPEG_PMT *pmt, UINT8 *descs, int descs_len, PidInfo *pPidInfo, UINT32 flag) { DHL_RESULT err = DHL_OK; STATUS status; serviceLocationDescriptorPtr_t sld = NULL; if (descs && descs_len > 0) { UINT8 *sld_desc; err = GetMpegDescriptor(descs, descs_len, service_location_tag, 0, &sld_desc); // 0xA1, SLD descriptor tag. if (!err) err = ParseServiceLocationDescriptor(sld_desc, &sld); } status = Dmc_DecidePidInfo(pmt, err ? NULL : sld, pPidInfo, flag); if (sld) FreeMpegDescriptor(sld); return status; } // cafrii 061114 add support multiple audio format // #define StreamTypeToAudioType(t) ( \ (t) == StreamType_AC3Audio ? eDHL_AUDIO_TYPE_AC3 : \ (t) == StreamType_MPEG2Audio ? eDHL_AUDIO_TYPE_MPEG_2 : \ (t) == StreamType_AACAudioADTS ? eDHL_AUDIO_TYPE_AAC_ADTS : \ (t) == StreamType_AACAudioLATM ? eDHL_AUDIO_TYPE_AAC_LATM : \ eDHL_AUDIO_TYPE_UNKNOWN ) #define StreamTypeToVideoType(t) ( \ (t) == StreamType_MPEG2Video ? eDHL_VIDEO_TYPE_MPEG2 : \ (t) == StreamType_DC2Video ? eDHL_VIDEO_TYPE_MPEG2 : \ (t) == StreamType_MPEG1Video ? eDHL_VIDEO_TYPE_MPEG1 : \ (t) == StreamType_H264 ? eDHL_VIDEO_TYPE_H264 : \ eDHL_VIDEO_TYPE_UNKNOWN ) // // PSIP (VCT SLD)와 PMT 정보를 이용하여 PID를 결정한다. // // [IN] pmt, sld, flag // [OUT] pPidInfo // // 경우에 따라서 vctChannelPtr_t, 또는 sld 형태로 받는게 나을 수도 있음. // STATUS Dmc_DecidePidInfo(MPEG_PMT *pmt, serviceLocationDescriptorPtr_t sld, PidInfo *pPidInfo, UINT32 flag) { #define MAX_PID_LIST 20 char buf[100]; UINT16 list_p[MAX_PID_LIST]; // candidate pid list from PMT UINT16 list_v[MAX_PID_LIST]; // candidate pid list from VCT int n_list_p, n_list_v; // number of candidate for each list int i, ip, iv; PidInfo pi; BOOL bVerbose = (flag & DMC_DPIF_SILENT) ? 0 : 1; tDHL_VideoCodingType vidType; tDHL_AudioCodingType audType; UINT32 vidCap, audCap; DHL_AV_Query(eDHL_AV_QUERY_VIDEO_CAP, &vidCap); DHL_AV_Query(eDHL_AV_QUERY_AUDIO_CAP, &audCap); if (bVerbose) //dprint(1, "%s: \n", __FUNCTION__); memset(&pi, 0, sizeof(pi)); // cafrii 060728 add // -------- VIDEO ------------ // Video pid from PMT memset(list_p, 0, sizeof(list_p)); n_list_p = 0; for (i=0; pmt && inumStreams; i++) { vidType = StreamTypeToVideoType(pmt->streams[i].stream_type); if (vidType == eDHL_VIDEO_TYPE_UNKNOWN) continue; if ((vidCap & (1<streams[i].elementary_PID)) { //dprint(0, "!! pmt video pes pid %x invalid\n", pmt->streams[i].elementary_PID); continue; } if (n_list_p >= MAX_PID_LIST) { //dprint(0, "!! pmt video pid too many\n"); break; } list_p[n_list_p++] = pmt->streams[i].elementary_PID; } // Video pid from VCT memset(list_v, 0, sizeof(list_v)); n_list_v = 0; for (i=0; sld && inumber_elements; i++) { vidType = StreamTypeToVideoType(sld->element[i].stream_type); if (vidType == eDHL_VIDEO_TYPE_UNKNOWN) continue; if ((vidCap & (1<element[i].elementary_PID)) { //dprint(0, "!! vct video pes pid %x invalid\n", sld->element[i].elementary_PID); continue; } if (n_list_v >= MAX_PID_LIST) { //dprint(0, "!! vct video pid too many\n"); break; } list_v[n_list_v++] = sld->element[i].elementary_PID; } // decide video pid using list of pmt and vct if ((list_v[0] != list_p[0] || dprintable(3)) && bVerbose) { if (list_v[0] != list_p[0] && n_list_p*n_list_v) // 일치하지 않는 경우. // 만약 pmt나 vct 중 하나만 지정한 경우엔 경고 메시지 출력하지 말자. dprint(0, "!! Warning: pmt/vct video pid mismatch\n"); buf[0] = 0; //sprintf(buf, "vpid pmt(%d):", n_list_p); //for (i=0; i 0) // choose from list_pmt pi.video = list_p[0]; // it also may be zero else if (n_list_v > 0) // choose from list_vct pi.video = list_v[0]; // it also may be zero } // video pid로부터 video type 추출. if (pi.video) { pi.videoType = eDHL_VIDEO_TYPE_UNKNOWN; for (i=0; pmt && inumStreams && pi.videoType==eDHL_VIDEO_TYPE_UNKNOWN; i++) { if (pmt->streams[i].elementary_PID == pi.video) pi.videoType = StreamTypeToVideoType(pmt->streams[i].stream_type); } for (i=0; sld && inumber_elements && pi.videoType==eDHL_VIDEO_TYPE_UNKNOWN; i++) { if (sld->element[i].elementary_PID == pi.video) pi.videoType = StreamTypeToVideoType(sld->element[i].stream_type); } DHL_ASSERT(pi.videoType != eDHL_VIDEO_TYPE_UNKNOWN, ""); } // -------- AUDIO ------------ // Audio pid from PMT memset(list_p, 0, sizeof(list_p)); n_list_p = 0; for (i=0; pmt && inumStreams; i++) { audType = StreamTypeToAudioType(pmt->streams[i].stream_type); if (audType == eDHL_AUDIO_TYPE_UNKNOWN) continue; if ((audCap & (1<streams[i].elementary_PID)) { dprint(0, "!! pmt audio pes pid %x invalid\n", pmt->streams[i].elementary_PID); continue; } if (n_list_p >= MAX_PID_LIST) { dprint(0, "!! pmt audio pid too many\n"); break; } list_p[n_list_p++] = pmt->streams[i].elementary_PID; } // Audio pid from VCT memset(list_v, 0, sizeof(list_v)); n_list_v = 0; for (i=0; sld && inumber_elements; i++) { audType = StreamTypeToAudioType(sld->element[i].stream_type); if (audType == eDHL_AUDIO_TYPE_UNKNOWN) continue; if ((audCap & (1<element[i].elementary_PID)) { dprint(0, "!! vct video pes pid %x invalid\n", sld->element[i].elementary_PID); continue; } if (n_list_v >= MAX_PID_LIST) { dprint(0, "!! vct video pid too many\n"); break; } list_v[n_list_v++] = sld->element[i].elementary_PID; } // decide Audio pid if ((list_v[0] != list_p[0] || dprintable(3)) && bVerbose) { if (list_v[0] != list_p[0] && pmt && sld) // 일치하지 않는 경우. // 만약 pmt나 vct 중 하나만 지정한 경우엔 경고 메시지 출력하지 말자. dprint(0, "!! Warning: pmt/vct audio pid mismatch\n"); buf[0] = 0; //sprintf(buf, "apid pmt(%d):", n_list_p); //for (i=0; i 0) // choose from list_pmt pi.audio = list_p[0]; // it also may be zero if (n_list_v > 0) // choose from list_vct pi.audio = list_v[0]; // it also may be zero } // audio pid로부터 audio type 추출. if (pi.audio) { pi.audioType = eDHL_AUDIO_TYPE_UNKNOWN; for (i=0; pmt && inumStreams && pi.audioType==eDHL_AUDIO_TYPE_UNKNOWN; i++) { if (pmt->streams[i].elementary_PID == pi.audio) pi.audioType = StreamTypeToAudioType(pmt->streams[i].stream_type); } for (i=0; sld && inumber_elements && pi.audioType==eDHL_AUDIO_TYPE_UNKNOWN; i++) { if (sld->element[i].elementary_PID == pi.audio) pi.audioType = StreamTypeToAudioType(sld->element[i].stream_type); } DHL_ASSERT(pi.audioType != eDHL_AUDIO_TYPE_UNKNOWN, ""); } // -------- check ------------ if (pi.video == 0 && pi.audio == 0){ dprint(0, "!! Warning: no valid pid\n"); return statusNotFound; } // -------- PCR ------------ pi.pcr = 0; if (1) { int pmt_pcr, sld_pcr; pmt_pcr = pmt ? pmt->PCR_PID : 0; sld_pcr = sld ? sld->PCR_PID : 0; if (pmt_pcr == sld_pcr && IS_VALID_PCR_PID(pmt_pcr)) pi.pcr = pmt_pcr; else { if (bVerbose && pmt && sld) // 만약 pmt나 vct 중 하나만 지정한 경우엔 경고 메시지 출력하지 말자. dprint(0, "!! Warning: pcr invalid, pmt %x, vct %x\n", pmt_pcr, sld_pcr); if (IS_VALID_PCR_PID(pmt_pcr)) pi.pcr = pmt_pcr; else if (IS_VALID_PCR_PID(sld_pcr)) pi.pcr = sld_pcr; else { if (IS_VALID_PCR_PID(pi.video)) pi.pcr = pi.video; else if (IS_VALID_PCR_PID(pi.audio)) pi.pcr = pi.audio; } } } pi.bValid = TRUE; if (pPidInfo) *pPidInfo = pi; return statusOK; } #if COMMENT _______Timing_Util________(){} #endif // Dmc_CheckIfFormatChanged // 두 sequence header를 비교 분석하여 새로운 seq header에서 display timing이 // 바뀌었는지 체크한다. // // 변경되었으면 TRUE를 리턴한다. // // 불리는 곳: StartDigital (가장 마지막의 seqHdr와 비교) // HandleImportantChange (video source가 Running change된 경우임) // BOOL Dmc_CheckIfFormatChanged(tDHL_VideoSeqHdr *newsh, tDHL_VideoSeqHdr *oldsh) { #if 0 // reference only. member of tDHL_VideoSeqHdr UINT32 generationNumber; /* Increments each time it changes */ UINT16 horizontal_size; /* incorporates horizontal_size_value and extension */ UINT16 vertical_size; /* incorporates vettical_size_value and extension */ MPEG_ASPECT_RATIO aspect_ratio_information; MPEG_FRAME_RATE frame_rate_code; FLOAT frame_rate; /* incorporates frame_rate_code, extension_n,_d */ UINT32 bit_rate; /* bit_rate_extension is added */ UINT32 vbv_buffer_size; /* Specified in bytes. (vbv_buffer_size_extension,value * 16/8 * 1024 */ BOOLEAN constrained_parameter_flag; BOOLEAN MPEG2; /* True if sequece_extension is present */ UINT8 profile_and_level_indication; BOOLEAN progressive_sequence; MPEG_CHROMA_FORMAT chroma_format; BOOLEAN low_delay; #endif if (newsh == NULL) return FALSE; // do not change. current seq hdr is invalid. if (oldsh == NULL) return TRUE; // newly generated. so changed!! // cafrii // 수직 해상도 1080과 1088은 같은 해상도로 간주하도록 변경. // if (newsh->horizontal_size != oldsh->horizontal_size) return TRUE; // now we treat vertical line 1080 and 1088 as same format. if (newsh->vertical_size == 1080 || newsh->vertical_size == 1088) { if (oldsh->vertical_size != 1080 && oldsh->vertical_size != 1088) return TRUE; } else if (newsh->vertical_size != oldsh->vertical_size) return TRUE; if (newsh->aspect_ratio_information != oldsh->aspect_ratio_information || newsh->frame_rate_code != oldsh->frame_rate_code || newsh->progressive_sequence != oldsh->progressive_sequence) return TRUE; return FALSE; // no change in resolution/timing. } // Dmc_WhichATSCFormat // Sarnoff Stream ATSC_01 ~ ATSC_36 중에서 어떤 것에 해당되는지 리턴. // 정확히 같은게 없으면 0을 리턴한다. // int Dmc_WhichATSCFormat(tDHL_VideoSeqHdr *seq) { if (seq->horizontal_size == 1920 && (seq->vertical_size == 1080 || seq->vertical_size == 1088)) { if (seq->progressive_sequence) { return seq->frame_rate_code == FRAMERATE_23_976 ? 1 : seq->frame_rate_code == FRAMERATE_24 ? 2 : seq->frame_rate_code == FRAMERATE_29_97 ? 3 : seq->frame_rate_code == FRAMERATE_30 ? 4 : 0; } else { return seq->frame_rate_code == FRAMERATE_29_97 ? 5 : seq->frame_rate_code == FRAMERATE_30 ? 6 : 0; } } else if (seq->horizontal_size == 1280 && seq->vertical_size == 720) { return seq->frame_rate_code == FRAMERATE_23_976 ? 7 : seq->frame_rate_code == FRAMERATE_24 ? 8 : seq->frame_rate_code == FRAMERATE_29_97 ? 9 : seq->frame_rate_code == FRAMERATE_30 ? 10 : seq->frame_rate_code == FRAMERATE_59_94 ? 11 : seq->frame_rate_code == FRAMERATE_60 ? 12 : 0; } else if (seq->horizontal_size == 704 && seq->vertical_size == 480) { if (DHL_AV_IsWideoFormat(seq)) { // 16:9 if (seq->progressive_sequence) { return seq->frame_rate_code == FRAMERATE_23_976 ? 13 : seq->frame_rate_code == FRAMERATE_24 ? 14 : seq->frame_rate_code == FRAMERATE_29_97 ? 15 : seq->frame_rate_code == FRAMERATE_30 ? 16 : seq->frame_rate_code == FRAMERATE_59_94 ? 17 : seq->frame_rate_code == FRAMERATE_60 ? 18 : 0; } else { return seq->frame_rate_code == FRAMERATE_29_97 ? 19 : seq->frame_rate_code == FRAMERATE_30 ? 20 : 0; } } else { // 4:3 if (seq->progressive_sequence) { return seq->frame_rate_code == FRAMERATE_23_976 ? 21 : seq->frame_rate_code == FRAMERATE_24 ? 22 : seq->frame_rate_code == FRAMERATE_29_97 ? 23 : seq->frame_rate_code == FRAMERATE_30 ? 24 : seq->frame_rate_code == FRAMERATE_59_94 ? 25 : seq->frame_rate_code == FRAMERATE_60 ? 26 : 0; } else { return seq->frame_rate_code == FRAMERATE_29_97 ? 27 : seq->frame_rate_code == FRAMERATE_30 ? 28 : 0; } } } else if (seq->horizontal_size == 640 && seq->vertical_size == 480) { if (seq->progressive_sequence) { return seq->frame_rate_code == FRAMERATE_23_976 ? 29 : seq->frame_rate_code == FRAMERATE_24 ? 30 : seq->frame_rate_code == FRAMERATE_29_97 ? 31 : seq->frame_rate_code == FRAMERATE_30 ? 32 : seq->frame_rate_code == FRAMERATE_59_94 ? 33 : seq->frame_rate_code == FRAMERATE_60 ? 34 : 0; } else { return seq->frame_rate_code == FRAMERATE_29_97 ? 35 : seq->frame_rate_code == FRAMERATE_30 ? 36 : 0; } } return 0; } #if COMMENT ________(){} #endif #if DMW_REGISTER_DEBUG_SYMBOL static DHL_SymbolTable symbols[] = { }; #endif void RegisterChannelUtilSymbols(void) { #if DMW_REGISTER_DEBUG_SYMBOL DHL_DBG_RegisterSymbols(symbols, DHL_NUMSYMBOLS(symbols)); #endif }