Lines Matching refs:reader
96 struct k_thread *reader = NULL; in copy_to_pending_readers() local
110 reader = _priq_wait_best(&pipe->data.waitq); in copy_to_pending_readers()
111 if (reader == NULL) { in copy_to_pending_readers()
115 reader_buf = reader->base.swap_data; in copy_to_pending_readers()
125 reader = NULL; in copy_to_pending_readers()
132 unpend_thread_no_timeout(reader); in copy_to_pending_readers()
133 z_abort_thread_timeout(reader); in copy_to_pending_readers()
136 if (reader != NULL) { in copy_to_pending_readers()
138 z_thread_return_value_set_with_data(reader, 0, NULL); in copy_to_pending_readers()
139 z_ready_thread(reader); in copy_to_pending_readers()
142 } while (reader != NULL && written < len); in copy_to_pending_readers()