mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-11-26 19:51:11 +00:00
Code Issues 1 Projects Releases Wiki Activity

GESTimelinePipeline: More render support

Browse source
This commit is contained in:
Edward Hervey 2009-12-09 12:22:34 +01:00
parent 2d430098f8
commit aedf73803d
1 changed files with 99 additions and 37 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

136
ges/ges-timeline-pipeline.c
View file

@ -37,8 +37,8 @@
typedef struct typedef struct
{ {
GESTimelinePipeline *pipeline; GESTimelinePipeline *pipeline;
GstElement *queue; GstElement *tee;
GstPad *srcpad; GstPad *srcpad; /* Timeline source pad */
GstPad *playsinkpad; GstPad *playsinkpad;
GstPad *encodebinpad; GstPad *encodebinpad;
} OutputChain; } OutputChain;
@ -170,7 +170,6 @@ pad_added_cb (GstElement * timeline, GstPad * pad, GESTimelinePipeline * self)
{ {
OutputChain *chain; OutputChain *chain;
GESTrack *track; GESTrack *track;
const gchar *sinkpad_name;
GstPad *sinkpad; GstPad *sinkpad;
gboolean reconfigured = FALSE; gboolean reconfigured = FALSE;
@ -184,50 +183,111 @@ pad_added_cb (GstElement * timeline, GstPad * pad, GESTimelinePipeline * self)
return; return;
} }
switch (track->type) { /* Don't connect track if it's not going to be used */
case GES_TRACK_TYPE_VIDEO: if (track->type == GES_TRACK_TYPE_VIDEO &&
sinkpad_name = "video_sink"; !(self->mode & TIMELINE_MODE_PREVIEW_VIDEO) &&
break; !(self->mode & TIMELINE_MODE_RENDER)) {
case GES_TRACK_TYPE_AUDIO: GST_DEBUG_OBJECT (self, "Video track... but we don't need it. Not linking");
sinkpad_name = "audio_sink";
break;
case GES_TRACK_TYPE_TEXT:
sinkpad_name = "text_sink";
break;
default:
GST_WARNING_OBJECT (self, "Can't handle tracks of type %d yet",
track->type);
return;
} }
if (track->type == GES_TRACK_TYPE_AUDIO &&
/* Request a sinkpad from playsink */ !(self->mode & TIMELINE_MODE_PREVIEW_AUDIO) &&
if (G_UNLIKELY (!(sinkpad = !(self->mode & TIMELINE_MODE_RENDER)) {
gst_element_get_request_pad (self->playsink, sinkpad_name)))) { GST_DEBUG_OBJECT (self, "Audio track... but we don't need it. Not linking");
GST_WARNING_OBJECT (self, "Couldn't get a pad from the playsink !");
return;
} }
if (G_UNLIKELY (gst_pad_link (pad, sinkpad) != GST_PAD_LINK_OK)) {
GST_WARNING_OBJECT (self, "Couldn't link track pad to playsink");
gst_object_unref (sinkpad);
return;
}
GST_DEBUG ("Reconfiguring playsink");
/* reconfigure playsink */
g_signal_emit_by_name (self->playsink, "reconfigure", &reconfigured);
GST_DEBUG ("'reconfigure' returned %d", reconfigured);
/* Create a new chain */ /* Create a new chain */
chain = g_new0 (OutputChain, 1); chain = g_new0 (OutputChain, 1);
chain->pipeline = self; chain->pipeline = self;
chain->srcpad = pad; chain->srcpad = pad;
chain->playsinkpad = sinkpad;
/* Adding tee */
chain->tee = gst_element_factory_make ("tee", NULL);
gst_bin_add (GST_BIN_CAST (self), chain->tee);
/* Linking pad to tee */
sinkpad = gst_element_get_pad (chain->tee, "sink");
gst_pad_link (pad, sinkpad);
/* Connect playsink */
if (self->mode & TIMELINE_MODE_PREVIEW) {
const gchar *sinkpad_name;
GST_DEBUG_OBJECT (self, "Connecting to playsink");
switch (track->type) {
case GES_TRACK_TYPE_VIDEO:
sinkpad_name = "video_sink";
break;
case GES_TRACK_TYPE_AUDIO:
sinkpad_name = "audio_sink";
break;
case GES_TRACK_TYPE_TEXT:
sinkpad_name = "text_sink";
break;
default:
GST_WARNING_OBJECT (self, "Can't handle tracks of type %d yet",
track->type);
goto error;
}
/* Request a sinkpad from playsink */
if (G_UNLIKELY (!(sinkpad =
gst_element_get_request_pad (self->playsink, sinkpad_name)))) {
GST_WARNING_OBJECT (self, "Couldn't get a pad from the playsink !");
goto error;
}
if (G_UNLIKELY (gst_pad_link (gst_element_get_request_pad (chain->tee,
"src%d"), sinkpad) != GST_PAD_LINK_OK)) {
GST_WARNING_OBJECT (self, "Couldn't link track pad to playsink");
goto error;
}
GST_DEBUG ("Reconfiguring playsink");
/* reconfigure playsink */
g_signal_emit_by_name (self->playsink, "reconfigure", &reconfigured);
GST_DEBUG ("'reconfigure' returned %d", reconfigured);
chain->playsinkpad = sinkpad;
}
/* Connect to encodebin */
if (self->mode & TIMELINE_MODE_RENDER) {
GST_DEBUG_OBJECT (self, "Connecting to encodebin");
sinkpad = NULL;
g_signal_emit_by_name (self->encodebin, "request-pad",
gst_pad_get_caps (pad), &sinkpad);
if (G_UNLIKELY (sinkpad == NULL)) {
GST_WARNING_OBJECT (self, "Couldn't get a pad from encodebin !");
goto error;
}
if (G_UNLIKELY (gst_pad_link (gst_element_get_request_pad (chain->tee,
"src%d"), sinkpad) != GST_PAD_LINK_OK)) {
GST_WARNING_OBJECT (self, "Couldn't link track pad to playsink");
goto error;
}
chain->encodebinpad = sinkpad;
}
self->chains = g_list_append (self->chains, chain); self->chains = g_list_append (self->chains, chain);
GST_DEBUG ("done"); GST_DEBUG ("done");
return;
error:
{
if (chain->tee) {
gst_bin_remove (GST_BIN_CAST (self), chain->tee);
gst_object_unref (chain->tee);
}
if (sinkpad)
gst_object_unref (sinkpad);
g_free (chain);
}
} }
static void static void
@ -236,6 +296,7 @@ pad_removed_cb (GstElement * timeline, GstPad * pad, GESTimelinePipeline * self)
GST_DEBUG_OBJECT (self, "pad removed %s:%s", GST_DEBUG_PAD_NAME (pad)); GST_DEBUG_OBJECT (self, "pad removed %s:%s", GST_DEBUG_PAD_NAME (pad));
/* FIXME : IMPLEMENT ! */ /* FIXME : IMPLEMENT ! */
GST_WARNING_OBJECT (self, "IMPLEMENTE ME !");
GST_DEBUG ("done"); GST_DEBUG ("done");
} }
@ -261,7 +322,8 @@ ges_timeline_pipeline_add_timeline (GESTimelinePipeline * pipeline,
GST_DEBUG ("pipeline:%p, timeline:%p", timeline, pipeline); GST_DEBUG ("pipeline:%p, timeline:%p", timeline, pipeline);
if (G_UNLIKELY (!gst_bin_add (GST_BIN (pipeline), GST_ELEMENT (timeline)))) { if (G_UNLIKELY (!gst_bin_add (GST_BIN_CAST (pipeline),
GST_ELEMENT (timeline)))) {
return FALSE; return FALSE;
} }
pipeline->timeline = timeline; pipeline->timeline = timeline;