#include int main (int argc, char *argv[]) { GstElement *pipeline, *thread, *queue, *src, *identity, *sink; gst_init (&argc, &argv); free (malloc (8)); /* -lefence */ pipeline = gst_pipeline_new ("pipeline"); src = gst_element_factory_make ("fakesrc", "src"); thread = gst_thread_new ("thread"); queue = gst_element_factory_make ("queue", "queue"); identity = gst_element_factory_make ("identity", "identity"); g_object_set (G_OBJECT (identity), "loop_based", TRUE, NULL); sink = gst_element_factory_make ("fakesink", "sink"); gst_bin_add (GST_BIN (thread), queue); gst_bin_add (GST_BIN (thread), identity); gst_bin_add (GST_BIN (thread), sink); gst_bin_add (GST_BIN (pipeline), thread); gst_bin_add (GST_BIN (pipeline), src); gst_element_link_pads (src, "src", queue, "sink"); gst_element_link_pads (queue, "src", identity, "sink"); gst_element_link_pads (identity, "src", sink, "sink"); gst_element_set_state (pipeline, GST_STATE_PLAYING); sleep (1); gst_element_set_state (pipeline, GST_STATE_PAUSED); gst_element_set_state (pipeline, GST_STATE_PLAYING); sleep (1); gst_element_set_state (pipeline, GST_STATE_PAUSED); return 0; }