mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-12-24 17:20:36 +00:00
Code Issues 1 Projects Releases Wiki Activity

queue2: reading_pos is updated in create_read only

Browse source
This commit is contained in:
Wim Taymans 2010-06-16 11:11:32 +02:00
parent cda4967839
commit 8de7cc2222
1 changed files with 1 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
plugins/elements/gstqueue2.c
View file

@ -1297,11 +1297,6 @@ gst_queue2_read_item_from_file (GstQueue2 * queue)
switch (ret) { switch (ret) {
case GST_FLOW_OK: case GST_FLOW_OK:
item = GST_MINI_OBJECT_CAST (buffer); item = GST_MINI_OBJECT_CAST (buffer);
queue->current->reading_pos += DEFAULT_BUFFER_SIZE;
if (QUEUE_IS_USING_RING_BUFFER (queue))
queue->current->rb_reading_pos =
(queue->current->rb_reading_pos +
DEFAULT_BUFFER_SIZE) % queue->ring_buffer_max_size;
break; break;
case GST_FLOW_UNEXPECTED: case GST_FLOW_UNEXPECTED:
item = GST_MINI_OBJECT_CAST (gst_event_new_eos ()); item = GST_MINI_OBJECT_CAST (gst_event_new_eos ());
@ -2530,8 +2525,7 @@ gst_queue2_get_range (GstPad * pad, guint64 offset, guint length,
GST_QUEUE2_MUTEX_LOCK_CHECK (queue, queue->srcresult, out_flushing); GST_QUEUE2_MUTEX_LOCK_CHECK (queue, queue->srcresult, out_flushing);
length = (length == -1) ? DEFAULT_BUFFER_SIZE : length; length = (length == -1) ? DEFAULT_BUFFER_SIZE : length;
queue->current->reading_pos = offset = offset = (offset == -1) ? queue->current->reading_pos : offset;
(offset == -1) ? queue->current->reading_pos : offset;
GST_DEBUG_OBJECT (queue, GST_DEBUG_OBJECT (queue,
"Getting range: offset %" G_GUINT64_FORMAT ", length %u", offset, length); "Getting range: offset %" G_GUINT64_FORMAT ", length %u", offset, length);