Lines Matching refs:pending_thread
132 struct k_thread *pending_thread; in put_msg_in_queue() local
147 pending_thread = z_unpend_first_thread(&msgq->wait_q); in put_msg_in_queue()
148 if (unlikely(pending_thread != NULL)) { in put_msg_in_queue()
152 (void)memcpy(pending_thread->base.swap_data, data, msgq->msg_size); in put_msg_in_queue()
154 arch_thread_return_value_set(pending_thread, 0); in put_msg_in_queue()
155 z_ready_thread(pending_thread); in put_msg_in_queue()
281 struct k_thread *pending_thread; in z_impl_k_msgq_get() local
299 pending_thread = z_unpend_first_thread(&msgq->wait_q); in z_impl_k_msgq_get()
300 if (unlikely(pending_thread != NULL)) { in z_impl_k_msgq_get()
306 (void)memcpy(msgq->write_ptr, (char *)pending_thread->base.swap_data, in z_impl_k_msgq_get()
315 arch_thread_return_value_set(pending_thread, 0); in z_impl_k_msgq_get()
316 z_ready_thread(pending_thread); in z_impl_k_msgq_get()
440 struct k_thread *pending_thread; in z_impl_k_msgq_purge() local
448 for (pending_thread = z_unpend_first_thread(&msgq->wait_q); in z_impl_k_msgq_purge()
449 pending_thread != NULL; in z_impl_k_msgq_purge()
450 pending_thread = z_unpend_first_thread(&msgq->wait_q)) { in z_impl_k_msgq_purge()
451 arch_thread_return_value_set(pending_thread, -ENOMSG); in z_impl_k_msgq_purge()
452 z_ready_thread(pending_thread); in z_impl_k_msgq_purge()