Fixed gst_play_dispose function so that GstPlay objects can be unrefed safely.

Original commit message from CVS:
Fixed gst_play_dispose function so that GstPlay objects can be unrefed safely.
Optimized some g_idle_add for the signal poller.

2 files changed, 75 insertions, 16 deletions

diff --git a/gst-libs/gst/play/play.old.c b/gst-libs/gst/play/play.old.c
index 2e9edea7..ee7d5f6e 100644
--- a/gst-libs/gst/play/play.old.c
+++ b/gst-libs/gst/play/play.old.c
@@ -73,8 +73,8 @@ static void         gst_play_init		    (GstPlay *play);
 static void         gst_play_class_init	            (GstPlayClass *klass);
 static void         gst_play_dispose		    (GObject *object);
 
-static void         gst_play_default_timeout_add    (guint interval, GSourceFunc function, gpointer data);
-static void         gst_play_default_idle_add       (GSourceFunc function, gpointer data);
+static guint         gst_play_default_timeout_add    (guint interval, GSourceFunc function, gpointer data);
+static guint         gst_play_default_idle_add       (GSourceFunc function, gpointer data);
 
 static void         gst_play_set_property	    (GObject *object, guint prop_id, 
 						     const GValue *value, GParamSpec *pspec);
@@ -298,6 +298,9 @@ gst_play_init (GstPlay *play)
 	play->video_bin_mutex = g_mutex_new();
 	gst_play_set_idle_timeout_funcs(play, gst_play_default_timeout_add, gst_play_default_idle_add);
 
+	/*fixored by dolphy */
+	
+	play->tick_timeout_id = play->idle_timeout_id = play->idle_signal_id = 0;
 }
 
 GstPlay *
@@ -390,6 +393,18 @@ static void
 gst_play_dispose (GObject *object)
 {
 	GstPlay *play = GST_PLAY (object);
+	/* fixored by dolphy : Before disposing removing any callback that could
+	be called : time ticks, signal poller, etc...*/
+	if (play->tick_timeout_id)
+		if (!g_source_remove(play->tick_timeout_id))
+			g_warning("failed to remove timetick timer %d", play->tick_timeout_id);
+	if (play->idle_timeout_id)
+		if (!g_source_remove(play->idle_timeout_id))
+			g_warning("failed to remove idle timer %d", play->idle_timeout_id);
+	if (play->idle_signal_id)
+		if (!g_source_remove(play->idle_signal_id))
+			g_warning("failed to remove signal idle timer %d", play->idle_signal_id);
+		
 	G_OBJECT_CLASS (parent_class)->dispose (object);
 	g_mutex_free(play->audio_bin_mutex);
 	g_mutex_free(play->video_bin_mutex);
@@ -413,7 +428,10 @@ callback_pipeline_deep_notify (GstElement *element, GstElement *orig, GParamSpec
 	signal->signal_data.info.element = orig;
 	signal->signal_data.info.param = param;
 	g_async_queue_push(play->signal_queue, signal);
-	play->idle_add_func ((GSourceFunc) gst_play_idle_signal, play);
+	/* fixored by dolphy : If an idle callback has been added for signal polling
+	no need to put a new one */
+	if (!play->idle_signal_id)
+		play->idle_signal_id = play->idle_add_func ((GSourceFunc) gst_play_idle_signal, play);
 }
 
 static void
@@ -431,12 +449,12 @@ callback_pipeline_state_change (GstElement *element, GstElementState old, GstEle
 	if (GST_IS_PIPELINE (play->pipeline)){
 		switch (state) {
 		case GST_STATE_PLAYING:
-			play->idle_add_func ((GSourceFunc) gst_play_idle_callback, play);
-			play->timeout_add_func (200, (GSourceFunc) gst_play_tick_callback, play);
+			play->idle_timeout_id = play->idle_add_func ((GSourceFunc) gst_play_idle_callback, play);
+			play->tick_timeout_id = play->timeout_add_func (200, (GSourceFunc) gst_play_tick_callback, play);
 			if (play->length_nanos == 0LL){
 				/* try to get the length up to 16 times */
 				play->get_length_attempt = 16;
-				play->timeout_add_func (200, (GSourceFunc) gst_play_get_length_callback, play);
+				play->timeout_add_func (200, (GSourceFunc) gst_play_get_length_callback, play); 
 			}
 			break;
 		default:
@@ -448,7 +466,10 @@ callback_pipeline_state_change (GstElement *element, GstElementState old, GstEle
 	signal->signal_data.state.old_state = old;
 	signal->signal_data.state.new_state = state;
 	g_async_queue_push(play->signal_queue, signal);
-	play->idle_add_func ((GSourceFunc) gst_play_idle_signal, play);
+	/* fixored by dolphy : If an idle callback has been added for signal polling
+	no need to put a new one */
+	if (!play->idle_signal_id)
+		play->idle_signal_id = play->idle_add_func ((GSourceFunc) gst_play_idle_signal, play);
 }
 
 static gboolean
@@ -456,7 +477,11 @@ gst_play_idle_signal (GstPlay *play)
 {
 	GstPlaySignal *signal;
 	gint queue_length;
-
+	
+	/* fixored by dolphy : Added safety check on play before poping */
+	
+	g_return_val_if_fail(GST_IS_PLAY(play), FALSE);
+	
 	signal = g_async_queue_try_pop(play->signal_queue);
 	if (signal == NULL){
 		return FALSE;
@@ -485,6 +510,13 @@ gst_play_idle_signal (GstPlay *play)
 
 	g_free(signal);
 	queue_length = g_async_queue_length (play->signal_queue);
+	
+	/* fixored by dolphy : If queue length is zero the idle callback will be
+	destroyed */
+	
+	if (!queue_length)
+		play->idle_signal_id = 0;
+	
 	return (queue_length > 0);
 }
 
@@ -509,7 +541,10 @@ callback_video_have_xid (GstElement *element, gint xid, GstPlay *play)
 	signal->signal_id = HAVE_XID;
 	signal->signal_data.video_xid.xid = xid;
 	g_async_queue_push(play->signal_queue, signal);
-	play->idle_add_func ((GSourceFunc) gst_play_idle_signal, play);
+	/* fixored by dolphy : If an idle callback has been added for signal polling
+	no need to put a new one */
+	if (!play->idle_signal_id)
+		play->idle_signal_id = play->idle_add_func ((GSourceFunc) gst_play_idle_signal, play);
 	/*g_print("have xid %d\n", xid);*/
 }
 
@@ -522,7 +557,10 @@ callback_video_have_size (GstElement *element, gint width, gint height, GstPlay
 	signal->signal_data.video_size.width = width;
 	signal->signal_data.video_size.height = height;
 	g_async_queue_push(play->signal_queue, signal);
-	play->idle_add_func ((GSourceFunc) gst_play_idle_signal, play);
+	/* fixored by dolphy : If an idle callback has been added for signal polling
+	no need to put a new one */
+	if (!play->idle_signal_id)
+		play->idle_signal_id = play->idle_add_func ((GSourceFunc) gst_play_idle_signal, play);
 	/*g_print("have size %d x %d\n", width, height);*/
 }
 
@@ -575,6 +613,11 @@ static gboolean
 gst_play_tick_callback (GstPlay *play)
 {
 	gint secs;
+	
+	/* fixored by dolphy : Added safety check on play before accessing */
+	
+	g_return_val_if_fail(GST_IS_PLAY(play), FALSE);
+	
 	play->clock = gst_bin_get_clock (GST_BIN (play->pipeline));
 	play->time_nanos = gst_clock_get_time(play->clock);
 	secs = (gint) (play->time_nanos / GST_SECOND);
@@ -589,6 +632,10 @@ gst_play_tick_callback (GstPlay *play)
 static gboolean
 gst_play_idle_callback (GstPlay *play)
 {
+	/* fixored by dolphy : Added safety check on play before iterating */
+	
+	g_return_val_if_fail(GST_IS_PLAY(play), FALSE);
+	
 	return gst_bin_iterate (GST_BIN (play->pipeline));
 }
 
@@ -702,22 +749,28 @@ gst_play_default_idle (GstPlayIdleData *idle_data)
 	return FALSE;
 }
 
-static void
+static guint
 gst_play_default_timeout_add (guint interval, GSourceFunc function, gpointer data)
 {
 	GstPlayIdleData *idle_data = g_new0(GstPlayIdleData, 1);
 	idle_data->func = function;
 	idle_data->data = data;
-	g_timeout_add (interval, (GSourceFunc)gst_play_default_idle, idle_data);
+	
+	/* fixored by dolphy : here we return the source tag to caller */
+	
+	return g_timeout_add (interval, (GSourceFunc)gst_play_default_idle, idle_data);
 }
 
-static void
+static guint
 gst_play_default_idle_add (GSourceFunc function, gpointer data)
 {
 	GstPlayIdleData *idle_data = g_new0(GstPlayIdleData, 1);
 	idle_data->func = function;
 	idle_data->data = data;
-	g_idle_add ((GSourceFunc)gst_play_default_idle, idle_data);
+	
+	/* fixored by dolphy : here we return the source tag to caller */
+	
+	return g_idle_add ((GSourceFunc)gst_play_default_idle, idle_data);
 }
 
 void
diff --git a/gst-libs/gst/play/play.old.h b/gst-libs/gst/play/play.old.h
index 16fbb007..f9bc1e62 100644
--- a/gst-libs/gst/play/play.old.h
+++ b/gst-libs/gst/play/play.old.h
@@ -77,8 +77,8 @@ typedef struct _GstPlay          GstPlay;
 typedef struct _GstPlayClass     GstPlayClass;
 typedef struct _GstPlayIdleData  GstPlayIdleData;
 
-typedef void (*GstPlayTimeoutAdd) (guint interval, GSourceFunc function, gpointer data);
-typedef void (*GstPlayIdleAdd)    (GSourceFunc function, gpointer data);
+typedef guint (*GstPlayTimeoutAdd) (guint interval, GSourceFunc function, gpointer data);
+typedef guint (*GstPlayIdleAdd)    (GSourceFunc function, gpointer data);
 
 struct _GstPlay
 {
@@ -116,6 +116,12 @@ struct _GstPlay
 	gint64 seek_time;
  	gint64 time_nanos;
  	gint64 length_nanos;
+	
+	/*fixored by dolphy */
+	
+	guint tick_timeout_id;
+	guint idle_timeout_id;
+	guint idle_signal_id;
 
 	GAsyncQueue *signal_queue;