mirrors/pulseaudio
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pulseaudio/pulseaudio.git synced 2025-11-01 22:58:47 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

combine-sink: add support for DYNAMIC_LATENCY

Browse source 
Mark the sink as DYNAMIC_LATENCY and implement update_sink_latency_range
on its sink-input to collect the combined latency range of all sinks.

Implement update_requested_latency on the sink to configure the final
latency by combining the sink-input requested latencies. This makes us
honour the client latency request.

Also add more debug log.

Fixes https://bugs.freedesktop.org/show_bug.cgi?id=47899
This commit is contained in:
Wim Taymans 2014-06-10 21:38:28 +02:00 • committed by Tanu Kaskinen
parent 38c5d6d585
commit 23f120aabb
1 changed files with 107 additions and 35 deletions
Download patch file Download diff file Expand all files Collapse all files

142
src/modules/module-combine-sink.c
View file

@ -104,7 +104,8 @@ struct output {
/* For communication of the stream parameters to the sink thread */ /* For communication of the stream parameters to the sink thread */
pa_atomic_t max_request; pa_atomic_t max_request;
pa_atomic_t requested_latency; pa_atomic_t max_latency;
pa_atomic_t min_latency;
PA_LLIST_FIELDS(struct output); PA_LLIST_FIELDS(struct output);
}; };
@ -131,6 +132,8 @@ struct userdata {
pa_resample_method_t resample_method; pa_resample_method_t resample_method;
pa_usec_t block_usec; pa_usec_t block_usec;
pa_usec_t default_min_latency;
pa_usec_t default_max_latency;
pa_idxset* outputs; /* managed in main context */ pa_idxset* outputs; /* managed in main context */
@ -150,11 +153,12 @@ enum {
SINK_MESSAGE_NEED, SINK_MESSAGE_NEED,
SINK_MESSAGE_UPDATE_LATENCY, SINK_MESSAGE_UPDATE_LATENCY,
SINK_MESSAGE_UPDATE_MAX_REQUEST, SINK_MESSAGE_UPDATE_MAX_REQUEST,
SINK_MESSAGE_UPDATE_REQUESTED_LATENCY SINK_MESSAGE_UPDATE_LATENCY_RANGE
}; };
enum { enum {
SINK_INPUT_MESSAGE_POST = PA_SINK_INPUT_MESSAGE_MAX, SINK_INPUT_MESSAGE_POST = PA_SINK_INPUT_MESSAGE_MAX,
SINK_INPUT_MESSAGE_SET_REQUESTED_LATENCY
}; };
static void output_disable(struct output *o); static void output_disable(struct output *o);
@ -469,35 +473,44 @@ static void sink_input_update_max_request_cb(pa_sink_input *i, size_t nbytes) {
return; return;
pa_atomic_store(&o->max_request, (int) nbytes); pa_atomic_store(&o->max_request, (int) nbytes);
pa_log_debug("Sink input update max request %lu", (unsigned long) nbytes);
pa_asyncmsgq_post(o->outq, PA_MSGOBJECT(o->userdata->sink), SINK_MESSAGE_UPDATE_MAX_REQUEST, NULL, 0, NULL, NULL); pa_asyncmsgq_post(o->outq, PA_MSGOBJECT(o->userdata->sink), SINK_MESSAGE_UPDATE_MAX_REQUEST, NULL, 0, NULL, NULL);
} }
/* Called from thread context */ /* Called from thread context */
static void sink_input_update_sink_requested_latency_cb(pa_sink_input *i) { static void sink_input_update_sink_latency_range_cb(pa_sink_input *i) {
struct output *o; struct output *o;
pa_usec_t c; pa_usec_t min, max, fix;
pa_assert(i); pa_assert(i);
pa_sink_input_assert_ref(i); pa_sink_input_assert_ref(i);
pa_assert_se(o = i->userdata); pa_assert_se(o = i->userdata);
c = pa_sink_get_requested_latency_within_thread(i->sink); fix = i->sink->thread_info.fixed_latency;
if (fix > 0) {
min = fix;
max = fix;
} else {
min = i->sink->thread_info.min_latency;
max = i->sink->thread_info.max_latency;
}
if (c == (pa_usec_t) -1) if ((pa_atomic_load(&o->min_latency) == (int) min) &&
c = i->sink->thread_info.max_latency; (pa_atomic_load(&o->max_latency) == (int) max))
if (pa_atomic_load(&o->requested_latency) == (int) c)
return; return;
pa_atomic_store(&o->requested_latency, (int) c); pa_atomic_store(&o->min_latency, (int) min);
pa_asyncmsgq_post(o->outq, PA_MSGOBJECT(o->userdata->sink), SINK_MESSAGE_UPDATE_REQUESTED_LATENCY, NULL, 0, NULL, NULL); pa_atomic_store(&o->max_latency, (int) max);
pa_log_debug("Sink input update latency range %lu %lu", (unsigned long) min, (unsigned long) max);
pa_asyncmsgq_post(o->outq, PA_MSGOBJECT(o->userdata->sink), SINK_MESSAGE_UPDATE_LATENCY_RANGE, NULL, 0, NULL, NULL);
} }
/* Called from I/O thread context */ /* Called from I/O thread context */
static void sink_input_attach_cb(pa_sink_input *i) { static void sink_input_attach_cb(pa_sink_input *i) {
struct output *o; struct output *o;
pa_usec_t c; pa_usec_t fix, min, max;
size_t nbytes;
pa_sink_input_assert_ref(i); pa_sink_input_assert_ref(i);
pa_assert_se(o = i->userdata); pa_assert_se(o = i->userdata);
@ -517,10 +530,20 @@ static void sink_input_attach_cb(pa_sink_input *i) {
pa_sink_input_request_rewind(i, 0, false, true, true); pa_sink_input_request_rewind(i, 0, false, true, true);
pa_atomic_store(&o->max_request, (int) pa_sink_input_get_max_request(i)); nbytes = pa_sink_input_get_max_request(i);
pa_atomic_store(&o->max_request, (int) nbytes);
pa_log_debug("attach max request %lu", (unsigned long) nbytes);
c = pa_sink_get_requested_latency_within_thread(i->sink); fix = i->sink->thread_info.fixed_latency;
pa_atomic_store(&o->requested_latency, (int) (c == (pa_usec_t) -1 ? 0 : c)); if (fix > 0) {
min = max = fix;
} else {
min = i->sink->thread_info.min_latency;
max = i->sink->thread_info.max_latency;
}
pa_atomic_store(&o->min_latency, (int) min);
pa_atomic_store(&o->max_latency, (int) max);
pa_log_debug("attach latency range %lu %lu", (unsigned long) min, (unsigned long) max);
/* We register the output. That means that the sink will start to pass data to /* We register the output. That means that the sink will start to pass data to
* this output. */ * this output. */
@ -547,6 +570,7 @@ static void sink_input_detach_cb(pa_sink_input *i) {
pa_rtpoll_item_free(o->outq_rtpoll_item_write); pa_rtpoll_item_free(o->outq_rtpoll_item_write);
o->outq_rtpoll_item_write = NULL; o->outq_rtpoll_item_write = NULL;
} }
} }
/* Called from main context */ /* Called from main context */
@ -585,6 +609,14 @@ static int sink_input_process_msg(pa_msgobject *obj, int code, void *data, int64
pa_memblockq_flush_write(o->memblockq, true); pa_memblockq_flush_write(o->memblockq, true);
return 0; return 0;
case SINK_INPUT_MESSAGE_SET_REQUESTED_LATENCY: {
pa_usec_t latency = (pa_usec_t) offset;
pa_sink_input_set_requested_latency_within_thread(o->sink_input, latency);
return 0;
}
} }
return pa_sink_input_process_msg(obj, code, data, offset, chunk); return pa_sink_input_process_msg(obj, code, data, offset, chunk);
@ -676,31 +708,42 @@ static void update_max_request(struct userdata *u) {
if (max_request <= 0) if (max_request <= 0)
max_request = pa_usec_to_bytes(u->block_usec, &u->sink->sample_spec); max_request = pa_usec_to_bytes(u->block_usec, &u->sink->sample_spec);
pa_log_debug("Sink update max request %lu", (unsigned long) max_request);
pa_sink_set_max_request_within_thread(u->sink, max_request); pa_sink_set_max_request_within_thread(u->sink, max_request);
} }
/* Called from IO context */ /* Called from IO context */
static void update_fixed_latency(struct userdata *u) { static void update_latency_range(struct userdata *u) {
pa_usec_t fixed_latency = 0; pa_usec_t min_latency = 0, max_latency = (pa_usec_t) -1;
struct output *o; struct output *o;
pa_assert(u); pa_assert(u);
pa_sink_assert_io_context(u->sink); pa_sink_assert_io_context(u->sink);
/* Collects the requested_latency values of all streams and sets /* Collects the latency_range values of all streams and sets
* the largest one as fixed_latency locally */ * the max of min and min of max locally */
PA_LLIST_FOREACH(o, u->thread_info.active_outputs) { PA_LLIST_FOREACH(o, u->thread_info.active_outputs) {
pa_usec_t rl = (size_t) pa_atomic_load(&o->requested_latency); pa_usec_t min = (size_t) pa_atomic_load(&o->min_latency);
pa_usec_t max = (size_t) pa_atomic_load(&o->max_latency);
if (rl > fixed_latency) if (min > min_latency)
fixed_latency = rl; min_latency = min;
if (max_latency == (pa_usec_t) -1 || max < max_latency)
max_latency = max;
} }
if (max_latency == (pa_usec_t) -1) {
/* no outputs, use block size */
min_latency = u->default_min_latency;
max_latency = u->default_max_latency;
}
else if (max_latency < min_latency)
max_latency = min_latency;
if (fixed_latency <= 0) /* never go below the min_latency or BLOCK_USEC */
fixed_latency = u->block_usec; max_latency = MIN (max_latency, MAX (min_latency, BLOCK_USEC));
pa_sink_set_fixed_latency_within_thread(u->sink, fixed_latency); pa_log_debug("Sink update latency range %lu %lu", min_latency, max_latency);
pa_sink_set_latency_range_within_thread(u->sink, min_latency, max_latency);
} }
/* Called from thread context of the io thread */ /* Called from thread context of the io thread */
@ -724,7 +767,6 @@ static void output_add_within_thread(struct output *o) {
/* Called from thread context of the io thread */ /* Called from thread context of the io thread */
static void output_remove_within_thread(struct output *o) { static void output_remove_within_thread(struct output *o) {
pa_assert(o); pa_assert(o);
pa_sink_assert_io_context(o->sink); pa_sink_assert_io_context(o->sink);
@ -741,6 +783,28 @@ static void output_remove_within_thread(struct output *o) {
} }
} }
/* Called from sink I/O thread context */
static void sink_update_requested_latency(pa_sink *s) {
struct userdata *u;
struct output *o;
pa_sink_assert_ref(s);
pa_assert_se(u = s->userdata);
u->block_usec = pa_sink_get_requested_latency_within_thread(s);
if (u->block_usec == (pa_usec_t) -1)
u->block_usec = s->thread_info.max_latency;
pa_log_debug("Sink update requested latency %0.2f", (double) u->block_usec / PA_USEC_PER_MSEC);
/* Just hand this one over to all sink_inputs */
PA_LLIST_FOREACH(o, u->thread_info.active_outputs) {
pa_asyncmsgq_post(o->inq, PA_MSGOBJECT(o->sink_input), SINK_INPUT_MESSAGE_SET_REQUESTED_LATENCY, NULL, u->block_usec, NULL, NULL);
}
}
/* Called from thread context of the io thread */ /* Called from thread context of the io thread */
static int sink_process_msg(pa_msgobject *o, int code, void *data, int64_t offset, pa_memchunk *chunk) { static int sink_process_msg(pa_msgobject *o, int code, void *data, int64_t offset, pa_memchunk *chunk) {
struct userdata *u = PA_SINK(o)->userdata; struct userdata *u = PA_SINK(o)->userdata;
@ -779,13 +843,13 @@ static int sink_process_msg(pa_msgobject *o, int code, void *data, int64_t offse
case SINK_MESSAGE_ADD_OUTPUT: case SINK_MESSAGE_ADD_OUTPUT:
output_add_within_thread(data); output_add_within_thread(data);
update_max_request(u); update_max_request(u);
update_fixed_latency(u); update_latency_range(u);
return 0; return 0;
case SINK_MESSAGE_REMOVE_OUTPUT: case SINK_MESSAGE_REMOVE_OUTPUT:
output_remove_within_thread(data); output_remove_within_thread(data);
update_max_request(u); update_max_request(u);
update_fixed_latency(u); update_latency_range(u);
return 0; return 0;
case SINK_MESSAGE_NEED: case SINK_MESSAGE_NEED:
@ -811,9 +875,10 @@ static int sink_process_msg(pa_msgobject *o, int code, void *data, int64_t offse
update_max_request(u); update_max_request(u);
break; break;
case SINK_MESSAGE_UPDATE_REQUESTED_LATENCY: case SINK_MESSAGE_UPDATE_LATENCY_RANGE:
update_fixed_latency(u); update_latency_range(u);
break; break;
} }
return pa_sink_process_msg(o, code, data, offset, chunk); return pa_sink_process_msg(o, code, data, offset, chunk);
@ -885,7 +950,7 @@ static int output_create_sink_input(struct output *o) {
o->sink_input->process_rewind = sink_input_process_rewind_cb; o->sink_input->process_rewind = sink_input_process_rewind_cb;
o->sink_input->update_max_rewind = sink_input_update_max_rewind_cb; o->sink_input->update_max_rewind = sink_input_update_max_rewind_cb;
o->sink_input->update_max_request = sink_input_update_max_request_cb; o->sink_input->update_max_request = sink_input_update_max_request_cb;
o->sink_input->update_sink_requested_latency = sink_input_update_sink_requested_latency_cb; o->sink_input->update_sink_latency_range = sink_input_update_sink_latency_range_cb;
o->sink_input->attach = sink_input_attach_cb; o->sink_input->attach = sink_input_attach_cb;
o->sink_input->detach = sink_input_detach_cb; o->sink_input->detach = sink_input_detach_cb;
o->sink_input->kill = sink_input_kill_cb; o->sink_input->kill = sink_input_kill_cb;
@ -974,7 +1039,6 @@ static void output_enable(struct output *o) {
/* Enable the sink input. That means that the sink /* Enable the sink input. That means that the sink
* is now asked for new data. */ * is now asked for new data. */
pa_sink_input_put(o->sink_input); pa_sink_input_put(o->sink_input);
} }
} }
@ -1138,6 +1202,7 @@ int pa__init(pa_module*m) {
uint32_t idx; uint32_t idx;
pa_sink_new_data data; pa_sink_new_data data;
uint32_t adjust_time_sec; uint32_t adjust_time_sec;
size_t nbytes;
pa_assert(m); pa_assert(m);
@ -1266,7 +1331,7 @@ int pa__init(pa_module*m) {
pa_proplist_sets(data.proplist, PA_PROP_DEVICE_DESCRIPTION, "Simultaneous Output"); pa_proplist_sets(data.proplist, PA_PROP_DEVICE_DESCRIPTION, "Simultaneous Output");
} }
u->sink = pa_sink_new(m->core, &data, PA_SINK_LATENCY); u->sink = pa_sink_new(m->core, &data, PA_SINK_LATENCY|PA_SINK_DYNAMIC_LATENCY);
pa_sink_new_data_done(&data); pa_sink_new_data_done(&data);
if (!u->sink) { if (!u->sink) {
@ -1276,13 +1341,20 @@ int pa__init(pa_module*m) {
u->sink->parent.process_msg = sink_process_msg; u->sink->parent.process_msg = sink_process_msg;
u->sink->set_state = sink_set_state; u->sink->set_state = sink_set_state;
u->sink->update_requested_latency = sink_update_requested_latency;
u->sink->userdata = u; u->sink->userdata = u;
pa_sink_set_rtpoll(u->sink, u->rtpoll); pa_sink_set_rtpoll(u->sink, u->rtpoll);
pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq); pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq);
u->block_usec = BLOCK_USEC; u->block_usec = BLOCK_USEC;
pa_sink_set_max_request(u->sink, pa_usec_to_bytes(u->block_usec, &u->sink->sample_spec)); nbytes = pa_usec_to_bytes(u->block_usec, &u->sink->sample_spec);
pa_sink_set_max_request(u->sink, nbytes);
pa_sink_set_latency_range(u->sink, 0, u->block_usec);
/* pulse clamps the range, get the real values */
u->default_min_latency = u->sink->thread_info.min_latency;
u->default_max_latency = u->sink->thread_info.max_latency;
if (!u->automatic) { if (!u->automatic) {
const char*split_state; const char*split_state;