diff options
| author | guozhanxin <[email protected]> | 2023-02-17 17:48:16 +0800 |
|---|---|---|
| committer | Man, Jianting (Meco) <[email protected]> | 2023-02-17 09:39:33 -0500 |
| commit | 1b3d287ceef877ad298507acaa081677936abe01 (patch) | |
| tree | 9dd2591d0a90adff41c9da9c933a91156d199f53 /components/drivers/ipc/workqueue.c | |
| parent | b065486b23bd9c2cd8d9e58e4daac3fb47dea7ed (diff) | |
[revert] workqueue RT_THREAD_SUSPEND flag
Diffstat (limited to 'components/drivers/ipc/workqueue.c')
| -rw-r--r-- | components/drivers/ipc/workqueue.c | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/components/drivers/ipc/workqueue.c b/components/drivers/ipc/workqueue.c index c70a1e1e28..9a09aae403 100644 --- a/components/drivers/ipc/workqueue.c +++ b/components/drivers/ipc/workqueue.c @@ -108,7 +108,7 @@ static rt_err_t _workqueue_submit_work(struct rt_workqueue *queue, /* whether the workqueue is doing work */ 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 */ rt_thread_resume(queue->work_thread); @@ -190,7 +190,7 @@ static void _delayed_work_timeout_handler(void *parameter) } /* whether the workqueue is doing work */ 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 */ 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)); /* whether the workqueue is doing work */ 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 */ rt_thread_resume(queue->work_thread); |