Add new libgstplay. This could in theory break ABI, but in practice it doesn't. If there's any complaints (serious on...

Original commit message from CVS:
Add new libgstplay. This could in theory break ABI, but in practice it doesn't. If there's any complaints (serious ones) I can revert this. It's tested and player-for-0.6.0 works with these changes, so it's binary compatible

3 files changed, 1546 insertions, 605 deletions

diff --git a/gst-libs/gst/play/play.old.c b/gst-libs/gst/play/play.old.c
index 4d3daecd3..88a370d5d 100644
--- a/gst-libs/gst/play/play.old.c
+++ b/gst-libs/gst/play/play.old.c
@@ -2,6 +2,7 @@
  * Copyright (C) 1999,2000,2001,2002 Erik Walthinsen <omega@cse.ogi.edu>
  *                    2000,2001,2002 Wim Taymans <wtay@chello.be>
  *                              2002 Steve Baker <steve@stevebaker.org>
+ *								2003 Julien Moutte <julien@moutte.net>
  *
  * play.c: GstPlay object code
  *
@@ -30,12 +31,15 @@ enum {
 	STREAM_LENGTH,
 	TIME_TICK,
 	HAVE_XID,
+	HAVE_VIS_XID,
 	HAVE_VIDEO_SIZE,
 	LAST_SIGNAL,
 };
 
 /* this struct is used to decouple signals coming out of threaded pipelines */
+
 typedef struct _GstPlaySignal    GstPlaySignal;
+
 struct _GstPlaySignal
 {
 	gint signal_id;
@@ -69,36 +73,21 @@ enum
 
 static guint gst_play_signals [LAST_SIGNAL] = { 0 };
 
-static void         gst_play_init		    (GstPlay *play);
-static void         gst_play_class_init	            (GstPlayClass *klass);
-static void         gst_play_dispose		    (GObject *object);
-
-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);
-static void         gst_play_get_property	    (GObject *object, guint prop_id, 
-						     GValue *value, GParamSpec *pspec);
-static void         callback_pipeline_error         (GObject *object, GstObject *orig, gchar *error, GstPlay* play);
-static void         callback_pipeline_state_change  (GstElement *element, GstElementState old, 
-						     GstElementState state, GstPlay *play);
-static void         callback_pipeline_deep_notify   (GstElement *element, GstElement *orig, 
-						     GParamSpec *param, GstPlay *play);
-static void         callback_audio_sink_eos         (GstElement *element, GstPlay *play);
-static void         callback_video_have_xid         (GstElement *element, gint xid, GstPlay *play);
-static void         callback_video_have_size        (GstElement *element, gint width, gint height, GstPlay *play);
+static GstElementClass *parent_class = NULL;
 
+/* ============================================================= */
+/*                                                               */
+/*                       Private Methods                         */
+/*                                                               */
+/* ============================================================= */
 
-static void         callback_bin_pre_iterate        (GstBin *bin, GMutex *mutex);
-static void         callback_bin_post_iterate       (GstBin *bin, GMutex *mutex);
+/* =========================================== */
+/*                                             */
+/*                  Tool Box                   */
+/*                                             */
+/* =========================================== */
 
-static gboolean     gst_play_idle_signal            (GstPlay *play);
-static gboolean     gst_play_idle_callback	    (GstPlay *play);
-static gboolean     gst_play_get_length_callback    (GstPlay *play);
-static gboolean     gst_play_tick_callback          (GstPlay *play);
-
-GQuark
+static GQuark
 gst_play_error_quark (void)
 {
 	static GQuark quark = 0;
@@ -109,11 +98,13 @@ gst_play_error_quark (void)
 	return quark;
 }
 
-/* GError creation when plugin is missing */
-/* If we want to make error messages less generic and have more errors
- * than only plug-ins, move the message creation to the switch */
+/* GError creation when plugin is missing
+ * If we want to make error messages less
+ * generic and have more errors than only
+ * plug-ins, move the message creation to the switch */
 static void
-gst_play_error_plugin (GstPlayError type, GError **error)
+gst_play_error_plugin (	GstPlayError type,
+						GError **error)
 {
         gchar *name;
 
@@ -143,327 +134,168 @@ gst_play_error_plugin (GstPlayError type, GError **error)
                         name = g_strdup ("unknown");
                         break;
         }
-        *error = g_error_new (GST_PLAY_ERROR, type,
-                              "The %s plug-in could not be found. "
-                              "This plug-in is essential for gst-player. "
-                              "Please install it and verify that it works "
-                              "by running 'gst-inspect %s'",
-                              name, name);
+		
+        *error = g_error_new (	GST_PLAY_ERROR,
+								type,
+								"The %s plug-in could not be found. "
+								"This plug-in is essential for gst-player. "
+								"Please install it and verify that it works "
+								"by running 'gst-inspect %s'",
+								name, name);
         g_free (name);
         return;
 }
 
-/* split static pipeline functions to a seperate file */
-#include "playpipelines.c"
-
-static GstElementClass * parent_class = NULL;
-
-GType
-gst_play_get_type (void)
+static void
+gst_play_set_property (	GObject *object,
+						guint prop_id,
+						const GValue *value,
+						GParamSpec *pspec)
 {
-	static GType play_type = 0;
+	GstPlay *play = GST_PLAY (object);
+
+	g_return_if_fail (GST_IS_PLAY (play));
 	
-	if (!play_type)
-	{
-		static const GTypeInfo play_info = {
-			sizeof (GstPlayClass),
-			(GBaseInitFunc) NULL,
-			(GBaseFinalizeFunc) NULL,
-			(GClassInitFunc) gst_play_class_init,
-			NULL, NULL, sizeof (GstPlay),
-			0, (GInstanceInitFunc) gst_play_init,
-			NULL
-		};
-      
-		play_type = g_type_register_static (G_TYPE_OBJECT, "GstPlay", &play_info, 0);
+	switch (prop_id) {
+	case ARG_LOCATION:
+		gst_play_set_location(play, g_value_get_string (value));
+		break;
+	case ARG_VOLUME:
+		gst_play_set_volume(play, g_value_get_float (value));
+		break;
+	case ARG_MUTE:
+		gst_play_set_mute(play, g_value_get_boolean (value));
+		break;
+	default:
+		G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+		break;
 	}
-
-	return play_type;
 }
 
 static void
-gst_play_class_init (GstPlayClass *klass)
+gst_play_get_property (	GObject *object,
+						guint prop_id,
+						GValue *value,
+						GParamSpec *pspec)
 {
-	GObjectClass *gobject_class = G_OBJECT_CLASS (klass);
-  
-	parent_class = g_type_class_ref(GST_TYPE_OBJECT);
-
-	klass->information = NULL;
-	klass->state_changed = NULL;
-	klass->stream_end = NULL;
-  
-	gobject_class->dispose = gst_play_dispose;
-	gobject_class->set_property = GST_DEBUG_FUNCPTR (gst_play_set_property);
-	gobject_class->get_property = GST_DEBUG_FUNCPTR (gst_play_get_property);
-
-	g_object_class_install_property (gobject_class, ARG_LOCATION,
-		g_param_spec_string ("location", "location of file", 
-			             "location of the file to play",
-				     NULL, G_PARAM_READWRITE));
-	g_object_class_install_property (gobject_class, ARG_VOLUME,
-		g_param_spec_float ("volume", "Playing volume", 
-			            "Playing volume", 
-							     0, 1.0, 0, G_PARAM_READWRITE));
-	g_object_class_install_property (gobject_class, ARG_MUTE,
-					 g_param_spec_boolean ("mute", "Volume muted", "Playing volume muted",
-							       FALSE, G_PARAM_READWRITE));
-  
-	gst_play_signals [INFORMATION] = 
-		g_signal_new ("information", 
-			      G_TYPE_FROM_CLASS (klass), 
-			      G_SIGNAL_RUN_FIRST,
-			      G_STRUCT_OFFSET (GstPlayClass, information), 
-			      NULL, NULL,
-			      gst_marshal_VOID__OBJECT_PARAM, 
-			      G_TYPE_NONE, 2, 
-			      G_TYPE_OBJECT, G_TYPE_PARAM);
-	
-	gst_play_signals [STATE_CHANGE] = 
-		g_signal_new ("state_change", 
-			      G_TYPE_FROM_CLASS (klass), 
-			      G_SIGNAL_RUN_FIRST,
-			      G_STRUCT_OFFSET (GstPlayClass, state_changed), 
-			      NULL, NULL,
-			      gst_marshal_VOID__INT_INT,
-			      G_TYPE_NONE, 2, 
-			      G_TYPE_INT, G_TYPE_INT);
-	
-	gst_play_signals [STREAM_END] =
-		g_signal_new ("stream_end",
-			      G_TYPE_FROM_CLASS (klass),
-			      G_SIGNAL_RUN_FIRST,
-			      G_STRUCT_OFFSET (GstPlayClass, stream_end),
-			      NULL, NULL,
-			      gst_marshal_VOID__VOID,
-			      G_TYPE_NONE, 0);
-
-	gst_play_signals [TIME_TICK] = 
-		g_signal_new ("time_tick", 
-			      G_TYPE_FROM_CLASS (klass), 
-			      G_SIGNAL_RUN_FIRST,
-			      G_STRUCT_OFFSET (GstPlayClass, time_tick), 
-			      NULL, NULL,
-			      gst_marshal_VOID__INT64,
-			      G_TYPE_NONE, 1, 
-			      G_TYPE_INT64);
-
-	gst_play_signals [STREAM_LENGTH] = 
-		g_signal_new ("stream_length", 
-			      G_TYPE_FROM_CLASS (klass), 
-			      G_SIGNAL_RUN_FIRST,
-			      G_STRUCT_OFFSET (GstPlayClass, stream_length), 
-			      NULL, NULL,
-			      gst_marshal_VOID__INT64,
-			      G_TYPE_NONE, 1, 
-			      G_TYPE_INT64);
-
-	gst_play_signals [HAVE_XID] = 
-		g_signal_new ("have_xid", 
-			      G_TYPE_FROM_CLASS (klass), 
-			      G_SIGNAL_RUN_FIRST,
-			      G_STRUCT_OFFSET (GstPlayClass, have_xid), 
-			      NULL, NULL,
-			      gst_marshal_VOID__INT,
-			      G_TYPE_NONE, 1, 
-			      G_TYPE_INT);
+	GstPlay *play = GST_PLAY (object);
 
-	gst_play_signals [HAVE_VIDEO_SIZE] = 
-		g_signal_new ("have_video_size", 
-			      G_TYPE_FROM_CLASS (klass), 
-			      G_SIGNAL_RUN_FIRST,
-			      G_STRUCT_OFFSET (GstPlayClass, have_video_size), 
-			      NULL, NULL,
-			      gst_marshal_VOID__INT_INT,
-			      G_TYPE_NONE, 2, 
-			      G_TYPE_INT, G_TYPE_INT);
+	g_return_if_fail (GST_IS_PLAY (play));
 
-	gst_control_init(NULL,NULL);
+	switch (prop_id) {
+	case ARG_LOCATION:
+		g_value_set_string (value, gst_play_get_location(play));
+		break;
+	case ARG_VOLUME:
+		g_value_set_float(value, gst_play_get_volume(play));
+		break;
+	case ARG_MUTE:
+		g_value_set_boolean (value, gst_play_get_mute(play));
+		break;
+	default:
+		G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+		break;
+	}
 }
 
+/* =========================================== */
+/*                                             */
+/*          Event Handlers, Callbacks          */
+/*                                             */
+/* =========================================== */
 
-
-static void 
-gst_play_init (GstPlay *play) 
-{
-	play->pipeline     = NULL;
-	play->source       = NULL;
-	play->autoplugger  = NULL;
-	play->audio_sink   = NULL;
-	play->audio_sink_element   = NULL;
-	play->video_sink   = NULL;
-	play->video_sink_element   = NULL;
-	play->volume       = NULL;
-	play->other_elements = g_hash_table_new(g_str_hash, g_str_equal);
-	play->audio_bin_mutex = g_mutex_new();
-	play->video_bin_mutex = g_mutex_new();
-	gst_play_set_idle_timeout_funcs(play, gst_play_default_timeout_add, gst_play_default_idle_add);
-	play->tick_timeout_id = play->idle_timeout_id = play->idle_signal_id = 0;
-}
-
-GstPlay *
-gst_play_new (GstPlayPipeType pipe_type, GError **error)
+static gboolean
+gst_play_get_length_callback (GstPlay *play)
 {
-	GstPlay *play;
-
-	play = g_object_new (GST_TYPE_PLAY, NULL);
+	gint64 value;
+	GstFormat format = GST_FORMAT_TIME;
+	gboolean query_worked = FALSE;
 
-	/* FIXME: looks like only VIDEO ever gets used ! */
-	switch (pipe_type){
-		case GST_PLAY_PIPE_VIDEO:
-			play->setup_pipeline = gst_play_video_setup;
-			play->teardown_pipeline = NULL;
-			play->set_data_src = gst_play_video_set_data_src;
-			play->set_autoplugger = gst_play_video_set_auto;
-			play->set_video_sink = gst_play_video_set_video;
-			play->set_audio_sink = gst_play_video_set_audio;
-			break;
-		case GST_PLAY_PIPE_AUDIO:
-			/* we can reuse the threaded set functions */
-			play->setup_pipeline = gst_play_audio_setup;
-			play->teardown_pipeline = NULL;
-			play->set_data_src = gst_play_simple_set_data_src;
-			play->set_autoplugger = gst_play_audiot_set_auto;
-			play->set_video_sink = NULL;
-			play->set_audio_sink = gst_play_audiot_set_audio;
-			break;
-		case GST_PLAY_PIPE_AUDIO_THREADED:
-			play->setup_pipeline = gst_play_audiot_setup;
-			play->teardown_pipeline = NULL;
-			play->set_data_src = gst_play_simple_set_data_src;
-			play->set_autoplugger = gst_play_audiot_set_auto;
-			play->set_video_sink = NULL;
-			play->set_audio_sink = gst_play_audiot_set_audio;
-			break;
-		case GST_PLAY_PIPE_AUDIO_HYPER_THREADED:
-			play->setup_pipeline = gst_play_audioht_setup;
-			play->teardown_pipeline = NULL;
-			play->set_data_src = gst_play_simple_set_data_src;
-			play->set_autoplugger = gst_play_audioht_set_auto;
-			play->set_video_sink = NULL;
-			play->set_audio_sink = gst_play_audioht_set_audio;
-			break;
-		default:
-			g_warning("unknown pipeline type: %d\n", pipe_type);
+	g_print("trying to get length\n");
+	if (play->audio_sink_element != NULL){
+		g_mutex_lock(play->audio_bin_mutex);
+		query_worked = gst_element_query (play->audio_sink_element, GST_QUERY_TOTAL, &format, &value);
+		g_mutex_unlock(play->audio_bin_mutex);
 	}
-
-	/* init pipeline */
-	if ((play->setup_pipeline) &&
-	    (! play->setup_pipeline (play, error)))
-	{
-		g_object_unref (play);
-		return NULL;
+	else if (play->video_sink_element != NULL){
+		g_mutex_lock(play->video_bin_mutex);
+		query_worked = gst_element_query (play->video_sink_element, GST_QUERY_TOTAL, &format, &value);
+		g_mutex_unlock(play->video_bin_mutex);
 	}
-
-
-	if (play->pipeline){
-		/* connect to pipeline events */
-		g_signal_connect (G_OBJECT (play->pipeline), "deep_notify", G_CALLBACK (callback_pipeline_deep_notify), play);
-		g_signal_connect (G_OBJECT (play->pipeline), "state_change", G_CALLBACK (callback_pipeline_state_change), play);
-		g_signal_connect (G_OBJECT (play->pipeline), "error", G_CALLBACK (callback_pipeline_error), play);
+	if (query_worked){
+		g_print("got length %" G_GINT64_FORMAT "\n", value);
+		g_signal_emit (G_OBJECT (play), gst_play_signals [STREAM_LENGTH], 0, value);
+		play->length_nanos = value;
+		return FALSE;
 	}
-
-	if (play->volume){
-		play->vol_dpman =  gst_dpman_get_manager(play->volume);
-		play->vol_dparam = gst_dpsmooth_new(G_TYPE_FLOAT);
-  
-		g_object_set(G_OBJECT(play->vol_dparam), "update_period", 2000000LL, NULL);
-  
-		g_object_set(G_OBJECT(play->vol_dparam), "slope_delta_float", 0.1F, NULL);
-		g_object_set(G_OBJECT(play->vol_dparam), "slope_time", 10000000LL, NULL); 
- 
-		if (!gst_dpman_attach_dparam (play->vol_dpman, "volume", play->vol_dparam)){
-			g_warning("could not attach dparam to volume element\n");
+	else {
+		if (play->get_length_attempt-- < 1){
+			/* we've tried enough times, give up */
+			return FALSE;
 		}
-		gst_dpman_set_mode(play->vol_dpman, "asynchronous");
-		gst_play_set_volume(play, 0.9);
 	}
-	
-	play->signal_queue = g_async_queue_new();
-
-	return play;
+	return (gst_element_get_state(play->pipeline) == GST_STATE_PLAYING);
 }
 
-static void
-gst_play_dispose (GObject *object)
+static gboolean
+gst_play_tick_callback (GstPlay *play)
 {
-	GstPlay *play = GST_PLAY (object);
-	/* 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);
-}
-
-static void
-callback_pipeline_error (GObject *object, GstObject *orig, gchar *error, GstPlay* play)
-{ 
-	g_print ("Pipeline error: %s\n", error);
-	if (gst_element_get_state(play->pipeline) == GST_STATE_PLAYING){
-		gst_element_set_state(play->pipeline, GST_STATE_READY);
+	gint secs;
+	
+	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);
+	if (secs != play->time_seconds){
+		play->time_seconds = secs;
+		g_signal_emit (G_OBJECT (play), gst_play_signals [TIME_TICK], 0, play->time_nanos);
 	}
-} 
 
-static void
-callback_pipeline_deep_notify (GstElement *element, GstElement *orig, GParamSpec *param, GstPlay* play)
+	return (gst_element_get_state(play->pipeline) == GST_STATE_PLAYING);
+}
+
+static gboolean
+gst_play_default_idle (GstPlayIdleData *idle_data)
 {
-	GstPlaySignal *signal;
-	signal = g_new0(GstPlaySignal, 1);
-	signal->signal_id = INFORMATION;
-	signal->signal_data.info.element = orig;
-	signal->signal_data.info.param = param;
-	g_async_queue_push(play->signal_queue, signal);
-	/* 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);
+	if(idle_data->func(idle_data->data)){
+		/* call this function again in the future */
+		return TRUE;
+	}
+	/* this function should no longer be called */
+	g_free(idle_data);
+	return FALSE;
 }
 
-static void
-callback_pipeline_state_change (GstElement *element, GstElementState old, GstElementState state, GstPlay* play)
+static guint
+gst_play_default_timeout_add (	guint interval,
+								GSourceFunc function,
+								gpointer data)
 {
-	GstPlaySignal *signal;
+	GstPlayIdleData *idle_data = g_new0(GstPlayIdleData, 1);
+	idle_data->func = function;
+	idle_data->data = data;
 
-	g_return_if_fail (GST_IS_ELEMENT (element));
-	g_return_if_fail (GST_IS_PLAY (play));
-	g_return_if_fail (element == play->pipeline);
+	return g_timeout_add (interval, (GSourceFunc)gst_play_default_idle, idle_data);
+}
 
-	/*g_print ("got state change %s to %s\n", gst_element_state_get_name (old), gst_element_state_get_name (state));*/
+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;
+	
+	return g_idle_add ((GSourceFunc)gst_play_default_idle, idle_data);
+}
 
-	/* do additional stuff depending on state */
-	if (GST_IS_PIPELINE (play->pipeline)){
-		switch (state) {
-		case GST_STATE_PLAYING:
-			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); 
-			}
-			break;
-		default:
-			break;
-		}
-	}	
-	signal = g_new0(GstPlaySignal, 1);
-	signal->signal_id = STATE_CHANGE;
-	signal->signal_data.state.old_state = old;
-	signal->signal_data.state.new_state = state;
-	g_async_queue_push(play->signal_queue, signal);
-	/* 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
+gst_play_idle_callback (GstPlay *play)
+{
+	g_return_val_if_fail(GST_IS_PLAY(play), FALSE);
+	
+	return gst_bin_iterate (GST_BIN (play->pipeline));
 }
 
 static gboolean
@@ -484,6 +316,10 @@ gst_play_idle_signal (GstPlay *play)
 		g_signal_emit (G_OBJECT (play), gst_play_signals[HAVE_XID], 0,
 		               signal->signal_data.video_xid.xid);
 		break;
+	case HAVE_VIS_XID:
+		g_signal_emit (G_OBJECT (play), gst_play_signals[HAVE_VIS_XID], 0,
+		               signal->signal_data.video_xid.xid);
+		break;
 	case HAVE_VIDEO_SIZE:
 		g_signal_emit (G_OBJECT (play), gst_play_signals[HAVE_VIDEO_SIZE], 0, 
 		               signal->signal_data.video_size.width, signal->signal_data.video_size.height);
@@ -502,13 +338,7 @@ gst_play_idle_signal (GstPlay *play)
 
 	g_free(signal);
 	queue_length = g_async_queue_length (play->signal_queue);
-	
-	/* If queue length is zero the idle callback will be
-	destroyed */
-	
-	if (!queue_length)
-		play->idle_signal_id = 0;
-	
+		
 	return (queue_length > 0);
 }
 
@@ -520,166 +350,344 @@ gst_play_idle_eos (GstPlay* play)
 }
 
 static void
-callback_audio_sink_eos (GstElement *element, GstPlay *play)
+callback_audio_sink_eos (	GstElement *element,
+							GstPlay *play)
 {
 	play->idle_add_func ((GSourceFunc) gst_play_idle_eos, play);
 }
 
 static void
-callback_video_have_xid (GstElement *element, gint xid, GstPlay *play)
+callback_video_have_xid (	GstElement *element,
+							gint xid,
+							GstPlay *play)
 {
 	GstPlaySignal *signal;
+	
 	signal = g_new0(GstPlaySignal, 1);
 	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);
+}
+
+static void
+callback_video_have_vis_xid (	GstElement *element,
+								gint xid,
+								GstPlay *play)
+{
+	GstPlaySignal *signal;
+	
+	signal = g_new0(GstPlaySignal, 1);
+	signal->signal_id = HAVE_VIS_XID;
+	signal->signal_data.video_xid.xid = xid;
+	
 	g_async_queue_push(play->signal_queue, signal);
-	/* 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);*/
+	
+	play->idle_add_func ((GSourceFunc) gst_play_idle_signal, play);
 }
 
 static void
-callback_video_have_size (GstElement *element, gint width, gint height, GstPlay *play)
+callback_video_have_size (	GstElement *element,
+							gint width,
+							gint height,
+							GstPlay *play)
 {
 	GstPlaySignal *signal;
+	
 	signal = g_new0(GstPlaySignal, 1);
 	signal->signal_id = HAVE_VIDEO_SIZE;
 	signal->signal_data.video_size.width = width;
 	signal->signal_data.video_size.height = height;
+	
 	g_async_queue_push(play->signal_queue, signal);
-	/* 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);*/
+	
+	play->idle_add_func ((GSourceFunc) gst_play_idle_signal, play);
 }
 
 static void 
-callback_bin_pre_iterate (GstBin *bin, GMutex *mutex)
+callback_bin_pre_iterate (	GstBin *bin,
+							GMutex *mutex)
 {
 	g_mutex_lock(mutex);
 }
 
 static void 
-callback_bin_post_iterate (GstBin *bin, GMutex *mutex)
+callback_bin_post_iterate (	GstBin *bin,
+							GMutex *mutex)
 {
 	g_mutex_unlock(mutex);
 }
 
-static gboolean
-gst_play_get_length_callback (GstPlay *play)
-{
-	gint64 value;
-	GstFormat format = GST_FORMAT_TIME;
-	gboolean query_worked = FALSE;
-
-	g_print("trying to get length\n");
-	if (play->audio_sink_element != NULL){
-		g_mutex_lock(play->audio_bin_mutex);
-		query_worked = gst_element_query (play->audio_sink_element, GST_QUERY_TOTAL, &format, &value);
-		g_mutex_unlock(play->audio_bin_mutex);
-	}
-	else if (play->video_sink_element != NULL){
-		g_mutex_lock(play->video_bin_mutex);
-		query_worked = gst_element_query (play->video_sink_element, GST_QUERY_TOTAL, &format, &value);
-		g_mutex_unlock(play->video_bin_mutex);
-	}
-	if (query_worked){
-		g_print("got length %lld\n", value);
-		g_signal_emit (G_OBJECT (play), gst_play_signals [STREAM_LENGTH], 0, value);
-		play->length_nanos = value;
-		return FALSE;
-	}
-	else {
-		if (play->get_length_attempt-- < 1){
-			/* we've tried enough times, give up */
-			return FALSE;
-		}
-	}
-	return (gst_element_get_state(play->pipeline) == GST_STATE_PLAYING);
-}
+static void
+callback_pipeline_error (	GObject *object,
+							GstObject *orig,
+							gchar *error,
+							GstPlay* play)
+{ 
+	g_print ("Pipeline error: %s\n", error);
+	if (gst_element_get_state(play->pipeline) == GST_STATE_PLAYING)
+		gst_element_set_state(play->pipeline, GST_STATE_READY);
+} 
 
-static gboolean
-gst_play_tick_callback (GstPlay *play)
+static void
+callback_pipeline_deep_notify (	GstElement *element,
+								GstElement *orig,
+								GParamSpec *param,
+								GstPlay* play)
 {
-	gint secs;
+	GstPlaySignal *signal;
 	
-	g_return_val_if_fail(GST_IS_PLAY(play), FALSE);
+	signal = g_new0(GstPlaySignal, 1);
+	signal->signal_id = INFORMATION;
+	signal->signal_data.info.element = orig;
+	signal->signal_data.info.param = param;
 	
-	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);
-	if (secs != play->time_seconds){
-		play->time_seconds = secs;
-		g_signal_emit (G_OBJECT (play), gst_play_signals [TIME_TICK], 0, play->time_nanos);
-	}
-
-	return (gst_element_get_state(play->pipeline) == GST_STATE_PLAYING);
+	g_async_queue_push(play->signal_queue, signal);
+	
+	play->idle_add_func ((GSourceFunc) gst_play_idle_signal, play);
 }
 
-static gboolean
-gst_play_idle_callback (GstPlay *play)
+static void
+callback_pipeline_state_change (	GstElement *element,
+									GstElementState old,
+									GstElementState state,
+									GstPlay* play)
 {
-	g_return_val_if_fail(GST_IS_PLAY(play), FALSE);
-	
-	return gst_bin_iterate (GST_BIN (play->pipeline));
+	GstPlaySignal *signal;
+
+	g_return_if_fail (GST_IS_ELEMENT (element));
+	g_return_if_fail (GST_IS_PLAY (play));
+	g_return_if_fail (element == play->pipeline);
+
+	/*g_print ("got state change %s to %s\n", gst_element_state_get_name (old), gst_element_state_get_name (state));*/
+
+	/* do additional stuff depending on state */
+	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);
+			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); 
+			}
+			break;
+		default:
+			break;
+		}
+	}	
+	signal = g_new0(GstPlaySignal, 1);
+	signal->signal_id = STATE_CHANGE;
+	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);
 }
 
+/* split static pipeline functions to a seperate file */
+#include "playpipelines.c"
+
+/* =========================================== */
+/*                                             */
+/*              Init & Class init              */
+/*                                             */
+/* =========================================== */
+
 static void
-gst_play_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec)
+gst_play_dispose (GObject *object)
 {
 	GstPlay *play = GST_PLAY (object);
 
-	g_return_if_fail (GST_IS_PLAY (play));
-	
-	switch (prop_id) {
-	case ARG_LOCATION:
-		gst_play_set_location(play, g_value_get_string (value));
-		break;
-	case ARG_VOLUME:
-		gst_play_set_volume(play, g_value_get_float (value));
-		break;
-	case ARG_MUTE:
-		gst_play_set_mute(play, g_value_get_boolean (value));
-		break;
-	default:
-		G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
-		break;
-	}
+	/* Removing all sources */
+	while (g_source_remove_by_user_data (play));
+		
+	G_OBJECT_CLASS (parent_class)->dispose (object);
+	g_mutex_free(play->audio_bin_mutex);
+	g_mutex_free(play->video_bin_mutex);
 }
 
 static void
-gst_play_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec)
+gst_play_class_init (GstPlayClass *klass)
 {
-	GstPlay *play = GST_PLAY (object);
+	GObjectClass *gobject_class = G_OBJECT_CLASS (klass);
+  
+	parent_class = g_type_class_ref(GST_TYPE_OBJECT);
 
-	g_return_if_fail (GST_IS_PLAY (play));
+	klass->information = NULL;
+	klass->state_changed = NULL;
+	klass->stream_end = NULL;
+  
+	gobject_class->dispose = gst_play_dispose;
+	gobject_class->set_property = GST_DEBUG_FUNCPTR (gst_play_set_property);
+	gobject_class->get_property = GST_DEBUG_FUNCPTR (gst_play_get_property);
 
-	switch (prop_id) {
-	case ARG_LOCATION:
-		g_value_set_string (value, gst_play_get_location(play));
-		break;
-	case ARG_VOLUME:
-		g_value_set_float(value, gst_play_get_volume(play));
-		break;
-	case ARG_MUTE:
-		g_value_set_boolean (value, gst_play_get_mute(play));
-		break;
-	default:
-		G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
-		break;
-	}
+	g_object_class_install_property (
+			gobject_class,
+			ARG_LOCATION,
+			g_param_spec_string (
+						"location",
+						"location of file", 
+						"location of the file to play",
+						NULL, G_PARAM_READWRITE));
+	
+	g_object_class_install_property (
+			gobject_class,
+			ARG_VOLUME,
+			g_param_spec_float (
+						"volume",
+						"Playing volume", 
+			            "Playing volume", 
+						0, 1.0, 0, G_PARAM_READWRITE));
+						
+	g_object_class_install_property (
+			gobject_class,
+			ARG_MUTE,
+			g_param_spec_boolean (
+						"mute",
+						"Volume muted",
+						"Playing volume muted",
+						FALSE, G_PARAM_READWRITE));
+  
+	gst_play_signals [INFORMATION] = 
+		g_signal_new ("information", 
+			      G_TYPE_FROM_CLASS (klass), 
+			      G_SIGNAL_RUN_FIRST,
+			      G_STRUCT_OFFSET (GstPlayClass, information), 
+			      NULL, NULL,
+			      gst_marshal_VOID__OBJECT_PARAM, 
+			      G_TYPE_NONE, 2, 
+			      G_TYPE_OBJECT, G_TYPE_PARAM);
+	
+	gst_play_signals [STATE_CHANGE] = 
+		g_signal_new ("state_change", 
+			      G_TYPE_FROM_CLASS (klass), 
+			      G_SIGNAL_RUN_FIRST,
+			      G_STRUCT_OFFSET (GstPlayClass, state_changed), 
+			      NULL, NULL,
+			      gst_marshal_VOID__INT_INT,
+			      G_TYPE_NONE, 2, 
+			      G_TYPE_INT, G_TYPE_INT);
+	
+	gst_play_signals [STREAM_END] =
+		g_signal_new ("stream_end",
+			      G_TYPE_FROM_CLASS (klass),
+			      G_SIGNAL_RUN_FIRST,
+			      G_STRUCT_OFFSET (GstPlayClass, stream_end),
+			      NULL, NULL,
+			      gst_marshal_VOID__VOID,
+			      G_TYPE_NONE, 0);
+
+	gst_play_signals [TIME_TICK] = 
+		g_signal_new ("time_tick", 
+			      G_TYPE_FROM_CLASS (klass), 
+			      G_SIGNAL_RUN_FIRST,
+			      G_STRUCT_OFFSET (GstPlayClass, time_tick), 
+			      NULL, NULL,
+			      gst_marshal_VOID__INT64,
+			      G_TYPE_NONE, 1, 
+			      G_TYPE_INT64);
+
+	gst_play_signals [STREAM_LENGTH] = 
+		g_signal_new ("stream_length", 
+			      G_TYPE_FROM_CLASS (klass), 
+			      G_SIGNAL_RUN_FIRST,
+			      G_STRUCT_OFFSET (GstPlayClass, stream_length), 
+			      NULL, NULL,
+			      gst_marshal_VOID__INT64,
+			      G_TYPE_NONE, 1, 
+			      G_TYPE_INT64);
+
+	gst_play_signals [HAVE_XID] = 
+		g_signal_new ("have_xid", 
+			      G_TYPE_FROM_CLASS (klass), 
+			      G_SIGNAL_RUN_FIRST,
+			      G_STRUCT_OFFSET (GstPlayClass, have_xid), 
+			      NULL, NULL,
+			      gst_marshal_VOID__INT,
+			      G_TYPE_NONE, 1, 
+			      G_TYPE_INT);
+				  
+	gst_play_signals [HAVE_VIS_XID] = 
+		g_signal_new ("have_vis_xid", 
+			      G_TYPE_FROM_CLASS (klass), 
+			      G_SIGNAL_RUN_FIRST,
+			      G_STRUCT_OFFSET (GstPlayClass, have_vis_xid), 
+			      NULL, NULL,
+			      gst_marshal_VOID__INT,
+			      G_TYPE_NONE, 1, 
+			      G_TYPE_INT);
+
+	gst_play_signals [HAVE_VIDEO_SIZE] = 
+		g_signal_new ("have_video_size", 
+			      G_TYPE_FROM_CLASS (klass), 
+			      G_SIGNAL_RUN_FIRST,
+			      G_STRUCT_OFFSET (GstPlayClass, have_video_size), 
+			      NULL, NULL,
+			      gst_marshal_VOID__INT_INT,
+			      G_TYPE_NONE, 2, 
+			      G_TYPE_INT, G_TYPE_INT);
+
+	gst_control_init(NULL,NULL);
 }
 
+
+
+static void 
+gst_play_init (GstPlay *play) 
+{
+	play->pipeline				= NULL;
+	play->source				= NULL;
+	play->autoplugger			= NULL;
+	play->audio_sink			= NULL;
+	play->audio_sink_element	= NULL;
+	play->video_sink			= NULL;
+	play->video_sink_element	= NULL;
+	play->volume				= NULL;
+	play->other_elements		= g_hash_table_new(g_str_hash, g_str_equal);
+	play->audio_bin_mutex		= g_mutex_new();
+	play->video_bin_mutex		= g_mutex_new();
+	
+	gst_play_set_idle_timeout_funcs(	play,
+										gst_play_default_timeout_add,
+										gst_play_default_idle_add);
+}
+
+/* ============================================================= */
+/*                                                               */
+/*                       Public Methods                          */
+/*                                                               */
+/* ============================================================= */
+
+/* =========================================== */
+/*                                             */
+/*                   Toolbox                   */
+/*                                             */
+/* =========================================== */
+
+/**
+ * gst_play_seek_to_time:
+ * @play: a #GstPlay.
+ * @time_nanos: a #gint64 indicating a time position.
+ *
+ * Performs a seek on @play until @time_nanos.
+ */
 void
-gst_play_seek_to_time (GstPlay *play, gint64 time_nanos)
+gst_play_seek_to_time (	GstPlay *play,
+						gint64 time_nanos)
 {
 	GstEvent *s_event;
         guint8   prev_state;
 	gboolean audio_seek_worked = FALSE;
 	gboolean video_seek_worked = FALSE;
+	gboolean visualisation_seek_worked = FALSE;
 
 	g_return_if_fail (GST_IS_PLAY (play));
 	if (time_nanos < 0LL){
@@ -701,11 +709,18 @@ gst_play_seek_to_time (GstPlay *play, gint64 time_nanos)
 	                              GST_SEEK_FLAG_FLUSH, play->seek_time);
 	if (play->audio_sink_element != NULL){
 		gst_event_ref (s_event);
-		audio_seek_worked = gst_element_send_event (play->audio_sink_element, s_event);
+		audio_seek_worked = gst_element_send_event (
+										play->audio_sink_element, s_event);
+	}
+	if (play->visualisation_sink_element != NULL){
+		gst_event_ref (s_event);
+		visualisation_seek_worked = gst_element_send_event (
+										play->visualisation_sink_element, s_event);
 	}
 	if (play->video_sink_element != NULL){
 		gst_event_ref (s_event);
-		video_seek_worked = gst_element_send_event (play->video_sink_element, s_event);
+		video_seek_worked = gst_element_send_event (
+										play->video_sink_element, s_event);
 	}
 	gst_event_unref (s_event);
 
@@ -716,61 +731,56 @@ gst_play_seek_to_time (GstPlay *play, gint64 time_nanos)
 	gst_element_set_state(play->pipeline, prev_state);
 }
 
+/**
+ * gst_play_need_new_video_window:
+ * @play: a #GstPlay.
+ *
+ * Request a new video window for @play.
+ */
 void
-gst_play_need_new_video_window(GstPlay *play)
+gst_play_need_new_video_window (GstPlay *play)
 {
+	g_return_if_fail (play != NULL);
 	g_return_if_fail (GST_IS_PLAY (play));
 	if (GST_IS_ELEMENT(play->video_sink_element)){
-		g_object_set(G_OBJECT(play->video_sink_element), "need_new_window", TRUE, NULL);
+		g_object_set(	G_OBJECT(play->video_sink_element),
+						"need_new_window", TRUE, NULL);
 	}
-}
-
-static gboolean
-gst_play_default_idle (GstPlayIdleData *idle_data)
-{
-	if(idle_data->func(idle_data->data)){
-		/* call this function again in the future */
-		return TRUE;
+	if (GST_IS_ELEMENT(play->visualisation_sink_element)){
+		g_object_set(	G_OBJECT(play->visualisation_sink_element),
+						"need_new_window", TRUE, NULL);
 	}
-	/* this function should no longer be called */
-	g_free(idle_data);
-	return FALSE;
-}
-
-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;
-
-	return g_timeout_add (interval, (GSourceFunc)gst_play_default_idle, idle_data);
-}
-
-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;
-	
-	return g_idle_add ((GSourceFunc)gst_play_default_idle, idle_data);
 }
 
 void
-gst_play_set_idle_timeout_funcs (GstPlay *play, GstPlayTimeoutAdd timeout_add_func, GstPlayIdleAdd idle_add_func)
+gst_play_set_idle_timeout_funcs (	GstPlay *play,
+									GstPlayTimeoutAdd timeout_add_func,
+									GstPlayIdleAdd idle_add_func)
 {
 	g_return_if_fail (GST_IS_PLAY (play));
 	play->timeout_add_func = timeout_add_func;
 	play->idle_add_func = idle_add_func;
 }
 
+/**
+ * gst_play_get_sink_element:
+ * @play: a #GstPlay.
+ * @element: a #GstElement.
+ * @sink_type: a #GstPlaySinkType.
+ *
+ * Searches recursively for a sink #GstElement with
+ * type @sink_type in @element which is supposed to be a #GstBin.
+ *
+ * Returns: the sink #GstElement of @element.
+ */
 GstElement*
-gst_play_get_sink_element (GstPlay *play, GstElement *element){
-	GstPad *pad = NULL;
+gst_play_get_sink_element (	GstPlay *play,
+							GstElement *element,
+							GstPlaySinkType sink_type)
+{
 	GList *elements = NULL;
 	const GList *pads = NULL;
-	gboolean has_src;
+	gboolean has_src, has_correct_type;
 
 	g_return_val_if_fail (GST_IS_PLAY (play), NULL);
 	g_return_val_if_fail (GST_IS_ELEMENT (element), NULL);
@@ -780,23 +790,75 @@ gst_play_get_sink_element (GstPlay *play, GstElement *element){
 		 * element is a sink element */		
 		return element;
 	}
-
+	
 	elements = (GList *) gst_bin_get_list (GST_BIN(element));
+	
 	/* traverse all elements looking for a src pad */
-	while (elements && pad == NULL) {	
+	
+	while (elements) {
+		
 		element = GST_ELEMENT (elements->data);
-		pads = gst_element_get_pad_list (element);
-		has_src = FALSE;
-		while (pads) {
-			/* check for src pad */
-			if (GST_PAD_DIRECTION (GST_PAD (pads->data)) == GST_PAD_SRC) {
-				has_src = TRUE;
-				break;
+		
+		/* Recursivity :) */
+		
+		if (GST_IS_BIN(element)) {
+			element = gst_play_get_sink_element(play,element,sink_type);
+			if (GST_IS_ELEMENT (element)) {
+				return element;
 			}
-			pads = g_list_next (pads);
 		}
-		if (!has_src){
-			return element;
+		else {
+		
+			pads = gst_element_get_pad_list (element);
+			has_src = FALSE;
+			has_correct_type = FALSE;
+			while (pads) {
+				/* check for src pad */
+				if (GST_PAD_DIRECTION (GST_PAD (pads->data)) == GST_PAD_SRC) {
+					has_src = TRUE;
+					break;
+				}
+				else {
+					/* If not a src pad checking caps */
+					GstCaps *caps;
+					caps = gst_pad_get_caps (GST_PAD (pads->data));
+					while (caps) {
+						gboolean has_video_cap = FALSE, has_audio_cap = FALSE;
+						if (g_ascii_strcasecmp(	gst_caps_get_mime (caps),
+														"audio/raw") == 0)
+						{
+							has_audio_cap = TRUE;
+						}
+						if (g_ascii_strcasecmp(	gst_caps_get_mime (caps),
+														"video/raw") == 0)
+						{
+							has_video_cap = TRUE;
+						}
+					
+						switch (sink_type) {
+							case GST_PLAY_SINK_TYPE_AUDIO:
+								if (has_audio_cap)
+									has_correct_type = TRUE;
+								break;;
+							case GST_PLAY_SINK_TYPE_VIDEO:
+								if (has_video_cap)
+									has_correct_type = TRUE;
+								break;;
+							case GST_PLAY_SINK_TYPE_ANY:
+								if ( (has_video_cap) || (has_audio_cap) )
+									has_correct_type = TRUE;
+								break;;
+							default:
+								has_correct_type = FALSE;
+						}
+						caps = caps->next;
+					}
+				}
+				pads = g_list_next (pads);
+			}
+			if ( (!has_src) && (has_correct_type) ){
+				return element;
+			}
 		}
 		elements = g_list_next (elements);
 	}
@@ -804,62 +866,24 @@ gst_play_get_sink_element (GstPlay *play, GstElement *element){
 	return NULL;
 }
 
-gboolean
-gst_play_set_data_src (GstPlay *play, GstElement *data_src)
-{
-	g_return_val_if_fail (GST_IS_PLAY (play), FALSE);
-	g_return_val_if_fail (GST_IS_ELEMENT (data_src), FALSE);
-
-	if (gst_play_get_state (play) != GST_STATE_READY){
-		gst_play_set_state (play, GST_STATE_READY);
-	}
-
-	if (play->set_data_src){
-		return play->set_data_src(play, data_src);
-	}
-
-	/* if there is no set_data_src func, fail quietly */
-	return FALSE;
-}
-
-gboolean
-gst_play_set_video_sink (GstPlay *play, GstElement *video_sink)
-{
-	g_return_val_if_fail (GST_IS_PLAY (play), FALSE);
-	g_return_val_if_fail (GST_IS_ELEMENT (video_sink), FALSE);
-
-	if (gst_play_get_state (play) != GST_STATE_READY){
-		gst_play_set_state (play, GST_STATE_READY);
-	}
-
-	if (play->set_video_sink){
-		return play->set_video_sink(play, video_sink);
-	}
-
-	/* if there is no set_video_sink func, fail quietly */
-	return FALSE;
-}
-
-gboolean
-gst_play_set_audio_sink (GstPlay *play, GstElement *audio_sink)
-{
-	g_return_val_if_fail (GST_IS_PLAY (play), FALSE);
-	g_return_val_if_fail (GST_IS_ELEMENT (audio_sink), FALSE);
-
-	if (gst_play_get_state (play) != GST_STATE_READY){
-		gst_play_set_state (play, GST_STATE_READY);
-	}
-
-	if (play->set_audio_sink){
-		return play->set_audio_sink(play, audio_sink);
-	}
-
-	/* if there is no set_audio_sink func, fail quietly */
-	return FALSE;
-}
+/* =========================================== */
+/*                                             */
+/*      State, Mute, Volume, Location          */
+/*                                             */
+/* =========================================== */
 
+/**
+ * gst_play_set_state:
+ * @play: a #GstPlay.
+ * @state: a #GstElementState.
+ *
+ * Set state of @play 's pipeline to @state.
+ *
+ * Returns: a #GstElementStateReturn indicating if the operation succeeded.
+ */
 GstElementStateReturn
-gst_play_set_state (GstPlay *play, GstElementState state)
+gst_play_set_state (	GstPlay *play,
+						GstElementState state)
 {
 	g_return_val_if_fail (GST_IS_PLAY (play), GST_STATE_FAILURE);
 	g_return_val_if_fail (GST_IS_ELEMENT(play->pipeline), GST_STATE_FAILURE);
@@ -868,6 +892,14 @@ gst_play_set_state (GstPlay *play, GstElementState state)
 	return gst_element_set_state(play->pipeline, state);
 }
 
+/**
+ * gst_play_get_state:
+ * @play: a #GstPlay.
+ *
+ * Get state of @play 's pipeline.
+ *
+ * Returns: a #GstElementState indicating @play 's pipeline current state.
+ */
 GstElementState
 gst_play_get_state (GstPlay *play)
 {
@@ -877,8 +909,18 @@ gst_play_get_state (GstPlay *play)
 	return gst_element_get_state(play->pipeline);
 }
 
+/**
+ * gst_play_set_location:
+ * @play: a #GstPlay.
+ * @location: a const #gchar indicating location to play
+ *
+ * Set location of @play to @location.
+ *
+ * Returns: TRUE if location was set successfully.
+ */
 gboolean
-gst_play_set_location (GstPlay *play, const gchar *location)
+gst_play_set_location (	GstPlay *play,
+						const gchar *location)
 {
 	GstElementState current_state;
 	g_return_val_if_fail (GST_IS_PLAY (play), FALSE);
@@ -910,6 +952,14 @@ gst_play_set_location (GstPlay *play, const gchar *location)
 	return TRUE;
 }
 
+/**
+ * gst_play_get_location:
+ * @play: a #GstPlay.
+ *
+ * Get current location of @play.
+ *
+ * Returns: a #gchar pointer to current location.
+ */
 gchar*
 gst_play_get_location (GstPlay *play)
 {
@@ -920,15 +970,30 @@ gst_play_get_location (GstPlay *play)
 	return location;
 }
 
-
+/**
+ * gst_play_set_volume:
+ * @play: a #GstPlay.
+ * @volume: a #gfloat indicating volume level.
+ *
+ * Set current volume of @play.
+ */
 void
-gst_play_set_volume (GstPlay *play, gfloat volume)
+gst_play_set_volume (	GstPlay *play,
+						gfloat volume)
 {
 	g_return_if_fail (GST_IS_PLAY (play));
 
 	g_object_set(G_OBJECT(play->vol_dparam), "value_float", volume, NULL);
 }
 
+/**
+ * gst_play_get_volume:
+ * @play: a #GstPlay.
+ *
+ * Get current volume of @play.
+ *
+ * Returns: a #gfloat indicating current volume level.
+ */
 gfloat
 gst_play_get_volume (GstPlay *play)
 {
@@ -941,14 +1006,30 @@ gst_play_get_volume (GstPlay *play)
 	return volume;
 }
 
+/**
+ * gst_play_set_mute:
+ * @play: a #GstPlay.
+ * @mute: a #gboolean indicating wether audio is muted or not.
+ *
+ * Mutes/Unmutes audio playback of @play.
+ */
 void
-gst_play_set_mute (GstPlay *play, gboolean mute)
+gst_play_set_mute (	GstPlay *play,
+					gboolean mute)
 {
 	g_return_if_fail (GST_IS_PLAY (play));
 
 	g_object_set (G_OBJECT (play->volume), "mute", mute, NULL);
 }
-	
+
+/**
+ * gst_play_get_mute:
+ * @play: a #GstPlay.
+ *
+ * Get current muted status of @play.
+ *
+ * Returns: a #gboolean indicating if audio is muted or not.
+ */
 gboolean
 gst_play_get_mute (GstPlay *play)
 {
@@ -961,6 +1042,237 @@ gst_play_get_mute (GstPlay *play)
 	return mute;
 }
 
-/* modelines */
-/* vim:set ts=8:sw=8:noet */
+/* =========================================== */
+/*                                             */
+/*    Audio sink, Video sink, Data src         */
+/*                                             */
+/* =========================================== */
+
+/**
+ * gst_play_set_data_src:
+ * @play: a #GstPlay.
+ * @data_src: a #GstElement.
+ *
+ * Set @data_src as the source element of @play.
+ *
+ * Returns: TRUE if call succeeded.
+ */
+gboolean
+gst_play_set_data_src (	GstPlay *play,
+						GstElement *data_src)
+{
+	g_return_val_if_fail (GST_IS_PLAY (play), FALSE);
+	g_return_val_if_fail (GST_IS_ELEMENT (data_src), FALSE);
+
+	if (gst_play_get_state (play) != GST_STATE_READY){
+		gst_play_set_state (play, GST_STATE_READY);
+	}
+
+	if (play->set_data_src){
+		return play->set_data_src(play, data_src);
+	}
+
+	/* if there is no set_data_src func, fail quietly */
+	return FALSE;
+}
+
+/**
+ * gst_play_set_video_sink:
+ * @play: a #GstPlay.
+ * @video_sink: a #GstElement.
+ *
+ * Set @video_sink as the video sink element of @play.
+ *
+ * Returns: TRUE if call succeeded.
+ */
+gboolean
+gst_play_set_video_sink (	GstPlay *play,
+							GstElement *video_sink)
+{
+	g_return_val_if_fail (GST_IS_PLAY (play), FALSE);
+	g_return_val_if_fail (GST_IS_ELEMENT (video_sink), FALSE);
+
+	if (gst_play_get_state (play) != GST_STATE_READY){
+		gst_play_set_state (play, GST_STATE_READY);
+	}
+
+	if (play->set_video_sink){
+		return play->set_video_sink(play, video_sink);
+	}
+
+	/* if there is no set_video_sink func, fail quietly */
+	return FALSE;
+}
+
+/**
+ * gst_play_set_audio_sink:
+ * @play: a #GstPlay.
+ * @audio_sink: a #GstElement.
+ *
+ * Set @audio_sink as the audio sink element of @play.
+ *
+ * Returns: TRUE if call succeeded.
+ */
+gboolean
+gst_play_set_audio_sink (	GstPlay *play,
+							GstElement *audio_sink)
+{
+	g_return_val_if_fail (GST_IS_PLAY (play), FALSE);
+	g_return_val_if_fail (GST_IS_ELEMENT (audio_sink), FALSE);
+
+	if (gst_play_get_state (play) != GST_STATE_READY){
+		gst_play_set_state (play, GST_STATE_READY);
+	}
+
+	if (play->set_audio_sink){
+		return play->set_audio_sink(play, audio_sink);
+	}
+
+	/* if there is no set_audio_sink func, fail quietly */
+	return FALSE;
+}
+
+/* =========================================== */
+/*                                             */
+/*          Object typing & Creation           */
+/*                                             */
+/* =========================================== */
+
+GType
+gst_play_get_type (void)
+{
+	static GType play_type = 0;
+	
+	if (!play_type)
+	{
+		static const GTypeInfo play_info = {
+			sizeof (GstPlayClass),
+			(GBaseInitFunc) NULL,
+			(GBaseFinalizeFunc) NULL,
+			(GClassInitFunc) gst_play_class_init,
+			NULL, NULL, sizeof (GstPlay),
+			0, (GInstanceInitFunc) gst_play_init,
+			NULL
+		};
+      
+		play_type = g_type_register_static (G_TYPE_OBJECT, "GstPlay", &play_info, 0);
+	}
+
+	return play_type;
+}
+
+
+GstPlay *
+gst_play_new (	GstPlayPipeType pipe_type,
+				GError **error)
+{
+	GstPlay *play;
+
+	play = g_object_new (GST_TYPE_PLAY, NULL);
+
+	/* FIXME: looks like only VIDEO ever gets used ! */
+	switch (pipe_type){
+		case GST_PLAY_PIPE_VIDEO:
+			play->setup_pipeline = gst_play_video_setup;
+			play->teardown_pipeline = NULL;
+			play->set_data_src = gst_play_video_set_data_src;
+			play->set_autoplugger = gst_play_video_set_auto;
+			play->set_video_sink = gst_play_video_set_video;
+			play->set_audio_sink = gst_play_video_set_audio;
+			break;
+		case GST_PLAY_PIPE_VIDEO_VISUALISATION:
+			play->setup_pipeline = gst_play_video_vis_setup;
+			play->teardown_pipeline = NULL;
+			play->set_data_src = gst_play_video_set_data_src;
+			play->set_autoplugger = gst_play_video_set_auto;
+			play->set_video_sink = gst_play_video_vis_set_video;
+			play->set_audio_sink = gst_play_video_vis_set_audio;
+			break;
+		case GST_PLAY_PIPE_AUDIO:
+			/* we can reuse the threaded set functions */
+			play->setup_pipeline = gst_play_audio_setup;
+			play->teardown_pipeline = NULL;
+			play->set_data_src = gst_play_simple_set_data_src;
+			play->set_autoplugger = gst_play_audiot_set_auto;
+			play->set_video_sink = NULL;
+			play->set_audio_sink = gst_play_audiot_set_audio;
+			break;
+		case GST_PLAY_PIPE_AUDIO_THREADED:
+			play->setup_pipeline = gst_play_audiot_setup;
+			play->teardown_pipeline = NULL;
+			play->set_data_src = gst_play_simple_set_data_src;
+			play->set_autoplugger = gst_play_audiot_set_auto;
+			play->set_video_sink = NULL;
+			play->set_audio_sink = gst_play_audiot_set_audio;
+			break;
+		case GST_PLAY_PIPE_AUDIO_HYPER_THREADED:
+			play->setup_pipeline = gst_play_audioht_setup;
+			play->teardown_pipeline = NULL;
+			play->set_data_src = gst_play_simple_set_data_src;
+			play->set_autoplugger = gst_play_audioht_set_auto;
+			play->set_video_sink = NULL;
+			play->set_audio_sink = gst_play_audioht_set_audio;
+			break;
+		default:
+			g_warning("unknown pipeline type: %d\n", pipe_type);
+	}
+
+	/* init pipeline */
+	if ((play->setup_pipeline) &&
+	    (! play->setup_pipeline (play, error)))
+	{
+		g_object_unref (play);
+		return NULL;
+	}
+
+
+	if (play->pipeline) {
+		/* connect to pipeline events */
+		g_signal_connect (	G_OBJECT (play->pipeline),
+							"deep_notify",
+							G_CALLBACK (callback_pipeline_deep_notify),
+							play);
+		g_signal_connect (	G_OBJECT (play->pipeline),
+							"state_change",
+							G_CALLBACK (callback_pipeline_state_change),
+							play);
+		g_signal_connect (	G_OBJECT (play->pipeline),
+							"error",
+							G_CALLBACK (callback_pipeline_error),
+							play);
+	}
+
+	if (play->volume) {
+		play->vol_dpman =  gst_dpman_get_manager(play->volume);
+		play->vol_dparam = gst_dpsmooth_new(G_TYPE_FLOAT);
+  
+		g_object_set(	G_OBJECT(play->vol_dparam),
+						"update_period", 2000000LL, NULL);
+  
+		g_object_set(	G_OBJECT(play->vol_dparam),
+						"slope_delta_float", 0.1F, NULL);
+		g_object_set(	G_OBJECT(play->vol_dparam),
+						"slope_time", 10000000LL, NULL); 
+ 
+		if (!gst_dpman_attach_dparam (	play->vol_dpman,
+										"volume",
+										play->vol_dparam))
+			g_warning("could not attach dparam to volume element\n");
+		
+		gst_dpman_set_mode(play->vol_dpman, "asynchronous");
+		gst_play_set_volume(play, 0.9);
+	}
+	
+	play->signal_queue = g_async_queue_new();
+
+	return play;
+}
+
+
+
+
+
+
+
+
 
diff --git a/gst-libs/gst/play/play.old.h b/gst-libs/gst/play/play.old.h
index acf777c93..90f9a5ce7 100644
--- a/gst-libs/gst/play/play.old.h
+++ b/gst-libs/gst/play/play.old.h
@@ -2,6 +2,7 @@
  * Copyright (C) 1999,2000,2001,2002 Erik Walthinsen <omega@cse.ogi.edu>
  *                    2000,2001,2002 Wim Taymans <wtay@chello.be>
  *                              2002 Steve Baker <steve@stevebaker.org>
+ *								2003 Julien Moutte <julien@moutte.net>
  *
  * play.h: GstPlay object code
  *
@@ -51,6 +52,7 @@ typedef enum {
 	GST_PLAY_PIPE_AUDIO_THREADED,
 	GST_PLAY_PIPE_AUDIO_HYPER_THREADED,
 	GST_PLAY_PIPE_VIDEO,
+	GST_PLAY_PIPE_VIDEO_VISUALISATION,
 } GstPlayPipeType;
 
 typedef enum {
@@ -63,6 +65,12 @@ typedef enum {
 	GST_PLAY_ERROR_LAST,
 } GstPlayError;
 
+typedef enum {
+	GST_PLAY_SINK_TYPE_AUDIO,
+	GST_PLAY_SINK_TYPE_VIDEO,
+	GST_PLAY_SINK_TYPE_ANY,
+} GstPlaySinkType;
+
 #define GST_PLAY_ERROR 		gst_play_error_quark ()
 
 #define GST_TYPE_PLAY            (gst_play_get_type())
@@ -76,7 +84,9 @@ typedef struct _GstPlay          GstPlay;
 typedef struct _GstPlayClass     GstPlayClass;
 typedef struct _GstPlayIdleData  GstPlayIdleData;
 
-typedef guint (*GstPlayTimeoutAdd) (guint interval, GSourceFunc function, gpointer data);
+typedef guint (*GstPlayTimeoutAdd) (	guint interval,
+										GSourceFunc function,
+										gpointer data);
 typedef guint (*GstPlayIdleAdd)    (GSourceFunc function, gpointer data);
 
 struct _GstPlay
@@ -99,6 +109,7 @@ struct _GstPlay
 	GstElement *video_sink_element;
 	GstElement *audio_sink;
 	GstElement *audio_sink_element;
+	GstElement *visualisation_sink_element;
 
 	GstDParamManager *vol_dpman;
 	GstDParam *vol_dparam;
@@ -117,10 +128,6 @@ struct _GstPlay
  	gint64 time_nanos;
  	gint64 length_nanos;
 	
-	guint tick_timeout_id;
-	guint idle_timeout_id;
-	guint idle_signal_id;
-
 	GAsyncQueue *signal_queue;
 
 	GstPlayTimeoutAdd timeout_add_func;
@@ -132,13 +139,24 @@ struct _GstPlayClass
 	GObjectClass parent_class;
 	
 	/* signals */
-	void (*information)    (GstPlay* play, GstElement* element, GParamSpec *param);
-	void (*state_changed)  (GstPlay* play, GstElementState old_state, GstElementState new_state);
-	void (*stream_end)     (GstPlay* play);
-	void (*time_tick)    (GstPlay* play, gint64 time_nanos);
-	void (*stream_length)  (GstPlay* play, gint64 length_nanos);
-	void (*have_xid)  (GstPlay* play, gint xid);
-	void (*have_video_size)  (GstPlay* play, gint width, gint height);
+	void (*information)		(	GstPlay* play,
+								GstElement* element,
+								GParamSpec *param);
+	void (*state_changed)	(	GstPlay* play,
+								GstElementState old_state,
+								GstElementState new_state);
+	void (*stream_end)		(	GstPlay* play);
+	void (*time_tick)		(	GstPlay* play,
+								gint64 time_nanos);
+	void (*stream_length)	(	GstPlay* play,
+								gint64 length_nanos);
+	void (*have_xid)	  	(	GstPlay* play,
+								gint xid);
+	void (*have_vis_xid)	 (	GstPlay* play,
+								gint xid);
+	void (*have_video_size)	(	GstPlay* play,
+								gint width,
+								gint height);
 };
 
 struct _GstPlayIdleData
@@ -147,35 +165,83 @@ struct _GstPlayIdleData
 	gpointer data;
 };
 
-GType	  gst_play_get_type	   (void);
-
-GstPlay*  gst_play_new		   (GstPlayPipeType pipe_type, GError **error);
-
-void      gst_play_seek_to_time (GstPlay *play, gint64 time_nanos);
-
-GstElement*       gst_play_get_sink_element (GstPlay *play, GstElement *element);
-
-gboolean	  gst_play_set_data_src (GstPlay *play, GstElement *data_src);
-gboolean	  gst_play_set_video_sink  (GstPlay *play, GstElement *element);
-gboolean	  gst_play_set_audio_sink  (GstPlay *play, GstElement *element);
-void		  gst_play_need_new_video_window  (GstPlay *play);
 
-GstElementStateReturn gst_play_set_state       (GstPlay *play, GstElementState state);
-GstElementState gst_play_get_state (GstPlay *play);
-
-gboolean  gst_play_set_location    (GstPlay *play, const gchar *location);
-gchar*    gst_play_get_location    (GstPlay *play);
-
-void      gst_play_set_volume      (GstPlay *play, gfloat volume);
-gfloat     gst_play_get_volume      (GstPlay *play);
-
-void      gst_play_set_mute        (GstPlay *play, gboolean mute);
-gboolean  gst_play_get_mute        (GstPlay *play);
-
-void      gst_play_set_idle_timeout_funcs (GstPlay *play, GstPlayTimeoutAdd timeout_add_func, GstPlayIdleAdd idle_add_func);
+void
+gst_play_seek_to_time (	GstPlay *play,
+						gint64 time_nanos);
+
+void
+gst_play_need_new_video_window (GstPlay *play);
+
+void
+gst_play_set_idle_timeout_funcs (	GstPlay *play,
+									GstPlayTimeoutAdd timeout_add_func,
+									GstPlayIdleAdd idle_add_func);
+GstElement*
+gst_play_get_sink_element (	GstPlay *play,
+							GstElement *element,
+							GstPlaySinkType sink_type);
+
+/* Set/Get state */
+
+GstElementStateReturn
+gst_play_set_state (	GstPlay *play,
+						GstElementState state);
+GstElementState
+gst_play_get_state (GstPlay *play);
+
+/* Set/Get location */
+
+gboolean
+gst_play_set_location (	GstPlay *play,
+						const gchar *location);
+gchar*
+gst_play_get_location (GstPlay *play);
+
+/* Set/Get volume */
+
+void
+gst_play_set_volume (	GstPlay *play,
+						gfloat volume);
+gfloat
+gst_play_get_volume (GstPlay *play);
+
+/* Set/Get mute */
+
+void
+gst_play_set_mute (	GstPlay *play,
+					gboolean mute);
+gboolean
+gst_play_get_mute (GstPlay *play);
+
+/* Set sinks and data src */
+
+gboolean
+gst_play_set_data_src (	GstPlay *play,
+						GstElement *data_src);
+gboolean
+gst_play_set_video_sink (	GstPlay *play,
+							GstElement *video_sink);
+gboolean
+gst_play_set_visualisation_video_sink (	GstPlay *play,
+										GstElement *video_sink);
+gboolean
+gst_play_set_audio_sink (	GstPlay *play,
+							GstElement *audio_sink);
+
+gboolean
+gst_play_set_visualisation_element (	GstPlay *play,
+										GstElement *element);
+										
+gboolean
+gst_play_connect_visualisation (	GstPlay *play,
+									gboolean connect);
+									
+GType
+gst_play_get_type (void);
+
+GstPlay *
+gst_play_new (	GstPlayPipeType pipe_type,
+				GError **error);
 
 #endif /* __GSTPLAY_H__ */
-
-/* modelines */
-/* vim:set ts=8:sw=8:noet */
-
diff --git a/gst-libs/gst/play/playpipelines.c b/gst-libs/gst/play/playpipelines.c
index 527ea43fa..163d1a2dd 100644
--- a/gst-libs/gst/play/playpipelines.c
+++ b/gst-libs/gst/play/playpipelines.c
@@ -2,6 +2,7 @@
  * Copyright (C) 1999,2000,2001,2002 Erik Walthinsen <omega@cse.ogi.edu>
  *                    2000,2001,2002 Wim Taymans <wtay@chello.be>
  *                              2002 Steve Baker <steve@stevebaker.org>
+ *								2003 Julien Moutte <julien@moutte.net>
  *
  * playpipelines.c: Set up pipelines for playback
  *
@@ -22,13 +23,16 @@
  */
 
 static gboolean
-gst_play_default_set_data_src (GstPlay *play, GstElement *datasrc, GstElement* parent)
+gst_play_default_set_data_src (	GstPlay *play,
+								GstElement *datasrc,
+								GstElement* parent)
 {
 	g_return_val_if_fail (GST_IS_PLAY (play), FALSE);
 	g_return_val_if_fail (GST_IS_ELEMENT (datasrc), FALSE);
 	
 	if (GST_IS_ELEMENT(play->source)) {
-		/* we need to remove the existing data source before creating a new one */
+		/* we need to remove the existing data
+			source before creating a new one */
 		if (GST_IS_ELEMENT(play->autoplugger)){
 			gst_element_unlink (play->autoplugger, play->source);
 		}
@@ -51,7 +55,8 @@ gst_play_default_set_data_src (GstPlay *play, GstElement *datasrc, GstElement* p
  */
 
 static gboolean 
-gst_play_audio_setup (GstPlay *play, GError **error)
+gst_play_audio_setup (	GstPlay *play,
+						GError **error)
 {
 	
 	/* creating gst_bin */
@@ -105,7 +110,8 @@ gst_play_audio_setup (GstPlay *play, GError **error)
 }
 
 static gboolean
-gst_play_simple_set_data_src (GstPlay *play, GstElement *datasrc)
+gst_play_simple_set_data_src (	GstPlay *play,
+								GstElement *datasrc)
 {
 	return gst_play_default_set_data_src(play, datasrc, play->pipeline);
 }
@@ -116,7 +122,8 @@ gst_play_simple_set_data_src (GstPlay *play, GstElement *datasrc)
  */
  
 static gboolean 
-gst_play_audiot_setup (GstPlay *play, GError **error)
+gst_play_audiot_setup (	GstPlay *play,
+						GError **error)
 {
 	
 	g_return_val_if_fail (GST_IS_PLAY(play), FALSE);
@@ -173,7 +180,8 @@ gst_play_audiot_setup (GstPlay *play, GError **error)
 
 
 static gboolean
-gst_play_audiot_set_audio (GstPlay *play, GstElement *audio_sink)
+gst_play_audiot_set_audio (	GstPlay *play,
+							GstElement *audio_sink)
 {
 	g_return_val_if_fail (GST_IS_PLAY(play), FALSE);
 	g_return_val_if_fail (GST_IS_ELEMENT (audio_sink), FALSE);
@@ -188,7 +196,15 @@ gst_play_audiot_set_audio (GstPlay *play, GstElement *audio_sink)
 	gst_bin_add (GST_BIN (play->pipeline), play->audio_sink);
 	gst_element_link (play->volume, play->audio_sink);
 
-	play->audio_sink_element = gst_play_get_sink_element (play, audio_sink);
+	play->audio_sink_element = gst_play_get_sink_element (
+										play,
+										audio_sink,
+										GST_PLAY_SINK_TYPE_AUDIO);
+	
+	play->visualisation_sink_element = gst_play_get_sink_element (
+										play,
+										audio_sink,
+										GST_PLAY_SINK_TYPE_VIDEO);
 	
 	if (play->audio_sink_element != NULL) {
 		g_signal_connect (G_OBJECT (play->audio_sink_element), "eos",
@@ -200,14 +216,16 @@ gst_play_audiot_set_audio (GstPlay *play, GstElement *audio_sink)
 
 
 static gboolean
-gst_play_audiot_set_auto (GstPlay *play, GstElement *autoplugger)
+gst_play_audiot_set_auto (	GstPlay *play,
+							GstElement *autoplugger)
 {
 
 	g_return_val_if_fail (GST_IS_PLAY (play), FALSE);
 	g_return_val_if_fail (GST_IS_ELEMENT (autoplugger), FALSE);
 	
 	if (play->autoplugger) {
-		/* we need to remove the existing autoplugger before creating a new one */
+		/* we need to remove the existing autoplugger
+			before creating a new one */
 		gst_element_unlink (play->autoplugger, play->volume);
 		gst_element_unlink (play->autoplugger, play->source);
 		gst_bin_remove (GST_BIN (play->pipeline), play->autoplugger);
@@ -228,7 +246,8 @@ gst_play_audiot_set_auto (GstPlay *play, GstElement *autoplugger)
  */
 
 static gboolean 
-gst_play_audioht_setup (GstPlay *play, GError **error)
+gst_play_audioht_setup (	GstPlay *play,
+							GError **error)
 {
 	GstElement *audio_thread, *audio_queue;
 
@@ -313,7 +332,8 @@ gst_play_audioht_setup (GstPlay *play, GError **error)
 
 
 static gboolean
-gst_play_audioht_set_audio (GstPlay *play, GstElement *audio_sink)
+gst_play_audioht_set_audio (	GstPlay *play,
+								GstElement *audio_sink)
 {
 	GstElement *audio_thread;
 	
@@ -332,7 +352,15 @@ gst_play_audioht_set_audio (GstPlay *play, GstElement *audio_sink)
 	gst_bin_add (GST_BIN (audio_thread), play->audio_sink);
 	gst_element_link (play->volume, play->audio_sink);
 
-	play->audio_sink_element = gst_play_get_sink_element (play, audio_sink);
+	play->audio_sink_element = gst_play_get_sink_element (
+												play,
+												audio_sink,
+												GST_PLAY_SINK_TYPE_AUDIO);
+	
+	play->visualisation_sink_element = gst_play_get_sink_element (
+												play,
+												audio_sink,
+												GST_PLAY_SINK_TYPE_VIDEO);
 	
 	if (play->audio_sink_element != NULL) {
 		g_signal_connect (G_OBJECT (play->audio_sink_element), "eos",
@@ -344,7 +372,8 @@ gst_play_audioht_set_audio (GstPlay *play, GstElement *audio_sink)
 
 
 static gboolean
-gst_play_audioht_set_auto (GstPlay *play, GstElement *autoplugger)
+gst_play_audioht_set_auto (	GstPlay *play,
+							GstElement *autoplugger)
 {
 	GstElement *audio_thread;
 	
@@ -354,7 +383,8 @@ gst_play_audioht_set_auto (GstPlay *play, GstElement *autoplugger)
 	audio_thread = g_hash_table_lookup(play->other_elements, "audio_thread");
 
 	if (play->autoplugger) {
-		/* we need to remove the existing autoplugger before creating a new one */
+		/* we need to remove the existing autoplugger
+			before creating a new one */
 		gst_element_unlink (play->autoplugger, audio_thread);
 		gst_element_unlink (play->autoplugger, play->source);
 		gst_bin_remove (GST_BIN (play->pipeline), play->autoplugger);
@@ -371,12 +401,13 @@ gst_play_audioht_set_auto (GstPlay *play, GstElement *autoplugger)
 
 /*
  * GST_PLAY_PIPE_VIDEO
- * { gnomevfssrc ! spider ! { queue ! volume ! osssink }
+ * { gnomevfssrc ! spider ! { queue ! volume ! (audiosink) }
  * spider0.src2 ! { queue ! colorspace ! (videosink) } }
  */
 
 static gboolean 
-gst_play_video_setup (GstPlay *play, GError **error)
+gst_play_video_setup (	GstPlay *play,
+						GError **error)
 {
 	GstElement *audio_bin, *audio_queue;
 	GstElement *video_queue, *video_bin;
@@ -523,7 +554,8 @@ gst_play_video_setup (GstPlay *play, GError **error)
 }
 
 static gboolean
-gst_play_video_set_data_src (GstPlay *play, GstElement *datasrc)
+gst_play_video_set_data_src (	GstPlay *play,
+								GstElement *datasrc)
 {
 	GstElement *work_thread;
 	g_return_val_if_fail (GST_IS_PLAY(play), FALSE);
@@ -533,11 +565,13 @@ gst_play_video_set_data_src (GstPlay *play, GstElement *datasrc)
 }
 
 static gboolean
-gst_play_video_set_auto (GstPlay *play, GstElement *autoplugger)
+gst_play_video_set_auto (	GstPlay *play,
+							GstElement *autoplugger)
 {
 
 	GstElement *audio_bin, *video_bin, *work_thread;
 
+	g_return_val_if_fail (play != NULL, FALSE);
 	g_return_val_if_fail (GST_IS_PLAY(play), FALSE);
 	g_return_val_if_fail (GST_IS_ELEMENT (autoplugger), FALSE);
 
@@ -546,7 +580,8 @@ gst_play_video_set_auto (GstPlay *play, GstElement *autoplugger)
 	work_thread = g_hash_table_lookup(play->other_elements, "work_thread");
 
 	if (play->autoplugger) {
-		/* we need to remove the existing autoplugger before creating a new one */
+		/* we need to remove the existing autoplugger
+			before creating a new one */
 		gst_element_unlink (play->autoplugger, audio_bin);
 		gst_element_unlink (play->autoplugger, play->source);
 		gst_element_unlink (play->autoplugger, video_bin);
@@ -567,7 +602,8 @@ gst_play_video_set_auto (GstPlay *play, GstElement *autoplugger)
 
 
 static gboolean
-gst_play_video_set_video (GstPlay *play, GstElement *video_sink)
+gst_play_video_set_video (	GstPlay *play,
+							GstElement *video_sink)
 {
 	GstElement *video_mate, *video_bin;
 	
@@ -585,21 +621,33 @@ gst_play_video_set_video (GstPlay *play, GstElement *video_sink)
 	gst_bin_add (GST_BIN (video_bin), play->video_sink);
 	gst_element_link (video_mate, play->video_sink);
 
-	play->video_sink_element = gst_play_get_sink_element (play, video_sink);
+	play->video_sink_element = gst_play_get_sink_element (
+											play,
+											video_sink,
+											GST_PLAY_SINK_TYPE_VIDEO);
 
 	if (play->video_sink_element != NULL) {
-		g_signal_connect (G_OBJECT (play->video_sink_element), "have_xid",
-				  G_CALLBACK (callback_video_have_xid), play);
-		g_signal_connect (G_OBJECT (play->video_sink_element), "have_size",
-				  G_CALLBACK (callback_video_have_size), play);
-		g_object_set(G_OBJECT(play->video_sink_element), "need_new_window", TRUE, "toplevel", FALSE, NULL);
+		g_signal_connect (	G_OBJECT (play->video_sink_element),
+							"have_xid",
+				  			G_CALLBACK (callback_video_have_xid),
+							play);
+		g_signal_connect (	G_OBJECT (play->video_sink_element),
+							"have_size",
+				  			G_CALLBACK (callback_video_have_size),
+							play);
+		g_object_set(	G_OBJECT(play->video_sink_element),
+						"need_new_window",
+						TRUE,
+						"toplevel",
+						FALSE, NULL);
 	}
 	return TRUE;
 }
 
 
 static gboolean
-gst_play_video_set_audio (GstPlay *play, GstElement *audio_sink)
+gst_play_video_set_audio (	GstPlay *play,
+							GstElement *audio_sink)
 {
 	GstElement *audio_bin;
 	
@@ -618,8 +666,16 @@ gst_play_video_set_audio (GstPlay *play, GstElement *audio_sink)
 	gst_bin_add (GST_BIN (audio_bin), play->audio_sink);
 	gst_element_link (play->volume, play->audio_sink);
 
-	play->audio_sink_element = gst_play_get_sink_element (play, audio_sink);
+	play->audio_sink_element = gst_play_get_sink_element (
+										play,
+										audio_sink,
+										GST_PLAY_SINK_TYPE_AUDIO);
 
+	play->visualisation_sink_element = gst_play_get_sink_element (
+										play,
+										audio_sink,
+										GST_PLAY_SINK_TYPE_VIDEO);
+	
 	if (play->audio_sink_element != NULL) {
 		g_signal_connect (G_OBJECT (play->audio_sink_element), "eos",
 				  G_CALLBACK (callback_audio_sink_eos), play);
@@ -628,5 +684,512 @@ gst_play_video_set_audio (GstPlay *play, GstElement *audio_sink)
 	return TRUE;
 }
 
+/*
+ * GST_PLAY_PIPE_VIDEO_VISUALISATION
+ * { gnomevfssrc ! spider ! { queue ! volume ! (audiosink) }
+ * spider0.src2 ! { queue ! colorspace ! (videosink) } }
+ */
+
+static gboolean 
+gst_play_video_vis_setup (	GstPlay *play,
+							GError **error)
+{
+	
+	GstElement *work_thread, *tee_element;
+	GstPad *tee_vis_pad, *tee_audio_pad, *vis_video_thread_pad;
+	GstElement *vis_audio_thread, *vis_video_thread;
+	GstElement *vis_audio_queue, *vis_video_queue;
+	GstElement *vis_colorspace, *vis_audio_sink, *vis_video_sink;
+	GstElement *video_queue, *video_bin, *colorspace;
+	
+	g_return_val_if_fail (play != NULL, FALSE);
+	g_return_val_if_fail (GST_IS_PLAY(play), FALSE);
+	
+	/* creating pipeline */	
+	play->pipeline = gst_pipeline_new ("main_pipeline");
+	g_return_val_if_fail (GST_IS_PIPELINE (play->pipeline), FALSE);
+
+	/* creating work thread */
+	work_thread = gst_thread_new ("work_thread");
+	g_return_val_if_fail (GST_IS_THREAD (work_thread), FALSE);
+	g_hash_table_insert(play->other_elements, "work_thread", work_thread);
+	
+	gst_bin_add (GST_BIN (play->pipeline), work_thread);
+
+	/* create source element */
+	play->source = gst_element_factory_make ("gnomevfssrc", "source");
+	if (!play->source)
+	{
+		gst_play_error_plugin (GST_PLAY_ERROR_GNOMEVFSSRC, error);
+		return FALSE;
+	}	
+	gst_bin_add (GST_BIN (work_thread), play->source);
+	
+	/* BEGIN VIS STUFF */
+
+	/* Creating here the audio vis bin */
+	
+	play->audio_sink = gst_element_factory_make ( "bin", "audio_bin");
+	if (!play->audio_sink)
+	{
+		gst_play_error_plugin (GST_PLAY_ERROR_THREAD, error);
+		return FALSE;
+	}
+	g_hash_table_insert(	play->other_elements,
+							"audio_bin",
+							play->audio_sink);
+		
+	play->volume = gst_element_factory_make ("volume", "audio_volume");
+	if (!play->volume)
+	{
+		gst_play_error_plugin (GST_PLAY_ERROR_VOLUME, error);
+		return FALSE;
+	}
+	g_hash_table_insert (	play->other_elements,
+							"audio_volume",
+							play->volume);
+		
+	tee_element = gst_element_factory_make ("tee", "audio_tee");
+	g_return_val_if_fail(GST_IS_ELEMENT(tee_element), FALSE);
+	g_hash_table_insert(	play->other_elements,
+							"vis_tee",
+							play->audio_sink);
+								
+	tee_vis_pad = gst_element_get_request_pad (tee_element, "src%d");
+	tee_audio_pad = gst_element_get_request_pad (tee_element, "src%d");
+	g_hash_table_insert(	play->other_elements,
+							"tee_vis_pad",
+							tee_vis_pad);
+	g_hash_table_insert(	play->other_elements,
+							"tee_audio_pad",
+							tee_audio_pad);
+	
+	gst_bin_add_many (	GST_BIN (play->audio_sink),
+						play->volume, tee_element, NULL);
+	gst_element_link_many (play->volume, tee_element, NULL);
+	gst_element_add_ghost_pad (	play->audio_sink,
+								gst_element_get_pad (play->volume, "sink"),
+								"sink");
+
+	/* Creating audio part of the visualisation bin
+		{ queue ! volume ! (audiosink) }
+	*/
+	
+	vis_audio_thread = gst_thread_new ("vis_audio_thread");
+	if (!vis_audio_thread)
+	{
+		gst_play_error_plugin (GST_PLAY_ERROR_THREAD, error);
+		return FALSE;
+	}
+	g_hash_table_insert(	play->other_elements,
+							"vis_audio_thread",
+							vis_audio_thread);
+	
+	vis_audio_queue = gst_element_factory_make ("queue", "vis_audio_queue");
+	if (!vis_audio_queue)
+	{
+		gst_play_error_plugin (GST_PLAY_ERROR_QUEUE, error);
+		return FALSE;
+	}	
+	g_hash_table_insert (	play->other_elements,
+							"vis_audio_queue",
+							vis_audio_queue);
+		
+	vis_audio_sink = gst_element_factory_make ("fakesink", "vis_audio_sink");
+	if (!vis_audio_sink)
+	{
+		gst_play_error_plugin (GST_PLAY_ERROR_FAKESINK, error);
+		return FALSE;
+	}
+	g_hash_table_insert (	play->other_elements,
+							"vis_audio_sink",
+							vis_audio_sink);
+	play->audio_sink_element = NULL;
+
+	gst_bin_add_many (	GST_BIN (vis_audio_thread), vis_audio_queue,
+						vis_audio_sink, NULL);
+	
+	gst_element_link_many (	vis_audio_queue, vis_audio_sink, NULL);
+	
+	/* setting up iterate functions */	
+	gst_bin_set_pre_iterate_function (
+		GST_BIN (vis_audio_thread), 
+		(GstBinPrePostIterateFunction) callback_bin_pre_iterate, 
+		play->audio_bin_mutex);
+	gst_bin_set_post_iterate_function (
+		GST_BIN (vis_audio_thread), 
+		(GstBinPrePostIterateFunction) callback_bin_post_iterate, 
+		play->audio_bin_mutex);
+	
+	gst_bin_add ( GST_BIN(play->audio_sink), vis_audio_thread);
+	
+	gst_pad_link (	tee_audio_pad,
+					gst_element_add_ghost_pad (
+						vis_audio_thread, 
+						gst_element_get_pad (vis_audio_queue, "sink"),
+						"sink"));
+	
+	/* Creating video part of the visualisation bin
+		{ queue ! (visualisation) ! colorspace ! (videosink) }
+	*/
+	
+	vis_video_thread = gst_thread_new ("vis_video_thread");
+	if (!vis_video_thread)
+	{
+		gst_play_error_plugin (GST_PLAY_ERROR_THREAD, error);
+		return FALSE;
+	}
+	g_hash_table_insert (	play->other_elements,
+							"vis_video_thread",
+							vis_video_thread);
+	
+	vis_video_queue = gst_element_factory_make ("queue", "vis_video_queue");
+	if (!vis_video_queue)
+	{
+		gst_play_error_plugin (GST_PLAY_ERROR_QUEUE, error);
+		return FALSE;
+	}	
+	g_hash_table_insert (	play->other_elements,
+							"vis_video_queue",
+							vis_video_queue);
+	
+	vis_colorspace = gst_element_factory_make ("colorspace", "vis_colorspace");
+	if (!vis_colorspace)
+	{
+		gst_play_error_plugin (GST_PLAY_ERROR_COLORSPACE, error);
+		return FALSE;
+	}
+	g_hash_table_insert (	play->other_elements,
+							"vis_colorspace",
+							vis_colorspace);
+	
+	vis_video_sink = gst_element_factory_make ("fakesink", "vis_video_sink");
+	if (!vis_video_sink)
+	{
+		gst_play_error_plugin (GST_PLAY_ERROR_FAKESINK, error);
+		return FALSE;
+	}
+	g_hash_table_insert (	play->other_elements,
+							"vis_video_sink",
+							vis_video_sink);
+	play->video_sink_element = NULL;
+	
+	gst_bin_add_many (	GST_BIN (vis_video_thread), vis_video_queue,
+						vis_colorspace, vis_video_sink, NULL);
+	
+	/* Not linking now as we miss too much stuff */
+
+	/* setting up iterate functions
+	gst_bin_set_pre_iterate_function (
+		GST_BIN (vis_video_thread), 
+		(GstBinPrePostIterateFunction) callback_bin_pre_iterate, 
+		play->video_bin_mutex);
+	gst_bin_set_post_iterate_function (
+		GST_BIN (vis_video_thread), 
+		(GstBinPrePostIterateFunction) callback_bin_post_iterate, 
+		play->video_bin_mutex);*/
+
+	vis_video_thread_pad = gst_element_add_ghost_pad (
+								vis_video_thread, 
+								gst_element_get_pad (vis_video_queue, "sink"),
+								"sink");
+
+	g_hash_table_insert(	play->other_elements,
+							"vis_video_thread_pad",
+							vis_video_thread_pad);
+	
+	gst_bin_add (GST_BIN(play->audio_sink), vis_video_thread);
+
+	/* END VIS STUFF */
+
+	gst_bin_add (GST_BIN (work_thread), play->audio_sink);
+
+	/* create video elements */
+	play->video_sink = gst_element_factory_make ("fakesink", "fake_show");
+	if (!play->video_sink)
+	{
+		gst_play_error_plugin (GST_PLAY_ERROR_FAKESINK, error);
+		return FALSE;
+	}
+	play->video_sink_element = NULL;
+
+	video_queue = gst_element_factory_make ("queue", "video_queue");
+	if (!video_queue)
+	{
+		gst_play_error_plugin (GST_PLAY_ERROR_QUEUE, error);
+		return FALSE;
+	}
+	g_hash_table_insert (play->other_elements, "video_queue", video_queue);
+
+	colorspace = gst_element_factory_make ("colorspace", "colorspace");
+	if (!colorspace)
+	{
+		gst_play_error_plugin (GST_PLAY_ERROR_COLORSPACE, error);
+		return FALSE;
+	}
+	g_hash_table_insert (play->other_elements, "colorspace", colorspace);
+
+	video_bin = gst_thread_new ("video_thread");
+	if (!video_bin)
+	{
+		gst_play_error_plugin (GST_PLAY_ERROR_THREAD, error);
+		return FALSE;
+	}
+	g_hash_table_insert (play->other_elements, "video_bin", video_bin);
+
+	/* adding all that stuff to bin */
+	gst_bin_add_many (GST_BIN (video_bin), video_queue, colorspace, 
+			play->video_sink, NULL);
+	
+	gst_element_link_many (video_queue, colorspace,
+			play->video_sink, NULL);
+	
+	/* setting up iterate functions 
+	gst_bin_set_pre_iterate_function (
+			GST_BIN (video_bin), 
+			(GstBinPrePostIterateFunction) callback_bin_pre_iterate, 
+			play->video_bin_mutex);
+	gst_bin_set_post_iterate_function (
+			GST_BIN (video_bin), 
+			(GstBinPrePostIterateFunction) callback_bin_post_iterate,
+			play->video_bin_mutex);*/
+	
+	gst_element_add_ghost_pad (
+			video_bin, gst_element_get_pad (video_queue, "sink"),
+			"sink");
+			
+	gst_bin_add (GST_BIN (work_thread), video_bin);
+
+	return TRUE;
+}
+
+static gboolean
+gst_play_video_vis_set_audio (	GstPlay *play,
+							GstElement *audio_sink)
+{
+	GstElement *audio_bin, *vis_audio_sink, *vis_audio_queue;
+	
+	g_return_val_if_fail (play != NULL, FALSE);
+	g_return_val_if_fail (audio_sink != NULL, FALSE);
+	g_return_val_if_fail (GST_IS_PLAY(play), FALSE);
+	g_return_val_if_fail (GST_IS_ELEMENT (audio_sink), FALSE);
+	
+	audio_bin = g_hash_table_lookup (	play->other_elements,
+										"vis_audio_thread");
+	vis_audio_sink = g_hash_table_lookup (	play->other_elements,
+											"vis_audio_sink");
+	vis_audio_queue = g_hash_table_lookup (	play->other_elements,
+											"vis_audio_queue");
+	
+	if (vis_audio_sink)
+	{
+		gst_element_unlink (vis_audio_queue, vis_audio_sink);
+		gst_bin_remove (GST_BIN (audio_bin), vis_audio_sink);
+	}
+
+	gst_bin_add (GST_BIN (audio_bin), audio_sink);
+	gst_element_link (vis_audio_queue, audio_sink);
+
+	g_hash_table_replace(	play->other_elements,
+							"vis_audio_sink",
+							audio_sink);
+	
+	play->audio_sink_element = gst_play_get_sink_element (
+										play,
+										audio_sink,
+										GST_PLAY_SINK_TYPE_AUDIO);
+
+	if (play->audio_sink_element != NULL) {
+		g_signal_connect (G_OBJECT (play->audio_sink_element), "eos",
+				  G_CALLBACK (callback_audio_sink_eos), play);
+	}
+
+	return TRUE;
+}
+
+static gboolean
+gst_play_video_vis_set_video (	GstPlay *play,
+								GstElement *video_sink)
+{
+	GstElement *video_mate, *video_bin;
+	
+	g_return_val_if_fail (play != NULL, FALSE);
+	g_return_val_if_fail (video_sink != NULL, FALSE);
+	g_return_val_if_fail (GST_IS_PLAY(play), FALSE);
+	g_return_val_if_fail (GST_IS_ELEMENT (video_sink), FALSE);
+
+	video_bin = g_hash_table_lookup(play->other_elements, "video_bin");
+	video_mate = g_hash_table_lookup(play->other_elements, "colorspace");
+
+	if (play->video_sink) {
+		gst_element_unlink (video_mate, play->video_sink);
+		gst_bin_remove (GST_BIN (video_bin), play->video_sink);
+	}
+	play->video_sink = video_sink;
+	gst_bin_add (GST_BIN (video_bin), play->video_sink);
+	gst_element_link (video_mate, play->video_sink);
+
+	play->video_sink_element = gst_play_get_sink_element (
+											play,
+											video_sink,
+											GST_PLAY_SINK_TYPE_VIDEO);
+
+	if (play->video_sink_element != NULL) {
+		g_signal_connect (	G_OBJECT (play->video_sink_element),
+							"have_xid",
+				  			G_CALLBACK (callback_video_have_xid),
+							play);
+		g_signal_connect (	G_OBJECT (play->video_sink_element),
+							"have_size",
+				  			G_CALLBACK (callback_video_have_size),
+							play);
+		g_object_set(	G_OBJECT(play->video_sink_element),
+						"need_new_window",
+						TRUE,
+						"toplevel",
+						FALSE, NULL);
+	}
+	return TRUE;
+}
+
+/**
+ * gst_play_set_visualisation_video_sink:
+ * @play: a #GstPlay.
+ * @video_sink: a #GstElement.
+ *
+ * Set @video_sink as the visualisation video sink element of @play.
+ *
+ * Returns: TRUE if call succeeded.
+ */
+gboolean
+gst_play_set_visualisation_video_sink (	GstPlay *play,
+										GstElement *video_sink)
+{
+	GstElement *video_mate, *video_bin, *vis_video_sink;
+	
+	g_return_val_if_fail (play != NULL, FALSE);
+	g_return_val_if_fail (video_sink != NULL, FALSE);
+	g_return_val_if_fail (GST_IS_PLAY(play), FALSE);
+	g_return_val_if_fail (GST_IS_ELEMENT (video_sink), FALSE);
+
+	video_bin = g_hash_table_lookup(play->other_elements, "vis_video_thread");
+	video_mate = g_hash_table_lookup(play->other_elements, "vis_colorspace");
+	vis_video_sink = g_hash_table_lookup(	play->other_elements,
+											"vis_video_sink");
+	
+	if (vis_video_sink) {
+		gst_element_unlink (video_mate, vis_video_sink);
+		gst_bin_remove (GST_BIN (video_bin), vis_video_sink);
+	}
+	
+	gst_bin_add (GST_BIN (video_bin), video_sink);
+	gst_element_link (video_mate, video_sink);
+	
+	g_hash_table_replace(	play->other_elements,
+							"vis_video_sink",
+							video_sink);
+	
+	play->visualisation_sink_element = gst_play_get_sink_element (
+											play,
+											video_sink,
+											GST_PLAY_SINK_TYPE_VIDEO);
+
+	if (play->visualisation_sink_element != NULL) {
+		g_signal_connect (	G_OBJECT (play->visualisation_sink_element),
+							"have_xid",
+				  			G_CALLBACK (callback_video_have_vis_xid),
+							play);
+		/*g_signal_connect (	G_OBJECT (play->visualisation_sink_element),
+							"have_size",
+				  			G_CALLBACK (callback_video_have_vis_size),
+							play);*/
+		g_object_set(	G_OBJECT(play->visualisation_sink_element),
+						"need_new_window",
+						TRUE,
+						"toplevel",
+						FALSE, NULL);
+	}
+	return TRUE;
+}
+
+/**
+ * gst_play_set_visualisation_element:
+ * @play: a #GstPlay.
+ * @element: a #GstElement.
+ *
+ * Set @video_sink as the video sink element of @play.
+ *
+ * Returns: TRUE if call succeeded.
+ */
+gboolean
+gst_play_set_visualisation_element (	GstPlay *play,
+										GstElement *element)
+{
+	GstElement *video_queue, *video_colorspace;
+	GstElement *vis_element, *vis_video_bin;
+	
+	g_return_val_if_fail (play != NULL, FALSE);
+	g_return_val_if_fail (element != NULL, FALSE);
+	g_return_val_if_fail (GST_IS_PLAY(play), FALSE);
+	g_return_val_if_fail (GST_IS_ELEMENT (element), FALSE);
+
+	vis_video_bin = g_hash_table_lookup (	play->other_elements,
+											"vis_video_thread");
+	video_queue = g_hash_table_lookup (	play->other_elements,
+										"vis_video_queue");
+	video_colorspace = g_hash_table_lookup (	play->other_elements,
+											"vis_colorspace");
+	vis_element = g_hash_table_lookup (	play->other_elements,
+											"vis_element");
+	if (vis_element) {
+		gst_element_unlink (video_queue, vis_element);
+		gst_element_unlink (vis_element, video_colorspace);
+		gst_bin_remove (GST_BIN (vis_video_bin), vis_element);
+	}
+	
+	gst_bin_add (GST_BIN (vis_video_bin), element);
+	gst_element_link_many (video_queue, element, video_colorspace, NULL);
+	
+	g_hash_table_replace(	play->other_elements,
+							"vis_element",
+							element);
+	
+	return TRUE;
+}
+
+/**
+ * gst_play_connect_visualisation:
+ * @play: a #GstPlay.
+ * @connect: a #gboolean indicating wether or not
+ * visualisation should be connected.
+ *
+ * Connect or disconnect visualisation bin in @play.
+ *
+ * Returns: TRUE if call succeeded.
+ */
+gboolean
+gst_play_connect_visualisation (	GstPlay *play,
+									gboolean connect)
+{
+	GstPad *tee_vis_pad, *vis_video_thread_pad;
+	
+	g_return_val_if_fail (play != NULL, FALSE);
+	g_return_val_if_fail (GST_IS_PLAY(play), FALSE);
+	
+	tee_vis_pad = g_hash_table_lookup(	play->other_elements,
+											"tee_vis_pad");
+	vis_video_thread_pad = g_hash_table_lookup(	play->other_elements,
+												"vis_video_thread_pad");
+	
+	if (connect) {
+		gst_pad_link (tee_vis_pad, vis_video_thread_pad);
+	}
+	else {
+		gst_pad_unlink (tee_vis_pad, vis_video_thread_pad);
+	}
+	
+	return TRUE;
+}
+
 /* modelines */
 /* vim:set ts=8:sw=8:noet */