#include "cc_config.h"
#include "cc_type.h"
#include "cc_def.h"
#include "cc_private.h"


/*config*/

#define MAX_NUM_USER_MSGQ (CC_NUM_PIC_USER_Q+8)
	//user message°¡ Àֱ⠶§¹®¿¡ 8À» ´õ Ãß°¡ÇÔ


/* variables */

static struct {
	
	tDCCDDI_MSGQ p_user_msgq_id;
	tDCCDDI_SEM p_sync_mtx_id;
	tDCCDDI_SEM p_sync_sem_id;
	
	int num_msgq;
	
	struct {
		UINT32 duration; //ms ´ÜÀ§
		UINT32 start_ms;
		UINT32 prev_ms;
		UINT32 opt;
	} timer_list[MAX_NUM_TIMER];
	
	BOOL buser_msg_on;
	BOOL brst_ready;
	
} p_main_attr;



#define ATTR(i) p_main_attr.i

static BOOL b_cc_main_inited=FALSE;

#if 0
__Local_Func__() {}
#endif


static void p_proc_user_data(tDCC_PicUDRaw *praw_pud)
{
	tDCC_CMD send_msg;
	
	if(!ATTR(p_user_msgq_id) || !ATTR(buser_msg_on)) return;
		
	send_msg.cmd=eCMD_USER_DATA;
	send_msg.opt=0;
	send_msg.param1=(UINT32)praw_pud;
	send_msg.param2=0;
	
	CCPRINT("send_ud", "sending user data, pic_type: %d, pts : %ud, size: %d\n", 
					praw_pud->pic_type, 
					praw_pud->data,
					praw_pud->size);
	
	if(DCCExec_IsCurDLY()) {
		
		//pud °Ë»öÇؼ­ DLC¸¦ ã¾Æ¾ß ÇÔ.
		UINT8 *buf=praw_pud->data;
		int i;
		BOOL bdlc_send=FALSE;
		
		for(i=0; i<(buf[5]&0x1f); i++) {
		
			if(7+i*3+2>=praw_pud->size) {
				break;
			}
			
			if((buf[7+i*3]&0x3)==0x3) {
				
				if(buf[7+i*3+2]==0x8E) { //DLC
					DCCExec_ProcessMsg(eCMD_DLC, 0, 0, 0); //delay cancelÀ» ³¯¸².
					bdlc_send=TRUE;
				}
				else if(buf[7+i*3+2]==0x8F) { //RST
					DCCExec_ProcessMsg(eCMD_DLC, 0, 0, 0); //delay cancelÀ» ³¯¸².
					bdlc_send=TRUE;
				}
			}
			else if((buf[7+i*3]&0x3)==0x2) {
				
				if(buf[7+i*3+1]==0x8E || buf[7+i*3+2]==0x8E) { //DLC
					DCCExec_ProcessMsg(eCMD_DLC, 0, 0, 0); //delay cancelÀ» ³¯¸².
					bdlc_send=TRUE;
				}
				else if(buf[7+i*3+1]==0x8F || buf[7+i*3+2]==0x8F) { //RST
					DCCExec_ProcessMsg(eCMD_DLC, 0, 0, 0); //delay cancelÀ» ³¯¸².
					bdlc_send=TRUE;
				}
			}
		}
		
		if(!bdlc_send && ATTR(num_msgq)>=CC_NUM_PIC_USER_Q*2/3) {
			DCCExec_ProcessMsg(eCMD_DLC, 0, 0, 0); //delay cancelÀ» ³¯¸².
		}
		
	}
	
	DCCDDI_SendMessage(ATTR(p_user_msgq_id), &send_msg, sizeof(send_msg));
	ATTR(num_msgq)++;
	
}


#if 0
__Task__() {}
#endif


static void p_cc_task(UINT32 arg)
{
	int ret;
	int rcv_len;
	int i;
	
	tDCC_PicUDRaw *pic_ud_raw=NULL, *pic_ud_buf=NULL;
		//pic_ud_buf´Â reorderingÀ» À§ÇØ ÇÊ¿äÇÔ.
	tDCC_PicUD pic_ud;
	tDCC_CMD user_msg;
	
	while(1) 
	{

		//±ú¾î³¯ ½Ã°¢ °è»ê
		int min_ms=0x7fffffff;
//		int min_id=MAX_NUM_TIMER;
		//±ú¾î³¯ ½Ã°£ °è»ê
		for(i=0; i<MAX_NUM_TIMER; i++) {
			if(ATTR(timer_list)[i].duration==TIMER_NOUSE) continue;
			
			if(ATTR(timer_list)[i].prev_ms+ATTR(timer_list)[i].duration<min_ms) {
				min_ms=ATTR(timer_list)[i].prev_ms+ATTR(timer_list)[i].duration;
//				min_id=i;
			}
		}
#if 1//BKTEST
		DHL_OS_Delay(100);		
#endif
		if(DCCExec_IsCurDLY()) {
			ret=-1;
			
			DCCDDI_Delay(10);
		} else if(min_ms==0x7fffffff)
			ret=DCCDDI_ReceiveMessage(ATTR(p_user_msgq_id), &user_msg, sizeof(user_msg), &rcv_len);
		else {
			min_ms-=DCCDDI_GetCurMs();
			if(min_ms<0) min_ms=0;
			ret=DCCDDI_ReceiveMessage_Wait(ATTR(p_user_msgq_id), &user_msg, sizeof(user_msg), &rcv_len, min_ms);
		}
		
		if((ret==0) && b_cc_main_inited) { //»ç¿ëÀÚ data°¡ ÀÖ´Â °æ¿ì.
			
			switch(user_msg.cmd) {
			
				case eCMD_USER_DATA :
					
					ATTR(num_msgq)--;
					
					if(ATTR(num_msgq)>=0 && ATTR(num_msgq)<CC_NUM_PIC_USER_Q) { 
						//¿¹¿Ü »óȲÀÌ ¹ß»ýÇÑ °æ¿ìÀÓ..ÀÌ °æ¿ì´Â ÃʱâÈ­.
						if(ATTR(num_msgq)<CC_NUM_PIC_USER_Q/2) 
							DCCGrp_SetScrollSpeed(CC_SCROLL_DELAY1, CC_SCROLL_SLICE1);
						else if(ATTR(num_msgq)<CC_NUM_PIC_USER_Q*2/3) 
							DCCGrp_SetScrollSpeed(CC_SCROLL_DELAY2, CC_SCROLL_SLICE2);
						else if(ATTR(num_msgq)<CC_NUM_PIC_USER_Q*3/4) 
							DCCGrp_SetScrollSpeed(CC_SCROLL_DELAY3, CC_SCROLL_SLICE3);
						else 
							DCCGrp_SetScrollSpeed(CC_SCROLL_DELAY4, CC_SCROLL_SLICE4);
					}
					
					pic_ud_raw=(tDCC_PicUDRaw *)user_msg.param1;
					//reordering ¼öÇà
					
#if 1
					CCPRINT("parse_ud", "user data coming, pic_type: %d, pts : %ud, size: %d\n", 
									pic_ud_raw->pic_type, 
									pic_ud_raw->data,
									pic_ud_raw->size);
#else					
					CCPRINT("parse_ud", "user data coming, pic_type(%d) !!\n", pic_ud_raw->pic_type);
#endif				

#if 1	// reordering ÇÊ¿äÇÑ °æ¿ì //adjust in cc ddi
					if(pic_ud_raw->pic_type==eDCC_PIC_CT_I || pic_ud_raw->pic_type==eDCC_PIC_CT_P) {
						if(pic_ud_buf) {
							//Ȥ½Ã backupÀ» ÇØ ³õÀº °ÍÀÌ ÀÖÀ¸¸é ½ÇÇàÇÔ.
							DCCFront_ParsePicUD(pic_ud_buf, &pic_ud);
							pic_ud_buf=NULL;
						}
						//backup
						pic_ud_buf=pic_ud_raw;
					}
					else {
						DCCFront_ParsePicUD(pic_ud_raw, &pic_ud);
					}
#else	// reordering ¾È ÇÏ´Â °æ¿ì 
					DCCFront_ParsePicUD(pic_ud_raw, &pic_ud);

					pic_ud_raw->isUsing = 0;
					
					
#endif
				break;
				
			
				case eCMD_SET_TIMER :
					if(user_msg.param1<MAX_NUM_TIMER) {
						CCPRINT("time", "timer set(timer id:%d, duration:%d ms)\n", user_msg.param1, user_msg.param2);
						ATTR(timer_list)[user_msg.param1].duration=user_msg.param2;
						ATTR(timer_list)[user_msg.param1].opt=user_msg.opt;
						ATTR(timer_list)[user_msg.param1].prev_ms=DCCDDI_GetCurMs();
						ATTR(timer_list)[user_msg.param1].start_ms=DCCDDI_GetCurMs();
					}
					break;
				
				case eCMD_TIMER_RESET :
					for(i=0; i<MAX_NUM_TIMER; i++) ATTR(timer_list)[i].duration=TIMER_NOUSE;
					
					break;
				
				case eCMD_USER_SET_SERVICE :
					DCCFront_SetService(user_msg.param1);
					DCCExec_ProcessMsg((tDCC_CmdSet)user_msg.cmd, user_msg.opt, user_msg.param1, user_msg.param2);
					break;
					
				case eCMD_USER_SET_FEEDING :
					DCCFront_SetFeeding608(user_msg.param1);
					break;
				
				case eCMD_SYNC :
					DCCDDI_GiveSemaphore(ATTR(p_sync_sem_id));
					break;
				
				default :
					DCCExec_ProcessMsg((tDCC_CmdSet)user_msg.cmd, user_msg.opt, user_msg.param1, user_msg.param2);
			}
		}
		
		for(i=0; i<MAX_NUM_TIMER; i++) {
			if(ATTR(timer_list)[i].duration==TIMER_NOUSE) continue;
			
			if(CC_MS_PASS(ATTR(timer_list)[i].prev_ms) > ATTR(timer_list)[i].duration) {
				DCCExec_ProcessMsg(eCMD_TIMER, 0, i, CC_MS_PASS(ATTR(timer_list)[i].start_ms));
								
				ATTR(timer_list)[i].prev_ms=DCCDDI_GetCurMs();
				
				if(ATTR(timer_list)[i].opt & eDCC_OPT_TIMER_ONESHOT) {
					ATTR(timer_list)[i].duration=TIMER_NOUSE;
				}
			}
		}
	}
	DHL_OS_SelfDeleteTask();
}


#if 0
__APIs__() {}
#endif


void DCCMain_Init()
{
	int i;
	
	if(!b_cc_main_inited) {
		
		for(i=0; i<MAX_NUM_TIMER; i++) ATTR(timer_list)[i].duration=TIMER_NOUSE;
		//ÃʱâÈ­ ÀÛ¾÷.
		ATTR(p_user_msgq_id)=DCCDDI_CreateMessageQueue("cc exec", MAX_NUM_USER_MSGQ, sizeof(tDCC_CMD));
		ATTR(p_sync_mtx_id)=DCCDDI_CreateMutexSemaphore("cc mtx");
		ATTR(p_sync_sem_id)=DCCDDI_CreateBinarySemaphore("cc sem");
		//task »ý¼º
		DCCDDI_SpawnTask((void *)p_cc_task);
		
		DCCDDI_SetUserCallback((tDCC_UserCallback)p_proc_user_data);
		
		ATTR(buser_msg_on)=TRUE;
		
		ATTR(num_msgq)=0;
		
		b_cc_main_inited=TRUE;
	}

}

void DCCMain_ResetQueue(void)
{
	tDCC_CMD user_msg;
	int rcv_len;
	
	DCCMain_UserMsgOnOff(FALSE);
	
	while(DCCDDI_ReceiveMessage_NoWait(ATTR(p_user_msgq_id), &user_msg, 
		sizeof(user_msg), &rcv_len)==0)
	{
		//Ȥ½Ã syncµµ ³¯·Á¹ö¼­ blockingÀÌ °É¸®´Â °æ¿ì°¡ ÀÖÀ» °Í °°¾Æ¼­ ¾Æ·¡ ÄÚµå Ãß°¡ÇÔ.
		if(user_msg.cmd==eCMD_SYNC)
			DCCDDI_GiveSemaphore(ATTR(p_sync_sem_id));
	}
		
	ATTR(num_msgq)=0;
		
	DCCMain_UserMsgOnOff(TRUE);
}

void DCCMain_UserMsgOnOff(BOOL bon)
{
	//user message Áß´Ü/½ÃÀÛ.
	ATTR(buser_msg_on)=bon;
}


void DCCMain_SendCmd(UINT8 cmd, UINT32 opt, UINT32 param1, UINT32 param2)
{
	tDCC_CMD send_msg;
	if(!b_cc_main_inited) return;	
	if(!ATTR(p_user_msgq_id)) return;
	
	if(!ATTR(buser_msg_on) && cmd==eCMD_USER_DATA) return;
		//msg offÀÌ°í userdata typeÀ̸é ó¸® ¾ÈÇÔ
	
	if(cmd==eCMD_SYNC) {
		opt|=eDCC_OPT_SYNC;
	}
	else {
		send_msg.cmd=cmd;
		send_msg.opt=opt;
		send_msg.param1=param1;
		send_msg.param2=param2;
	}
	
	if(opt&eDCC_OPT_SYNC) {
		
		DCCDDI_TakeSemaphore(ATTR(p_sync_mtx_id));	
		
		if(cmd!=eCMD_SYNC) {
			DCCDDI_SendMessage(ATTR(p_user_msgq_id), &send_msg, sizeof(send_msg));
			if(cmd==eCMD_USER_DATA) {
				ATTR(num_msgq)++;
			}
		}
		
		send_msg.cmd=eCMD_SYNC;
		send_msg.opt=0;
		send_msg.param1=0;
		send_msg.param2=0;
		
		DCCDDI_SendMessage(ATTR(p_user_msgq_id), &send_msg, sizeof(send_msg));
		
		DCCDDI_TakeSemaphore(ATTR(p_sync_sem_id));
		
		DCCDDI_GiveSemaphore(ATTR(p_sync_mtx_id));
	}
	else {
		DCCDDI_SendMessage(ATTR(p_user_msgq_id), &send_msg, sizeof(send_msg));
		if(cmd==eCMD_USER_DATA) {
			ATTR(num_msgq)++;
		}
	}
	
	
}


/* end of file */