X-Git-Url: https://git.cweiske.de/enigma2.git/blobdiff_plain/4934fe267ddc796ab220168ca6284872f0a5e3d0..c0a2787dc8f4859ff9601a8299ede60142a196b5:/lib/base/filepush.h diff --git a/lib/base/filepush.h b/lib/base/filepush.h index a536df17..25257880 100644 --- a/lib/base/filepush.h +++ b/lib/base/filepush.h @@ -5,12 +5,13 @@ #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() {} - virtual void getNextSourceSpan(size_t bytes_read, off_t &start, size_t &size)=0; }; class eFilePushThread: public eThread, public Object @@ -20,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); @@ -29,22 +31,27 @@ public: void flush(); void enablePVRCommit(int); - void setSG(iFilePushScatterGather *); + void setScatterGather(iFilePushScatterGather *); - enum { evtEOF, evtReadError, evtWriteError }; + enum { evtEOF, evtReadError, evtWriteError, evtUser }; Signal1 m_event; + /* 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); };