mirror of
https://gitlab.freedesktop.org/pipewire/pipewire.git
synced 2025-11-03 09:01:54 -05:00
monitor: move subscribe test to monitor tool
This commit is contained in:
Wim Taymans
parent
7cf87d902e
commit
e61cbb3931
3 changed files with 19 additions and 13 deletions
268
src/tools/pinos-monitor.c
Normal file
268
src/tools/pinos-monitor.c
Normal file
|
|
@ -0,0 +1,268 @@
|
|||
/* Pinos
|
||||
* 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 <gst/gst.h>
|
||||
|
||||
#include <client/pinos.h>
|
||||
|
||||
static GMainLoop *loop;
|
||||
|
||||
static gboolean
|
||||
print_field (GQuark field, const GValue * value, gpointer user_data)
|
||||
{
|
||||
gchar *str = gst_value_serialize (value);
|
||||
|
||||
g_print ("\t\t%15s: %s\n", g_quark_to_string (field), str);
|
||||
g_free (str);
|
||||
return TRUE;
|
||||
}
|
||||
|
||||
static void
|
||||
print_formats (const gchar *name, GBytes *formats)
|
||||
{
|
||||
GstCaps *caps = gst_caps_from_string (g_bytes_get_data (formats, NULL));
|
||||
guint i;
|
||||
|
||||
g_print ("\t%s:\n", name);
|
||||
|
||||
if (gst_caps_is_any (caps)) {
|
||||
g_print ("\t\tANY\n");
|
||||
return;
|
||||
}
|
||||
if (gst_caps_is_empty (caps)) {
|
||||
g_print ("\t\tEMPTY\n");
|
||||
return;
|
||||
}
|
||||
for (i = 0; i < gst_caps_get_size (caps); i++) {
|
||||
GstStructure *structure = gst_caps_get_structure (caps, i);
|
||||
GstCapsFeatures *features = gst_caps_get_features (caps, i);
|
||||
|
||||
if (features && (gst_caps_features_is_any (features) ||
|
||||
!gst_caps_features_is_equal (features,
|
||||
GST_CAPS_FEATURES_MEMORY_SYSTEM_MEMORY))) {
|
||||
gchar *features_string = gst_caps_features_to_string (features);
|
||||
|
||||
g_print ("\t\t%s(%s)\n", gst_structure_get_name (structure),
|
||||
features_string);
|
||||
g_free (features_string);
|
||||
} else {
|
||||
g_print ("\t\t%s\n", gst_structure_get_name (structure));
|
||||
}
|
||||
gst_structure_foreach (structure, print_field, NULL);
|
||||
}
|
||||
}
|
||||
|
||||
static void
|
||||
print_properties (PinosProperties *props)
|
||||
{
|
||||
gpointer state = NULL;
|
||||
const gchar *key;
|
||||
|
||||
g_print ("\tproperties:\n");
|
||||
while ((key = pinos_properties_iterate (props, &state))) {
|
||||
g_print ("\t\t%s = \"%s\"\n", key, pinos_properties_get (props, key));
|
||||
}
|
||||
}
|
||||
|
||||
static gboolean
|
||||
dump_daemon_info (PinosContext *c, const PinosDaemonInfo *info, gpointer userdata)
|
||||
{
|
||||
if (info == NULL)
|
||||
return FALSE;
|
||||
|
||||
g_print ("\tid: %p\n", info->id);
|
||||
if (info->change_mask & (1 << 0))
|
||||
g_print ("\tuser-name: \"%s\"\n", info->user_name);
|
||||
if (info->change_mask & (1 << 1))
|
||||
g_print ("\thost-name: \"%s\"\n", info->host_name);
|
||||
if (info->change_mask & (1 << 2))
|
||||
g_print ("\tversion: \"%s\"\n", info->version);
|
||||
if (info->change_mask & (1 << 3))
|
||||
g_print ("\tname: \"%s\"\n", info->name);
|
||||
if (info->change_mask & (1 << 4))
|
||||
g_print ("\tcookie: %d\n", info->cookie);
|
||||
if (info->change_mask & (1 << 5))
|
||||
print_properties (info->properties);
|
||||
|
||||
return TRUE;
|
||||
}
|
||||
|
||||
static gboolean
|
||||
dump_client_info (PinosContext *c, const PinosClientInfo *info, gpointer userdata)
|
||||
{
|
||||
if (info == NULL)
|
||||
return FALSE;
|
||||
|
||||
g_print ("\tid: %p\n", info->id);
|
||||
if (info->change_mask & (1 << 0))
|
||||
g_print ("\tname: \"%s\"\n", info->name);
|
||||
if (info->change_mask & (1 << 1))
|
||||
print_properties (info->properties);
|
||||
|
||||
return TRUE;
|
||||
}
|
||||
|
||||
static gboolean
|
||||
dump_source_info (PinosContext *c, const PinosSourceInfo *info, gpointer userdata)
|
||||
{
|
||||
if (info == NULL)
|
||||
return FALSE;
|
||||
|
||||
g_print ("\tid: %p\n", info->id);
|
||||
if (info->change_mask & (1 << 0))
|
||||
g_print ("\tsource-path: \"%s\"\n", info->source_path);
|
||||
if (info->change_mask & (1 << 1))
|
||||
g_print ("\tname: \"%s\"\n", info->name);
|
||||
if (info->change_mask & (1 << 2))
|
||||
g_print ("\tstate: %d\n", info->state);
|
||||
if (info->change_mask & (1 << 3))
|
||||
print_formats ("possible formats", info->possible_formats);
|
||||
if (info->change_mask & (1 << 4))
|
||||
print_properties (info->properties);
|
||||
|
||||
return TRUE;
|
||||
}
|
||||
|
||||
static gboolean
|
||||
dump_source_output_info (PinosContext *c, const PinosSourceOutputInfo *info, gpointer userdata)
|
||||
{
|
||||
if (info == NULL)
|
||||
return FALSE;
|
||||
|
||||
g_print ("\tid: %p\n", info->id);
|
||||
if (info->change_mask & (1 << 0))
|
||||
g_print ("\tclient-path: \"%s\"\n", info->client_path);
|
||||
if (info->change_mask & (1 << 1))
|
||||
g_print ("\tsource-path: \"%s\"\n", info->source_path);
|
||||
if (info->change_mask & (1 << 2))
|
||||
print_formats ("possible-formats", info->possible_formats);
|
||||
if (info->change_mask & (1 << 3))
|
||||
g_print ("\tstate: \"%d\"\n", info->state);
|
||||
if (info->change_mask & (1 << 4))
|
||||
print_formats ("format", info->format);
|
||||
if (info->change_mask & (1 << 5))
|
||||
print_properties (info->properties);
|
||||
|
||||
return TRUE;
|
||||
}
|
||||
|
||||
static void
|
||||
dump_object (PinosContext *context, GDBusProxy *proxy, PinosSubscriptionFlags flags)
|
||||
{
|
||||
if (flags & PINOS_SUBSCRIPTION_FLAG_DAEMON) {
|
||||
pinos_context_get_daemon_info (context,
|
||||
PINOS_DAEMON_INFO_FLAGS_NONE,
|
||||
dump_daemon_info,
|
||||
NULL,
|
||||
NULL);
|
||||
}
|
||||
else if (flags & PINOS_SUBSCRIPTION_FLAG_CLIENT) {
|
||||
pinos_context_get_client_info_by_id (context,
|
||||
proxy,
|
||||
PINOS_CLIENT_INFO_FLAGS_NONE,
|
||||
dump_client_info,
|
||||
NULL,
|
||||
NULL);
|
||||
}
|
||||
else if (flags & PINOS_SUBSCRIPTION_FLAG_SOURCE) {
|
||||
pinos_context_get_source_info_by_id (context,
|
||||
proxy,
|
||||
PINOS_SOURCE_INFO_FLAGS_FORMATS,
|
||||
dump_source_info,
|
||||
NULL,
|
||||
NULL);
|
||||
}
|
||||
else if (flags & PINOS_SUBSCRIPTION_FLAG_SOURCE_OUTPUT) {
|
||||
pinos_context_get_source_output_info_by_id (context,
|
||||
proxy,
|
||||
PINOS_SOURCE_OUTPUT_INFO_FLAGS_NONE,
|
||||
dump_source_output_info,
|
||||
NULL,
|
||||
NULL);
|
||||
}
|
||||
}
|
||||
|
||||
static void
|
||||
subscription_cb (PinosContext *context,
|
||||
PinosSubscriptionEvent type,
|
||||
PinosSubscriptionFlags flags,
|
||||
gpointer id,
|
||||
gpointer user_data)
|
||||
{
|
||||
switch (type) {
|
||||
case PINOS_SUBSCRIPTION_EVENT_NEW:
|
||||
g_print ("added: %s\n", g_dbus_proxy_get_object_path (id));
|
||||
dump_object (context, G_DBUS_PROXY (id), flags);
|
||||
break;
|
||||
|
||||
case PINOS_SUBSCRIPTION_EVENT_CHANGE:
|
||||
g_print ("changed: %s\n", g_dbus_proxy_get_object_path (id));
|
||||
dump_object (context, G_DBUS_PROXY (id), flags);
|
||||
break;
|
||||
|
||||
case PINOS_SUBSCRIPTION_EVENT_REMOVE:
|
||||
g_print ("removed: %s\n", g_dbus_proxy_get_object_path (id));
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
static void
|
||||
on_state_notify (GObject *gobject,
|
||||
GParamSpec *pspec,
|
||||
gpointer user_data)
|
||||
{
|
||||
PinosContextState state;
|
||||
PinosContext *c = PINOS_CONTEXT (gobject);
|
||||
const GError *error;
|
||||
|
||||
g_object_get (c, "state", &state, NULL);
|
||||
|
||||
switch (state) {
|
||||
case PINOS_CONTEXT_STATE_ERROR:
|
||||
error = pinos_context_get_error (c);
|
||||
g_print ("context error: %s\n", error->message);
|
||||
break;
|
||||
|
||||
default:
|
||||
g_print ("context state %d\n", state);
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
gint
|
||||
main (gint argc, gchar *argv[])
|
||||
{
|
||||
PinosContext *c;
|
||||
|
||||
pinos_init (&argc, &argv);
|
||||
|
||||
loop = g_main_loop_new (NULL, FALSE);
|
||||
|
||||
c = pinos_context_new (NULL, "test-client", NULL);
|
||||
g_signal_connect (c, "notify::state", (GCallback) on_state_notify, c);
|
||||
g_object_set (c, "subscription-mask", PINOS_SUBSCRIPTION_FLAGS_ALL, NULL);
|
||||
g_signal_connect (c, "subscription-event", (GCallback) subscription_cb, NULL);
|
||||
pinos_context_connect(c, PINOS_CONTEXT_FLAGS_NOFAIL);
|
||||
|
||||
g_main_loop_run (loop);
|
||||
|
||||
g_object_unref (c);
|
||||
|
||||
return 0;
|
||||
}
|
||||
Loading…
Add table
Add a link
Reference in a new issue