Home
last modified time | relevance | path

Searched refs:sink_input (Results 1 – 25 of 27) sorted by relevance

12

/third_party/pulseaudio/src/modules/
Dmodule-remap-sink.c54 pa_sink_input *sink_input; member
84 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) { in sink_process_msg()
91 pa_sink_get_latency_within_thread(u->sink_input->sink, true) + in sink_process_msg()
94 …pa_bytes_to_usec(pa_memblockq_get_length(u->sink_input->thread_info.render_memblockq), &u->sink_in… in sink_process_msg()
97 *((int64_t*) data) += pa_resampler_get_delay_usec(u->sink_input->thread_info.resampler); in sink_process_msg()
113 !PA_SINK_INPUT_IS_LINKED(u->sink_input->state)) in sink_set_state_in_main_thread()
116 pa_sink_input_cork(u->sink_input, state == PA_SINK_SUSPENDED); in sink_set_state_in_main_thread()
131 pa_sink_input_request_rewind(u->sink_input, 0, false, true, true); in sink_set_state_in_io_thread_cb()
145 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) in sink_request_rewind()
148 pa_sink_input_request_rewind(u->sink_input, s->thread_info.rewind_nbytes, true, false, false); in sink_request_rewind()
[all …]
Dmodule-virtual-sink.c63 pa_sink_input *sink_input; member
95 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) { in sink_process_msg_cb()
103 pa_sink_get_latency_within_thread(u->sink_input->sink, true) + in sink_process_msg_cb()
106 …pa_bytes_to_usec(pa_memblockq_get_length(u->sink_input->thread_info.render_memblockq), &u->sink_in… in sink_process_msg_cb()
109 *((int64_t*) data) += pa_resampler_get_delay_usec(u->sink_input->thread_info.resampler); in sink_process_msg_cb()
125 !PA_SINK_INPUT_IS_LINKED(u->sink_input->state)) in sink_set_state_in_main_thread_cb()
128 pa_sink_input_cork(u->sink_input, state == PA_SINK_SUSPENDED); in sink_set_state_in_main_thread_cb()
143 pa_sink_input_request_rewind(u->sink_input, 0, false, true, true); in sink_set_state_in_io_thread_cb()
157 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) in sink_request_rewind_cb()
161 pa_sink_input_request_rewind(u->sink_input, in sink_request_rewind_cb()
[all …]
Dmodule-sine.c46 pa_sink_input *sink_input; member
96 pa_sink_input_unlink(u->sink_input); in sink_input_kill_cb()
97 pa_sink_input_unref(u->sink_input); in sink_input_kill_cb()
98 u->sink_input = NULL; in sink_input_kill_cb()
153 u->sink_input = NULL; in pa__init()
167 pa_sink_input_new(&u->sink_input, m->core, &data); in pa__init()
170 if (!u->sink_input) in pa__init()
173 u->sink_input->pop = sink_input_pop_cb; in pa__init()
174 u->sink_input->process_rewind = sink_input_process_rewind_cb; in pa__init()
175 u->sink_input->kill = sink_input_kill_cb; in pa__init()
[all …]
Dmodule-loopback.c82 pa_sink_input *sink_input; member
268 if (u->sink_input) { in teardown()
269 pa_sink_input_unlink(u->sink_input); in teardown()
270 pa_sink_input_unref(u->sink_input); in teardown()
271 u->sink_input = NULL; in teardown()
403 …pa_asyncmsgq_send(sink->asyncmsgq, PA_MSGOBJECT(u->sink_input), SINK_INPUT_MESSAGE_UPDATE_MIN_LATE… in update_minimum_latency()
447 update_minimum_latency(u, u->sink_input->sink, false); in adjust_rates()
478 old_rate = u->sink_input->sample_spec.rate; in adjust_rates()
487 current_buffer_latency = pa_bytes_to_usec(buffer, &u->sink_input->sample_spec); in adjust_rates()
528 …pa_asyncmsgq_send(u->sink_input->sink->asyncmsgq, PA_MSGOBJECT(u->sink_input), SINK_INPUT_MESSAGE_… in adjust_rates()
[all …]
Dmodule-virtual-surround-sink.c79 pa_sink_input *sink_input; member
270 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) { in sink_process_msg_cb()
278 pa_sink_get_latency_within_thread(u->sink_input->sink, true) + in sink_process_msg_cb()
281 …pa_bytes_to_usec(pa_memblockq_get_length(u->sink_input->thread_info.render_memblockq), &u->sink_in… in sink_process_msg_cb()
284 *((int64_t*) data) += pa_resampler_get_delay_usec(u->sink_input->thread_info.resampler); in sink_process_msg_cb()
300 !PA_SINK_INPUT_IS_LINKED(u->sink_input->state)) in sink_set_state_in_main_thread_cb()
303 pa_sink_input_cork(u->sink_input, state == PA_SINK_SUSPENDED); in sink_set_state_in_main_thread_cb()
318 pa_sink_input_request_rewind(u->sink_input, 0, false, true, true); in sink_set_state_in_io_thread_cb()
333 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) in sink_request_rewind_cb()
340 pa_sink_input_request_rewind(u->sink_input, nbytes_input, true, false, false); in sink_request_rewind_cb()
[all …]
Dmodule-ladspa-sink.c80 pa_sink_input *sink_input; member
351 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) { in sink_process_msg_cb()
359 pa_sink_get_latency_within_thread(u->sink_input->sink, true) + in sink_process_msg_cb()
362 …pa_bytes_to_usec(pa_memblockq_get_length(u->sink_input->thread_info.render_memblockq), &u->sink_in… in sink_process_msg_cb()
365 *((int64_t*) data) += pa_resampler_get_delay_usec(u->sink_input->thread_info.resampler); in sink_process_msg_cb()
393 !PA_SINK_INPUT_IS_LINKED(u->sink_input->state)) in sink_set_state_in_main_thread_cb()
396 pa_sink_input_cork(u->sink_input, state == PA_SINK_SUSPENDED); in sink_set_state_in_main_thread_cb()
411 pa_sink_input_request_rewind(u->sink_input, 0, false, true, true); in sink_set_state_in_io_thread_cb()
425 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) in sink_request_rewind_cb()
429 pa_sink_input_request_rewind(u->sink_input, in sink_request_rewind_cb()
[all …]
Dmodule-combine-sink.c97 pa_sink_input *sink_input; member
285 if (!o->sink_input || !PA_SINK_IS_OPENED(o->sink->state)) in adjust_rates()
297 … + pa_bytes_to_usec(o->latency_snapshot.output_memblockq_size, &o->sink_input->sample_spec) in adjust_rates()
302 …tes_to_usec(rdata.send_counter - o->latency_snapshot.receive_counter, &o->sink_input->sample_spec); in adjust_rates()
351 if (!o->sink_input || !PA_SINK_IS_OPENED(o->sink->state)) in adjust_rates()
355 … new_rate = rate_controller(o, base_rate, o->sink_input->sample_spec.rate, latency_difference); in adjust_rates()
357 …pa_log_info("[%s] new rate is %u Hz; ratio is %0.3f.", o->sink_input->sink->name, new_rate, (doubl… in adjust_rates()
358 pa_sink_input_set_rate(o->sink_input, new_rate); in adjust_rates()
382 …pa_asyncmsgq_send(o->control_inq, PA_MSGOBJECT(o->sink_input), SINK_INPUT_MESSAGE_LATENCY_SNAPSHOT… in time_callback()
520 …pa_asyncmsgq_post(j->audio_inq, PA_MSGOBJECT(j->sink_input), SINK_INPUT_MESSAGE_POST, NULL, 0, &ch… in render_memblock()
[all …]
Dmodule-equalizer-sink.c89 pa_sink_input *sink_input; member
253 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) { in sink_process_msg_cb()
260 pa_sink_get_latency_within_thread(u->sink_input->sink, true) + in sink_process_msg_cb()
264 … pa_memblockq_get_length(u->input_q), &u->sink_input->sink->sample_spec) + in sink_process_msg_cb()
265 …pa_bytes_to_usec(pa_memblockq_get_length(u->sink_input->thread_info.render_memblockq), &u->sink_in… in sink_process_msg_cb()
270 *((int64_t*) data) += pa_resampler_get_delay_usec(u->sink_input->thread_info.resampler); in sink_process_msg_cb()
286 !PA_SINK_INPUT_IS_LINKED(u->sink_input->state)) in sink_set_state_in_main_thread_cb()
289 pa_sink_input_cork(u->sink_input, state == PA_SINK_SUSPENDED); in sink_set_state_in_main_thread_cb()
304 pa_sink_input_request_rewind(u->sink_input, 0, false, true, true); in sink_set_state_in_io_thread_cb()
318 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) in sink_request_rewind_cb()
[all …]
Dmodule-stream-restore.c1314 pa_sink_input *sink_input; in subscribe_callback() local
1316 if (!(sink_input = pa_idxset_get_by_index(c->sink_inputs, idx))) in subscribe_callback()
1321 if (sink_input->origin_sink) in subscribe_callback()
1324 …if (!(name = pa_proplist_get_stream_group(sink_input->proplist, "sink-input", IDENTIFICATION_PROPE… in subscribe_callback()
1333 if (sink_input->save_volume && pa_sink_input_is_volume_readable(sink_input)) { in subscribe_callback()
1334 pa_assert(sink_input->volume_writable); in subscribe_callback()
1336 entry->channel_map = sink_input->channel_map; in subscribe_callback()
1337 pa_sink_input_get_volume(sink_input, &entry->volume, false); in subscribe_callback()
1346 if (sink_input->save_muted) { in subscribe_callback()
1347 entry->muted = sink_input->muted; in subscribe_callback()
[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()
/third_party/pulseaudio/src/modules/rtp/
Dmodule-rtp-recv.c89 pa_sink_input *sink_input; member
139 …c_t*) data) = pa_bytes_to_usec(pa_memblockq_get_length(s->memblockq), &s->sink_input->sample_spec); in sink_input_process_msg()
230 if (!PA_SINK_IS_OPENED(s->sink_input->sink->thread_info.state)) { in rtpoll_work_cb()
276 uint32_t current_rate = s->sink_input->sample_spec.rate; in rtpoll_work_cb()
282 …wi = pa_bytes_to_usec((uint64_t) pa_memblockq_get_write_index(s->memblockq), &s->sink_input->sampl… in rtpoll_work_cb()
283 …ri = pa_bytes_to_usec((uint64_t) pa_memblockq_get_read_index(s->memblockq), &s->sink_input->sample… in rtpoll_work_cb()
287 sink_delay = pa_sink_get_latency_within_thread(s->sink_input->sink, false); in rtpoll_work_cb()
288 sink_delay += pa_resampler_get_delay_usec(s->sink_input->thread_info.resampler); in rtpoll_work_cb()
289 …y = pa_bytes_to_usec(pa_memblockq_get_length(s->sink_input->thread_info.render_memblockq), &s->sin… in rtpoll_work_cb()
355 s->sink_input->sample_spec.rate = new_rate; in rtpoll_work_cb()
[all …]
/third_party/pulseaudio/src/modules/dbus/
Diface-stream.c43 pa_sink_input *sink_input; member
191 idx = (s->type == STREAM_TYPE_PLAYBACK) ? s->sink_input->index : s->source_output->index; in handle_get_index()
199 return pa_sprintf_malloc("Playback stream %u", (unsigned) s->sink_input->index); in stream_to_string()
212 driver = (s->type == STREAM_TYPE_PLAYBACK) ? s->sink_input->driver : s->source_output->driver; in handle_get_driver()
235 …owner_module = (s->type == STREAM_TYPE_PLAYBACK) ? s->sink_input->module : s->source_output->modul… in handle_get_owner_module()
260 client = (s->type == STREAM_TYPE_PLAYBACK) ? s->sink_input->client : s->source_output->client; in handle_get_client()
301 ? s->sink_input->sample_spec.format in handle_get_sample_format()
327 …channel_map = (s->type == STREAM_TYPE_PLAYBACK) ? &s->sink_input->channel_map : &s->source_output-… in handle_get_channels()
374 volume_writable = (s->type == STREAM_TYPE_PLAYBACK) ? s->sink_input->volume_writable : false; in handle_set_volume()
388 stream_channels = s->sink_input->channel_map.channels; in handle_set_volume()
[all …]
Diface-stream.h39 …iface_stream *pa_dbusiface_stream_new_playback(pa_dbusiface_core *core, pa_sink_input *sink_input);
Diface-core.h39 …*pa_dbusiface_core_get_playback_stream_path(pa_dbusiface_core *c, const pa_sink_input *sink_input);
Diface-client.c180 pa_sink_input *sink_input = NULL; in get_playback_streams() local
192 PA_IDXSET_FOREACH(sink_input, c->client->sink_inputs, idx) in get_playback_streams()
193 playback_streams[i++] = pa_dbusiface_core_get_playback_stream_path(c->core, sink_input); in get_playback_streams()
Diface-core.c1886 pa_sink_input *sink_input = call_data; in sink_input_put_cb() local
1892 pa_assert(sink_input); in sink_input_put_cb()
1894 stream_iface = pa_dbusiface_stream_new_playback(c, sink_input); in sink_input_put_cb()
1895 …pa_assert_se(pa_hashmap_put(c->playback_streams, PA_UINT32_TO_PTR(sink_input->index), stream_iface… in sink_input_put_cb()
1912 pa_sink_input *sink_input = call_data; in sink_input_unlink_cb() local
1918 pa_assert(sink_input); in sink_input_unlink_cb()
1920 …pa_assert_se((stream_iface = pa_hashmap_remove(c->playback_streams, PA_UINT32_TO_PTR(sink_input->i… in sink_input_unlink_cb()
2177 pa_sink_input *sink_input; in pa_dbusiface_core_new() local
2269 PA_IDXSET_FOREACH(sink_input, core->sink_inputs, idx) in pa_dbusiface_core_new()
2270 …p_put(c->playback_streams, PA_UINT32_TO_PTR(idx), pa_dbusiface_stream_new_playback(c, sink_input)); in pa_dbusiface_core_new()
[all …]
/third_party/pulseaudio/src/pulsecore/
Dplay-memblockq.c37 pa_sink_input *sink_input; member
51 if (!u->sink_input) in memblockq_stream_unlink()
54 pa_sink_input_unlink(u->sink_input); in memblockq_stream_unlink()
55 pa_sink_input_unref(u->sink_input); in memblockq_stream_unlink()
56 u->sink_input = NULL; in memblockq_stream_unlink()
196 u->sink_input = NULL; in pa_memblockq_sink_input_new()
208 pa_sink_input_new(&u->sink_input, sink->core, &data); in pa_memblockq_sink_input_new()
211 if (!u->sink_input) in pa_memblockq_sink_input_new()
214 u->sink_input->pop = sink_input_pop_cb; in pa_memblockq_sink_input_new()
215 u->sink_input->process_rewind = sink_input_process_rewind_cb; in pa_memblockq_sink_input_new()
[all …]
Dsound-file-stream.c50 pa_sink_input *sink_input; member
71 if (!u->sink_input) in file_stream_unlink()
74 pa_sink_input_unlink(u->sink_input); in file_stream_unlink()
75 pa_sink_input_unref(u->sink_input); in file_stream_unlink()
76 u->sink_input = NULL; in file_stream_unlink()
248 u->sink_input = NULL; in pa_play_file()
308 pa_sink_input_new(&u->sink_input, sink->core, &data); in pa_play_file()
311 if (!u->sink_input) in pa_play_file()
314 u->sink_input->pop = sink_input_pop_cb; in pa_play_file()
315 u->sink_input->process_rewind = sink_input_process_rewind_cb; in pa_play_file()
[all …]
Dprotocol-simple.c53 pa_sink_input *sink_input; member
106 if (c->sink_input) { in connection_unlink()
107 pa_sink_input_unlink(c->sink_input); in connection_unlink()
108 pa_sink_input_unref(c->sink_input); in connection_unlink()
109 c->sink_input = NULL; in connection_unlink()
157 if (!c->sink_input || (l = (size_t) pa_atomic_load(&c->playback.missing)) <= 0) in do_read()
199 …pa_asyncmsgq_post(c->sink_input->sink->asyncmsgq, PA_MSGOBJECT(c->sink_input), SINK_INPUT_MESSAGE_… in do_read()
249 if (!c->sink_input && pa_iochannel_is_hungup(c->io)) in do_work()
264 if (c->sink_input) { in do_work()
272 …pa_asyncmsgq_post(c->sink_input->sink->asyncmsgq, PA_MSGOBJECT(c->sink_input), SINK_INPUT_MESSAGE_… in do_work()
[all …]
Dprotocol-esound.c95 pa_sink_input *sink_input; member
216 if (c->sink_input) { in connection_unlink()
217 pa_sink_input_unlink(c->sink_input); in connection_unlink()
218 pa_sink_input_unref(c->sink_input); in connection_unlink()
219 c->sink_input = NULL; in connection_unlink()
419 pa_assert(!c->sink_input && !c->input_memblockq); in esd_proto_stream_play()
429 pa_sink_input_new(&c->sink_input, c->protocol->core, &sdata); in esd_proto_stream_play()
432 CHECK_VALIDITY(c->sink_input, "Failed to create sink input."); in esd_proto_stream_play()
435 pa_sink_input_get_silence(c->sink_input, &silence); in esd_proto_stream_play()
449 c->sink_input->parent.process_msg = sink_input_process_msg; in esd_proto_stream_play()
[all …]
Dprotocol-native.c124 pa_sink_input *sink_input; member
640 if (s->sink_input) { in playback_stream_unlink()
641 pa_sink_input_unlink(s->sink_input); in playback_stream_unlink()
642 pa_sink_input_unref(s->sink_input); in playback_stream_unlink()
643 s->sink_input = NULL; in playback_stream_unlink()
789 …(unsigned long) (pa_bytes_to_usec(s->buffer_attr_req.maxlength, &s->sink_input->sample_spec) / PA_… in fix_playback_buffer_attr()
790 …(unsigned long) (pa_bytes_to_usec(s->buffer_attr_req.tlength, &s->sink_input->sample_spec) / PA_US… in fix_playback_buffer_attr()
791 …(unsigned long) (pa_bytes_to_usec(s->buffer_attr_req.minreq, &s->sink_input->sample_spec) / PA_USE… in fix_playback_buffer_attr()
792 …(unsigned long) (pa_bytes_to_usec(s->buffer_attr_req.prebuf, &s->sink_input->sample_spec) / PA_USE… in fix_playback_buffer_attr()
800 frame_size = pa_frame_size(&s->sink_input->sample_spec); in fix_playback_buffer_attr()
[all …]
Dsink-input.h301 pa_sink_input *sink_input; member
Dcli-command.c1101 pa_sink_input *sink_input; in pa_cli_command_kill_sink_input() local
1119 if (!(sink_input = pa_idxset_get_by_index(c->sink_inputs, idx))) { in pa_cli_command_kill_sink_input()
1124 pa_sink_input_kill(sink_input); in pa_cli_command_kill_sink_input()
/third_party/pulseaudio/src/modules/echo-cancel/
Dmodule-echo-cancel.c232 pa_sink_input *sink_input; member
304 plen = pa_bytes_to_usec(snapshot->plen, &u->sink_input->sample_spec); in calc_diff()
312 sink_delay = pa_bytes_to_usec(snapshot->sink_delay, &u->sink_input->sample_spec); in calc_diff()
355 …pa_asyncmsgq_send(u->sink_input->sink->asyncmsgq, PA_MSGOBJECT(u->sink_input), SINK_INPUT_MESSAGE_… in time_callback()
361 old_rate = u->sink_input->sample_spec.rate; in time_callback()
393 pa_sink_input_set_rate(u->sink_input, new_rate); in time_callback()
450 !PA_SINK_INPUT_IS_LINKED(u->sink_input->thread_info.state)) { in sink_process_msg_cb()
458 pa_sink_get_latency_within_thread(u->sink_input->sink, true) + in sink_process_msg_cb()
461 …pa_bytes_to_usec(pa_memblockq_get_length(u->sink_input->thread_info.render_memblockq), &u->sink_in… in sink_process_msg_cb()
464 *((int64_t*) data) += pa_resampler_get_delay_usec(u->sink_input->thread_info.resampler); in sink_process_msg_cb()
[all …]
/third_party/pulseaudio/src/modules/alsa/
Dmodule-alsa-card.c784 static pa_hook_result_t sink_input_put_hook_callback(pa_core *c, pa_sink_input *sink_input, struct … in sink_input_put_hook_callback() argument
786 pa_sink *sink = sink_input->sink; in sink_input_put_hook_callback()
790 role = pa_proplist_gets(sink_input->proplist, PA_PROP_MEDIA_ROLE); in sink_input_put_hook_callback()
814 static pa_hook_result_t sink_input_unlink_hook_callback(pa_core *c, pa_sink_input *sink_input, stru… in sink_input_unlink_hook_callback() argument
816 pa_sink *sink = sink_input->sink; in sink_input_unlink_hook_callback()
820 role = pa_proplist_gets(sink_input->proplist, PA_PROP_MEDIA_ROLE); in sink_input_unlink_hook_callback()

12