pipewire/src/tools/pipewire-monitor.c

650 lines
18 KiB
C
Raw Normal View History

2017-05-23 19:15:33 +02:00
/* PipeWire
2015-04-16 16:58:33 +02:00
* Copyright (C) 2015 Wim Taymans <wim.taymans@gmail.com>
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Library General Public
* License as published by the Free Software Foundation; either
* version 2 of the License, or (at your option) any later version.
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Library General Public License for more details.
*
* You should have received a copy of the GNU Library General Public
* License along with this library; if not, write to the
* Free Software Foundation, Inc., 51 Franklin St, Fifth Floor,
* Boston, MA 02110-1301, USA.
*/
#include <stdio.h>
#include <signal.h>
2018-08-14 12:33:53 +02:00
#include <spa/debug/format.h>
2017-07-11 15:57:20 +02:00
#include <pipewire/pipewire.h>
#include <pipewire/interfaces.h>
#include <pipewire/type.h>
2017-07-11 15:57:20 +02:00
struct proxy_data;
typedef void (*print_func_t) (struct proxy_data *data);
2017-05-23 19:15:33 +02:00
struct data {
struct pw_main_loop *loop;
struct pw_core *core;
struct pw_remote *remote;
struct spa_hook remote_listener;
2015-04-16 16:58:33 +02:00
struct pw_core_proxy *core_proxy;
struct pw_registry_proxy *registry_proxy;
struct spa_hook registry_listener;
uint32_t seq;
struct spa_list pending_list;
};
struct proxy_data {
2017-09-18 09:35:00 +02:00
struct data *data;
bool first;
struct pw_proxy *proxy;
uint32_t id;
uint32_t parent_id;
uint32_t permissions;
uint32_t version;
uint32_t type;
void *info;
pw_destroy_t destroy;
struct spa_hook proxy_listener;
struct spa_hook proxy_proxy_listener;
uint32_t pending_seq;
struct spa_list pending_link;
print_func_t print_func;
uint32_t n_params;
struct spa_pod **params;
2017-05-23 19:15:33 +02:00
};
2015-04-16 16:58:33 +02:00
static void add_pending(struct proxy_data *pd)
{
struct data *d = pd->data;
spa_list_append(&d->pending_list, &pd->pending_link);
pd->pending_seq = ++d->seq;
pw_core_proxy_sync(d->core_proxy, pd->pending_seq);
}
static void remove_pending(struct proxy_data *pd)
{
if (pd->pending_seq != SPA_ID_INVALID) {
spa_list_remove(&pd->pending_link);
pd->pending_seq = SPA_ID_INVALID;
}
}
static void on_sync_reply(void *data, uint32_t seq)
{
struct data *d = data;
struct proxy_data *pd, *t;
spa_list_for_each_safe(pd, t, &d->pending_list, pending_link) {
if (pd->pending_seq == seq) {
remove_pending(pd);
pd->print_func(pd);
}
}
}
static void clear_params(struct proxy_data *data)
{
int i;
for (i = 0; i < data->n_params; i++)
free(data->params[i]);
free(data->params);
data->n_params = 0;
data->params = NULL;
}
static void add_param(struct proxy_data *data, const struct spa_pod *param)
{
uint32_t idx = data->n_params++;
data->params = realloc(data->params, sizeof(struct spa_pod *) * data->n_params);
data->params[idx] = pw_spa_pod_copy(param);
}
static void print_properties(const struct spa_dict *props, char mark)
{
const struct spa_dict_item *item;
2017-08-27 17:58:25 +02:00
printf("%c\tproperties:\n", mark);
if (props == NULL || props->n_items == 0) {
printf("\t\tnone\n");
2017-05-26 08:05:01 +02:00
return;
2017-08-27 17:58:25 +02:00
}
2017-05-26 08:05:01 +02:00
spa_dict_for_each(item, props) {
2017-10-17 12:16:53 +02:00
if (item->value)
printf("%c\t\t%s = \"%s\"\n", mark, item->key, item->value);
else
printf("%c\t\t%s = (null)\n", mark, item->key);
2017-05-26 08:05:01 +02:00
}
}
#define MARK_CHANGE(f) ((print_mark && ((info)->change_mask & (1 << (f)))) ? '*' : ' ')
static void on_info_changed(void *data, const struct pw_core_info *info)
{
bool print_all = true, print_mark = false;
2017-05-26 08:05:01 +02:00
printf("\ttype: %s\n", PW_TYPE_INTERFACE__Core);
if (print_all) {
2017-05-26 08:05:01 +02:00
printf("%c\tuser-name: \"%s\"\n", MARK_CHANGE(0), info->user_name);
printf("%c\thost-name: \"%s\"\n", MARK_CHANGE(1), info->host_name);
printf("%c\tversion: \"%s\"\n", MARK_CHANGE(2), info->version);
printf("%c\tname: \"%s\"\n", MARK_CHANGE(3), info->name);
printf("%c\tcookie: %u\n", MARK_CHANGE(4), info->cookie);
print_properties(info->props, MARK_CHANGE(5));
}
2016-12-02 13:38:43 +01:00
}
static void module_event_info(void *object, struct pw_module_info *info)
2016-12-02 13:38:43 +01:00
{
2017-09-18 09:35:00 +02:00
struct proxy_data *data = object;
bool print_all, print_mark;
2016-12-02 13:38:43 +01:00
print_all = true;
if (data->info == NULL) {
printf("added:\n");
print_mark = false;
}
else {
printf("changed:\n");
print_mark = true;
}
info = data->info = pw_module_info_update(data->info, info);
2016-12-02 13:38:43 +01:00
printf("\tid: %d\n", data->id);
printf("\tparent_id: %d\n", data->parent_id);
printf("\tpermissions: %c%c%c\n", data->permissions & PW_PERM_R ? 'r' : '-',
data->permissions & PW_PERM_W ? 'w' : '-',
data->permissions & PW_PERM_X ? 'x' : '-');
printf("\ttype: %s (version %d)\n", PW_TYPE_INTERFACE__Module, data->version);
if (print_all) {
printf("%c\tname: \"%s\"\n", MARK_CHANGE(0), info->name);
printf("%c\tfilename: \"%s\"\n", MARK_CHANGE(1), info->filename);
printf("%c\targs: \"%s\"\n", MARK_CHANGE(2), info->args);
print_properties(info->props, MARK_CHANGE(3));
2017-05-26 08:05:01 +02:00
}
}
static const struct pw_module_proxy_events module_events = {
PW_VERSION_MODULE_PROXY_EVENTS,
.info = module_event_info,
};
static void print_node(struct proxy_data *data)
{
struct pw_node_info *info = data->info;
bool print_all, print_mark;
struct pw_type *t = pw_core_get_type(data->data->core);
2017-05-26 08:05:01 +02:00
print_all = true;
if (data->first) {
printf("added:\n");
print_mark = false;
data->first = false;
2017-05-26 08:05:01 +02:00
}
else {
printf("changed:\n");
print_mark = true;
}
printf("\tid: %d\n", data->id);
printf("\tparent_id: %d\n", data->parent_id);
printf("\tpermissions: %c%c%c\n", data->permissions & PW_PERM_R ? 'r' : '-',
data->permissions & PW_PERM_W ? 'w' : '-',
data->permissions & PW_PERM_X ? 'x' : '-');
printf("\ttype: %s (version %d)\n", PW_TYPE_INTERFACE__Node, data->version);
if (print_all) {
2017-05-26 08:05:01 +02:00
int i;
printf("%c\tname: \"%s\"\n", MARK_CHANGE(0), info->name);
printf("%c\tparams:\n", MARK_CHANGE(5));
for (i = 0; i < data->n_params; i++) {
if (spa_pod_is_object_type(data->params[i], t->spa_format))
2018-08-14 12:33:53 +02:00
spa_debug_format(2, t->map, data->params[i]);
else
spa_debug_pod(2, t->map, data->params[i]);
}
printf("%c\tinput ports: %u/%u\n", MARK_CHANGE(1),
info->n_input_ports, info->max_input_ports);
printf("%c\toutput ports: %u/%u\n", MARK_CHANGE(2),
info->n_output_ports, info->max_output_ports);
printf("%c\tstate: \"%s\"", MARK_CHANGE(3), pw_node_state_as_string(info->state));
2017-05-26 08:05:01 +02:00
if (info->state == PW_NODE_STATE_ERROR && info->error)
printf(" \"%s\"\n", info->error);
else
printf("\n");
print_properties(info->props, MARK_CHANGE(4));
2017-05-26 08:05:01 +02:00
}
}
static void node_event_info(void *object, struct pw_node_info *info)
{
struct proxy_data *data = object;
struct pw_type *t = pw_core_get_type(data->data->core);
data->info = pw_node_info_update(data->info, info);
if (info->change_mask & PW_NODE_CHANGE_MASK_ENUM_PARAMS) {
pw_node_proxy_enum_params((struct pw_node_proxy*)data->proxy,
t->param.idList, 0, 0, NULL);
add_pending(data);
}
if (data->pending_seq == SPA_ID_INVALID)
data->print_func(data);
}
static void node_event_param(void *object, uint32_t id, uint32_t index, uint32_t next,
const struct spa_pod *param)
{
struct proxy_data *data = object;
add_param(data, param);
}
static const struct pw_node_proxy_events node_events = {
PW_VERSION_NODE_PROXY_EVENTS,
.info = node_event_info,
.param = node_event_param
};
static void print_port(struct proxy_data *data)
{
struct pw_port_info *info = data->info;
bool print_all, print_mark;
struct pw_type *t = pw_core_get_type(data->data->core);
print_all = true;
if (data->first) {
printf("added:\n");
print_mark = false;
data->first = false;
}
else {
printf("changed:\n");
print_mark = true;
}
printf("\tid: %d\n", data->id);
printf("\tparent_id: %d\n", data->parent_id);
printf("\tpermissions: %c%c%c\n", data->permissions & PW_PERM_R ? 'r' : '-',
data->permissions & PW_PERM_W ? 'w' : '-',
data->permissions & PW_PERM_X ? 'x' : '-');
printf("\ttype: %s (version %d)\n", PW_TYPE_INTERFACE__Port, data->version);
if (print_all) {
int i;
printf("%c\tname: \"%s\"\n", MARK_CHANGE(0), info->name);
printf("%c\tparams:\n", MARK_CHANGE(2));
for (i = 0; i < data->n_params; i++) {
if (spa_pod_is_object_type(data->params[i], t->spa_format))
2018-08-14 12:33:53 +02:00
spa_debug_format(2, t->map, data->params[i]);
else
spa_debug_pod(2, t->map, data->params[i]);
}
print_properties(info->props, MARK_CHANGE(1));
}
}
static void port_event_info(void *object, struct pw_port_info *info)
{
struct proxy_data *data = object;
struct pw_type *t = pw_core_get_type(data->data->core);
data->info = pw_port_info_update(data->info, info);
if (info->change_mask & PW_PORT_CHANGE_MASK_ENUM_PARAMS) {
pw_port_proxy_enum_params((struct pw_port_proxy*)data->proxy,
t->param.idEnumFormat, 0, 0, NULL);
add_pending(data);
}
if (data->pending_seq == SPA_ID_INVALID)
data->print_func(data);
}
static void port_event_param(void *object, uint32_t id, uint32_t index, uint32_t next,
const struct spa_pod *param)
{
struct proxy_data *data = object;
add_param(data, param);
}
static const struct pw_port_proxy_events port_events = {
PW_VERSION_PORT_PROXY_EVENTS,
.info = port_event_info,
.param = port_event_param
};
2017-09-18 09:35:00 +02:00
static void factory_event_info(void *object, struct pw_factory_info *info)
{
struct proxy_data *data = object;
struct pw_type *t = pw_core_get_type(data->data->core);
bool print_all, print_mark;
print_all = true;
if (data->info == NULL) {
printf("added:\n");
print_mark = false;
}
else {
printf("changed:\n");
print_mark = true;
}
info = data->info = pw_factory_info_update(data->info, info);
printf("\tid: %d\n", data->id);
printf("\tparent_id: %d\n", data->parent_id);
printf("\tpermissions: %c%c%c\n", data->permissions & PW_PERM_R ? 'r' : '-',
data->permissions & PW_PERM_W ? 'w' : '-',
data->permissions & PW_PERM_X ? 'x' : '-');
printf("\ttype: %s (version %d)\n", PW_TYPE_INTERFACE__Factory, data->version);
printf("\tname: \"%s\"\n", info->name);
printf("\tobject-type: %s/%d\n", spa_type_map_get_type(t->map, info->type), info->version);
if (print_all) {
print_properties(info->props, MARK_CHANGE(0));
}
}
static const struct pw_factory_proxy_events factory_events = {
PW_VERSION_FACTORY_PROXY_EVENTS,
.info = factory_event_info
};
static void client_event_info(void *object, struct pw_client_info *info)
{
2017-09-18 09:35:00 +02:00
struct proxy_data *data = object;
bool print_all, print_mark;
2017-05-26 08:05:01 +02:00
print_all = true;
if (data->info == NULL) {
printf("added:\n");
print_mark = false;
}
else {
printf("changed:\n");
print_mark = true;
2017-05-26 08:05:01 +02:00
}
info = data->info = pw_client_info_update(data->info, info);
printf("\tid: %d\n", data->id);
printf("\tparent_id: %d\n", data->parent_id);
printf("\tpermissions: %c%c%c\n", data->permissions & PW_PERM_R ? 'r' : '-',
data->permissions & PW_PERM_W ? 'w' : '-',
data->permissions & PW_PERM_X ? 'x' : '-');
printf("\ttype: %s (version %d)\n", PW_TYPE_INTERFACE__Client, data->version);
if (print_all) {
print_properties(info->props, MARK_CHANGE(0));
2017-05-26 08:05:01 +02:00
}
}
static const struct pw_client_proxy_events client_events = {
PW_VERSION_CLIENT_PROXY_EVENTS,
.info = client_event_info
};
static void link_event_info(void *object, struct pw_link_info *info)
{
2017-09-18 09:35:00 +02:00
struct proxy_data *data = object;
2018-08-14 12:33:53 +02:00
struct pw_type *t = pw_core_get_type(data->data->core);
bool print_all, print_mark;
2017-05-26 08:05:01 +02:00
print_all = true;
if (data->info == NULL) {
printf("added:\n");
print_mark = false;
}
else {
printf("changed:\n");
print_mark = true;
2017-05-26 08:05:01 +02:00
}
info = data->info = pw_link_info_update(data->info, info);
printf("\tid: %d\n", data->id);
printf("\tparent_id: %d\n", data->parent_id);
printf("\tpermissions: %c%c%c\n", data->permissions & PW_PERM_R ? 'r' : '-',
data->permissions & PW_PERM_W ? 'w' : '-',
data->permissions & PW_PERM_X ? 'x' : '-');
printf("\ttype: %s (version %d)\n", PW_TYPE_INTERFACE__Link, data->version);
if (print_all) {
2017-05-26 08:05:01 +02:00
printf("%c\toutput-node-id: %u\n", MARK_CHANGE(0), info->output_node_id);
printf("%c\toutput-port-id: %u\n", MARK_CHANGE(0), info->output_port_id);
printf("%c\tinput-node-id: %u\n", MARK_CHANGE(1), info->input_node_id);
printf("%c\tinput-port-id: %u\n", MARK_CHANGE(1), info->input_port_id);
printf("%c\tformat:\n", MARK_CHANGE(2));
if (info->format)
2018-08-14 12:33:53 +02:00
spa_debug_format(2, t->map, info->format);
else
2017-08-27 17:58:25 +02:00
printf("\t\tnone\n");
print_properties(info->props, MARK_CHANGE(3));
2017-05-26 08:05:01 +02:00
}
}
static const struct pw_link_proxy_events link_events = {
PW_VERSION_LINK_PROXY_EVENTS,
.info = link_event_info
};
static void
destroy_proxy (void *data)
{
struct proxy_data *pd = data;
clear_params(pd);
remove_pending(pd);
if (pd->info == NULL)
return;
if (pd->destroy)
pd->destroy(pd->info);
pd->info = NULL;
}
2016-12-02 13:38:43 +01:00
static const struct pw_proxy_events proxy_events = {
PW_VERSION_PROXY_EVENTS,
.destroy = destroy_proxy,
};
static void registry_event_global(void *data, uint32_t id, uint32_t parent_id,
uint32_t permissions, uint32_t type, uint32_t version,
const struct spa_dict *props)
{
struct data *d = data;
struct pw_proxy *proxy;
uint32_t client_version;
const void *events;
struct pw_core *core = d->core;
struct pw_type *t = pw_core_get_type(core);
struct proxy_data *pd;
pw_destroy_t destroy;
print_func_t print_func = NULL;
if (type == t->node) {
events = &node_events;
client_version = PW_VERSION_NODE;
destroy = (pw_destroy_t) pw_node_info_free;
print_func = print_node;
}
else if (type == t->port) {
events = &port_events;
client_version = PW_VERSION_PORT;
destroy = (pw_destroy_t) pw_port_info_free;
print_func = print_port;
}
else if (type == t->module) {
events = &module_events;
client_version = PW_VERSION_MODULE;
destroy = (pw_destroy_t) pw_module_info_free;
}
2017-09-18 09:35:00 +02:00
else if (type == t->factory) {
events = &factory_events;
client_version = PW_VERSION_FACTORY;
destroy = (pw_destroy_t) pw_factory_info_free;
}
else if (type == t->client) {
events = &client_events;
client_version = PW_VERSION_CLIENT;
destroy = (pw_destroy_t) pw_client_info_free;
}
else if (type == t->link) {
events = &link_events;
client_version = PW_VERSION_LINK;
destroy = (pw_destroy_t) pw_link_info_free;
}
else {
printf("added:\n");
printf("\tid: %u\n", id);
printf("\tparent_id: %d\n", parent_id);
printf("\tpermissions: %c%c%c\n", permissions & PW_PERM_R ? 'r' : '-',
permissions & PW_PERM_W ? 'w' : '-',
permissions & PW_PERM_X ? 'x' : '-');
printf("\ttype: %s (version %d)\n", spa_type_map_get_type(t->map, type), version);
print_properties(props, ' ');
return;
}
proxy = pw_registry_proxy_bind(d->registry_proxy, id, type,
client_version,
sizeof(struct proxy_data));
if (proxy == NULL)
goto no_mem;
pd = pw_proxy_get_user_data(proxy);
2017-09-18 09:35:00 +02:00
pd->data = d;
pd->first = true;
pd->proxy = proxy;
pd->id = id;
pd->parent_id = parent_id;
pd->permissions = permissions;
pd->version = version;
pd->destroy = destroy;
pd->pending_seq = SPA_ID_INVALID;
pd->print_func = print_func;
pw_proxy_add_proxy_listener(proxy, &pd->proxy_proxy_listener, events, pd);
pw_proxy_add_listener(proxy, &pd->proxy_listener, &proxy_events, pd);
return;
no_mem:
printf("failed to create proxy");
return;
}
static void registry_event_global_remove(void *object, uint32_t id)
2015-04-16 16:58:33 +02:00
{
printf("removed:\n");
printf("\tid: %u\n", id);
2015-04-16 16:58:33 +02:00
}
static const struct pw_registry_proxy_events registry_events = {
PW_VERSION_REGISTRY_PROXY_EVENTS,
.global = registry_event_global,
.global_remove = registry_event_global_remove,
};
static void on_state_changed(void *_data, enum pw_remote_state old,
enum pw_remote_state state, const char *error)
2015-04-16 16:58:33 +02:00
{
struct data *data = _data;
struct pw_type *t = pw_core_get_type(data->core);
2017-05-26 08:05:01 +02:00
switch (state) {
2017-07-11 15:57:20 +02:00
case PW_REMOTE_STATE_ERROR:
printf("remote error: %s\n", error);
pw_main_loop_quit(data->loop);
2017-05-26 08:05:01 +02:00
break;
2017-07-11 15:57:20 +02:00
case PW_REMOTE_STATE_CONNECTED:
printf("remote state: \"%s\"\n", pw_remote_state_as_string(state));
data->core_proxy = pw_remote_get_core_proxy(data->remote);
data->registry_proxy = pw_core_proxy_get_registry(data->core_proxy,
t->registry,
PW_VERSION_REGISTRY, 0);
pw_registry_proxy_add_listener(data->registry_proxy,
&data->registry_listener,
&registry_events, data);
break;
2017-05-26 08:05:01 +02:00
default:
printf("remote state: \"%s\"\n", pw_remote_state_as_string(state));
2017-05-26 08:05:01 +02:00
break;
}
2015-04-16 16:58:33 +02:00
}
static const struct pw_remote_events remote_events = {
PW_VERSION_REMOTE_EVENTS,
.info_changed = on_info_changed,
.state_changed = on_state_changed,
.sync_reply = on_sync_reply,
};
static void do_quit(void *data, int signal_number)
{
struct data *d = data;
pw_main_loop_quit(d->loop);
}
2017-05-26 08:05:01 +02:00
int main(int argc, char *argv[])
2015-04-16 16:58:33 +02:00
{
struct data data = { 0 };
struct pw_loop *l;
struct pw_properties *props = NULL;
2015-04-16 16:58:33 +02:00
2017-05-26 08:05:01 +02:00
pw_init(&argc, &argv);
2015-04-16 16:58:33 +02:00
data.loop = pw_main_loop_new(NULL);
if (data.loop == NULL)
return -1;
l = pw_main_loop_get_loop(data.loop);
pw_loop_add_signal(l, SIGINT, do_quit, &data);
pw_loop_add_signal(l, SIGTERM, do_quit, &data);
data.core = pw_core_new(l, NULL);
if (data.core == NULL)
return -1;
if (argc > 1)
props = pw_properties_new(PW_REMOTE_PROP_REMOTE_NAME, argv[1], NULL);
data.remote = pw_remote_new(data.core, props, 0);
if (data.remote == NULL)
return -1;
2015-04-16 16:58:33 +02:00
pw_remote_add_listener(data.remote, &data.remote_listener, &remote_events, &data);
if (pw_remote_connect(data.remote) < 0)
return -1;
data.seq = 1;
spa_list_init(&data.pending_list);
pw_main_loop_run(data.loop);
2015-04-16 16:58:33 +02:00
pw_remote_destroy(data.remote);
pw_core_destroy(data.core);
pw_main_loop_destroy(data.loop);
2015-04-16 16:58:33 +02:00
2017-05-26 08:05:01 +02:00
return 0;
2015-04-16 16:58:33 +02:00
}