mirrors/libstb-hal
1
0
Fork 0
mirror of https://github.com/tuxbox-neutrino/libstb-hal.git synced 2025-08-27 07:23:11 +02:00
Code Issues Packages Projects Releases Wiki Activity

libspark/record: always fill read buffer

Browse Source
This commit is contained in:
martii
2014-06-28 09:33:47 +02:00
parent ac92e6a38e
commit f77184cb68
1 changed files with 26 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
libspark/record.cpp
View File

@@ -244,7 +244,11 @@ void cRecord::RecordThread()
while (exit_flag == RECORD_RUNNING) while (exit_flag == RECORD_RUNNING)
{ {
ssize_t s = dmx->Read(io_buf[chunk], readsize, 50); uint8_t *bufstart = io_buf[chunk];
int left = readsize;
ssize_t len = 0;
while ((exit_flag == RECORD_RUNNING) && (left > 0)) {
int s = dmx->Read(bufstart, left, 50);
lt_debug("%s: Read chunk=%d size=%d\n", __func__, chunk, s); lt_debug("%s: Read chunk=%d size=%d\n", __func__, chunk, s);
if (s < 0) if (s < 0)
{ {
@@ -259,14 +263,18 @@ void cRecord::RecordThread()
overflow_count++; overflow_count++;
continue; continue;
} }
len += s;
left -= s;
bufstart += s;
if (overflow_count) { if (overflow_count) {
lt_info("%s: Overflow cleared after %d iterations\n", __func__, overflow_count); lt_info("%s: Overflow cleared after %d iterations\n", __func__, overflow_count);
overflow_count = 0; overflow_count = 0;
} }
if (!s) }
if (!len)
continue; continue;
io_len[chunk] = s; io_len[chunk] = len;
sem_post(&sem); sem_post(&sem);
chunk++; chunk++;
chunk %= RECORD_WRITER_CHUNKS; chunk %= RECORD_WRITER_CHUNKS;