Searched refs:reader_queue (Results 1 – 4 of 4) sorted by relevance
| /components/libc/posix/io/eventfd/ |
| A D | eventfd.c | 35 rt_wqueue_t reader_queue; member
94 rt_poll_add(&ctx->reader_queue, req); in eventfd_poll()
153 rt_wqueue_wait(&ctx->reader_queue, 0, RT_WAITING_FOREVER); in eventfd_read()
236 rt_wqueue_wakeup(&ctx->reader_queue, (void *)POLLIN); in eventfd_write()
268 rt_wqueue_init(&ctx->reader_queue); in rt_eventfd_create()
|
| /components/drivers/ipc/ |
| A D | pipe.c | 143 while (!rt_list_isempty(&pipe->reader_queue.waiting_list)) in pipe_fops_close()
145 rt_wqueue_wakeup(&pipe->reader_queue, (void*)POLLIN); in pipe_fops_close()
254 if (rt_wqueue_wait_interruptible(&pipe->reader_queue, 0, -1) == -RT_EINTR) in pipe_fops_read()
328 rt_wqueue_wakeup(&pipe->reader_queue, (void*)POLLIN); in pipe_fops_write()
338 rt_wqueue_wakeup(&pipe->reader_queue, (void*)POLLIN); in pipe_fops_write()
364 rt_poll_add(&pipe->reader_queue, req); in pipe_fops_poll()
639 rt_wqueue_init(&pipe->reader_queue); in rt_pipe_create()
|
| /components/drivers/include/ipc/ |
| A D | pipe.h | 33 rt_wqueue_t reader_queue; member
|
| /components/lwp/ |
| A D | lwp_ipc.c | 163 rt_wqueue_wakeup(&ch->reader_queue, 0); in _rt_channel_check_wq_wakup_locked()
239 rt_wqueue_init(&ch->reader_queue); /* reader poll queue */ in rt_raw_channel_open()
1018 rt_poll_add(&(ch->reader_queue), req); in channel_fops_poll()
|
Completed in 7 milliseconds