X-Git-Url: https://git.cweiske.de/enigma2.git/blobdiff_plain/4a594e382e063bc9f313683d2bd6c679cbad0e9a..a5d197928d1660c95ef7891eb21e4941f89ca1c0:/lib/base/filepush.h diff --git a/lib/base/filepush.h b/lib/base/filepush.h index f2bd98be..35671cd6 100644 --- a/lib/base/filepush.h +++ b/lib/base/filepush.h @@ -5,6 +5,14 @@ #include #include #include +#include + +class iFilePushScatterGather +{ +public: + virtual void getNextSourceSpan(off_t current_offset, size_t bytes_read, off_t &start, size_t &size)=0; + virtual ~iFilePushScatterGather() {} +}; class eFilePushThread: public eThread, public Object { @@ -13,6 +21,7 @@ public: void thread(); void stop(); void start(int sourcefd, int destfd); + int start(const char *filename, int destfd); void pause(); void seek(int whence, off_t where); @@ -22,19 +31,30 @@ public: void flush(); void enablePVRCommit(int); - enum { evtEOF, evtReadError, evtWriteError }; - Signal1 m_event; + void setScatterGather(iFilePushScatterGather *); + enum { evtEOF, evtReadError, evtWriteError, evtUser }; + Signal1 m_event; + + void installSigUSR1Handler(); + void before_set_thread_alive(); + + /* you can send private events if you want */ + void sendEvent(int evt); +protected: + virtual void filterRecordData(const unsigned char *data, int len); private: + iFilePushScatterGather *m_sg; int m_stop; unsigned char m_buffer[65536]; int m_buf_start, m_buf_end; - int m_fd_source, m_fd_dest; + int m_fd_dest; int m_send_pvr_commit; + eRawFile m_raw_source; + eFixedMessagePump m_messagepump; - void sendEvent(int evt); void recvEvent(const int &evt); };