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

1 files changed, 848 insertions, 536 deletions

diff --git a/gst-libs/gst/play/play.old.c b/gst-libs/gst/play/play.old.c
index 4d3daecd..88a370d5 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;
+}
+
+
+
+
+
+
+
+