X-Git-Url: https://git.cweiske.de/enigma2.git/blobdiff_plain/4cb1a1e0bcadeba2bc44f8ae6610896bd493cfed..3ff1dc8555e0bf219e47ed002ea7b66a59bdaeb7:/lib/base/filepush.cpp diff --git a/lib/base/filepush.cpp b/lib/base/filepush.cpp index 5ae2f15d..17b767f8 100644 --- a/lib/base/filepush.cpp +++ b/lib/base/filepush.cpp @@ -34,6 +34,7 @@ void eFilePushThread::thread() { // TODO: take care of boundaries. int w = write(m_fd_dest, m_buffer + m_buf_start, m_buf_end - m_buf_start); + eDebug("wrote %d bytes", w); if (w <= 0) { if (errno == -EINTR) @@ -42,6 +43,7 @@ void eFilePushThread::thread() // ... we would stop the thread } + /* this should flush all written pages to disk. */ posix_fadvise(m_fd_dest, dest_pos, w, POSIX_FADV_DONTNEED); dest_pos += w; @@ -80,8 +82,7 @@ void eFilePushThread::start(int fd_source, int fd_dest) { m_fd_source = fd_source; m_fd_dest = fd_dest; - m_stop = 0; - run(); + resume(); } void eFilePushThread::stop() @@ -90,3 +91,19 @@ void eFilePushThread::stop() sendSignal(SIGUSR1); kill(); } + +void eFilePushThread::pause() +{ + stop(); +} + +void eFilePushThread::seek(off_t where) +{ + ::lseek(m_fd_source, where, SEEK_SET); +} + +void eFilePushThread::resume() +{ + m_stop = 0; + run(); +}