mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-01-18 21:35:44 +00:00
Code Issues 1 Projects Releases Wiki Activity

queue2: don't try to write 0 bytes

Browse source
This commit is contained in:
Wim Taymans 2010-06-15 17:26:15 +02:00
parent 73e27fb017
commit e882e1b533
1 changed files with 13 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
plugins/elements/gstqueue2.c
View file

@ -1630,6 +1630,7 @@ gst_queue2_write_buffer_to_ring_buffer (GstQueue2 * queue, GstBuffer * buffer)
goto seek_failed;
if (new_writing_pos > writing_pos) {
GST_INFO_OBJECT (queue, "writing %u bytes", buf_size);
/* no wrapping, just write */
if (fwrite (data, buf_size, 1, queue->temp_file) != 1)
goto handle_error;
@ -1640,16 +1641,22 @@ gst_queue2_write_buffer_to_ring_buffer (GstQueue2 * queue, GstBuffer * buffer)
block_one = rb_size - writing_pos;
block_two = buf_size - block_one;
/* write data to end of ring buffer */
if (fwrite (data, block_one, 1, queue->temp_file) != 1)
goto handle_error;
if (block_one > 0) {
GST_INFO_OBJECT (queue, "writing %u bytes", block_one);
/* write data to end of ring buffer */
if (fwrite (data, block_one, 1, queue->temp_file) != 1)
goto handle_error;
}
if (FSEEK_FILE (queue->temp_file, 0))
goto seek_failed;
data += block_one;
if (fwrite (data, block_two, 1, queue->temp_file) != 1)
goto handle_error;
if (block_two > 0) {
GST_INFO_OBJECT (queue, "writing %u bytes", block_two);
data += block_one;
if (fwrite (data, block_two, 1, queue->temp_file) != 1)
goto handle_error;
}
}
/* update the writing positions */