diff options
Diffstat (limited to 'gst-libs/gst')
| -rw-r--r-- | gst-libs/gst/play/play.old.c | 1384 | ||||
| -rw-r--r-- | gst-libs/gst/play/play.old.h | 148 | ||||
| -rw-r--r-- | gst-libs/gst/play/playpipelines.c | 619 |
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 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; +} + + + + + + + + diff --git a/gst-libs/gst/play/play.old.h b/gst-libs/gst/play/play.old.h index acf777c9..90f9a5ce 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 527ea43f..163d1a2d 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 */ |