gst-libs/gst/play/gstplay.c: Preparing switch integration, adding videobalance in the pipeline.

Original commit message from CVS:
2004-01-14  Julien MOUTTE  <julien@moutte.net>

* gst-libs/gst/play/gstplay.c: (gst_play_pipeline_setup),
(gst_play_set_location), (gst_play_set_visualization): Preparing
switch integration, adding videobalance in the pipeline.
This commit is contained in:
Julien Moutte 2004-01-14 21:50:39 +00:00
parent 2e376792cb
commit ab07e8f25a
3 changed files with 132 additions and 60 deletions

View file

@ -1,3 +1,9 @@
2004-01-14 Julien MOUTTE <julien@moutte.net>
* gst-libs/gst/play/gstplay.c: (gst_play_pipeline_setup),
(gst_play_set_location), (gst_play_set_visualization): Preparing
switch integration, adding videobalance in the pipeline.
2004-01-14 Julien MOUTTE <julien@moutte.net>
* gst-libs/gst/colorbalance/colorbalance.c:

View file

@ -59,11 +59,11 @@ static GstPipelineClass *parent_class = NULL;
static gboolean
gst_play_pipeline_setup (GstPlay *play)
{
GstElement *work_thread, *video_thread;
GstElement *source, *autoplugger, *video_switch;
GstElement *video_queue, *video_colorspace, *video_scaler, *video_sink;
GstElement *work_thread, *video_thread, *source;
GstElement *autoplugger, *switch_colorspace, *video_switch, *video_queue;
GstElement *video_balance, *video_colorspace, *video_scaler, *video_sink;
GstElement *audio_thread, *audio_queue, *audio_volume, *audio_sink;
GstElement *audio_tee, *vis_thread, *vis_queue, *vis_element;
GstElement *audio_tee, *vis_thread, *vis_queue, *vis_element, *end_vis_queue;
GstPad *audio_tee_pad1, *audio_tee_pad2, *vis_thread_pad, *audio_sink_pad;
g_return_val_if_fail (play != NULL, FALSE);
@ -76,7 +76,7 @@ gst_play_pipeline_setup (GstPlay *play)
g_hash_table_insert (play->priv->elements, "work_thread", work_thread);
gst_bin_add (GST_BIN (play), work_thread);
/* Placeholder for the source and autoplugger { fakesrc ! spider } */
/* Placeholder for the source and autoplugger { fakesrc ! spider } */
source = gst_element_factory_make ("fakesrc", "source");
if (!GST_IS_ELEMENT (source))
return FALSE;
@ -93,7 +93,7 @@ gst_play_pipeline_setup (GstPlay *play)
gst_element_link (source, autoplugger);
/* Creating our video output bin
{ queue ! colorspace ! videoscale ! fakesink } */
{ queue ! videobalance ! colorspace ! videoscale ! fakesink } */
video_thread = gst_element_factory_make ("thread", "video_thread");
if (!GST_IS_ELEMENT (video_thread))
return FALSE;
@ -108,6 +108,14 @@ gst_play_pipeline_setup (GstPlay *play)
g_hash_table_insert (play->priv->elements, "video_queue", video_queue);
video_balance = gst_element_factory_make ("videobalance",
"video_balance");
if (!GST_IS_ELEMENT (video_balance))
return FALSE;
g_hash_table_insert (play->priv->elements, "video_balance",
video_balance);
/* Colorspace conversion */
video_colorspace = gst_element_factory_make ("ffcolorspace",
"video_colorspace");
@ -136,13 +144,27 @@ gst_play_pipeline_setup (GstPlay *play)
g_hash_table_insert (play->priv->elements, "video_sink", video_sink);
/* Linking, Adding, Ghosting */
gst_element_link_many (video_queue, video_colorspace,
gst_element_link_many (video_queue, video_balance, video_colorspace,
video_scaler, video_sink, NULL);
gst_bin_add_many (GST_BIN (video_thread), video_queue, video_colorspace,
video_scaler, video_sink, NULL);
gst_bin_add_many (GST_BIN (video_thread), video_queue, video_balance,
video_colorspace, video_scaler, video_sink, NULL);
gst_element_add_ghost_pad (video_thread,
gst_element_get_pad (video_queue, "sink"),
"sink");
"sink");
/* autoplugger ! ffcolorspace ! switch */
switch_colorspace = NULL;
switch_colorspace = gst_element_factory_make ("ffcolorspace",
"switch_colorspace");
if (!GST_IS_ELEMENT (switch_colorspace)) {
switch_colorspace = gst_element_factory_make ("colorspace",
"switch_colorspace");
if (!GST_IS_ELEMENT (switch_colorspace))
return FALSE;
}
g_hash_table_insert (play->priv->elements, "switch_colorspace",
switch_colorspace);
video_switch = gst_element_factory_make ("switch",
"video_switch");
@ -151,12 +173,13 @@ gst_play_pipeline_setup (GstPlay *play)
g_hash_table_insert (play->priv->elements, "video_switch", video_switch);
/*gst_bin_add (GST_BIN (work_thread), video_switch);*/
gst_bin_add_many (GST_BIN (work_thread), switch_colorspace,
/*video_switch,*/ NULL);
/* Connecting autoplugger to video switch and video switch to video output
gst_element_link (autoplugger, video_switch);
gst_element_link (video_switch, video_thread);*/
gst_element_link (autoplugger, video_thread);
/* Connecting autoplugger to video switch and video switch to video output */
gst_element_link_many (autoplugger, switch_colorspace,
/*video_switch,*/ video_thread, NULL);
/* gst_element_link (autoplugger, video_thread); */
/* Creating our audio output bin
{ queue ! volume ! tee ! { queue ! goom } ! fakesink } */
@ -224,12 +247,20 @@ gst_play_pipeline_setup (GstPlay *play)
g_hash_table_insert (play->priv->elements, "vis_element", vis_element);
end_vis_queue = gst_element_factory_make ("queue", "end_vis_queue");
if (!GST_IS_ELEMENT (end_vis_queue))
return FALSE;
g_hash_table_insert (play->priv->elements, "end_vis_queue",
end_vis_queue);
/* Adding, Linking, Ghosting in visualization */
gst_bin_add_many (GST_BIN (vis_thread), vis_queue, vis_element, NULL);
gst_element_link (vis_queue, vis_element);
gst_bin_add_many (GST_BIN (vis_thread), vis_queue, vis_element,
end_vis_queue, NULL);
gst_element_link_many (vis_queue, vis_element, end_vis_queue, NULL);
vis_thread_pad = gst_element_add_ghost_pad (vis_thread,
gst_element_get_pad (vis_queue, "sink"),
"sink");
"sink");
g_hash_table_insert (play->priv->elements, "vis_thread_pad",
vis_thread_pad);
@ -241,7 +272,7 @@ gst_play_pipeline_setup (GstPlay *play)
audio_tee, vis_thread, audio_sink, NULL);
gst_element_add_ghost_pad (audio_thread,
gst_element_get_pad (audio_queue, "sink"),
"sink");
"sink");
/* Connecting audio output to autoplugger */
gst_element_link (autoplugger, audio_thread);
@ -473,7 +504,8 @@ gst_play_class_init (GstPlayClass *klass)
gboolean
gst_play_set_location (GstPlay *play, const char *location)
{
GstElement *work_thread, *source, *autoplugger, *video_thread, *audio_thread;
GstElement *work_thread, *source, *autoplugger;
GstElement *switch_colorspace, *audio_thread;
g_return_val_if_fail (play != NULL, FALSE);
g_return_val_if_fail (GST_IS_PLAY (play), FALSE);
@ -489,8 +521,9 @@ gst_play_set_location (GstPlay *play, const char *location)
work_thread = g_hash_table_lookup (play->priv->elements, "work_thread");
if (!GST_IS_ELEMENT (work_thread))
return FALSE;
video_thread = g_hash_table_lookup (play->priv->elements, "video_thread");
if (!GST_IS_ELEMENT (video_thread))
switch_colorspace = g_hash_table_lookup (play->priv->elements,
"switch_colorspace");
if (!GST_IS_ELEMENT (switch_colorspace))
return FALSE;
audio_thread = g_hash_table_lookup (play->priv->elements, "audio_thread");
if (!GST_IS_ELEMENT (audio_thread))
@ -505,7 +538,7 @@ gst_play_set_location (GstPlay *play, const char *location)
/* Spider can autoplugg only once. We remove the actual one and put a new
autoplugger */
gst_element_unlink (source, autoplugger);
gst_element_unlink (autoplugger, video_thread);
gst_element_unlink (autoplugger, switch_colorspace);
gst_element_unlink (autoplugger, audio_thread);
gst_bin_remove (GST_BIN (work_thread), autoplugger);
@ -515,7 +548,7 @@ gst_play_set_location (GstPlay *play, const char *location)
gst_bin_add (GST_BIN (work_thread), autoplugger);
gst_element_link (source, autoplugger);
gst_element_link (autoplugger, video_thread);
gst_element_link (autoplugger, switch_colorspace);
gst_element_link (autoplugger, audio_thread);
g_hash_table_replace (play->priv->elements, "autoplugger", autoplugger);
@ -778,7 +811,7 @@ gst_play_set_audio_sink (GstPlay *play, GstElement *audio_sink)
gboolean
gst_play_set_visualization (GstPlay *play, GstElement *vis_element)
{
GstElement *old_vis_element, *vis_thread, *vis_queue/*, *video_switch*/;
GstElement *old_vis_element, *vis_thread, *vis_queue, *end_vis_queue;
gboolean was_playing = FALSE;
g_return_val_if_fail (play != NULL, FALSE);
@ -803,17 +836,17 @@ gst_play_set_visualization (GstPlay *play, GstElement *vis_element)
vis_queue = g_hash_table_lookup (play->priv->elements, "vis_queue");
if (!GST_IS_ELEMENT (vis_queue))
return FALSE;
/*video_switch = g_hash_table_lookup (play->priv->elements, "video_switch");
if (!GST_IS_ELEMENT (video_switch))
return FALSE;*/
end_vis_queue = g_hash_table_lookup (play->priv->elements, "end_vis_queue");
if (!GST_IS_ELEMENT (end_vis_queue))
return FALSE;
/* Unlinking, removing the old element then adding and linking the new one */
gst_element_unlink (vis_queue, old_vis_element);
/*gst_element_unlink (old_vis_element, video_switch);*/
gst_element_unlink (old_vis_element, end_vis_queue);
gst_bin_remove (GST_BIN (vis_thread), old_vis_element);
gst_bin_add (GST_BIN (vis_thread), vis_element);
gst_element_link (vis_queue, vis_element);
/*gst_element_link (vis_element, video_switch);*/
gst_element_link (vis_element, end_vis_queue);
if (was_playing)
gst_element_set_state (GST_ELEMENT (play), GST_STATE_PLAYING);

View file

@ -59,11 +59,11 @@ static GstPipelineClass *parent_class = NULL;
static gboolean
gst_play_pipeline_setup (GstPlay *play)
{
GstElement *work_thread, *video_thread;
GstElement *source, *autoplugger, *video_switch;
GstElement *video_queue, *video_colorspace, *video_scaler, *video_sink;
GstElement *work_thread, *video_thread, *source;
GstElement *autoplugger, *switch_colorspace, *video_switch, *video_queue;
GstElement *video_balance, *video_colorspace, *video_scaler, *video_sink;
GstElement *audio_thread, *audio_queue, *audio_volume, *audio_sink;
GstElement *audio_tee, *vis_thread, *vis_queue, *vis_element;
GstElement *audio_tee, *vis_thread, *vis_queue, *vis_element, *end_vis_queue;
GstPad *audio_tee_pad1, *audio_tee_pad2, *vis_thread_pad, *audio_sink_pad;
g_return_val_if_fail (play != NULL, FALSE);
@ -76,7 +76,7 @@ gst_play_pipeline_setup (GstPlay *play)
g_hash_table_insert (play->priv->elements, "work_thread", work_thread);
gst_bin_add (GST_BIN (play), work_thread);
/* Placeholder for the source and autoplugger { fakesrc ! spider } */
/* Placeholder for the source and autoplugger { fakesrc ! spider } */
source = gst_element_factory_make ("fakesrc", "source");
if (!GST_IS_ELEMENT (source))
return FALSE;
@ -93,7 +93,7 @@ gst_play_pipeline_setup (GstPlay *play)
gst_element_link (source, autoplugger);
/* Creating our video output bin
{ queue ! colorspace ! videoscale ! fakesink } */
{ queue ! videobalance ! colorspace ! videoscale ! fakesink } */
video_thread = gst_element_factory_make ("thread", "video_thread");
if (!GST_IS_ELEMENT (video_thread))
return FALSE;
@ -108,6 +108,14 @@ gst_play_pipeline_setup (GstPlay *play)
g_hash_table_insert (play->priv->elements, "video_queue", video_queue);
video_balance = gst_element_factory_make ("videobalance",
"video_balance");
if (!GST_IS_ELEMENT (video_balance))
return FALSE;
g_hash_table_insert (play->priv->elements, "video_balance",
video_balance);
/* Colorspace conversion */
video_colorspace = gst_element_factory_make ("ffcolorspace",
"video_colorspace");
@ -136,13 +144,27 @@ gst_play_pipeline_setup (GstPlay *play)
g_hash_table_insert (play->priv->elements, "video_sink", video_sink);
/* Linking, Adding, Ghosting */
gst_element_link_many (video_queue, video_colorspace,
gst_element_link_many (video_queue, video_balance, video_colorspace,
video_scaler, video_sink, NULL);
gst_bin_add_many (GST_BIN (video_thread), video_queue, video_colorspace,
video_scaler, video_sink, NULL);
gst_bin_add_many (GST_BIN (video_thread), video_queue, video_balance,
video_colorspace, video_scaler, video_sink, NULL);
gst_element_add_ghost_pad (video_thread,
gst_element_get_pad (video_queue, "sink"),
"sink");
"sink");
/* autoplugger ! ffcolorspace ! switch */
switch_colorspace = NULL;
switch_colorspace = gst_element_factory_make ("ffcolorspace",
"switch_colorspace");
if (!GST_IS_ELEMENT (switch_colorspace)) {
switch_colorspace = gst_element_factory_make ("colorspace",
"switch_colorspace");
if (!GST_IS_ELEMENT (switch_colorspace))
return FALSE;
}
g_hash_table_insert (play->priv->elements, "switch_colorspace",
switch_colorspace);
video_switch = gst_element_factory_make ("switch",
"video_switch");
@ -151,12 +173,13 @@ gst_play_pipeline_setup (GstPlay *play)
g_hash_table_insert (play->priv->elements, "video_switch", video_switch);
/*gst_bin_add (GST_BIN (work_thread), video_switch);*/
gst_bin_add_many (GST_BIN (work_thread), switch_colorspace,
/*video_switch,*/ NULL);
/* Connecting autoplugger to video switch and video switch to video output
gst_element_link (autoplugger, video_switch);
gst_element_link (video_switch, video_thread);*/
gst_element_link (autoplugger, video_thread);
/* Connecting autoplugger to video switch and video switch to video output */
gst_element_link_many (autoplugger, switch_colorspace,
/*video_switch,*/ video_thread, NULL);
/* gst_element_link (autoplugger, video_thread); */
/* Creating our audio output bin
{ queue ! volume ! tee ! { queue ! goom } ! fakesink } */
@ -224,12 +247,20 @@ gst_play_pipeline_setup (GstPlay *play)
g_hash_table_insert (play->priv->elements, "vis_element", vis_element);
end_vis_queue = gst_element_factory_make ("queue", "end_vis_queue");
if (!GST_IS_ELEMENT (end_vis_queue))
return FALSE;
g_hash_table_insert (play->priv->elements, "end_vis_queue",
end_vis_queue);
/* Adding, Linking, Ghosting in visualization */
gst_bin_add_many (GST_BIN (vis_thread), vis_queue, vis_element, NULL);
gst_element_link (vis_queue, vis_element);
gst_bin_add_many (GST_BIN (vis_thread), vis_queue, vis_element,
end_vis_queue, NULL);
gst_element_link_many (vis_queue, vis_element, end_vis_queue, NULL);
vis_thread_pad = gst_element_add_ghost_pad (vis_thread,
gst_element_get_pad (vis_queue, "sink"),
"sink");
"sink");
g_hash_table_insert (play->priv->elements, "vis_thread_pad",
vis_thread_pad);
@ -241,7 +272,7 @@ gst_play_pipeline_setup (GstPlay *play)
audio_tee, vis_thread, audio_sink, NULL);
gst_element_add_ghost_pad (audio_thread,
gst_element_get_pad (audio_queue, "sink"),
"sink");
"sink");
/* Connecting audio output to autoplugger */
gst_element_link (autoplugger, audio_thread);
@ -473,7 +504,8 @@ gst_play_class_init (GstPlayClass *klass)
gboolean
gst_play_set_location (GstPlay *play, const char *location)
{
GstElement *work_thread, *source, *autoplugger, *video_thread, *audio_thread;
GstElement *work_thread, *source, *autoplugger;
GstElement *switch_colorspace, *audio_thread;
g_return_val_if_fail (play != NULL, FALSE);
g_return_val_if_fail (GST_IS_PLAY (play), FALSE);
@ -489,8 +521,9 @@ gst_play_set_location (GstPlay *play, const char *location)
work_thread = g_hash_table_lookup (play->priv->elements, "work_thread");
if (!GST_IS_ELEMENT (work_thread))
return FALSE;
video_thread = g_hash_table_lookup (play->priv->elements, "video_thread");
if (!GST_IS_ELEMENT (video_thread))
switch_colorspace = g_hash_table_lookup (play->priv->elements,
"switch_colorspace");
if (!GST_IS_ELEMENT (switch_colorspace))
return FALSE;
audio_thread = g_hash_table_lookup (play->priv->elements, "audio_thread");
if (!GST_IS_ELEMENT (audio_thread))
@ -505,7 +538,7 @@ gst_play_set_location (GstPlay *play, const char *location)
/* Spider can autoplugg only once. We remove the actual one and put a new
autoplugger */
gst_element_unlink (source, autoplugger);
gst_element_unlink (autoplugger, video_thread);
gst_element_unlink (autoplugger, switch_colorspace);
gst_element_unlink (autoplugger, audio_thread);
gst_bin_remove (GST_BIN (work_thread), autoplugger);
@ -515,7 +548,7 @@ gst_play_set_location (GstPlay *play, const char *location)
gst_bin_add (GST_BIN (work_thread), autoplugger);
gst_element_link (source, autoplugger);
gst_element_link (autoplugger, video_thread);
gst_element_link (autoplugger, switch_colorspace);
gst_element_link (autoplugger, audio_thread);
g_hash_table_replace (play->priv->elements, "autoplugger", autoplugger);
@ -778,7 +811,7 @@ gst_play_set_audio_sink (GstPlay *play, GstElement *audio_sink)
gboolean
gst_play_set_visualization (GstPlay *play, GstElement *vis_element)
{
GstElement *old_vis_element, *vis_thread, *vis_queue/*, *video_switch*/;
GstElement *old_vis_element, *vis_thread, *vis_queue, *end_vis_queue;
gboolean was_playing = FALSE;
g_return_val_if_fail (play != NULL, FALSE);
@ -803,17 +836,17 @@ gst_play_set_visualization (GstPlay *play, GstElement *vis_element)
vis_queue = g_hash_table_lookup (play->priv->elements, "vis_queue");
if (!GST_IS_ELEMENT (vis_queue))
return FALSE;
/*video_switch = g_hash_table_lookup (play->priv->elements, "video_switch");
if (!GST_IS_ELEMENT (video_switch))
return FALSE;*/
end_vis_queue = g_hash_table_lookup (play->priv->elements, "end_vis_queue");
if (!GST_IS_ELEMENT (end_vis_queue))
return FALSE;
/* Unlinking, removing the old element then adding and linking the new one */
gst_element_unlink (vis_queue, old_vis_element);
/*gst_element_unlink (old_vis_element, video_switch);*/
gst_element_unlink (old_vis_element, end_vis_queue);
gst_bin_remove (GST_BIN (vis_thread), old_vis_element);
gst_bin_add (GST_BIN (vis_thread), vis_element);
gst_element_link (vis_queue, vis_element);
/*gst_element_link (vis_element, video_switch);*/
gst_element_link (vis_element, end_vis_queue);
if (was_playing)
gst_element_set_state (GST_ELEMENT (play), GST_STATE_PLAYING);