summaryrefslogtreecommitdiff
path: root/components/drivers/src
diff options
context:
space:
mode:
authortangyuxin <[email protected]>2021-02-01 14:36:18 +0800
committertangyuxin <[email protected]>2021-02-01 15:02:20 +0800
commitc5218b5eeed799593485c89234de809858cb6bf2 (patch)
tree1f251a95fd9ef115a154d2be6bcc4f75efd6ba7e /components/drivers/src
parent5b52e6c7e315d25c5a492d5460442e6e3f5c5631 (diff)
修复紧急工作队列插入问题
紧急工作仍插入队列尾部,先将其插入队列头部
Diffstat (limited to 'components/drivers/src')
-rw-r--r--components/drivers/src/workqueue.c18
1 files changed, 8 insertions, 10 deletions
diff --git a/components/drivers/src/workqueue.c b/components/drivers/src/workqueue.c
index 5c497cd5c8..d21bf08f4d 100644
--- a/components/drivers/src/workqueue.c
+++ b/components/drivers/src/workqueue.c
@@ -267,24 +267,22 @@ rt_err_t rt_workqueue_critical_work(struct rt_workqueue *queue, struct rt_work *
RT_ASSERT(work != RT_NULL);
level = rt_hw_interrupt_disable();
- if (queue->work_current == work)
- {
- rt_hw_interrupt_enable(level);
- return -RT_EBUSY;
- }
-
/* NOTE: the work MUST be initialized firstly */
rt_list_remove(&(work->list));
-
- rt_list_insert_after(queue->work_list.prev, &(work->list));
- if (queue->work_current == RT_NULL)
+ rt_list_insert_after(&queue->work_list, &(work->list));
+ /* whether the workqueue is doing work */
+ if (queue->work_current == RT_NULL &&
+ ((queue->work_thread->stat & RT_THREAD_STAT_MASK) == RT_THREAD_SUSPEND))
{
rt_hw_interrupt_enable(level);
/* resume work thread */
rt_thread_resume(queue->work_thread);
rt_schedule();
}
- else rt_hw_interrupt_enable(level);
+ else
+ {
+ rt_hw_interrupt_enable(level);
+ }
return RT_EOK;
}