Home
last modified time | relevance | path

Searched refs:thread_mq (Results 1 - 22 of 22) sorted by relevance

/third_party/pulseaudio/src/modules/
H A Dmodule-sine-source.c61 pa_thread_mq thread_mq; member
163 pa_thread_mq_install(&u->thread_mq); in thread_func()
193 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->module, 0, NULL, NULL); in thread_func()
194 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
234 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
272 pa_source_set_asyncmsgq(u->source, u->thread_mq.inq); in pa__init()
317 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in pa__done()
321 pa_thread_mq_done(&u->thread_mq); in pa__done()
H A Dmodule-null-source.c68 pa_thread_mq thread_mq; member
147 pa_thread_mq_install(&u->thread_mq); in thread_func()
192 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->module, 0, NULL, NULL); in thread_func()
193 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
226 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
253 pa_source_set_asyncmsgq(u->source, u->thread_mq.inq); in pa__init()
301 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in pa__done()
305 pa_thread_mq_done(&u->thread_mq); in pa__done()
H A Dmodule-pipe-source.c71 pa_thread_mq thread_mq; member
130 pa_thread_mq_install(&u->thread_mq); in thread_func()
198 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->module, 0, NULL, NULL); in thread_func()
199 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
234 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
294 pa_source_set_asyncmsgq(u->source, u->thread_mq.inq); in pa__init()
344 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in pa__done()
348 pa_thread_mq_done(&u->thread_mq); in pa__done()
H A Dmodule-tunnel-sink-new.c94 pa_thread_mq *thread_mq; member
186 pa_thread_mq_install(u->thread_mq); in thread_func()
264 pa_asyncmsgq_post(u->thread_mq->outq, PA_MSGOBJECT(u->msg), TUNNEL_MESSAGE_MAYBE_RESTART, u, 0, NULL, NULL); in thread_func()
265 pa_asyncmsgq_wait_for(u->thread_mq->inq, PA_MESSAGE_SHUTDOWN); in thread_func()
444 pa_asyncmsgq_post(u->thread_mq->outq, PA_MSGOBJECT(u->msg), TUNNEL_MESSAGE_CREATE_SINK_REQUEST, u, 0, NULL, NULL); in context_state_cb()
607 pa_sink_set_asyncmsgq(u->sink, u->thread_mq->inq); in create_sink()
689 u->thread_mq = pa_xnew0(pa_thread_mq, 1); in do_init()
691 if (pa_thread_mq_init_thread_mainloop(u->thread_mq, m->core->mainloop, u->thread_mainloop_api) < 0) { in do_init()
774 pa_asyncmsgq_send(u->thread_mq->inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in do_done()
778 if (u->thread_mq) { in do_done()
[all...]
H A Dmodule-tunnel-source-new.c92 pa_thread_mq *thread_mq; member
234 pa_thread_mq_install(u->thread_mq); in thread_func()
278 pa_asyncmsgq_post(u->thread_mq->outq, PA_MSGOBJECT(u->msg), TUNNEL_MESSAGE_MAYBE_RESTART, u, 0, NULL, NULL); in thread_func()
279 pa_asyncmsgq_wait_for(u->thread_mq->inq, PA_MESSAGE_SHUTDOWN); in thread_func()
418 pa_asyncmsgq_post(u->thread_mq->outq, PA_MSGOBJECT(u->msg), TUNNEL_MESSAGE_CREATE_SOURCE_REQUEST, u, 0, NULL, NULL); in context_state_cb()
579 pa_source_set_asyncmsgq(u->source, u->thread_mq->inq); in create_source()
661 u->thread_mq = pa_xnew0(pa_thread_mq, 1); in do_init()
663 if (pa_thread_mq_init_thread_mainloop(u->thread_mq, m->core->mainloop, u->thread_mainloop_api) < 0) { in do_init()
743 pa_asyncmsgq_send(u->thread_mq->inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in do_done()
747 if (u->thread_mq) { in do_done()
[all...]
H A Dmodule-pipe-sink.c76 pa_thread_mq thread_mq; member
319 pa_thread_mq_install(&u->thread_mq); in thread_func_use_timing()
353 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->module, 0, NULL, NULL); in thread_func_use_timing()
354 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func_use_timing()
367 pa_thread_mq_install(&u->thread_mq); in thread_func()
408 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->module, 0, NULL, NULL); in thread_func()
409 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
451 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
524 pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq); in pa__init()
586 pa_asyncmsgq_send(u->thread_mq in pa__done()
[all...]
H A Dmodule-null-sink.c69 pa_thread_mq thread_mq; member
274 pa_thread_mq_install(&u->thread_mq); in thread_func()
308 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->module, 0, NULL, NULL); in thread_func()
309 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
345 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
404 pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq); in pa__init()
467 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in pa__done()
471 pa_thread_mq_done(&u->thread_mq); in pa__done()
H A Dmodule-esound-sink.c93 pa_thread_mq thread_mq; member
238 pa_thread_mq_install(&u->thread_mq); in thread_func()
377 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->module, 0, NULL, NULL); in thread_func()
378 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
434 pa_asyncmsgq_post(u->thread_mq.inq, PA_MSGOBJECT(u->sink), SINK_MESSAGE_PASS_SOCKET, NULL, 0, NULL, NULL); in do_write()
620 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
671 pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq); in pa__init()
743 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in pa__done()
747 pa_thread_mq_done(&u->thread_mq); in pa__done()
H A Dmodule-waveout.c77 pa_thread_mq thread_mq; member
259 pa_thread_mq_install(&u->thread_mq); in thread_func()
296 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->module, 0, NULL, NULL); in thread_func()
297 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
798 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
804 pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq); in pa__init()
808 pa_source_set_asyncmsgq(u->source, u->thread_mq.inq); in pa__init()
848 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in pa__done()
851 pa_thread_mq_done(&u->thread_mq); in pa__done()
H A Dmodule-zeroconf-publish.c128 pa_thread_mq thread_mq; member
744 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->msg), AVAHI_MESSAGE_PUBLISH_ALL, u, 0, NULL, NULL); in client_callback()
794 pa_thread_mq_install(&u->thread_mq); in create_client()
806 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->msg), AVAHI_MESSAGE_SHUTDOWN_START, u, 0, NULL, NULL); in create_client()
829 if (pa_thread_mq_init(&u->thread_mq, u->core->mainloop, u->rtpoll) < 0) { in pa__init()
890 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->msg), AVAHI_MESSAGE_SHUTDOWN_COMPLETE, u, 0, NULL, NULL); in client_free()
907 pa_asyncmsgq_wait_for(u->thread_mq.outq, AVAHI_MESSAGE_SHUTDOWN_COMPLETE); in pa__done()
912 pa_thread_mq_done(&u->thread_mq); in pa__done()
H A Dmodule-solaris.c94 pa_thread_mq thread_mq; member
676 pa_thread_mq_install(&u->thread_mq); in thread_func()
864 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->module, 0, NULL, NULL); in thread_func()
865 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
975 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
1024 pa_source_set_asyncmsgq(u->source, u->thread_mq.inq); in pa__init()
1068 pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq); in pa__init()
1159 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in pa__done()
1163 pa_thread_mq_done(&u->thread_mq); in pa__done()
H A Dmodule-combine-sink.c150 pa_thread_mq thread_mq; member
436 pa_thread_mq_install(&u->thread_mq); in thread_func()
476 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->module, 0, NULL, NULL); in thread_func()
477 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
1497 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) {
1638 pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq);
1756 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL);
1760 pa_thread_mq_done(&u->thread_mq);
H A Dmodule-tunnel.c219 pa_thread_mq thread_mq; member
569 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->sink), SINK_MESSAGE_POST, NULL, 0, &memchunk, NULL); in send_data()
861 pa_thread_mq_install(&u->thread_mq); in thread_func()
881 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->msg), TUNNEL_MESSAGE_MAYBE_RESTART, u, 0, NULL, NULL); in thread_func()
882 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
2148 pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq); in create_sink()
2193 pa_source_set_asyncmsgq(u->source, u->thread_mq.inq); in create_source()
2355 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in do_init()
2570 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in do_done()
2574 pa_thread_mq_done(&u->thread_mq); in do_done()
[all...]
/third_party/pulseaudio/src/modules/jack/
H A Dmodule-jack-sink.c89 pa_thread_mq thread_mq; member
167 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->module, 0, NULL, NULL); in sink_process_msg()
234 pa_thread_mq_install(&u->thread_mq); in thread_func()
252 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->module, 0, NULL, NULL); in thread_func()
253 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
335 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
440 pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq); in pa__init()
523 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in pa__done()
527 pa_thread_mq_done(&u->thread_mq); in pa__done()
H A Dmodule-jack-source.c77 pa_thread_mq thread_mq; member
124 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->module, 0, NULL, NULL); in source_process_msg()
197 pa_thread_mq_install(&u->thread_mq); in thread_func()
212 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->module, 0, NULL, NULL); in thread_func()
213 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
283 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
382 pa_source_set_asyncmsgq(u->source, u->thread_mq.inq); in pa__init()
463 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in pa__done()
467 pa_thread_mq_done(&u->thread_mq); in pa__done()
/third_party/pulseaudio/src/modules/raop/
H A Draop-sink.c84 pa_thread_mq thread_mq; member
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); in raop_state_cb()
434 pa_thread_mq_install(&u->thread_mq); in thread_func()
488 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->sink), in thread_func()
551 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->sink), in thread_func()
593 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->sink), PA_SINK_MESSAGE_DISCONNECT_REQUEST, in thread_func()
607 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->sink), PA_SINK_MESSAGE_DISCONNECT_REQUEST, in thread_func()
652 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->module, 0, NULL, NULL); in thread_func()
653 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
787 if (pa_thread_mq_init(&u->thread_mq, in pa_raop_sink_new()
[all...]
/third_party/pulseaudio/src/pulsecore/
H A Dthread-mq.c35 PA_STATIC_TLS_DECLARE_NO_FREE(thread_mq); variable
217 pa_assert(!(PA_STATIC_TLS_GET(thread_mq))); in pa_thread_mq_install()
218 PA_STATIC_TLS_SET(thread_mq, q); in pa_thread_mq_install()
222 return PA_STATIC_TLS_GET(thread_mq); in pa_thread_mq_get()
/third_party/pulseaudio/src/modules/macosx/
H A Dmodule-coreaudio-device.c82 pa_thread_mq thread_mq; member
504 pa_sink_set_asyncmsgq(sink, u->thread_mq.inq); in ca_device_create_sink()
638 pa_source_set_asyncmsgq(source, u->thread_mq.inq); in ca_device_create_source()
728 pa_thread_mq_install(&u->thread_mq); in thread_func()
751 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->module->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->module, 0, NULL, NULL); in thread_func()
752 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
843 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
936 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in pa__done()
938 pa_thread_mq_done(&u->thread_mq); in pa__done()
/third_party/pulseaudio/src/modules/oss/
H A Dmodule-oss.c107 pa_thread_mq thread_mq; member
905 pa_thread_mq_install(&u->thread_mq); in thread_func()
1176 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->module, 0, NULL, NULL); in thread_func()
1177 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
1293 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
1371 pa_source_set_asyncmsgq(u->source, u->thread_mq.inq); in pa__init()
1441 pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq); in pa__init()
1552 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in pa__done()
1556 pa_thread_mq_done(&u->thread_mq); in pa__done()
/third_party/pulseaudio/src/modules/bluetooth/
H A Dmodule-bluez5-device.c133 pa_thread_mq thread_mq; member
1443 pa_thread_mq_install(&u->thread_mq); in thread_func()
1705 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
1720 if (pa_thread_mq_init(&u->thread_mq, u->core->mainloop, u->rtpoll) < 0) { in start_thread()
1731 pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq); in start_thread()
1746 pa_source_set_asyncmsgq(u->source, u->thread_mq.inq); in start_thread()
1798 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in stop_thread()
1811 pa_thread_mq_done(&u->thread_mq); in stop_thread()
/third_party/pulseaudio/src/modules/alsa/
H A Dalsa-sink.c109 pa_thread_mq thread_mq; member
1974 pa_thread_mq_install(&u->thread_mq); in thread_func()
2144 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->module, 0, NULL, NULL); in thread_func()
2145 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
2465 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa_alsa_sink_new()
2746 pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq); in pa_alsa_sink_new()
2876 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in userdata_free()
2880 pa_thread_mq_done(&u->thread_mq); in userdata_free()
H A Dalsa-source.c97 pa_thread_mq thread_mq; member
1706 pa_thread_mq_install(&u->thread_mq); in thread_func()
1848 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->module, 0, NULL, NULL); in thread_func()
1849 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
2156 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa_alsa_source_new()
2411 pa_source_set_asyncmsgq(u->source, u->thread_mq.inq); in pa_alsa_source_new()
2502 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in userdata_free()
2506 pa_thread_mq_done(&u->thread_mq); in userdata_free()

Completed in 47 milliseconds