Lines Matching refs:thread_mq
79 pa_thread_mq thread_mq; member
123 …pa_asyncmsgq_post(u->thread_mq.inq, PA_MSGOBJECT(u->sink), PA_SINK_MESSAGE_SET_RAOP_STATE, PA_INT_… in raop_state_cb()
411 pa_thread_mq_install(&u->thread_mq); in thread_func()
458 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->sink), in thread_func()
521 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->sink), in thread_func()
563 … pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->sink), PA_SINK_MESSAGE_DISCONNECT_REQUEST, in thread_func()
577 … pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->sink), PA_SINK_MESSAGE_DISCONNECT_REQUEST, in thread_func()
618 …pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->modu… in thread_func()
619 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
753 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa_raop_sink_new()
875 pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq); in pa_raop_sink_new()
925 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in userdata_free()
929 pa_thread_mq_done(&u->thread_mq); in userdata_free()