mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-11-04 13:30:12 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

pulse-server: combine-sink: add latency_compensate option

Browse source 
Add option to turn on latency compensation in module-combine-stream.
This commit is contained in:
Pauli Virtanen 2023-05-01 19:44:38 +03:00 • committed by Wim Taymans
parent cc5da73665
commit 10352dbaa5
1 changed files with 8 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

9
src/modules/module-protocol-pulse/modules/module-combine-sink.c
View file

@ -31,7 +31,8 @@ static const struct spa_dict_item module_combine_sink_info[] = {
"rate=<sample rate> " "rate=<sample rate> "
"channels=<number of channels> " "channels=<number of channels> "
"channel_map=<channel map> " "channel_map=<channel map> "
"remix=<remix channels> " }, "remix=<remix channels> "
"latency_compensate=<bool> " },
{ PW_KEY_MODULE_VERSION, PACKAGE_VERSION }, { PW_KEY_MODULE_VERSION, PACKAGE_VERSION },
}; };
@ -58,6 +59,7 @@ struct module_combine_sink_data {
unsigned int sinks_pending; unsigned int sinks_pending;
unsigned int remix:1; unsigned int remix:1;
unsigned int latency_compensate:1;
unsigned int load_emitted:1; unsigned int load_emitted:1;
unsigned int start_error:1; unsigned int start_error:1;
}; };
@ -154,6 +156,8 @@ static int module_combine_sink_load(struct module *module)
fprintf(f, "{"); fprintf(f, "{");
fprintf(f, " node.name = %s", data->sink_name); fprintf(f, " node.name = %s", data->sink_name);
fprintf(f, " node.description = %s", data->sink_name); fprintf(f, " node.description = %s", data->sink_name);
if (data->latency_compensate)
fprintf(f, " combine.latency-compensate = true");
if (data->info.rate != 0) if (data->info.rate != 0)
fprintf(f, " audio.rate = %u", data->info.rate); fprintf(f, " audio.rate = %u", data->info.rate);
if (data->info.channels != 0) { if (data->info.channels != 0) {
@ -280,6 +284,9 @@ static int module_combine_sink_prepare(struct module * const module)
pw_properties_set(props, "remix", NULL); pw_properties_set(props, "remix", NULL);
} }
if ((str = pw_properties_get(props, "latency_compensate")) != NULL)
d->latency_compensate = pw_properties_parse_bool(str);
if ((str = pw_properties_get(props, "adjust_time")) != NULL) { if ((str = pw_properties_get(props, "adjust_time")) != NULL) {
pw_log_info("The `adjust_time` modarg is ignored"); pw_log_info("The `adjust_time` modarg is ignored");
pw_properties_set(props, "adjust_time", NULL); pw_properties_set(props, "adjust_time", NULL);