Lines Matching refs:thread_mq
76 pa_thread_mq thread_mq; member
322 pa_thread_mq_install(&u->thread_mq); in thread_func_use_timing()
356 …pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->modu… in thread_func_use_timing()
357 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func_use_timing()
370 pa_thread_mq_install(&u->thread_mq); in thread_func()
411 …pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->modu… in thread_func()
412 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
454 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
527 pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq); in pa__init()
589 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in pa__done()
593 pa_thread_mq_done(&u->thread_mq); in pa__done()