求教傻孩子，环形FIFO出队问题，可以入列，非法出列。

slzm40

        开始是用傻孩子那篇用宏定义的FIFO，后来有问题，我就改成函数的方式了。稍做修改用在自己的程序上。 也把宏改成通俗的了。
        先说问题，改完后可以入列，意思是入列正常，出列也能出，但是全为零。  我做了实验，前面入列8次，全对的，出列也是八次。。。全为零。。。

1. 
   
2. 定义结构体
   
3. typedef struct
   
4. {
   
5.         uint8_t Ep_add;
   
6.         uint8_t Ep_val;
   
7. } EP_Data;
   
8. 定义队列结构体
   
9. typedef struct {
   
10.     EP_Data         *ptBuffer;                                            
    
11.     uint8_t                tSize;                                                
    
12.     uint8_t      tHead;                                                  
    
13.     uint8_t      tTail;                                                  
    
14.     uint8_t      tCounter;                                             
    
15. }t_ep_queue_t;
    
16. 
    
17. t_ep_queue_t  EP_Queue; //声明队列
    
18. EP_Data epbuf[ep_size];//定义缓冲区
    
19. /*        队列初始化                */                                                  
    
20. bool t_ep_queue_init(t_ep_queue_t *ptQueue, EP_Data *ptBuffer, uint8_t tSize)
    
21. {                                                                           
    
22.     t_ep_queue_t *ptQ = (t_ep_queue_t *)ptQueue;      
    
23.     if (NULL == ptQueue || NULL == ptBuffer || 0 == tSize) {               
    
24.         return false;                                                      
    
25.     }                                                                                                                                            
    
26.     ptQ->ptBuffer = ptBuffer;                                               
    
27.     ptQ->tSize = tSize;                                                     
    
28.     ptQ->tHead = 0;                                                         
    
29.     ptQ->tTail = 0;                                                         
    
30.     ptQ->tCounter = 0;
    
31.                                                                            
    
32.     return true;                                                            
    
33. }                                                                           
    
34. /*        入队 函数*/                                                                               
    
35. bool t_ep_enqueue(t_ep_queue_t *ptQueue, EP_Data *tObj)                               
    
36. {                                                                                                                                                       
    
37.         bool bResult = false;                                                                                                       
    
38.         t_ep_queue_t *ptQ = (t_ep_queue_t *)ptQueue;               
    
39.         if (NULL == ptQ && NULL == tObj) {                                                                                 
    
40.                 return false;                                                                                                               
    
41.         }                                                                                                                                               
    
42.                                                                                                                                                                                                                                                                        
    
43.                         if (ptQ->tCounter != ptQ->tSize) {                                                               
    
44.                         ptQ->ptBuffer[ptQ->tTail] = *tObj;                                                                                                                                                        
    
45.                         if (++ptQ->tTail >= ptQ->tSize) {                                                                
    
46.                                 ptQ->tTail = 0;                                                                                        
    
47.                         }       
    
48.                         ptQ->tCounter++;
    
49.                         bResult = true;                                                                                                
    
50.                         }                                                                                                                                                                                                                                                                       
    
51.         return bResult;                                                                                                                
    
52. }                                                                                                                                                       
    
53.   /*        出队        函数        */                                                      
    
54. bool t_ep_dequeue(t_ep_queue_t *ptQueue, EP_Data *ptObj)            
    
55. {                                                                          
    
56.         bool bResult = false;                                                                                                       
    
57.         t_ep_queue_t *ptQ = (t_ep_queue_t *)ptQueue;               
    
58.         if(ptQ == NULL && ptObj == NULL){                                                                               
    
59.                 return false;                                                                                                               
    
60.           }                                                                                                                                                                                                                                                        
    
61.                         if (ptQ->tCounter != 0) {                                                                               
    
62.                                 *ptObj = ptQ->ptBuffer[ptQ->tHead];                                                                                                                                       
    
63.                                 if(ptQ->tSize >= ++ptQ->tHead){                                                               
    
64.                                         ptQ->tHead = 0;                                                                                
    
65.                                         }
    
66.                                 ptQ->tCounter--;
    
67.                         bResult = true;                                                                                                
    
68.                         }                                                                                                                               
    
69.                                                                                                                                                                                                                                   
    
70.     return bResult;                                                         
    
71. }                                                                        
    
72. /* 我就看看,就是不出出队*/                                                                       
    
73.                                                                                                                        
    
74. void Ep_init()
    
75. {
    
76.         t_ep_queue_init(&EP_Queue,&epbuf[0],ep_size);
    
77. }
    
78. 
    
79. bool Ep_enqueue(EP_Data *value)
    
80. {       
    
81.         return t_ep_enqueue(&EP_Queue,value);
    
82. }
    
83. 
    
84. bool Ep_dequeue(EP_Data *value)
    
85. {
    
86.         return t_ep_dequeue(&EP_Queue,value);
    
87. }
    
88. 
    
89. /*出队主程序*/
    
90. void EP_Task()
    
91. {
    
92.         EP_Data wep;
    
93.         if(Ep_dequeue(&wep) == true)
    
94.                 {
    
95.                 eeprom_write(wep.Ep_add,wep.Ep_val);
    
96.                 }
    
97. }
    
98. 
    

复制代码

各种值不出队，但入队次数和出队次数倒是正常的

slzm40

好了。。我找到问题了= = 在出队中if(ptQ->tSize >= ++ptQ->tHead) 这句写错了，应该是if(ptQ->tSize <= ++ptQ->tHead)

slzm40

花了两个小时，就这一个小错误。。。从入列到出列，到初始化全仔细看了。。不得不说，PIC的IDE优化太多了。。。不按套路出牌，在结构体里，count和size在我仿真中值一直是零哎。。

myqiang1990

本屌丝在一个WEB服务器里面接受加密文件用的~仅供参考~

1. /*******************************************************************************
   
2. ** 文件名:             Queue.c
   
3. ** 版本：                  1.0
   
4. ** 工作环境:         RealView MDK-ARM 4.23
   
5. ** 作者:                 陈志强
   
6. ** 生成日期:         2012-5-18
   
7. ** 功能:                 
   
8. ** 相关文件:       
   
9. ** 修改日志：
   
10. ** 注意事项:  
    
11.                             采用循环队列接收POST的数据,为什么要采用循环队列呢?因为TCP
    
12.                                 每次发下来的数据你根本就不知道是多少到底是不是512的整数倍！
    
13.                                 但是我们解码必须保证是512个字节的整数数据！
    
14.                                
    
15. *******************************************************************************/
    
16. #include "stm32f4xx.h"
    
17. #include "queue.h"
    
18. #include <string.h>
    
19. /*******************************************************************************
    
20. *全局变量：       
    
21. *全局说明:
    
22. ********************************************************************************/
    
23. Q_Queue  Dq;
    
24. 
    
25. static uint32_t APPStartddress;
    
26. static uint32_t IAPStartddress;
    
27. u8 PrgBuffer[PBLOCK] = {0}; //编程缓冲
    
28. /*******************************************************************************
    
29. *函数原型：void Q_Int(void)
    
30. *参数入口：no
    
31. *参数出口: no
    
32. *函数说明: no
    
33. ********************************************************************************/
    
34. void Q_Int(Q_Queue *q)
    
35. {
    
36.    q->head = 0;
    
37.    q->tail = 0;
    
38.    q->size = 0;
    
39.    CleanData();
    
40.    APPStartddress = APPLICATION_ADDRESS;
    
41.    IAPStartddress = IAP_START_ADDRESS;
    
42. }
    
43. /*******************************************************************************
    
44. *函数原型：void Q_In(Q_Queue *q, u8 data)
    
45. *参数入口：no
    
46. *参数出口: no
    
47. *函数说明: 入队
    
48. ********************************************************************************/
    
49. static u8 Q_InPut(Q_Queue *q, u8 data)
    
50. {
    
51.   if((q->tail + 1) % BLOCK == q->head)//满了
    
52.    {
    
53.      return Q_FULL;
    
54.    }
    
55.   else
    
56.    {
    
57.       q->Data[q->tail] = data;
    
58.       q->tail = (q->tail + 1) % BLOCK;
    
59.       q->size++;
    
60.    }
    
61.   return Q_OK;
    
62. }
    
63. /*******************************************************************************
    
64. *函数原型：void Q_Out(Q_Queue *q, u8 *data)
    
65. *参数入口：no
    
66. *参数出口: no
    
67. *函数说明: 出队
    
68. ********************************************************************************/
    
69. static u8 Q_OutPut(Q_Queue *q, u8 *data)
    
70. {
    
71.   if(q->tail == q->head)//空
    
72.    {
    
73.      return Q_EMPTY;
    
74.    }
    
75.   else
    
76.    {
    
77.        *data = q->Data[q->head];
    
78.         q->head = (q->head + 1) % BLOCK;
    
79.         q->size--;       
    
80.    }
    
81.    return Q_OK;
    
82. }
    
83. /*******************************************************************************
    
84. *函数原型：void Q_DataInPut(Q_Queue *q, u8 *data, u16 len)
    
85. *参数入口：no
    
86. *参数出口: no
    
87. *函数说明: 数据入队
    
88. ********************************************************************************/
    
89. u8 Q_DataInPut(Q_Queue *q, u8 *dataaddr, u16 len)
    
90. {
    
91.    u16 i = 0;
    
92. 
    
93.    for(i = 0; i < len; i++)
    
94.     {
    
95.           if(Q_InPut(q, *(dataaddr + i)) == Q_FULL)
    
96.             return Q_FULL;
    
97.         }
    
98.   return Q_OK;
    
99. }
    
100. /*******************************************************************************
     
101. *函数原型：u8 Q_DataOutPut(Q_Queue *q, u8 *buffer, u16 len)
     
102. *参数入口：no
     
103. *参数出口: no
     
104. *函数说明: 处理
     
105. ********************************************************************************/
     
106. u8 Q_DataOutPut(Q_Queue *q, u8 *buffer, u16 len)
     
107. {
     
108.   u16 i = 0;
     
109. 
     
110.   for(i = 0; i < len; i++)
     
111.    {
     
112.      if(Q_OutPut(q, buffer + i) == Q_EMPTY)
     
113.           return Q_EMPTY;
     
114.    }
     
115. return Q_OK;
     
116. }

复制代码

1. /*******************************************************************************
   
2. ** 文件名:             Queue.h
   
3. ** 版本：                  1.0
   
4. ** 工作环境:         RealView MDK-ARM 4.23
   
5. ** 作者:                 陈志强
   
6. ** 生成日期:         2012-5-18
   
7. ** 功能:                 
   
8. ** 相关文件:       
   
9. ** 修改日志：
   
10. ** 注意事项:  
    
11.                             循环队列
    
12. *******************************************************************************/
    
13. #ifndef _QUEUE_H_
    
14. #define _QUEUE_H_
    
15. /*******************************************************************************/
    
16. #define BLOCK   5120
    
17. #define PBLOCK  512
    
18. 
    
19. #define Q_FULL  0x01
    
20. #define Q_EMPTY 0x02
    
21. #define Q_OK    0x03
    
22. /*******************************************************************************/
    
23. typedef struct
    
24. {
    
25.    u32 head;
    
26.    u32 tail;
    
27.    u32 size;
    
28.    u8  Data[BLOCK];
    
29. 
    
30. }Q_Queue;
    
31. 
    
32. extern Q_Queue  Dq;
    
33. 
    
34. #define CleanData()   memset(Dq.Data, 0, BLOCK)
    
35. /*******************************************************************************/
    
36. void Q_Int(Q_Queue *q);
    
37. u8 Q_DataInPut(Q_Queue *q, u8 *dataaddr, u16 len);
    
38. u8 Q_DataOutPut(Q_Queue *q, u8 *buffer, u16 len);
    
39. void ProgameHanld(Q_Queue *q);
    
40. /*******************************************************************************/
    
41. #endif
    

复制代码

Gorgon_Meducer

myqiang1990 发表于 2014-10-26 12:21
本屌丝在一个WEB服务器里面接受加密文件用的~仅供参考~

建议不要用%运算。

Gallen.Zhang

myqiang1990 发表于 2014-10-26 12:21
本屌丝在一个WEB服务器里面接受加密文件用的~仅供参考~

我有一个疑问：队列中的元素个数size（即tail和head的差值）小于BLOCK，也就是说队列并没有满，但是有可能head或者tail大于BLOCK，此时Data数据缓冲区不就溢出了吗？

myqiang1990

Gallen.Zhang 发表于 2014-10-28 16:39
我有一个疑问：队列中的元素个数size（即tail和head的差值）小于BLOCK，也就是说队列并没有满，但是有可 ...

NO ~~NO~~~认真分析q->tail = (q->tail + 1) % BLOCK;和q->head = (q->head + 1) % BLOCK;这两句话~~不可能大于 BLOCK，下标只可能在0--BLOCK - 1之间循环，数据个数只能在0---BLOCK之间循环
tail和head在做你追我赶反复运动~数据只可能在BLOCK这么大的数据块中循环运动~~意思是他们两个的运动范围就是0--BLOCK~不会超过BLOCK~~

这个循环列队是不是很简洁啊~~呵呵~~

myqiang1990

Gorgon_Meducer 发表于 2014-10-28 15:16
建议不要用%运算。

为什么呢？我觉得加个if判断不够简洁啊~~所以用了%~~是不是%会不会导致入队出队效率不够高？

Gorgon_Meducer

myqiang1990 发表于 2014-10-28 17:53
为什么呢？我觉得加个if判断不够简洁啊~~所以用了%~~是不是%会不会导致入队出队效率不够高？ ...

会产生整数除法运算。

Gallen.Zhang

myqiang1990 发表于 2014-10-28 17:46
NO ~~NO~~~认真分析q->tail = (q->tail + 1) % BLOCK;和q->head = (q->head + 1) % BLOCK;这两句话~~不可 ...

谢谢提醒，我忽略了对BLOCK取余运算！

小溪

Gorgon_Meducer 发表于 2014-10-28 18:34
会产生整数除法运算。

请问，产生整数出发有什么不好吗？

slzm40

开始我也用取余那样算，后来改了 ，毕竟计算机是0和1的。

Timerunner321

myqiang1990的程序挺好，学习了

Gorgon_Meducer

小溪 发表于 2014-10-28 20:23
请问，产生整数出发有什么不好吗？

还是除法……没有硬件除法器的话肯定没有整数比较来得快

Timerunner321

有用，谢谢

gxay2000

a_2012_m

Gorgon_Meducer 发表于 2014-12-16 10:55
还是除法……没有硬件除法器的话肯定没有整数比较来得快

不用取余运算，有什么好的方式替代吗?

ALUMEI

a_2012_m 发表于 2016-4-27 10:32
不用取余运算，有什么好的方式替代吗?

参考linux 内核源码的 kfifo部分。 fifo的经典了

wt19891114

MARK.环形FIFO ,正在学习！

a_2012_m

ALUMEI 发表于 2016-4-27 10:40
参考linux 内核源码的 kfifo部分。 fifo的经典了

谢谢，参考kfifo看看！

Gorgon_Meducer

a_2012_m 发表于 2016-4-27 10:32
不用取余运算，有什么好的方式替代吗?

如果是2的整倍数，用逻辑&运算，
如果不是，简单的用if 判断就可以了