Lines Matching refs:thread
86 rt_thread_t thread; in rt_prio_queue_detach() local
92 thread = RT_THREAD_LIST_NODE_ENTRY(que->suspended_pop_list.next); in rt_prio_queue_detach()
94 thread->error = -RT_ERROR; in rt_prio_queue_detach()
96 rt_thread_resume(thread); in rt_prio_queue_detach()
160 rt_thread_t thread; in rt_prio_queue_push() local
163 thread = RT_THREAD_LIST_NODE_ENTRY(que->suspended_pop_list.next); in rt_prio_queue_push()
165 rt_thread_resume(thread); in rt_prio_queue_push()
194 rt_thread_t thread; in rt_prio_queue_pop() local
204 thread = rt_thread_self(); in rt_prio_queue_pop()
205 thread->error = RT_EOK; in rt_prio_queue_pop()
206 rt_thread_suspend(thread); in rt_prio_queue_pop()
208 rt_list_insert_before(&(que->suspended_pop_list), &RT_THREAD_LIST_NODE(thread)); in rt_prio_queue_pop()
212 rt_timer_control(&(thread->thread_timer), in rt_prio_queue_pop()
215 rt_timer_start(&(thread->thread_timer)); in rt_prio_queue_pop()
223 if (thread->error != RT_EOK) in rt_prio_queue_pop()
224 return thread->error; in rt_prio_queue_pop()