mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-11-02 09:01:50 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

link: recalc latency when the peer latency changed

Browse source 
Trigger a recalculation of the port latency when the peer port
latency changed.

This makes the latency update from a port propagate through the
pipeline.
This commit is contained in:
Wim Taymans 2021-05-25 17:47:47 +02:00
parent cd58c51582
commit 80d48ad3b6
1 changed files with 16 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

16
src/pipewire/impl-link.c
View file

@ -846,16 +846,32 @@ static void output_port_state_changed(void *data, enum pw_impl_port_state old,
port_state_changed(this, this->output, this->input, state, error); port_state_changed(this, this->output, this->input, state, error);
} }
static void input_port_latency_changed(void *data)
{
struct impl *impl = data;
struct pw_impl_link *this = &impl->this;
pw_impl_port_recalc_latency(this->output);
}
static void output_port_latency_changed(void *data)
{
struct impl *impl = data;
struct pw_impl_link *this = &impl->this;
pw_impl_port_recalc_latency(this->input);
}
static const struct pw_impl_port_events input_port_events = { static const struct pw_impl_port_events input_port_events = {
PW_VERSION_IMPL_PORT_EVENTS, PW_VERSION_IMPL_PORT_EVENTS,
.param_changed = input_port_param_changed, .param_changed = input_port_param_changed,
.state_changed = input_port_state_changed, .state_changed = input_port_state_changed,
.latency_changed = input_port_latency_changed,
}; };
static const struct pw_impl_port_events output_port_events = { static const struct pw_impl_port_events output_port_events = {
PW_VERSION_IMPL_PORT_EVENTS, PW_VERSION_IMPL_PORT_EVENTS,
.param_changed = output_port_param_changed, .param_changed = output_port_param_changed,
.state_changed = output_port_state_changed, .state_changed = output_port_state_changed,
.latency_changed = output_port_latency_changed,
}; };
static void node_result(struct impl *impl, struct pw_impl_port *port, static void node_result(struct impl *impl, struct pw_impl_port *port,