diff --git a/components/drivers/src/dataqueue.c b/components/drivers/src/dataqueue.c index fc4ce1ef1eb484ff23d4fffcea9c9738afdd3de6..a10b0805b4ac4e2c3e8866514173cbdeab0412e0 100644 --- a/components/drivers/src/dataqueue.c +++ b/components/drivers/src/dataqueue.c @@ -122,10 +122,9 @@ rt_err_t rt_data_queue_push(struct rt_data_queue *queue, queue->queue[queue->put_index % queue->size].data_size = data_size; queue->put_index += 1; + /* there is at least one thread in suspended list */ if (!rt_list_isempty(&(queue->suspended_pop_list))) { - /* there is at least one thread in suspended list */ - /* get thread entry */ thread = rt_list_entry(queue->suspended_pop_list.next, struct rt_thread, @@ -217,10 +216,7 @@ rt_err_t rt_data_queue_pop(struct rt_data_queue *queue, if ((queue->put_index - queue->get_index) <= queue->lwm) { - /* - * there is at least one thread in suspended list - * and less than low water mark - */ + /* there is at least one thread in suspended list */ if (!rt_list_isempty(&(queue->suspended_push_list))) { /* get thread entry */