rendered paste body#include <gst/gst.h>static GMainLoop *loop;GstElement *pipeline;GstPad *videopad = NULL, *audiopad = NULL;static gbooleanmy_bus_callback (GstBus *bus, GstMessage *message, gpointer data){ gchar* f; GstCaps* caps; g_print ("Got %s message\n", GST_MESSAGE_TYPE_NAME (message)); switch (GST_MESSAGE_TYPE (message)) { case GST_MESSAGE_STATE_CHANGED: { GstState old, new, pending; gst_message_parse_state_changed (message, &old, &new, &pending);#if 0 g_debug ("state changed: %s: %u, %u, %u", GST_OBJECT_NAME (message->src), old, new, pending);#endif if (new == GST_STATE_PLAYING && GST_MESSAGE_SRC(message) == pipeline) { /* video */ caps = gst_pad_get_negotiated_caps(videopad); f = gst_caps_to_string(caps); g_print("%s\n", f); gst_caps_unref (caps); /* audio */ caps = gst_pad_get_negotiated_caps(audiopad); f = gst_caps_to_string(caps); g_print("%s\n", f); gst_caps_unref (caps); /* our job is done */ gst_element_set_state (pipeline, GST_STATE_NULL); g_main_loop_quit (loop); } break; } case GST_MESSAGE_ERROR: { GError *err; gchar *debug; gst_message_parse_error (message, &err, &debug); g_print ("Error: %s\n", err->message); g_error_free (err); g_free (debug); g_main_loop_quit (loop); break; } case GST_MESSAGE_EOS: /* end-of-stream */ g_main_loop_quit (loop); break; default: /* unhandled message */ break; } /* we want to be notified again the next time there is a message * on the bus, so returning TRUE (FALSE means we want to stop watching * for messages on the bus and our callback should not be called again) */ return TRUE;}static voidcb_newpad (GstElement *decodebin, GstPad *pad, gboolean last, gpointer data){ GstCaps *caps; GstStructure *str; GstElement *fakesink; /* get caps/struct */ caps = gst_pad_get_caps (pad); str = gst_caps_get_structure (caps, 0); /* check media type */ if (g_strrstr (gst_structure_get_name (str), "audio")) { audiopad = pad; fakesink = gst_element_factory_make ("fakesink", "audiofakesink"); g_print("Audio Done (%d).\n", (int)audiopad); } else { videopad = pad; fakesink = gst_element_factory_make ("fakesink", "videofakesink"); g_print("Video Done (%d).\n", (int)videopad); } /* attach to fakesink */ gst_bin_add_many (GST_BIN (pipeline), fakesink, NULL); GstPad* sinkpad = gst_element_get_pad (fakesink, "sink"); g_print("Sinkpad: %d.\n", (int)sinkpad); gst_pad_link (pad, sinkpad); gst_caps_unref(caps); }gintmain (gint argc, gchar *argv[]){ GstElement *src, *dec, *conv, *sink; GstPad *audiopad; GstBus *bus; /* init GStreamer */ gst_init (&argc, &argv); loop = g_main_loop_new (NULL, FALSE); /* make sure we have input */ if (argc != 2) { g_print ("Usage: %s <filename>\n", argv[0]); return -1; } /* setup */ pipeline = gst_pipeline_new ("pipeline"); bus = gst_pipeline_get_bus (GST_PIPELINE (pipeline)); gst_bus_add_watch (bus, my_bus_callback, loop); gst_object_unref (bus); src = gst_element_factory_make ("filesrc", "source"); g_object_set (G_OBJECT (src), "location", argv[1], NULL); dec = gst_element_factory_make ("decodebin2", "decoder"); g_signal_connect (dec, "new-decoded-pad", G_CALLBACK (cb_newpad), NULL); gst_bin_add_many (GST_BIN (pipeline), src, dec, NULL); gst_element_link (src, dec); /* run */ gst_element_set_state (pipeline, GST_STATE_PLAYING); g_main_loop_run (loop); /* cleanup */ gst_element_set_state (pipeline, GST_STATE_NULL); gst_object_unref (GST_OBJECT (pipeline)); return 0;}