| /third_party/pulseaudio/src/modules/ |
| H A D | module-null-source.c | 40 #include <pulsecore/rtpoll.h>
69 pa_rtpoll *rtpoll; member
175 pa_rtpoll_set_timer_absolute(u->rtpoll, u->timestamp + u->block_usec); in thread_func()
177 pa_rtpoll_set_timer_disabled(u->rtpoll); in thread_func()
180 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) in thread_func()
183 timer_elapsed = pa_rtpoll_timer_elapsed(u->rtpoll); in thread_func()
224 u->rtpoll = pa_rtpoll_new(); in pa__init()
226 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
254 pa_source_set_rtpoll(u->source, u->rtpoll); in pa__init()
310 if (u->rtpoll) in pa__done()
[all...] |
| H A D | module-sine-source.c | 40 #include <pulsecore/rtpoll.h>
62 pa_rtpoll *rtpoll; member
178 pa_rtpoll_set_timer_absolute(u->rtpoll, u->timestamp); in thread_func()
180 pa_rtpoll_set_timer_disabled(u->rtpoll); in thread_func()
183 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) in thread_func()
232 u->rtpoll = pa_rtpoll_new(); in pa__init()
234 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
273 pa_source_set_rtpoll(u->source, u->rtpoll); in pa__init()
329 if (u->rtpoll) in pa__done()
330 pa_rtpoll_free(u->rtpoll); in pa__done()
[all...] |
| H A D | module-pipe-source.c | 46 #include <pulsecore/rtpoll.h>
72 pa_rtpoll *rtpoll; member
181 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) in thread_func()
232 u->rtpoll = pa_rtpoll_new(); in pa__init()
234 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
295 pa_source_set_rtpoll(u->source, u->rtpoll); in pa__init()
298 u->rtpoll_item = pa_rtpoll_item_new(u->rtpoll, PA_RTPOLL_NEVER, 1); in pa__init()
359 if (u->rtpoll) in pa__done()
360 pa_rtpoll_free(u->rtpoll); in pa__done()
|
| H A D | module-null-sink.c | 43 #include <pulsecore/rtpoll.h>
70 pa_rtpoll *rtpoll; member
293 pa_rtpoll_set_timer_absolute(u->rtpoll, u->timestamp); in thread_func()
295 pa_rtpoll_set_timer_disabled(u->rtpoll); in thread_func()
298 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) in thread_func()
342 u->rtpoll = pa_rtpoll_new(); in pa__init()
345 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
405 pa_sink_set_rtpoll(u->sink, u->rtpoll); in pa__init()
476 if (u->rtpoll) in pa__done()
477 pa_rtpoll_free(u->rtpoll); in pa__done()
[all...] |
| H A D | module-pipe-sink.c | 49 #include <pulsecore/rtpoll.h>
77 pa_rtpoll *rtpoll; member
338 pa_rtpoll_set_timer_absolute(u->rtpoll, u->timestamp); in thread_func_use_timing()
340 pa_rtpoll_set_timer_disabled(u->rtpoll); in thread_func_use_timing()
343 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) in thread_func_use_timing()
391 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) in thread_func()
444 u->rtpoll = pa_rtpoll_new(); in pa__init()
451 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
525 pa_sink_set_rtpoll(u->sink, u->rtpoll); in pa__init()
540 u->rtpoll_item = pa_rtpoll_item_new(u->rtpoll, PA_RTPOLL_NEVE in pa__init()
[all...] |
| H A D | module-esound-sink.c | 71 #include <pulsecore/rtpoll.h>
94 pa_rtpoll *rtpoll; member
174 u->rtpoll_item = pa_rtpoll_item_new(u->rtpoll, PA_RTPOLL_NEVER, 1); in sink_process_msg()
356 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) in thread_func()
618 u->rtpoll = pa_rtpoll_new(); in pa__init()
620 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
672 pa_sink_set_rtpoll(u->sink, u->rtpoll); in pa__init()
758 if (u->rtpoll) in pa__done()
759 pa_rtpoll_free(u->rtpoll); in pa__done()
|
| H A D | module-virtual-source.c | 37 #include <pulsecore/rtpoll.h>
41 #include <pulsecore/rtpoll.h>
81 pa_rtpoll *rtpoll; member
383 pa_source_set_rtpoll(u->source, o->source->thread_info.rtpoll); in source_output_attach_cb()
547 /* The rtpoll created here is never run. It is only necessary to avoid crashes in pa__init()
549 * module-combine-sink. Both modules base their asyncmsq on the rtpoll provided in pa__init()
552 u->rtpoll = pa_rtpoll_new(); in pa__init()
681 pa_sink_set_rtpoll(u->sink, u->rtpoll); in pa__init()
754 if (u->rtpoll) in pa__done()
755 pa_rtpoll_free(u->rtpoll); in pa__done()
[all...] |
| H A D | module-waveout.c | 78 pa_rtpoll *rtpoll; member
281 pa_rtpoll_set_timer_relative(u->rtpoll, u->poll_timeout); in thread_func()
283 pa_rtpoll_set_timer_disabled(u->rtpoll); in thread_func()
286 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) in thread_func()
796 u->rtpoll = pa_rtpoll_new(); in pa__init()
798 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
805 pa_sink_set_rtpoll(u->sink, u->rtpoll); in pa__init()
809 pa_source_set_rtpoll(u->source, u->rtpoll); in pa__init()
858 if (u->rtpoll) in pa__done()
859 pa_rtpoll_free(u->rtpoll); in pa__done()
[all...] |
| H A D | module-solaris.c | 61 #include <pulsecore/rtpoll.h>
95 pa_rtpoll *rtpoll; member
241 u->rtpoll_item = pa_rtpoll_item_new(u->rtpoll, PA_RTPOLL_NEVER, 1); in build_pollfd()
773 pa_rtpoll_set_timer_absolute(u->rtpoll, xtime0 + PA_MIN(xsleep_interval, ysleep_interval)); in thread_func()
775 pa_rtpoll_set_timer_disabled(u->rtpoll); in thread_func()
840 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) in thread_func()
973 u->rtpoll = pa_rtpoll_new(); in pa__init()
975 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
1025 pa_source_set_rtpoll(u->source, u->rtpoll); in pa__init()
1069 pa_sink_set_rtpoll(u->sink, u->rtpoll); in pa__init()
[all...] |
| H A D | module-tunnel-sink-new.c | 43 #include <pulsecore/rtpoll.h>
100 pa_rtpoll *rtpoll; member
608 pa_sink_set_rtpoll(u->sink, u->rtpoll); in create_sink()
699 /* The rtpoll created here is never run. It is only necessary to avoid crashes in do_init()
701 * module-combine-sink. Both modules base their asyncmsq on the rtpoll provided in do_init()
703 * pa_asyncmsq_process_one() themselves. module_rtp_recv also uses the rtpoll, in do_init()
706 u->rtpoll = pa_rtpoll_new(); in do_init()
798 if (u->rtpoll) in do_done()
799 pa_rtpoll_free(u->rtpoll); in do_done()
|
| H A D | module-tunnel-source-new.c | 43 #include <pulsecore/rtpoll.h>
98 pa_rtpoll *rtpoll; member
580 pa_source_set_rtpoll(u->source, u->rtpoll); in create_source()
671 /* The rtpoll created here is never run. It is only necessary to avoid crashes in do_init()
673 * module-loopback bases the asyncmsq on the rtpoll provided by the source and in do_init()
675 u->rtpoll = pa_rtpoll_new(); in do_init()
767 if (u->rtpoll) in do_done()
768 pa_rtpoll_free(u->rtpoll); in do_done()
|
| H A D | module-combine-sink.c | 45 #include <pulsecore/rtpoll.h>
151 pa_rtpoll *rtpoll; member
456 pa_rtpoll_set_timer_absolute(u->rtpoll, u->thread_info.timestamp); in thread_func()
459 pa_rtpoll_set_timer_disabled(u->rtpoll); in thread_func()
464 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) { in thread_func()
654 i->sink->thread_info.rtpoll, in sink_input_attach_cb()
659 i->sink->thread_info.rtpoll, in sink_input_attach_cb()
664 i->sink->thread_info.rtpoll, in sink_input_attach_cb()
969 o->userdata->rtpoll,
973 o->userdata->rtpoll,
[all...] |
| /third_party/pulseaudio/src/modules/raop/ |
| H A D | raop-sink.c | 61 #include <pulsecore/rtpoll.h>
85 pa_rtpoll *rtpoll; member
218 u->oob = pa_raop_client_register_pollfd(u->raop, u->rtpoll, &u->rtpoll_item); in sink_process_msg()
230 pa_rtpoll_set_timer_absolute(u->rtpoll, now); in sink_process_msg()
234 pa_rtpoll_set_timer_disabled(u->rtpoll); in sink_process_msg()
265 pa_rtpoll_set_timer_disabled(u->rtpoll); in sink_process_msg()
273 pa_rtpoll_set_timer_disabled(u->rtpoll); in sink_process_msg()
322 pa_rtpoll_set_timer_disabled(u->rtpoll); in sink_set_state_in_io_thread_cb()
346 pa_rtpoll_set_timer_absolute(u->rtpoll, now); in sink_set_state_in_io_thread_cb()
355 pa_rtpoll_set_timer_absolute(u->rtpoll, no in sink_set_state_in_io_thread_cb()
[all...] |
| /third_party/pulseaudio/src/modules/jack/ |
| H A D | module-jack-sink.c | 44 #include <pulsecore/rtpoll.h>
91 pa_rtpoll *rtpoll; member
242 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) in thread_func()
333 u->rtpoll = pa_rtpoll_new(); in pa__init()
335 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
352 u->rtpoll_item = pa_rtpoll_item_new_asyncmsgq_read(u->rtpoll, PA_RTPOLL_EARLY-1, u->jack_msgq); in pa__init()
441 pa_sink_set_rtpoll(u->sink, u->rtpoll); in pa__init()
538 if (u->rtpoll) in pa__done()
539 pa_rtpoll_free(u->rtpoll); in pa__done()
|
| H A D | module-jack-source.c | 44 #include <pulsecore/rtpoll.h>
79 pa_rtpoll *rtpoll; member
202 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) in thread_func()
281 u->rtpoll = pa_rtpoll_new(); in pa__init()
283 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
294 u->rtpoll_item = pa_rtpoll_item_new_asyncmsgq_read(u->rtpoll, PA_RTPOLL_EARLY-1, u->jack_msgq); in pa__init()
383 pa_source_set_rtpoll(u->source, u->rtpoll); in pa__init()
478 if (u->rtpoll) in pa__done()
479 pa_rtpoll_free(u->rtpoll); in pa__done()
|
| /third_party/pulseaudio/src/pulsecore/ |
| H A D | thread-mq.h | 25 #include <pulsecore/rtpoll.h>
39 int pa_thread_mq_init(pa_thread_mq *q, pa_mainloop_api *mainloop, pa_rtpoll *rtpoll);
|
| H A D | rtpoll.c | 43 #include "rtpoll.h"
70 pa_rtpoll *rtpoll; member
156 p = i->rtpoll; in rtpoll_item_destroy()
234 pa_log("rtpoll finish"); in pa_rtpoll_run()
245 pa_log("rtpoll finish"); in pa_rtpoll_run()
281 pa_log("rtpoll finish"); in pa_rtpoll_run()
417 i->rtpoll = p; in pa_rtpoll_item_new()
450 if (i->rtpoll->running) { in pa_rtpoll_item_free()
452 i->rtpoll->scan_for_dead = true; in pa_rtpoll_item_free()
463 if (i->rtpoll in pa_rtpoll_item_get_pollfd()
[all...] |
| H A D | thread-mq.c | 136 int pa_thread_mq_init(pa_thread_mq *q, pa_mainloop_api *mainloop, pa_rtpoll *rtpoll) { in pa_thread_mq_init() argument
159 pa_rtpoll_item_new_asyncmsgq_read(rtpoll, PA_RTPOLL_EARLY, q->inq); in pa_thread_mq_init()
160 pa_rtpoll_item_new_asyncmsgq_write(rtpoll, PA_RTPOLL_LATE, q->outq); in pa_thread_mq_init()
|
| /third_party/pulseaudio/src/modules/rtp/ |
| H A D | rtp.h | 28 #include <pulsecore/rtpoll.h>
45 pa_rtpoll_item* pa_rtp_context_get_rtpoll_item(pa_rtp_context *c, pa_rtpoll *rtpoll);
|
| /third_party/pulseaudio/src/modules/alsa/ |
| H A D | alsa-util.h | 30 #include <pulsecore/rtpoll.h>
130 pa_rtpoll_item* pa_alsa_build_pollfd(snd_pcm_t *pcm, pa_rtpoll *rtpoll);
|
| H A D | alsa-sink.c | 54 #include <pulsecore/rtpoll.h>
110 pa_rtpoll *rtpoll; member
1058 if (!(u->alsa_rtpoll_item = pa_alsa_build_pollfd(u->pcm_handle, u->rtpoll))) in build_pollfd()
1993 bool on_timeout = pa_rtpoll_timer_elapsed(u->rtpoll); in thread_func()
2079 pa_rtpoll_set_timer_relative(u->rtpoll, rtpoll_sleep); in thread_func()
2083 pa_rtpoll_set_timer_disabled(u->rtpoll); in thread_func()
2086 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) in thread_func()
2305 if (pa_alsa_set_mixer_rtpoll(u->mixer_pd, u->mixer_handle, u->rtpoll) < 0) { in setup_mixer()
2463 u->rtpoll = pa_rtpoll_new(); in pa_alsa_sink_new()
2465 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < in pa_alsa_sink_new()
[all...] |
| H A D | alsa-source.c | 49 #include <pulsecore/rtpoll.h>
98 pa_rtpoll *rtpoll; member
980 if (!(u->alsa_rtpoll_item = pa_alsa_build_pollfd(u->pcm_handle, u->rtpoll))) in build_pollfd()
1720 bool on_timeout = pa_rtpoll_timer_elapsed(u->rtpoll); in thread_func()
1783 pa_rtpoll_set_timer_relative(u->rtpoll, rtpoll_sleep); in thread_func()
1787 pa_rtpoll_set_timer_disabled(u->rtpoll); in thread_func()
1790 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) in thread_func()
2009 if (pa_alsa_set_mixer_rtpoll(u->mixer_pd, u->mixer_handle, u->rtpoll) < 0) { in setup_mixer()
2154 u->rtpoll = pa_rtpoll_new(); in pa_alsa_source_new()
2156 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < in pa_alsa_source_new()
[all...] |
| /third_party/pulseaudio/src/modules/macosx/ |
| H A D | module-coreaudio-device.c | 85 pa_rtpoll *rtpoll; member
505 pa_sink_set_rtpoll(sink, u->rtpoll); in ca_device_create_sink()
639 pa_source_set_rtpoll(source, u->rtpoll); in ca_device_create_source()
739 ret = pa_rtpoll_run(u->rtpoll); in thread_func()
841 u->rtpoll = pa_rtpoll_new(); in pa__init()
843 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
854 pa_rtpoll_item_new_asyncmsgq_read(u->rtpoll, PA_RTPOLL_EARLY-1, u->async_msgq); in pa__init()
981 pa_rtpoll_free(u->rtpoll); in pa__done()
|
| /third_party/pulseaudio/src/modules/oss/ |
| H A D | module-oss.c | 65 #include <pulsecore/rtpoll.h>
108 pa_rtpoll *rtpoll; member
484 u->rtpoll_item = pa_rtpoll_item_new(u->rtpoll, PA_RTPOLL_NEVER, 1); in build_pollfd()
1136 pa_rtpoll_set_timer_relative(u->rtpoll, 1000000); in thread_func()
1139 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) { in thread_func()
1291 u->rtpoll = pa_rtpoll_new(); in pa__init()
1293 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
1372 pa_source_set_rtpoll(u->source, u->rtpoll); in pa__init()
1442 pa_sink_set_rtpoll(u->sink, u->rtpoll); in pa__init()
1570 if (u->rtpoll) in pa__done()
[all...] |
| /third_party/pulseaudio/src/modules/bluetooth/ |
| H A D | module-bluez5-device.c | 44 #include <pulsecore/rtpoll.h>
134 pa_rtpoll *rtpoll; member
759 u->rtpoll_item = pa_rtpoll_item_new(u->rtpoll, PA_RTPOLL_NEVER, 1); in setup_stream()
1675 pa_rtpoll_set_timer_relative(u->rtpoll, sleep_for); in thread_func()
1687 pa_rtpoll_set_timer_disabled(u->rtpoll); in thread_func()
1689 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) { in thread_func()
1715 pa_assert(!u->rtpoll); in start_thread()
1718 u->rtpoll = pa_rtpoll_new(); in start_thread()
1720 if (pa_thread_mq_init(&u->thread_mq, u->core->mainloop, u->rtpoll) < 0) { in start_thread()
1732 pa_sink_set_rtpoll(u->sink, u->rtpoll); in start_thread()
[all...] |