diff options
Diffstat (limited to 'gst-libs/gst/play')
| -rw-r--r-- | gst-libs/gst/play/play.old.c | 1860 | ||||
| -rw-r--r-- | gst-libs/gst/play/play.old.h | 283 | ||||
| -rw-r--r-- | gst-libs/gst/play/playpipelines.c | 1852 |
3 files changed, 1963 insertions, 2032 deletions
diff --git a/gst-libs/gst/play/play.old.c b/gst-libs/gst/play/play.old.c index c30efae9..69382c0c 100644 --- a/gst-libs/gst/play/play.old.c +++ b/gst-libs/gst/play/play.old.c @@ -24,60 +24,73 @@ #include "play.h" -enum { - STREAM_END, - INFORMATION, - STATE_CHANGE, - STREAM_LENGTH, - TIME_TICK, - HAVE_XID, - HAVE_VIS_XID, - HAVE_VIDEO_SIZE, - PIPELINE_ERROR, - /* put additional signals before this comment */ - LAST_SIGNAL, +enum +{ + STREAM_END, + INFORMATION, + STATE_CHANGE, + STREAM_LENGTH, + TIME_TICK, + HAVE_XID, + HAVE_VIS_XID, + HAVE_VIDEO_SIZE, + PIPELINE_ERROR, + /* put additional signals before this comment */ + LAST_SIGNAL, }; /* this struct is used to decouple signals coming out of threaded pipelines */ -typedef struct _GstPlaySignal GstPlaySignal; +typedef struct _GstPlaySignal GstPlaySignal; struct _GstPlaySignal { - gint signal_id; - union { - struct { - gint width; - gint height; - } video_size; - struct { - gint xid; - } video_xid; - struct { - GstElementState old_state; - GstElementState new_state; - } state; - struct { - GstObject* object; - GParamSpec* param; - } info; - struct { - GstElement* element; - char* error; - } error; - } signal_data; + gint signal_id; + union + { + struct + { + gint width; + gint height; + } + video_size; + struct + { + gint xid; + } + video_xid; + struct + { + GstElementState old_state; + GstElementState new_state; + } + state; + struct + { + GstObject *object; + GParamSpec *param; + } + info; + struct + { + GstElement *element; + char *error; + } + error; + } + signal_data; }; enum { - ARG_0, - ARG_LOCATION, - ARG_VOLUME, - ARG_MUTE, - /* FILL ME */ + ARG_0, + ARG_LOCATION, + ARG_VOLUME, + ARG_MUTE, + /* FILL ME */ }; -static guint gst_play_signals [LAST_SIGNAL] = { 0 }; +static guint gst_play_signals[LAST_SIGNAL] = { 0 }; static GstElementClass *parent_class = NULL; @@ -96,12 +109,13 @@ static GstElementClass *parent_class = NULL; static GQuark gst_play_error_quark (void) { - static GQuark quark = 0; - if (quark == 0) { - quark = g_quark_from_static_string ("gst-play-error-quark"); - } + static GQuark quark = 0; + if (quark == 0) + { + quark = g_quark_from_static_string ("gst-play-error-quark"); + } - return quark; + return quark; } /* GError creation when plugin is missing @@ -109,101 +123,99 @@ gst_play_error_quark (void) * 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; - - if (error == NULL) return; - - switch (type) - { - case GST_PLAY_ERROR_THREAD: - name = g_strdup ("thread"); - break; - case GST_PLAY_ERROR_QUEUE: - name = g_strdup ("queue"); - break; - case GST_PLAY_ERROR_FAKESINK: - name = g_strdup ("fakesink"); - break; - case GST_PLAY_ERROR_VOLUME: - name = g_strdup ("volume"); - break; - case GST_PLAY_ERROR_COLORSPACE: - name = g_strdup ("colorspace"); - break; - case GST_PLAY_ERROR_GNOMEVFSSRC: - name = g_strdup ("gnomevfssrc"); - break; - default: - 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 libgstplay. " - "Please install it and verify that it works " - "by running 'gst-inspect %s'", - name, name); - g_free (name); - return; + gchar *name; + + if (error == NULL) + return; + + switch (type) + { + case GST_PLAY_ERROR_THREAD: + name = g_strdup ("thread"); + break; + case GST_PLAY_ERROR_QUEUE: + name = g_strdup ("queue"); + break; + case GST_PLAY_ERROR_FAKESINK: + name = g_strdup ("fakesink"); + break; + case GST_PLAY_ERROR_VOLUME: + name = g_strdup ("volume"); + break; + case GST_PLAY_ERROR_COLORSPACE: + name = g_strdup ("colorspace"); + break; + case GST_PLAY_ERROR_GNOMEVFSSRC: + name = g_strdup ("gnomevfssrc"); + break; + default: + 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 libgstplay. " + "Please install it and verify that it works " + "by running 'gst-inspect %s'", name, name); + g_free (name); + return; } static void -gst_play_set_property ( GObject *object, - guint prop_id, - const GValue *value, - GParamSpec *pspec) +gst_play_set_property (GObject * object, + guint prop_id, + const GValue * value, GParamSpec * pspec) { - GstPlay *play; - g_return_if_fail (object != NULL); - g_return_if_fail (GST_IS_PLAY (object)); - play = GST_PLAY (object); - - 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; - } + GstPlay *play; + g_return_if_fail (object != NULL); + g_return_if_fail (GST_IS_PLAY (object)); + play = GST_PLAY (object); + + 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; + } } static void -gst_play_get_property ( GObject *object, - guint prop_id, - GValue *value, - GParamSpec *pspec) +gst_play_get_property (GObject * object, + guint prop_id, GValue * value, GParamSpec * pspec) { - GstPlay *play; - g_return_if_fail (object != NULL); - g_return_if_fail (GST_IS_PLAY (object)); - play = GST_PLAY (object); - - 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; - } + GstPlay *play; + g_return_if_fail (object != NULL); + g_return_if_fail (GST_IS_PLAY (object)); + play = GST_PLAY (object); + + 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; + } } /* =========================================== */ @@ -213,298 +225,308 @@ gst_play_get_property ( GObject *object, /* =========================================== */ static gboolean -gst_play_get_length_callback (GstPlay *play) +gst_play_get_length_callback (GstPlay * play) { - gint64 value; - GstFormat format = GST_FORMAT_TIME; - gboolean query_worked = FALSE; - - if ( (play->audio_sink_element != NULL) && - (GST_IS_ELEMENT (play->audio_sink_element)) ) { - query_worked = gst_element_query (play->audio_sink_element, GST_QUERY_TOTAL, &format, &value); - } - else if ( (play->video_sink_element != NULL) && - (GST_IS_ELEMENT (play->video_sink_element)) ) { - query_worked = gst_element_query (play->video_sink_element, GST_QUERY_TOTAL, &format, &value); - } - if (query_worked){ - 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; - } + gint64 value; + GstFormat format = GST_FORMAT_TIME; + gboolean query_worked = FALSE; + + if ((play->audio_sink_element != NULL) && + (GST_IS_ELEMENT (play->audio_sink_element))) + { + query_worked = + gst_element_query (play->audio_sink_element, GST_QUERY_TOTAL, &format, + &value); + } + else if ((play->video_sink_element != NULL) && + (GST_IS_ELEMENT (play->video_sink_element))) + { + query_worked = + gst_element_query (play->video_sink_element, GST_QUERY_TOTAL, &format, + &value); + } + if (query_worked) + { + 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); + } + return (gst_element_get_state (play->pipeline) == GST_STATE_PLAYING); } static gboolean -gst_play_tick_callback (GstPlay *play) +gst_play_tick_callback (GstPlay * play) { - gint secs; - - g_return_val_if_fail (play != NULL, FALSE); - 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); - } - - return (gst_element_get_state(play->pipeline) == GST_STATE_PLAYING); + gint secs; + + g_return_val_if_fail (play != NULL, FALSE); + 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); + } + + return (gst_element_get_state (play->pipeline) == GST_STATE_PLAYING); } static gboolean -gst_play_default_idle (GstPlayIdleData *idle_data) +gst_play_default_idle (GstPlayIdleData * idle_data) { - 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; + 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 guint -gst_play_default_timeout_add ( guint interval, - GSourceFunc function, - gpointer data) +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; + 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); + return g_timeout_add (interval, (GSourceFunc) gst_play_default_idle, + idle_data); } static guint -gst_play_default_idle_add ( GSourceFunc function, - gpointer data) +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); + 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); } static gboolean -gst_play_idle_callback (GstPlay *play) +gst_play_idle_callback (GstPlay * play) { - g_return_val_if_fail (play != NULL, FALSE); - g_return_val_if_fail (GST_IS_PLAY(play), FALSE); - - return gst_bin_iterate (GST_BIN (play->pipeline)); + g_return_val_if_fail (play != NULL, FALSE); + g_return_val_if_fail (GST_IS_PLAY (play), FALSE); + + return gst_bin_iterate (GST_BIN (play->pipeline)); } static gboolean -gst_play_idle_signal (GstPlay *play) +gst_play_idle_signal (GstPlay * play) { - GstPlaySignal *signal; - gint queue_length; - - g_return_val_if_fail (play != NULL, FALSE); - g_return_val_if_fail (GST_IS_PLAY(play), FALSE); - - signal = g_async_queue_try_pop(play->signal_queue); - if (signal == NULL){ - return FALSE; - } - - switch (signal->signal_id){ - case HAVE_XID: - 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); - break; - case STATE_CHANGE: - g_signal_emit (G_OBJECT (play), gst_play_signals[STATE_CHANGE], 0, - signal->signal_data.state.old_state, signal->signal_data.state.new_state); - break; - case INFORMATION: - g_signal_emit (G_OBJECT (play), gst_play_signals[INFORMATION], 0, - signal->signal_data.info.object, signal->signal_data.info.param); - gst_object_unref (signal->signal_data.info.object); - break; - case PIPELINE_ERROR: - g_signal_emit (G_OBJECT (play), gst_play_signals[PIPELINE_ERROR], 0, - signal->signal_data.error.element, signal->signal_data.error.error); - if (signal->signal_data.error.error) - g_free (signal->signal_data.error.error); - gst_object_unref (GST_OBJECT(signal->signal_data.error.element)); - break; - default: - break; - } - - g_free(signal); - queue_length = g_async_queue_length (play->signal_queue); - - return (queue_length > 0); + GstPlaySignal *signal; + gint queue_length; + + g_return_val_if_fail (play != NULL, FALSE); + g_return_val_if_fail (GST_IS_PLAY (play), FALSE); + + signal = g_async_queue_try_pop (play->signal_queue); + if (signal == NULL) + { + return FALSE; + } + + switch (signal->signal_id) + { + case HAVE_XID: + 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); + break; + case STATE_CHANGE: + g_signal_emit (G_OBJECT (play), gst_play_signals[STATE_CHANGE], 0, + signal->signal_data.state.old_state, + signal->signal_data.state.new_state); + break; + case INFORMATION: + g_signal_emit (G_OBJECT (play), gst_play_signals[INFORMATION], 0, + signal->signal_data.info.object, + signal->signal_data.info.param); + gst_object_unref (signal->signal_data.info.object); + break; + case PIPELINE_ERROR: + g_signal_emit (G_OBJECT (play), gst_play_signals[PIPELINE_ERROR], 0, + signal->signal_data.error.element, + signal->signal_data.error.error); + if (signal->signal_data.error.error) + g_free (signal->signal_data.error.error); + gst_object_unref (GST_OBJECT (signal->signal_data.error.element)); + break; + default: + break; + } + + g_free (signal); + queue_length = g_async_queue_length (play->signal_queue); + + return (queue_length > 0); } static gboolean -gst_play_idle_eos (GstPlay* play) +gst_play_idle_eos (GstPlay * play) { - g_signal_emit (G_OBJECT (play), gst_play_signals [STREAM_END], 0); - return FALSE; + g_signal_emit (G_OBJECT (play), gst_play_signals[STREAM_END], 0); + return FALSE; } 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); + 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); + 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) +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); - - play->idle_add_func ((GSourceFunc) gst_play_idle_signal, 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); + + 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); - - play->idle_add_func ((GSourceFunc) gst_play_idle_signal, 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); + + play->idle_add_func ((GSourceFunc) gst_play_idle_signal, play); } static void -callback_pipeline_error ( GstElement *object, - GstElement *orig, - char *error, - GstPlay* play) -{ - GstPlaySignal *signal; - - signal = g_new0(GstPlaySignal, 1); - signal->signal_id = PIPELINE_ERROR; - signal->signal_data.error.element = orig; - signal->signal_data.error.error = g_strdup(error); - - gst_object_ref (GST_OBJECT(orig)); - - g_async_queue_push(play->signal_queue, signal); - - if (GST_IS_ELEMENT(play->pipeline)) - gst_element_set_state(play->pipeline, GST_STATE_READY); - - play->idle_add_func ((GSourceFunc) gst_play_idle_signal, play); -} +callback_pipeline_error (GstElement * object, + GstElement * orig, char *error, GstPlay * play) +{ + GstPlaySignal *signal; + + signal = g_new0 (GstPlaySignal, 1); + signal->signal_id = PIPELINE_ERROR; + signal->signal_data.error.element = orig; + signal->signal_data.error.error = g_strdup (error); + + gst_object_ref (GST_OBJECT (orig)); + + g_async_queue_push (play->signal_queue, signal); + + if (GST_IS_ELEMENT (play->pipeline)) + gst_element_set_state (play->pipeline, GST_STATE_READY); + + play->idle_add_func ((GSourceFunc) gst_play_idle_signal, play); +} static void -callback_pipeline_deep_notify ( GstObject *element, - GstObject *orig, - GParamSpec *param, - GstPlay* play) +callback_pipeline_deep_notify (GstObject * element, + GstObject * orig, + GParamSpec * param, GstPlay * play) { - GstPlaySignal *signal; - - signal = g_new0(GstPlaySignal, 1); - signal->signal_id = INFORMATION; - signal->signal_data.info.object = orig; - signal->signal_data.info.param = param; - - gst_object_ref (orig); - - g_async_queue_push(play->signal_queue, signal); - - play->idle_add_func ((GSourceFunc) gst_play_idle_signal, play); + GstPlaySignal *signal; + + signal = g_new0 (GstPlaySignal, 1); + signal->signal_id = INFORMATION; + signal->signal_data.info.object = orig; + signal->signal_data.info.param = param; + + gst_object_ref (orig); + + g_async_queue_push (play->signal_queue, signal); + + play->idle_add_func ((GSourceFunc) gst_play_idle_signal, play); } static void -callback_pipeline_state_change ( GstElement *element, - GstElementState old, - GstElementState state, - GstPlay* play) +callback_pipeline_state_change (GstElement * element, + GstElementState old, + GstElementState state, GstPlay * play) { - GstPlaySignal *signal; - - g_return_if_fail (play != NULL); - g_return_if_fail (element != NULL); - g_return_if_fail (GST_IS_ELEMENT (element)); - g_return_if_fail (GST_IS_PLAY (play)); - g_return_if_fail (element == play->pipeline); - - /* 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; + GstPlaySignal *signal; + + g_return_if_fail (play != NULL); + g_return_if_fail (element != NULL); + g_return_if_fail (GST_IS_ELEMENT (element)); + g_return_if_fail (GST_IS_PLAY (play)); + g_return_if_fail (element == play->pipeline); + + /* 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); + g_async_queue_push (play->signal_queue, signal); - play->idle_add_func ((GSourceFunc) gst_play_idle_signal, play); + play->idle_add_func ((GSourceFunc) gst_play_idle_signal, play); } /* split static pipeline functions to a seperate file */ @@ -517,172 +539,155 @@ callback_pipeline_state_change ( GstElement *element, /* =========================================== */ static void -gst_play_dispose (GObject *object) +gst_play_dispose (GObject * object) { - GstPlay *play; + GstPlay *play; + + g_return_if_fail (object != NULL); + g_return_if_fail (GST_IS_PLAY (object)); + play = GST_PLAY (object); - g_return_if_fail (object != NULL); - g_return_if_fail (GST_IS_PLAY(object)); - play = GST_PLAY (object); + /* Removing all sources */ + while (g_source_remove_by_user_data (play)); - /* Removing all sources */ - while (g_source_remove_by_user_data (play)); - - G_OBJECT_CLASS (parent_class)->dispose (object); + G_OBJECT_CLASS (parent_class)->dispose (object); } static void -gst_play_class_init (GstPlayClass *klass) +gst_play_class_init (GstPlayClass * klass) { - 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 [PIPELINE_ERROR] = - g_signal_new ("pipeline_error", - G_TYPE_FROM_CLASS (klass), - G_SIGNAL_RUN_FIRST, - G_STRUCT_OFFSET (GstPlayClass, pipeline_error), - NULL, NULL, - gst_marshal_VOID__OBJECT_STRING, - G_TYPE_NONE, 2, - G_TYPE_OBJECT, G_TYPE_STRING); - - 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); + 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[PIPELINE_ERROR] = + g_signal_new ("pipeline_error", + G_TYPE_FROM_CLASS (klass), + G_SIGNAL_RUN_FIRST, + G_STRUCT_OFFSET (GstPlayClass, pipeline_error), + NULL, NULL, + gst_marshal_VOID__OBJECT_STRING, + G_TYPE_NONE, 2, G_TYPE_OBJECT, G_TYPE_STRING); + + 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) +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); - - gst_play_set_idle_timeout_funcs( play, - gst_play_default_timeout_add, - gst_play_default_idle_add); + 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); + + gst_play_set_idle_timeout_funcs (play, + gst_play_default_timeout_add, + gst_play_default_idle_add); } /* ============================================================= */ @@ -705,58 +710,65 @@ gst_play_init (GstPlay *play) * 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 (play != NULL); - g_return_if_fail (GST_IS_PLAY (play)); - if (time_nanos < 0LL){ - play->seek_time = 0LL; - } - else if (time_nanos < 0LL){ - play->seek_time = play->length_nanos; - } - else { - play->seek_time = time_nanos; - } - - /*g_print("doing seek to %lld\n", play->seek_time);*/ - prev_state = GST_STATE(play->pipeline); - if (gst_play_set_state (play, GST_STATE_PAUSED) != GST_STATE_SUCCESS) - g_warning ("gst_play_seek: setting to READY failed\n"); - - s_event = gst_event_new_seek (GST_FORMAT_TIME | - GST_SEEK_METHOD_SET | - 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); - } - 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); - } - gst_event_unref (s_event); - - if (audio_seek_worked || video_seek_worked){ - play->time_nanos = gst_clock_get_time(play->clock); - g_signal_emit (G_OBJECT (play), gst_play_signals [TIME_TICK], 0, play->time_nanos); - } - if (gst_element_set_state (play->pipeline, prev_state) != GST_STATE_SUCCESS) - g_warning ("gst_play_seek_to_time: setting to READY failed\n"); + 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 (play != NULL); + g_return_if_fail (GST_IS_PLAY (play)); + if (time_nanos < 0LL) + { + play->seek_time = 0LL; + } + else if (time_nanos < 0LL) + { + play->seek_time = play->length_nanos; + } + else + { + play->seek_time = time_nanos; + } + + /*g_print("doing seek to %lld\n", play->seek_time); */ + prev_state = GST_STATE (play->pipeline); + if (gst_play_set_state (play, GST_STATE_PAUSED) != GST_STATE_SUCCESS) + g_warning ("gst_play_seek: setting to READY failed\n"); + + s_event = gst_event_new_seek (GST_FORMAT_TIME | + GST_SEEK_METHOD_SET | + 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); + } + 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); + } + gst_event_unref (s_event); + + if (audio_seek_worked || video_seek_worked) + { + play->time_nanos = gst_clock_get_time (play->clock); + g_signal_emit (G_OBJECT (play), gst_play_signals[TIME_TICK], 0, + play->time_nanos); + } + if (gst_element_set_state (play->pipeline, prev_state) != GST_STATE_SUCCESS) + g_warning ("gst_play_seek_to_time: setting to READY failed\n"); } /** @@ -766,29 +778,31 @@ gst_play_seek_to_time ( GstPlay *play, * 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); - } - if (GST_IS_ELEMENT(play->visualisation_sink_element)){ - g_object_set( G_OBJECT(play->visualisation_sink_element), - "need_new_window", TRUE, NULL); - } + 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); + } + if (GST_IS_ELEMENT (play->visualisation_sink_element)) + { + g_object_set (G_OBJECT (play->visualisation_sink_element), + "need_new_window", TRUE, NULL); + } } 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 (play != NULL); - g_return_if_fail (GST_IS_PLAY (play)); - play->timeout_add_func = timeout_add_func; - play->idle_add_func = idle_add_func; + g_return_if_fail (play != NULL); + g_return_if_fail (GST_IS_PLAY (play)); + play->timeout_add_func = timeout_add_func; + play->idle_add_func = idle_add_func; } /** @@ -802,99 +816,109 @@ gst_play_set_idle_timeout_funcs ( GstPlay *play, * * Returns: the sink #GstElement of @element. */ -GstElement* -gst_play_get_sink_element ( GstPlay *play, - GstElement *element, - GstPlaySinkType sink_type) +GstElement * +gst_play_get_sink_element (GstPlay * play, + GstElement * element, GstPlaySinkType sink_type) { - GList *elements = NULL; - const GList *pads = NULL; - gboolean has_src, has_correct_type; - - g_return_val_if_fail (play != NULL, NULL); - g_return_val_if_fail (element != NULL, NULL); - g_return_val_if_fail (GST_IS_PLAY (play), NULL); - g_return_val_if_fail (GST_IS_ELEMENT (element), NULL); - - if (!GST_IS_BIN(element)){ - /* since its not a bin, we'll presume this - * element is a sink element */ - return element; + GList *elements = NULL; + const GList *pads = NULL; + gboolean has_src, has_correct_type; + + g_return_val_if_fail (play != NULL, NULL); + g_return_val_if_fail (element != NULL, NULL); + g_return_val_if_fail (GST_IS_PLAY (play), NULL); + g_return_val_if_fail (GST_IS_ELEMENT (element), NULL); + + if (!GST_IS_BIN (element)) + { + /* since its not a bin, we'll presume this + * 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) + { + + element = GST_ELEMENT (elements->data); + + /* Recursivity :) */ + + if (GST_IS_BIN (element)) + { + element = gst_play_get_sink_element (play, element, sink_type); + if (GST_IS_ELEMENT (element)) + { + return element; + } } - - elements = (GList *) gst_bin_get_list (GST_BIN(element)); - - /* traverse all elements looking for a src pad */ - - while (elements) { - - element = GST_ELEMENT (elements->data); - - /* Recursivity :) */ - - if (GST_IS_BIN(element)) { - element = gst_play_get_sink_element(play,element,sink_type); - if (GST_IS_ELEMENT (element)) { - 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 { - - 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); + 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; } - if ( (!has_src) && (has_correct_type) ){ - return element; + + 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; + } } - elements = g_list_next (elements); + pads = g_list_next (pads); + } + if ((!has_src) && (has_correct_type)) + { + return element; + } } - /* we didn't find a sink element */ - return NULL; + elements = g_list_next (elements); + } + /* we didn't find a sink element */ + return NULL; } /* =========================================== */ @@ -913,14 +937,13 @@ gst_play_get_sink_element ( GstPlay *play, * 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 (play != NULL, GST_STATE_FAILURE); - 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); + g_return_val_if_fail (play != NULL, GST_STATE_FAILURE); + 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); - return gst_element_set_state(play->pipeline, state); + return gst_element_set_state (play->pipeline, state); } /** @@ -932,13 +955,13 @@ gst_play_set_state ( GstPlay *play, * Returns: a #GstElementState indicating @play 's pipeline current state. */ GstElementState -gst_play_get_state (GstPlay *play) +gst_play_get_state (GstPlay * play) { - g_return_val_if_fail (play != NULL, GST_STATE_FAILURE); - g_return_val_if_fail (GST_IS_PLAY (play), GST_STATE_FAILURE); - g_return_val_if_fail (play->pipeline, GST_STATE_FAILURE); + g_return_val_if_fail (play != NULL, GST_STATE_FAILURE); + g_return_val_if_fail (GST_IS_PLAY (play), GST_STATE_FAILURE); + g_return_val_if_fail (play->pipeline, GST_STATE_FAILURE); - return gst_element_get_state(play->pipeline); + return gst_element_get_state (play->pipeline); } /** @@ -951,39 +974,44 @@ gst_play_get_state (GstPlay *play) * 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 (play != NULL, FALSE); - g_return_val_if_fail (GST_IS_PLAY (play), FALSE); - g_return_val_if_fail (location != NULL, FALSE); - - current_state = gst_play_get_state (play); - if (current_state != GST_STATE_READY){ - if (gst_play_set_state (play, GST_STATE_READY) != GST_STATE_SUCCESS) - g_warning ("gst_play_set_location: setting to READY failed\n"); - } - - if (play->set_autoplugger){ - if (! play->set_autoplugger(play, gst_element_factory_make ("spider", "autoplugger"))){ - g_warning ("couldn't replace autoplugger\n"); - return FALSE; - } + GstElementState current_state; + g_return_val_if_fail (play != NULL, FALSE); + g_return_val_if_fail (GST_IS_PLAY (play), FALSE); + g_return_val_if_fail (location != NULL, FALSE); + + current_state = gst_play_get_state (play); + if (current_state != GST_STATE_READY) + { + if (gst_play_set_state (play, GST_STATE_READY) != GST_STATE_SUCCESS) + g_warning ("gst_play_set_location: setting to READY failed\n"); + } + + if (play->set_autoplugger) + { + if (!play-> + set_autoplugger (play, + gst_element_factory_make ("spider", + "autoplugger"))) + { + g_warning ("couldn't replace autoplugger\n"); + return FALSE; } + } - /* FIXME check for valid location (somehow) */ - g_object_set (G_OBJECT (play->source), "location", location, NULL); + /* FIXME check for valid location (somehow) */ + g_object_set (G_OBJECT (play->source), "location", location, NULL); - /* reset time/length values */ - play->time_seconds = 0; - play->length_nanos = 0LL; - play->time_nanos = 0LL; - g_signal_emit (G_OBJECT (play), gst_play_signals [STREAM_LENGTH], 0, 0LL); - g_signal_emit (G_OBJECT (play), gst_play_signals [TIME_TICK], 0, 0LL); - play->need_stream_length = TRUE; + /* reset time/length values */ + play->time_seconds = 0; + play->length_nanos = 0LL; + play->time_nanos = 0LL; + g_signal_emit (G_OBJECT (play), gst_play_signals[STREAM_LENGTH], 0, 0LL); + g_signal_emit (G_OBJECT (play), gst_play_signals[TIME_TICK], 0, 0LL); + play->need_stream_length = TRUE; - return TRUE; + return TRUE; } /** @@ -994,15 +1022,15 @@ gst_play_set_location ( GstPlay *play, * * Returns: a #gchar pointer to current location. */ -gchar* -gst_play_get_location (GstPlay *play) +gchar * +gst_play_get_location (GstPlay * play) { - gchar* location; - g_return_val_if_fail (play != NULL, NULL); - g_return_val_if_fail (GST_IS_PLAY (play), NULL); - g_return_val_if_fail (GST_IS_ELEMENT(play->source), NULL); - g_object_get (G_OBJECT (play->source), "location", &location, NULL); - return location; + gchar *location; + g_return_val_if_fail (play != NULL, NULL); + g_return_val_if_fail (GST_IS_PLAY (play), NULL); + g_return_val_if_fail (GST_IS_ELEMENT (play->source), NULL); + g_object_get (G_OBJECT (play->source), "location", &location, NULL); + return location; } /** @@ -1013,13 +1041,12 @@ gst_play_get_location (GstPlay *play) * 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 (play != NULL); - g_return_if_fail (GST_IS_PLAY (play)); + g_return_if_fail (play != NULL); + g_return_if_fail (GST_IS_PLAY (play)); - g_object_set(G_OBJECT(play->vol_dparam), "value_float", volume, NULL); + g_object_set (G_OBJECT (play->vol_dparam), "value_float", volume, NULL); } /** @@ -1031,16 +1058,16 @@ gst_play_set_volume ( GstPlay *play, * Returns: a #gfloat indicating current volume level. */ gfloat -gst_play_get_volume (GstPlay *play) +gst_play_get_volume (GstPlay * play) { - gfloat volume; + gfloat volume; - g_return_val_if_fail (play != NULL, 0); - g_return_val_if_fail (GST_IS_PLAY (play), 0); + g_return_val_if_fail (play != NULL, 0); + g_return_val_if_fail (GST_IS_PLAY (play), 0); - g_object_get(G_OBJECT(play->vol_dparam), "value_float", &volume, NULL); + g_object_get (G_OBJECT (play->vol_dparam), "value_float", &volume, NULL); - return volume; + return volume; } /** @@ -1051,13 +1078,12 @@ gst_play_get_volume (GstPlay *play) * 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 (play != NULL); - g_return_if_fail (GST_IS_PLAY (play)); + g_return_if_fail (play != NULL); + g_return_if_fail (GST_IS_PLAY (play)); - g_object_set (G_OBJECT (play->volume), "mute", mute, NULL); + g_object_set (G_OBJECT (play->volume), "mute", mute, NULL); } /** @@ -1069,16 +1095,16 @@ gst_play_set_mute ( GstPlay *play, * Returns: a #gboolean indicating if audio is muted or not. */ gboolean -gst_play_get_mute (GstPlay *play) +gst_play_get_mute (GstPlay * play) { - gboolean mute; + gboolean mute; - g_return_val_if_fail (play != NULL, 0); - g_return_val_if_fail (GST_IS_PLAY (play), 0); + g_return_val_if_fail (play != NULL, 0); + g_return_val_if_fail (GST_IS_PLAY (play), 0); - g_object_get (G_OBJECT (play->volume), "mute", &mute, NULL); + g_object_get (G_OBJECT (play->volume), "mute", &mute, NULL); - return mute; + return mute; } /* =========================================== */ @@ -1097,25 +1123,26 @@ gst_play_get_mute (GstPlay *play) * Returns: TRUE if call succeeded. */ gboolean -gst_play_set_data_src ( GstPlay *play, - GstElement *data_src) +gst_play_set_data_src (GstPlay * play, GstElement * data_src) { - g_return_val_if_fail (play != NULL, FALSE); - g_return_val_if_fail (data_src != NULL, FALSE); - 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){ - if (gst_play_set_state (play, GST_STATE_READY) != GST_STATE_SUCCESS) - g_warning ("gst_play_set_data_src: setting to READY failed\n"); - } - - 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; + g_return_val_if_fail (play != NULL, FALSE); + g_return_val_if_fail (data_src != NULL, FALSE); + 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) + { + if (gst_play_set_state (play, GST_STATE_READY) != GST_STATE_SUCCESS) + g_warning ("gst_play_set_data_src: setting to READY failed\n"); + } + + 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; } /** @@ -1128,25 +1155,26 @@ gst_play_set_data_src ( GstPlay *play, * Returns: TRUE if call succeeded. */ gboolean -gst_play_set_video_sink ( GstPlay *play, - GstElement *video_sink) +gst_play_set_video_sink (GstPlay * play, GstElement * 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); - - if (gst_play_get_state (play) != GST_STATE_READY){ - if (gst_play_set_state (play, GST_STATE_READY) != GST_STATE_SUCCESS) - g_warning ("gst_play_set_video_sink: setting to READY failed\n"); - } - - 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; + 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); + + if (gst_play_get_state (play) != GST_STATE_READY) + { + if (gst_play_set_state (play, GST_STATE_READY) != GST_STATE_SUCCESS) + g_warning ("gst_play_set_video_sink: setting to READY failed\n"); + } + + 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; } /** @@ -1159,25 +1187,26 @@ gst_play_set_video_sink ( GstPlay *play, * Returns: TRUE if call succeeded. */ gboolean -gst_play_set_audio_sink ( GstPlay *play, - GstElement *audio_sink) +gst_play_set_audio_sink (GstPlay * play, GstElement * audio_sink) { - 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); - - if (gst_play_get_state (play) != GST_STATE_READY){ - if (gst_play_set_state (play, GST_STATE_READY) != GST_STATE_SUCCESS) - g_warning ("gst_play_set_audio_sink: setting to READY failed\n"); - } - - 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; + 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); + + if (gst_play_get_state (play) != GST_STATE_READY) + { + if (gst_play_set_state (play, GST_STATE_READY) != GST_STATE_SUCCESS) + g_warning ("gst_play_set_audio_sink: setting to READY failed\n"); + } + + 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; } /* =========================================== */ @@ -1189,129 +1218,126 @@ gst_play_set_audio_sink ( GstPlay *play, 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; + 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) +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; + 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 36057505..1c4f594e 100644 --- a/gst-libs/gst/play/play.old.h +++ b/gst-libs/gst/play/play.old.h @@ -40,36 +40,44 @@ * playing state. */ -typedef enum { - GST_PLAY_OK, - GST_PLAY_UNKNOWN_MEDIA, - GST_PLAY_CANNOT_PLAY, - GST_PLAY_ERROR, -} GstPlayReturn; - -typedef enum { - GST_PLAY_PIPE_AUDIO, - GST_PLAY_PIPE_AUDIO_THREADED, - GST_PLAY_PIPE_AUDIO_HYPER_THREADED, - GST_PLAY_PIPE_VIDEO, - GST_PLAY_PIPE_VIDEO_VISUALISATION, -} GstPlayPipeType; - -typedef enum { - GST_PLAY_ERROR_FAKESINK, - GST_PLAY_ERROR_THREAD, - GST_PLAY_ERROR_QUEUE, - GST_PLAY_ERROR_GNOMEVFSSRC, - GST_PLAY_ERROR_VOLUME, - GST_PLAY_ERROR_COLORSPACE, - GST_PLAY_ERROR_LAST, -} GstPlayError; - -typedef enum { - GST_PLAY_SINK_TYPE_AUDIO, - GST_PLAY_SINK_TYPE_VIDEO, - GST_PLAY_SINK_TYPE_ANY, -} GstPlaySinkType; +typedef enum +{ + GST_PLAY_OK, + GST_PLAY_UNKNOWN_MEDIA, + GST_PLAY_CANNOT_PLAY, + GST_PLAY_ERROR, +} +GstPlayReturn; + +typedef enum +{ + GST_PLAY_PIPE_AUDIO, + GST_PLAY_PIPE_AUDIO_THREADED, + GST_PLAY_PIPE_AUDIO_HYPER_THREADED, + GST_PLAY_PIPE_VIDEO, + GST_PLAY_PIPE_VIDEO_VISUALISATION, +} +GstPlayPipeType; + +typedef enum +{ + GST_PLAY_ERROR_FAKESINK, + GST_PLAY_ERROR_THREAD, + GST_PLAY_ERROR_QUEUE, + GST_PLAY_ERROR_GNOMEVFSSRC, + GST_PLAY_ERROR_VOLUME, + GST_PLAY_ERROR_COLORSPACE, + 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 () @@ -80,168 +88,131 @@ typedef enum { #define GST_IS_PLAY_CLASS(obj) (G_TYPE_CHECK_CLASS_TYPE ((klass), GST_TYPE_PLAY)) #define GST_PLAY_GET_CLASS(obj) (G_TYPE_INSTANCE_GET_CLASS ((obj), GTK_TYPE_PLAY, GstPlayClass)) -typedef struct _GstPlay GstPlay; -typedef struct _GstPlayClass GstPlayClass; -typedef struct _GstPlayIdleData GstPlayIdleData; +typedef struct _GstPlay GstPlay; +typedef struct _GstPlayClass GstPlayClass; +typedef struct _GstPlayIdleData GstPlayIdleData; -typedef guint (*GstPlayTimeoutAdd) ( guint interval, - GSourceFunc function, - gpointer data); -typedef guint (*GstPlayIdleAdd) (GSourceFunc function, gpointer data); +typedef guint (*GstPlayTimeoutAdd) (guint interval, + GSourceFunc function, gpointer data); +typedef guint (*GstPlayIdleAdd) (GSourceFunc function, gpointer data); struct _GstPlay { - GObject parent; - - gboolean (*setup_pipeline) (GstPlay *play, GError **error); - void (*teardown_pipeline) (GstPlay *play); - gboolean (*set_data_src) (GstPlay *play, GstElement *datasrc); - gboolean (*set_autoplugger) (GstPlay *play, GstElement *autoplugger); - gboolean (*set_video_sink) (GstPlay *play, GstElement *videosink); - gboolean (*set_audio_sink) (GstPlay *play, GstElement *audiosink); - - /* core elements */ - GstElement *pipeline; - GstElement *volume; - GstElement *source; - GstElement *autoplugger; - GstElement *video_sink; - GstElement *video_sink_element; - GstElement *audio_sink; - GstElement *audio_sink_element; - GstElement *visualisation_sink_element; - - GstDParamManager *vol_dpman; - GstDParam *vol_dparam; - GHashTable *other_elements; - - GstClock *clock; - - gboolean need_stream_length; - gboolean need_seek; - gint time_seconds; - gint get_length_attempt; - gint64 seek_time; - gint64 time_nanos; - gint64 length_nanos; - - GAsyncQueue *signal_queue; - - GstPlayTimeoutAdd timeout_add_func; - GstPlayIdleAdd idle_add_func; + GObject parent; + + gboolean (*setup_pipeline) (GstPlay * play, GError ** error); + void (*teardown_pipeline) (GstPlay * play); + gboolean (*set_data_src) (GstPlay * play, GstElement * datasrc); + gboolean (*set_autoplugger) (GstPlay * play, GstElement * autoplugger); + gboolean (*set_video_sink) (GstPlay * play, GstElement * videosink); + gboolean (*set_audio_sink) (GstPlay * play, GstElement * audiosink); + + /* core elements */ + GstElement *pipeline; + GstElement *volume; + GstElement *source; + GstElement *autoplugger; + GstElement *video_sink; + GstElement *video_sink_element; + GstElement *audio_sink; + GstElement *audio_sink_element; + GstElement *visualisation_sink_element; + + GstDParamManager *vol_dpman; + GstDParam *vol_dparam; + GHashTable *other_elements; + + GstClock *clock; + + gboolean need_stream_length; + gboolean need_seek; + gint time_seconds; + gint get_length_attempt; + gint64 seek_time; + gint64 time_nanos; + gint64 length_nanos; + + GAsyncQueue *signal_queue; + + GstPlayTimeoutAdd timeout_add_func; + GstPlayIdleAdd idle_add_func; }; struct _GstPlayClass { - GObjectClass parent_class; - - /* signals */ - void (*information) (GstPlay* play, - GstObject* element, - GParamSpec *param); - void (*pipeline_error) (GstPlay* play, - GstElement* element, - char *error); - 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); + GObjectClass parent_class; + + /* signals */ + void (*information) (GstPlay * play, + GstObject * element, GParamSpec * param); + void (*pipeline_error) (GstPlay * play, GstElement * element, char *error); + 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 { - GSourceFunc func; - gpointer data; + GSourceFunc func; + gpointer data; }; -void -gst_play_seek_to_time ( GstPlay *play, - gint64 time_nanos); +void gst_play_seek_to_time (GstPlay * play, gint64 time_nanos); -void -gst_play_need_new_video_window (GstPlay *play); +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); +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); +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); +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); +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); +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_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); +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); +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__ */ diff --git a/gst-libs/gst/play/playpipelines.c b/gst-libs/gst/play/playpipelines.c index d5baa166..43b71c04 100644 --- a/gst-libs/gst/play/playpipelines.c +++ b/gst-libs/gst/play/playpipelines.c @@ -23,32 +23,34 @@ */ 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 (play != NULL, FALSE); - g_return_val_if_fail (datasrc != NULL, FALSE); - 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 */ - if (GST_IS_ELEMENT(play->autoplugger)){ - gst_element_unlink (play->autoplugger, play->source); - } - gst_bin_remove (GST_BIN(parent), play->source); - } - - play->source = datasrc; - g_return_val_if_fail (play->source != NULL, FALSE); - - gst_bin_add (GST_BIN (parent), play->source); - if (GST_IS_ELEMENT(play->autoplugger)){ - gst_element_link (play->autoplugger, play->source); + g_return_val_if_fail (play != NULL, FALSE); + g_return_val_if_fail (datasrc != NULL, FALSE); + 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 */ + if (GST_IS_ELEMENT (play->autoplugger)) + { + gst_element_unlink (play->autoplugger, play->source); } - return TRUE; + gst_bin_remove (GST_BIN (parent), play->source); + } + + play->source = datasrc; + g_return_val_if_fail (play->source != NULL, FALSE); + + gst_bin_add (GST_BIN (parent), play->source); + if (GST_IS_ELEMENT (play->autoplugger)) + { + gst_element_link (play->autoplugger, play->source); + } + return TRUE; } /* @@ -56,173 +58,166 @@ gst_play_default_set_data_src ( GstPlay *play, * gnomevfssrc ! spider ! volume ! osssink */ -static gboolean -gst_play_audio_setup ( GstPlay *play, - GError **error) +static gboolean +gst_play_audio_setup (GstPlay * play, GError ** error) { - - /* creating gst_bin */ - play->pipeline = gst_pipeline_new ("main_pipeline"); - g_return_val_if_fail (GST_IS_PIPELINE (play->pipeline), FALSE); - - /* 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; - } - - /* Adding element to bin */ - gst_bin_add (GST_BIN (play->pipeline), play->source); - - /* create audio elements */ - play->volume = gst_element_factory_make ("volume", "volume"); - if (!play->volume) - { - gst_play_error_plugin (GST_PLAY_ERROR_VOLUME, error); - return FALSE; - } - /* creating fake audio_sink */ - play->audio_sink = gst_element_factory_make ("fakesink", "fake_audio"); - if (play->audio_sink == NULL) - { - gst_play_error_plugin (GST_PLAY_ERROR_FAKESINK, error); - return FALSE; - } - - gst_bin_add_many ( - GST_BIN (play->pipeline), play->volume, - play->audio_sink, NULL); - - gst_element_link (play->volume, play->audio_sink); - - return TRUE; + /* creating gst_bin */ + play->pipeline = gst_pipeline_new ("main_pipeline"); + g_return_val_if_fail (GST_IS_PIPELINE (play->pipeline), FALSE); + + /* 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; + } + + /* Adding element to bin */ + gst_bin_add (GST_BIN (play->pipeline), play->source); + + /* create audio elements */ + play->volume = gst_element_factory_make ("volume", "volume"); + if (!play->volume) + { + gst_play_error_plugin (GST_PLAY_ERROR_VOLUME, error); + return FALSE; + } + + /* creating fake audio_sink */ + play->audio_sink = gst_element_factory_make ("fakesink", "fake_audio"); + if (play->audio_sink == NULL) + { + gst_play_error_plugin (GST_PLAY_ERROR_FAKESINK, error); + return FALSE; + } + + gst_bin_add_many (GST_BIN (play->pipeline), play->volume, + play->audio_sink, NULL); + + gst_element_link (play->volume, play->audio_sink); + + return TRUE; } 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); + return gst_play_default_set_data_src (play, datasrc, play->pipeline); } /* * GST_PLAY_PIPE_AUDIO_THREADED * { gnomevfssrc ! spider ! volume ! osssink } */ - -static gboolean -gst_play_audiot_setup ( GstPlay *play, - GError **error) -{ - g_return_val_if_fail (play != NULL, FALSE); - g_return_val_if_fail (GST_IS_PLAY(play), FALSE); - - /* creating gst_thread */ - play->pipeline = gst_thread_new ("main_pipeline"); - g_return_val_if_fail (GST_IS_THREAD (play->pipeline), FALSE); - /* 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; - } - - /* Adding element to bin */ - gst_bin_add (GST_BIN (play->pipeline), play->source); - - /* create audio elements */ - play->volume = gst_element_factory_make ("volume", "volume"); - if (!play->volume) - { - gst_play_error_plugin (GST_PLAY_ERROR_VOLUME, error); - return FALSE; - } - - /* creating fake audiosink */ - play->audio_sink = gst_element_factory_make ("fakesink", "fake_audio"); - if (play->audio_sink == NULL) - { - gst_play_error_plugin (GST_PLAY_ERROR_FAKESINK, error); - return FALSE; - } - - gst_bin_add_many ( - GST_BIN (play->pipeline), play->volume, - play->audio_sink, NULL); - - gst_element_link (play->volume, play->audio_sink); - - return TRUE; +static gboolean +gst_play_audiot_setup (GstPlay * play, GError ** error) +{ + g_return_val_if_fail (play != NULL, FALSE); + g_return_val_if_fail (GST_IS_PLAY (play), FALSE); + + /* creating gst_thread */ + play->pipeline = gst_thread_new ("main_pipeline"); + g_return_val_if_fail (GST_IS_THREAD (play->pipeline), FALSE); + + /* 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; + } + + /* Adding element to bin */ + gst_bin_add (GST_BIN (play->pipeline), play->source); + + /* create audio elements */ + play->volume = gst_element_factory_make ("volume", "volume"); + if (!play->volume) + { + gst_play_error_plugin (GST_PLAY_ERROR_VOLUME, error); + return FALSE; + } + + /* creating fake audiosink */ + play->audio_sink = gst_element_factory_make ("fakesink", "fake_audio"); + if (play->audio_sink == NULL) + { + gst_play_error_plugin (GST_PLAY_ERROR_FAKESINK, error); + return FALSE; + } + + gst_bin_add_many (GST_BIN (play->pipeline), play->volume, + play->audio_sink, NULL); + + gst_element_link (play->volume, play->audio_sink); + + return TRUE; } 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 (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); - - if (play->audio_sink) - { - gst_element_unlink (play->volume, play->audio_sink); - gst_bin_remove (GST_BIN (play->pipeline), play->audio_sink); - } - - play->audio_sink = 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, - 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); - } - - return TRUE; + 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); + + if (play->audio_sink) + { + gst_element_unlink (play->volume, play->audio_sink); + gst_bin_remove (GST_BIN (play->pipeline), play->audio_sink); + } + + play->audio_sink = 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, + 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); + } + + return TRUE; } 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 (play != NULL, FALSE); - g_return_val_if_fail (autoplugger != NULL, FALSE); - 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 */ - gst_element_unlink (play->autoplugger, play->volume); - gst_element_unlink (play->autoplugger, play->source); - gst_bin_remove (GST_BIN (play->pipeline), play->autoplugger); - } - - play->autoplugger = autoplugger; - g_return_val_if_fail (play->autoplugger != NULL, FALSE); - - gst_bin_add (GST_BIN (play->pipeline), play->autoplugger); - gst_element_link (play->source, play->autoplugger); - gst_element_link (play->autoplugger, play->volume); - return TRUE; + g_return_val_if_fail (play != NULL, FALSE); + g_return_val_if_fail (autoplugger != NULL, FALSE); + 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 */ + gst_element_unlink (play->autoplugger, play->volume); + gst_element_unlink (play->autoplugger, play->source); + gst_bin_remove (GST_BIN (play->pipeline), play->autoplugger); + } + + play->autoplugger = autoplugger; + g_return_val_if_fail (play->autoplugger != NULL, FALSE); + + gst_bin_add (GST_BIN (play->pipeline), play->autoplugger); + gst_element_link (play->source, play->autoplugger); + gst_element_link (play->autoplugger, play->volume); + return TRUE; } /* @@ -230,153 +225,149 @@ gst_play_audiot_set_auto ( GstPlay *play, * { gnomevfssrc ! spider ! { queue ! volume ! osssink } } */ -static gboolean -gst_play_audioht_setup ( GstPlay *play, - GError **error) +static gboolean +gst_play_audioht_setup (GstPlay * play, GError ** error) { - GstElement *audio_thread, *audio_queue; + GstElement *audio_thread, *audio_queue; + + g_return_val_if_fail (play != NULL, FALSE); + g_return_val_if_fail (GST_IS_PLAY (play), FALSE); - g_return_val_if_fail (play != NULL, FALSE); - g_return_val_if_fail (GST_IS_PLAY(play), FALSE); - /* play->pipeline = gst_thread_new ("main_pipeline"); g_return_val_if_fail (GST_IS_THREAD (play->pipeline), FALSE); */ - /* creating pipeline */ - play->pipeline = gst_pipeline_new ("main_pipeline"); - g_return_val_if_fail (GST_IS_PIPELINE (play->pipeline), FALSE); - - /* 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; - } - - /* Adding element to bin */ - gst_bin_add (GST_BIN (play->pipeline), play->source); - - /* create audio thread */ - audio_thread = gst_thread_new ("audio_thread"); - g_return_val_if_fail (GST_IS_THREAD (audio_thread), FALSE); - - g_hash_table_insert(play->other_elements, "audio_thread", audio_thread); - - /* create audio queue */ - audio_queue = gst_element_factory_make ("queue", "audio_queue"); - if (!audio_queue) - { - gst_play_error_plugin (GST_PLAY_ERROR_QUEUE, error); - return FALSE; - } - - g_hash_table_insert(play->other_elements, "audio_queue", audio_queue); - - /* create source element */ - play->volume = gst_element_factory_make ("volume", "volume"); - if (!play->volume) - { - gst_play_error_plugin (GST_PLAY_ERROR_VOLUME, error); - return FALSE; - } - - /* create audiosink. */ - play->audio_sink = gst_element_factory_make ("fakesink", "play_audio"); - if (play->audio_sink == NULL) - { - gst_play_error_plugin (GST_PLAY_ERROR_FAKESINK, error); - return FALSE; - } - - gst_bin_add_many ( - GST_BIN (audio_thread), audio_queue, play->volume, - play->audio_sink, NULL); - - gst_element_link_many (audio_queue, play->volume, play->audio_sink); - - gst_element_add_ghost_pad ( - audio_thread, gst_element_get_pad (audio_queue, "sink"), - "sink"); - - gst_bin_add (GST_BIN (play->pipeline), audio_thread); - - return TRUE; + /* creating pipeline */ + play->pipeline = gst_pipeline_new ("main_pipeline"); + g_return_val_if_fail (GST_IS_PIPELINE (play->pipeline), FALSE); + + /* 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; + } + + /* Adding element to bin */ + gst_bin_add (GST_BIN (play->pipeline), play->source); + + /* create audio thread */ + audio_thread = gst_thread_new ("audio_thread"); + g_return_val_if_fail (GST_IS_THREAD (audio_thread), FALSE); + + g_hash_table_insert (play->other_elements, "audio_thread", audio_thread); + + /* create audio queue */ + audio_queue = gst_element_factory_make ("queue", "audio_queue"); + if (!audio_queue) + { + gst_play_error_plugin (GST_PLAY_ERROR_QUEUE, error); + return FALSE; + } + + g_hash_table_insert (play->other_elements, "audio_queue", audio_queue); + + /* create source element */ + play->volume = gst_element_factory_make ("volume", "volume"); + if (!play->volume) + { + gst_play_error_plugin (GST_PLAY_ERROR_VOLUME, error); + return FALSE; + } + + /* create audiosink. */ + play->audio_sink = gst_element_factory_make ("fakesink", "play_audio"); + if (play->audio_sink == NULL) + { + gst_play_error_plugin (GST_PLAY_ERROR_FAKESINK, error); + return FALSE; + } + + gst_bin_add_many (GST_BIN (audio_thread), audio_queue, play->volume, + play->audio_sink, NULL); + + gst_element_link_many (audio_queue, play->volume, play->audio_sink); + + gst_element_add_ghost_pad (audio_thread, + gst_element_get_pad (audio_queue, "sink"), + "sink"); + + gst_bin_add (GST_BIN (play->pipeline), audio_thread); + + return TRUE; } 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; - - 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); + GstElement *audio_thread; - audio_thread = g_hash_table_lookup(play->other_elements, "audio_thread"); + 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); - if (play->audio_sink) - { - gst_element_unlink (play->volume, play->audio_sink); - gst_bin_remove (GST_BIN (audio_thread), play->audio_sink); - } + audio_thread = g_hash_table_lookup (play->other_elements, "audio_thread"); - play->audio_sink = 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, - 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); - } - - return TRUE; + if (play->audio_sink) + { + gst_element_unlink (play->volume, play->audio_sink); + gst_bin_remove (GST_BIN (audio_thread), play->audio_sink); + } + + play->audio_sink = 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, + 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); + } + + return TRUE; } static gboolean -gst_play_audioht_set_auto ( GstPlay *play, - GstElement *autoplugger) +gst_play_audioht_set_auto (GstPlay * play, GstElement * autoplugger) { - GstElement *audio_thread; - - g_return_val_if_fail (play != NULL, FALSE); - g_return_val_if_fail (autoplugger != NULL, FALSE); - g_return_val_if_fail (GST_IS_PLAY(play), FALSE); - g_return_val_if_fail (GST_IS_ELEMENT (autoplugger), FALSE); - - 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 */ - gst_element_unlink (play->autoplugger, audio_thread); - gst_element_unlink (play->autoplugger, play->source); - gst_bin_remove (GST_BIN (play->pipeline), play->autoplugger); - } - - play->autoplugger = autoplugger; - g_return_val_if_fail (play->autoplugger != NULL, FALSE); - - gst_bin_add (GST_BIN (play->pipeline), play->autoplugger); - gst_element_link (play->source, play->autoplugger); - gst_element_link (play->autoplugger, audio_thread); - return TRUE; + GstElement *audio_thread; + + g_return_val_if_fail (play != NULL, FALSE); + g_return_val_if_fail (autoplugger != NULL, FALSE); + g_return_val_if_fail (GST_IS_PLAY (play), FALSE); + g_return_val_if_fail (GST_IS_ELEMENT (autoplugger), FALSE); + + 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 */ + gst_element_unlink (play->autoplugger, audio_thread); + gst_element_unlink (play->autoplugger, play->source); + gst_bin_remove (GST_BIN (play->pipeline), play->autoplugger); + } + + play->autoplugger = autoplugger; + g_return_val_if_fail (play->autoplugger != NULL, FALSE); + + gst_bin_add (GST_BIN (play->pipeline), play->autoplugger); + gst_element_link (play->source, play->autoplugger); + gst_element_link (play->autoplugger, audio_thread); + return TRUE; } /* @@ -385,272 +376,259 @@ gst_play_audioht_set_auto ( GstPlay *play, * spider0.src2 ! { queue ! colorspace ! (videosink) } } */ -static gboolean -gst_play_video_setup ( GstPlay *play, - GError **error) +static gboolean +gst_play_video_setup (GstPlay * play, GError ** error) { - GstElement *audio_bin, *audio_queue; - GstElement *video_queue, *video_bin; - GstElement *work_thread, *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); - - /* creating volume element */ - play->volume = gst_element_factory_make ("volume", "volume"); - if (!play->volume) - { - gst_play_error_plugin (GST_PLAY_ERROR_VOLUME, error); - return FALSE; - } - - /* creating audio_sink element */ - play->audio_sink = gst_element_factory_make ("fakesink", "fake_audio"); - if (!play->audio_sink) - { - gst_play_error_plugin (GST_PLAY_ERROR_FAKESINK, error); - return FALSE; - } - play->audio_sink_element = NULL; - - /* creating audio_queue element */ - audio_queue = gst_element_factory_make ("queue", "audio_queue"); - if (!audio_queue) - { - gst_play_error_plugin (GST_PLAY_ERROR_QUEUE, error); - return FALSE; - } - g_hash_table_insert (play->other_elements, "audio_queue", audio_queue); - - /* creating audio thread */ - audio_bin = gst_thread_new ("audio_bin"); - if (!audio_bin) - { - gst_play_error_plugin (GST_PLAY_ERROR_THREAD, error); - return FALSE; - } - g_hash_table_insert (play->other_elements, "audio_bin", audio_bin); - - /* adding all that stuff to bin */ - gst_bin_add_many ( - GST_BIN (audio_bin), audio_queue, play->volume, - play->audio_sink, NULL); - gst_element_link_many (audio_queue, play->volume, - play->audio_sink, NULL); - - gst_element_add_ghost_pad ( - audio_bin, - gst_element_get_pad (audio_queue, "sink"), - "sink"); - - gst_bin_add (GST_BIN (work_thread), audio_bin); - - /* 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_bin"); - 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); - - 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; + GstElement *audio_bin, *audio_queue; + GstElement *video_queue, *video_bin; + GstElement *work_thread, *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); + + /* creating volume element */ + play->volume = gst_element_factory_make ("volume", "volume"); + if (!play->volume) + { + gst_play_error_plugin (GST_PLAY_ERROR_VOLUME, error); + return FALSE; + } + + /* creating audio_sink element */ + play->audio_sink = gst_element_factory_make ("fakesink", "fake_audio"); + if (!play->audio_sink) + { + gst_play_error_plugin (GST_PLAY_ERROR_FAKESINK, error); + return FALSE; + } + play->audio_sink_element = NULL; + + /* creating audio_queue element */ + audio_queue = gst_element_factory_make ("queue", "audio_queue"); + if (!audio_queue) + { + gst_play_error_plugin (GST_PLAY_ERROR_QUEUE, error); + return FALSE; + } + g_hash_table_insert (play->other_elements, "audio_queue", audio_queue); + + /* creating audio thread */ + audio_bin = gst_thread_new ("audio_bin"); + if (!audio_bin) + { + gst_play_error_plugin (GST_PLAY_ERROR_THREAD, error); + return FALSE; + } + g_hash_table_insert (play->other_elements, "audio_bin", audio_bin); + + /* adding all that stuff to bin */ + gst_bin_add_many (GST_BIN (audio_bin), audio_queue, play->volume, + play->audio_sink, NULL); + gst_element_link_many (audio_queue, play->volume, play->audio_sink, NULL); + + gst_element_add_ghost_pad (audio_bin, + gst_element_get_pad (audio_queue, "sink"), + "sink"); + + gst_bin_add (GST_BIN (work_thread), audio_bin); + + /* 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_bin"); + 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); + + 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_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 (play != NULL, FALSE); - g_return_val_if_fail (datasrc != NULL, FALSE); - g_return_val_if_fail (GST_IS_PLAY(play), FALSE); - g_return_val_if_fail (GST_IS_ELEMENT(datasrc), FALSE); - - work_thread = g_hash_table_lookup(play->other_elements, "work_thread"); - return gst_play_default_set_data_src(play, datasrc, work_thread); + GstElement *work_thread; + g_return_val_if_fail (play != NULL, FALSE); + g_return_val_if_fail (datasrc != NULL, FALSE); + g_return_val_if_fail (GST_IS_PLAY (play), FALSE); + g_return_val_if_fail (GST_IS_ELEMENT (datasrc), FALSE); + + work_thread = g_hash_table_lookup (play->other_elements, "work_thread"); + return gst_play_default_set_data_src (play, datasrc, work_thread); } 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; + GstElement *audio_bin, *video_bin, *work_thread; - g_return_val_if_fail (play != NULL, FALSE); - g_return_val_if_fail (autoplugger != NULL, FALSE); - g_return_val_if_fail (GST_IS_PLAY(play), FALSE); - g_return_val_if_fail (GST_IS_ELEMENT (autoplugger), FALSE); + g_return_val_if_fail (play != NULL, FALSE); + g_return_val_if_fail (autoplugger != NULL, FALSE); + g_return_val_if_fail (GST_IS_PLAY (play), FALSE); + g_return_val_if_fail (GST_IS_ELEMENT (autoplugger), FALSE); - audio_bin = g_hash_table_lookup(play->other_elements, "audio_bin"); - video_bin = g_hash_table_lookup(play->other_elements, "video_bin"); - work_thread = g_hash_table_lookup(play->other_elements, "work_thread"); + audio_bin = g_hash_table_lookup (play->other_elements, "audio_bin"); + video_bin = g_hash_table_lookup (play->other_elements, "video_bin"); + 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 */ - gst_element_unlink (play->autoplugger, audio_bin); - gst_element_unlink (play->autoplugger, play->source); - gst_element_unlink (play->autoplugger, video_bin); + if (play->autoplugger) + { + /* 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); - gst_bin_remove (GST_BIN (work_thread), play->autoplugger); - } - - play->autoplugger = autoplugger; - g_return_val_if_fail (play->autoplugger != NULL, FALSE); + gst_bin_remove (GST_BIN (work_thread), play->autoplugger); + } - gst_bin_add (GST_BIN (work_thread), play->autoplugger); - gst_element_link (play->source, play->autoplugger); - gst_element_link (play->autoplugger, audio_bin); - gst_element_link (play->autoplugger, video_bin); + play->autoplugger = autoplugger; + g_return_val_if_fail (play->autoplugger != NULL, FALSE); - return TRUE; + gst_bin_add (GST_BIN (work_thread), play->autoplugger); + gst_element_link (play->source, play->autoplugger); + gst_element_link (play->autoplugger, audio_bin); + gst_element_link (play->autoplugger, video_bin); + + return TRUE; } 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; - - 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; + 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; } 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; - - 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, "audio_bin"); - - if (play->audio_sink) - { - gst_element_unlink (play->volume, play->audio_sink); - gst_bin_remove (GST_BIN (audio_bin), play->audio_sink); - } + GstElement *audio_bin; - play->audio_sink = 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, - 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); - } + 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, "audio_bin"); + + if (play->audio_sink) + { + gst_element_unlink (play->volume, play->audio_sink); + gst_bin_remove (GST_BIN (audio_bin), play->audio_sink); + } + + play->audio_sink = 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, + GST_PLAY_SINK_TYPE_AUDIO); - return TRUE; + 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); + } + + return TRUE; } /* @@ -659,331 +637,295 @@ gst_play_video_set_audio ( GstPlay *play, * spider0.src2 ! { queue ! colorspace ! (videosink) } } */ -static gboolean -gst_play_video_vis_setup ( GstPlay *play, - GError **error) +static gboolean +gst_play_video_vis_setup (GstPlay * play, GError ** error) { - - GstElement *work_thread, *tee_element; - GstPad *tee_vis_pad, *tee_audio_pad; - GstPad *audio_sink_pad, *vis_video_thread_pad; - GstElement *vis_video_thread; - GstElement *audio_queue, *audio_sink; - GstElement *vis_colorspace, *vis_video_queue, *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_thread_new ("audio_thread"); - 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); - - audio_queue = gst_element_factory_make ("queue", "audio_queue"); - if (!audio_queue) - { - gst_play_error_plugin (GST_PLAY_ERROR_QUEUE, error); - return FALSE; - } - g_hash_table_insert ( play->other_elements, - "audio_queue", - audio_queue); - - 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); - - audio_sink = gst_element_factory_make ("fakesink", "audio_sink"); - if (!audio_sink) - { - gst_play_error_plugin (GST_PLAY_ERROR_FAKESINK, error); - return FALSE; - } - g_hash_table_insert ( play->other_elements, - "audio_sink", - audio_sink); - - audio_sink_pad = gst_element_get_pad (audio_sink, "sink"); - g_hash_table_insert ( play->other_elements, - "audio_sink_pad", - audio_sink_pad); - - play->audio_sink_element = NULL; - - - gst_bin_add_many ( GST_BIN (play->audio_sink), - audio_queue, play->volume, - tee_element, audio_sink, NULL); - gst_element_link_many ( audio_queue, play->volume, - tee_element, NULL); - - gst_pad_link ( tee_audio_pad, audio_sink_pad); - - gst_element_add_ghost_pad ( play->audio_sink, - gst_element_get_pad (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); - - - 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); - - 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; + GstElement *work_thread, *tee_element; + GstPad *tee_vis_pad, *tee_audio_pad; + GstPad *audio_sink_pad, *vis_video_thread_pad; + GstElement *vis_video_thread; + GstElement *audio_queue, *audio_sink; + GstElement *vis_colorspace, *vis_video_queue, *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_thread_new ("audio_thread"); + 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); + + audio_queue = gst_element_factory_make ("queue", "audio_queue"); + if (!audio_queue) + { + gst_play_error_plugin (GST_PLAY_ERROR_QUEUE, error); + return FALSE; + } + g_hash_table_insert (play->other_elements, "audio_queue", audio_queue); + + 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); + + audio_sink = gst_element_factory_make ("fakesink", "audio_sink"); + if (!audio_sink) + { + gst_play_error_plugin (GST_PLAY_ERROR_FAKESINK, error); + return FALSE; + } + g_hash_table_insert (play->other_elements, "audio_sink", audio_sink); + + audio_sink_pad = gst_element_get_pad (audio_sink, "sink"); + g_hash_table_insert (play->other_elements, + "audio_sink_pad", audio_sink_pad); + + play->audio_sink_element = NULL; + + + gst_bin_add_many (GST_BIN (play->audio_sink), + audio_queue, play->volume, tee_element, audio_sink, NULL); + gst_element_link_many (audio_queue, play->volume, tee_element, NULL); + + gst_pad_link (tee_audio_pad, audio_sink_pad); + + gst_element_add_ghost_pad (play->audio_sink, + gst_element_get_pad (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); + + + 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); + + 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) +gst_play_video_vis_set_audio (GstPlay * play, GstElement * audio_sink) { - GstElement *audio_bin, *vis_audio_sink; - GstPad *audio_sink_pad, *tee_audio_pad; - - 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, - "audio_bin"); - vis_audio_sink = g_hash_table_lookup ( play->other_elements, - "audio_sink"); - audio_sink_pad = g_hash_table_lookup ( play->other_elements, - "audio_sink_pad"); - tee_audio_pad = g_hash_table_lookup ( play->other_elements, - "tee_audio_pad"); - - if ( (vis_audio_sink) && GST_IS_ELEMENT(vis_audio_sink) ) - { - gst_pad_unlink (tee_audio_pad, audio_sink_pad); - gst_bin_remove (GST_BIN (audio_bin), vis_audio_sink); - } + GstElement *audio_bin, *vis_audio_sink; + GstPad *audio_sink_pad, *tee_audio_pad; - gst_bin_add (GST_BIN (audio_bin), audio_sink); - - audio_sink_pad = gst_element_get_pad (audio_sink,"sink"); - - gst_pad_link (tee_audio_pad, audio_sink_pad); - - g_hash_table_replace( play->other_elements, - "audio_sink", - audio_sink); - - g_hash_table_replace( play->other_elements, - "audio_sink_pad", - audio_sink_pad); - - 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); - } + 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, "audio_bin"); + vis_audio_sink = g_hash_table_lookup (play->other_elements, "audio_sink"); + audio_sink_pad = g_hash_table_lookup (play->other_elements, + "audio_sink_pad"); + tee_audio_pad = g_hash_table_lookup (play->other_elements, "tee_audio_pad"); - return TRUE; + if ((vis_audio_sink) && GST_IS_ELEMENT (vis_audio_sink)) + { + gst_pad_unlink (tee_audio_pad, audio_sink_pad); + gst_bin_remove (GST_BIN (audio_bin), vis_audio_sink); + } + + gst_bin_add (GST_BIN (audio_bin), audio_sink); + + audio_sink_pad = gst_element_get_pad (audio_sink, "sink"); + + gst_pad_link (tee_audio_pad, audio_sink_pad); + + g_hash_table_replace (play->other_elements, "audio_sink", audio_sink); + + g_hash_table_replace (play->other_elements, + "audio_sink_pad", audio_sink_pad); + + 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) +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; + 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; } /** @@ -996,54 +938,49 @@ gst_play_video_vis_set_video ( GstPlay *play, * Returns: TRUE if call succeeded. */ gboolean -gst_play_set_visualisation_video_sink ( GstPlay *play, - GstElement *video_sink) +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; + 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; } /** @@ -1056,39 +993,35 @@ gst_play_set_visualisation_video_sink ( GstPlay *play, * Returns: TRUE if call succeeded. */ gboolean -gst_play_set_visualisation_element ( GstPlay *play, - GstElement *element) +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; + 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; } /** @@ -1102,41 +1035,42 @@ gst_play_set_visualisation_element ( GstPlay *play, * Returns: TRUE if call succeeded. */ gboolean -gst_play_connect_visualisation ( GstPlay *play, - gboolean connect) +gst_play_connect_visualisation (GstPlay * play, gboolean connect) { - GstPad *tee_vis_pad, *vis_video_thread_pad; - GstElement *vis_video_thread; - gboolean connected = FALSE; - - 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"); - vis_video_thread = g_hash_table_lookup( play->other_elements, - "vis_video_thread"); - - if (gst_pad_get_peer (vis_video_thread_pad) != NULL) - connected = TRUE; - else - connected = FALSE; - - if ( (connect) && (!connected) ) { - gst_pad_link (tee_vis_pad, vis_video_thread_pad); - } - else if ( (!connect) && (connected) ){ - gst_pad_unlink (tee_vis_pad, vis_video_thread_pad); - } - - if ( GST_IS_ELEMENT(vis_video_thread) && GST_IS_ELEMENT(play->pipeline) ) { - gst_element_set_state ( vis_video_thread, - gst_element_get_state (play->pipeline)); - } - - return TRUE; + GstPad *tee_vis_pad, *vis_video_thread_pad; + GstElement *vis_video_thread; + gboolean connected = FALSE; + + 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"); + vis_video_thread = g_hash_table_lookup (play->other_elements, + "vis_video_thread"); + + if (gst_pad_get_peer (vis_video_thread_pad) != NULL) + connected = TRUE; + else + connected = FALSE; + + if ((connect) && (!connected)) + { + gst_pad_link (tee_vis_pad, vis_video_thread_pad); + } + else if ((!connect) && (connected)) + { + gst_pad_unlink (tee_vis_pad, vis_video_thread_pad); + } + + if (GST_IS_ELEMENT (vis_video_thread) && GST_IS_ELEMENT (play->pipeline)) + { + gst_element_set_state (vis_video_thread, + gst_element_get_state (play->pipeline)); + } + + return TRUE; } /* modelines */ |