/* Pinos * Copyright (C) 2015 Wim Taymans * * 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 #include 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 (GBytes *formats) { GstCaps *caps = gst_caps_from_string (g_bytes_get_data (formats, NULL)); guint i; g_print ("\tformats:\n"); 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); g_print ("\tuser-name: \"%s\"\n", info->user_name); g_print ("\thost-name: \"%s\"\n", info->host_name); g_print ("\tversion: \"%s\"\n", info->version); g_print ("\tname: \"%s\"\n", info->name); g_print ("\tcookie: %d\n", info->cookie); 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); g_print ("\tname: \"%s\"\n", info->name); 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); g_print ("\tsource-path: \"%s\"\n", info->source_path); g_print ("\tname: \"%s\"\n", info->name); g_print ("\tstate: %d\n", info->state); print_formats (info->formats); 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); g_print ("\tclient-path: \"%s\"\n", info->client_path); g_print ("\tsource-path: \"%s\"\n", info->source_path); print_formats (info->possible_formats); print_properties (info->properties); return TRUE; } static void dump_object (PinosContext *context, GDBusProxy *proxy, PinosSubscriptionFlags flags) { if (flags & PINOS_SUBSCRIPTION_FLAGS_DAEMON) { pinos_context_get_daemon_info (context, PINOS_DAEMON_INFO_FLAGS_NONE, dump_daemon_info, NULL, NULL); } else if (flags & PINOS_SUBSCRIPTION_FLAGS_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_FLAGS_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_FLAGS_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)); 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; g_object_get (gobject, "state", &state, NULL); g_print ("got context state %d\n", state); switch (state) { case PINOS_CONTEXT_STATE_ERROR: g_main_loop_quit (loop); break; case PINOS_CONTEXT_STATE_READY: break; default: 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; }