problem with compiling the maktroska application using gstreamer

[Thiago Santos]

On 09/14/2014 07:35 PM, gsksiva21 wrote:
> hai ,
> i'm a beginner to gstreamer. i wrote my first code to play matroska file ..
> but i'm little bit confused to use the dynamic pipeline and now the video
> not playing at all ..
> help me out  fix the errors.
What errors? Do you get anything printed?

GST_DEBUG can likely tell what is going on, did you try it?

Also, you are using GStreamer 0.10 that is unmantained and obsolete. 
Please upgrade to 1.0 when possible.

>
> note :
>   i can able to play the mkv file using gst-launch-0.10.
> i put some debug message inside the on-pad-added function call but no
> message printed!!
>
> kindly let me know where the problem is & how to resolve it...
> i tired a lot but i'm not able to overcome it..!
>   
> and this is my application pipeline flow:
>
>   gst-launch-0.10  filesrc location=Videos/0001.mkv ! matroskademux name=d
> d.video_00 ! queue !  h264parse ! ffdec_h264 ! ffmpegcolorspace !
> xvimagesink  d.audio_00 ! queue ! ac3parse !  ffdec_ac3 ! audioconvert !
> audioresample ! alsasink
>
>
>   my application code as below :
>
> #include <stdio.h>
> #include <gst/gst.h>
>
> typedef struct __CustomData {
> GstElement *source;
> GstElement *demuxer;
> GstElement *audio_queue;
> GstElement *audio_parse;
> GstElement *audio_decoder;
> GstElement *audio_convert;
> GstElement *audio_resamp;
> GstElement *audio_sink;
> GstElement *video_queue;
> GstElement *video_parse;
> GstElement *video_decoder;
> GstElement *video_convert;
> GstElement *video_sink;
> GstElement *pipeline;
> }CustomData;
>    
> static gboolean bus_call (GstBus *bus, GstMessage *msg,gpointer data);
> static void on_pad_added (GstElement *src, GstPad *pad, CustomData *data);
> gint main (gint argc , gchar *argv[])
> {
> CustomData data;
> GstBus *bus;
> GstMessage *msg;
> GstStateChangeReturn ret;
> gboolean terminate = FALSE;
> GMainLoop *loop;
> guint bus_watch_id;
> gint64 time_nanoseconds =1;
> GstPadTemplate *src_pad_template;
> GstPad *audio_pad, *video_pad;
> GstPad *queue_audio_pad, *queue_video_pad;
>   
> gst_init(&argc ,&argv);
>
> if (argc < 2 || !gst_uri_is_valid (argv[1]))
> {
> g_error ("Usage: %s file:///path/to/file", argv[0]);
> return -1;
> }
> loop = g_main_loop_new (NULL, FALSE);
> /*pipeline*/
>
> data.pipeline=gst_pipeline_new("mak_pipeline");
>
>
> data.source=gst_element_factory_make ("filesrc","mak_source");
> data.demuxer=gst_element_factory_make("matroskademux","mat_demux");
>
> /*audio part */
> data.audio_queue = gst_element_factory_make("queue","audio_queue");
> data.audio_parse =gst_element_factory_make ("ac3parse","audio_parse");
> data.audio_decoder=gst_element_factory_make ("ffdec_ac3","audio_decoder");
> data.audio_convert=gst_element_factory_make ("audioconvert","audio_conv");
> data.audio_resamp=gst_element_factory_make ("audioresample","audio_resamp");
> data.audio_sink=gst_element_factory_make ("alsasink","audio_sink");
>
>
>
> if (!data.pipeline  || ! data.source || ! data.demuxer || ! data.audio_queue
> 		|| ! data.audio_parse || ! data.audio_decoder || ! data.audio_convert
> 		|| ! data.audio_resamp || ! data.audio_sink  )
> {
> g_printerr("audio element creation failed \n");
> gst_object_unref(data.pipeline);
> return -1 ;
> }
>
> /*video part */
> data.video_queue=gst_element_factory_make ("queue","video_queue");
> data.video_parse =gst_element_factory_make ("h264parse","video_parse");
> data.video_decoder=gst_element_factory_make("ffdec_h264","video_decoder");
> data.video_convert= gst_element_factory_make
> ("ffmpegcolorspace","video_convert");
> data.video_sink=gst_element_factory_make ("autovideosink","video_sink" );
> if (!data.video_queue  || ! data.video_parse || ! data.video_decoder
> 		|| ! data.video_convert || ! data.video_sink)
> {
> g_printerr("video element creation failed \n");
> gst_object_unref(data.pipeline);
> return -1 ;
> }
> /*input file path set*/
> g_object_set (G_OBJECT (data.source), "location", argv[1], NULL);
> 	//create abus for log message tracking
> 	bus=gst_pipeline_get_bus(GST_PIPELINE(data.pipeline));
> 	bus_watch_id = gst_bus_add_watch (bus, bus_call, loop);
> 	gst_object_unref (bus);
>
> /*bin creation*/
> gst_bin_add_many
> (GST_BIN(data.pipeline),data.source,data.demuxer,data.audio_queue,
> data.audio_parse,data.audio_decoder,data.audio_convert,data.audio_resamp,data.audio_sink,
> data.video_queue,data.video_parse,data.video_decoder,data.video_convert,data.video_sink,NULL);
>
> /*link creation*/
> if (!gst_element_link(data.source,data.demuxer))
> {
> g_printerr("source to demuxer link failed \n");
> gst_object_unref(data.pipeline);
> return -1;
> }
>
> if (!gst_element_link_many(data.audio_queue,data.audio_parse,
> data.audio_decoder,data.audio_convert,data.audio_resamp,data.audio_sink,NULL))
> {
> g_printerr("audio queue part failed to link \n ");
> gst_object_unref(data.pipeline);
> return -1;
> }
>
> if (!gst_element_link_many(data.video_queue,data.video_parse,
> data.video_decoder,data.video_convert,data.video_sink,NULL))
> {
> g_printerr("video link failed \n ");
> gst_object_unref(data.pipeline);
> return -1;
> }
> /*link elements with pipeline was done*/
> g_print("before pad added \n ");
> /*pad added processing*/
>
>    g_signal_connect (data.demuxer, "pad-added", G_CALLBACK (on_pad_added),
> &data);
> /*using request pad */
> g_print("after pad added \n ");
> g_print ("Now playing: %s\n", argv[1]);
>
> ret = gst_element_set_state (data.pipeline, GST_STATE_PLAYING);
>
> if (ret == GST_STATE_CHANGE_FAILURE) {
> g_printerr ("Unable to set the pipeline to the playing state.\n");
> gst_object_unref (data.pipeline);
> return -1;
> }
>
> /* Iterate */
> g_print ("Running...\n");
> //g_timeout_add (200, (GSourceFunc) cb_print_position, data.pipeline);
> //seek_to_time (data.pipeline,time_nanoseconds);
>
> g_main_loop_run (loop);
> /* Listen to the bus */
> bus = gst_element_get_bus (data.pipeline);
> /* we add a message handler */
> bus_watch_id = gst_bus_add_watch (bus, bus_call, loop);
> gst_object_unref (bus);
You are getting the bus after the mainloop and you already did it above.

>
> /* Out of the main loop, clean up nicely */
> g_print ("Returned, stopping playback\n");
> gst_element_set_state (data.pipeline, GST_STATE_NULL);
> g_print ("Deleting pipeline\n");
> gst_object_unref (GST_OBJECT (data.pipeline));
> g_source_remove (bus_watch_id);
> g_main_loop_unref (loop);
>
> return 0;
> }
>
>
> static gboolean bus_call (GstBus *bus,GstMessage *msg,gpointer data)
> {
> GMainLoop *loop = (GMainLoop *) data;
> switch (GST_MESSAGE_TYPE (msg)) {
> case GST_MESSAGE_EOS:
> g_print ("End of stream\n");
> g_main_loop_quit (loop);
> break;
> case GST_MESSAGE_ERROR: {
> gchar *debug;
> GError *error;
> gst_message_parse_error (msg, &error, &debug);
> g_free (debug);
> g_printerr ("Error: %s\n", error->message);
> g_error_free (error);
> g_main_loop_quit (loop);
> break;
> }
> default:
> break;
> }
> return TRUE;
> }
> static void on_pad_added  (GstElement *src, GstPad *new_pad, CustomData
> *data) {
>
> gint width, height;
> GstPadLinkReturn ret;
> GstCaps *new_pad_caps = NULL;
> GstStructure *new_pad_struct = NULL;
> const gchar *new_pad_type = NULL;
> GstPad *sink_pad_audio =NULL;
> GstPad *sink_pad_video=NULL;
> g_print("inside pad added \n ");
> sink_pad_audio = gst_element_get_static_pad (data->audio_queue, "sink");
> sink_pad_video = gst_element_get_static_pad (data->video_queue, "sink");
> g_print("inside pad added \n ");
> g_print ("Received new pad '%s' from '%s':\n", GST_PAD_NAME (new_pad),
> GST_ELEMENT_NAME (src));
>
> /* If our audio converter is already linked, we have nothing to do here */
>
> if (gst_pad_is_linked (sink_pad_audio)) {
> g_print (" We are already linked. Ignoring.\n");
> goto exit;
> }
>
>
> /* If our video converter is already linked, we have nothing to do here */
> if (gst_pad_is_linked (sink_pad_video)) {
> g_print (" We are already linked. Ignoring.\n");
> goto exit;
> }
>
> /* Check the new pad's type */
> new_pad_caps = gst_pad_get_caps (new_pad);
> new_pad_struct = gst_caps_get_structure (new_pad_caps, 0);
> new_pad_type = gst_structure_get_name (new_pad_struct);
>
> if (g_str_has_prefix (new_pad_type, "audio/x-raw")){
>
> /* Attempt the link */
> ret = gst_pad_link (new_pad, sink_pad_audio);
> if (GST_PAD_LINK_FAILED (ret)) {
> g_print (" Type is '%s' but link failed.\n", new_pad_type);
> } else {
> //read_video_props (new_pad_caps);
> g_print (" Link succeeded (type '%s').\n", new_pad_type);
>
> }
> } else if (g_str_has_prefix (new_pad_type, "video/x-raw")) {
> /* Attempt the link */
>
> ret = gst_pad_link (new_pad, sink_pad_video);
> if (GST_PAD_LINK_FAILED (ret)) {
> g_print (" Type is '%s' but link failed.\n", new_pad_type);
> } else {
>
> g_print (" Link succeeded (type '%s').\n", new_pad_type);
>
> }
> } else {
> g_print (" It has type '%s' which is not raw audio. Ignoring.\n",
> new_pad_type);
> goto exit;
> }
>
> exit:
> /* Unreference the new pad's caps, if we got them */
> if (new_pad_caps != NULL)
> gst_caps_unref (new_pad_caps);
>
> /* Unreference the sink pad */
> gst_object_unref (sink_pad_audio);
> gst_object_unref (sink_pad_video);
> }
>
>
> regards
> gsksiva
>
>
>
>
> --
> View this message in context: http://gstreamer-devel.966125.n4.nabble.com/problem-with-compiling-the-maktroska-application-using-gstreamer-tp4668718.html
> Sent from the GStreamer-devel mailing list archive at Nabble.com.
> _______________________________________________
> gstreamer-devel mailing list
> gstreamer-devel at lists.freedesktop.org
> http://lists.freedesktop.org/mailman/listinfo/gstreamer-devel


-- 
Thiago Sousa Santos
Senior Multimedia Engineer, Open Source Group
Samsung Research America - Silicon Valley