Home
last modified time | relevance | path

Searched refs:asyncmsgq (Results 1 – 25 of 31) sorted by relevance

12

/third_party/pulseaudio/src/modules/
Dmodule-loopback.c85 pa_asyncmsgq *asyncmsgq; member
403 …pa_asyncmsgq_send(sink->asyncmsgq, PA_MSGOBJECT(u->sink_input), SINK_INPUT_MESSAGE_UPDATE_MIN_LATE… in update_minimum_latency()
528 …pa_asyncmsgq_send(u->sink_input->sink->asyncmsgq, PA_MSGOBJECT(u->sink_input), SINK_INPUT_MESSAGE_… in adjust_rates()
622 …pa_asyncmsgq_send(u->sink_input->sink->asyncmsgq, PA_MSGOBJECT(u->sink_input), SINK_INPUT_MESSAGE_… in time_callback()
623 …pa_asyncmsgq_send(u->source_output->source->asyncmsgq, PA_MSGOBJECT(u->source_output), SOURCE_OUTP… in time_callback()
755 …pa_asyncmsgq_post(u->asyncmsgq, PA_MSGOBJECT(u->sink_input), SINK_INPUT_MESSAGE_POST, PA_INT_TO_PT… in source_output_push_cb()
767 …pa_asyncmsgq_post(u->asyncmsgq, PA_MSGOBJECT(u->sink_input), SINK_INPUT_MESSAGE_REWIND, NULL, (int… in source_output_process_rewind_cb()
815 …pa_asyncmsgq_send(sink->asyncmsgq, PA_MSGOBJECT(u->sink_input), SINK_INPUT_MESSAGE_SET_EFFECTIVE_S… in update_effective_source_latency()
855 u->asyncmsgq); in source_output_attach_cb()
952 …pa_asyncmsgq_send(u->sink_input->sink->asyncmsgq, PA_MSGOBJECT(u->sink_input), SINK_INPUT_MESSAGE_… in source_output_moving_cb()
[all …]
Dmodule-virtual-source.c359 …pa_asyncmsgq_post(u->asyncmsgq, PA_MSGOBJECT(u->sink_input), SINK_INPUT_MESSAGE_REWIND, NULL, (int… in source_output_process_rewind_cb()
460 pa_source_set_asyncmsgq(u->source, dest->asyncmsgq); in source_output_moving_cb()
602 pa_source_set_asyncmsgq(u->source, master->asyncmsgq); in pa__init()
680 pa_sink_set_asyncmsgq(u->sink, master->asyncmsgq); in pa__init()
Dmodule-tunnel.c382 …pa_asyncmsgq_send(u->sink->asyncmsgq, PA_MSGOBJECT(u->sink), SINK_MESSAGE_REMOTE_SUSPEND, PA_UINT3… in command_suspended()
384 …pa_asyncmsgq_send(u->source->asyncmsgq, PA_MSGOBJECT(u->source), SOURCE_MESSAGE_REMOTE_SUSPEND, PA… in command_suspended()
415 …pa_asyncmsgq_send(u->sink->asyncmsgq, PA_MSGOBJECT(u->sink), SINK_MESSAGE_REMOTE_SUSPEND, PA_UINT3… in command_moved()
417 …pa_asyncmsgq_send(u->source->asyncmsgq, PA_MSGOBJECT(u->source), SOURCE_MESSAGE_REMOTE_SUSPEND, PA… in command_moved()
910 …pa_asyncmsgq_post(u->sink->asyncmsgq, PA_MSGOBJECT(u->sink), SINK_MESSAGE_REQUEST, NULL, bytes, NU… in command_request()
1015 …pa_asyncmsgq_send(u->sink->asyncmsgq, PA_MSGOBJECT(u->sink), SINK_MESSAGE_GET_LATENCY_SNAPSHOT, &s… in stream_get_latency_callback()
1023 …pa_asyncmsgq_send(u->sink->asyncmsgq, PA_MSGOBJECT(u->sink), SINK_MESSAGE_UPDATE_LATENCY, 0, delay… in stream_get_latency_callback()
1025 …pa_asyncmsgq_send(u->source->asyncmsgq, PA_MSGOBJECT(u->source), SOURCE_MESSAGE_UPDATE_LATENCY, 0,… in stream_get_latency_callback()
1720 …pa_asyncmsgq_post(u->sink->asyncmsgq, PA_MSGOBJECT(u->sink), SINK_MESSAGE_REQUEST, NULL, bytes, NU… in create_stream_callback()
1977 …pa_asyncmsgq_send(u->source->asyncmsgq, PA_MSGOBJECT(u->source), SOURCE_MESSAGE_POST, PA_UINT_TO_P… in pstream_memblock_callback()
Dmodule-remap-source.c266 pa_source_set_asyncmsgq(u->source, dest->asyncmsgq); in source_output_moving_cb()
386 pa_source_set_asyncmsgq(u->source, master->asyncmsgq); in pa__init()
Dmodule-remap-sink.c312 pa_sink_set_asyncmsgq(u->sink, dest->asyncmsgq); in sink_input_moving_cb()
427 pa_sink_set_asyncmsgq(u->sink, master->asyncmsgq); in pa__init()
Dmodule-virtual-sink.c438 pa_sink_set_asyncmsgq(u->sink, dest->asyncmsgq); in sink_input_moving_cb()
580 pa_sink_set_asyncmsgq(u->sink, master->asyncmsgq); in pa__init()
Dmodule-combine-sink.c271 …pa_asyncmsgq_send(u->sink->asyncmsgq, PA_MSGOBJECT(u->sink), SINK_MESSAGE_GET_SNAPSHOT, &rdata, 0,… in adjust_rates()
361 …pa_asyncmsgq_send(u->sink->asyncmsgq, PA_MSGOBJECT(u->sink), SINK_MESSAGE_UPDATE_LATENCY, NULL, (i… in adjust_rates()
687 …pa_asyncmsgq_send(o->userdata->sink->asyncmsgq, PA_MSGOBJECT(o->userdata->sink), SINK_MESSAGE_ADD_… in sink_input_attach_cb()
699 …pa_asyncmsgq_send(o->userdata->sink->asyncmsgq, PA_MSGOBJECT(o->userdata->sink), SINK_MESSAGE_REMO… in sink_input_detach_cb()
Dmodule-ladspa-sink.c233 …pa_asyncmsgq_send(u->sink->asyncmsgq, PA_MSGOBJECT(u->sink), LADSPA_SINK_MESSAGE_UPDATE_PARAMETERS… in set_algorithm_parameters()
684 pa_sink_set_asyncmsgq(u->sink, dest->asyncmsgq); in sink_input_moving_cb()
1329 pa_sink_set_asyncmsgq(u->sink, master->asyncmsgq); in pa__init()
Dmodule-virtual-surround-sink.c662 pa_sink_set_asyncmsgq(u->sink, dest->asyncmsgq); in sink_input_moving_cb()
895 pa_sink_set_asyncmsgq(u->sink, master->asyncmsgq); in pa__init()
Dmodule-tunnel-source-new.c591 …pa_asyncmsgq_send(u->source->asyncmsgq, PA_MSGOBJECT(u->source), TUNNEL_MESSAGE_SOURCE_CREATED, u,… in create_source()
/third_party/pulseaudio/src/pulsecore/
Dasyncmsgq.c38 PA_STATIC_FLIST_DECLARE(asyncmsgq, 0, pa_xfree);
95 if (pa_flist_push(PA_STATIC_FLIST_GET(asyncmsgq), i) < 0) in asyncmsgq_free()
122 if (!(i = pa_flist_pop(PA_STATIC_FLIST_GET(asyncmsgq)))) in pa_asyncmsgq_post()
230 if (pa_flist_push(PA_STATIC_FLIST_GET(asyncmsgq), a->current) < 0) in pa_asyncmsgq_done()
Dsource.c288 s->asyncmsgq = NULL; in pa_source_new()
413 if (s->asyncmsgq) { in source_set_state()
416 …if ((ret = pa_asyncmsgq_send(s->asyncmsgq, PA_MSGOBJECT(s), PA_SOURCE_MESSAGE_SET_STATE, &data, 0,… in source_set_state()
607 pa_assert(s->asyncmsgq); in pa_source_put()
780 s->asyncmsgq = q; in pa_source_set_asyncmsgq()
1172 …pa_assert_se(pa_asyncmsgq_send(s->asyncmsgq, PA_MSGOBJECT(s), PA_SOURCE_MESSAGE_GET_LATENCY, &usec… in pa_source_get_latency()
1749 …pa_assert_se(pa_asyncmsgq_send(root_source->asyncmsgq, PA_MSGOBJECT(root_source), PA_SOURCE_MESSAG… in pa_source_set_volume()
1770 …pa_assert_se(pa_asyncmsgq_send(s->asyncmsgq, PA_MSGOBJECT(s), PA_SOURCE_MESSAGE_SET_VOLUME, NULL, … in pa_source_set_soft_volume()
1857 …pa_assert_se(pa_asyncmsgq_send(s->asyncmsgq, PA_MSGOBJECT(s), PA_SOURCE_MESSAGE_GET_VOLUME, NULL, … in pa_source_get_volume()
1910 …pa_assert_se(pa_asyncmsgq_send(s->asyncmsgq, PA_MSGOBJECT(s), PA_SOURCE_MESSAGE_SET_MUTE, NULL, 0,… in pa_source_set_mute()
[all …]
Dsink.c301 s->asyncmsgq = NULL; in pa_sink_new()
462 if (s->asyncmsgq) { in sink_set_state()
465 …if ((ret = pa_asyncmsgq_send(s->asyncmsgq, PA_MSGOBJECT(s), PA_SINK_MESSAGE_SET_STATE, &data, 0, N… in sink_set_state()
659 pa_assert(s->asyncmsgq); in pa_sink_put()
851 s->asyncmsgq = q; in pa_sink_set_asyncmsgq()
1588 …pa_assert_se(pa_asyncmsgq_send(s->asyncmsgq, PA_MSGOBJECT(s), PA_SINK_MESSAGE_GET_LAST_REWIND, &re… in pa_sink_get_last_rewind()
1609 …pa_assert_se(pa_asyncmsgq_send(s->asyncmsgq, PA_MSGOBJECT(s), PA_SINK_MESSAGE_GET_LATENCY, &usec, … in pa_sink_get_latency()
2225 …pa_assert_se(pa_asyncmsgq_send(root_sink->asyncmsgq, PA_MSGOBJECT(root_sink), PA_SINK_MESSAGE_SET_… in pa_sink_set_volume()
2246 …pa_assert_se(pa_asyncmsgq_send(s->asyncmsgq, PA_MSGOBJECT(s), PA_SINK_MESSAGE_SET_VOLUME, NULL, 0,… in pa_sink_set_soft_volume()
2334 …pa_assert_se(pa_asyncmsgq_send(s->asyncmsgq, PA_MSGOBJECT(s), PA_SINK_MESSAGE_GET_VOLUME, NULL, 0,… in pa_sink_get_volume()
[all …]
Dsource-output.c565 …pa_assert_se(pa_asyncmsgq_send(o->source->asyncmsgq, PA_MSGOBJECT(o), PA_SOURCE_OUTPUT_MESSAGE_SET… in source_output_set_state()
624 if (o->source->asyncmsgq) in pa_source_output_unlink()
625 …pa_assert_se(pa_asyncmsgq_send(o->source->asyncmsgq, PA_MSGOBJECT(o->source), PA_SOURCE_MESSAGE_RE… in pa_source_output_unlink()
714 …pa_assert_se(pa_asyncmsgq_send(o->source->asyncmsgq, PA_MSGOBJECT(o->source), PA_SOURCE_MESSAGE_AD… in pa_source_output_put()
739 …pa_assert_se(pa_asyncmsgq_send(o->source->asyncmsgq, PA_MSGOBJECT(o), PA_SOURCE_OUTPUT_MESSAGE_GET… in pa_source_output_get_latency()
956 …pa_assert_se(pa_asyncmsgq_send(o->source->asyncmsgq, PA_MSGOBJECT(o), PA_SOURCE_OUTPUT_MESSAGE_SET… in pa_source_output_set_requested_latency()
986 …pa_assert_se(pa_asyncmsgq_send(o->source->asyncmsgq, PA_MSGOBJECT(o), PA_SOURCE_OUTPUT_MESSAGE_GET… in pa_source_output_get_requested_latency()
1043 …pa_assert_se(pa_asyncmsgq_send(o->source->asyncmsgq, PA_MSGOBJECT(o), PA_SOURCE_OUTPUT_MESSAGE_SET… in pa_source_output_set_volume()
1131 …pa_assert_se(pa_asyncmsgq_send(o->source->asyncmsgq, PA_MSGOBJECT(o), PA_SOURCE_OUTPUT_MESSAGE_SET… in pa_source_output_set_mute()
1278 …pa_asyncmsgq_post(o->source->asyncmsgq, PA_MSGOBJECT(o), PA_SOURCE_OUTPUT_MESSAGE_SET_RATE, PA_UIN… in pa_source_output_set_rate()
[all …]
Dsink-input.c715 …pa_assert_se(pa_asyncmsgq_send(i->sink->asyncmsgq, PA_MSGOBJECT(i), PA_SINK_INPUT_MESSAGE_SET_STAT… in sink_input_set_state()
808 if (i->sink->asyncmsgq) in pa_sink_input_unlink()
809 …pa_assert_se(pa_asyncmsgq_send(i->sink->asyncmsgq, PA_MSGOBJECT(i->sink), PA_SINK_MESSAGE_REMOVE_I… in pa_sink_input_unlink()
919 …pa_assert_se(pa_asyncmsgq_send(i->sink->asyncmsgq, PA_MSGOBJECT(i->sink), PA_SINK_MESSAGE_ADD_INPU… in pa_sink_input_put()
944 …pa_assert_se(pa_asyncmsgq_send(i->sink->asyncmsgq, PA_MSGOBJECT(i), PA_SINK_INPUT_MESSAGE_GET_LATE… in pa_sink_input_get_latency()
1373 …pa_assert_se(pa_asyncmsgq_send(i->sink->asyncmsgq, PA_MSGOBJECT(i), PA_SINK_INPUT_MESSAGE_SET_REQU… in pa_sink_input_set_requested_latency()
1403 …pa_assert_se(pa_asyncmsgq_send(i->sink->asyncmsgq, PA_MSGOBJECT(i), PA_SINK_INPUT_MESSAGE_GET_REQU… in pa_sink_input_get_requested_latency()
1461 …pa_assert_se(pa_asyncmsgq_send(i->sink->asyncmsgq, PA_MSGOBJECT(i), PA_SINK_INPUT_MESSAGE_SET_SOFT… in pa_sink_input_set_volume()
1489 …pa_assert_se(pa_asyncmsgq_send(i->sink->asyncmsgq, PA_MSGOBJECT(i), PA_SINK_INPUT_MESSAGE_SET_SOFT… in pa_sink_input_add_volume_factor()
1520 …pa_assert_se(pa_asyncmsgq_send(i->sink->asyncmsgq, PA_MSGOBJECT(i), PA_SINK_INPUT_MESSAGE_SET_SOFT… in pa_sink_input_remove_volume_factor()
[all …]
Dmeson.build2 'asyncmsgq.c',
62 'asyncmsgq.h',
Dprotocol-simple.c199 …pa_asyncmsgq_post(c->sink_input->sink->asyncmsgq, PA_MSGOBJECT(c->sink_input), SINK_INPUT_MESSAGE_… in do_read()
272 …pa_asyncmsgq_post(c->sink_input->sink->asyncmsgq, PA_MSGOBJECT(c->sink_input), SINK_INPUT_MESSAGE_… in do_work()
Dsource.h115 pa_asyncmsgq *asyncmsgq; member
Dsink.h114 pa_asyncmsgq *asyncmsgq; member
Dprotocol-native.c2859 …pa_asyncmsgq_post(s->sink_input->sink->asyncmsgq, PA_MSGOBJECT(s->sink_input), SINK_INPUT_MESSAGE_… in command_drain_playback_stream()
2911 …pa_assert_se(pa_asyncmsgq_send(s->sink_input->sink->asyncmsgq, PA_MSGOBJECT(s->sink_input), SINK_I… in command_get_playback_latency()
2957 …pa_assert_se(pa_asyncmsgq_send(s->source_output->source->asyncmsgq, PA_MSGOBJECT(s->source_output)… in command_get_record_latency()
4013 …pa_asyncmsgq_send(s->sink_input->sink->asyncmsgq, PA_MSGOBJECT(s->sink_input), SINK_INPUT_MESSAGE_… in command_trigger_or_flush_or_prebuf_playback_stream()
4017 …pa_asyncmsgq_send(s->sink_input->sink->asyncmsgq, PA_MSGOBJECT(s->sink_input), SINK_INPUT_MESSAGE_… in command_trigger_or_flush_or_prebuf_playback_stream()
4021 …pa_asyncmsgq_send(s->sink_input->sink->asyncmsgq, PA_MSGOBJECT(s->sink_input), SINK_INPUT_MESSAGE_… in command_trigger_or_flush_or_prebuf_playback_stream()
4123 …pa_assert_se(pa_asyncmsgq_send(s->sink_input->sink->asyncmsgq, PA_MSGOBJECT(s->sink_input), SINK_I… in command_set_stream_buffer_attr()
5092 …pa_asyncmsgq_post(ps->sink_input->sink->asyncmsgq, PA_MSGOBJECT(ps->sink_input), SINK_INPUT_MESSAG… in pstream_memblock_callback()
5094 …pa_asyncmsgq_post(ps->sink_input->sink->asyncmsgq, PA_MSGOBJECT(ps->sink_input), SINK_INPUT_MESSAG… in pstream_memblock_callback()
5096 …pa_asyncmsgq_post(ps->sink_input->sink->asyncmsgq, PA_MSGOBJECT(ps->sink_input), SINK_INPUT_MESSAG… in pstream_memblock_callback()
/third_party/pulseaudio/src/modules/echo-cancel/
Dmodule-echo-cancel.c221 pa_asyncmsgq *asyncmsgq; member
354 …pa_asyncmsgq_send(u->source_output->source->asyncmsgq, PA_MSGOBJECT(u->source_output), SOURCE_OUTP… in time_callback()
355 …pa_asyncmsgq_send(u->sink_input->sink->asyncmsgq, PA_MSGOBJECT(u->sink_input), SINK_INPUT_MESSAGE_… in time_callback()
367 …pa_asyncmsgq_post(u->asyncmsgq, PA_MSGOBJECT(u->source_output), SOURCE_OUTPUT_MESSAGE_APPLY_DIFF_T… in time_callback()
375 …pa_asyncmsgq_post(u->asyncmsgq, PA_MSGOBJECT(u->source_output), SOURCE_OUTPUT_MESSAGE_APPLY_DIFF_T… in time_callback()
715 …pa_asyncmsgq_send(u->sink_input->sink->asyncmsgq, PA_MSGOBJECT(u->sink_input), SINK_INPUT_MESSAGE_… in do_resync()
717 while (pa_asyncmsgq_process_one(u->asyncmsgq)) in do_resync()
917 while (pa_asyncmsgq_process_one(u->asyncmsgq) > 0) in source_output_push_cb()
1002 pa_asyncmsgq_post(u->asyncmsgq, PA_MSGOBJECT(u->source_output), SOURCE_OUTPUT_MESSAGE_POST, in sink_input_pop_cb()
1048 …pa_asyncmsgq_post(u->asyncmsgq, PA_MSGOBJECT(u->source_output), SOURCE_OUTPUT_MESSAGE_REWIND, NULL… in sink_input_process_rewind_cb()
[all …]
/third_party/pulseaudio/src/
D.gitignore34 asyncmsgq-test
/third_party/pulseaudio/src/tests/
Dmeson.build57 [ 'asyncmsgq-test', 'asyncmsgq-test.c',
/third_party/pulseaudio/ohosbuild/src/pulsecore/
DBUILD.gn46 "../../../src/pulsecore/asyncmsgq.c",
/third_party/pulseaudio/po/
DPOTFILES.in81 src/pulsecore/asyncmsgq.c

12