| /third_party/pulseaudio/src/modules/ |
| D | module-null-source.c | 68 pa_rtpoll *rtpoll; member
170 pa_rtpoll_set_timer_absolute(u->rtpoll, u->timestamp + u->block_usec); in thread_func()
172 pa_rtpoll_set_timer_disabled(u->rtpoll); in thread_func()
175 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) in thread_func()
178 timer_elapsed = pa_rtpoll_timer_elapsed(u->rtpoll); in thread_func()
218 u->rtpoll = pa_rtpoll_new(); in pa__init()
220 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
248 pa_source_set_rtpoll(u->source, u->rtpoll); in pa__init()
297 if (u->rtpoll) in pa__done()
298 pa_rtpoll_free(u->rtpoll); in pa__done()
|
| D | module-sine-source.c | 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()
|
| D | module-pipe-source.c | 72 pa_rtpoll *rtpoll; member
183 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) in thread_func()
234 u->rtpoll = pa_rtpoll_new(); in pa__init()
236 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
297 pa_source_set_rtpoll(u->source, u->rtpoll); in pa__init()
300 u->rtpoll_item = pa_rtpoll_item_new(u->rtpoll, PA_RTPOLL_NEVER, 1); in pa__init()
361 if (u->rtpoll) in pa__done()
362 pa_rtpoll_free(u->rtpoll); in pa__done()
|
| D | module-null-sink.c | 70 pa_rtpoll *rtpoll; member
271 pa_rtpoll_set_timer_absolute(u->rtpoll, u->timestamp); in thread_func()
273 pa_rtpoll_set_timer_disabled(u->rtpoll); in thread_func()
276 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) in thread_func()
320 u->rtpoll = pa_rtpoll_new(); in pa__init()
322 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
382 pa_sink_set_rtpoll(u->sink, u->rtpoll); in pa__init()
455 if (u->rtpoll) in pa__done()
456 pa_rtpoll_free(u->rtpoll); in pa__done()
|
| D | module-pipe-sink.c | 77 pa_rtpoll *rtpoll; member
341 pa_rtpoll_set_timer_absolute(u->rtpoll, u->timestamp); in thread_func_use_timing()
343 pa_rtpoll_set_timer_disabled(u->rtpoll); in thread_func_use_timing()
346 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) in thread_func_use_timing()
394 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) in thread_func()
447 u->rtpoll = pa_rtpoll_new(); in pa__init()
454 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
528 pa_sink_set_rtpoll(u->sink, u->rtpoll); in pa__init()
543 u->rtpoll_item = pa_rtpoll_item_new(u->rtpoll, PA_RTPOLL_NEVER, 1); in pa__init()
604 if (u->rtpoll) in pa__done()
[all …]
|
| D | module-esound-sink.c | 88 pa_rtpoll *rtpoll; member
159 u->rtpoll_item = pa_rtpoll_item_new(u->rtpoll, PA_RTPOLL_NEVER, 1); in sink_process_msg()
317 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) in thread_func()
575 u->rtpoll = pa_rtpoll_new(); in pa__init()
577 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
629 pa_sink_set_rtpoll(u->sink, u->rtpoll); in pa__init()
715 if (u->rtpoll) in pa__done()
716 pa_rtpoll_free(u->rtpoll); in pa__done()
|
| D | module-waveout.c | 76 pa_rtpoll *rtpoll; member
279 pa_rtpoll_set_timer_relative(u->rtpoll, u->poll_timeout); in thread_func()
281 pa_rtpoll_set_timer_disabled(u->rtpoll); in thread_func()
284 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) in thread_func()
729 u->rtpoll = pa_rtpoll_new(); in pa__init()
731 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
738 pa_sink_set_rtpoll(u->sink, u->rtpoll); in pa__init()
742 pa_source_set_rtpoll(u->source, u->rtpoll); in pa__init()
791 if (u->rtpoll) in pa__done()
792 pa_rtpoll_free(u->rtpoll); in pa__done()
|
| D | module-solaris.c | 90 pa_rtpoll *rtpoll; member
228 u->rtpoll_item = pa_rtpoll_item_new(u->rtpoll, PA_RTPOLL_NEVER, 1); in build_pollfd()
742 … pa_rtpoll_set_timer_absolute(u->rtpoll, xtime0 + PA_MIN(xsleep_interval, ysleep_interval)); in thread_func()
744 pa_rtpoll_set_timer_disabled(u->rtpoll); in thread_func()
809 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) in thread_func()
936 u->rtpoll = pa_rtpoll_new(); in pa__init()
938 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
988 pa_source_set_rtpoll(u->source, u->rtpoll); in pa__init()
1032 pa_sink_set_rtpoll(u->sink, u->rtpoll); in pa__init()
1140 if (u->rtpoll) in pa__done()
[all …]
|
| D | module-combine-sink.c | 135 pa_rtpoll *rtpoll; member
345 pa_rtpoll_set_timer_absolute(u->rtpoll, u->thread_info.timestamp); in thread_func()
348 pa_rtpoll_set_timer_disabled(u->rtpoll); in thread_func()
353 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) { in thread_func()
539 i->sink->thread_info.rtpoll, in sink_input_attach_cb()
544 i->sink->thread_info.rtpoll, in sink_input_attach_cb()
549 i->sink->thread_info.rtpoll, in sink_input_attach_cb()
822 o->userdata->rtpoll, in output_add_within_thread()
826 o->userdata->rtpoll, in output_add_within_thread()
830 o->userdata->rtpoll, in output_add_within_thread()
[all …]
|
| D | module-tunnel-sink-new.c | 79 pa_rtpoll *rtpoll; member
527 u->rtpoll = pa_rtpoll_new(); in pa__init()
568 pa_sink_set_rtpoll(u->sink, u->rtpoll); in pa__init()
629 if (u->rtpoll) in pa__done()
630 pa_rtpoll_free(u->rtpoll); in pa__done()
|
| D | module-tunnel-source-new.c | 77 pa_rtpoll *rtpoll; member
523 u->rtpoll = pa_rtpoll_new(); in pa__init()
562 pa_source_set_rtpoll(u->source, u->rtpoll); in pa__init()
623 if (u->rtpoll) in pa__done()
624 pa_rtpoll_free(u->rtpoll); in pa__done()
|
| D | module-virtual-source.c | 81 pa_rtpoll *rtpoll; member
380 pa_source_set_rtpoll(u->source, o->source->thread_info.rtpoll); in source_output_attach_cb()
549 u->rtpoll = pa_rtpoll_new(); in pa__init()
678 pa_sink_set_rtpoll(u->sink, u->rtpoll); in pa__init()
751 if (u->rtpoll) in pa__done()
752 pa_rtpoll_free(u->rtpoll); in pa__done()
|
| /third_party/pulseaudio/src/modules/raop/ |
| D | raop-sink.c | 80 pa_rtpoll *rtpoll; member
199 u->oob = pa_raop_client_register_pollfd(u->raop, u->rtpoll, &u->rtpoll_item); in sink_process_msg()
211 pa_rtpoll_set_timer_absolute(u->rtpoll, now); in sink_process_msg()
215 pa_rtpoll_set_timer_disabled(u->rtpoll); in sink_process_msg()
246 pa_rtpoll_set_timer_disabled(u->rtpoll); in sink_process_msg()
254 pa_rtpoll_set_timer_disabled(u->rtpoll); in sink_process_msg()
303 pa_rtpoll_set_timer_disabled(u->rtpoll); in sink_set_state_in_io_thread_cb()
323 pa_rtpoll_set_timer_absolute(u->rtpoll, now); in sink_set_state_in_io_thread_cb()
332 pa_rtpoll_set_timer_absolute(u->rtpoll, now); in sink_set_state_in_io_thread_cb()
424 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) in thread_func()
[all …]
|
| /third_party/pulseaudio/src/modules/jack/ |
| D | module-jack-source.c | 75 pa_rtpoll *rtpoll; member
198 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) in thread_func()
275 u->rtpoll = pa_rtpoll_new(); in pa__init()
277 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
288 u->rtpoll_item = pa_rtpoll_item_new_asyncmsgq_read(u->rtpoll, PA_RTPOLL_EARLY-1, u->jack_msgq); in pa__init()
366 pa_source_set_rtpoll(u->source, u->rtpoll); in pa__init()
461 if (u->rtpoll) in pa__done()
462 pa_rtpoll_free(u->rtpoll); in pa__done()
|
| D | module-jack-sink.c | 87 pa_rtpoll *rtpoll; member
238 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) in thread_func()
327 u->rtpoll = pa_rtpoll_new(); in pa__init()
329 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
346 u->rtpoll_item = pa_rtpoll_item_new_asyncmsgq_read(u->rtpoll, PA_RTPOLL_EARLY-1, u->jack_msgq); in pa__init()
424 pa_sink_set_rtpoll(u->sink, u->rtpoll); in pa__init()
521 if (u->rtpoll) in pa__done()
522 pa_rtpoll_free(u->rtpoll); in pa__done()
|
| /third_party/pulseaudio/src/pulsecore/ |
| D | rtpoll.c | 69 pa_rtpoll *rtpoll; member
155 p = i->rtpoll; in rtpoll_item_destroy()
410 i->rtpoll = p; in pa_rtpoll_item_new()
443 if (i->rtpoll->running) { in pa_rtpoll_item_free()
445 i->rtpoll->scan_for_dead = true; in pa_rtpoll_item_free()
456 if (i->rtpoll->rebuild_needed) in pa_rtpoll_item_get_pollfd()
457 rtpoll_rebuild(i->rtpoll); in pa_rtpoll_item_get_pollfd()
562 i->rtpoll->quit = true; in asyncmsgq_read_work()
|
| 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()
|
| D | thread-mq.h | 39 int pa_thread_mq_init(pa_thread_mq *q, pa_mainloop_api *mainloop, pa_rtpoll *rtpoll);
|
| /third_party/pulseaudio/src/modules/macosx/ |
| 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/ |
| D | module-oss.c | 108 pa_rtpoll *rtpoll; member
482 u->rtpoll_item = pa_rtpoll_item_new(u->rtpoll, PA_RTPOLL_NEVER, 1); in build_pollfd()
1140 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) in thread_func()
1280 u->rtpoll = pa_rtpoll_new(); in pa__init()
1282 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa__init()
1361 pa_source_set_rtpoll(u->source, u->rtpoll); in pa__init()
1431 pa_sink_set_rtpoll(u->sink, u->rtpoll); in pa__init()
1558 if (u->rtpoll) in pa__done()
1559 pa_rtpoll_free(u->rtpoll); in pa__done()
|
| /third_party/pulseaudio/src/modules/bluetooth/ |
| D | module-bluez5-device.c | 119 pa_rtpoll *rtpoll; member
836 u->rtpoll_item = pa_rtpoll_item_new(u->rtpoll, PA_RTPOLL_NEVER, 1); in setup_stream()
1563 pa_rtpoll_set_timer_relative(u->rtpoll, sleep_for); in thread_func()
1575 pa_rtpoll_set_timer_disabled(u->rtpoll); in thread_func()
1577 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) { in thread_func()
1603 pa_assert(!u->rtpoll); in start_thread()
1606 u->rtpoll = pa_rtpoll_new(); in start_thread()
1608 if (pa_thread_mq_init(&u->thread_mq, u->core->mainloop, u->rtpoll) < 0) { in start_thread()
1620 pa_sink_set_rtpoll(u->sink, u->rtpoll); in start_thread()
1635 pa_source_set_rtpoll(u->source, u->rtpoll); in start_thread()
[all …]
|
| /third_party/pulseaudio/src/modules/rtp/ |
| D | rtp.h | 45 pa_rtpoll_item* pa_rtp_context_get_rtpoll_item(pa_rtp_context *c, pa_rtpoll *rtpoll);
|
| /third_party/pulseaudio/src/modules/alsa/ |
| D | alsa-source.c | 89 pa_rtpoll *rtpoll; member
939 if (!(u->alsa_rtpoll_item = pa_alsa_build_pollfd(u->pcm_handle, u->rtpoll))) in build_pollfd()
1647 bool on_timeout = pa_rtpoll_timer_elapsed(u->rtpoll); in thread_func()
1702 pa_rtpoll_set_timer_relative(u->rtpoll, rtpoll_sleep); in thread_func()
1706 pa_rtpoll_set_timer_disabled(u->rtpoll); in thread_func()
1709 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) in thread_func()
1928 if (pa_alsa_set_mixer_rtpoll(u->mixer_pd, u->mixer_handle, u->rtpoll) < 0) { in setup_mixer()
2073 u->rtpoll = pa_rtpoll_new(); in pa_alsa_source_new()
2075 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa_alsa_source_new()
2325 pa_source_set_rtpoll(u->source, u->rtpoll); in pa_alsa_source_new()
[all …]
|
| D | alsa-sink.c | 101 pa_rtpoll *rtpoll; member
1024 if (!(u->alsa_rtpoll_item = pa_alsa_build_pollfd(u->pcm_handle, u->rtpoll))) in build_pollfd()
1918 bool on_timeout = pa_rtpoll_timer_elapsed(u->rtpoll); in thread_func()
1996 pa_rtpoll_set_timer_relative(u->rtpoll, rtpoll_sleep); in thread_func()
2000 pa_rtpoll_set_timer_disabled(u->rtpoll); in thread_func()
2003 if ((ret = pa_rtpoll_run(u->rtpoll)) < 0) in thread_func()
2222 if (pa_alsa_set_mixer_rtpoll(u->mixer_pd, u->mixer_handle, u->rtpoll) < 0) { in setup_mixer()
2376 u->rtpoll = pa_rtpoll_new(); in pa_alsa_sink_new()
2378 if (pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll) < 0) { in pa_alsa_sink_new()
2639 pa_sink_set_rtpoll(u->sink, u->rtpoll); in pa_alsa_sink_new()
[all …]
|
| /third_party/pulseaudio/src/ |
| D | .gitignore | 74 rtpoll-test
|