| /third_party/pulseaudio/src/modules/ |
| D | module-null-source.c | 67 pa_thread_mq thread_mq; member
142 pa_thread_mq_install(&u->thread_mq); in thread_func()
187 …pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->modu… in thread_func()
188 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
220 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
247 pa_source_set_asyncmsgq(u->source, u->thread_mq.inq); in pa__init()
288 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in pa__done()
292 pa_thread_mq_done(&u->thread_mq); in pa__done()
|
| D | module-sine-source.c | 61 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->modu… 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()
|
| D | module-pipe-source.c | 71 pa_thread_mq thread_mq; member
130 pa_thread_mq_install(&u->thread_mq); in thread_func()
200 …pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->modu… in thread_func()
201 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
236 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
296 pa_source_set_asyncmsgq(u->source, u->thread_mq.inq); in pa__init()
346 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in pa__done()
350 pa_thread_mq_done(&u->thread_mq); in pa__done()
|
| D | module-tunnel-sink-new.c | 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()
[all …]
|
| D | module-tunnel-source-new.c | 71 pa_thread_mq *thread_mq; member
198 pa_thread_mq_install(u->thread_mq); in thread_func()
239 …pa_asyncmsgq_post(u->thread_mq->outq, PA_MSGOBJECT(u->module->core), PA_CORE_MESSAGE_UNLOAD_MODULE… in thread_func()
240 pa_asyncmsgq_wait_for(u->thread_mq->inq, PA_MESSAGE_SHUTDOWN); in thread_func()
512 u->thread_mq = pa_xnew0(pa_thread_mq, 1); in pa__init()
514 …if (pa_thread_mq_init_thread_mainloop(u->thread_mq, m->core->mainloop, u->thread_mainloop_api) < 0… in pa__init()
561 pa_source_set_asyncmsgq(u->source, u->thread_mq->inq); in pa__init()
599 pa_asyncmsgq_send(u->thread_mq->inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in pa__done()
603 if (u->thread_mq) { in pa__done()
604 pa_thread_mq_done(u->thread_mq); in pa__done()
[all …]
|
| D | module-pipe-sink.c | 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()
[all …]
|
| D | module-null-sink.c | 69 pa_thread_mq thread_mq; member
252 pa_thread_mq_install(&u->thread_mq); in thread_func()
286 …pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->modu… in thread_func()
287 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
322 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
381 pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq); in pa__init()
446 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in pa__done()
450 pa_thread_mq_done(&u->thread_mq); in pa__done()
|
| D | module-esound-sink.c | 87 pa_thread_mq thread_mq; member
216 pa_thread_mq_install(&u->thread_mq); in thread_func()
338 …pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->modu… in thread_func()
339 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
395 …pa_asyncmsgq_post(u->thread_mq.inq, PA_MSGOBJECT(u->sink), SINK_MESSAGE_PASS_SOCKET, NULL, 0, NULL… in do_write()
577 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
628 pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq); in pa__init()
700 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in pa__done()
704 pa_thread_mq_done(&u->thread_mq); in pa__done()
|
| D | module-waveout.c | 75 pa_thread_mq thread_mq; member
257 pa_thread_mq_install(&u->thread_mq); in thread_func()
294 …pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->modu… in thread_func()
295 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
731 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
737 pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq); in pa__init()
741 pa_source_set_asyncmsgq(u->source, u->thread_mq.inq); in pa__init()
781 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in pa__done()
784 pa_thread_mq_done(&u->thread_mq); in pa__done()
|
| D | module-zeroconf-publish.c | 128 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, … 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, NUL… 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, … 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()
|
| D | module-solaris.c | 89 pa_thread_mq thread_mq; member
655 pa_thread_mq_install(&u->thread_mq); in thread_func()
833 …pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->modu… in thread_func()
834 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
938 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
987 pa_source_set_asyncmsgq(u->source, u->thread_mq.inq); in pa__init()
1031 pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq); in pa__init()
1122 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in pa__done()
1126 pa_thread_mq_done(&u->thread_mq); in pa__done()
|
| D | module-combine-sink.c | 134 pa_thread_mq thread_mq; member
325 pa_thread_mq_install(&u->thread_mq); in thread_func()
365 …pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->modu… in thread_func()
366 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
1318 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
1446 pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq); in pa__init()
1562 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in pa__done()
1566 pa_thread_mq_done(&u->thread_mq); in pa__done()
|
| D | module-tunnel.c | 189 pa_thread_mq thread_mq; member
479 …pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->sink), SINK_MESSAGE_POST, NULL, 0, &memchunk,… in send_data()
714 pa_thread_mq_install(&u->thread_mq); in thread_func()
734 …pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->modu… in thread_func()
735 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
1986 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
2175 pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq); in pa__init()
2215 pa_source_set_asyncmsgq(u->source, u->thread_mq.inq); in pa__init()
2297 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in pa__done()
2301 pa_thread_mq_done(&u->thread_mq); in pa__done()
|
| /third_party/pulseaudio/src/modules/jack/ |
| D | module-jack-source.c | 73 pa_thread_mq thread_mq; member
120 …pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->modu… in source_process_msg()
193 pa_thread_mq_install(&u->thread_mq); in thread_func()
208 …pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->modu… in thread_func()
209 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
277 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
365 pa_source_set_asyncmsgq(u->source, u->thread_mq.inq); in pa__init()
446 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in pa__done()
450 pa_thread_mq_done(&u->thread_mq); in pa__done()
|
| D | module-jack-sink.c | 85 pa_thread_mq thread_mq; member
163 …pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->modu… in sink_process_msg()
230 pa_thread_mq_install(&u->thread_mq); in thread_func()
248 …pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->modu… in thread_func()
249 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
329 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
423 pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq); in pa__init()
506 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in pa__done()
510 pa_thread_mq_done(&u->thread_mq); in pa__done()
|
| /third_party/pulseaudio/src/modules/raop/ |
| D | raop-sink.c | 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()
[all …]
|
| /third_party/pulseaudio/src/pulsecore/ |
| D | thread-mq.c | 35 PA_STATIC_TLS_DECLARE_NO_FREE(thread_mq);
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/ |
| D | module-coreaudio-device.c | 82 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,… 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/ |
| D | module-oss.c | 107 pa_thread_mq thread_mq; member
904 pa_thread_mq_install(&u->thread_mq); in thread_func()
1164 …pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->modu… in thread_func()
1165 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
1282 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
1360 pa_source_set_asyncmsgq(u->source, u->thread_mq.inq); in pa__init()
1430 pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq); in pa__init()
1540 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in pa__done()
1544 pa_thread_mq_done(&u->thread_mq); in pa__done()
|
| /third_party/pulseaudio/src/modules/bluetooth/ |
| D | module-bluez5-device.c | 118 pa_thread_mq thread_mq; member
1371 pa_thread_mq_install(&u->thread_mq); in thread_func()
1593 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
1608 if (pa_thread_mq_init(&u->thread_mq, u->core->mainloop, u->rtpoll) < 0) { in start_thread()
1619 pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq); in start_thread()
1634 pa_source_set_asyncmsgq(u->source, u->thread_mq.inq); in start_thread()
1663 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in stop_thread()
1676 pa_thread_mq_done(&u->thread_mq); in stop_thread()
|
| /third_party/pulseaudio/src/modules/alsa/ |
| D | alsa-source.c | 88 pa_thread_mq thread_mq; member
1633 pa_thread_mq_install(&u->thread_mq); in thread_func()
1767 …pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->modu… in thread_func()
1768 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
2075 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa_alsa_source_new()
2324 pa_source_set_asyncmsgq(u->source, u->thread_mq.inq); in pa_alsa_source_new()
2415 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in userdata_free()
2419 pa_thread_mq_done(&u->thread_mq); in userdata_free()
|
| D | alsa-sink.c | 100 pa_thread_mq thread_mq; member
1899 pa_thread_mq_install(&u->thread_mq); in thread_func()
2061 …pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->modu… in thread_func()
2062 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in thread_func()
2378 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa_alsa_sink_new()
2638 pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq); in pa_alsa_sink_new()
2768 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in userdata_free()
2772 pa_thread_mq_done(&u->thread_mq); in userdata_free()
|