tests/muxing/case1.c

   1 #include <gst/gst.h>
   2
   3 gboolean playing = TRUE;
   4
   5 static void
   6 handoff_signal (GstElement *element, GstBuffer *buf)
   7 {
   8   g_print ("handoff \"%s\" %llu\n", gst_element_get_name (element), GST_BUFFER_TIMESTAMP (buf));
   9 }
  10
  11 static void
  12 eos_signal (GstElement *element)
  13 {
  14   g_print ("eos received from \"%s\"\n", gst_element_get_name (element));
  15
  16   playing = FALSE;
  17 }
  18
  19 int
  20 main(int argc,char *argv[])
  21 {
  22   GstBin *pipeline;
  23   GstElement *src, *tee, *identity1, *identity2, *aggregator, *sink;
  24
  25   gst_init (&argc, &argv);
  26
  27   pipeline = GST_BIN (gst_pipeline_new ("pipeline"));
  28   g_return_val_if_fail (pipeline != NULL, 1);
  29
  30   src = gst_element_factory_make ("fakesrc", "src");
  31   g_object_set (G_OBJECT (src), "num_buffers", 40, NULL);
  32   g_return_val_if_fail (src != NULL, 2);
  33   tee = gst_element_factory_make ("tee", "tee");
  34   g_return_val_if_fail (tee != NULL, 3);
  35   identity1 = gst_element_factory_make ("identity", "identity0");
  36   g_return_val_if_fail (identity1 != NULL, 3);
  37   identity2 = gst_element_factory_make ("identity", "identity1");
  38   g_object_set (G_OBJECT (identity2), "duplicate", 2, NULL);
  39   g_object_set (G_OBJECT (identity2), "loop_based", TRUE, NULL);
  40   g_return_val_if_fail (identity2 != NULL, 3);
  41   aggregator = gst_element_factory_make ("aggregator", "aggregator");
  42   g_object_set (G_OBJECT (aggregator), "sched", 4, NULL);
  43   g_return_val_if_fail (aggregator != NULL, 3);
  44   sink = gst_element_factory_make ("fakesink", "sink");
  45   g_return_val_if_fail (sink != NULL, 4);
  46
  47   gst_bin_add_many (pipeline, src, tee, identity1, identity2, aggregator, sink, NULL);
  48
  49   gst_element_link_pads (src, "src", tee, "sink");
  50   gst_pad_link (gst_element_get_request_pad (tee, "src%d"),
  51                    gst_element_get_pad (identity1, "sink"));
  52   gst_pad_link (gst_element_get_request_pad (tee, "src%d"),
  53                    gst_element_get_pad (identity2, "sink"));
  54   gst_pad_link (gst_element_get_pad (identity1, "src"),
  55                    gst_element_get_request_pad (aggregator, "sink%d"));
  56   gst_pad_link (gst_element_get_pad (identity2, "src"),
  57                    gst_element_get_request_pad (aggregator, "sink%d"));
  58   gst_element_link_pads (aggregator, "src", sink, "sink");
  59
  60   g_signal_connect (G_OBJECT (src), "eos",
  61                     G_CALLBACK (eos_signal), NULL);
  62   g_signal_connect (G_OBJECT (sink), "handoff",
  63                     G_CALLBACK (handoff_signal), NULL);
  64
  65   gst_element_set_state (GST_ELEMENT (pipeline), GST_STATE_PLAYING);
  66
  67   while (gst_bin_iterate (pipeline));
  68
  69   gst_element_set_state (GST_ELEMENT (pipeline), GST_STATE_NULL);
  70
  71   exit (0);
  72 }