一个严谨的FIFO（RING BUFF）

只看该作者 · 2023-11-28 16:32

/**
***************************************************
* @brief func_fifo_FindDelete
* @note 比较FIFO中数据
* @param fifo
*                         指向待操作的FIFO，
*       ind
*                         从FIFO的pull后面的第ind个开始
*       len
*                         比较的长度为len
*       data
*                         比较的数据
*       timeout
*                         等待busy 超时时间，单位ms
*       timeout
* @retval  FifoErr
* @data 2021.09.03
* @auth WXL
* @his    1.0.0.0    2021.09.03    WXL
*             create
***************************************************
**/
FifoErr func_fifo_Find(FifoTypeDef* fifo, INT16U ind, INT8U* data, INT16U len,  INT16U* pos)
{
FifoErr err = FIFO_EOK;
INT16U    cycle = 0;

if(FIFO_INIT_CHECK(fifo) == 0)
{
return FIFO_EINIT;
}

FIFO_SET_BUSY(fifo);
INT16U times = fifo->CntUsed - ind - len - 1;
err = FIFO_EFAILED;
while(cycle < times)
{
      if(func_fifo_CmpLower(fifo, ind+cycle, len, data) == FIFO_EOK)
      {
         err = FIFO_EOK;
         *pos = cycle;
         break;
      }
      cycle++;
}
FIFO_RESET_BUSY(fifo);

return err;
}

只看该作者 · 2023-11-28 16:32

获取FIFO的使用量，需要操作busy标志位
INT16U func_fifo_GetUsed(FifoTypeDef* fifo)
{
INT16U num = 0;

FIFO_SET_BUSY(fifo);
num = fifo->CntUsed;
FIFO_RESET_BUSY(fifo);
return num;
}

只看该作者 · 2023-11-28 16:32

FIFO使用定时器的回调函数。回调函数中判断FIFO的标志位。对不同类型的FIFO执行不同的操作。

中断写入类型的FIFO，进行备份去数据的写入
/**
***************************************************
* @brief func_fifo_TimerCallBack
* @note FIFO链表定时器中断回调
* @param NONE
* @retval  NONE
* @data 2021.09.03
* @auth WXL
* @his    1.0.0.0    2021.09.03    WXL
*             create
***************************************************
**/
void func_fifo_TimerCallBack()
{
FifoTypeDef* point = FifoChain;

while(point!= NULL)
{
//FIFO 不繁忙不在中断中
if(FIFO_GET_BUSY(point) == 0 && FIFO_GET_INT(point) == 0)
{
if(point->Type == FIFO_TYPE_INT_PUSH && point->BackCount != 0)
{
func_fifo_Push2Fifo(point, 0, 0);
}
else if(point->Type == FIFO_TYPE_INT_PULL && point->CntUsed != 0)
{
point->func_timmer();
}
}
point = point->Next;
}
}