X-Git-Url: https://git.cweiske.de/enigma2.git/blobdiff_plain/e39c12fcbf218f0964782a48d6e66145e1ce5039..ff840bdbd611fde4e94f80b733e9482dd95ac441:/lib/dvb/dvb.h diff --git a/lib/dvb/dvb.h b/lib/dvb/dvb.h index bb9e2689..4ca986b1 100644 --- a/lib/dvb/dvb.h +++ b/lib/dvb/dvb.h @@ -1,12 +1,17 @@ #ifndef __dvb_dvb_h #define __dvb_dvb_h +#ifndef SWIG + +#include +#include +#include #include #include #include +#include #include -class eDVBChannel; class eDVBChannel; /* we do NOT handle resource conflicts here. instead, the allocateChannel @@ -14,14 +19,42 @@ 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; + Signal0 stateChanged; + 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) + { + /* emit */ stateChanged(); + disable->start(3000, true); + } + } + void inc_use() + { + if (++m_inuse == 1) + { + m_frontend->openFrontend(); + /* emit */ stateChanged(); + } + } 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 @@ -93,11 +126,13 @@ private: eSmartPtrList m_demux; }; -class eDVBResourceManager: public iObject +#endif // SWIG + +class eDVBResourceManager: public iObject, public Object { DECLARE_REF(eDVBResourceManager); int avail, busy; - + eSmartPtrList m_adapter; eSmartPtrList m_demux; @@ -105,18 +140,19 @@ 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); + RESULT allocateDemux(eDVBRegisteredFrontend *fe, ePtr &demux, int cap); struct active_channel { @@ -136,16 +172,23 @@ 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(); + void feStateChanged(); +#ifndef SWIG public: +#endif eDVBResourceManager(); virtual ~eDVBResourceManager(); - - static RESULT getInstance(ePtr &ptr) { if (instance) { ptr = instance; return 0; } return -1; } - + RESULT setChannelList(iDVBChannelList *list); RESULT getChannelList(ePtr &list); @@ -154,27 +197,65 @@ public: errNoDemux = -2, errChidNotFound = -3 }; - - /* allocate channel... */ - RESULT allocateChannel(const eDVBChannelID &channelid, eUsePtr &channel); - RESULT allocateRawChannel(eUsePtr &channel); - RESULT allocatePVRChannel(int caps); RESULT connectChannelAdded(const Slot1 &channelAdded, ePtr &connection); - RESULT connectChannelRemoved(const Slot1 &channelRemoved, ePtr &connection); - RESULT connectChannelRunning(const Slot1 &channelRemoved, ePtr &connection); + bool canAllocateChannel(const eDVBChannelID &channelid, const eDVBChannelID &ignore); + + /* allocate channel... */ + RESULT allocateChannel(const eDVBChannelID &channelid, eUsePtr &channel); + RESULT allocatePVRChannel(eUsePtr &channel); +#ifdef SWIG +public: +#endif + PSignal1 frontendUseMaskChanged; + RESULT allocateRawChannel(eUsePtr &, int frontend_index); + static RESULT getInstance(ePtr &); }; +TEMPLATE_TYPEDEF(ePtr, eDVBResourceManagerPtr); +#ifndef SWIG -class eDVBChannel: public iDVBChannel, public Object + /* iDVBPVRChannel includes iDVBChannel. don't panic. */ +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, 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); + RESULT getDemux(ePtr &demux, int cap); + RESULT getFrontend(ePtr &frontend); + RESULT getCurrentFrontendParameters(ePtr ¶m); + + /* iDVBPVRChannel */ + RESULT playFile(const char *file); + void stopFile(); + + void setCueSheet(eCueSheet *cuesheet); + + RESULT getLength(pts_t &len); + RESULT getCurrentPosition(iDVBDemux *decoding_demux, pts_t &pos, int mode); + + int getUseCount() { return m_use_count; } private: ePtr m_frontend; - ePtr m_demux; + 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 */ @@ -183,24 +264,31 @@ private: void frontendStateChanged(iDVBFrontend*fe); ePtr m_conn_frontendStateChanged; + /* for PVR playback */ + eFilePushThread *m_pvr_thread; + 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 */ oRefCount m_use_count; void AddUse(); void ReleaseUse(); -public: - eDVBChannel(eDVBResourceManager *mgr, eDVBAllocatedFrontend *frontend, eDVBAllocatedDemux *demux); - virtual ~eDVBChannel(); - - /* only for managed channels - effectively tunes to the channelid. should not be used... */ - RESULT setChannel(const eDVBChannelID &id); - eDVBChannelID getChannelID() { return m_channel_id; } - - RESULT connectStateChange(const Slot1 &stateChange, ePtr &connection); - RESULT getState(int &state); - - RESULT setCIRouting(const eDVBCIRouting &routing); - RESULT getDemux(ePtr &demux); - RESULT getFrontend(ePtr &frontend); }; +#endif // SWIG #endif