gstreamer/ext/lame/test-lame.c

#include <gst/gst.h>


/* 
 * this example uses tee, fakesrc, fakesink and lame
 *
 * it requests a new pad from tee and attaches lame and fakesink
 * after iterating
 * it requests another one
 * this is to test if the encoder is initialized ok when adding to a
 * pipe that has played
 */

static void
error_callback (GObject * object, GstObject * orig, gchar * error)
{
  g_print ("ERROR: %s: %s\n", GST_OBJECT_NAME (orig), error);
}

int
main (int argc, char *argv[])
{
  GstElement *pipeline;
  GstElement *src, *tee, *encoder1, *encoder2, *sink1, *sink2;
  GstPad *teepad1, *teepad2;
  GstCaps *caps;


  gst_init (&argc, &argv);

  /* create elements */
  if (!(pipeline = gst_element_factory_make ("pipeline", "pipeline")))
    return 1;
  if (!(src = gst_element_factory_make ("fakesrc", "source")))
    return 1;
  if (!(tee = gst_element_factory_make ("tee", "tee")))
    return 1;
  if (!(encoder1 = gst_element_factory_make ("lame", "lame1")))
    return 1;
  if (!(encoder2 = gst_element_factory_make ("lame", "lame2")))
    return 1;
  if (!(sink1 = gst_element_factory_make ("fakesink", "sink1")))
    return 1;
  if (!(sink2 = gst_element_factory_make ("fakesink", "sink2")))
    return 1;

  pipeline = gst_pipeline_new ("pipeline");
  g_signal_connect (pipeline, "error", G_CALLBACK (error_callback), NULL);

  /* set up input */
  g_print ("setting up input\n");
  gst_bin_add (GST_BIN (pipeline), src);
  gst_bin_add (GST_BIN (pipeline), tee);
  gst_pad_link (gst_element_get_pad (src, "src"),
      gst_element_get_pad (tee, "sink"));

  /* set up fakesrc */
  g_object_set (G_OBJECT (src), "filltype", 3, NULL);
  g_object_set (G_OBJECT (src), "sizetype", 3, NULL);

  /* set caps on fakesrc */
  caps = GST_CAPS_NEW ("input audio",
      "audio/raw",
      "format", GST_PROPS_STRING ("int"),
      "rate", GST_PROPS_INT (44100),
      "width", GST_PROPS_INT (16),
      "depth", GST_PROPS_INT (16),
      "law", GST_PROPS_INT (0),
      "signed", GST_PROPS_BOOLEAN (TRUE), "channels", GST_PROPS_INT (1)
      );

  g_object_set (G_OBJECT (src), "sizetype", 3, "filltype", 3, NULL);


  gst_element_set_state (pipeline, GST_STATE_READY);
  g_print ("Setting caps on fakesrc's src pad\n");
  if (gst_pad_try_set_caps (gst_element_get_pad (src, "src"), caps) <= 0)
    g_print ("Could not set caps !\n");

  /* request first pad from tee and connect */
  g_print ("attaching first output pipe to tee\n");
  teepad1 = gst_element_request_pad_by_name (tee, "src%d");

  gst_bin_add (GST_BIN (pipeline), encoder1);
  gst_bin_add (GST_BIN (pipeline), sink1);
  gst_pad_link (teepad1, gst_element_get_pad (encoder1, "sink"));
  gst_pad_link (gst_element_get_pad (encoder1, "src"),
      gst_element_get_pad (sink1, "sink"));

  gst_element_set_state (pipeline, GST_STATE_PLAYING);
  /* iterate */
  g_print ("iterate\n");
  gst_bin_iterate (GST_BIN (pipeline));
  gst_element_set_state (pipeline, GST_STATE_PAUSED);

  /* request second pad and connect */
  g_print ("attaching second output pipe to tee\n");
  teepad2 = gst_element_request_pad_by_name (tee, "src%d");

  gst_bin_add (GST_BIN (pipeline), encoder2);
  gst_bin_add (GST_BIN (pipeline), sink2);
  gst_pad_link (teepad2, gst_element_get_pad (encoder2, "sink"));
  gst_pad_link (gst_element_get_pad (encoder2, "src"),
      gst_element_get_pad (sink2, "sink"));

  gst_element_set_state (pipeline, GST_STATE_PLAYING);
  g_print ("iterate\n");
  gst_bin_iterate (GST_BIN (pipeline));
  g_print ("done\n");
  return 0;
}