diff options
| author | Sebastian Dröge <slomo@circular-chaos.org> | 2008-01-19 16:13:31 +0000 |
|---|---|---|
| committer | Sebastian Dröge <slomo@circular-chaos.org> | 2008-01-19 16:13:31 +0000 |
| commit | 252d4044bf20602c2489243c5f554df9b992d7c4 (patch) | |
| tree | 9cdabbf62e41029145a43eae118281144d3d6abd /gst | |
| parent | a0283af747eb72ba84298d2a264f957fc4fb8ea3 (diff) | |
gst/rawparse/gstrawparse.c: Handle framesizes > 4096 with multiple frames per buffer correctly in pull mode and handl...
Original commit message from CVS:
* gst/rawparse/gstrawparse.c: (gst_raw_parse_push_buffer),
(gst_raw_parse_loop):
Handle framesizes > 4096 with multiple frames per buffer correctly
in pull mode and handle short reads better.
Also put offset and offset_end on outgoing buffers.
Diffstat (limited to 'gst')
| -rw-r--r-- | gst/rawparse/gstrawparse.c | 19 |
1 files changed, 14 insertions, 5 deletions
diff --git a/gst/rawparse/gstrawparse.c b/gst/rawparse/gstrawparse.c index be7549b09..cbb43a456 100644 --- a/gst/rawparse/gstrawparse.c +++ b/gst/rawparse/gstrawparse.c @@ -221,9 +221,13 @@ gst_raw_parse_push_buffer (GstRawParse * rp, GstBuffer * buffer) gst_util_uint64_scale (rp->n_frames, GST_SECOND * rp->fps_d, rp->fps_n); GST_BUFFER_DURATION (buffer) = gst_util_uint64_scale (nframes * GST_SECOND, rp->fps_d, rp->fps_n); + GST_BUFFER_OFFSET (buffer) = rp->offset / rp->framesize; + GST_BUFFER_OFFSET_END (buffer) = GST_BUFFER_OFFSET (buffer) + nframes; } else { GST_BUFFER_TIMESTAMP (buffer) = rp->segment.start; GST_BUFFER_DURATION (buffer) = GST_CLOCK_TIME_NONE; + GST_BUFFER_OFFSET (buffer) = rp->offset / rp->framesize; + GST_BUFFER_OFFSET_END (buffer) = GST_BUFFER_OFFSET (buffer) + nframes; } gst_buffer_set_caps (buffer, GST_PAD_CAPS (rp->srcpad)); if (rp->discont) { @@ -296,7 +300,7 @@ gst_raw_parse_loop (GstElement * element) goto pause; } - if (rp_class->multiple_frames_per_buffer) + if (rp_class->multiple_frames_per_buffer && rp->framesize < 4096) size = 4096 - (4096 % rp->framesize); else size = rp->framesize; @@ -330,10 +334,15 @@ gst_raw_parse_loop (GstElement * element) GST_DEBUG_OBJECT (rp, "Short read at offset %" G_GINT64_FORMAT ", got only %u of %u bytes", rp->offset, GST_BUFFER_SIZE (buffer), size); - gst_buffer_unref (buffer); - buffer = NULL; - ret = GST_FLOW_UNEXPECTED; - goto pause; + + if (size > rp->framesize) { + GST_BUFFER_SIZE (buffer) -= GST_BUFFER_SIZE (buffer) % rp->framesize; + } else { + gst_buffer_unref (buffer); + buffer = NULL; + ret = GST_FLOW_UNEXPECTED; + goto pause; + } } if (rp->need_newsegment) { |