Lines Matching refs:asyncq
54 pa_asyncq *asyncq; member
61 pa_asyncq *asyncq; in pa_asyncmsgq_new() local
64 asyncq = pa_asyncq_new(size); in pa_asyncmsgq_new()
65 if (!asyncq) in pa_asyncmsgq_new()
71 a->asyncq = asyncq; in pa_asyncmsgq_new()
82 while ((i = pa_asyncq_pop(a->asyncq, false))) { in asyncmsgq_free()
99 pa_asyncq_free(a->asyncq, NULL); in asyncmsgq_free()
140 pa_asyncq_post(a->asyncq, i); in pa_asyncmsgq_post()
165 pa_assert_se(pa_asyncq_push(a->asyncq, &i, true) == 0); in pa_asyncmsgq_send()
180 if (!(a->current = pa_asyncq_pop(a->asyncq, wait_op))) { in pa_asyncmsgq_get()
287 return pa_asyncq_read_fd(a->asyncq); in pa_asyncmsgq_read_fd()
293 return pa_asyncq_read_before_poll(a->asyncq); in pa_asyncmsgq_read_before_poll()
299 pa_asyncq_read_after_poll(a->asyncq); in pa_asyncmsgq_read_after_poll()
305 return pa_asyncq_write_fd(a->asyncq); in pa_asyncmsgq_write_fd()
311 pa_asyncq_write_before_poll(a->asyncq); in pa_asyncmsgq_write_before_poll()
317 pa_asyncq_write_after_poll(a->asyncq); in pa_asyncmsgq_write_after_poll()