summaryrefslogtreecommitdiffstats
path: root/spa/tools
diff options
context:
space:
mode:
authorDaniel Baumann <daniel.baumann@progress-linux.org>2024-04-07 18:28:17 +0000
committerDaniel Baumann <daniel.baumann@progress-linux.org>2024-04-07 18:28:17 +0000
commit7a46c07230b8d8108c0e8e80df4522d0ac116538 (patch)
treed483300dab478b994fe199a5d19d18d74153718a /spa/tools
parentInitial commit. (diff)
downloadpipewire-7a46c07230b8d8108c0e8e80df4522d0ac116538.tar.xz
pipewire-7a46c07230b8d8108c0e8e80df4522d0ac116538.zip
Adding upstream version 0.3.65.upstream/0.3.65upstream
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to '')
-rw-r--r--spa/tools/meson.build11
-rw-r--r--spa/tools/spa-inspect.c319
-rw-r--r--spa/tools/spa-json-dump.c165
-rw-r--r--spa/tools/spa-monitor.c229
4 files changed, 724 insertions, 0 deletions
diff --git a/spa/tools/meson.build b/spa/tools/meson.build
new file mode 100644
index 0000000..6f12e9c
--- /dev/null
+++ b/spa/tools/meson.build
@@ -0,0 +1,11 @@
+executable('spa-inspect', 'spa-inspect.c',
+ dependencies : [ spa_dep, dl_lib ],
+ install : true)
+
+executable('spa-monitor', 'spa-monitor.c',
+ dependencies : [ spa_dep, dl_lib ],
+ install : true)
+
+executable('spa-json-dump', 'spa-json-dump.c',
+ dependencies : [ spa_dep, dl_lib, ],
+ install : true)
diff --git a/spa/tools/spa-inspect.c b/spa/tools/spa-inspect.c
new file mode 100644
index 0000000..4e79104
--- /dev/null
+++ b/spa/tools/spa-inspect.c
@@ -0,0 +1,319 @@
+/* Simple Plugin API
+ *
+ * Copyright © 2018 Wim Taymans
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a
+ * copy of this software and associated documentation files (the "Software"),
+ * to deal in the Software without restriction, including without limitation
+ * the rights to use, copy, modify, merge, publish, distribute, sublicense,
+ * and/or sell copies of the Software, and to permit persons to whom the
+ * Software is furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice (including the next
+ * paragraph) shall be included in all copies or substantial portions of the
+ * Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
+ * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
+ * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
+ * DEALINGS IN THE SOFTWARE.
+ */
+
+#include <string.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <unistd.h>
+#include <dlfcn.h>
+
+#include <spa/support/plugin.h>
+#include <spa/support/log-impl.h>
+#include <spa/support/loop.h>
+#include <spa/utils/result.h>
+#include <spa/utils/string.h>
+#include <spa/node/node.h>
+#include <spa/node/utils.h>
+#include <spa/pod/parser.h>
+#include <spa/param/param.h>
+#include <spa/param/format.h>
+#include <spa/debug/dict.h>
+#include <spa/debug/pod.h>
+#include <spa/debug/format.h>
+#include <spa/debug/types.h>
+
+static SPA_LOG_IMPL(default_log);
+
+struct data {
+ struct spa_support support[4];
+ uint32_t n_support;
+ struct spa_log *log;
+ struct spa_loop loop;
+ struct spa_node *node;
+ struct spa_hook listener;
+};
+
+static void print_param(void *data, int seq, int res, uint32_t type, const void *result)
+{
+ switch (type) {
+ case SPA_RESULT_TYPE_NODE_PARAMS:
+ {
+ const struct spa_result_node_params *r = result;
+
+ if (spa_pod_is_object_type(r->param, SPA_TYPE_OBJECT_Format))
+ spa_debug_format(16, NULL, r->param);
+ else
+ spa_debug_pod(16, NULL, r->param);
+ break;
+ }
+ default:
+ break;
+ }
+}
+
+static void
+inspect_node_params(struct data *data, struct spa_node *node,
+ uint32_t n_params, struct spa_param_info *params)
+{
+ int res;
+ uint32_t i;
+ struct spa_hook listener;
+ static const struct spa_node_events node_events = {
+ SPA_VERSION_NODE_EVENTS,
+ .result = print_param,
+ };
+
+ for (i = 0; i < n_params; i++) {
+ printf("enumerating: %s:\n", spa_debug_type_find_name(spa_type_param, params[i].id));
+
+ if (!SPA_FLAG_IS_SET(params[i].flags, SPA_PARAM_INFO_READ))
+ continue;
+
+ spa_zero(listener);
+ spa_node_add_listener(node, &listener, &node_events, data);
+ res = spa_node_enum_params(node, 0, params[i].id, 0, UINT32_MAX, NULL);
+ spa_hook_remove(&listener);
+
+ if (res != 0) {
+ printf("error enum_params %d: %s", params[i].id, spa_strerror(res));
+ break;
+ }
+ }
+}
+
+static void
+inspect_port_params(struct data *data, struct spa_node *node,
+ enum spa_direction direction, uint32_t port_id,
+ uint32_t n_params, struct spa_param_info *params)
+{
+ int res;
+ uint32_t i;
+ struct spa_hook listener;
+ static const struct spa_node_events node_events = {
+ SPA_VERSION_NODE_EVENTS,
+ .result = print_param,
+ };
+
+ for (i = 0; i < n_params; i++) {
+ printf("param: %s: flags %c%c\n",
+ spa_debug_type_find_name(spa_type_param, params[i].id),
+ params[i].flags & SPA_PARAM_INFO_READ ? 'r' : '-',
+ params[i].flags & SPA_PARAM_INFO_WRITE ? 'w' : '-');
+
+ if (!SPA_FLAG_IS_SET(params[i].flags, SPA_PARAM_INFO_READ))
+ continue;
+
+ printf("values:\n");
+ spa_zero(listener);
+ spa_node_add_listener(node, &listener, &node_events, data);
+ res = spa_node_port_enum_params(node, 0,
+ direction, port_id,
+ params[i].id, 0, UINT32_MAX,
+ NULL);
+ spa_hook_remove(&listener);
+
+ if (res != 0) {
+ printf("error port_enum_params %d: %s", params[i].id, spa_strerror(res));
+ break;
+ }
+ }
+}
+
+static void node_info(void *_data, const struct spa_node_info *info)
+{
+ struct data *data = _data;
+
+ printf("node info: %08"PRIx64"\n", info->change_mask);
+ printf("max input ports: %u\n", info->max_input_ports);
+ printf("max output ports: %u\n", info->max_output_ports);
+
+ if (info->change_mask & SPA_NODE_CHANGE_MASK_PROPS) {
+ printf("node properties:\n");
+ spa_debug_dict(2, info->props);
+ }
+ if (info->change_mask & SPA_NODE_CHANGE_MASK_PARAMS) {
+ inspect_node_params(data, data->node, info->n_params, info->params);
+ }
+}
+
+static void node_port_info(void *_data, enum spa_direction direction, uint32_t id,
+ const struct spa_port_info *info)
+{
+ struct data *data = _data;
+
+ printf(" %s port: %08x",
+ direction == SPA_DIRECTION_INPUT ? "input" : "output",
+ id);
+
+ if (info == NULL) {
+ printf(" removed\n");
+ }
+ else {
+ printf(" info:\n");
+ if (info->change_mask & SPA_PORT_CHANGE_MASK_PROPS) {
+ printf("port properties:\n");
+ spa_debug_dict(2, info->props);
+ }
+ if (info->change_mask & SPA_PORT_CHANGE_MASK_PARAMS) {
+ inspect_port_params(data, data->node, direction, id,
+ info->n_params, info->params);
+ }
+ }
+}
+
+static const struct spa_node_events node_events =
+{
+ SPA_VERSION_NODE_EVENTS,
+ .info = node_info,
+ .port_info = node_port_info,
+};
+
+static void inspect_node(struct data *data, struct spa_node *node)
+{
+ data->node = node;
+ spa_node_add_listener(node, &data->listener, &node_events, data);
+ spa_hook_remove(&data->listener);
+}
+
+static void inspect_factory(struct data *data, const struct spa_handle_factory *factory)
+{
+ int res;
+ struct spa_handle *handle;
+ void *interface;
+ const struct spa_interface_info *info;
+ uint32_t index;
+
+ printf("factory version:\t\t%d\n", factory->version);
+ printf("factory name:\t\t'%s'\n", factory->name);
+ if (factory->version < 1) {
+ printf("\tno further info for version %d < 1\n", factory->version);
+ return;
+ }
+
+ printf("factory info:\n");
+ if (factory->info)
+ spa_debug_dict(2, factory->info);
+ else
+ printf(" none\n");
+
+ printf("factory interfaces:\n");
+ for (index = 0;;) {
+ if ((res = spa_handle_factory_enum_interface_info(factory, &info, &index)) <= 0) {
+ if (res != 0)
+ printf("error spa_handle_factory_enum_interface_info: %s",
+ spa_strerror(res));
+ break;
+ }
+ printf(" interface: '%s'\n", info->type);
+ }
+
+ handle = calloc(1, spa_handle_factory_get_size(factory, NULL));
+ if ((res =
+ spa_handle_factory_init(factory, handle, NULL, data->support, data->n_support)) < 0) {
+ printf("can't make factory instance: %d\n", res);
+ goto out;
+ }
+
+ printf("factory instance:\n");
+
+ for (index = 0;;) {
+ if ((res = spa_handle_factory_enum_interface_info(factory, &info, &index)) <= 0) {
+ if (res != 0)
+ printf("error spa_handle_factory_enum_interface_info: %s",
+ spa_strerror(res));
+ break;
+ }
+ printf(" interface: '%s'\n", info->type);
+
+ if ((res = spa_handle_get_interface(handle, info->type, &interface)) < 0) {
+ printf("can't get interface: %s: %d\n", info->type, res);
+ continue;
+ }
+
+ if (spa_streq(info->type, SPA_TYPE_INTERFACE_Node))
+ inspect_node(data, interface);
+ else
+ printf("skipping unknown interface\n");
+ }
+
+ if ((res = spa_handle_clear(handle)) < 0)
+ printf("failed to clear handle: %s\n", spa_strerror(res));
+
+out:
+ free(handle);
+}
+
+static const struct spa_loop_methods impl_loop = {
+ SPA_VERSION_LOOP_METHODS,
+};
+
+int main(int argc, char *argv[])
+{
+ struct data data = { 0 };
+ int res;
+ void *handle;
+ spa_handle_factory_enum_func_t enum_func;
+ uint32_t index;
+ const char *str;
+
+ if (argc < 2) {
+ printf("usage: %s <plugin.so>\n", argv[0]);
+ return -1;
+ }
+
+ data.log = &default_log.log;
+ data.loop.iface = SPA_INTERFACE_INIT(
+ SPA_TYPE_INTERFACE_Loop,
+ SPA_VERSION_LOOP,
+ &impl_loop, &data);
+
+ if ((str = getenv("SPA_DEBUG")))
+ data.log->level = atoi(str);
+
+ data.support[0] = SPA_SUPPORT_INIT(SPA_TYPE_INTERFACE_Log, data.log);
+ data.support[1] = SPA_SUPPORT_INIT(SPA_TYPE_INTERFACE_Loop, &data.loop);
+ data.support[2] = SPA_SUPPORT_INIT(SPA_TYPE_INTERFACE_DataLoop, &data.loop);
+ data.n_support = 3;
+
+ if ((handle = dlopen(argv[1], RTLD_NOW)) == NULL) {
+ printf("can't load %s\n", argv[1]);
+ return -1;
+ }
+ if ((enum_func = dlsym(handle, SPA_HANDLE_FACTORY_ENUM_FUNC_NAME)) == NULL) {
+ printf("can't find function\n");
+ return -1;
+ }
+
+ for (index = 0;;) {
+ const struct spa_handle_factory *factory;
+
+ if ((res = enum_func(&factory, &index)) <= 0) {
+ if (res != 0)
+ printf("error enum_func: %s", spa_strerror(res));
+ break;
+ }
+ inspect_factory(&data, factory);
+ }
+ return 0;
+}
diff --git a/spa/tools/spa-json-dump.c b/spa/tools/spa-json-dump.c
new file mode 100644
index 0000000..ae0c67d
--- /dev/null
+++ b/spa/tools/spa-json-dump.c
@@ -0,0 +1,165 @@
+/* Simple Plugin API
+ *
+ * Copyright © 2021 Wim Taymans
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a
+ * copy of this software and associated documentation files (the "Software"),
+ * to deal in the Software without restriction, including without limitation
+ * the rights to use, copy, modify, merge, publish, distribute, sublicense,
+ * and/or sell copies of the Software, and to permit persons to whom the
+ * Software is furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice (including the next
+ * paragraph) shall be included in all copies or substantial portions of the
+ * Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
+ * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
+ * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
+ * DEALINGS IN THE SOFTWARE.
+ */
+
+#include <string.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <unistd.h>
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <sys/mman.h>
+#include <fcntl.h>
+#include <errno.h>
+
+#include <spa/utils/result.h>
+#include <spa/utils/json.h>
+
+static void encode_string(FILE *f, const char *val, int len)
+{
+ int i;
+ fprintf(f, "\"");
+ for (i = 0; i < len; i++) {
+ char v = val[i];
+ switch (v) {
+ case '\n':
+ fprintf(f, "\\n");
+ break;
+ case '\r':
+ fprintf(f, "\\r");
+ break;
+ case '\b':
+ fprintf(f, "\\b");
+ break;
+ case '\t':
+ fprintf(f, "\\t");
+ break;
+ case '\f':
+ fprintf(f, "\\f");
+ break;
+ case '\\': case '"':
+ fprintf(f, "\\%c", v);
+ break;
+ default:
+ if (v > 0 && v < 0x20)
+ fprintf(f, "\\u%04x", v);
+ else
+ fprintf(f, "%c", v);
+ break;
+ }
+ }
+ fprintf(f, "\"");
+}
+
+static int dump(FILE *file, int indent, struct spa_json *it, const char *value, int len)
+{
+ struct spa_json sub;
+ int count = 0;
+ char key[1024];
+
+ if (spa_json_is_array(value, len)) {
+ fprintf(file, "[");
+ spa_json_enter(it, &sub);
+ while ((len = spa_json_next(&sub, &value)) > 0) {
+ fprintf(file, "%s\n%*s", count++ > 0 ? "," : "",
+ indent+2, "");
+ dump(file, indent+2, &sub, value, len);
+ }
+ fprintf(file, "%s%*s]", count > 0 ? "\n" : "",
+ count > 0 ? indent : 0, "");
+ } else if (spa_json_is_object(value, len)) {
+ fprintf(file, "{");
+ spa_json_enter(it, &sub);
+ while (spa_json_get_string(&sub, key, sizeof(key)) > 0) {
+ fprintf(file, "%s\n%*s",
+ count++ > 0 ? "," : "",
+ indent+2, "");
+ encode_string(file, key, strlen(key));
+ fprintf(file, ": ");
+ if ((len = spa_json_next(&sub, &value)) <= 0)
+ break;
+ dump(file, indent+2, &sub, value, len);
+ }
+ fprintf(file, "%s%*s}", count > 0 ? "\n" : "",
+ count > 0 ? indent : 0, "");
+ } else if (spa_json_is_string(value, len) ||
+ spa_json_is_null(value, len) ||
+ spa_json_is_bool(value, len) ||
+ spa_json_is_int(value, len) ||
+ spa_json_is_float(value, len)) {
+ fprintf(file, "%.*s", len, value);
+ } else {
+ encode_string(file, value, len);
+ }
+ return 0;
+}
+
+int main(int argc, char *argv[])
+{
+ int fd, len, res, exit_code = EXIT_FAILURE;
+ void *data;
+ struct stat sbuf;
+ struct spa_json it;
+ const char *value;
+
+ if (argc < 2) {
+ fprintf(stderr, "usage: %s <spa-json-file>\n", argv[0]);
+ goto error;
+ }
+ if ((fd = open(argv[1], O_CLOEXEC | O_RDONLY)) < 0) {
+ fprintf(stderr, "error opening file '%s': %m\n", argv[1]);
+ goto error;
+ }
+ if (fstat(fd, &sbuf) < 0) {
+ fprintf(stderr, "error statting file '%s': %m\n", argv[1]);
+ goto error_close;
+ }
+ if ((data = mmap(NULL, sbuf.st_size, PROT_READ, MAP_PRIVATE, fd, 0)) == MAP_FAILED) {
+ fprintf(stderr, "error mmapping file '%s': %m\n", argv[1]);
+ goto error_close;
+ }
+
+ spa_json_init(&it, data, sbuf.st_size);
+ if ((len = spa_json_next(&it, &value)) <= 0) {
+ fprintf(stderr, "not a valid file '%s': %s\n", argv[1], spa_strerror(len));
+ goto error_unmap;
+ }
+ if (!spa_json_is_container(value, len)) {
+ spa_json_init(&it, data, sbuf.st_size);
+ value = "{";
+ len = 1;
+ }
+ if ((res = dump(stdout, 0, &it, value, len)) < 0) {
+ fprintf(stderr, "error parsing file '%s': %s\n", argv[1], spa_strerror(res));
+ goto error_unmap;
+ }
+ fprintf(stdout, "\n");
+ exit_code = EXIT_SUCCESS;
+
+error_unmap:
+ munmap(data, sbuf.st_size);
+error_close:
+ close(fd);
+error:
+ return exit_code;
+}
diff --git a/spa/tools/spa-monitor.c b/spa/tools/spa-monitor.c
new file mode 100644
index 0000000..28159f3
--- /dev/null
+++ b/spa/tools/spa-monitor.c
@@ -0,0 +1,229 @@
+/* Simple Plugin API
+ *
+ * Copyright © 2018 Wim Taymans
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a
+ * copy of this software and associated documentation files (the "Software"),
+ * to deal in the Software without restriction, including without limitation
+ * the rights to use, copy, modify, merge, publish, distribute, sublicense,
+ * and/or sell copies of the Software, and to permit persons to whom the
+ * Software is furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice (including the next
+ * paragraph) shall be included in all copies or substantial portions of the
+ * Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
+ * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
+ * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
+ * DEALINGS IN THE SOFTWARE.
+ */
+
+#include <string.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <unistd.h>
+#include <dlfcn.h>
+#include <errno.h>
+#include <poll.h>
+
+#include <spa/utils/string.h>
+#include <spa/support/log-impl.h>
+#include <spa/support/loop.h>
+#include <spa/support/plugin.h>
+#include <spa/monitor/device.h>
+
+#include <spa/debug/dict.h>
+#include <spa/debug/pod.h>
+
+static SPA_LOG_IMPL(default_log);
+
+struct data {
+ struct spa_log *log;
+ struct spa_loop main_loop;
+
+ struct spa_support support[3];
+ uint32_t n_support;
+
+ unsigned int n_sources;
+ struct spa_source sources[16];
+
+ bool rebuild_fds;
+ struct pollfd fds[16];
+ unsigned int n_fds;
+};
+
+
+static void inspect_info(struct data *data, const struct spa_device_object_info *info)
+{
+ spa_debug_dict(0, info->props);
+}
+
+static void on_device_info(void *_data, const struct spa_device_info *info)
+{
+ spa_debug_dict(0, info->props);
+}
+
+static void on_device_object_info(void *_data, uint32_t id, const struct spa_device_object_info *info)
+{
+ struct data *data = _data;
+
+ if (info == NULL) {
+ fprintf(stderr, "removed: %u\n", id);
+ }
+ else {
+ fprintf(stderr, "added/changed: %u\n", id);
+ inspect_info(data, info);
+ }
+}
+
+static int do_add_source(void *object, struct spa_source *source)
+{
+ struct data *data = object;
+
+ data->sources[data->n_sources] = *source;
+ data->n_sources++;
+ data->rebuild_fds = true;
+
+ return 0;
+}
+
+static const struct spa_loop_methods impl_loop = {
+ SPA_VERSION_LOOP_METHODS,
+ .add_source = do_add_source,
+};
+
+static const struct spa_device_events impl_device_events = {
+ SPA_VERSION_DEVICE_EVENTS,
+ .info = on_device_info,
+ .object_info = on_device_object_info,
+};
+
+static void handle_device(struct data *data, struct spa_device *device)
+{
+ struct spa_hook listener;
+
+ spa_zero(listener);
+ spa_device_add_listener(device, &listener, &impl_device_events, data);
+
+ while (true) {
+ int r;
+ uint32_t i;
+
+ /* rebuild */
+ if (data->rebuild_fds) {
+ for (i = 0; i < data->n_sources; i++) {
+ struct spa_source *p = &data->sources[i];
+ data->fds[i].fd = p->fd;
+ data->fds[i].events = p->mask;
+ }
+ data->n_fds = data->n_sources;
+ data->rebuild_fds = false;
+ }
+
+ r = poll((struct pollfd *) data->fds, data->n_fds, -1);
+ if (r < 0) {
+ if (errno == EINTR)
+ continue;
+ break;
+ }
+ if (r == 0) {
+ fprintf(stderr, "device %p: select timeout", device);
+ break;
+ }
+
+ /* after */
+ for (i = 0; i < data->n_sources; i++) {
+ struct spa_source *p = &data->sources[i];
+ p->func(p);
+ }
+ }
+ spa_hook_remove(&listener);
+}
+
+int main(int argc, char *argv[])
+{
+ struct data data = { 0 };
+ int res;
+ void *handle;
+ spa_handle_factory_enum_func_t enum_func;
+ uint32_t fidx;
+
+ data.log = &default_log.log;
+ data.main_loop.iface = SPA_INTERFACE_INIT(
+ SPA_TYPE_INTERFACE_Loop,
+ SPA_VERSION_LOOP,
+ &impl_loop, &data);
+
+ data.support[0] = SPA_SUPPORT_INIT(SPA_TYPE_INTERFACE_Log, data.log);
+ data.support[1] = SPA_SUPPORT_INIT(SPA_TYPE_INTERFACE_Loop, &data.main_loop);
+ data.n_support = 2;
+
+ if (argc < 2) {
+ printf("usage: %s <plugin.so>\n", argv[0]);
+ return -1;
+ }
+
+ if ((handle = dlopen(argv[1], RTLD_NOW)) == NULL) {
+ printf("can't load %s\n", argv[1]);
+ return -1;
+ }
+ if ((enum_func = dlsym(handle, SPA_HANDLE_FACTORY_ENUM_FUNC_NAME)) == NULL) {
+ printf("can't find function\n");
+ return -1;
+ }
+
+ for (fidx = 0;;) {
+ const struct spa_handle_factory *factory;
+ uint32_t iidx;
+
+ if ((res = enum_func(&factory, &fidx)) <= 0) {
+ if (res != 0)
+ printf("can't enumerate factories: %d\n", res);
+ break;
+ }
+
+ if (factory->version < 1) {
+ printf("factories version %d < %d not supported\n",
+ factory->version, 1);
+ continue;
+ }
+
+ for (iidx = 0;;) {
+ const struct spa_interface_info *info;
+
+ if ((res =
+ spa_handle_factory_enum_interface_info(factory, &info, &iidx)) <= 0) {
+ if (res != 0)
+ printf("can't enumerate interfaces: %d\n", res);
+ break;
+ }
+
+ if (spa_streq(info->type, SPA_TYPE_INTERFACE_Device)) {
+ struct spa_handle *handle;
+ void *interface;
+
+ handle = calloc(1, spa_handle_factory_get_size(factory, NULL));
+ if ((res =
+ spa_handle_factory_init(factory, handle, NULL, data.support,
+ data.n_support)) < 0) {
+ printf("can't make factory instance: %s\n", strerror(res));
+ continue;
+ }
+
+ if ((res =
+ spa_handle_get_interface(handle, SPA_TYPE_INTERFACE_Device,
+ &interface)) < 0) {
+ printf("can't get interface: %s\n", strerror(res));
+ continue;
+ }
+ handle_device(&data, interface);
+ }
+ }
+ }
+
+ return 0;
+}