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

policy-node: also handle the single stream move

Browse source
This commit is contained in:
Wim Taymans 2020-10-21 15:39:37 +02:00
parent bfac6f04db
commit 25e4f2088c
1 changed files with 13 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

21
src/examples/media-session/policy-node.c
View file

@ -725,6 +725,17 @@ static const struct sm_media_session_events session_events = {
.destroy = session_destroy, .destroy = session_destroy,
}; };
static int do_move_node(struct node *n, struct node *src, struct node *dst)
{
n->moving = true;
if (src)
unlink_nodes(n, src);
if (dst)
link_nodes(n, dst);
n->moving = false;
return 0;
}
static int move_node(struct impl *impl, uint32_t source, uint32_t target) static int move_node(struct impl *impl, uint32_t source, uint32_t target)
{ {
struct node *n, *src_node, *dst_node; struct node *n, *src_node, *dst_node;
@ -758,10 +769,7 @@ static int move_node(struct impl *impl, uint32_t source, uint32_t target)
pw_properties_parse_bool(str)) pw_properties_parse_bool(str))
continue; continue;
n->moving = true; do_move_node(n, src_node, dst_node);
unlink_nodes(n, src_node);
link_nodes(n, dst_node);
n->moving = false;
} }
return 0; return 0;
} }
@ -792,10 +800,7 @@ static int handle_move(struct impl *impl, struct node *src_node, struct node *ds
str = get_device_name(dst_node); str = get_device_name(dst_node);
src_node->obj->target_node = str ? strdup(str) : NULL; src_node->obj->target_node = str ? strdup(str) : NULL;
if (src_node->peer) return do_move_node(src_node, src_node->peer, dst_node);
unlink_nodes(src_node, src_node->peer);
link_nodes(src_node, dst_node);
return 0;
} }
static int metadata_property(void *object, uint32_t subject, static int metadata_property(void *object, uint32_t subject,