Searched refs:thread_mq (Results 1 – 5 of 5) sorted by relevance
| /ohos5.0/foundation/multimedia/audio_framework/frameworks/native/pulseaudio/modules/capturer/ |
| H A D | module_inner_capturer_sink.c | 75 pa_thread_mq thread_mq; member
303 pa_thread_mq_install(&u->thread_mq); in ThreadFunc()
343 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), in ThreadFunc()
345 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in ThreadFunc()
436 mq = pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll); in pa__init()
443 pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq); in pa__init()
497 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in pa__done()
501 pa_thread_mq_done(&u->thread_mq); in pa__done()
|
| /ohos5.0/foundation/multimedia/audio_framework/frameworks/native/pulseaudio/modules/hdi/ |
| H A D | hdi_source.c | 72 pa_thread_mq thread_mq; member
118 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in UserdataFree()
122 pa_thread_mq_done(&u->thread_mq); in UserdataFree()
310 pa_thread_mq_install(&u->thread_mq); in ThreadFuncCapturerTimer()
332 …pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->modu… in ThreadFuncCapturerTimer()
334 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in ThreadFuncCapturerTimer()
424 pa_source_set_asyncmsgq(u->source, u->thread_mq.inq); in PaSetSourceProperties()
534 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in PaHdiSourceNew()
|
| H A D | module_split_stream_sink.c | 100 pa_thread_mq thread_mq; member
752 pa_thread_mq_install(&u->thread_mq); in ThreadFunc()
785 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), in ThreadFunc()
787 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in ThreadFunc()
994 pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq); in PaHdiSinkNewInit()
1066 mq = pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll); 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()
|
| H A D | sink_userdata.h | 49 pa_thread_mq thread_mq; member
|
| H A D | hdi_sink.c | 525 if (u->thread_mq.inq) { in OffloadCallback()
526 pa_asyncmsgq_post(u->thread_mq.inq, NULL, 0, NULL, 0, NULL, NULL); in OffloadCallback()
3232 pa_thread_mq_install(&u->thread_mq); in ThreadFuncRendererTimerBus()
3265 … pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, in ThreadFuncRendererTimerBus()
3267 pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); in ThreadFuncRendererTimerBus()
4019 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in PaHdiSinkNewInitUserData()
4090 pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq); in PaHdiSinkNewInitUserDataAndSink()
4225 pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); in UserdataFreeThread()
4254 pa_thread_mq_done(&u->thread_mq); in UserdataFreeThread()
|