mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-02-26 07:56:38 +00:00
Code Issues 1 Projects Releases Wiki Activity

matroska: error mode if can't push buffer

Browse source 
If gst_pad_push() fails, inform and return flow error.
This commit is contained in:
Luis de Bethencourt 2015-03-09 12:51:17 +00:00
parent f494da89b4
commit db3ade5bfb
1 changed files with 7 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
gst/matroska/matroska-parse.c
View file

@ -2414,7 +2414,7 @@ static GstFlowReturn
gst_matroska_parse_output (GstMatroskaParse * parse, GstBuffer * buffer, gst_matroska_parse_output (GstMatroskaParse * parse, GstBuffer * buffer,
gboolean keyframe) gboolean keyframe)
{ {
GstFlowReturn ret = GST_FLOW_OK; GstFlowReturn ret;
if (!parse->pushed_headers) { if (!parse->pushed_headers) {
GstCaps *caps; GstCaps *caps;
@ -2457,7 +2457,11 @@ gst_matroska_parse_output (GstMatroskaParse * parse, GstBuffer * buffer,
GST_BUFFER_FLAG_SET (buf, GST_BUFFER_FLAG_HEADER); GST_BUFFER_FLAG_SET (buf, GST_BUFFER_FLAG_HEADER);
GST_BUFFER_FLAG_SET (buf, GST_BUFFER_FLAG_DELTA_UNIT); GST_BUFFER_FLAG_SET (buf, GST_BUFFER_FLAG_DELTA_UNIT);
gst_pad_push (parse->srcpad, buf); ret = gst_pad_push (parse->srcpad, buf);
if (ret != GST_FLOW_OK) {
GST_WARNING_OBJECT (parse, "Failed to push buffer");
return ret;
}
parse->pushed_headers = TRUE; parse->pushed_headers = TRUE;
} }
@ -2472,9 +2476,8 @@ gst_matroska_parse_output (GstMatroskaParse * parse, GstBuffer * buffer,
} else { } else {
GST_BUFFER_TIMESTAMP (buffer) = parse->last_timestamp; GST_BUFFER_TIMESTAMP (buffer) = parse->last_timestamp;
} }
ret = gst_pad_push (parse->srcpad, gst_buffer_ref (buffer));
return ret; return gst_pad_push (parse->srcpad, gst_buffer_ref (buffer));
} }
static GstFlowReturn static GstFlowReturn