From 8dfeddab12777e90f8739f9dab33c62657465854 Mon Sep 17 00:00:00 2001

From: Wim Taymans <wtaymans@redhat.com>

Date: Mon, 4 Jan 2016 11:39:33 +0100

Subject: [PATCH] inspect: Add RPM output format

---

 tools/gst-inspect.c | 276 +++++++++++++++++++++++++++++++++++++++++++++++++---

 1 file changed, 261 insertions(+), 15 deletions(-)

diff --git a/tools/gst-inspect.c b/tools/gst-inspect.c

index 845f52e..9084949 100644

--- a/tools/gst-inspect.c

+++ b/tools/gst-inspect.c

@@ -1302,9 +1302,225 @@ print_element_info (GstElementFactory * factory, gboolean print_names)

   return 0;

 }

+static void

+print_gst_structure_append_field (GList * strings, const char *field)

+{

+  GList *s;

+

+  //g_message ("adding '%s' to the string", field);

+

+  for (s = strings; s != NULL; s = s->next) {

+    g_string_append (s->data, field);

+  }

+}

 static void

-print_plugin_automatic_install_info_codecs (GstElementFactory * factory)

+print_gst_structure_append_field_index (GList * strings, const char *field,

+    guint num_items, guint offset)

+{

+  GList *s;

+  guint i;

+

+  //g_message ("adding '%s' to the string (num: %d offset: %d)", field, num_items, offset);

+

+  for (s = strings, i = 0; s != NULL; s = s->next, i++) {

+    if (i == offset) {

+      //g_message ("adding '%s' at '%d'", field, i);

+      g_string_append (s->data, field);

+    }

+    if (i == num_items)

+      i = 0;

+  }

+

+}

+

+static GList *

+print_gst_structure_dup_fields (GList * strings, guint num_items)

+{

+  guint new_items, i;

+

+  if (num_items == 1)

+    return strings;

+

+  //g_message ("creating %d new items", num_items);

+

+  new_items = g_list_length (strings) * (num_items - 1);

+  for (i = 0; i < new_items; i++) {

+    GString *s, *first;

+

+    first = strings->data;

+    s = g_string_new_len (first->str, first->len);

+    strings = g_list_prepend (strings, s);

+  }

+

+  return strings;

+}

+

+enum

+{

+  FIELD_VERSION = 0,

+  FIELD_LAYER,

+  FIELD_VARIANT,

+  FIELD_SYSTEMSTREAM

+};

+

+static int

+field_get_type (const char *field_name)

+{

+  if (strstr (field_name, "version") != NULL)

+    return FIELD_VERSION;

+  if (strcmp (field_name, "layer") == 0)

+    return FIELD_LAYER;

+  if (strcmp (field_name, "systemstream") == 0)

+    return FIELD_SYSTEMSTREAM;

+  if (strcmp (field_name, "variant") == 0)

+    return FIELD_VARIANT;

+

+  return -1;

+}

+

+static gint

+fields_type_compare (const char *a, const char *b)

+{

+  gint a_type, b_type;

+

+  a_type = field_get_type (a);

+  b_type = field_get_type (b);

+  if (a_type < b_type)

+    return -1;

+  if (b_type < a_type)

+    return 1;

+  return 0;

+}

+

+static void

+print_gst_structure_for_rpm (const char *type_name, GstStructure * s)

+{

+  guint i, num_fields;

+  const char *name;

+  GList *fields, *l, *strings;

+  GString *string;

+

+  name = gst_structure_get_name (s);

+  strings = NULL;

+  num_fields = gst_structure_n_fields (s);

+  fields = NULL;

+

+  for (i = 0; i < num_fields; i++) {

+    const char *field_name;

+

+    field_name = gst_structure_nth_field_name (s, i);

+    if (field_get_type (field_name) < 0) {

+      //g_message ("ignoring field named %s", field_name);

+      continue;

+    }

+

+    fields =

+        g_list_insert_sorted (fields, g_strdup (field_name),

+        (GCompareFunc) fields_type_compare);

+  }

+

+  /* Example:

+   * gstreamer1(decoder-video/mpeg)(mpegversion=1)()(64bit) */

+  string = g_string_new ("gstreamer1");

+  g_string_append_c (string, '(');

+  g_string_append (string, type_name);

+  g_string_append_c (string, '-');

+  g_string_append (string, name);

+  g_string_append_c (string, ')');

+

+  strings = g_list_append (strings, string);

+

+  for (l = fields; l != NULL; l = l->next) {

+    char *field_name;

+    GType type;

+

+    field_name = l->data;

+

+    type = gst_structure_get_field_type (s, field_name);

+    //g_message ("field is: %s, type: %s", field_name, g_type_name (type));

+

+    if (type == G_TYPE_INT) {

+      char *field;

+      int value;

+

+      gst_structure_get_int (s, field_name, &value);

+      field = g_strdup_printf ("(%s=%d)", field_name, value);

+      print_gst_structure_append_field (strings, field);

+      g_free (field);

+    } else if (type == G_TYPE_BOOLEAN) {

+      char *field;

+      int value;

+

+      gst_structure_get_boolean (s, field_name, &value);

+      field = g_strdup_printf ("(%s=%s)", field_name, value ? "true" : "false");

+      print_gst_structure_append_field (strings, field);

+      g_free (field);

+    } else if (type == GST_TYPE_INT_RANGE) {

+      const GValue *value;

+      int min, max;

+

+      value = gst_structure_get_value (s, field_name);

+      min = gst_value_get_int_range_min (value);

+      max = gst_value_get_int_range_max (value);

+

+      strings = print_gst_structure_dup_fields (strings, max - min + 1);

+

+      for (i = min; i <= max; i++) {

+        char *field;

+

+        field = g_strdup_printf ("(%s=%d)", field_name, i);

+        print_gst_structure_append_field_index (strings, field, max - min + 1,

+            i - min);

+        g_free (field);

+      }

+    } else if (type == GST_TYPE_LIST) {

+      const GValue *value;

+      int num_items;

+

+      value = gst_structure_get_value (s, field_name);

+      num_items = gst_value_list_get_size (value);

+

+      strings = print_gst_structure_dup_fields (strings, num_items);

+

+      for (i = 0; i < num_items; i++) {

+        char *field;

+        const GValue *item_value;

+

+        item_value = gst_value_list_get_value (value, i);

+        field = g_strdup_printf ("(%s=%d)", field_name,

+            g_value_get_int (item_value));

+        print_gst_structure_append_field_index (strings, field, num_items, i);

+        g_free (field);

+      }

+    } else if (type == G_TYPE_STRING) {

+      char *field;

+      const char *value;

+

+      value = gst_structure_get_string (s, field_name);

+      field = g_strdup_printf ("(%s=%s)", field_name, value);

+      print_gst_structure_append_field (strings, field);

+      g_free (field);

+    } else {

+      g_warning ("unhandled type! %s", g_type_name (type));

+    }

+

+    g_free (field_name);

+  }

+

+  g_list_free (fields);

+

+  for (l = strings; l != NULL; l = l->next) {

+    string = l->data;

+    g_print ("%s\n", string->str);

+    g_string_free (string, TRUE);

+  }

+  g_list_free (strings);

+}

+

+static void

+print_plugin_automatic_install_info_codecs (GstElementFactory * factory,

+    gboolean rpm_format)

 {

   GstPadDirection direction;

   const gchar *type_name;

@@ -1330,6 +1546,13 @@ print_plugin_automatic_install_info_codecs (GstElementFactory * factory)

     return;

   }

+  if (rpm_format) {

+    /* Ignore NONE ranked plugins */

+    if ((gst_plugin_feature_get_rank (GST_PLUGIN_FEATURE (factory))) ==

+        GST_RANK_NONE)

+      return;

+  }

+

   /* decoder/demuxer sink pads should always be static and there should only

    * be one, the same applies to encoders/muxers and source pads */

   static_templates = gst_element_factory_get_static_pad_templates (factory);

@@ -1366,15 +1589,20 @@ print_plugin_automatic_install_info_codecs (GstElementFactory * factory)

     gst_structure_remove_field (s, "rate");

     gst_structure_remove_field (s, "depth");

     gst_structure_remove_field (s, "clock-rate");

-    s_str = gst_structure_to_string (s);

-    g_print ("%s-%s\n", type_name, s_str);

-    g_free (s_str);

+    if (!rpm_format) {

+      s_str = gst_structure_to_string (s);

+      g_print ("%s-%s\n", type_name, s_str);

+      g_free (s_str);

+    } else {

+      print_gst_structure_for_rpm (type_name, s);

+    }

   }

   gst_caps_unref (caps);

 }

 static void

-print_plugin_automatic_install_info_protocols (GstElementFactory * factory)

+print_plugin_automatic_install_info_protocols (GstElementFactory * factory,

+    gboolean rpm_format)

 {

   const gchar *const *protocols;

@@ -1383,13 +1611,19 @@ print_plugin_automatic_install_info_protocols (GstElementFactory * factory)

     switch (gst_element_factory_get_uri_type (factory)) {

       case GST_URI_SINK:

         while (*protocols != NULL) {

-          g_print ("urisink-%s\n", *protocols);

+          if (!rpm_format)

+            g_print ("urisink-%s\n", *protocols);

+          else

+            g_print ("gstreamer1(urisink-%s)\n", *protocols);

           ++protocols;

         }

         break;

       case GST_URI_SRC:

         while (*protocols != NULL) {

-          g_print ("urisource-%s\n", *protocols);

+          if (!rpm_format)

+            g_print ("urisource-%s\n", *protocols);

+          else

+            g_print ("gstreamer1(urisource-%s)\n", *protocols);

           ++protocols;

         }

         break;

@@ -1400,7 +1634,7 @@ print_plugin_automatic_install_info_protocols (GstElementFactory * factory)

 }

 static void

-print_plugin_automatic_install_info (GstPlugin * plugin)

+print_plugin_automatic_install_info (GstPlugin * plugin, gboolean rpm_format)

 {

   GList *features, *l;

@@ -1419,11 +1653,15 @@ print_plugin_automatic_install_info (GstPlugin * plugin)

     if (feature_plugin == plugin) {

       GstElementFactory *factory;

-      g_print ("element-%s\n", gst_plugin_feature_get_name (feature));

+      if (!rpm_format)

+        g_print ("element-%s\n", gst_plugin_feature_get_name (feature));

+      else

+        g_print ("gstreamer1(element-%s)\n",

+            gst_plugin_feature_get_name (feature));

       factory = GST_ELEMENT_FACTORY (feature);

-      print_plugin_automatic_install_info_protocols (factory);

-      print_plugin_automatic_install_info_codecs (factory);

+      print_plugin_automatic_install_info_protocols (factory, rpm_format);

+      print_plugin_automatic_install_info_codecs (factory, rpm_format);

     }

     if (feature_plugin)

       gst_object_unref (feature_plugin);

@@ -1445,7 +1683,7 @@ print_all_plugin_automatic_install_info (void)

     plugin = (GstPlugin *) (plugins->data);

     plugins = g_list_next (plugins);

-    print_plugin_automatic_install_info (plugin);

+    print_plugin_automatic_install_info (plugin, FALSE);

   }

   gst_plugin_list_free (orig_plugins);

 }

@@ -1457,6 +1695,7 @@ main (int argc, char *argv[])

   gboolean do_print_blacklist = FALSE;

   gboolean plugin_name = FALSE;

   gboolean print_aii = FALSE;

+  gboolean print_aii_rpm = FALSE;

   gboolean uri_handlers = FALSE;

   gboolean check_exists = FALSE;

   gchar *min_version = NULL;

@@ -1474,6 +1713,9 @@ main (int argc, char *argv[])

               "or all plugins provide.\n                                       "

               "Useful in connection with external automatic plugin "

               "installation mechanisms"), NULL},

+    {"rpm", '\0', 0, G_OPTION_ARG_NONE, &print_aii_rpm,

+        N_("Print the machine-parsable list of features of a plugin in RPM "

+              "Provides compatible-format"), NULL},

     {"plugin", '\0', 0, G_OPTION_ARG_NONE, &plugin_name,

         N_("List the plugin contents"), NULL},

     {"exists", '\0', 0, G_OPTION_ARG_NONE, &check_exists,

@@ -1610,7 +1852,7 @@ main (int argc, char *argv[])

       /* if there is such a plugin, print out info */

       if (plugin) {

         if (print_aii) {

-          print_plugin_automatic_install_info (plugin);

+          print_plugin_automatic_install_info (plugin, print_aii_rpm);

         } else {

           print_plugin_info (plugin);

           print_plugin_features (plugin);

@@ -1623,13 +1865,17 @@ main (int argc, char *argv[])

           if (plugin) {

             if (print_aii) {

-              print_plugin_automatic_install_info (plugin);

+              print_plugin_automatic_install_info (plugin, print_aii_rpm);

             } else {

               print_plugin_info (plugin);

               print_plugin_features (plugin);

             }

           } else {

-            g_printerr (_("Could not load plugin file: %s\n"), error->message);

+            if (!print_aii_rpm)

+              g_print (_("Could not load plugin file: %s\n"), error->message);

+            else

+              g_printerr (_("Could not load plugin file: %s\n"),

+                  error->message);

             g_clear_error (&error);

             return -1;

           }

-- 

2.5.0