X-Git-Url: https://git.cweiske.de/enigma2.git/blobdiff_plain/06fb2bcb4ddf528cbe65d58be41cf8ecf8697e76..8ef240801bf66e543cdea9df3b32fc09cebcc7e5:/lib/dvb/dvb.h diff --git a/lib/dvb/dvb.h b/lib/dvb/dvb.h index b739f0ae..6209f281 100644 --- a/lib/dvb/dvb.h +++ b/lib/dvb/dvb.h @@ -1,13 +1,15 @@ #ifndef __dvb_dvb_h #define __dvb_dvb_h +#include +#include +#include #include #include #include #include #include -class eDVBChannel; class eDVBChannel; /* we do NOT handle resource conflicts here. instead, the allocateChannel @@ -15,14 +17,35 @@ class eDVBChannel; (and how to deallocate it). */ class iDVBAdapter; -class eDVBRegisteredFrontend: public iObject +class eDVBRegisteredFrontend: public iObject, public Object { -DECLARE_REF(eDVBRegisteredFrontend); + DECLARE_REF(eDVBRegisteredFrontend); + eTimer *disable; + void closeFrontend() + { + if (!m_inuse && m_frontend->closeFrontend()) // frontend busy + disable->start(60000, true); // retry close in 60secs + } public: + eDVBRegisteredFrontend(eDVBFrontend *fe, iDVBAdapter *adap) + :disable(new eTimer(eApp)), m_adapter(adap), m_frontend(fe), m_inuse(0) + { + disable = new eTimer(eApp); + CONNECT(disable->timeout, eDVBRegisteredFrontend::closeFrontend); + } + void dec_use() + { + if (!--m_inuse) + disable->start(3000, true); + } + void inc_use() + { + if (++m_inuse == 1) + m_frontend->openFrontend(); + } iDVBAdapter *m_adapter; ePtr m_frontend; int m_inuse; - eDVBRegisteredFrontend(eDVBFrontend *fe, iDVBAdapter *adap): m_adapter(adap), m_frontend(fe), m_inuse(0) { } }; struct eDVBRegisteredDemux @@ -94,11 +117,11 @@ private: eSmartPtrList m_demux; }; -class eDVBResourceManager: public iObject +class eDVBResourceManager: public iObject, public Object { DECLARE_REF(eDVBResourceManager); int avail, busy; - + eSmartPtrList m_adapter; eSmartPtrList m_demux; @@ -106,15 +129,16 @@ class eDVBResourceManager: public iObject void addAdapter(iDVBAdapter *adapter); - /* allocates a frontend able to tune to channelID "chid". + /* allocates a frontend able to tune to frontend paramters 'feperm'. the frontend must be tuned lateron. there is no guarante - that tuning will suceed - it just means that if this frontend + that tuning will succeed - it just means that if this frontend can't tune, no other frontend could do it. there might be a priority given to certain frontend/chid combinations. this will be evaluated here. */ - RESULT allocateFrontend(const eDVBChannelID &chid, ePtr &fe); + RESULT allocateFrontend(ePtr &fe, ePtr &feparm); + RESULT allocateFrontendByIndex(ePtr &fe, int index); /* allocate a demux able to filter on the selected frontend. */ RESULT allocateDemux(eDVBRegisteredFrontend *fe, ePtr &demux, int cap); @@ -137,10 +161,16 @@ class eDVBResourceManager: public iObject friend class eDVBChannel; RESULT addChannel(const eDVBChannelID &chid, eDVBChannel *ch); RESULT removeChannel(eDVBChannel *ch); - + Signal1 m_channelAdded; - Signal1 m_channelRemoved; - Signal1 m_channelRunning; + + bool canAllocateFrontend(ePtr &feparm); + + eUsePtr m_cached_channel; + Connection m_cached_channel_state_changed_conn; + eTimer m_releaseCachedChannelTimer; + void DVBChannelStateChanged(iDVBChannel*); + void releaseCachedChannel(); public: eDVBResourceManager(); virtual ~eDVBResourceManager(); @@ -155,33 +185,34 @@ public: errNoDemux = -2, errChidNotFound = -3 }; - + /* allocate channel... */ RESULT allocateChannel(const eDVBChannelID &channelid, eUsePtr &channel); - RESULT allocateRawChannel(eUsePtr &channel); + RESULT allocateRawChannel(eUsePtr &channel, int frontend_index); RESULT allocatePVRChannel(eUsePtr &channel); RESULT connectChannelAdded(const Slot1 &channelAdded, ePtr &connection); - RESULT connectChannelRemoved(const Slot1 &channelRemoved, ePtr &connection); - RESULT connectChannelRunning(const Slot1 &channelRemoved, ePtr &connection); -}; -class eFilePushThread; + bool canAllocateChannel(const eDVBChannelID &channelid, const eDVBChannelID &ignore); +}; /* iDVBPVRChannel includes iDVBChannel. don't panic. */ -class eDVBChannel: public iDVBPVRChannel, public Object +class eDVBChannel: public iDVBPVRChannel, public iFilePushScatterGather, public Object { DECLARE_REF(eDVBChannel); + friend class eDVBResourceManager; public: eDVBChannel(eDVBResourceManager *mgr, eDVBAllocatedFrontend *frontend); virtual ~eDVBChannel(); /* only for managed channels - effectively tunes to the channelid. should not be used... */ /* cannot be used for PVR channels. */ - RESULT setChannel(const eDVBChannelID &id); + RESULT setChannel(const eDVBChannelID &id, ePtr &feparam); eDVBChannelID getChannelID() { return m_channel_id; } RESULT connectStateChange(const Slot1 &stateChange, ePtr &connection); + RESULT connectEvent(const Slot2 &eventChange, ePtr &connection); + RESULT getState(int &state); RESULT setCIRouting(const eDVBCIRouting &routing); @@ -190,20 +221,23 @@ public: /* iDVBPVRChannel */ RESULT playFile(const char *file); + void stopFile(); + + void setCueSheet(eCueSheet *cuesheet); + RESULT getLength(pts_t &len); - RESULT getCurrentPosition(pts_t &pos); - RESULT seekTo(int relative, pts_t &pts); - /* seeking to relative positions won't work - - there is an unknown amount of buffers in between */ - RESULT seekToPosition(const off_t &off); + RESULT getCurrentPosition(iDVBDemux *decoding_demux, pts_t &pos, int mode); + int getUseCount() { return m_use_count; } private: + ePtr m_feparm; // for retune on lostlock ePtr m_frontend; ePtr m_demux, m_decoder_demux; ePtr m_current_frontend_parameters; eDVBChannelID m_channel_id; Signal1 m_stateChanged; + Signal2 m_event; int m_state; /* for channel list */ @@ -214,8 +248,22 @@ private: /* for PVR playback */ eFilePushThread *m_pvr_thread; - int m_pvr_fd_src, m_pvr_fd_dst; + void pvrEvent(int event); + + int m_pvr_fd_dst; eDVBTSTools m_tstools; + + ePtr m_cue; + + void cueSheetEvent(int event); + ePtr m_conn_cueSheetEvent; + int m_skipmode_m, m_skipmode_n; + + std::list > m_source_span; + void getNextSourceSpan(off_t current_offset, size_t bytes_read, off_t &start, size_t &size); + void flushPVR(iDVBDemux *decoding_demux=0); + + eSingleLock m_cuesheet_lock; friend class eUsePtr; /* use count */