X-Git-Url: https://git.cweiske.de/enigma2.git/blobdiff_plain/f0b5b5c0d6a4320b318f0a700492b6046a39e18a..c326dee2e7ce346cffecd196d971dd91ef1454f5:/lib/dvb/pmt.cpp diff --git a/lib/dvb/pmt.cpp b/lib/dvb/pmt.cpp index 834a2905..e77c097d 100644 --- a/lib/dvb/pmt.cpp +++ b/lib/dvb/pmt.cpp @@ -3,6 +3,7 @@ #include #include #include +#include #include eDVBServicePMTHandler::eDVBServicePMTHandler(int record) @@ -12,6 +13,7 @@ eDVBServicePMTHandler::eDVBServicePMTHandler(int record) eDVBResourceManager::getInstance(m_resourceManager); CONNECT(m_PMT.tableReady, eDVBServicePMTHandler::PMTready); CONNECT(m_PAT.tableReady, eDVBServicePMTHandler::PATready); + eDVBCIInterfaces::getInstance()->addPMTHandler(this); eDebug("new PMT handler record: %d", m_record); } @@ -25,8 +27,9 @@ eDVBServicePMTHandler::~eDVBServicePMTHandler() m_demux->getCADemuxID(demux_num); ePtr > ptr; m_PMT.getCurrent(ptr); - eDVBCAService::unregister_demux(m_reference, demux_num, ptr); + eDVBCAService::unregister_service(m_reference, demux_num, ptr); } + eDVBCIInterfaces::getInstance()->removePMTHandler(this); } void eDVBServicePMTHandler::channelStateChanged(iDVBChannel *channel) @@ -69,11 +72,15 @@ void eDVBServicePMTHandler::PMTready(int error) else { serviceEvent(eventNewProgramInfo); - if (!m_pvr_channel && !m_ca_servicePtr) // don't send campmt to camd.socket for playbacked services + if (!m_pvr_channel) { - uint8_t demux_num; - m_demux->getCADemuxID(demux_num); - eDVBCAService::register_demux(m_reference, demux_num, m_ca_servicePtr); + eDVBCIInterfaces::getInstance()->gotPMT(this); + if(!m_ca_servicePtr) // don't send campmt to camd.socket for playbacked services + { + uint8_t demux_num; + m_demux->getCADemuxID(demux_num); + eDVBCAService::register_service(m_reference, demux_num, m_ca_servicePtr); + } } if (m_ca_servicePtr) { @@ -200,6 +207,15 @@ int eDVBServicePMTHandler::getProgramInfo(struct program &program) return -1; } +int eDVBServicePMTHandler::getChannel(eUsePtr &channel) +{ + channel = m_channel; + if (channel) + return 0; + else + return -1; +} + int eDVBServicePMTHandler::getDemux(ePtr &demux) { demux = m_demux; @@ -286,7 +302,7 @@ eDVBCAService::~eDVBCAService() ::close(m_sock); } -RESULT eDVBCAService::register_demux( const eServiceReferenceDVB &ref, int demux_num, eDVBCAService *&caservice ) +RESULT eDVBCAService::register_service( const eServiceReferenceDVB &ref, int demux_num, eDVBCAService *&caservice ) { CAServiceMap::iterator it = exist.find(ref); if ( it != exist.end() ) @@ -316,7 +332,7 @@ RESULT eDVBCAService::register_demux( const eServiceReferenceDVB &ref, int demux return 0; } -RESULT eDVBCAService::unregister_demux( const eServiceReferenceDVB &ref, int demux_num, eTable *ptr ) +RESULT eDVBCAService::unregister_service( const eServiceReferenceDVB &ref, int demux_num, eTable *ptr ) { CAServiceMap::iterator it = exist.find(ref); if ( it == exist.end() ) @@ -394,6 +410,7 @@ void eDVBCAService::buildCAPMT(eTable *ptr) uint8_t demux_mask = 0; uint8_t first_demux_num = 0xFF; +#if 1 int iter=0, max_demux_slots = sizeof(m_used_demux); while ( iter < max_demux_slots ) { @@ -405,6 +422,10 @@ void eDVBCAService::buildCAPMT(eTable *ptr) } ++iter; } +#else + demux_mask = 3; + first_demux_num = 0; +#endif if ( first_demux_num == 0xFF ) { @@ -424,7 +445,7 @@ void eDVBCAService::buildCAPMT(eTable *ptr) return; } - const std::vector::const_iterator i=ptr->getSections().begin(); + std::vector::const_iterator i=ptr->getSections().begin(); if ( i != ptr->getSections().end() ) { CaProgramMapSection capmt(*i++, m_prev_build_hash ? 0x05 /*update*/ : 0x03 /*only*/, 0x01 ); @@ -446,8 +467,8 @@ void eDVBCAService::buildCAPMT(eTable *ptr) tmp[0] = 0x82; // demux tmp[1] = 0x02; - tmp[3] = first_demux_num; // read section data from demux number tmp[2] = demux_mask; // descramble bitmask + tmp[3] = first_demux_num; // read section data from demux number capmt.injectDescriptor(tmp, false); tmp[0] = 0x81; // dvbnamespace