X-Git-Url: https://git.cweiske.de/enigma2.git/blobdiff_plain/bb9abed29ca9126cc2b8a0fa3d76ea2e7245cee7..66238a69f495173897e7e1e62a7f05ff4356ae44:/lib/dvb_ci/dvbci.cpp

diff --git a/lib/dvb_ci/dvbci.cpp b/lib/dvb_ci/dvbci.cpp
index cf7acde6..8f1fcac9 100644
--- a/lib/dvb_ci/dvbci.cpp
+++ b/lib/dvb_ci/dvbci.cpp
@@ -6,13 +6,16 @@
 #include <lib/base/ebase.h>
 
 #include <lib/base/eerror.h>
+#include <lib/dvb/pmt.h>
 #include <lib/dvb_ci/dvbci.h>
 #include <lib/dvb_ci/dvbci_session.h>
-
+#include <lib/dvb_ci/dvbci_camgr.h>
 #include <lib/dvb_ci/dvbci_ui.h>
 #include <lib/dvb_ci/dvbci_appmgr.h>
 #include <lib/dvb_ci/dvbci_mmi.h>
 
+#include <dvbsi++/ca_program_map_section.h>
+
 eDVBCIInterfaces *eDVBCIInterfaces::instance = 0;
 
 eDVBCIInterfaces::eDVBCIInterfaces()
@@ -113,14 +116,118 @@ int eDVBCIInterfaces::answerText(int slotid, int answer)
 	return slot->answerText(answer);
 }
 
-int eDVBCIInterfaces::answerEnq(int slotid, int answer, char *value)
+int eDVBCIInterfaces::answerEnq(int slotid, char *value)
+{
+	eDVBCISlot *slot;
+
+	if( (slot = getSlot(slotid)) == 0 )
+		return -1;
+	
+	return slot->answerEnq(value);
+}
+
+int eDVBCIInterfaces::cancelEnq(int slotid)
+{
+	eDVBCISlot *slot;
+
+	if( (slot = getSlot(slotid)) == 0 )
+		return -1;
+	
+	return slot->cancelEnq();
+}
+
+void eDVBCIInterfaces::addPMTHandler(eDVBServicePMTHandler *pmthandler)
+{
+	CIPmtHandler new_handler(pmthandler);
+
+	eServiceReferenceDVB service;
+	pmthandler->getService(service);
+
+	eDebug("[eDVBCIInterfaces] addPMTHandler %s", service.toString().c_str());
+
+	// HACK the first service get the CI..
+	eSmartPtrList<eDVBCISlot>::iterator ci_it(m_slots.begin());
+	for (; ci_it != m_slots.end(); ++ci_it)
+	{
+		if (ci_it->use_count)
+			continue;
+		ci_it->use_count=1;
+		new_handler.cislot = ci_it;
+		new_handler.cislot->resetPrevSentCAPMTVersion();
+	}
+
+	if (ci_it == m_slots.end())
+	{
+		PMTHandlerList::iterator it = m_pmt_handlers.begin();
+		while (it != m_pmt_handlers.end())
+		{
+			eServiceReferenceDVB ref;
+			it->pmthandler->getService(ref);
+			if ( service == ref && it->cislot )
+			{
+				new_handler.cislot = it->cislot;
+				++new_handler.cislot->use_count;
+				break;
+			}
+			++it;
+		}
+	}
+
+	m_pmt_handlers.push_back(new_handler);
+}
+
+void eDVBCIInterfaces::removePMTHandler(eDVBServicePMTHandler *pmthandler)
+{
+	PMTHandlerList::iterator it=std::find(m_pmt_handlers.begin(),m_pmt_handlers.end(),pmthandler);
+	if (it != m_pmt_handlers.end())
+	{
+		eDVBCISlot *slot = it->cislot;
+		eDVBServicePMTHandler *pmthandler = it->pmthandler;
+		m_pmt_handlers.erase(it);
+		if (slot && !--slot->use_count)
+		{
+#if 0
+			eDebug("[eDVBCIInterfaces] remove last pmt handler for service %s send empty capmt");
+			std::vector<uint16_t> caids;
+			caids.push_back(0xFFFF);
+			slot->resetPrevSentCAPMTVersion();
+			slot->sendCAPMT(pmthandler, caids);
+#endif
+	// check if another service is running
+			it = m_pmt_handlers.begin();
+			while (it != m_pmt_handlers.end())
+			{
+				if ( !it->cislot )
+				{
+					it->cislot = slot;
+					++slot->use_count;
+					slot->resetPrevSentCAPMTVersion();
+					slot->sendCAPMT(it->pmthandler);
+					break;
+				}
+				++it;
+			}
+		}
+	}
+}
+
+void eDVBCIInterfaces::gotPMT(eDVBServicePMTHandler *pmthandler)
+{
+	eDebug("[eDVBCIInterfaces] gotPMT");
+	PMTHandlerList::iterator it=std::find(m_pmt_handlers.begin(), m_pmt_handlers.end(), pmthandler);
+	eServiceReferenceDVB service;
+	if ( it != m_pmt_handlers.end() && it->cislot)
+		it->cislot->sendCAPMT(pmthandler);
+}
+
+int eDVBCIInterfaces::getMMIState(int slotid)
 {
 	eDVBCISlot *slot;
 
 	if( (slot = getSlot(slotid)) == 0 )
 		return -1;
 	
-	return slot->answerEnq(answer, value);
+	return slot->getMMIState();
 }
 
 int eDVBCISlot::send(const unsigned char *data, size_t len)
@@ -195,6 +302,8 @@ eDVBCISlot::eDVBCISlot(eMainloop *context, int nr)
 
 	application_manager = 0;
 	mmi_session = 0;
+	ca_manager = 0;
+	use_count = 0;
 	
 	slotid = nr;
 
@@ -270,10 +379,97 @@ int eDVBCISlot::answerText(int answer)
 	return 0;
 }
 
-int eDVBCISlot::answerEnq(int answer, char *value)
+int eDVBCISlot::getMMIState()
+{
+	if(mmi_session)
+		return 1;
+
+	return 0;
+}
+
+int eDVBCISlot::answerEnq(char *value)
 {
-	printf("edvbcislot: answerMMI(%d,%s)\n", answer, value);
+	printf("edvbcislot: answerENQ(%s)\n", value);
 	return 0;
 }
 
+int eDVBCISlot::cancelEnq()
+{
+	printf("edvbcislot: cancelENQ\n");
+
+	if(mmi_session)
+		mmi_session->cancelEnq();
+
+	return 0;
+}
+
+int eDVBCISlot::sendCAPMT(eDVBServicePMTHandler *pmthandler, const std::vector<uint16_t> &ids)
+{
+	const std::vector<uint16_t> &caids = ids.empty() && ca_manager ? ca_manager->getCAIDs() : ids;
+	ePtr<eTable<ProgramMapSection> > ptr;
+	if (pmthandler->getPMT(ptr))
+		return -1;
+	else
+	{
+		eDVBTableSpec table_spec;
+		ptr->getSpec(table_spec);
+		int pmt_version = table_spec.version & 0x1F; // just 5 bits
+		if ( pmt_version == prev_sent_capmt_version )
+		{
+			eDebug("[eDVBCISlot] dont sent self capmt version twice");
+			return -1;
+		}
+		std::vector<ProgramMapSection*>::const_iterator i=ptr->getSections().begin();
+		if ( i == ptr->getSections().end() )
+			return -1;
+		else
+		{
+			unsigned char raw_data[2048];
+			CaProgramMapSection capmt(*i++, prev_sent_capmt_version != 0xFF ? 0x05 /*update*/ : 0x03 /*only*/, 0x01, caids );
+			while( i != ptr->getSections().end() )
+			{
+		//			eDebug("append");
+				capmt.append(*i++);
+			}
+			capmt.writeToBuffer(raw_data);
+#if 1
+// begin calc capmt length
+			int wp=0;
+			int hlen;
+			if ( raw_data[3] & 0x80 )
+			{
+				int i=0;
+				int lenbytes = raw_data[3] & ~0x80;
+				while(i < lenbytes)
+					wp = (wp << 8) | raw_data[4 + i++];
+				wp+=4;
+				wp+=lenbytes;
+				hlen = 4 + lenbytes;
+			}
+			else
+			{
+				wp = raw_data[3];
+				wp+=4;
+				hlen = 4;
+			}
+// end calc capmt length
+			if (!ca_manager)
+				eDebug("no ca_manager !!! dump unfiltered capmt:");
+			else
+				eDebug("ca_manager %p dump capmt:", ca_manager);
+			for(int i=0;i<wp;i++)
+				eDebugNoNewLine("%02x ", raw_data[i]);
+			eDebug("");
+#endif
+			if (ca_manager)
+			{
+				//dont need tag and lenfield
+				ca_manager->sendCAPMT(raw_data + hlen, wp - hlen);
+				prev_sent_capmt_version = pmt_version;
+			}
+		}
+	}
+	
+}
+
 eAutoInitP0<eDVBCIInterfaces> init_eDVBCIInterfaces(eAutoInitNumbers::dvb, "CI Slots");