/third_party/pulseaudio/src/tests/ |
H A 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...] |
H A D | connect-stress.c | 33 #include <pulse/mainloop.h> 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() [all...] |
/third_party/pulseaudio/src/modules/ |
H A D | restart-module.c | 28 #include <pulse/mainloop.h> 43 static void do_reinit(pa_mainloop_api *mainloop, pa_restart_data *rd); 45 static void call_init(pa_mainloop_api *mainloop, pa_time_event *e, const struct timeval *tv, void *userdata) { in call_init() argument 50 mainloop->time_free(rd->time_event); in call_init() 60 do_reinit(mainloop, rd); in call_init() 63 static void defer_callback(pa_mainloop_api *mainloop, pa_defer_event *e, void *userdata) { in defer_callback() argument 68 mainloop->defer_enable(rd->defer_event, 0); in defer_callback() 69 mainloop->defer_free(rd->defer_event); in defer_callback() 72 do_reinit(mainloop, rd); in defer_callback() 75 static void do_reinit(pa_mainloop_api *mainloop, pa_restart_dat argument [all...] |
H A D | module-zeroconf-publish.c | 36 #include <pulse/thread-mainloop.h> 74 * communication, calling any of those functions in the PA mainloop context 75 * could lead to the mainloop being blocked for long periods. 77 * To avoid this, we create a threaded-mainloop for Avahi calls, and push all 80 * 1. If access to PA data structures is needed, use the PA mainloop context 82 * 2. If a (blocking) avahi-client call is needed, use the Avahi mainloop 84 * We do have message queue to pass messages from the Avahi mainloop to the PA 85 * mainloop. 135 pa_threaded_mainloop *mainloop; member 140 pa_hashmap *services; /* protect with mainloop loc [all...] |
/third_party/pulseaudio/src/pulse/ |
H A D | simple.c | 30 #include <pulse/thread-mainloop.h> 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) < in pa_simple_new() [all...] |
H A D | mainloop.c | 53 #include "mainloop.h" 57 pa_mainloop *mainloop; member 72 pa_mainloop *mainloop; member 87 pa_mainloop *mainloop; member 171 e->mainloop = m; in mainloop_io_new() 200 e->mainloop->rebuild_pollfds = true; in mainloop_io_enable() 202 pa_mainloop_wakeup(e->mainloop); in mainloop_io_enable() 210 e->mainloop->io_events_please_scan ++; in mainloop_io_free() 212 e->mainloop->n_io_events --; in mainloop_io_free() 213 e->mainloop in mainloop_io_free() [all...] |
H A D | glib-mainloop.c | 32 #include "glib-mainloop.h" 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 in glib_time_restart() [all...] |
H A D | ohos_glib-mainloop.c | 33 #include "glib-mainloop.h" 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 in glib_time_restart() [all...] |
H A D | thread-mainloop.c | 33 #include <pulse/mainloop.h> 42 #include "thread-mainloop.h" 256 pa_threaded_mainloop *mainloop; member 266 pa_atomic_store(&data->mainloop->in_once_unlocked, 1); in once_unlocked_cb() 267 pa_mutex_unlock(data->mainloop->mutex); in once_unlocked_cb() 269 data->callback(data->mainloop, data->userdata); in once_unlocked_cb() 271 pa_mutex_lock(data->mainloop->mutex); in once_unlocked_cb() 272 pa_atomic_store(&data->mainloop->in_once_unlocked, 0); in once_unlocked_cb() 290 data->mainloop = m; in pa_threaded_mainloop_once_unlocked()
|
H A D | pulseaudio.h | 25 #include <pulse/mainloop-api.h> 41 #include <pulse/thread-mainloop.h> 42 #include <pulse/mainloop.h> 43 #include <pulse/mainloop-signal.h> 51 * included: \ref direction.h, \ref mainloop-api.h, \ref sample.h, \ref def.h, 55 * thread-mainloop.h, \ref mainloop.h, \ref util.h, \ref proplist.h, 56 * \ref timeval.h, \ref rtclock.h and \ref mainloop-signal.h at 176 * \li libpulse-mainloop-glib - GLIB 2.x main loop bindings.
|
/third_party/ffmpeg/libavdevice/ |
H A D | pulse_audio_enc.c | 48 pa_threaded_mainloop *mainloop; member 66 pa_threaded_mainloop_signal(s->mainloop, 0); in pulse_audio_sink_device_cb() 87 pa_threaded_mainloop_wait(s->mainloop); in pulse_update_sink_info() 164 // Calling from mainloop callback. No need to lock mainloop. in pulse_event() 179 pa_threaded_mainloop_signal(s->mainloop, 0); in pulse_stream_writable() 205 pa_threaded_mainloop_signal(s->mainloop, 0); in pulse_stream_state() 218 pa_threaded_mainloop_wait(s->mainloop); in pulse_stream_wait() 234 pa_threaded_mainloop_signal(s->mainloop, 0); in pulse_context_state() 247 pa_threaded_mainloop_wait(s->mainloop); in pulse_context_wait() [all...] |
H A D | pulse_audio_dec.c | 49 pa_threaded_mainloop *mainloop; member 84 pa_threaded_mainloop_signal(p->mainloop, 0); in context_state_cb() 96 pa_threaded_mainloop_signal(p->mainloop, 0); in stream_state_cb() 104 pa_threaded_mainloop_signal(p->mainloop, 0); in stream_request_cb() 110 pa_threaded_mainloop_signal(p->mainloop, 0); in stream_latency_update_cb() 117 if (pd->mainloop) in pulse_close() 118 pa_threaded_mainloop_stop(pd->mainloop); in pulse_close() 130 if (pd->mainloop) in pulse_close() 131 pa_threaded_mainloop_free(pd->mainloop); in pulse_close() 132 pd->mainloop in pulse_close() [all...] |
/third_party/pulseaudio/src/modules/dbus/ |
H A D | module-dbus-protocol.c | 28 #include <pulse/mainloop-api.h> 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, new_connection); in connection_new_cb() 216 /* Called by PA mainloop when a D-Bus fd watch event needs handling. */ 217 static void io_event_cb(pa_mainloop_api *mainloop, pa_io_event *e, int fd, pa_io_event_flags_t events, void *userdata) { in io_event_cb() argument 240 /* Called by PA mainloop when a D-Bus timer event needs handling. */ 241 static void time_event_cb(pa_mainloop_api *mainloop, pa_time_event* e, const struct timeval *tv, void *userdata) { 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 in watch_add_cb() 325 pa_mainloop_api *mainloop; timeout_add_cb() local 362 pa_mainloop_api *mainloop; timeout_toggled_cb() local [all...] |
/third_party/pulseaudio/src/pulsecore/ |
H A 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, t in timeout_update() [all...] |
H A D | x11wrap.c | 145 i->io_event = w->core->mainloop->io_new(w->core->mainloop, fd, PA_IO_EVENT_INPUT, internal_io_event, w); in x11_internal_add() 157 w->core->mainloop->io_free(i->io_event); in x11_internal_remove() 225 w->defer_event = c->mainloop->defer_new(c->mainloop, defer_event, w); in x11_wrapper_new() 226 w->io_event = c->mainloop->io_new(c->mainloop, ConnectionNumber(d), PA_IO_EVENT_INPUT, display_io_event, w); in x11_wrapper_new() 227 w->cleanup_event = c->mainloop->defer_new(c->mainloop, deferred_x11_teardown, w); in x11_wrapper_new() 228 w->core->mainloop in x11_wrapper_new() [all...] |
H A 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 in enable_events() [all...] |
H A 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_c [all...] |
H A D | thread-mq.c | 31 #include <pulse/mainloop-api.h> 136 int pa_thread_mq_init(pa_thread_mq *q, pa_mainloop_api *mainloop, pa_rtpoll *rtpoll) { in pa_thread_mq_init() argument 138 pa_assert(mainloop); in pa_thread_mq_init() 142 q->main_mainloop = mainloop; in pa_thread_mq_init() 154 pa_assert_se(q->read_main_event = mainloop->io_new(mainloop, pa_asyncmsgq_read_fd(q->outq), PA_IO_EVENT_INPUT, asyncmsgq_read_cb, q)); in pa_thread_mq_init() 157 pa_assert_se(q->write_main_event = mainloop->io_new(mainloop, pa_asyncmsgq_write_fd(q->inq), PA_IO_EVENT_INPUT, asyncmsgq_write_inq_cb, q)); in pa_thread_mq_init()
|
H A D | dbus-util.c | 39 pa_mainloop_api *mainloop; member 58 /* DBusDispatchStatusFunction callback for the pa mainloop */ 67 c->mainloop->defer_enable(c->dispatch_event, 0); in dispatch_status() 73 c->mainloop->defer_enable(c->dispatch_event, 1); in dispatch_status() 142 /* DBusAddWatchFunction callback for pa mainloop */ 150 ev = c->mainloop->io_new( in add_watch() 151 c->mainloop, in add_watch() 160 /* DBusRemoveWatchFunction callback for pa mainloop */ 169 c->mainloop->io_free(ev); in remove_watch() 172 /* DBusWatchToggledFunction callback for pa mainloop */ [all...] |
H A D | srbchannel.c | 88 pa_mainloop_api *mainloop; member 230 sr->mainloop = m; in pa_srbchannel_new() 296 sr->mainloop = m; in pa_srbchannel_new_from_template() 351 sr->defer_event = sr->mainloop->defer_new(sr->mainloop, defer_cb, sr); in pa_srbchannel_set_callback() 352 sr->mainloop->defer_enable(sr->defer_event, 1); in pa_srbchannel_set_callback() 364 sr->mainloop->defer_free(sr->defer_event); in pa_srbchannel_free() 366 sr->mainloop->io_free(sr->read_event); in pa_srbchannel_free()
|
H A D | ioline.c | 48 pa_mainloop_api *mainloop; member 89 l->mainloop = pa_iochannel_get_mainloop_api(io); in pa_ioline_new() 91 l->defer_event = l->mainloop->defer_new(l->mainloop, defer_callback, l); in pa_ioline_new() 92 l->mainloop->defer_enable(l->defer_event, 0); in pa_ioline_new() 109 l->mainloop->defer_free(l->defer_event); in ioline_free() 144 l->mainloop->defer_free(l->defer_event); in pa_ioline_close() 195 l->mainloop->defer_enable(l->defer_event, 1); in pa_ioline_puts() 383 l->mainloop->defer_enable(l->defer_event, 0); in do_work() 412 pa_assert(l->mainloop in defer_callback() [all...] |
H A D | core-subscribe.c | 120 c->mainloop->defer_free(c->subscription_defer_event); in pa_subscription_free_all() 159 pa_assert(c->mainloop == m); in defer_cb() 163 c->mainloop->defer_enable(c->subscription_defer_event, 0); in defer_cb() 193 /* Schedule an mainloop event so that a pending subscription event is dispatched */ 198 c->subscription_defer_event = c->mainloop->defer_new(c->mainloop, defer_cb, c); in sched_event() 202 c->mainloop->defer_enable(c->subscription_defer_event, 1); in sched_event()
|
H A D | pdispatch.c | 225 pa_mainloop_api *mainloop; member 238 pa_assert(r->pdispatch->mainloop); in reply_info_free() 241 r->pdispatch->mainloop->time_free(r->time_event); in reply_info_free() 249 pa_pdispatch* pa_pdispatch_new(pa_mainloop_api *mainloop, bool use_rtclock, const pa_pdispatch_cb_t *table, unsigned entries) { in pa_pdispatch_new() argument 252 pa_assert(mainloop); in pa_pdispatch_new() 257 pd->mainloop = mainloop; in pa_pdispatch_new() 381 pa_assert(r->pdispatch->mainloop == m); in timeout_callback() 404 pa_assert_se(r->time_event = pd->mainloop->time_new(pd->mainloop, in pa_pdispatch_register_reply() [all...] |
/third_party/pulseaudio/src/utils/ |
H A 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, in context_success_cb() [all...] |
/third_party/mesa3d/bin/pick/ |
H A D | ui.py | 119 mainloop: urwid.MainLoop = attr.ib(None, init=False) 164 o = self.mainloop.widget 165 self.mainloop.widget = urwid.Overlay( 170 self.mainloop.widget = o 194 o = self.mainloop.widget 197 self.mainloop.widget = o 228 self.mainloop.widget = urwid.Overlay( 233 o = self.mainloop.widget 236 self.mainloop.widget = o 262 self.mainloop [all...] |