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

baseparse: do not accumulate buffers on passthrough mode

Browse source 
If on passthrough during reverse playback, do not accumulate buffers as
baseparse will never check for DISCONT flag to push those buffers.
So just push buffers downstream as if it was forward playback.

https://bugzilla.gnome.org/show_bug.cgi?id=721941
This commit is contained in:
Thiago Santos 2014-01-10 09:10:06 -03:00
parent 6a05291ca2
commit a3ff2976cc
1 changed files with 29 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

29
libs/gst/base/gstbaseparse.c
View file

@ -473,6 +473,7 @@ static GstFlowReturn gst_base_parse_locate_time (GstBaseParse * parse,
static GstFlowReturn gst_base_parse_start_fragment (GstBaseParse * parse);
static GstFlowReturn gst_base_parse_finish_fragment (GstBaseParse * parse,
gboolean prev_head);
static GstFlowReturn gst_base_parse_send_buffers (GstBaseParse * parse);
static inline GstFlowReturn gst_base_parse_check_sync (GstBaseParse * parse);
@ -2297,6 +2298,34 @@ gst_base_parse_push_frame (GstBaseParse * parse, GstBaseParseFrame * frame)
size);
ret = gst_pad_push (parse->srcpad, buffer);
GST_LOG_OBJECT (parse, "frame pushed, flow %s", gst_flow_get_name (ret));
} else if (!parse->priv->disable_passthrough && parse->priv->passthrough) {
/* in backwards playback mode, if on passthrough we need to push buffers
* directly without accumulating them into the buffers_queued as baseparse
* will never check for a DISCONT while on passthrough and those buffers
* will never be pushed.
*
* also, as we are on reverse playback, it might be possible that
* passthrough might have just been enabled, so make sure to drain the
* buffers_queued list */
if (G_UNLIKELY (parse->priv->buffers_queued != NULL)) {
gst_base_parse_finish_fragment (parse, TRUE);
ret = gst_base_parse_send_buffers (parse);
}
if (ret == GST_FLOW_OK) {
GST_LOG_OBJECT (parse,
"pushing frame (%" G_GSIZE_FORMAT " bytes) now..", size);
ret = gst_pad_push (parse->srcpad, buffer);
GST_LOG_OBJECT (parse, "frame pushed, flow %s",
gst_flow_get_name (ret));
} else {
GST_LOG_OBJECT (parse,
"frame (%" G_GSIZE_FORMAT " bytes) not pushed: %s", size,
gst_flow_get_name (ret));
gst_buffer_unref (buffer);
}
} else {
GST_LOG_OBJECT (parse, "frame (%" G_GSIZE_FORMAT " bytes) queued for now",
size);