| /third_party/pulseaudio/src/tests/ |
| D | passthrough-test.c | 39 pa_threaded_mainloop_wait(mainloop); \
46 static pa_threaded_mainloop *mainloop = NULL; variable
66 pa_threaded_mainloop_signal(mainloop, false); in context_state_callback()
71 pa_threaded_mainloop_signal(mainloop, false); in context_state_callback()
76 pa_threaded_mainloop_signal(mainloop, false); in context_state_callback()
91 pa_threaded_mainloop_signal(mainloop, false); in module_index_cb()
97 pa_threaded_mainloop_signal(mainloop, false); in success_cb()
103 pa_threaded_mainloop_lock(mainloop); in passthrough_teardown()
113 pa_threaded_mainloop_unlock(mainloop); in passthrough_teardown()
115 pa_threaded_mainloop_stop(mainloop); in passthrough_teardown()
[all …]
|
| D | connect-stress.c | 55 static pa_threaded_mainloop *mainloop = NULL; variable
72 mainloop = pa_threaded_mainloop_new(); in _connect()
73 fail_unless(mainloop != NULL); in _connect()
75 api = pa_threaded_mainloop_get_api(mainloop); in _connect()
87 ret = pa_threaded_mainloop_start(mainloop); in _connect()
94 fail_unless(mainloop != NULL); in _disconnect()
97 pa_threaded_mainloop_lock(mainloop); in _disconnect()
109 pa_threaded_mainloop_unlock(mainloop); in _disconnect()
110 pa_threaded_mainloop_stop(mainloop); in _disconnect()
111 pa_threaded_mainloop_free(mainloop); in _disconnect()
[all …]
|
| /third_party/pulseaudio/src/pulse/ |
| D | simple.c | 39 pa_threaded_mainloop *mainloop; member
92 pa_threaded_mainloop_signal(p->mainloop, 0); in context_state_cb()
113 pa_threaded_mainloop_signal(p->mainloop, 0); in stream_state_cb()
126 pa_threaded_mainloop_signal(p->mainloop, 0); in stream_request_cb()
134 pa_threaded_mainloop_signal(p->mainloop, 0); in stream_latency_update_cb()
160 if (!(p->mainloop = pa_threaded_mainloop_new())) in pa_simple_new()
163 if (!(p->context = pa_context_new(pa_threaded_mainloop_get_api(p->mainloop), name))) in pa_simple_new()
173 pa_threaded_mainloop_lock(p->mainloop); in pa_simple_new()
175 if (pa_threaded_mainloop_start(p->mainloop) < 0) in pa_simple_new()
192 pa_threaded_mainloop_wait(p->mainloop); in pa_simple_new()
[all …]
|
| D | meson.build | 19 'mainloop-api.c',
20 'mainloop-signal.c',
21 'mainloop.c',
29 'thread-mainloop.c',
50 'mainloop-api.h',
51 'mainloop-signal.h',
52 'mainloop.h',
61 'thread-mainloop.h',
70 libpulse_headers += 'glib-mainloop.h'
109 libpulse_mainloop_glib = shared_library('pulse-mainloop-glib',
[all …]
|
| D | ohos_glib-mainloop.c | 36 pa_glib_mainloop *mainloop; member
50 pa_glib_mainloop *mainloop; member
64 pa_glib_mainloop *mainloop; member
229 e->mainloop = g; in glib_io_new()
260 e->mainloop->io_events_please_scan++; in glib_io_free()
263 g_source_remove_poll(&e->mainloop->source, &e->poll_fd); in glib_io_free()
293 e->mainloop = g; in glib_time_new()
322 g_assert(e->mainloop->n_enabled_time_events > 0); in glib_time_restart()
323 e->mainloop->n_enabled_time_events--; in glib_time_restart()
325 e->mainloop->n_enabled_time_events++; in glib_time_restart()
[all …]
|
| D | glib-mainloop.c | 35 pa_glib_mainloop *mainloop; member
49 pa_glib_mainloop *mainloop; member
63 pa_glib_mainloop *mainloop; member
228 e->mainloop = g; in glib_io_new()
259 e->mainloop->io_events_please_scan++; in glib_io_free()
262 g_source_remove_poll(&e->mainloop->source, &e->poll_fd); in glib_io_free()
292 e->mainloop = g; in glib_time_new()
321 g_assert(e->mainloop->n_enabled_time_events > 0); in glib_time_restart()
322 e->mainloop->n_enabled_time_events--; in glib_time_restart()
324 e->mainloop->n_enabled_time_events++; in glib_time_restart()
[all …]
|
| D | mainloop.c | 53 pa_mainloop *mainloop; member
68 pa_mainloop *mainloop; member
83 pa_mainloop *mainloop; member
167 e->mainloop = m; in mainloop_io_new()
196 e->mainloop->rebuild_pollfds = true; in mainloop_io_enable()
198 pa_mainloop_wakeup(e->mainloop); in mainloop_io_enable()
206 e->mainloop->io_events_please_scan ++; in mainloop_io_free()
208 e->mainloop->n_io_events --; in mainloop_io_free()
209 e->mainloop->rebuild_pollfds = true; in mainloop_io_free()
211 pa_mainloop_wakeup(e->mainloop); in mainloop_io_free()
[all …]
|
| /third_party/glib/glib/tests/ |
| D | unix.c | 145 GMainLoop *mainloop; in test_signal() local
148 mainloop = g_main_loop_new (NULL, FALSE); in test_signal()
152 g_unix_signal_add (signum, on_sig_received, mainloop); in test_signal()
155 id = g_timeout_add (5000, on_sig_timeout, mainloop); in test_signal()
156 g_main_loop_run (mainloop); in test_signal()
162 g_timeout_add (500, exit_mainloop, mainloop); in test_signal()
163 g_main_loop_run (mainloop); in test_signal()
168 g_unix_signal_add (signum, on_sig_received_2, mainloop); in test_signal()
169 g_unix_signal_add (signum, on_sig_received_2, mainloop); in test_signal()
170 id = g_timeout_add (5000, on_sig_timeout, mainloop); in test_signal()
[all …]
|
| /third_party/ffmpeg/libavdevice/ |
| D | pulse_audio_enc.c | 45 pa_threaded_mainloop *mainloop; member
63 pa_threaded_mainloop_signal(s->mainloop, 0); in pulse_audio_sink_device_cb()
84 pa_threaded_mainloop_wait(s->mainloop); in pulse_update_sink_info()
176 pa_threaded_mainloop_signal(s->mainloop, 0); in pulse_stream_writable()
202 pa_threaded_mainloop_signal(s->mainloop, 0); in pulse_stream_state()
215 pa_threaded_mainloop_wait(s->mainloop); in pulse_stream_wait()
231 pa_threaded_mainloop_signal(s->mainloop, 0); in pulse_context_state()
244 pa_threaded_mainloop_wait(s->mainloop); in pulse_context_wait()
257 pa_threaded_mainloop_signal(s->mainloop, 0); in pulse_stream_result()
263 pa_threaded_mainloop_unlock(s->mainloop); in pulse_finish_stream_operation()
[all …]
|
| D | pulse_audio_dec.c | 48 pa_threaded_mainloop *mainloop; member
83 pa_threaded_mainloop_signal(p->mainloop, 0); in context_state_cb()
95 pa_threaded_mainloop_signal(p->mainloop, 0); in stream_state_cb()
103 pa_threaded_mainloop_signal(p->mainloop, 0); in stream_request_cb()
109 pa_threaded_mainloop_signal(p->mainloop, 0); in stream_latency_update_cb()
116 if (pd->mainloop) in pulse_close()
117 pa_threaded_mainloop_stop(pd->mainloop); in pulse_close()
129 if (pd->mainloop) in pulse_close()
130 pa_threaded_mainloop_free(pd->mainloop); in pulse_close()
131 pd->mainloop = NULL; in pulse_close()
[all …]
|
| /third_party/gstreamer/gstplugins_good/ext/pulse/ |
| D | pulsesrc.c | 390 pa_threaded_mainloop_signal (pulsesrc->mainloop, 0); in gst_pulsesrc_source_info_cb()
399 if (!pulsesrc->mainloop) in gst_pulsesrc_device_description()
402 pa_threaded_mainloop_lock (pulsesrc->mainloop); in gst_pulsesrc_device_description()
418 pa_threaded_mainloop_wait (pulsesrc->mainloop); in gst_pulsesrc_device_description()
428 pa_threaded_mainloop_unlock (pulsesrc->mainloop); in gst_pulsesrc_device_description()
466 pa_threaded_mainloop_signal (psrc->mainloop, 0); in gst_pulsesrc_source_output_info_cb()
475 if (!pulsesrc->mainloop) in gst_pulsesrc_get_source_output_info()
481 pa_threaded_mainloop_lock (pulsesrc->mainloop); in gst_pulsesrc_get_source_output_info()
489 pa_threaded_mainloop_wait (pulsesrc->mainloop); in gst_pulsesrc_get_source_output_info()
504 pa_threaded_mainloop_unlock (pulsesrc->mainloop); in gst_pulsesrc_get_source_output_info()
[all …]
|
| D | pulsesink.c | 151 static pa_threaded_mainloop *mainloop = NULL; variable
285 pa_threaded_mainloop_wait (mainloop); in gst_pulse_destroy_stream()
423 pa_threaded_mainloop *mainloop = (pa_threaded_mainloop *) userdata; in gst_pulsering_context_state_cb() local
434 pa_threaded_mainloop_signal (mainloop, 0); in gst_pulsering_context_state_cb()
523 pa_threaded_mainloop_lock (mainloop); in gst_pulseringbuffer_open_device()
535 api = pa_threaded_mainloop_get_api (mainloop); in gst_pulseringbuffer_open_device()
544 gst_pulsering_context_state_cb, mainloop); in gst_pulseringbuffer_open_device()
583 pa_threaded_mainloop_wait (mainloop); in gst_pulseringbuffer_open_device()
593 pa_threaded_mainloop_unlock (mainloop); in gst_pulseringbuffer_open_device()
603 pa_threaded_mainloop_unlock (mainloop); in gst_pulseringbuffer_open_device()
[all …]
|
| D | pulsedeviceprovider.c | 185 pa_threaded_mainloop_signal (self->mainloop, 0); in context_state_cb()
246 pa_threaded_mainloop_signal (self->mainloop, 0); in get_source_info_cb()
309 pa_threaded_mainloop_signal (self->mainloop, 0); in get_server_info_cb()
320 pa_threaded_mainloop_signal (self->mainloop, 0); in get_sink_info_cb()
497 pa_threaded_mainloop_wait (self->mainloop); in run_pulse_operation()
510 if (!(self->mainloop = pa_threaded_mainloop_new ())) { in gst_pulse_device_provider_start()
514 if (pa_threaded_mainloop_start (self->mainloop) < 0) { in gst_pulse_device_provider_start()
516 pa_threaded_mainloop_free (self->mainloop); in gst_pulse_device_provider_start()
517 self->mainloop = NULL; in gst_pulse_device_provider_start()
521 pa_threaded_mainloop_lock (self->mainloop); in gst_pulse_device_provider_start()
[all …]
|
| /third_party/pulseaudio/src/modules/dbus/ |
| D | module-dbus-protocol.c | 165 … c->server->userdata->module->core->mainloop->defer_enable(c->server->userdata->cleanup_event, 1); in disconnection_filter_cb()
202 …c->wrap_conn = pa_dbus_wrap_connection_new_from_existing(s->userdata->module->core->mainloop, true… in connection_new_cb()
217 static void io_event_cb(pa_mainloop_api *mainloop, pa_io_event *e, int fd, pa_io_event_flags_t even… in io_event_cb() argument
241 static void time_event_cb(pa_mainloop_api *mainloop, pa_time_event* e, const struct timeval *tv, vo… in time_event_cb() argument
250 mainloop->time_restart(e, &next); in time_event_cb()
278 pa_mainloop_api *mainloop; in watch_add_cb() local
284 mainloop = s->userdata->module->core->mainloop; in watch_add_cb()
286 ev = mainloop->io_new( in watch_add_cb()
287 mainloop, in watch_add_cb()
305 s->userdata->module->core->mainloop->io_free(ev); in watch_remove_cb()
[all …]
|
| /third_party/pulseaudio/src/pulsecore/ |
| D | avahi-wrap.c | 33 pa_mainloop_api *mainloop; member
86 … w->io_event = p->mainloop->io_new(p->mainloop, fd, translate_io_flags(event), watch_callback, w); in watch_new()
94 w->avahi_poll->mainloop->io_enable(w->io_event, translate_io_flags(event)); in watch_update()
106 w->avahi_poll->mainloop->io_free(w->io_event); in watch_free()
139 t->time_event = tv ? p->mainloop->time_new(p->mainloop, tv, timeout_callback, t) : NULL; in timeout_new()
149 t->avahi_poll->mainloop->time_restart(t->time_event, tv); in timeout_update()
151 …t->time_event = t->avahi_poll->mainloop->time_new(t->avahi_poll->mainloop, tv, timeout_callback, t… in timeout_update()
153 t->avahi_poll->mainloop->time_free(t->time_event); in timeout_update()
162 t->avahi_poll->mainloop->time_free(t->time_event); in timeout_free()
181 p->mainloop = m; in pa_avahi_poll_new()
|
| D | iochannel.c | 47 pa_mainloop_api* mainloop; member
66 io->mainloop->io_free(io->input_event); in delete_events()
69 io->mainloop->io_free(io->output_event); in delete_events()
94 io->mainloop->io_enable(io->input_event, f); in enable_events()
96 … io->input_event = io->output_event = io->mainloop->io_new(io->mainloop, io->ifd, f, callback, io); in enable_events()
105 io->mainloop->io_enable(io->input_event, PA_IO_EVENT_INPUT); in enable_events()
107 … io->input_event = io->mainloop->io_new(io->mainloop, io->ifd, PA_IO_EVENT_INPUT, callback, io); in enable_events()
109 io->mainloop->io_free(io->input_event); in enable_events()
117 io->mainloop->io_enable(io->output_event, PA_IO_EVENT_OUTPUT); in enable_events()
119 … io->output_event = io->mainloop->io_new(io->mainloop, io->ofd, PA_IO_EVENT_OUTPUT, callback, io); in enable_events()
[all …]
|
| D | dbus-util.c | 39 pa_mainloop_api *mainloop; member
67 c->mainloop->defer_enable(c->dispatch_event, 0); in dispatch_status()
73 c->mainloop->defer_enable(c->dispatch_event, 1); in dispatch_status()
150 ev = c->mainloop->io_new( in add_watch()
151 c->mainloop, in add_watch()
169 c->mainloop->io_free(ev); in remove_watch()
183 c->mainloop->io_enable(ev, get_watch_flags(watch)); in toggle_watch()
206 …ev = c->mainloop->time_new(c->mainloop, pa_timeval_rtstore(&tv, pa_rtclock_now() + dbus_timeout_ge… in add_timeout()
207 c->mainloop->time_set_destroy(ev, time_event_destroy_cb); in add_timeout()
223 c->mainloop->time_free(ev); in remove_timeout()
[all …]
|
| D | x11wrap.c | 140 …i->io_event = w->core->mainloop->io_new(w->core->mainloop, fd, PA_IO_EVENT_INPUT, internal_io_even… in x11_internal_add()
152 w->core->mainloop->io_free(i->io_event); in x11_internal_remove()
188 w->defer_event = c->mainloop->defer_new(c->mainloop, defer_event, w); in x11_wrapper_new()
189 …w->io_event = c->mainloop->io_new(c->mainloop, ConnectionNumber(d), PA_IO_EVENT_INPUT, display_io_… in x11_wrapper_new()
208 w->core->mainloop->io_free(w->io_event); in x11_wrapper_free()
209 w->core->mainloop->defer_free(w->defer_event); in x11_wrapper_free()
255 w->core->mainloop->defer_enable(w->defer_event, 1); in pa_x11_wrapper_get_display()
|
| D | socket-client.c | 71 pa_mainloop_api *mainloop; member
94 c->mainloop = m; in socket_client_new()
104 c->mainloop->io_free(c->io_event); in free_events()
109 c->mainloop->time_free(c->timeout_event); in free_events()
114 c->mainloop->defer_free(c->defer_event); in free_events()
150 io = pa_iochannel_new(c->mainloop, c->fd, c->fd); in do_call()
206 c->io_event = c->mainloop->io_new(c->mainloop, c->fd, PA_IO_EVENT_OUTPUT, connect_io_cb, c);
208 c->defer_event = c->mainloop->defer_new(c->mainloop, connect_defer_cb, c);
293 pa_assert(c->mainloop);
306 c->mainloop->io_free(c->asyncns_io_event);
[all …]
|
| /third_party/pulseaudio/src/utils/ |
| D | padsp.c | 85 pa_threaded_mainloop *mainloop; member
389 if (i->mainloop) in fd_info_free()
390 pa_threaded_mainloop_stop(i->mainloop); in fd_info_free()
407 if (i->mainloop) in fd_info_free()
408 pa_threaded_mainloop_free(i->mainloop); in fd_info_free()
459 pa_threaded_mainloop_signal(i->mainloop, 0); in context_state_cb()
516 pa_threaded_mainloop_lock(i->mainloop); in atfork_prepare()
532 pa_threaded_mainloop_unlock(i->mainloop); in atfork_parent()
602 pa_threaded_mainloop_signal(i->mainloop, 0); in stream_success_cb()
612 pa_threaded_mainloop_signal(i->mainloop, 0); in context_success_cb()
[all …]
|
| /third_party/gstreamer/gstplugins_bad/tests/examples/mpegts/ |
| D | tsmux-prog-map.c | 42 _on_bus_message (GstBus * bus, GstMessage * message, GMainLoop * mainloop) in _on_bus_message() argument
47 g_main_loop_quit (mainloop); in _on_bus_message()
60 GMainLoop *mainloop; in main() local
73 mainloop = g_main_loop_new (NULL, FALSE); in main()
77 g_signal_connect (bus, "message", (GCallback) _on_bus_message, mainloop); in main()
91 g_main_loop_run (mainloop); in main()
|
| D | ts-scte-writer.c | 10 _on_bus_message (GstBus * bus, GstMessage * message, GMainLoop * mainloop) in _on_bus_message() argument
15 g_main_loop_quit (mainloop); in _on_bus_message()
66 GMainLoop *mainloop; in main() local
79 mainloop = g_main_loop_new (NULL, FALSE); in main()
89 g_signal_connect (bus, "message", (GCallback) _on_bus_message, mainloop); in main()
93 g_main_loop_run (mainloop); in main()
|
| D | ts-section-writer.c | 7 _on_bus_message (GstBus * bus, GstMessage * message, GMainLoop * mainloop) in _on_bus_message() argument
12 g_main_loop_quit (mainloop); in _on_bus_message()
57 GMainLoop *mainloop; in main() local
69 mainloop = g_main_loop_new (NULL, FALSE); in main()
78 g_signal_connect (bus, "message", (GCallback) _on_bus_message, mainloop); in main()
82 g_main_loop_run (mainloop); in main()
|
| /third_party/flutter/skia/third_party/externals/sdl/src/audio/pulseaudio/ |
| D | SDL_pulseaudio.c | 260 WaitForPulseOperation(pa_mainloop *mainloop, pa_operation *o) in WaitForPulseOperation() argument
263 if (mainloop && o) { in WaitForPulseOperation()
266 okay = (PULSEAUDIO_pa_mainloop_iterate(mainloop, 1, NULL) >= 0); in WaitForPulseOperation()
273 DisconnectFromPulseServer(pa_mainloop *mainloop, pa_context *context) in DisconnectFromPulseServer() argument
279 if (mainloop != NULL) { in DisconnectFromPulseServer()
280 PULSEAUDIO_pa_mainloop_free(mainloop); in DisconnectFromPulseServer()
287 pa_mainloop *mainloop = NULL; in ConnectToPulseServer_Internal() local
296 if (!(mainloop = PULSEAUDIO_pa_mainloop_new())) { in ConnectToPulseServer_Internal()
300 *_mainloop = mainloop; in ConnectToPulseServer_Internal()
302 mainloop_api = PULSEAUDIO_pa_mainloop_get_api(mainloop); in ConnectToPulseServer_Internal()
[all …]
|
| /third_party/pulseaudio/src/modules/ |
| D | module-zeroconf-publish.c | 135 pa_threaded_mainloop *mainloop; member
403 pa_threaded_mainloop_lock(u->mainloop); in get_service()
429 pa_threaded_mainloop_unlock(u->mainloop); in get_service()
470 pa_threaded_mainloop_lock(u->mainloop); in device_new_or_changed_cb()
472 pa_threaded_mainloop_unlock(u->mainloop); in device_new_or_changed_cb()
483 pa_threaded_mainloop_lock(u->mainloop); in device_unlink_cb()
485 pa_threaded_mainloop_unlock(u->mainloop); in device_unlink_cb()
587 pa_threaded_mainloop_lock(u->mainloop); in publish_all_services()
589 pa_threaded_mainloop_unlock(u->mainloop); in publish_all_services()
594 pa_threaded_mainloop_lock(u->mainloop); in publish_all_services()
[all …]
|