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

libs/gst/base/gstbasesink.c: Query the total number of bytes when activating the pad in pull mode.

Browse source 
Original commit message from CVS:
* libs/gst/base/gstbasesink.c: (gst_base_sink_pad_activate_pull),
(gst_base_sink_query):
Query the total number of bytes when activating the pad in pull mode.
Implement duration query in pull mode by using the installed pad convert
function to convert from bytes to the requested format.
This commit is contained in:
Wim Taymans 2008-10-17 13:27:59 +00:00
parent fe07568997
commit 4561f3bf47
2 changed files with 69 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
ChangeLog
View file

@ -1,3 +1,11 @@
2008-10-17 Wim Taymans <wim.taymans@collabora.co.uk>
* libs/gst/base/gstbasesink.c: (gst_base_sink_pad_activate_pull),
(gst_base_sink_query):
Query the total number of bytes when activating the pad in pull mode.
Implement duration query in pull mode by using the installed pad convert
function to convert from bytes to the requested format.
2008-10-16 Wim Taymans <wim.taymans@collabora.co.uk>
* docs/libs/gstreamer-libs-sections.txt:

65
libs/gst/base/gstbasesink.c
View file

@ -3290,20 +3290,40 @@ gst_base_sink_pad_activate_pull (GstPad * pad, gboolean active)
bclass = GST_BASE_SINK_GET_CLASS (basesink);
if (active) {
GstFormat format;
gint64 duration;
/* we mark we have a newsegment here because pull based
* mode works just fine without having a newsegment before the
* first buffer */
gst_segment_init (&basesink->segment, GST_FORMAT_BYTES);
gst_segment_init (basesink->abidata.ABI.clip_segment, GST_FORMAT_BYTES);
format = GST_FORMAT_BYTES;
gst_segment_init (&basesink->segment, format);
gst_segment_init (basesink->abidata.ABI.clip_segment, format);
GST_OBJECT_LOCK (basesink);
basesink->have_newsegment = TRUE;
GST_OBJECT_UNLOCK (basesink);
/* get the peer duration in bytes */
result = gst_pad_query_peer_duration (pad, &format, &duration);
if (result) {
GST_DEBUG_OBJECT (basesink,
"setting duration in bytes to %" G_GINT64_FORMAT, duration);
gst_segment_set_duration (basesink->abidata.ABI.clip_segment, format,
duration);
gst_segment_set_duration (&basesink->segment, format, duration);
} else {
GST_DEBUG_OBJECT (basesink, "unknown duration");
}
if (bclass->activate_pull)
result = bclass->activate_pull (basesink, TRUE);
else
result = FALSE;
if (!result)
goto activate_failed;
/* but if starting the thread fails, set it back */
if (!result)
basesink->pad_mode = GST_ACTIVATE_NONE;
@ -3325,6 +3345,13 @@ gst_base_sink_pad_activate_pull (GstPad * pad, gboolean active)
gst_object_unref (basesink);
return result;
/* ERRORS */
activate_failed:
{
GST_ERROR_OBJECT (basesink, "subclass failed to activate in pull mode");
return FALSE;
}
}
/* send an event to our sinkpad peer. */
@ -3627,9 +3654,39 @@ gst_base_sink_query (GstElement * element, GstQuery * query)
break;
}
case GST_QUERY_DURATION:
GST_DEBUG_OBJECT (basesink, "duration query");
res = gst_base_sink_peer_query (basesink, query);
{
GstFormat format, uformat;
gint64 duration, uduration;
gst_query_parse_duration (query, &format, NULL);
GST_DEBUG_OBJECT (basesink, "duration query in format %s",
gst_format_get_name (format));
if (basesink->pad_mode == GST_ACTIVATE_PULL) {
uformat = GST_FORMAT_BYTES;
/* get the duration in bytes, in pull mode that's all we are sure to
* know. */
res = gst_pad_query_peer_duration (basesink->sinkpad, &uformat,
&uduration);
if (res && format != uformat) {
/* convert to the requested format */
res = gst_pad_query_convert (basesink->sinkpad, uformat, uduration,
&format, &duration);
} else {
duration = uduration;
}
if (res) {
/* set the result */
gst_query_set_duration (query, format, duration);
}
} else {
/* in push mode we simply forward upstream */
res = gst_base_sink_peer_query (basesink, query);
}
break;
}
case GST_QUERY_LATENCY:
{
gboolean live, us_live;