queue.bak

基于ARM7处理器的中断与串口在ucos下切换的演示程序

** 修改人:
** 日　期:
**------------------------------------------------------------------------------------------------------
********************************************************************************************************/
#ifndef EN_QUEUE_NDATA
#define EN_QUEUE_NDATA    0
#endif

#if EN_QUEUE_NDATA > 0

        uint16 QueueNData(void *Buf)
{
    uint16 temp;
    
    temp = 0;                                                   /* 队列无效返回0 */
    if (Buf != NULL)
    {
        OS_ENTER_CRITICAL();
        temp = ((DataQueue *)Buf)->NData;
        OS_EXIT_CRITICAL();
    }
    return temp;
}

#endif

/*********************************************************************************************************
** 函数名称: QueueSize
** 功能描述: 取得队列总容量
** 输　入: Buf:指向队列的指针
** 输　出: 队列总容量
** 全局变量: 无
** 调用模块: OS_ENTER_CRITICAL,OS_EXIT_CRITICAL
**
** 作　者: 陈明计
** 日　期: 2003年7月2日
**-------------------------------------------------------------------------------------------------------
** 修改人:
** 日　期:
**------------------------------------------------------------------------------------------------------
********************************************************************************************************/
#ifndef EN_QUEUE_SIZE
#define EN_QUEUE_SIZE    0
#endif

#if EN_QUEUE_SIZE > 0

        uint16 QueueSize(void *Buf)
{
    uint16 temp;
    
    temp = 0;                                                   /* 队列无效返回0 */
    if (Buf != NULL)
    {
        OS_ENTER_CRITICAL();
        temp = ((DataQueue *)Buf)->MaxData;
        OS_EXIT_CRITICAL();
    }
    return temp;
}

#endif

/*********************************************************************************************************
** 函数名称: OSQFlush
** 功能描述: 清空队列
** 输　入: Buf:指向队列的指针
** 输　出: 无
** 全局变量: 无
** 调用模块: OS_ENTER_CRITICAL,OS_EXIT_CRITICAL
**
** 作　者: 陈明计
** 日　期: 2003年7月2日
**-------------------------------------------------------------------------------------------------------
** 修改人:
** 日　期:
**------------------------------------------------------------------------------------------------------
********************************************************************************************************/
#ifndef EN_QUEUE_FLUSH
#define EN_QUEUE_FLUSH    0
#endif

#if EN_QUEUE_FLUSH > 0

        void QueueFlush(void *Buf)
{
    DataQueue *Queue;
    
    if (Buf != NULL)                                                /* 队列是否有效 */
    {                                                               /* 有效         */
        Queue = (DataQueue *)Buf;
        OS_ENTER_CRITICAL();
        Queue->Out = Queue->Buf;
        Queue->In = Queue->Buf;
        Queue->NData = 0;                                           /* 数据数目为0 */
        OS_EXIT_CRITICAL();
    }
}

#endif

int QueueWriteBlock(void * Buf, QUEUE_DATA_TYPE * Data, int WriteDataLen, BOOLEAN LessWrite)
{
    uint8 err;
    DataQueue *Queue;
	int i;

    err = NOT_OK;
    if (Buf != NULL)                                                    /* 队列是否有效 */
    {
        Queue = (DataQueue *)Buf;
        
        OS_ENTER_CRITICAL();
        
        if ((Queue->NData + WriteDataLen)<= Queue->MaxData)                              /* 队列是否满  */
        {                                                               /* 不满        */
            i = 0;
			while (i < WriteDataLen)
            {
                Queue->In[0] = *(Data+i);
				i++;
				Queue->In++;
				if (Queue->In >= Queue->End)
                {
                     Queue->In = Queue->Buf;
                }
			}
			Queue->NData = Queue->NData + WriteDataLen;
			err = WriteDataLen;
			myprintf("inmaxdata\r\n");
        }
        else if (LessWrite)
        {                                                               /* 满           */
            i = 0;
			while (i < (Queue->MaxData - Queue->NData))
			{
                Queue->In[0] = *(Data+i);
				i++;
				Queue->In++;
			    if (Queue->In >= Queue->End)
                {
                     Queue->In = Queue->Buf;
                }
			}
			Queue->NData = Queue->MaxData;
			err = Queue->MaxData - Queue->NData;
			myprintf("inlessdata\r\n");
        }
		else
		{
            err = OS_Q_FULL;
            if (Queue->WriteFull != NULL)                               /* 调用用户处理函数 */
            {
                err = Queue->WriteFull(Queue, Data, Q_WRITE_MODE);
            }
			myprintf("inerrfull\r\n");
		}
        OS_EXIT_CRITICAL();
    }
    return err;

}
int QueueReadBlock(QUEUE_DATA_TYPE * Ret, void * Buf, int ReadDataLen, BOOLEAN LessRead)
{
    uint8 err;
    DataQueue *Queue;
	int i;

    err = NOT_OK;
    if (Buf != NULL)                                            /* 队列是否有效 */
    {                                                           /* 有效 */
        Queue = (DataQueue *)Buf;
        
        OS_ENTER_CRITICAL();
        
        if (Queue->NData >= ReadDataLen)                                   /* 队列是否为空 */
        {                                                       /* 不空         */
            i = 0;
			while (i < ReadDataLen)
            {
                *(Ret + i) = Queue->Out[0];                               /* 数据出队     */
                Queue->Out++;                                       /* 调整出队指针 */
                if (Queue->Out >= Queue->End)
                {
                    Queue->Out = Queue->Buf;
                }
				i++;
			}
            Queue->NData = Queue->NData - ReadDataLen;                                     /* 数据减少      */
            err = ReadDataLen;
        }
		else if (LessRead)
		{
            i = 0;
			while (i < Queue->NData)
            {
                *(Ret + i) = Queue->Out[0];                               /* 数据出队     */
                Queue->Out++;                                       /* 调整出队指针 */
                if (Queue->Out >= Queue->End)
                {
                    Queue->Out = Queue->Buf;
                }
				i++;
			}
            Queue->NData = 0;                                     /* 数据减少      */
            err = Queue->NData;
		}
        else
        {                                                       /* 空              */
            err = QUEUE_EMPTY;
            if (Queue->ReadEmpty != NULL)                       /* 调用用户处理函数 */
            {
                err = Queue->ReadEmpty(Ret, Queue);
            }
        }
        OS_EXIT_CRITICAL();
    }
    return err;
}

/*********************************************************************************************************
** 函数名称 ：IRQ_Eint0()
** 函数功能 ：外部中断0 EINT0服务程序口。
** 入口参数 ：无。
** 出口擦数 ：无。
*********************************************************************************************************
*/

void Eint0_Exception(void)
{
	uint32 i;
	uint8  tempchar;
	DataQueue *Queue;
	
	        Queue = (DataQueue *)RcvSendBuf;

	EXTINT = 0x01;
	tempchar = ((IO0PIN & 0x00600000) >> 21)|  //P0.22 P0.21
              ((IO1PIN & 0x00040000) >> 16)|  //P1.18
              ((IO0PIN & 0x0E000000) >> 22)|  //P0.27 P0.26 P0.25
              ((IO1PIN & 0x00020000) >> 11)|  //P1.17
              ((IO0PIN & 0x10000000) >> 21);   //P0.28

	//QueueWrite((void *)RcvSendBuf, tempchar);

	    //if (Queue->NData < Queue->MaxData)                              /* 队列是否满  */
        //{                                                               /* 不满        */
            Queue->In[0] = tempchar;                                        /* 数据入队    */
            Queue->In++;                                                /* 调整入队指针*/
            if (Queue->In >= Queue->End)
            {
                Queue->In = Queue->Buf;
            }
            Queue->NData++;                                             /* 数据增加    */
        //}
	
	
	VICVectAddr = 0; 
	
	/* 	等待外部中断信号恢复为高电平
	 	若信号保持为低电平，中断标志会一直置位。*/
	//while ((EXTINT & 0x01) != 0)
	//{
		EXTINT = 0x01;				/* 清除EINT0中断标志		*/
	//}
	
	VICVectAddr = 0;				/* 向量中断结束				*/
}

/*********************************************************************************************************
**                            End Of File
********************************************************************************************************/