#include <lib/base/filepush.h>
#include <lib/base/eerror.h>
#include <errno.h>
+#include <fcntl.h>
eFilePushThread::eFilePushThread()
{
void eFilePushThread::thread()
{
+ off_t dest_pos = 0;
eDebug("FILEPUSH THREAD START");
// this is a race. FIXME.
act.sa_flags = 0;
sigaction(SIGUSR1, &act, 0);
+ dest_pos = lseek(m_fd_dest, 0, SEEK_CUR);
/* m_stop must be evaluated after each syscall. */
while (!m_stop)
{
eDebug("eFilePushThread *write error* - not yet handled");
// ... we would stop the thread
}
- printf("FILEPUSH: wrote %d bytes\n", w);
+
+ posix_fadvise(m_fd_dest, dest_pos, w, POSIX_FADV_DONTNEED);
+
+ dest_pos += w;
+// printf("FILEPUSH: wrote %d bytes\n", w);
m_buf_start += w;
continue;
}
continue;
eDebug("eFilePushThread *read error* - not yet handled");
}
- printf("FILEPUSH: read %d bytes\n", m_buf_end);
+ if (m_buf_end == 0)
+ {
+ eDebug("FILEPUSH: end-of-file! (currently unhandled)");
+ if (!lseek(m_fd_source, 0, SEEK_SET))
+ {
+ eDebug("(looping)");
+ continue;
+ }
+ break;
+ }
+// printf("FILEPUSH: read %d bytes\n", m_buf_end);
}
eDebug("FILEPUSH THREAD STOP");