check: tagschecking: tests for tags serialization in muxers

Adds a check unit test that aims to test tags serialization
and deserialization consistency (in muxers). It provides a
basic function that allows one to easily specify tags, a
muxer and a demuxer and a test will be done to check if
the tags have been consistently muxed and demuxed

tests/check/pipelines/tagschecking.c

@@ -0,0 +1,273 @@
+/* GStreamer
+ * Copyright (C) 2008 Nokia Corporation. (contact <stefan.kost@nokia.com>)
+ * Copyright (C) 2010 Thiago Santos <thiago.sousa.santos@collabora.co.uk>
+ *
+ * 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., 59 Temple Place - Suite 330,
+ * Boston, MA 02111-1307, USA.
+ */
+
+#include <gst/check/gstcheck.h>
+
+static GstTagList *received_tags = NULL;
+
+static gboolean
+bus_handler (GstBus * bus, GstMessage * message, gpointer data)
+{
+  GMainLoop *loop = (GMainLoop *) data;
+
+  switch (message->type) {
+    case GST_MESSAGE_EOS:
+      g_main_loop_quit (loop);
+      break;
+    case GST_MESSAGE_WARNING:
+    case GST_MESSAGE_ERROR:{
+      GError *gerror;
+
+      gchar *debug;
+
+      gst_message_parse_error (message, &gerror, &debug);
+      gst_object_default_error (GST_MESSAGE_SRC (message), gerror, debug);
+      g_error_free (gerror);
+      g_free (debug);
+      g_main_loop_quit (loop);
+      break;
+    }
+    case GST_MESSAGE_TAG:{
+      if (received_tags == NULL) {
+        gst_message_parse_tag (message, &received_tags);
+      } else {
+        GstTagList *tl = NULL, *ntl = NULL;
+
+        gst_message_parse_tag (message, &tl);
+        if (tl) {
+          ntl = gst_tag_list_merge (received_tags, tl, GST_TAG_MERGE_PREPEND);
+          if (ntl) {
+            GST_LOG ("taglists merged: %" GST_PTR_FORMAT, ntl);
+            gst_tag_list_free (received_tags);
+            received_tags = ntl;
+          }
+          gst_tag_list_free (tl);
+        }
+      }
+      break;
+    }
+    default:
+      break;
+  }
+
+  return TRUE;
+}
+
+static void
+test_mux_tags (const gchar * tag_str, const gchar * muxer, const gchar * file)
+{
+  GstElement *pipeline;
+  GstBus *bus;
+  GMainLoop *loop;
+  GstTagList *sent_tags;
+  GstElement *videotestsrc, *mux;
+  GstTagSetter *setter;
+  gchar *launch_str;
+
+  GST_DEBUG ("testing xmp muxing on : %s", muxer);
+
+  launch_str = g_strdup_printf ("videotestsrc name=src ! %s name=mux ! "
+      "filesink location=%s name=sink", muxer, file);
+  pipeline = gst_parse_launch (launch_str, NULL);
+  g_free (launch_str);
+  fail_unless (pipeline != NULL);
+
+  videotestsrc = gst_bin_get_by_name (GST_BIN (pipeline), "src");
+  fail_unless (videotestsrc != NULL);
+  g_object_set (G_OBJECT (videotestsrc), "num-buffers", 1, NULL);
+
+  mux = gst_bin_get_by_name (GST_BIN (pipeline), "mux");
+  fail_unless (mux != NULL);
+
+  loop = g_main_loop_new (NULL, TRUE);
+  fail_unless (loop != NULL);
+
+  bus = gst_element_get_bus (pipeline);
+  fail_unless (bus != NULL);
+  gst_bus_add_watch (bus, bus_handler, loop);
+  gst_object_unref (bus);
+
+  gst_element_set_state (pipeline, GST_STATE_READY);
+
+  setter = GST_TAG_SETTER (mux);
+  fail_unless (setter != NULL);
+  sent_tags = gst_structure_from_string (tag_str, NULL);
+  fail_unless (sent_tags != NULL);
+  gst_tag_setter_merge_tags (setter, sent_tags, GST_TAG_MERGE_REPLACE);
+
+  gst_element_set_state (pipeline, GST_STATE_PLAYING);
+  g_main_loop_run (loop);
+
+  gst_element_set_state (pipeline, GST_STATE_NULL);
+
+  g_main_loop_unref (loop);
+  g_object_unref (mux);
+  g_object_unref (videotestsrc);
+  g_object_unref (pipeline);
+}
+
+static void
+test_demux_tags (const gchar * tag_str, const gchar * demuxer,
+    const gchar * file)
+{
+  GstElement *pipeline;
+  GstBus *bus;
+  GMainLoop *loop;
+  GstTagList *sent_tags;
+  gint i, j, n_recv, n_sent;
+  const gchar *name_sent, *name_recv;
+  const GValue *value_sent, *value_recv;
+  gboolean found;
+  gint comparison;
+  GstElement *demux;
+  gchar *launch_str;
+
+  GST_DEBUG ("testing tags : %s", tag_str);
+
+  if (received_tags) {
+    gst_tag_list_free (received_tags);
+    received_tags = NULL;
+  }
+
+  launch_str = g_strdup_printf ("filesrc location=%s ! %s name=demux ! "
+      "fakesink", file, demuxer);
+  pipeline = gst_parse_launch (launch_str, NULL);
+  g_free (launch_str);
+  fail_unless (pipeline != NULL);
+
+  demux = gst_bin_get_by_name (GST_BIN (pipeline), "demux");
+  fail_unless (demux != NULL);
+
+  loop = g_main_loop_new (NULL, TRUE);
+  fail_unless (loop != NULL);
+
+  bus = gst_element_get_bus (pipeline);
+  fail_unless (bus != NULL);
+  gst_bus_add_watch (bus, bus_handler, loop);
+  gst_object_unref (bus);
+
+  sent_tags = gst_structure_from_string (tag_str, NULL);
+  fail_unless (sent_tags != NULL);
+
+  gst_element_set_state (pipeline, GST_STATE_PLAYING);
+  g_main_loop_run (loop);
+
+  GST_DEBUG ("mainloop done : %p", received_tags);
+
+  /* verify tags */
+  fail_unless (received_tags != NULL);
+  n_recv = gst_structure_n_fields (received_tags);
+  n_sent = gst_structure_n_fields (sent_tags);
+  fail_unless (n_recv >= n_sent);
+  /* FIXME: compare taglits values */
+  for (i = 0; i < n_sent; i++) {
+    name_sent = gst_structure_nth_field_name (sent_tags, i);
+    value_sent = gst_structure_get_value (sent_tags, name_sent);
+    found = FALSE;
+    for (j = 0; j < n_recv; j++) {
+      name_recv = gst_structure_nth_field_name (received_tags, j);
+      if (!strcmp (name_sent, name_recv)) {
+        value_recv = gst_structure_get_value (received_tags, name_recv);
+        comparison = gst_value_compare (value_sent, value_recv);
+        if (comparison != GST_VALUE_EQUAL) {
+          gchar *vs = g_strdup_value_contents (value_sent);
+          gchar *vr = g_strdup_value_contents (value_recv);
+          GST_DEBUG ("sent = %s:'%s', recv = %s:'%s'",
+              G_VALUE_TYPE_NAME (value_sent), vs,
+              G_VALUE_TYPE_NAME (value_recv), vr);
+          g_free (vs);
+          g_free (vr);
+        }
+        fail_unless (comparison == GST_VALUE_EQUAL,
+            "tag item %s has been received with different type or value",
+            name_sent);
+        found = TRUE;
+        break;
+      }
+    }
+    fail_unless (found, "tag item %s is lost", name_sent);
+  }
+
+  gst_tag_list_free (received_tags);
+  received_tags = NULL;
+  gst_tag_list_free (sent_tags);
+
+  gst_element_set_state (pipeline, GST_STATE_NULL);
+
+  g_main_loop_unref (loop);
+  g_object_unref (demux);
+  g_object_unref (pipeline);
+}
+
+static void
+test_tags (const gchar * tag_str, const gchar * muxer, const gchar * demuxer)
+{
+  gchar *tmpfile;
+  gchar *tmp;
+
+  tmp = g_strdup_printf ("%s%d", "gst-check-xmp-test-", g_random_int ());
+  tmpfile = g_build_filename (g_get_tmp_dir (), tmp, NULL);
+  g_free (tmp);
+
+  GST_DEBUG ("testing tags : %s", tag_str);
+  test_mux_tags (tag_str, muxer, tmpfile);
+  test_demux_tags (tag_str, demuxer, tmpfile);
+}
+
+GST_START_TEST (test_common_tags)
+{
+  test_tags ("taglist,title=(string)test_title", "qtmux", "qtdemux");
+}
+
+GST_END_TEST;
+
+Suite *
+metadata_suite (void)
+{
+  Suite *s = suite_create ("XMP");
+
+  TCase *tc_chain = tcase_create ("general");
+
+  /* time out after 60s, not the default 3 */
+  tcase_set_timeout (tc_chain, 60);
+
+  suite_add_tcase (s, tc_chain);
+  tcase_add_test (tc_chain, test_common_tags);
+
+  return s;
+}
+
+int
+main (int argc, char **argv)
+{
+  int nf;
+
+  Suite *s = metadata_suite ();
+
+  SRunner *sr = srunner_create (s);
+
+  gst_check_init (&argc, &argv);
+
+  srunner_run_all (sr, CK_NORMAL);
+  nf = srunner_ntests_failed (sr);
+  srunner_free (sr);
+
+  return nf;
+}