GStreamer-devel

pause problem

Classic

List

Threaded

2 messages Options

Paulo Benatto

pause problem

i created a pipe filesrc ! decodebin ! appsink and set the appsink to dont emit signals and block when reaches a maximum number of buffers, my problem is that with this behaviour after pausing the pipeline i cant set it to playing again, the stream seens to be locked. Before setting to play again if i perform a seek (to any position) them the playing will occur. Im using a separated thread to pull the data from the appsink, i dont now if this is a bug of appsink, i cant see what im doing wrong (i used gst-debug=5 and the pipe seens to get blocked when i set it back to playing state). I would apreciate if someone could help, here is the source code:

#include <stdio.h>
#include <glib.h>
#include <gst/gst.h>
#include <gst/app/gstappsink.h>

static const int SLEEP_TIME_US = 5000;
static gboolean run_thread = TRUE;

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 ("Fim da 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 ("Erro: %s\n", error->message);
       g_error_free (error);

       g_main_loop_quit (loop);

       break;
       }

       default:
       g_print("Tipo da mensagem [%d], Nome da mensagem [%s]\n", GST_MESSAGE_TYPE (msg), GST_MESSAGE_TYPE_NAME(msg));
       break;
   }       return TRUE;
}

// ------------------ START PADS - ELEMENTS GENERIC FUNCTIONS --------------- //

static int connect_pads(GstPad* src, GstPad* sink)
{
   gchar* src_name = NULL;
   gchar* sink_name = NULL;
   if(gst_pad_link(src, sink) != GST_PAD_LINK_OK){
       src_name = gst_pad_get_name(src);
       sink_name = gst_pad_get_name(sink);
       g_debug("Error linking [%s] to [%s]", src_name, sink_name);
       g_free(src_name);
       g_free(sink_name);
       return FALSE;
   }
   return TRUE;
}

// ------------------ END PADS - ELEMENTS GENERIC FUNCTIONS --------------- //

// ------------------ START DECODEBIN FUNCTIONS --------------------- //
static void callback_type_found(GstElement *decodebin, GstPad *srcpad, gboolean last, gpointer output)
{
   GstElement* output_element = (GstElement*)output;
   GstPad* sinkpad = NULL;
      if(output_element == NULL) {
       g_debug("callback_type_found: Error casting gpointer to GstElement");
       return;
   }

   sinkpad = gst_element_get_static_pad(output_element, "sink");       if(sinkpad == NULL) {
       g_debug("callback_type_found: Error getting output_element sink pad");
       return;
   }

   if(!connect_pads(srcpad, sinkpad)) {
       g_debug("callback_type_found: Cannot connect decodebin "
                                               "srcpad to output_element sinkpad");
       g_object_unref (sinkpad);
       return;
   }

   g_debug("callback_type_found: Ended successfully");
   g_object_unref(sinkpad);
}

static void build_decodebin(GstElement* pipeline, GstElement* src, GstElement* output, const gchar* caps)
{
   GstElement* decoder = gst_element_factory_make ("decodebin", "decoder");
   g_debug("Trying to use decodebin to find type and decode media!");
   if(!decoder) {
       g_debug("build_decodebin: Error creating decodebin");
       return;
   }

   if(caps != NULL) {
       GstCaps* caps_obj = gst_caps_from_string(caps);
       if(caps_obj == NULL){
           g_debug("build_decodebin: Error creating caps[%s]", caps);
           return;
       }
       g_object_set(G_OBJECT (decoder), "sink-caps", caps_obj, NULL);
   }

   if(!gst_bin_add(GST_BIN (pipeline), decoder)) {
       g_debug("build_decodebin: Error inserting the decodebin on the pipeline");
       return;
   }

   if(!gst_element_link(src, decoder)) {
       g_debug("build_decodebin: Error linking the source element to the decoder");
       return;
   }
      g_signal_connect (decoder, "new-decoded-pad", G_CALLBACK(callback_type_found), output);
}

// ------------------ END DECODEBIN FUNCTIONS --------------------- //

static gpointer pull_func(gpointer data)
{
   GstAppSink* appsink = (GstAppSink*) data;
   GstBuffer* buffer = NULL;
      while(run_thread){
       g_usleep(SLEEP_TIME_US);
       if(appsink){
           buffer = gst_app_sink_pull_buffer(appsink);
           if(buffer){
               g_debug("appsink: buffer timestamp(%lli) size(%d)",
               GST_BUFFER_TIMESTAMP(buffer),
               GST_BUFFER_SIZE(buffer));
               gst_buffer_unref(buffer);
           }else{
               g_warning("NULL BUFFER PULLED !!");
           }
       }else{
           g_warning("NULL APPSINK !!!");
       }
   }

   return NULL;
}

gboolean resume_time(gpointer data)
{
   /* IF I DO THIS THE PLAYING WORKS AND APPSINK GIVES ME BUFFERS
   gint64 cur;
   GstFormat format = gst_format_get_by_nick(gst_format_get_name(GST_FORMAT_TIME));
   gst_element_query_position(GST_ELEMENT (data), &format, &cur);

   if (!gst_element_seek_simple(GST_ELEMENT(data),
                                GST_FORMAT_TIME,
                                GST_SEEK_FLAG_FLUSH | GST_SEEK_FLAG_KEY_UNIT, cur)) {
       g_print ("Seek failed!\n");
       return FALSE;
   }*/

   g_debug("PLAY \n");
   gst_element_set_state(GST_ELEMENT(data), GST_STATE_PLAYING);

   return FALSE;
}

gboolean pause_time(gpointer data)
{
   g_debug("PAUSE \n");
   gst_element_set_state (GST_ELEMENT(data), GST_STATE_PAUSED);
   return FALSE;
}

int main(int argc, char *argv[])
{
   GstElement *pipeline = NULL;
   GstElement *source = NULL;
   GstElement *appsink = NULL;
   GstBus *bus = NULL;
   GMainLoop *loop = NULL;
   GThread * pull_thread = NULL;

   if(argc < 2){
       g_debug("Usage [%s] [uri]", argv[0]);
       return -1;
   }
   gst_init (&argc, &argv);
   loop = g_main_loop_new (NULL, FALSE);
      pipeline      = gst_pipeline_new ("pause-block-pipe");
   source        = gst_element_factory_make ("filesrc", "sourceFile");
   g_object_set (G_OBJECT(source), "location", argv[1], NULL);
   appsink       = gst_element_factory_make ("appsink", "asink");

   if (!pipeline || !source || !appsink) {
       g_printerr ("Erro na criacao de um dos elementos do pipe.\n");
       return -1;
   }
   bus = gst_pipeline_get_bus (GST_PIPELINE (pipeline));
   gst_bus_add_watch (bus, bus_call, loop);
   gst_object_unref (bus);

   gst_bin_add_many (GST_BIN(pipeline), source, appsink, NULL);
   build_decodebin(pipeline, source, appsink, NULL);

   gst_app_sink_set_max_buffers((GstAppSink*)appsink, 10);
   g_object_set (G_OBJECT(appsink), "sync", FALSE, NULL);

   pull_thread = g_thread_create(pull_func, appsink, TRUE, NULL);
   if(!pull_thread){
       g_debug("Error creating thread!!");
       return -1;
   }
   gst_element_set_state (pipeline, GST_STATE_PLAYING);
   g_timeout_add_seconds(2, pause_time, pipeline);
   g_timeout_add_seconds(6, resume_time, pipeline);

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

   /* Out of the main loop, clean up nicely */
   g_print ("Terminando...\n");
   run_thread = FALSE;
   gst_element_set_state (pipeline, GST_STATE_NULL);

   g_print ("Deletando pipeline...\n");
   gst_object_unref (GST_OBJECT (pipeline));
      return 1;    }

--
Paulo Leonardo Benatto, patito
"the fear of being free makes you proud of being a slave"

------------------------------------------------------------------------------
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
[hidden email]
https://lists.sourceforge.net/lists/listinfo/gstreamer-devel

Tiago Katcipis

Re: pause problem

http://bugzilla.gnome.org/show_bug.cgi?id=592657

On Thu, Aug 20, 2009 at 2:05 PM, Paulo Benatto <[hidden email]> wrote:

i created a pipe filesrc ! decodebin ! appsink and set the appsink to dont emit signals and block when reaches a maximum number of buffers, my problem is that with this behaviour after pausing the pipeline i cant set it to playing again, the stream seens to be locked. Before setting to play again if i perform a seek (to any position) them the playing will occur. Im using a separated thread to pull the data from the appsink, i dont now if this is a bug of appsink, i cant see what im doing wrong (i used gst-debug=5 and the pipe seens to get blocked when i set it back to playing state). I would apreciate if someone could help, here is the source code:

#include <stdio.h>
#include <glib.h>
#include <gst/gst.h>
#include <gst/app/gstappsink.h>

static const int SLEEP_TIME_US = 5000;
static gboolean run_thread = TRUE;

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 ("Fim da 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 ("Erro: %s\n", error->message);
       g_error_free (error);

       g_main_loop_quit (loop);

       break;
       }

       default:
       g_print("Tipo da mensagem [%d], Nome da mensagem [%s]\n", GST_MESSAGE_TYPE (msg), GST_MESSAGE_TYPE_NAME(msg));
       break;
   }       return TRUE;
}

// ------------------ START PADS - ELEMENTS GENERIC FUNCTIONS --------------- //

static int connect_pads(GstPad* src, GstPad* sink)
{
   gchar* src_name = NULL;
   gchar* sink_name = NULL;
   if(gst_pad_link(src, sink) != GST_PAD_LINK_OK){
       src_name = gst_pad_get_name(src);
       sink_name = gst_pad_get_name(sink);
       g_debug("Error linking [%s] to [%s]", src_name, sink_name);
       g_free(src_name);
       g_free(sink_name);
       return FALSE;
   }
   return TRUE;
}

// ------------------ END PADS - ELEMENTS GENERIC FUNCTIONS --------------- //

// ------------------ START DECODEBIN FUNCTIONS --------------------- //
static void callback_type_found(GstElement *decodebin, GstPad *srcpad, gboolean last, gpointer output)
{
   GstElement* output_element = (GstElement*)output;
   GstPad* sinkpad = NULL;
      if(output_element == NULL) {
       g_debug("callback_type_found: Error casting gpointer to GstElement");
       return;
   }

   sinkpad = gst_element_get_static_pad(output_element, "sink");       if(sinkpad == NULL) {
       g_debug("callback_type_found: Error getting output_element sink pad");
       return;
   }

   if(!connect_pads(srcpad, sinkpad)) {
       g_debug("callback_type_found: Cannot connect decodebin "
                                               "srcpad to output_element sinkpad");
       g_object_unref (sinkpad);
       return;
   }

   g_debug("callback_type_found: Ended successfully");
   g_object_unref(sinkpad);
}

static void build_decodebin(GstElement* pipeline, GstElement* src, GstElement* output, const gchar* caps)
{
   GstElement* decoder = gst_element_factory_make ("decodebin", "decoder");
   g_debug("Trying to use decodebin to find type and decode media!");
   if(!decoder) {
       g_debug("build_decodebin: Error creating decodebin");
       return;
   }

   if(caps != NULL) {
       GstCaps* caps_obj = gst_caps_from_string(caps);
       if(caps_obj == NULL){
           g_debug("build_decodebin: Error creating caps[%s]", caps);
           return;
       }
       g_object_set(G_OBJECT (decoder), "sink-caps", caps_obj, NULL);
   }

   if(!gst_bin_add(GST_BIN (pipeline), decoder)) {
       g_debug("build_decodebin: Error inserting the decodebin on the pipeline");
       return;
   }

   if(!gst_element_link(src, decoder)) {
       g_debug("build_decodebin: Error linking the source element to the decoder");
       return;
   }
      g_signal_connect (decoder, "new-decoded-pad", G_CALLBACK(callback_type_found), output);
}

// ------------------ END DECODEBIN FUNCTIONS --------------------- //

static gpointer pull_func(gpointer data)
{
   GstAppSink* appsink = (GstAppSink*) data;
   GstBuffer* buffer = NULL;
      while(run_thread){
       g_usleep(SLEEP_TIME_US);
       if(appsink){
           buffer = gst_app_sink_pull_buffer(appsink);
           if(buffer){
               g_debug("appsink: buffer timestamp(%lli) size(%d)",
               GST_BUFFER_TIMESTAMP(buffer),
               GST_BUFFER_SIZE(buffer));
               gst_buffer_unref(buffer);
           }else{
               g_warning("NULL BUFFER PULLED !!");
           }
       }else{
           g_warning("NULL APPSINK !!!");
       }
   }

   return NULL;
}

gboolean resume_time(gpointer data)
{
   /* IF I DO THIS THE PLAYING WORKS AND APPSINK GIVES ME BUFFERS
   gint64 cur;
   GstFormat format = gst_format_get_by_nick(gst_format_get_name(GST_FORMAT_TIME));
   gst_element_query_position(GST_ELEMENT (data), &format, &cur);

   if (!gst_element_seek_simple(GST_ELEMENT(data),
                                GST_FORMAT_TIME,
                                GST_SEEK_FLAG_FLUSH | GST_SEEK_FLAG_KEY_UNIT, cur)) {
       g_print ("Seek failed!\n");
       return FALSE;
   }*/

   g_debug("PLAY \n");
   gst_element_set_state(GST_ELEMENT(data), GST_STATE_PLAYING);

   return FALSE;
}

gboolean pause_time(gpointer data)
{
   g_debug("PAUSE \n");
   gst_element_set_state (GST_ELEMENT(data), GST_STATE_PAUSED);
   return FALSE;
}

int main(int argc, char *argv[])
{
   GstElement *pipeline = NULL;
   GstElement *source = NULL;
   GstElement *appsink = NULL;
   GstBus *bus = NULL;
   GMainLoop *loop = NULL;
   GThread * pull_thread = NULL;

   if(argc < 2){
       g_debug("Usage [%s] [uri]", argv[0]);
       return -1;
   }
   gst_init (&argc, &argv);
   loop = g_main_loop_new (NULL, FALSE);
      pipeline      = gst_pipeline_new ("pause-block-pipe");
   source        = gst_element_factory_make ("filesrc", "sourceFile");
   g_object_set (G_OBJECT(source), "location", argv[1], NULL);
   appsink       = gst_element_factory_make ("appsink", "asink");

   if (!pipeline || !source || !appsink) {
       g_printerr ("Erro na criacao de um dos elementos do pipe.\n");
       return -1;
   }
   bus = gst_pipeline_get_bus (GST_PIPELINE (pipeline));
   gst_bus_add_watch (bus, bus_call, loop);
   gst_object_unref (bus);

   gst_bin_add_many (GST_BIN(pipeline), source, appsink, NULL);
   build_decodebin(pipeline, source, appsink, NULL);

   gst_app_sink_set_max_buffers((GstAppSink*)appsink, 10);
   g_object_set (G_OBJECT(appsink), "sync", FALSE, NULL);

   pull_thread = g_thread_create(pull_func, appsink, TRUE, NULL);
   if(!pull_thread){
       g_debug("Error creating thread!!");
       return -1;
   }
   gst_element_set_state (pipeline, GST_STATE_PLAYING);
   g_timeout_add_seconds(2, pause_time, pipeline);
   g_timeout_add_seconds(6, resume_time, pipeline);

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

   /* Out of the main loop, clean up nicely */
   g_print ("Terminando...\n");
   run_thread = FALSE;
   gst_element_set_state (pipeline, GST_STATE_NULL);

   g_print ("Deletando pipeline...\n");
   gst_object_unref (GST_OBJECT (pipeline));
      return 1;    }

--
Paulo Leonardo Benatto, patito
"the fear of being free makes you proud of being a slave"

------------------------------------------------------------------------------
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
[hidden email]
https://lists.sourceforge.net/lists/listinfo/gstreamer-devel

--
"it might be a profitable thing to learn Java, but it has no intellectual value whatsoever" Alexander Stepanov

------------------------------------------------------------------------------
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
[hidden email]
https://lists.sourceforge.net/lists/listinfo/gstreamer-devel