#include "..\startup\def.h"
#include "..\startup\44b.h"
#include "..\ucos-ii\includes.h"

#include "isr.h"
#include "uart.h"

OS_EVENT *Uart0_Rev_mbox=NULL;                   //Uart0 receive mail box
OS_EVENT *Uart1_Rev_mbox=NULL;                   //Uart1 receive mail box

U8 Uart0_Buffer[UART0_REVBUFFER_SIZE],Uart1_Buffer[UART1_REVBUFFER_SIZE];

static U8* pUart0_rev=Uart0_Buffer,	//Uart0 接收緩沖區(qū)指針
		*pUart0_read=Uart0_Buffer;	//Uart0 讀緩沖區(qū)指針

static U8* pUart1_rev=Uart1_Buffer,	//Uart1 接收緩沖區(qū)指針
		*pUart1_read=Uart1_Buffer;	//Uart1 讀緩沖區(qū)指針

static int nRev_Uart0=1,nRev_Uart1=1;	//設(shè)定的Uart接收字符數(shù)

void irq_OSRevUart1()
{
	int nrev;

	if(!(rUTRSTAT1 & 0x1))
		return;

	//Receive data
	*pUart1_rev=RdURXH1();
	pUart1_rev++;
	if(pUart1_rev==Uart1_Buffer+UART1_REVBUFFER_SIZE)
		pUart1_rev=Uart1_Buffer;

	nrev=pUart1_rev-pUart1_read;

	if(nrev>=nRev_Uart1)
		OSMboxPost(Uart1_Rev_mbox, (void*)nrev);
}

void irq_OSRevUart0()
{
	int nrev;

	if(!(rUTRSTAT0 & 0x1))
		return;

	//Receive data
	*pUart0_rev=RdURXH0();
	pUart0_rev++;
	if(pUart0_rev==Uart0_Buffer+UART0_REVBUFFER_SIZE)
		pUart0_rev=Uart0_Buffer;

	nrev=pUart0_rev-pUart0_read;

	if(nrev>=nRev_Uart0)
		OSMboxPost(Uart0_Rev_mbox, (void*)nrev);
}

/*************************
	讀串口0的數(shù)據(jù)
	返回值,實(shí)際讀取的數(shù)據(jù)
****************************/
int OSReadUart0(U8 data[], int num, int ntimeout)
{
	int i;
	INT8U err;
	int nrev;

	nRev_Uart0=num;	//設(shè)置Uart1接收數(shù)據(jù)數(shù)

	nrev=pUart0_rev-pUart0_read;
	if(nrev<0)//循環(huán)緩沖區(qū)調(diào)整
		nrev+=UART0_REVBUFFER_SIZE;

	if(nrev<num){
		while((nrev=(int)OSMboxPend(Uart0_Rev_mbox, ntimeout,&err))<num){
			if(err==OS_TIMEOUT){
				num=nrev;
				break;
			}
		}
	}

	for(i=0;i<num;i++){
		data[i]=*pUart0_read;
		pUart0_read++;
		if(pUart0_read==Uart0_Buffer+UART0_REVBUFFER_SIZE)
			pUart0_read=Uart0_Buffer;
	}
	return nrev;
}

/*************************
	讀串口1的數(shù)據(jù)
	返回值,實(shí)際讀取的數(shù)據(jù)
****************************/
int OSReadUart1(U8 data[], int num, int ntimeout)
{
	int i;
	INT8U err;
	int nrev;

	nRev_Uart1=num;	//設(shè)置Uart1接收數(shù)據(jù)數(shù)

	nrev=pUart1_rev-pUart1_read;
	if(nrev<0)//循環(huán)緩沖區(qū)調(diào)整
		nrev+=UART1_REVBUFFER_SIZE;

	if(nrev<num){
		while((nrev=(int)OSMboxPend(Uart1_Rev_mbox, ntimeout,&err))<num){
			if(err==OS_TIMEOUT){
				num=nrev;
				break;
			}
		}
	}

	for(i=0;i<num;i++){
		data[i]=*pUart1_read;
		pUart1_read++;
		if(pUart1_read==Uart1_Buffer+UART1_REVBUFFER_SIZE)
			pUart1_read=Uart1_Buffer;
	}
	return nrev;
}

/*************************
	等待串口1的數(shù)據(jù)
****************************/
void OSWartUart1()
{
	INT8U err;
	OSMboxPend(Uart1_Rev_mbox, 0,&err);
}

/*************************
	等待串口0的數(shù)據(jù)
****************************/
void OSWartUart0()
{
	INT8U err;
	OSMboxPend(Uart0_Rev_mbox, 0,&err);
}

void OSInitUart()
{
	if(Uart0_Rev_mbox==NULL)
		Uart0_Rev_mbox=OSMboxCreate((void*)NULL);

	if(Uart1_Rev_mbox==NULL)
		Uart1_Rev_mbox=OSMboxCreate((void*)NULL);
}

/*************************
	開(kāi)啟串口0接收中斷
****************************/
void OpenUart0Rev()
{
	U32 temp;
	SetISR_Interrupt(INT_URXD0_OFFSET,irq_OSRevUart0, 0);

/*	temp=rINTMSK;
	rINTMSK=0xffffffff;

	rI_ISPC=BIT_URXD0;
	rINTMSK=(~BIT_URXD0)&temp;*/

}

/*************************
	開(kāi)啟串口1接收中斷
****************************/
void OpenUart1Rev()
{
	U32 temp;
	SetISR_Interrupt(INT_URXD1_OFFSET,irq_OSRevUart1,0);

/*	temp=rINTMSK;
	rINTMSK=0xffffffff;

	rI_ISPC=BIT_URXD1;
	rINTMSK=(~BIT_URXD1)&temp;*/
}