Lines Matching refs:inq
45 else if (pa_asyncmsgq_read_fd(q->inq) == fd)
46 pa_asyncmsgq_ref(aq = q->inq);
83 pa_assert(pa_asyncmsgq_write_fd(q->inq) == fd);
86 pa_asyncmsgq_write_after_poll(q->inq);
87 pa_asyncmsgq_write_before_poll(q->inq);
107 q->inq = pa_asyncmsgq_new(0);
108 if (!q->inq)
123 pa_asyncmsgq_read_before_poll(q->inq);
124 pa_asyncmsgq_write_before_poll(q->inq);
125 pa_assert_se(q->read_thread_event = thread_mainloop->io_new(thread_mainloop, pa_asyncmsgq_read_fd(q->inq), PA_IO_EVENT_INPUT, asyncmsgq_read_cb, q));
126 pa_assert_se(q->write_main_event = main_mainloop->io_new(main_mainloop, pa_asyncmsgq_write_fd(q->inq), PA_IO_EVENT_INPUT, asyncmsgq_write_inq_cb, q));
145 q->inq = pa_asyncmsgq_new(0);
146 if (!q->inq)
156 pa_asyncmsgq_write_before_poll(q->inq);
157 pa_assert_se(q->write_main_event = mainloop->io_new(mainloop, pa_asyncmsgq_write_fd(q->inq), PA_IO_EVENT_INPUT, asyncmsgq_write_inq_cb, q));
159 pa_rtpoll_item_new_asyncmsgq_read(rtpoll, PA_RTPOLL_EARLY, q->inq);
174 * inq is empty. However, the outq might still contain messages
204 if (q->inq)
205 pa_asyncmsgq_unref(q->inq);
208 q->inq = q->outq = NULL;