基于队列的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