summaryrefslogtreecommitdiff
path: root/src/thread.c
diff options
context:
space:
mode:
authorBernard Xiong <[email protected]>2021-07-03 19:07:39 +0800
committerGitHub <[email protected]>2021-07-03 19:07:39 +0800
commit3a29bf4889a73ca47444d272cfa69c0a826ebeeb (patch)
tree4108e382f38d4ff14a2e90a4ecd7dfa565e21570 /src/thread.c
parentd7d22e0afccb2179e5197f31ece537ea80f124e6 (diff)
parent3dfebe337ab996eeaea651c3a87f06af114e9326 (diff)
Merge pull request #4843 from fenghuijie/master
添加dcache invalidate/dcache clean&invalidate接口
Diffstat (limited to 'src/thread.c')
-rw-r--r--src/thread.c40
1 files changed, 25 insertions, 15 deletions
diff --git a/src/thread.c b/src/thread.c
index c0a8f0ee74..88cc7b61ba 100644
--- a/src/thread.c
+++ b/src/thread.c
@@ -32,8 +32,6 @@
#include <rthw.h>
#include <rtthread.h>
-extern rt_list_t rt_thread_defunct;
-
#ifdef RT_USING_HOOK
static void (*rt_thread_suspend_hook)(rt_thread_t thread);
static void (*rt_thread_resume_hook) (rt_thread_t thread);
@@ -131,7 +129,7 @@ static void _rt_thread_exit(void)
else
{
/* insert to defunct thread list */
- rt_list_insert_after(&rt_thread_defunct, &(thread->tlist));
+ rt_thread_defunct_enqueue(thread);
}
/* switch to next task */
@@ -379,17 +377,22 @@ rt_err_t rt_thread_detach(rt_thread_t thread)
/* release thread timer */
rt_timer_detach(&(thread->thread_timer));
- /* disable interrupt */
- lock = rt_hw_interrupt_disable();
-
/* change stat */
thread->stat = RT_THREAD_CLOSE;
- /* detach thread object */
- rt_object_detach((rt_object_t)thread);
-
- /* enable interrupt */
- rt_hw_interrupt_enable(lock);
+ if (rt_object_is_systemobject((rt_object_t)thread) == RT_TRUE)
+ {
+ rt_object_detach((rt_object_t)thread);
+ }
+ else
+ {
+ /* disable interrupt */
+ lock = rt_hw_interrupt_disable();
+ /* insert to defunct thread list */
+ rt_thread_defunct_enqueue(thread);
+ /* enable interrupt */
+ rt_hw_interrupt_enable(lock);
+ }
return RT_EOK;
}
@@ -484,7 +487,7 @@ rt_err_t rt_thread_delete(rt_thread_t thread)
thread->stat = RT_THREAD_CLOSE;
/* insert to defunct thread list */
- rt_list_insert_after(&rt_thread_defunct, &(thread->tlist));
+ rt_thread_defunct_enqueue(thread);
/* enable interrupt */
rt_hw_interrupt_enable(lock);
@@ -847,12 +850,12 @@ rt_err_t rt_thread_resume(rt_thread_t thread)
rt_timer_stop(&thread->thread_timer);
- /* enable interrupt */
- rt_hw_interrupt_enable(temp);
-
/* insert to schedule ready list */
rt_schedule_insert_thread(thread);
+ /* enable interrupt */
+ rt_hw_interrupt_enable(temp);
+
RT_OBJECT_HOOK_CALL(rt_thread_resume_hook, (thread));
return RT_EOK;
}
@@ -867,6 +870,7 @@ RTM_EXPORT(rt_thread_resume);
void rt_thread_timeout(void *parameter)
{
struct rt_thread *thread;
+ register rt_base_t temp;
thread = (struct rt_thread *)parameter;
@@ -875,6 +879,9 @@ void rt_thread_timeout(void *parameter)
RT_ASSERT((thread->stat & RT_THREAD_STAT_MASK) == RT_THREAD_SUSPEND);
RT_ASSERT(rt_object_get_type((rt_object_t)thread) == RT_Object_Class_Thread);
+ /* disable interrupt */
+ temp = rt_hw_interrupt_disable();
+
/* set error number */
thread->error = -RT_ETIMEOUT;
@@ -884,6 +891,9 @@ void rt_thread_timeout(void *parameter)
/* insert to schedule ready list */
rt_schedule_insert_thread(thread);
+ /* enable interrupt */
+ rt_hw_interrupt_enable(temp);
+
/* do schedule */
rt_schedule();
}