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