/* * $Id: streamer.h,v 1.8.2.1 2008/10/22 11:59:37 schmirl Exp $ */ #ifndef VDR_STREAMDEV_STREAMER_H #define VDR_STREAMDEV_STREAMER_H #include #include #include class cTBSocket; class cStreamdevStreamer; #define STREAMERBUFSIZE MEGABYTE(4) #define WRITERBUFSIZE KILOBYTE(256) // --- cStreamdevWriter ------------------------------------------------------- class cStreamdevWriter: public cThread { private: cStreamdevStreamer *m_Streamer; cTBSocket *m_Socket; protected: virtual void Action(void); public: cStreamdevWriter(cTBSocket *Socket, cStreamdevStreamer *Streamer); virtual ~cStreamdevWriter(); }; // --- cStreamdevStreamer ----------------------------------------------------- class cStreamdevStreamer: public cThread { private: bool m_Running; cStreamdevWriter *m_Writer; cRingBufferLinear *m_RingBuffer; cRingBufferLinear *m_SendBuffer; protected: virtual void Action(void); bool IsRunning(void) const { return m_Running; } public: cStreamdevStreamer(const char *Name); virtual ~cStreamdevStreamer(); virtual void Start(cTBSocket *Socket); virtual void Stop(void); bool Abort(void); void Activate(bool On); int Receive(uchar *Data, int Length) { return m_RingBuffer->Put(Data, Length); } void ReportOverflow(int Bytes) { m_RingBuffer->ReportOverflow(Bytes); } virtual int Put(const uchar *Data, int Count) { return m_SendBuffer->Put(Data, Count); } virtual uchar *Get(int &Count) { return m_SendBuffer->Get(Count); } virtual void Del(int Count) { m_SendBuffer->Del(Count); } virtual void Detach(void) {} virtual void Attach(void) {} }; inline bool cStreamdevStreamer::Abort(void) { return Active() && !m_Writer->Active(); } #endif // VDR_STREAMDEV_STREAMER_H