Lines Matching refs:wait_q
47 z_waitq_init(&pipe->wait_q.writers); in k_pipe_init()
48 z_waitq_init(&pipe->wait_q.readers); in k_pipe_init()
165 CHECKIF((z_waitq_head(&pipe->wait_q.readers) != NULL) || in k_pipe_cleanup()
166 (z_waitq_head(&pipe->wait_q.writers) != NULL)) { in k_pipe_cleanup()
248 _wait_q_t *wait_q, in pipe_waiter_list_populate() argument
257 (void) z_sched_waitq_walk(wait_q, pipe_walk_op, &walk_data); in pipe_waiter_list_populate()
415 &pipe->wait_q.readers, in z_impl_k_pipe_put()
493 z_sched_wait(&pipe->lock, key, &pipe->wait_q.writers, timeout, NULL); in z_impl_k_pipe_put()
565 &pipe->wait_q.writers, in pipe_get_internal()
640 &pipe->wait_q.writers, in pipe_get_internal()
679 z_sched_wait(&pipe->lock, key, &pipe->wait_q.readers, timeout, NULL); in pipe_get_internal()