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

spa-node: cleanup when the module unloads

Browse source
This commit is contained in:
Wim Taymans 2017-11-24 17:01:30 +01:00
parent e2c49199f6
commit f623556d9b
1 changed files with 40 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

46
src/modules/spa/module-node.c
View file

@ -33,11 +33,33 @@
#include "spa-monitor.h" #include "spa-monitor.h"
#include "spa-node.h" #include "spa-node.h"
struct node_data {
struct pw_node *this;
struct pw_core *core;
struct pw_properties *properties;
struct spa_hook module_listener;
};
static void module_destroy(void *_data)
{
struct node_data *data = _data;
pw_node_destroy(data->this);
}
static const struct pw_module_events module_events = {
PW_VERSION_MODULE_EVENTS,
.destroy = module_destroy,
};
bool pipewire__module_init(struct pw_module *module, const char *args) bool pipewire__module_init(struct pw_module *module, const char *args)
{ {
struct pw_properties *props = NULL; struct pw_properties *props = NULL;
char **argv; char **argv;
int i, n_tokens; int i, n_tokens;
struct pw_core *core = pw_module_get_core(module);
struct pw_node *node;
struct node_data *data;
if (args == NULL) if (args == NULL)
goto wrong_arguments; goto wrong_arguments;
@ -59,15 +81,27 @@ bool pipewire__module_init(struct pw_module *module, const char *args)
pw_free_strv(prop); pw_free_strv(prop);
} }
pw_spa_node_load(pw_module_get_core(module), node = pw_spa_node_load(core,
NULL, NULL,
pw_module_get_global(module), pw_module_get_global(module),
argv[0], argv[1], argv[2], argv[0], argv[1], argv[2],
PW_SPA_NODE_FLAG_ACTIVATE, PW_SPA_NODE_FLAG_ACTIVATE,
props, 0); props,
sizeof(struct node_data));
pw_free_strv(argv); pw_free_strv(argv);
if (node == NULL)
return false;
data = pw_spa_node_get_user_data(node);
data->this = node;
data->core = core;
data->properties = props;
pw_log_debug("module %p: new", module);
pw_module_add_listener(module, &data->module_listener, &module_events, data);
return true; return true;
not_enough_arguments: not_enough_arguments: