Lines Matching refs:outq
43 if (pa_asyncmsgq_read_fd(q->outq) == fd)
44 pa_asyncmsgq_ref(aq = q->outq);
93 pa_assert(pa_asyncmsgq_write_fd(q->outq) == fd);
96 pa_asyncmsgq_write_after_poll(q->outq);
97 pa_asyncmsgq_write_before_poll(q->outq);
111 q->outq = pa_asyncmsgq_new(0);
112 if (!q->outq)
118 pa_assert_se(pa_asyncmsgq_read_before_poll(q->outq) == 0);
119 pa_asyncmsgq_write_before_poll(q->outq);
120 pa_assert_se(q->read_main_event = main_mainloop->io_new(main_mainloop, pa_asyncmsgq_read_fd(q->outq), PA_IO_EVENT_INPUT, asyncmsgq_read_cb, q));
121 pa_assert_se(q->write_thread_event = thread_mainloop->io_new(thread_mainloop, pa_asyncmsgq_write_fd(q->outq), PA_IO_EVENT_INPUT, asyncmsgq_write_outq_cb, q));
149 q->outq = pa_asyncmsgq_new(0);
150 if (!q->outq)
153 pa_assert_se(pa_asyncmsgq_read_before_poll(q->outq) == 0);
154 pa_assert_se(q->read_main_event = mainloop->io_new(mainloop, pa_asyncmsgq_read_fd(q->outq), PA_IO_EVENT_INPUT, asyncmsgq_read_cb, q));
160 pa_rtpoll_item_new_asyncmsgq_write(rtpoll, PA_RTPOLL_LATE, q->outq);
174 * inq is empty. However, the outq might still contain messages
179 if (q->outq && !pa_asyncmsgq_dispatching(q->outq)) {
182 pa_asyncmsgq *z = q->outq;
206 if (q->outq)
207 pa_asyncmsgq_unref(q->outq);
208 q->inq = q->outq = NULL;