Compiler: AM5728: GStream playing TS files

Hello,

In the code I do not see the correct adding of the demuxer element.

With gst-inspect-1.0  you could check the SRC and SINK templates.

Here is example of how demuxer could be add:

static void on_pad_added (GstElement *element, GstPad *pad, gpointer data)

{

GstPad *sinkpad;

gchar *name;

GstElement *vqueue = (GstElement *) data;

GstElement *aqueue = (GstElement *) data;

/* Link this pad with the queue sink pad */

name = gst_pad_get_name( pad );

if (strncmp(name, "video_00", NULL)==0){

g_print ("Dynamic pad created, linking demuxer/vsink\n");

sinkpad = gst_element_get_static_pad (vqueue, "sink");

gst_pad_link (pad, sinkpad);

gst_object_unref (sinkpad);

   }  

else if (strncmp(name, "audio_00",  NULL)==0){

g_print ("Dynamic pad created, linking demuxer/asink\n");

sinkpad = gst_element_get_static_pad (aqueue, "sink");

gst_pad_link (pad, sinkpad);

gst_object_unref (sinkpad);

}

printf( "%s - New pad '%s'\n", __FUNCTION__, name);

}

The bold test should be changed based on which demuxer you are using (SRC and SINK templates from gst-inspect command.).

With function g_signal_connect  you could "listen" for the newly created demuxer's pads and link the elements.

BR
Margarita

Hello,

Please try this code:



#include <stdio.h>
#include <gst/gst.h>




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 *element, GstPad *pad, gpointer data)
{
GstPad *sinkpad;
gchar *name;

GstElement *vqueue = (GstElement *) data;
GstElement *aqueue = (GstElement *) data;
/* Link this pad with the queue sink pad */
name = gst_pad_get_name( pad );
if (strncmp(name, "video_0041", NULL)==0){
g_print ("Dynamic pad created, linking demuxer/vsink\n");
sinkpad = gst_element_get_static_pad (vqueue, "sink");
gst_pad_link (pad, sinkpad);
gst_object_unref (sinkpad);
}

printf( "%s - New pad '%s'\n", __FUNCTION__, name);

}



int main (int argc, char *argv[])
{
GMainLoop *loop;
GstBus *bus;
GstCaps *caps;

GstElement *pipeline;
GstElement *filesrc;
GstElement *demuxer;
GstElement *vqueue;
GstElement *parser;
GstElement *decoder;
GstElement *vsink;





/* Initialisation */
gst_init (&argc, &argv);
loop = g_main_loop_new (NULL, FALSE);

/* Create gstreamer elements*/

pipeline = gst_pipeline_new("tsplay");

filesrc = gst_element_factory_make("filesrc", "filesource");
g_return_val_if_fail (filesrc, -1);
g_object_set (G_OBJECT (filesrc), "location", argv[1], NULL);

demuxer = gst_element_factory_make("tsdemux", "demux");
g_return_val_if_fail (demuxer, -1);

vqueue = gst_element_factory_make("queue","vqueue");
g_return_val_if_fail (vqueue, -1);

parser = gst_element_factory_make("h264parse","parser");
g_return_val_if_fail (parser, -1);

decoder = gst_element_factory_make("ducatih264dec", "decoder");
g_return_val_if_fail (decoder, -1);


vsink = gst_element_factory_make("waylandsink", "sink");
g_return_val_if_fail (vsink, -1);



/* Add a message handler */
bus = gst_pipeline_get_bus (GST_PIPELINE (pipeline));
gst_bus_add_watch (bus, bus_call, loop);
gst_object_unref (bus);


/* Add elements to pipeline before linking them.*/


gst_bin_add (GST_BIN (pipeline), filesrc);
gst_bin_add (GST_BIN (pipeline), demuxer);
gst_bin_add (GST_BIN (pipeline), vqueue);
gst_bin_add (GST_BIN (pipeline), parser);
gst_bin_add (GST_BIN (pipeline), decoder);
gst_bin_add (GST_BIN (pipeline), vsink);


/* Link the pipeline */
gst_element_link_pads (filesrc, "src", demuxer, "sink");
gst_element_link_pads (demuxer, "src", vqueue, "sink");
/* listen for newly created pads */
g_signal_connect (G_OBJECT (demuxer), "pad-added", G_CALLBACK (on_pad_added), vqueue);
gst_element_link_pads (vqueue, "src", parser, "sink");
gst_element_link_pads (parser, "src", decoder, "sink");
gst_element_link_pads (decoder, "src", vsink, "sink");

/* Set the pipeline to "playing" state */
g_print ("Playing: %s\n", argv[1]);
gst_element_set_state (pipeline, GST_STATE_PLAYING);

/* Iterate */
g_print ("Running...\n");
g_main_loop_run (loop);

/* Out of the main loop, clean up nicely */
g_print ("Returned, stopping playback\n");
gst_element_set_state (pipeline, GST_STATE_NULL);

g_print ("Deleting pipeline\n");
gst_object_unref (GST_OBJECT (pipeline));

return 0;
}

Let me know the result.
Execution: ./<name of the app> <video file name>


BR
Margarita