数据队列rt_data_queue_push似乎有bug？

发布于 2019-09-21 10:33:04 浏览：1896 订阅该版

```c
struct rt_data_queue
{
    rt_uint16_t size;
    rt_uint16_t lwm;
    rt_bool_t   waiting_lwm;

rt_uint16_t get_index;
    rt_uint16_t put_index;

struct rt_data_item *queue;

rt_list_t suspended_push_list;
    rt_list_t suspended_pop_list;

/* event notify */
    void (*evt_notify)(struct rt_data_queue *queue, rt_uint32_t event);
};

rt_err_t rt_data_queue_push(struct rt_data_queue *queue,
                            const void *data_ptr,
                            rt_size_t data_size,
                            rt_int32_t timeout)
{
    rt_ubase_t  level;
    rt_thread_t thread;
    rt_err_t    result;

RT_ASSERT(queue != RT_NULL);

result = RT_EOK;
    thread = rt_thread_self();

level = rt_hw_interrupt_disable();
    while (queue->put_index - queue->get_index == queue->size)
    {
        /* queue is full */
        if (timeout == 0)
        {
            result = -RT_ETIMEOUT;

goto __exit;
        }
省略下面部分代码
....
}
```

在dataqueue.c文件中，put_index 和get_index 只作+1运算，运算超过0xFFFF次后，会出现`put_index < get_index` 的情况。

put_index 和get_index 都是16位的，而当CPU是32位时，直接相减可能会溢出。
比如当`put_index = 1，get_index = 0xFFFF，size = 2`的情况下，
`queue->put_index - queue->get_index = 0xFFFF0002` 不等于 `size `
因此，上述红色标示的代码应当修改为
`while (((rt_uint16_t )(queue->put_index - queue->get_index) )== queue->size)`
类似的情况还有rt_data_queue_pop函数中的
`if ((queue->put_index - queue->get_index) <= queue->lwm)`

建议修改在dataqueue.h文件中的
```c
#define RT_DATAQUEUE_SIZE(dq)        ((dq)->put_index - (dq)->get_index)
```
为
```c
#define RT_DATAQUEUE_SIZE(dq)      ((rt_uint16_t ) ((dq)->put_index - (dq)->get_index))
```
然后.c中统一使用上述宏

以上分析，个人观点，仅供参考，希望指正