summaryrefslogtreecommitdiffstats
path: root/gst-libs/gst/play/playpipelines.c
diff options
context:
space:
mode:
Diffstat (limited to 'gst-libs/gst/play/playpipelines.c')
-rw-r--r--gst-libs/gst/play/playpipelines.c1852
1 files changed, 893 insertions, 959 deletions
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 */