24                    rt_uint16_t size,  in rt_data_queue_init()  argument
32     queue->size = size;  in rt_data_queue_init()
41     queue->queue = (struct rt_data_item *)rt_malloc(sizeof(struct rt_data_item) * size);  in rt_data_queue_init()
66     while (queue->put_index - queue->get_index == queue->size)  in rt_data_queue_push()
107     queue->queue[queue->put_index % queue->size].data_ptr  = data_ptr;  in rt_data_queue_push()
108     queue->queue[queue->put_index % queue->size].data_size = data_size;  in rt_data_queue_push()
142                            rt_size_t *size,   in rt_data_queue_pop()  argument
151     RT_ASSERT(size != RT_NULL);  in rt_data_queue_pop()
198     *data_ptr = queue->queue[queue->get_index % queue->size].data_ptr;  in rt_data_queue_pop()
199     *size     = queue->queue[queue->get_index % queue->size].data_size;  in rt_data_queue_pop()
244                             rt_size_t *size)  in rt_data_queue_peak()  argument
259     *data_ptr = queue->queue[queue->get_index % queue->size].data_ptr;  in rt_data_queue_peak()
260     *size     = queue->queue[queue->get_index % queue->size].data_size;  in rt_data_queue_peak()