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

pw-link: Support destroying all links between ports of two nodes

Browse source 
With this commit, something like
`pw-link -d my-device alsa_output.headset` can be used to destroy
all links from output ports of `my-device` to input ports of
`alsa_output.headset`.
This commit is contained in:
Antonio Larrosa 2022-04-22 12:57:46 +02:00 • committed by Wim Taymans
parent 3a18da7cc3
commit 6dd3ee4e15
1 changed files with 36 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

42
src/tools/pw-link.c
View file

@ -427,7 +427,24 @@ static int do_link_ports(struct data *data)
static int do_unlink_ports(struct data *data) static int do_unlink_ports(struct data *data)
{ {
struct object *l, *n, *p; struct object *l, *n, *p;
uint32_t link_id = 0; bool found_any = false;
struct object *in_node = NULL, *out_node = NULL;
if (data->opt_input != NULL) {
/* 2 args, check if they are node names */
spa_list_for_each(n, &data->objects, link) {
if (n->type != OBJECT_NODE)
continue;
if (out_node == NULL && node_matches(data, n, data->opt_output)) {
out_node = n;
continue;
} else if (in_node == NULL && node_matches(data, n, data->opt_input)) {
in_node = n;
continue;
}
}
}
spa_list_for_each(l, &data->objects, link) { spa_list_for_each(l, &data->objects, link) {
if (l->type != OBJECT_LINK) if (l->type != OBJECT_LINK)
@ -437,6 +454,21 @@ static int do_unlink_ports(struct data *data)
/* 1 arg, check link id */ /* 1 arg, check link id */
if (l->id != (uint32_t)atoi(data->opt_output)) if (l->id != (uint32_t)atoi(data->opt_output))
continue; continue;
} else if (out_node && in_node) {
/* 2 args, check nodes */
if ((p = find_object(data, OBJECT_PORT, l->extra[0])) == NULL)
continue;
if ((n = find_object(data, OBJECT_NODE, p->extra[1])) == NULL)
continue;
if (n->id != out_node->id)
continue;
if ((p = find_object(data, OBJECT_PORT, l->extra[1])) == NULL)
continue;
if ((n = find_object(data, OBJECT_NODE, p->extra[1])) == NULL)
continue;
if (n->id != in_node->id)
continue;
} else { } else {
/* 2 args, check port names */ /* 2 args, check port names */
if ((p = find_object(data, OBJECT_PORT, l->extra[0])) == NULL) if ((p = find_object(data, OBJECT_PORT, l->extra[0])) == NULL)
@ -453,14 +485,12 @@ static int do_unlink_ports(struct data *data)
if (!port_matches(data, n, p, data->opt_input)) if (!port_matches(data, n, p, data->opt_input))
continue; continue;
} }
link_id = l->id; pw_registry_destroy(data->registry, l->id);
break; found_any = true;
} }
if (link_id == 0) if (!found_any)
return -ENOENT; return -ENOENT;
pw_registry_destroy(data->registry, link_id);
core_sync(data); core_sync(data);
pw_main_loop_run(data->loop); pw_main_loop_run(data->loop);