tests: Add simple test for funnel element

3 files changed, 157 insertions, 1 deletions

diff --git a/.gitignore b/.gitignore
index 95d92048..2c793542 100644
--- a/.gitignore
+++ b/.gitignore
@@ -82,6 +82,7 @@ tests/check/rtp/recvcodecs
 tests/check/msn/conference
 tests/check/utils/binadded
 tests/check/elements/rtcpfilter
+tests/check/elements/funnel
 tests/rtp/codec-discovery
 examples/commandline/simple-call
 examples/gui/*.pyo
diff --git a/tests/check/Makefile.am b/tests/check/Makefile.am
index cac15e9d..12201fb0 100644
--- a/tests/check/Makefile.am
+++ b/tests/check/Makefile.am
@@ -53,7 +53,8 @@ check_PROGRAMS = \
 	rtp/recvcodecs \
 	msn/conference \
 	utils/binadded \
-	elements/rtcpfilter
+	elements/rtcpfilter \
+	elements/funnel
 
 AM_CFLAGS = \
 	$(CFLAGS) \
@@ -143,3 +144,6 @@ utils_binadded_SOURCES = \
 elements_rtcpfilter_CFLAGS = $(AM_CFLAGS)
 elements_rtcpfilter_SOURCES = elements/rtcpfilter.c
 elements_rtcpfilter_LDADD = $(LDADD) -lgstrtp-0.10
+
+elements_funnel_CFLAGS = $(AM_CFLAGS)
+elements_funnel_SOURCES = elements/funnel.c
diff --git a/tests/check/elements/funnel.c b/tests/check/elements/funnel.c
new file mode 100644
index 00000000..1a2d3855
--- /dev/null
+++ b/tests/check/elements/funnel.c
@@ -0,0 +1,151 @@
+/* Farsight 2 unit tests for the fsfunnel
+ *
+ * Copyright (C) 2008 Collabora, Nokia
+ * @author: Olivier Crete <olivier.crete@collabora.co.uk>
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 2.1 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
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301 USA
+*/
+
+
+#ifdef HAVE_CONFIG_H
+# include <config.h>
+#endif
+
+#include <gst/check/gstcheck.h>
+
+struct TestData {
+  GstElement *funnel;
+  GstPad *funnelsrc, *funnelsink11, *funnelsink22;
+  GstPad *mysink, *mysrc1, *mysrc2;
+};
+
+static void
+setup_test_objects (struct TestData *td, GstPadChainFunction chain_func)
+{
+  GstCaps *caps =  gst_caps_new_simple ("test/test", NULL);
+
+  td->funnel = gst_element_factory_make ("fsfunnel", NULL);
+
+  td->funnelsrc = gst_element_get_static_pad (td->funnel, "src");
+  fail_unless (td->funnelsrc != NULL);
+
+  td->funnelsink11 = gst_element_get_request_pad (td->funnel, "sink11");
+  fail_unless (td->funnelsink11 != NULL);
+  fail_unless (!strcmp (GST_OBJECT_NAME (td->funnelsink11), "sink11"));
+
+  td->funnelsink22 = gst_element_get_request_pad (td->funnel, "sink22");
+  fail_unless (td->funnelsink22 != NULL);
+  fail_unless (!strcmp (GST_OBJECT_NAME (td->funnelsink22), "sink22"));
+
+  fail_unless (gst_element_set_state (td->funnel, GST_STATE_PLAYING) ==
+      GST_STATE_CHANGE_SUCCESS);
+
+  td->mysink = gst_pad_new ("sink", GST_PAD_SINK);
+  gst_pad_set_chain_function (td->mysink, chain_func);
+  gst_pad_set_active (td->mysink, TRUE);
+  gst_pad_set_caps (td->mysink, caps);
+
+  td->mysrc1 = gst_pad_new ("src1", GST_PAD_SRC);
+  gst_pad_set_active (td->mysrc1, TRUE);
+  gst_pad_set_caps (td->mysrc1, caps);
+
+  td->mysrc2 = gst_pad_new ("src2", GST_PAD_SRC);
+  gst_pad_set_active (td->mysrc2, TRUE);
+  gst_pad_set_caps (td->mysrc2, caps);
+
+  fail_unless (GST_PAD_LINK_SUCCESSFUL(
+          gst_pad_link (td->funnelsrc, td->mysink)));
+
+  fail_unless (GST_PAD_LINK_SUCCESSFUL(
+          gst_pad_link (td->mysrc1, td->funnelsink11)));
+
+  fail_unless (GST_PAD_LINK_SUCCESSFUL(
+          gst_pad_link (td->mysrc2, td->funnelsink22)));
+
+  gst_caps_unref (caps);
+}
+
+static void
+release_test_objects (struct TestData *td)
+{
+  gst_pad_set_active (td->mysink, FALSE);
+  gst_pad_set_active (td->mysrc1, FALSE);
+  gst_pad_set_active (td->mysrc1, FALSE);
+
+  gst_object_unref (td->mysink);
+  gst_object_unref (td->mysrc1);
+  gst_object_unref (td->mysrc2);
+
+  fail_unless (gst_element_set_state (td->funnel, GST_STATE_NULL) ==
+      GST_STATE_CHANGE_SUCCESS);
+
+  gst_object_unref (td->funnelsrc);
+  gst_object_unref (td->funnelsink11);
+  gst_element_release_request_pad (td->funnel, td->funnelsink11);
+  gst_object_unref (td->funnelsink22);
+  gst_element_release_request_pad (td->funnel, td->funnelsink22);
+
+  gst_object_unref (td->funnel);
+}
+
+static gint bufcount = 0;
+
+static GstFlowReturn
+chain_ok (GstPad *pad, GstBuffer *buffer)
+{
+  bufcount++;
+
+  gst_buffer_unref (buffer);
+
+  return GST_FLOW_OK;
+}
+
+GST_START_TEST (test_funnel_simple)
+{
+  struct TestData td;
+
+  setup_test_objects (&td, chain_ok);
+
+  bufcount = 0;
+
+  fail_unless (gst_pad_push (td.mysrc1, gst_buffer_new ()) == GST_FLOW_OK);
+  fail_unless (gst_pad_push (td.mysrc2, gst_buffer_new ()) == GST_FLOW_OK);
+
+  fail_unless (bufcount == 2);
+
+  release_test_objects (&td);
+}
+GST_END_TEST;
+
+static Suite *
+funnel_suite (void)
+{
+  Suite *s = suite_create ("funnel");
+  TCase *tc_chain;
+  GLogLevelFlags fatal_mask;
+
+  fatal_mask = g_log_set_always_fatal (G_LOG_FATAL_MASK);
+  fatal_mask |= G_LOG_LEVEL_WARNING | G_LOG_LEVEL_CRITICAL;
+  g_log_set_always_fatal (fatal_mask);
+
+  tc_chain = tcase_create ("funnel simple");
+  tcase_add_test (tc_chain, test_funnel_simple);
+  suite_add_tcase (s, tc_chain);
+
+  return s;
+}
+
+GST_CHECK_MAIN (funnel);
+