Lines Matching refs:asyncq
55 pa_asyncq *asyncq;
62 pa_asyncq *asyncq;
65 asyncq = pa_asyncq_new(size);
66 if (!asyncq)
72 a->asyncq = asyncq;
83 while ((i = pa_asyncq_pop(a->asyncq, false))) {
100 pa_asyncq_free(a->asyncq, NULL);
124 pa_snprintf(t, sizeof(t), "pa_asyncmsgq_post[%d] %u", code, PaAsyncqGetNumToRead(a->asyncq));
145 pa_asyncq_post(a->asyncq, i);
155 pa_snprintf(t, sizeof(t), "pa_asyncmsgq_send[%d] %u", code, PaAsyncqGetNumToRead(a->asyncq));
174 pa_assert_se(pa_asyncq_push(a->asyncq, &i, true) == 0);
189 if (!(a->current = pa_asyncq_pop(a->asyncq, wait_op))) {
197 pa_snprintf(t, sizeof(t), "pa_asyncmsgq_get[%d] %u", a->current->code, PaAsyncqGetNumToRead(a->asyncq));
300 return pa_asyncq_read_fd(a->asyncq);
306 return pa_asyncq_read_before_poll(a->asyncq);
312 pa_asyncq_read_after_poll(a->asyncq);
318 return pa_asyncq_write_fd(a->asyncq);
324 pa_asyncq_write_before_poll(a->asyncq);
330 pa_asyncq_write_after_poll(a->asyncq);