Lines Matching refs:thread_mq
73 pa_thread_mq *thread_mq; member
149 pa_thread_mq_install(u->thread_mq); in thread_func()
224 …pa_asyncmsgq_post(u->thread_mq->outq, PA_MSGOBJECT(u->module->core), PA_CORE_MESSAGE_UNLOAD_MODULE… in thread_func()
225 pa_asyncmsgq_wait_for(u->thread_mq->inq, PA_MESSAGE_SHUTDOWN); in thread_func()
513 u->thread_mq = pa_xnew0(pa_thread_mq, 1); in pa__init()
515 …if (pa_thread_mq_init_thread_mainloop(u->thread_mq, m->core->mainloop, u->thread_mainloop_api) < 0… in pa__init()
567 pa_sink_set_asyncmsgq(u->sink, u->thread_mq->inq); in pa__init()
605 pa_asyncmsgq_send(u->thread_mq->inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in pa__done()
609 if (u->thread_mq) { in pa__done()
610 pa_thread_mq_done(u->thread_mq); in pa__done()
611 pa_xfree(u->thread_mq); in pa__done()