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

client-stream: only add link once

Browse source
This commit is contained in:
Wim Taymans 2019-03-14 12:28:01 +01:00
parent 24117b33c7
commit 132dd760ee
2 changed files with 6 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

3
src/modules/module-client-node/client-stream.c
View file

@ -181,6 +181,9 @@ static void try_link_controls(struct impl *impl)
if (!impl->use_converter) if (!impl->use_converter)
return; return;
if (impl->control.valid || impl->notify.valid)
return;
target = pw_node_find_port(impl->this.node, impl->direction, 0); target = pw_node_find_port(impl->this.node, impl->direction, 0);
if (target == NULL) { if (target == NULL) {

6
src/pipewire/control.c
View file

@ -92,18 +92,18 @@ pw_control_new(struct pw_core *core,
void pw_control_destroy(struct pw_control *control) void pw_control_destroy(struct pw_control *control)
{ {
struct impl *impl = SPA_CONTAINER_OF(control, struct impl, this); struct impl *impl = SPA_CONTAINER_OF(control, struct impl, this);
struct pw_control_link *link, *tmp; struct pw_control_link *link;
pw_log_debug("control %p: destroy", control); pw_log_debug("control %p: destroy", control);
pw_control_emit_destroy(control); pw_control_emit_destroy(control);
if (control->direction == SPA_DIRECTION_OUTPUT) { if (control->direction == SPA_DIRECTION_OUTPUT) {
spa_list_for_each_safe(link, tmp, &control->links, out_link) spa_list_consume(link, &control->links, out_link)
pw_control_remove_link(link); pw_control_remove_link(link);
} }
else { else {
spa_list_for_each_safe(link, tmp, &control->links, in_link) spa_list_consume(link, &control->links, in_link)
pw_control_remove_link(link); pw_control_remove_link(link);
} }