Home
last modified time | relevance | path

Searched refs:suspend_thread (Results 1 – 6 of 6) sorted by relevance

/components/drivers/ipc/
A Dcompletion_up.c188 rt_thread_t suspend_thread; in rt_completion_wakeup_by_errno() local
198 suspend_thread = RT_COMPLETION_THREAD(completion); in rt_completion_wakeup_by_errno()
199 if (suspend_thread) in rt_completion_wakeup_by_errno()
205 suspend_thread->error = thread_errno; in rt_completion_wakeup_by_errno()
208 error = rt_thread_resume(suspend_thread); in rt_completion_wakeup_by_errno()
A Dcompletion_mp.c305 rt_thread_t suspend_thread; in rt_completion_wakeup_by_errno() local
347 suspend_thread = GET_THREAD(expected_value); in rt_completion_wakeup_by_errno()
351 suspend_thread->error = thread_errno; in rt_completion_wakeup_by_errno()
359 rt_thread_resume(suspend_thread); in rt_completion_wakeup_by_errno()
/components/finsh/
A Dcmd.c315 if (!rt_list_isempty(&sem->parent.suspend_thread)) in list_sem()
384 if (!rt_list_isempty(&e->parent.suspend_thread)) in list_event()
391 rt_susp_list_print(&(e->parent.suspend_thread)); in list_event()
450 if (!rt_list_isempty(&m->parent.suspend_thread)) in list_mutex()
459 rt_list_len(&m->parent.suspend_thread)); in list_mutex()
460 rt_susp_list_print(&(m->parent.suspend_thread)); in list_mutex()
472 rt_list_len(&m->parent.suspend_thread)); in list_mutex()
525 if (!rt_list_isempty(&m->parent.suspend_thread)) in list_mailbox()
596 if (!rt_list_isempty(&m->parent.suspend_thread)) in list_msgqueue()
726 rt_list_for_each(node, &mp->suspend_thread) in list_mempool()
[all …]
/components/libc/posix/pthreads/
A Dpthread_cond.c174 if (!rt_list_isempty(&cond->sem.parent.suspend_thread)) in pthread_cond_destroy()
288 if (rt_list_isempty(&cond->sem.parent.suspend_thread)) in pthread_cond_signal()
410 rt_list_insert_before(&(sem->parent.suspend_thread), &RT_THREAD_LIST_NODE(thread)); in _pthread_cond_timedwait()
/components/lwp/
A Dlwp_ipc.c116 rt_list_init(&(ipc->suspend_thread)); /* receiver list */ in rt_channel_object_init()
301 _channel_list_resume_all_locked(&ch->parent.suspend_thread); in rt_raw_channel_close()
584 RT_ASSERT(ch->parent.suspend_thread.next != &ch->parent.suspend_thread); in _do_send_recv_timeout()
623 thread_recv = RT_THREAD_LIST_NODE_ENTRY(ch->parent.suspend_thread.next); in _do_send_recv_timeout()
627 rt_channel_list_resume(&ch->parent.suspend_thread); in _do_send_recv_timeout()
769 ret = rt_channel_list_resume(&ch->parent.suspend_thread); in wakeup_receiver()
865 rc = rt_channel_list_suspend(&ch->parent.suspend_thread, thread); in _rt_raw_channel_recv_timeout()
1049 _channel_list_resume_all_locked(&ch->parent.suspend_thread); in channel_fops_close()
/components/libc/posix/ipc/
A Dsemaphore.c178 if(rt_list_len(&sem->sem->parent.suspend_thread) != 0) in sem_destroy()

Completed in 12 milliseconds