From 3a1a483cd9d2f4495e73e38d71241090677ceb4c Mon Sep 17 00:00:00 2001
From: Wim Taymans <wim.taymans@gmail.com>
Date: Wed, 11 Jul 2001 19:26:22 +0000
Subject: [PATCH] Added a muxing test case.

Original commit message from CVS:
Added a muxing test case.
---
 tests/Makefile.am        |  2 +-
 tests/muxing/.gitignore  | 10 +++++++
 tests/muxing/Makefile.am |  5 ++++
 tests/muxing/case1.c     | 74 ++++++++++++++++++++++++++++++++++++++++++++++++
 4 files changed, 90 insertions(+), 1 deletion(-)
 create mode 100644 tests/muxing/.gitignore
 create mode 100644 tests/muxing/Makefile.am
 create mode 100644 tests/muxing/case1.c

diff --git a/tests/Makefile.am b/tests/Makefile.am
index d8377aa..e974d86 100644
--- a/tests/Makefile.am
+++ b/tests/Makefile.am
@@ -1,4 +1,4 @@
-SUBDIRS = sched eos nego
+SUBDIRS = sched eos nego muxing
 
 noinst_PROGRAMS = init loadall simplefake states caps queue registry \
 paranoia rip mp3encode autoplug props case4 markup load tee autoplug2 autoplug3 \
diff --git a/tests/muxing/.gitignore b/tests/muxing/.gitignore
new file mode 100644
index 0000000..4cc2293
--- /dev/null
+++ b/tests/muxing/.gitignore
@@ -0,0 +1,10 @@
+Makefile
+Makefile.in
+*.o
+*.lo
+*.la
+.deps
+.libs
+*.xml
+*.gst
+case1
diff --git a/tests/muxing/Makefile.am b/tests/muxing/Makefile.am
new file mode 100644
index 0000000..5b25390
--- /dev/null
+++ b/tests/muxing/Makefile.am
@@ -0,0 +1,5 @@
+noinst_PROGRAMS = case1 
+
+# jsut apps here, this is safe
+LIBS += $(GST_LIBS)
+CFLAGS += $(GST_CFLAGS)
diff --git a/tests/muxing/case1.c b/tests/muxing/case1.c
new file mode 100644
index 0000000..dd93076
--- /dev/null
+++ b/tests/muxing/case1.c
@@ -0,0 +1,74 @@
+#include <gst/gst.h>
+
+gboolean playing = TRUE;
+
+static void
+handoff_signal (GstElement *element, GstBuffer *buf)
+{
+  g_print ("handoff \"%s\" %llu\n", gst_element_get_name (element), GST_BUFFER_TIMESTAMP (buf));
+}
+
+static void
+eos_signal (GstElement *element)
+{
+  g_print ("eos received from \"%s\"\n", gst_element_get_name (element));
+
+  playing = FALSE;
+}
+
+int 
+main(int argc,char *argv[]) 
+{
+  GstBin *pipeline;
+  GstElement *src, *tee, *identity1, *identity2, *aggregator, *sink;
+
+  gst_init (&argc, &argv);
+
+  pipeline = GST_BIN (gst_pipeline_new ("pipeline"));
+  g_return_val_if_fail (pipeline != NULL, 1);
+
+  src = gst_elementfactory_make ("fakesrc", "src");
+  g_object_set (G_OBJECT (src), "num_buffers", 4, NULL);
+  g_return_val_if_fail (src != NULL, 2);
+  tee = gst_elementfactory_make ("tee", "tee");
+  g_return_val_if_fail (tee != NULL, 3);
+  identity1 = gst_elementfactory_make ("identity", "identity1");
+  g_return_val_if_fail (identity1 != NULL, 3);
+  identity2 = gst_elementfactory_make ("identity", "identity2");
+  g_object_set (G_OBJECT (identity2), "duplicate", 2, NULL);
+  g_return_val_if_fail (identity2 != NULL, 3);
+  aggregator = gst_elementfactory_make ("aggregator", "aggregator");
+  g_return_val_if_fail (aggregator != NULL, 3);
+  sink = gst_elementfactory_make ("fakesink", "sink");
+  g_return_val_if_fail (sink != NULL, 4);
+
+  gst_bin_add (pipeline, GST_ELEMENT (src));
+  gst_bin_add (pipeline, GST_ELEMENT (tee));
+  gst_bin_add (pipeline, GST_ELEMENT (identity1));
+  gst_bin_add (pipeline, GST_ELEMENT (identity2));
+  gst_bin_add (pipeline, GST_ELEMENT (aggregator));
+  gst_bin_add (pipeline, GST_ELEMENT (sink));
+
+  gst_element_connect (src, "src", tee, "sink");
+  gst_pad_connect (gst_element_request_pad_by_name (tee, "src%d"),
+		   gst_element_get_pad (identity1, "sink"));
+  gst_pad_connect (gst_element_request_pad_by_name (tee, "src%d"),
+		   gst_element_get_pad (identity2, "sink"));
+  gst_pad_connect (gst_element_get_pad (identity1, "src"),
+  		   gst_element_request_pad_by_name (aggregator, "sink%d"));
+  gst_pad_connect (gst_element_get_pad (identity2, "src"),
+  		   gst_element_request_pad_by_name (aggregator, "sink%d"));
+  gst_element_connect (aggregator, "src", sink, "sink");
+
+  g_signal_connectc (G_OBJECT (src), "eos", eos_signal, NULL, FALSE);
+  g_signal_connectc (G_OBJECT (sink), "handoff", handoff_signal, NULL, FALSE);
+
+  gst_element_set_state (GST_ELEMENT (pipeline), GST_STATE_PLAYING);
+
+  while (playing)
+    gst_bin_iterate (pipeline);
+
+  gst_element_set_state (GST_ELEMENT (pipeline), GST_STATE_NULL);
+
+  exit (0);
+}
-- 
2.7.4