eFilePushThread::eFilePushThread(): m_messagepump(eApp, 0)
{
m_stop = 0;
+ m_sg = 0;
flush();
enablePVRCommit(0);
CONNECT(m_messagepump.recv_msg, eFilePushThread::recvEvent);
void eFilePushThread::thread()
{
off_t dest_pos = 0;
+ size_t bytes_read = 0;
+
+ off_t current_span_offset;
+ size_t current_span_remaining = 0;
int already_empty = 0;
eDebug("FILEPUSH THREAD START");
m_buf_start += w;
continue;
}
-
+
/* now fill our buffer. */
+
+ if (m_sg && !current_span_remaining)
+ {
+ m_sg->getNextSourceSpan(bytes_read, current_span_offset, current_span_remaining);
+ bytes_read = 0;
+ }
+
+ size_t maxread = sizeof(m_buffer);
+
+ /* if we have a source span, don't read past the end */
+ if (m_sg && maxread < current_span_remaining)
+ maxread = current_span_remaining;
+
m_buf_start = 0;
- m_buf_end = read(m_fd_source, m_buffer, sizeof(m_buffer));
+ m_buf_end = 0;
+
+ if (maxread)
+ m_buf_end = read(m_fd_source, m_buffer, maxread);
+
+ bytes_read += m_buf_end;
+
if (m_buf_end < 0)
{
m_buf_end = 0;
continue;
}
sendEvent(evtEOF);
-
#if 0
eDebug("FILEPUSH: end-of-file! (currently unhandled)");
if (!lseek(m_fd_source, 0, SEEK_SET))
#include <lib/base/message.h>
#include <sys/types.h>
+class iFilePushScatterGather
+{
+public:
+ virtual void getNextSourceSpan(size_t bytes_read, off_t &start, size_t &size)=0;
+};
+
class eFilePushThread: public eThread, public Object
{
public:
void flush();
void enablePVRCommit(int);
+ void setSG(iFilePushScatterGather *);
+
enum { evtEOF, evtReadError, evtWriteError };
Signal1<void,int> m_event;
private:
+ iFilePushScatterGather *m_sg;
int m_stop;
unsigned char m_buffer[65536];
int m_buf_start, m_buf_end;