GstPipeline and bus call

[killerrats]

edited the code from what i gave you and may be that state change will give
you a pause or ready or something. then maybe if it goes to paused 10 times
and it will quit the loop.

/************* 
global values 
*****    ***********/

GstElement *pipeline;
GMainLoop *loop;
GstBus *bus;
GstMessage* msg;
GstState* state;

#define GST_PLAYER_UDP "udpsrc port=5555 caps=\"application/x-rtp,
media=(string)video, clock-rate=(int)90000, encoding-name=(string)H264,
payload=(int)96\"\ 
                ! rtph264depay ! decodebin ! videoconvert ! autovideosink" 

static gboolean bus_cb (GstBus *bus, GstMessage *msg, gpointer *data);
				
int main()
{
	/* Initialize GStreamer */
	gst_init (&argc, &argv);

	/* Build the pipeline */
	pipeline = gst_parse_launch (GST_PLAYER_UDP, &error); 
	if (!pipeline){ 
			g_print ("\tParse error: %s\n", error->message); 
			return 0; 
	} 
	
	loop = g_main_loop_new (NULL, FALSE);

	/* Start playing */
	gst_element_set_state (pipeline, GST_STATE_PLAYING);

	/* Wait until error or EOS */
	 bus = gst_pipeline_get_bus (GST_PIPELINE (pipeline)); 
	 if(bus == NULL)
	 {
		std::cout << "\nNo Bus\n";
		return 0;
	 }
	gst_bus_add_signal_watch(bus);
	g_signal_connect (bus, "message", G_CALLBACK (bus_cb), this->apPipeline);
	
	g_timeout_add_seconds (1, timeout_cb, loop);
	
	g_main_loop_run(loop);
	
	/* Free resources */
	gst_object_unref (bus);
	gst_element_set_state (pipeline, GST_STATE_NULL);
	gst_object_unref (pipeline);
} 


/********************** 
    bus method
******************/
gboolean bus_cb (GstBus *bus, GstMessage *msg, gpointer *data) {

  switch (GST_MESSAGE_TYPE (msg)) {
	case GST_MESSAGE_ERROR: {
      GError *err;
      gchar *debug;

      gst_message_parse_error (msg, &err, &debug);
      g_print ("Error: %s\n", err->message);
      g_error_free (err);
      g_free (debug);

      gst_element_set_state (pipeline, GST_STATE_READY);
      g_main_loop_quit (loop);
      return FALSE;
    }
    case GST_MESSAGE_EOS:
      /* end-of-stream */
      gst_element_set_state (pipeline, GST_STATE_READY);
      g_main_loop_quit (loop);
      return FALSE;
    case GST_MESSAGE_STATE_CHANGED:
	{
        GstElement* source =
gst_bin_get_by_name(GST_BIN(pipeline),"source");

		if (GST_MESSAGE_SRC (msg) == GST_OBJECT(source)) {
            GstState old_state, new_state, pending_state;
            gst_message_parse_state_changed (msg, &old_state, &new_state,
&pending_state);
			std::string oldstate(gst_element_state_get_name (old_state));
			std::string newstate(gst_element_state_get_name (new_state));
			std::string changestate = "Pipeline state changed from "+oldstate+" to "
+ newstate;
                        std::cout << changestate;
		state = new_state;
		gst_object_unref(source);
	}
	break;
    default:
      /* Unhandled message */
      break;
    }
      return TRUE;
}

gboolean PipelineClass::timeout_cb (gpointer user_data)
{
	static int time = 0;
	static int timeout = 0;
	int MaxTimeout = 10;	
						
		switch (state)
		{
                case GST_STATE_READY:
                {
                   std::cout << "STATE Ready";
                 }
		case GST_STATE_PLAYING:
			{
                               std::cout << "STATE Playing":
			  timeout = 0;
			}
			break;
		case GST_STATE_PAUSED:
			{
                               std::cout << "STATE Paused":
				if(timeout == MaxTimeout)
                                {
                                   g_main_loop_quit(loop);
                                }
				timeout++;
				break;
			}
		case GST_STATE_NULL:
                               std::cout << "STATE Null":
			return FALSE;
		default:
			break;
		}
  return TRUE;
}



--
View this message in context: http://gstreamer-devel.966125.n4.nabble.com/GstPipeline-and-bus-call-tp4684199p4684232.html
Sent from the GStreamer-devel mailing list archive at Nabble.com.