mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-11-04 13:30:12 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

media-session: keep track of links

Browse source 
Also keep track of links when not tracked in the endpoint link.
This commit is contained in:
Wim Taymans 2020-07-15 14:19:25 +02:00
parent 5194c8a92f
commit 035fb26d71
1 changed files with 9 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

11
src/examples/media-session/media-session.c
View file

@ -121,6 +121,8 @@ struct impl {
struct spa_list endpoint_link_list; /** list of struct endpoint_link */ struct spa_list endpoint_link_list; /** list of struct endpoint_link */
struct pw_map endpoint_links; /** map of endpoint_link */ struct pw_map endpoint_links; /** map of endpoint_link */
struct spa_list link_list; /** list of struct link */
struct spa_list sync_list; /** list of struct sync */ struct spa_list sync_list; /** list of struct sync */
int rescan_seq; int rescan_seq;
int last_seq; int last_seq;
@ -147,7 +149,8 @@ struct link {
uint32_t input_port; uint32_t input_port;
struct endpoint_link *endpoint_link; struct endpoint_link *endpoint_link;
struct spa_list link; /**< link in struct endpoint_link link_list */ struct spa_list link; /**< link in struct endpoint_link link_list or
* struct impl link_list */
}; };
struct object_info { struct object_info {
@ -1406,8 +1409,9 @@ static void proxy_link_destroy(void *data)
{ {
struct link *l = data; struct link *l = data;
if (l->endpoint_link) {
spa_list_remove(&l->link); spa_list_remove(&l->link);
if (l->endpoint_link) {
check_endpoint_link(l->endpoint_link); check_endpoint_link(l->endpoint_link);
l->endpoint_link = NULL; l->endpoint_link = NULL;
} }
@ -1467,6 +1471,8 @@ static int link_nodes(struct impl *impl, struct endpoint_link *link,
if (link) { if (link) {
l->endpoint_link = link; l->endpoint_link = link;
spa_list_append(&link->link_list, &l->link); spa_list_append(&link->link_list, &l->link);
} else {
spa_list_append(&impl->link_list, &l->link);
} }
outport = spa_list_next(outport, link); outport = spa_list_next(outport, link);
@ -1859,6 +1865,7 @@ int main(int argc, char *argv[])
pw_map_init(&impl.globals, 64, 64); pw_map_init(&impl.globals, 64, 64);
spa_list_init(&impl.global_list); spa_list_init(&impl.global_list);
spa_list_init(&impl.link_list);
pw_map_init(&impl.endpoint_links, 64, 64); pw_map_init(&impl.endpoint_links, 64, 64);
spa_list_init(&impl.endpoint_link_list); spa_list_init(&impl.endpoint_link_list);
spa_list_init(&impl.sync_list); spa_list_init(&impl.sync_list);