Lines Matching defs:thread_mq
94 pa_thread_mq *thread_mq;
186 pa_thread_mq_install(u->thread_mq);
264 pa_asyncmsgq_post(u->thread_mq->outq, PA_MSGOBJECT(u->msg), TUNNEL_MESSAGE_MAYBE_RESTART, u, 0, NULL, NULL);
265 pa_asyncmsgq_wait_for(u->thread_mq->inq, PA_MESSAGE_SHUTDOWN);
444 pa_asyncmsgq_post(u->thread_mq->outq, PA_MSGOBJECT(u->msg), TUNNEL_MESSAGE_CREATE_SINK_REQUEST, u, 0, NULL, NULL);
607 pa_sink_set_asyncmsgq(u->sink, u->thread_mq->inq);
689 u->thread_mq = pa_xnew0(pa_thread_mq, 1);
691 if (pa_thread_mq_init_thread_mainloop(u->thread_mq, m->core->mainloop, u->thread_mainloop_api) < 0) {
774 pa_asyncmsgq_send(u->thread_mq->inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL);
778 if (u->thread_mq) {
779 pa_thread_mq_done(u->thread_mq);
780 pa_xfree(u->thread_mq);