Lines Matching refs:thread
98 rt_thread_t thread; in rt_data_queue_push() local
108 thread = rt_thread_self(); in rt_data_queue_push()
122 thread->error = RT_EOK; in rt_data_queue_push()
125 result = rt_thread_suspend_to_list(thread, &queue->suspended_push_list, in rt_data_queue_push()
133 rt_timer_control(&(thread->thread_timer), in rt_data_queue_push()
136 rt_timer_start(&(thread->thread_timer)); in rt_data_queue_push()
149 result = thread->error; in rt_data_queue_push()
215 rt_thread_t thread; in rt_data_queue_pop() local
227 thread = rt_thread_self(); in rt_data_queue_pop()
240 thread->error = RT_EOK; in rt_data_queue_pop()
243 result = rt_thread_suspend_to_list(thread, &queue->suspended_pop_list, in rt_data_queue_pop()
251 rt_timer_control(&(thread->thread_timer), in rt_data_queue_pop()
254 rt_timer_start(&(thread->thread_timer)); in rt_data_queue_pop()
265 result = thread->error; in rt_data_queue_pop()