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-factory: also create links when possible

Browse source
This commit is contained in:
Wim Taymans 2018-09-10 18:49:41 +02:00
parent d1a399aadd
commit 3c76b150c7
1 changed files with 32 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

35
src/modules/module-link-factory.c
View file

@ -29,6 +29,7 @@
#include "pipewire/log.h" #include "pipewire/log.h"
#include "pipewire/module.h" #include "pipewire/module.h"
#include "pipewire/link.h" #include "pipewire/link.h"
#include "pipewire/private.h"
static const struct spa_dict_item module_props[] = { static const struct spa_dict_item module_props[] = {
{ PW_MODULE_PROP_AUTHOR, "Wim Taymans <wim.taymans@gmail.com>" }, { PW_MODULE_PROP_AUTHOR, "Wim Taymans <wim.taymans@gmail.com>" },
@ -43,6 +44,33 @@ struct factory_data {
struct spa_hook module_listener; struct spa_hook module_listener;
}; };
static struct pw_port *get_port(struct pw_node *node, enum spa_direction direction)
{
struct pw_port *p;
int res;
p = pw_node_find_port(node, direction, SPA_ID_INVALID);
if (p == NULL || pw_port_is_linked(p)) {
uint32_t port_id;
port_id = pw_node_get_free_port_id(node, direction);
if (port_id == SPA_ID_INVALID)
return NULL;
p = pw_port_new(direction, port_id, NULL, 0);
if (p == NULL)
return NULL;
if ((res = pw_port_add(p, node)) < 0) {
pw_log_warn("can't add port: %s", spa_strerror(res));
return NULL;
}
}
return p;
}
static void *create_object(void *_data, static void *create_object(void *_data,
struct pw_resource *resource, struct pw_resource *resource,
uint32_t type, uint32_t type,
@ -99,8 +127,9 @@ static void *create_object(void *_data,
input_node = pw_global_get_object(global); input_node = pw_global_get_object(global);
if (output_port_id == -1) if (output_port_id == -1) {
outport = pw_node_find_port(output_node, SPA_DIRECTION_OUTPUT, SPA_ID_INVALID); outport = get_port(output_node, SPA_DIRECTION_OUTPUT);
}
else { else {
global = pw_core_find_global(core, output_port_id); global = pw_core_find_global(core, output_port_id);
if (global == NULL || pw_global_get_type(global) != PW_TYPE_INTERFACE_Port) if (global == NULL || pw_global_get_type(global) != PW_TYPE_INTERFACE_Port)
@ -112,7 +141,7 @@ static void *create_object(void *_data,
goto no_output_port; goto no_output_port;
if (input_port_id == -1) if (input_port_id == -1)
inport = pw_node_find_port(input_node, SPA_DIRECTION_INPUT, SPA_ID_INVALID); inport = get_port(input_node, SPA_DIRECTION_INPUT);
else { else {
global = pw_core_find_global(core, input_port_id); global = pw_core_find_global(core, input_port_id);
if (global == NULL || pw_global_get_type(global) != PW_TYPE_INTERFACE_Port) if (global == NULL || pw_global_get_type(global) != PW_TYPE_INTERFACE_Port)