diff options
Diffstat (limited to 'gst-libs/gst/play/playpipelines.c')
| -rw-r--r-- | gst-libs/gst/play/playpipelines.c | 1852 |
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 */ |