[gst-devel] gstreamer appliaction
Sedji Gaouaou
sedji.gaouaou at atmel.com
Mon Nov 30 15:32:25 CET 2009
Hi,
Sorry to bother you again, but I have changed my apps accordingly to the
comments of Kapil:
In on_pad_added, I am nw using the queue:
void on_pad_added (GstElement *element, GstPad *pad)
{
g_debug ("Signal: pad-added");
GstCaps *caps;
GstStructure *str;
gchar *name;
caps = gst_pad_get_caps (pad);
g_assert (caps != NULL);
name = gst_pad_get_name (pad);
g_print ("Name of the pad %s\n", name);
g_free (name);
str = gst_caps_get_structure (caps, 0);
g_assert (str != NULL);
if (g_strrstr (gst_structure_get_name (str), "video")) {
g_debug ("Linking video pad to dec_vd");
// Link it actually
GstPad *targetsink = gst_element_get_pad (vdqueue, "sink");
g_assert (targetsink != NULL);
gst_pad_link (pad, targetsink);
gst_object_unref (targetsink);
}
if (g_strrstr (gst_structure_get_name (str), "audio")) {
g_debug ("Linking audio pad to dec_ad");
// Link it actually
GstPad *targetsink = gst_element_get_pad (adqueue, "sink");
g_assert (targetsink != NULL);
gst_pad_link (pad, targetsink);
gst_object_unref (targetsink);
}
gst_caps_unref (caps);
}
And in my main I have done:
/* demux only */
gst_bin_add_many (GST_BIN (pipeline),
source, demuxer, NULL);
/* video only */
gst_bin_add_many (GST_BIN (pipeline), vdqueue, decvd, vdsink, NULL);
/* audio only */
gst_bin_add_many (GST_BIN (pipeline), adqueue, decad, adsink, NULL);
/* we link the elements together */
/* file-source -> demuxer ~> decoder -> image sink */
gst_element_link (source, demuxer);
if(!gst_element_link_many( vdqueue, decvd, vdsink, NULL)) {
printf("problem linking video elements!!!!!\n");
return FALSE;
}
if(!gst_element_link_many( adqueue, decad, adsink, NULL)) {
printf("problem linking audio elements!!!!!\n");
return FALSE;
}
g_signal_connect (demuxer, "pad-added", G_CALLBACK (on_pad_added), NULL);
So basically I should have:
|source | demux | ---> |video decod|video sink(ximagesink|
---> |audio decod| alsasink|
But when I try to play an avi file, it stucks...I guess there is a pb
with the thread or something...
Here is the message:
root at at91sam9m10ekes:/# ./player mnt/video/test.avi
Now playing: mnt/video/test.avi
** (player:2628): DEBUG: Signal: pad-added
Name of the pad video_00 --> so video pad is ok
** (player:2628): DEBUG: Linking video pad to dec_vd
** (player:2628): DEBUG: Signal: pad-added
Name of the pad audio_00 --> so audio pad is ok
** (player:2628): DEBUG: Linking audio pad to dec_ad
Running...
And it is stuck here with no video nor sound playing...
Has anyone got an idea?
BR,
Sedji
> On Thu, Nov 26, 2009 at 9:52 PM, Kapil Agrawal <kapil.agl at gmail.com> wrote:
>> you should be adding respective queue before the audio and video decoder
>> (essentially after the demuxer), and in the on_pad_added connect to the
>> sinkpad of those queue.
>>
>>>
>>> #include <gst/gst.h>
>>> #include <glib.h>
>>> #include <string.h>
>>>
>>>
>>> static GstElement *source, *demuxer, *vdqueue, *adqueue, *vdsink,
>>> *adsink, *decvd, *decad;
>>>
>>> void on_pad_added (GstElement *element, GstPad *pad)
>>> {
>>> g_debug ("Signal: pad-added");
>>> GstCaps *caps;
>>> GstStructure *str;
>>>
>>> caps = gst_pad_get_caps (pad);
>>> g_assert (caps != NULL);
>>> str = gst_caps_get_structure (caps, 0);
>>> g_assert (str != NULL);
>>>
>>> if (g_strrstr (gst_structure_get_name (str), "video")) {
>>> g_debug ("Linking video pad to dec_vd");
>>> // Link it actually
>>> GstPad *targetsink = gst_element_get_pad (decvd, "sink");
>>> g_assert (targetsink != NULL);
>>> gst_pad_link (pad, targetsink);
>>> gst_object_unref (targetsink);
>>> }
>>>
>>> if (g_strrstr (gst_structure_get_name (str), "audio")) {
>>> g_debug ("Linking audio pad to dec_ad");
>>> // Link it actually
>>> GstPad *targetsink = gst_element_get_pad (decad, "sink");
>>> g_assert (targetsink != NULL);
>>> gst_pad_link (pad, targetsink);
>>> gst_object_unref (targetsink);
>>> }
>>>
>>> gst_caps_unref (caps);
>>> }
>>>
>>> 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;
>>> }
>>>
>>> int
>>> main (int argc,
>>> char *argv[])
>>> {
>>> GMainLoop *loop;
>>>
>>> GstElement *pipeline;
>>> GstBus *bus;
>>>
>>> /* Initialisation */
>>> gst_init (&argc, &argv);
>>>
>>> loop = g_main_loop_new (NULL, FALSE);
>>>
>>>
>>> /* Check input arguments */
>>> if (argc != 2) {
>>> g_printerr ("Usage: %s <Video H264 filename>\n", argv[0]);
>>> return -1;
>>> }
>>>
>>> /* Create gstreamer elements */
>>> pipeline = gst_pipeline_new ("media-player");
>>> source = gst_element_factory_make
>>> ("filesrc","file-source");
>>> demuxer = gst_element_factory_make
>>> ("avidemux","avi-demuxer");
>>> decvd = gst_element_factory_make ("x170",
>>> "video-decoder");
>>> decad = gst_element_factory_make ("mad", "mp3-decoder");
>>> vdsink = gst_element_factory_make ("ximagesink",
>>> "video-sink");
>>> vdqueue = gst_element_factory_make ("multiqueue",
>>> "video-queue");
>>> adqueue = gst_element_factory_make ("multiqueue",
>>> "audio-queue");
>>> adsink = gst_element_factory_make ("osssink",
>>> "audio-sink");
>>>
>>> /* if needed to be set to MPEG4(value 4), default is AUTO */
>>> //g_object_set (decvd, "codec", 4, NULL);
>>> /* output format: RGB16 (i.e 2) */
>>> g_object_set (decvd, "output", 2, NULL);
>>> /* Scaling value */
>>> g_object_set (decvd, "scaling", 1.0, NULL);
>>> /* Threshold of the VDEC to sync audio and video */
>>> g_object_set (decvd, "inbuf-thresh", 100000, NULL);
>>>
>>> if (!pipeline || !source || !demuxer || !decvd || !vdsink ||
>>> !vdqueue
>>> || !decad || !adqueue || !adsink) {
>>> g_printerr ("One element could not be created.
>>> Exiting.\n");
>>> return -1;
>>> }
>>>
>>> /* Set up the pipeline */
>>>
>>> /* we set the input filename to the source element */
>>> g_object_set (G_OBJECT (source), "location", argv[1], NULL);
>>>
>>> /* we add a message handler */
>>> bus = gst_pipeline_get_bus (GST_PIPELINE (pipeline));
>>> gst_bus_add_watch (bus, bus_call, loop);
>>> gst_object_unref (bus);
>>>
>>> /* we add all elements into the pipeline */
>>> /* file-source | avi-demuxer | x170-decoder | ximagesink
>>> * | mad | audioconvert | osssink*/
>>>
>>> /* demux only */
>>> gst_bin_add_many (GST_BIN (pipeline),
>>> source, demuxer, NULL);
>>>
>>> /* video only */
>>> gst_bin_add_many (GST_BIN (pipeline),
>>> decvd, vdqueue, vdsink, NULL);
>>>
>>> /* audio only */
>>> gst_bin_add_many (GST_BIN (pipeline),
>>> decad, adqueue, adsink, NULL);
>>>
>>> /* we link the elements together */
>>> /* file-source -> demuxer ~> decoder -> image sink */
>>> gst_element_link (source, demuxer);
>>>
>>> if(!gst_element_link_many(decvd, vdqueue, vdsink, NULL)) {
>>> printf("problem linking video elements!!!!!\n");
>>> return FALSE;
>>> }
>>>
>>> if(!gst_element_link_many( decad, adqueue, adsink, NULL)) {
>>> printf("problem linking audio elements!!!!!\n");
>>> return FALSE;
>>> }
>>>
>>> gst_element_link_pads (demuxer, "video", vdqueue, "sink");
>>> gst_element_link_pads (demuxer, "audio", adqueue, "sink");
>>>
>>> g_signal_connect (demuxer, "pad-added", G_CALLBACK (on_pad_added),
>>> NULL);
>>>
>>> /* note that the demuxer will be linked to the decoder dynamically.
>>> The reason is that Ogg may contain various streams (for example
>>> audio and video). The source pad(s) will be created at run time,
>>> by the demuxer when it detects the amount and nature of streams.
>>> Therefore we connect a callback function which will be executed
>>> when the "pad-added" is emitted.*/
>>>
>>> /* Set the pipeline to "playing" state*/
>>> g_print ("Now 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 Crystal Reports handle the reporting - Free Crystal Reports 2008
>>> 30-Day
>>> trial. Simplify your report design, integration and deployment - and focus
>>> on
>>> what you do best, core application coding. Discover what's new with
>>> Crystal Reports now. http://p.sf.net/sfu/bobj-july
>>> _______________________________________________
>>> gstreamer-devel mailing list
>>> gstreamer-devel at lists.sourceforge.net
>>> https://lists.sourceforge.net/lists/listinfo/gstreamer-devel
>>
>>
>> --
>> http://www.linkedin.com/in/kapilagrawal
>>
>> ------------------------------------------------------------------------------
>> Let Crystal Reports handle the reporting - Free Crystal Reports 2008 30-Day
>> trial. Simplify your report design, integration and deployment - and focus
>> on
>> what you do best, core application coding. Discover what's new with
>> Crystal Reports now. http://p.sf.net/sfu/bobj-july
>> _______________________________________________
>> gstreamer-devel mailing list
>> gstreamer-devel at lists.sourceforge.net
>> https://lists.sourceforge.net/lists/listinfo/gstreamer-devel
>>
>>
>
> ------------------------------------------------------------------------------
> Let Crystal Reports handle the reporting - Free Crystal Reports 2008 30-Day
> trial. Simplify your report design, integration and deployment - and focus on
> what you do best, core application coding. Discover what's new with
> Crystal Reports now. http://p.sf.net/sfu/bobj-july
> _______________________________________________
> gstreamer-devel mailing list
> gstreamer-devel at lists.sourceforge.net
> https://lists.sourceforge.net/lists/listinfo/gstreamer-devel
>
More information about the gstreamer-devel
mailing list