diff options
Diffstat (limited to 'lib/base/filepush.h')
| -rw-r--r-- | lib/base/filepush.h | 12 |
1 files changed, 11 insertions, 1 deletions
diff --git a/lib/base/filepush.h b/lib/base/filepush.h index a419d719..7eb79974 100644 --- a/lib/base/filepush.h +++ b/lib/base/filepush.h @@ -2,9 +2,11 @@ #define __lib_base_filepush_h #include <lib/base/thread.h> +#include <libsig_comp.h> +#include <lib/base/message.h> #include <sys/types.h> -class eFilePushThread: public eThread +class eFilePushThread: public eThread, public Object { public: eFilePushThread(); @@ -19,11 +21,19 @@ public: /* flushes the internal readbuffer */ void flush(); + enum { evtEOF, evtReadError, evtWriteError }; + Signal1<void,int> m_event; + private: int m_stop; unsigned char m_buffer[65536]; int m_buf_start, m_buf_end; int m_fd_source, m_fd_dest; + + eFixedMessagePump<int> m_messagepump; + + void sendEvent(int evt); + void recvEvent(const int &evt); }; #endif |