From 93d7bd2c433df62c58b47927c938670149e708f4 Mon Sep 17 00:00:00 2001 From: =?utf8?q?Sebastian=20Dr=C3=B6ge?= Date: Mon, 15 Feb 2010 01:17:49 +0100 Subject: [PATCH] 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. --- tests/check/Makefile.am | 4 + tests/check/elements/decodebin2.c | 203 ++++++++++++++++++++++++++++++++++++++ 2 files changed, 207 insertions(+) create mode 100644 tests/check/elements/decodebin2.c diff --git a/tests/check/Makefile.am b/tests/check/Makefile.am index ef3f50e..7809954 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 0000000..84cf405 --- /dev/null +++ b/tests/check/elements/decodebin2.c @@ -0,0 +1,203 @@ +/* GStreamer unit tests for decodebin2 + * + * Copyright (C) 2006 Tim-Philipp Müller + * + * 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 +#endif + +#include +#include + +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); -- 2.7.4