Lines Matching defs:thread_mq
92 pa_thread_mq *thread_mq;
234 pa_thread_mq_install(u->thread_mq);
278 pa_asyncmsgq_post(u->thread_mq->outq, PA_MSGOBJECT(u->msg), TUNNEL_MESSAGE_MAYBE_RESTART, u, 0, NULL, NULL);
279 pa_asyncmsgq_wait_for(u->thread_mq->inq, PA_MESSAGE_SHUTDOWN);
418 pa_asyncmsgq_post(u->thread_mq->outq, PA_MSGOBJECT(u->msg), TUNNEL_MESSAGE_CREATE_SOURCE_REQUEST, u, 0, NULL, NULL);
579 pa_source_set_asyncmsgq(u->source, u->thread_mq->inq);
661 u->thread_mq = pa_xnew0(pa_thread_mq, 1);
663 if (pa_thread_mq_init_thread_mainloop(u->thread_mq, m->core->mainloop, u->thread_mainloop_api) < 0) {
743 pa_asyncmsgq_send(u->thread_mq->inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL);
747 if (u->thread_mq) {
748 pa_thread_mq_done(u->thread_mq);
749 pa_xfree(u->thread_mq);