queue.c

来自「周立功开发板SmartArm2200 I2C中断方式读写板上EEPROM CAT」· C语言 代码 · 共 76 行

/*****************************************************************************************
* 模块名称: 串口数据帧缓冲队列
* 模块描述: 串口接收的数据帧缓冲区
* 创建人  : hlb
* 创建日期: 2007-6-11
******************************************************************************************
* 修改人  :
* 修改日期:
*****************************************************************************************/
#define __QUEUE
#include "public.h"
#include "queue.h"
#include <string.h>
/*****************************************************************************************
* 函数名称: void Queue_Init(void)
* 函数描述: 队列初始化
*****************************************************************************************/
void Queue_Init(TQueue *que)
{
  que->S_Idx = 0;
  que->E_Idx = 0;
  que->size = QUEUE_SIZE;
  que->count = 0;
}
/*****************************************************************************************
* 函数名称: U32 Queue_Size(void)
* 函数描述: 取队列的宽度
*****************************************************************************************/
U32 Queue_Size(TQueue *que)
{
  return que->size;
}
/*****************************************************************************************
* 函数名称: unsigned char Queue_Count(void)
* 函数描述: 取队列的宽度
*****************************************************************************************/
U32 Queue_Count(TQueue *que)
{
  return (que->count);
}
/*****************************************************************************************
* 函数名称: char * Queue_Get(void)
* 函数描述: 取出一帧数据
*****************************************************************************************/
U8 * Queue_Get(TQueue *que)
{
  U8 *p = 0;
  if (que->count > 0)
  {
    p = (U8 *)que->Data[que->S_Idx];
    que->S_Idx++;
    if(que->S_Idx > que->size - 1) que->S_Idx = 0;
    que->count--;
  }
  else
  {
    p = 0;
  }

  return p;
}
/*****************************************************************************************
* 函数名称: void Queue_Put(char *p)
* 函数描述: x写一帧数据到队列
*****************************************************************************************/
void Queue_Put(TQueue *que, U8 *p, U32 Len)
{
  if(que->count < que->size)
  {
    memcpy((void *)que->Data[que->E_Idx], (void *)p, Len);
    que->E_Idx++;
    if(que->E_Idx > que->size - 1) que->E_Idx = 0;
    que->count++;
  }
}