Lines Matching refs:thread
232 static int pipe_walk_op(struct k_thread *thread, void *data) in pipe_walk_op() argument
235 struct _pipe_desc *desc = (struct _pipe_desc *)thread->base.swap_data; in pipe_walk_op()
287 desc[0].thread = NULL; in pipe_buffer_list_populate()
297 desc[1].thread = NULL; in pipe_buffer_list_populate()
359 if (dest->thread == NULL) { in pipe_write()
372 z_unpend_thread(dest->thread); in pipe_write()
373 z_ready_thread(dest->thread); in pipe_write()
460 src_desc->thread = _current; in z_impl_k_pipe_put()
598 dest_desc->thread = _current; in pipe_get_internal()
617 if (src_desc->thread == NULL) { in pipe_get_internal()
630 z_unpend_thread(src_desc->thread); in pipe_get_internal()
631 z_ready_thread(src_desc->thread); in pipe_get_internal()