Lines Matching defs:thread_mq
84 pa_thread_mq thread_mq;
132 pa_asyncmsgq_post(u->thread_mq.inq, PA_MSGOBJECT(u->sink), PA_SINK_MESSAGE_SET_RAOP_STATE, PA_INT_TO_PTR(state), 0, NULL, NULL);
434 pa_thread_mq_install(&u->thread_mq);
488 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->sink),
551 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->sink),
593 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->sink), PA_SINK_MESSAGE_DISCONNECT_REQUEST,
607 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->sink), PA_SINK_MESSAGE_DISCONNECT_REQUEST,
652 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->module, 0, NULL, NULL);
653 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN);
787 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) {
912 pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq);
962 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL);
966 pa_thread_mq_done(&u->thread_mq);