decodebin2: Add simple unit test, mainly a copy of the decodebin unit test

The only difference between the two unit tests right now is,
that the decodebin2 test resets the element to READY before trying
to reuse it instead of NULL. decodebin2 guarantees to be reusable
without going back to NULL.

2 files changed, 207 insertions, 0 deletions

diff --git a/tests/check/Makefile.am b/tests/check/Makefile.am
index ef3f50e1..78099541 100644
--- a/tests/check/Makefile.am
+++ b/tests/check/Makefile.am
@@ -95,6 +95,7 @@ check_PROGRAMS = \
 	elements/audioresample \
 	elements/audiotestsrc \
 	elements/decodebin \
+	elements/decodebin2 \
 	elements/ffmpegcolorspace \
 	elements/gdpdepay \
 	elements/gdppay \
@@ -264,6 +265,9 @@ elements_playbin2_CFLAGS = $(GST_BASE_CFLAGS) $(AM_CFLAGS)
 elements_decodebin_LDADD = $(GST_BASE_LIBS) $(LDADD)
 elements_decodebin_CFLAGS = $(GST_BASE_CFLAGS) $(AM_CFLAGS)
 
+elements_decodebin2_LDADD = $(GST_BASE_LIBS) $(LDADD)
+elements_decodebin2_CFLAGS = $(GST_BASE_CFLAGS) $(AM_CFLAGS)
+
 elements_subparse_LDADD =  $(LDADD)
 elements_subparse_CFLAGS = $(CFLAGS) $(AM_CFLAGS)
 
diff --git a/tests/check/elements/decodebin2.c b/tests/check/elements/decodebin2.c
new file mode 100644
index 00000000..84cf4054
--- /dev/null
+++ b/tests/check/elements/decodebin2.c
@@ -0,0 +1,203 @@
+/* GStreamer unit tests for decodebin2
+ *
+ * Copyright (C) 2006 Tim-Philipp Müller <tim centricular net>
+ *
+ * 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.
+ */
+
+#ifdef HAVE_CONFIG_H
+# include <config.h>
+#endif
+
+#include <gst/check/gstcheck.h>
+#include <unistd.h>
+
+static const gchar dummytext[] =
+    "Quick Brown Fox Jumps over a Lazy Frog Quick Brown "
+    "Fox Jumps over a Lazy Frog Quick Brown Fox Jumps over a Lazy Frog Quick "
+    "Brown Fox Jumps over a Lazy Frog Quick Brown Fox Jumps over a Lazy Frog "
+    "Quick Brown Fox Jumps over a Lazy Frog Quick Brown Fox Jumps over a Lazy "
+    "Frog Quick Brown Fox Jumps over a Lazy Frog Quick Brown Fox Jumps over a "
+    "Lazy Frog Quick Brown Fox Jumps over a Lazy Frog Quick Brown Fox Jumps "
+    "over a Lazy Frog Quick Brown Fox Jumps over a Lazy Frog Quick Brown Fox "
+    "jumps over a Lazy Frog Quick Brown Fox Jumps over a Lazy Frog Quick Brown "
+    "Fox Jumps over a Lazy Frog Quick Brown Fox Jumps over a Lazy Frog Quick "
+    "Brown Fox Jumps over a Lazy Frog Quick Brown Fox Jumps over a Lazy Frog "
+    "Quick Brown Fox Jumps over a Lazy Frog Quick Brown Fox Jumps over a Lazy "
+    "Frog Quick Brown Fox Jumps over a Lazy Frog Quick Brown Fox Jumps over a "
+    "Lazy Frog Quick Brown Fox Jumps over a Lazy Frog Quick Brown Fox Jumps "
+    "over a Lazy Frog Quick Brown Fox Jumps over a Lazy Frog Quick Brown Fox ";
+
+static void
+src_handoff_cb (GstElement * src, GstBuffer * buf, GstPad * pad, gpointer data)
+{
+  GST_BUFFER_DATA (buf) = (guint8 *) dummytext;
+  GST_BUFFER_SIZE (buf) = sizeof (dummytext);
+  GST_BUFFER_OFFSET (buf) = 0;
+  GST_BUFFER_FLAG_SET (buf, GST_BUFFER_FLAG_READONLY);
+}
+
+static void
+decodebin_new_decoded_pad_cb (GstElement * decodebin, GstPad * pad,
+    gboolean last, gboolean * p_flag)
+{
+  /* we should not be reached */
+  fail_unless (decodebin == NULL, "new-decoded-pad should not be emitted");
+}
+
+/* make sure that decodebin errors out instead of creating a new decoded pad
+ * if the entire stream is a plain text file */
+GST_START_TEST (test_text_plain_streams)
+{
+  GstElement *pipe, *src, *decodebin;
+  GstMessage *msg;
+
+  pipe = gst_pipeline_new (NULL);
+  fail_unless (pipe != NULL, "failed to create pipeline");
+
+  src = gst_element_factory_make ("fakesrc", "src");
+  fail_unless (src != NULL, "Failed to create fakesrc element");
+
+  g_object_set (src, "signal-handoffs", TRUE, NULL);
+  g_object_set (src, "num-buffers", 1, NULL);
+  g_object_set (src, "can-activate-pull", FALSE, NULL);
+  g_signal_connect (src, "handoff", G_CALLBACK (src_handoff_cb), NULL);
+
+  decodebin = gst_element_factory_make ("decodebin2", "decodebin");
+  fail_unless (decodebin != NULL, "Failed to create decodebin element");
+
+  g_signal_connect (decodebin, "new-decoded-pad",
+      G_CALLBACK (decodebin_new_decoded_pad_cb), NULL);
+
+  fail_unless (gst_bin_add (GST_BIN (pipe), src));
+  fail_unless (gst_bin_add (GST_BIN (pipe), decodebin));
+  fail_unless (gst_element_link (src, decodebin), "can't link src<->decodebin");
+
+  fail_unless_equals_int (gst_element_set_state (pipe, GST_STATE_READY),
+      GST_STATE_CHANGE_SUCCESS);
+  /* it's push-based, so should be async */
+  fail_unless_equals_int (gst_element_set_state (pipe, GST_STATE_PAUSED),
+      GST_STATE_CHANGE_ASYNC);
+
+  /* it should error out at some point */
+  msg = gst_bus_poll (GST_ELEMENT_BUS (pipe), GST_MESSAGE_ERROR, -1);
+  fail_unless (msg != NULL);
+  fail_unless (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_ERROR);
+  gst_message_unref (msg);
+
+  gst_element_set_state (pipe, GST_STATE_NULL);
+  gst_object_unref (pipe);
+}
+
+GST_END_TEST;
+
+static void
+new_decoded_pad_plug_fakesink_cb (GstElement * decodebin, GstPad * srcpad,
+    gboolean last, GstElement * pipeline)
+{
+  GstElement *sink;
+  GstPad *sinkpad;
+
+  GST_LOG ("Linking fakesink");
+
+  sink = gst_element_factory_make ("fakesink", "sink");
+  fail_unless (sink != NULL, "Failed to create fakesink element");
+
+  gst_bin_add (GST_BIN (pipeline), sink);
+
+  sinkpad = gst_element_get_static_pad (sink, "sink");
+  fail_unless_equals_int (gst_pad_link (srcpad, sinkpad), GST_PAD_LINK_OK);
+  gst_object_unref (sinkpad);
+
+  gst_element_set_state (sink, GST_STATE_PLAYING);
+}
+
+GST_START_TEST (test_reuse_without_decoders)
+{
+  GstElement *pipe, *src, *decodebin, *sink;
+
+  pipe = gst_pipeline_new (NULL);
+  fail_unless (pipe != NULL, "failed to create pipeline");
+
+  src = gst_element_factory_make ("audiotestsrc", "src");
+  fail_unless (src != NULL, "Failed to create audiotestsrc element");
+
+  decodebin = gst_element_factory_make ("decodebin2", "decodebin");
+  fail_unless (decodebin != NULL, "Failed to create decodebin element");
+
+  g_signal_connect (decodebin, "new-decoded-pad",
+      G_CALLBACK (new_decoded_pad_plug_fakesink_cb), pipe);
+
+  fail_unless (gst_bin_add (GST_BIN (pipe), src));
+  fail_unless (gst_bin_add (GST_BIN (pipe), decodebin));
+  fail_unless (gst_element_link (src, decodebin), "can't link src<->decodebin");
+
+  fail_unless_equals_int (gst_element_set_state (pipe, GST_STATE_READY),
+      GST_STATE_CHANGE_SUCCESS);
+  /* it's push-based, so should be async */
+  fail_unless_equals_int (gst_element_set_state (pipe, GST_STATE_PAUSED),
+      GST_STATE_CHANGE_ASYNC);
+
+  /* wait for state change to complete */
+  fail_unless_equals_int (gst_element_get_state (pipe, NULL, NULL, -1),
+      GST_STATE_CHANGE_SUCCESS);
+
+  /* there shouldn't be any errors */
+  fail_if (gst_bus_poll (GST_ELEMENT_BUS (pipe), GST_MESSAGE_ERROR, 0) != NULL);
+
+  /* reset */
+  gst_element_set_state (pipe, GST_STATE_READY);
+
+  sink = gst_bin_get_by_name (GST_BIN (pipe), "sink");
+  gst_bin_remove (GST_BIN (pipe), sink);
+  gst_element_set_state (sink, GST_STATE_NULL);
+  gst_object_unref (sink);
+
+  GST_LOG ("second try");
+
+  fail_unless_equals_int (gst_element_set_state (pipe, GST_STATE_READY),
+      GST_STATE_CHANGE_SUCCESS);
+  /* it's push-based, so should be async */
+  fail_unless_equals_int (gst_element_set_state (pipe, GST_STATE_PAUSED),
+      GST_STATE_CHANGE_ASYNC);
+
+  /* wait for state change to complete */
+  fail_unless_equals_int (gst_element_get_state (pipe, NULL, NULL, -1),
+      GST_STATE_CHANGE_SUCCESS);
+
+  /* there shouldn't be any errors */
+  fail_if (gst_bus_poll (GST_ELEMENT_BUS (pipe), GST_MESSAGE_ERROR, 0) != NULL);
+
+  gst_element_set_state (pipe, GST_STATE_NULL);
+  gst_object_unref (pipe);
+}
+
+GST_END_TEST;
+
+static Suite *
+decodebin2_suite (void)
+{
+  Suite *s = suite_create ("decodebin2");
+  TCase *tc_chain = tcase_create ("general");
+
+  suite_add_tcase (s, tc_chain);
+  tcase_add_test (tc_chain, test_text_plain_streams);
+  tcase_add_test (tc_chain, test_reuse_without_decoders);
+
+  return s;
+}
+
+GST_CHECK_MAIN (decodebin2);