mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-12-16 08:56:45 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

pulse-tunnel: add pulse.latency option

Browse source 
Add a pulse.latency option to override the default 100ms latency.
This commit is contained in:
Wim Taymans 2021-09-23 13:11:52 +02:00
parent 88ba3014d6
commit cb474043fa
1 changed files with 11 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

14
src/modules/module-pulse-tunnel.c
View file

@ -65,6 +65,7 @@
"[ audio.channels=<number of channels> ] " \ "[ audio.channels=<number of channels> ] " \
"[ audio.position=<channel map> ] " \ "[ audio.position=<channel map> ] " \
"pulse.server.address=<address> " \ "pulse.server.address=<address> " \
"pulse.latency=<latency in usec> " \
"[ tunnel.mode=capture|playback " \ "[ tunnel.mode=capture|playback " \
"[ stream.props=<properties> ] " "[ stream.props=<properties> ] "
@ -98,6 +99,8 @@ struct impl {
struct spa_hook core_proxy_listener; struct spa_hook core_proxy_listener;
struct spa_hook core_listener; struct spa_hook core_listener;
uint64_t latency_usec;
struct pw_properties *stream_props; struct pw_properties *stream_props;
struct pw_stream *stream; struct pw_stream *stream;
struct spa_hook stream_listener; struct spa_hook stream_listener;
@ -322,7 +325,7 @@ static int create_stream(struct impl *impl)
spa_zero(latency); spa_zero(latency);
latency.direction = impl->mode == MODE_CAPTURE ? PW_DIRECTION_OUTPUT : PW_DIRECTION_INPUT; latency.direction = impl->mode == MODE_CAPTURE ? PW_DIRECTION_OUTPUT : PW_DIRECTION_INPUT;
latency.min_ns = latency.max_ns = DEFAULT_LATENCY_USEC * 1000; latency.min_ns = latency.max_ns = impl->latency_usec * 1000;
params[n_params++] = spa_latency_build(&b, params[n_params++] = spa_latency_build(&b,
SPA_PARAM_Latency, &latency); SPA_PARAM_Latency, &latency);
@ -552,7 +555,7 @@ static int create_pulse_stream(struct impl *impl)
bufferattr.prebuf = (uint32_t) -1; bufferattr.prebuf = (uint32_t) -1;
if (impl->mode == MODE_CAPTURE) { if (impl->mode == MODE_CAPTURE) {
bufferattr.fragsize = pa_usec_to_bytes(DEFAULT_LATENCY_USEC, &ss); bufferattr.fragsize = pa_usec_to_bytes(impl->latency_usec, &ss);
res = pa_stream_connect_record(impl->pa_stream, res = pa_stream_connect_record(impl->pa_stream,
remote_node_target, &bufferattr, remote_node_target, &bufferattr,
@ -560,7 +563,7 @@ static int create_pulse_stream(struct impl *impl)
PA_STREAM_ADJUST_LATENCY | PA_STREAM_ADJUST_LATENCY |
PA_STREAM_AUTO_TIMING_UPDATE); PA_STREAM_AUTO_TIMING_UPDATE);
} else { } else {
bufferattr.tlength = pa_usec_to_bytes(DEFAULT_LATENCY_USEC, &ss); bufferattr.tlength = pa_usec_to_bytes(impl->latency_usec, &ss);
res = pa_stream_connect_playback(impl->pa_stream, res = pa_stream_connect_playback(impl->pa_stream,
remote_node_target, &bufferattr, remote_node_target, &bufferattr,
@ -777,6 +780,11 @@ int pipewire__module_init(struct pw_impl_module *module, const char *args)
goto error; goto error;
} }
} }
impl->latency_usec = DEFAULT_LATENCY_USEC;
if ((str = pw_properties_get(props, "pulse.latency")) != NULL)
spa_atou64(str, &impl->latency_usec, 0);
if (pw_properties_get(props, PW_KEY_NODE_GROUP) == NULL) if (pw_properties_get(props, PW_KEY_NODE_GROUP) == NULL)
pw_properties_set(props, PW_KEY_NODE_GROUP, "pipewire.dummy"); pw_properties_set(props, PW_KEY_NODE_GROUP, "pipewire.dummy");
if (pw_properties_get(props, PW_KEY_NODE_VIRTUAL) == NULL) if (pw_properties_get(props, PW_KEY_NODE_VIRTUAL) == NULL)