基于队列的UART通信模块

【基于队列的UART通信模块】/********************************
基于队列的Mega8UART通信驱动程序
文件名:uart.c
编译:WinAVR-20070122
硬件:CA-M8X
时钟:外部4MHz
*******************************/
#include
#include
#include"queue.h"
#defineUART_BUF_SIZE16//发送和接收缓冲长度
HQUEUEg_SendQueue;//发送队列句柄
HQUEUEg_RecvQueue;//接收队列句柄
uint8_tg_SendBuffer[UART_BUF_SIZE];//发送缓冲
uint8_tg_RecvBuffer[UART_BUF_SIZE];//接收缓冲
//接收中断SIG_UART_RECV
ISR(USART_RXC_vect)
{
uint8_tc=UDR;
QueueInput(&g_RecvQueue,c);
}
//发送寄存器空中断
ISR(USART_UDRE_vect)
{
if(QueueGetDataCount(&g_SendQueue)>0)//如果发送缓冲队列不空
{
UDR=QueueOutput(&g_SendQueue);//发送一字节
}
else//否则关闭发送中断
{
UCSRB&=~_BV(UDRIE);//关闭数据空中断
}
}
////////////以下为本模块三个接口函数///////////////////////////
//初始化
voidUartInit(void)
{
//UART硬件初始化
UCSRB=0;
UBRRH=0;
UBRRL=25;//96004MHz
UCSRB=(1< QueueCreate(&g_SendQueue,g_SendBuffer,UART_BUF_SIZE);
QueueCreate(&g_RecvQueue,g_RecvBuffer,UART_BUF_SIZE);
}
//读接收缓冲内的数据 , buf为读取缓冲 , size为buf能接收的最大长度 , 返回实际接收的长度
uint8_tUartRecv(uint8_t*buf,uint8_tsize)
{
uint8_ti;
for(i=0;i{
if(QueueGetDataCount(&g_RecvQueue)>0)
{
cli();//以下的队列操作不可被中断
buf[i]=QueueOutput(&g_RecvQueue);
sei();//中断重新允许
}
else
{
break;
}//ifelse
}//for
returni;//返回读到的数据字节数
}
//发送数据 , buf为发送数据缓冲器 , size为要发送的长度
voidUartSend(uint8_t*buf,uint8_tsize)
{
uint8_ti;
cli();//以下的队列操作不可被中断
for(i=0;iQueueInput(&g_SendQueue,buf[i]);
sei();//中断重新允许
UCSRB|=_BV(UDRIE);//数据空中断允许
}
//////////////////////////////////////////////////////////

uart.h:
//uart.h
#ifndefUART_H
#defineUART_H
voidUartInit(void);
uint8_tUartRecv(uint8_t*buf,uint8_tsize);
voidUartSend(uint8_t*buf,uint8_tsize);
#endif
queue.c:
/********************************
队列管理模块
文件名:queue.c
编译:WinAVR-20070122
芯艺设计室2004-2007版权所有
转载请保留本注释在内的全部内容
WEB:http://www.chipart.cn
Email:changfutong@sina.com
*******************************/
#include
#include"queue.h"
//向队列插入一字节
voidQueueInput(PHQUEUEQ,uint8_tdat)
{
if(Q->data_countbuf_size)
{
Q->pBuffer[Q->in_index]=dat;//写入数据
Q->in_index=(Q->in_index+1)%(Q->buf_size);//调整入口地址
Q->data_count++;//调整数据个数(此操作不可被中断)
}
else
{
if(Q->error<255)
Q->error++;
}
}
//从队列读出一字节
uint8_tQueueOutput(PHQUEUEQ)
{
uint8_tRet=0;
if(Q->data_count>0)
{
Ret=Q->pBuffer[Q->out_index];//读数据
Q->out_index=(Q->out_index+1)%(Q->buf_size);//调整出口地址
Q->data_count--;
}
returnRet;
}
//获得队列中数据个数
uint8_tQueueGetDataCount(PHQUEUEQ)
{
returnQ->data_count;
}
//清空队列,执行时不可被中断
voidQueueClear(PHQUEUEQ)
{
Q->in_index=0;
Q->out_index=0;
Q->data_count=0;
Q->error=0;
}
//初始化一队列
voidQueueCreate(PHQUEUEQ,uint8_t*buffer,uint8_tbuf_size)
{
Q->pBuffer=buffer;
Q->buf_size=buf_size;
QueueClear(Q);
}

queue.h:

//queue.h
#ifndefQUEUE_H_
#defineQUEUE_H_
//队列数据结构
typedefstructQUEUE_S
{
uint8_tin_index;//入队地址
uint8_tout_index;//出队地址
uint8_tbuf_size;//缓冲区长度
uint8_t*pBuffer;//缓冲
volatileuint8_tdata_count;//队列内数据个数
uint8_terror;
}HQUEUE,*PHQUEUE;
voidQueueInput(PHQUEUEQ,uint8_tdat);
uint8_tQueueOutput(PHQUEUEQ);
uint8_tQueueGetDataCount(PHQUEUEQ);
voidQueueClear(PHQUEUEQ);
voidQueueCreate(PHQUEUEQ,uint8_t*buffer,uint8_tbuf_size);
#endif

    推荐阅读