libs/rt-thread-official
libs/rt-thread-official
4
0
Fork 0
mirror of https://github.com/RT-Thread/rt-thread.git synced 2025-02-28 02:47:06 +08:00
Code Issues Releases Wiki Activity

[revert] workqueue RT_THREAD_SUSPEND flag

Browse Source
This commit is contained in:
guozhanxin 2023-02-17 17:48:16 +08:00 committed by Man, Jianting (Meco)
parent b065486b23
commit 1b3d287cee
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
components/drivers/ipc/workqueue.c
View File

@ -108,7 +108,7 @@ static rt_err_t _workqueue_submit_work(struct rt_workqueue *queue,
/* whether the workqueue is doing work */ /* whether the workqueue is doing work */
if (queue->work_current == RT_NULL && if (queue->work_current == RT_NULL &&
((queue->work_thread->stat & RT_THREAD_STAT_MASK) == RT_THREAD_SUSPEND)) ((queue->work_thread->stat & RT_THREAD_SUSPEND_MASK) == RT_THREAD_SUSPEND_MASK))
{ {
/* resume work thread */ /* resume work thread */
rt_thread_resume(queue->work_thread); rt_thread_resume(queue->work_thread);
@ -190,7 +190,7 @@ static void _delayed_work_timeout_handler(void *parameter)
} }
/* whether the workqueue is doing work */ /* whether the workqueue is doing work */
if (queue->work_current == RT_NULL && if (queue->work_current == RT_NULL &&
((queue->work_thread->stat & RT_THREAD_STAT_MASK) == RT_THREAD_SUSPEND)) ((queue->work_thread->stat & RT_THREAD_SUSPEND_MASK) == RT_THREAD_SUSPEND_MASK))
{ {
/* resume work thread */ /* resume work thread */
rt_thread_resume(queue->work_thread); rt_thread_resume(queue->work_thread);
@ -348,7 +348,7 @@ rt_err_t rt_workqueue_urgent_work(struct rt_workqueue *queue, struct rt_work *wo
rt_list_insert_after(&queue->work_list, &(work->list)); rt_list_insert_after(&queue->work_list, &(work->list));
/* whether the workqueue is doing work */ /* whether the workqueue is doing work */
if (queue->work_current == RT_NULL && if (queue->work_current == RT_NULL &&
((queue->work_thread->stat & RT_THREAD_STAT_MASK) == RT_THREAD_SUSPEND)) ((queue->work_thread->stat & RT_THREAD_SUSPEND_MASK) == RT_THREAD_SUSPEND_MASK))
{ {
/* resume work thread */ /* resume work thread */
rt_thread_resume(queue->work_thread); rt_thread_resume(queue->work_thread);