summaryrefslogtreecommitdiffstats
path: root/gst
diff options
context:
space:
mode:
Diffstat (limited to 'gst')
-rw-r--r--gst/rawparse/gstrawparse.c11
1 files changed, 6 insertions, 5 deletions
diff --git a/gst/rawparse/gstrawparse.c b/gst/rawparse/gstrawparse.c
index 16a6b9f7..be7549b0 100644
--- a/gst/rawparse/gstrawparse.c
+++ b/gst/rawparse/gstrawparse.c
@@ -304,13 +304,14 @@ gst_raw_parse_loop (GstElement * element)
if (rp->offset + size > rp->upstream_length) {
GstFormat fmt = GST_FORMAT_BYTES;
- if (!gst_pad_query_peer_duration (rp->sinkpad, &fmt, &rp->upstream_length)
- || rp->upstream_length < rp->offset + rp->framesize) {
+ if (!gst_pad_query_peer_duration (rp->sinkpad, &fmt, &rp->upstream_length)) {
+ GST_WARNING_OBJECT (rp,
+ "Could not get upstream duration, trying to pull frame by frame");
+ size = rp->framesize;
+ } else if (rp->upstream_length < rp->offset + rp->framesize) {
ret = GST_FLOW_UNEXPECTED;
goto pause;
- }
-
- if (rp->offset + size > rp->upstream_length) {
+ } else if (rp->offset + size > rp->upstream_length) {
size = rp->upstream_length - rp->offset;
size -= size % rp->framesize;
}