Lines Matching defs:thread_mq
219 pa_thread_mq thread_mq;
569 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->sink), SINK_MESSAGE_POST, NULL, 0, &memchunk, NULL);
861 pa_thread_mq_install(&u->thread_mq);
881 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->msg), TUNNEL_MESSAGE_MAYBE_RESTART, u, 0, NULL, NULL);
882 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN);
2148 pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq);
2193 pa_source_set_asyncmsgq(u->source, u->thread_mq.inq);
2355 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) {
2570 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL);
2574 pa_thread_mq_done(&u->thread_mq);