X-Git-Url: https://git.cweiske.de/enigma2.git/blobdiff_plain/c326dee2e7ce346cffecd196d971dd91ef1454f5..9f36196559617d4acec16d8ef54a452768e553c1:/lib/dvb_ci/dvbci.cpp

diff --git a/lib/dvb_ci/dvbci.cpp b/lib/dvb_ci/dvbci.cpp
index 82d3349d..632ab348 100644
--- a/lib/dvb_ci/dvbci.cpp
+++ b/lib/dvb_ci/dvbci.cpp
@@ -6,6 +6,7 @@
 #include <lib/base/ebase.h>
 
 #include <lib/base/eerror.h>
+#include <lib/base/nconfig.h> // access to python config
 #include <lib/dvb/pmt.h>
 #include <lib/dvb_ci/dvbci.h>
 #include <lib/dvb_ci/dvbci_session.h>
@@ -66,24 +67,88 @@ eDVBCISlot *eDVBCIInterfaces::getSlot(int slotid)
 	return 0;
 }
 
+int eDVBCIInterfaces::getSlotState(int slotid)
+{
+	eDVBCISlot *slot;
+
+	if( (slot = getSlot(slotid)) == 0 )
+		return eDVBCISlot::stateInvalid;
+
+	return slot->getState();
+}
+
 int eDVBCIInterfaces::reset(int slotid)
 {
 	eDVBCISlot *slot;
 
 	if( (slot = getSlot(slotid)) == 0 )
 		return -1;
-	
+
+	eDVBCISession::deleteSessions(slot);
+	ciRemoved(slot);
+
 	return slot->reset();
 }
 
+int eDVBCIInterfaces::enableTS(int slotid, int enable)
+{
+	eDVBCISlot *slot;
+
+	if( (slot = getSlot(slotid)) == 0 )
+		return -1;
+
+	int tunernum = 0;
+	PMTHandlerList::iterator it = m_pmt_handlers.begin();
+	while (it != m_pmt_handlers.end())
+	{
+		if ( it->cislot == slot )
+		{
+			eDVBServicePMTHandler *pmthandler = it->pmthandler;
+			eUsePtr<iDVBChannel> channel;
+			if (!pmthandler->getChannel(channel))
+			{
+				ePtr<iDVBFrontend> frontend;
+				if (!channel->getFrontend(frontend))
+				{
+					eDVBFrontend *fe = (eDVBFrontend*) &(*frontend);
+					tunernum = fe->getID();
+				}
+			}
+			break;
+		}
+		++it;
+	}
+	return slot->enableTS(enable, tunernum);
+}
+
 int eDVBCIInterfaces::initialize(int slotid)
 {
 	eDVBCISlot *slot;
 
 	if( (slot = getSlot(slotid)) == 0 )
 		return -1;
-	
-	return slot->initialize();
+
+	slot->removeService();
+
+	return sendCAPMT(slotid);
+}
+
+int eDVBCIInterfaces::sendCAPMT(int slotid)
+{
+	eDVBCISlot *slot;
+
+	if( (slot = getSlot(slotid)) == 0 )
+		return -1;
+
+	PMTHandlerList::iterator it = m_pmt_handlers.begin();
+	while (it != m_pmt_handlers.end())
+	{
+		if ( it->cislot == slot )
+			slot->sendCAPMT(it->pmthandler);  // send capmt
+		++it;
+	}
+
+	return 0;
 }
 
 int eDVBCIInterfaces::startMMI(int slotid)
@@ -116,88 +181,231 @@ 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(answer, value);
+	return slot->answerEnq(value);
 }
 
-void eDVBCIInterfaces::addPMTHandler(eDVBServicePMTHandler *pmthandler)
+int eDVBCIInterfaces::cancelEnq(int slotid)
 {
-	CIPmtHandler new_handler(pmthandler);
+	eDVBCISlot *slot;
 
-	eServiceReferenceDVB service;
-	pmthandler->getService(service);
+	if( (slot = getSlot(slotid)) == 0 )
+		return -1;
+	
+	return slot->cancelEnq();
+}
 
-	PMTHandlerSet::iterator it = m_pmt_handlers.begin();
-	while (it != m_pmt_handlers.end())
+void eDVBCIInterfaces::ciRemoved(eDVBCISlot *slot)
+{
+	for (PMTHandlerList::iterator it(m_pmt_handlers.begin());
+		it != m_pmt_handlers.end(); ++it)
 	{
+		if (it->cislot == slot)
+		{
+			eServiceReferenceDVB ref;
+			it->pmthandler->getServiceReference(ref);
+			slot->removeService(ref.getServiceID().get());
+			if (!--slot->use_count)
+				enableTS(slot->getSlotID(), 0);
+			it->cislot=0;
+		}
+	}
+}
+
+static bool canDescrambleMultipleServices(int slotid)
+{
+	char configStr[255];
+	snprintf(configStr, 255, "config.ci%d.canDescrambleMultipleServices", slotid);
+	std::string str;
+	ePythonConfigQuery::getConfigValue(configStr, str);
+	if ( str == "auto" )
+	{
+		std::string appname = eDVBCI_UI::getInstance()->getAppName(slotid);
+		if (appname.find("AlphaCrypt") != std::string::npos)
+			return true;
+	}
+	else if (str == "yes")
+		return true;
+	return false;
+}
+
+void eDVBCIInterfaces::recheckPMTHandlers()
+{
+//	eDebug("recheckPMTHAndlers()");
+	for (PMTHandlerList::iterator it(m_pmt_handlers.begin());
+		it != m_pmt_handlers.end(); ++it)
+	{
+		CAID_LIST caids;
+		ePtr<eDVBService> service;
 		eServiceReferenceDVB ref;
-		it->pmthandler->getService(ref);
-		if ( service == ref && it->usedby )
-			new_handler.usedby = it->usedby;
-		break;
+		eDVBServicePMTHandler *pmthandler = it->pmthandler;
+		eDVBServicePMTHandler::program p;
+
+		pmthandler->getServiceReference(ref);
+		pmthandler->getService(service);
+		if (!pmthandler->getProgramInfo(p))
+		{
+			int cnt=0;
+			for (std::set<uint16_t>::reverse_iterator x(p.caids.rbegin()); x != p.caids.rend(); ++x, ++cnt)
+				caids.push_front(*x);
+			if (service && cnt)
+				service->m_ca = caids;
+		}
+
+		if (it->cislot)
+			continue; // already running
+
+		if (service)
+			caids = service->m_ca;
+
+		if (!caids.empty())
+		{
+			for (eSmartPtrList<eDVBCISlot>::iterator ci_it(m_slots.begin()); ci_it != m_slots.end(); ++ci_it)
+			{
+				bool useThis=false;
+				eDVBCICAManagerSession *ca_manager = ci_it->getCAManager();
+				if (ca_manager)
+				{
+					const std::vector<uint16_t> &ci_caids = ca_manager->getCAIDs();
+					for (CAID_LIST::iterator ca(caids.begin()); ca != caids.end(); ++ca)
+					{
+						std::vector<uint16_t>::const_iterator z =
+							std::lower_bound(ci_caids.begin(), ci_caids.end(), *ca);
+						if ( z != ci_caids.end() && *z == *ca )
+						{
+							eDebug("found ci for caid %04x", *z);
+							useThis=true;
+							break;
+						}
+					}
+				}
+
+				if (useThis)
+				{
+					bool send_ca_pmt = false;
+					if (ci_it->use_count)  // check if this CI can descramble more than one service
+					{
+						PMTHandlerList::iterator tmp = m_pmt_handlers.begin();
+						while (tmp != m_pmt_handlers.end())
+						{
+							if ( tmp->cislot )
+							{
+								eServiceReferenceDVB ref2;
+								tmp->pmthandler->getServiceReference(ref2);
+								eDVBChannelID s1, s2;
+								if (ref != ref2)
+								{
+									ref.getChannelID(s1);
+									ref2.getChannelID(s2);
+								}
+								if (ref == ref2 || (s1 == s2 && canDescrambleMultipleServices(ci_it->getSlotID())))
+								{
+									it->cislot = tmp->cislot;
+									++it->cislot->use_count;
+									send_ca_pmt = true;
+//									eDebug("usecount now %d", it->cislot->use_count);
+									break;
+								}
+							}
+							++tmp;
+						}
+					}
+					else
+					{
+						ci_it->use_count=1;
+						it->cislot = ci_it;
+//						eDebug("usecount now %d", it->cislot->use_count);
+						enableTS(ci_it->getSlotID(), 1);
+						send_ca_pmt = true;
+					}
+					if (send_ca_pmt)
+						gotPMT(pmthandler);
+				}
+			}
+		}
 	}
-	m_pmt_handlers.insert(new_handler);
+}
+
+void eDVBCIInterfaces::addPMTHandler(eDVBServicePMTHandler *pmthandler)
+{
+	// check if this pmthandler is already registered
+	PMTHandlerList::iterator it = m_pmt_handlers.begin();
+	while (it != m_pmt_handlers.end())
+	{
+		if ( *it++ == pmthandler )
+			return;
+	}
+
+	eServiceReferenceDVB ref;
+	pmthandler->getServiceReference(ref);
+	eDebug("[eDVBCIInterfaces] addPMTHandler %s", ref.toString().c_str());
+
+	m_pmt_handlers.push_back(CIPmtHandler(pmthandler));
+	recheckPMTHandlers();
 }
 
 void eDVBCIInterfaces::removePMTHandler(eDVBServicePMTHandler *pmthandler)
 {
-	PMTHandlerSet::iterator it=m_pmt_handlers.find(pmthandler);
+	PMTHandlerList::iterator it=std::find(m_pmt_handlers.begin(),m_pmt_handlers.end(),pmthandler);
 	if (it != m_pmt_handlers.end())
 	{
-		eDVBCISlot *slot = it->usedby;
+		eDVBCISlot *slot = it->cislot;
 		eDVBServicePMTHandler *pmthandler = it->pmthandler;
 		m_pmt_handlers.erase(it);
-		if (slot)
+
+		eServiceReferenceDVB service_to_remove;
+		pmthandler->getServiceReference(service_to_remove);
+
+		bool sameServiceExist=false;
+		for (PMTHandlerList::iterator i=m_pmt_handlers.begin(); i != m_pmt_handlers.end(); ++i)
 		{
-			eServiceReferenceDVB removed_service;
-			pmthandler->getService(removed_service);
-			PMTHandlerSet::iterator it=m_pmt_handlers.begin();
-			while (it != m_pmt_handlers.end())
+			if (i->cislot)
 			{
 				eServiceReferenceDVB ref;
-				it->pmthandler->getService(ref);
-				if (ref == removed_service)
+				i->pmthandler->getServiceReference(ref);
+				if ( ref == service_to_remove )
+				{
+					sameServiceExist=true;
 					break;
-				++it;
+				}
 			}
-			if ( it == m_pmt_handlers.end() && slot->getPrevSentCAPMTVersion() != 0xFF  )
+		}
+
+		if (slot && !sameServiceExist)
+		{
+			if (slot->getNumOfServices() > 1)
 			{
+				eDebug("[eDVBCIInterfaces] remove last pmt handler for service %s send empty capmt",
+					service_to_remove.toString().c_str());
 				std::vector<uint16_t> caids;
 				caids.push_back(0xFFFF);
-				slot->sendCAPMT(pmthandler, caids);
+				slot->sendCAPMT(pmthandler, caids);  // send a capmt without caids to remove a running service
 			}
+			slot->removeService(service_to_remove.getServiceID().get());
+		}
+
+		if (slot && !--slot->use_count)
+		{
+			ASSERT(!slot->getNumOfServices());
+			enableTS(slot->getSlotID(),0);
 		}
 	}
+	// check if another service is waiting for the CI
+	recheckPMTHandlers();
 }
 
 void eDVBCIInterfaces::gotPMT(eDVBServicePMTHandler *pmthandler)
 {
 	eDebug("[eDVBCIInterfaces] gotPMT");
-	PMTHandlerSet::iterator it=m_pmt_handlers.find(pmthandler);
-	eServiceReferenceDVB service;
-	if ( it != m_pmt_handlers.end() )
-	{
-		eDebug("[eDVBCIInterfaces] usedby %p", it->usedby);
-		if (!it->usedby)
-		{
-			// HACK this assigns ALL RUNNING SERVICES to the first free CI !!!
-			for (eSmartPtrList<eDVBCISlot>::iterator ci_it(m_slots.begin()); ci_it != m_slots.end(); ++ci_it)
-			{
-				eDVBCISlot **usedby = &it->usedby;
-				*usedby = ci_it;
-				(*usedby)->resetPrevSentCAPMTVersion();
-				break;
-			}
-		}
-		if (it->usedby)
-			it->usedby->sendCAPMT(pmthandler);
-	}
+	PMTHandlerList::iterator it=std::find(m_pmt_handlers.begin(), m_pmt_handlers.end(), pmthandler);
+	if (it != m_pmt_handlers.end() && it->cislot)
+		it->cislot->sendCAPMT(pmthandler);
 }
 
 int eDVBCIInterfaces::getMMIState(int slotid)
@@ -212,18 +420,23 @@ int eDVBCIInterfaces::getMMIState(int slotid)
 
 int eDVBCISlot::send(const unsigned char *data, size_t len)
 {
-	int res;
+	int res=0;
 	//int i;
 	//printf("< ");
 	//for(i=0;i<len;i++)
 	//	printf("%02x ",data[i]);
 	//printf("\n");
 
-	res = ::write(fd, data, len);
-
-	//printf("write() %d\n",res);
+	if (sendqueue.empty())
+		res = ::write(fd, data, len);
 
-	notifier->setRequested(eSocketNotifier::Read | eSocketNotifier::Priority | eSocketNotifier::Write);
+	if (res < 0 || (unsigned int)res != len)
+	{
+		unsigned char *d = new unsigned char[len];
+		memcpy(d, data, len);
+		sendqueue.push( queueData(d, len) );
+		notifier->setRequested(eSocketNotifier::Read | eSocketNotifier::Priority | eSocketNotifier::Write);
+	}
 
 	return res;
 }
@@ -234,43 +447,57 @@ void eDVBCISlot::data(int what)
 		if(state != stateRemoved) {
 			state = stateRemoved;
 			printf("ci removed\n");
+			while(sendqueue.size())
+			{
+				delete [] sendqueue.top().data;
+				sendqueue.pop();
+			}
+			eDVBCIInterfaces::getInstance()->ciRemoved(this);
+			eDVBCISession::deleteSessions(this);
 			notifier->setRequested(eSocketNotifier::Read);
-			//HACK
-			eDVBCI_UI::getInstance()->setState(0,0);
+			eDVBCI_UI::getInstance()->setState(getSlotID(),0);
 		}
 		return;
 	}
 
-	__u8 data[4096];
-	int r;
-	r = ::read(fd, data, 4096);
+	if (state == stateInvalid)
+		reset();
 
 	if(state != stateInserted) {
-		state = stateInserted;
 		eDebug("ci inserted");
-
-		//HACK
-		eDVBCI_UI::getInstance()->setState(0,1);
-
+		state = stateInserted;
+		eDVBCI_UI::getInstance()->setState(getSlotID(),1);
+		notifier->setRequested(eSocketNotifier::Read|eSocketNotifier::Priority);
 		/* enable PRI to detect removal or errors */
-		notifier->setRequested(eSocketNotifier::Read|eSocketNotifier::Priority|eSocketNotifier::Write);
 	}
 
-	if(r > 0) {
-		//int i;
-		//printf("> ");
-		//for(i=0;i<r;i++)
-		//	printf("%02x ",data[i]);
-		//printf("\n");
-		eDVBCISession::receiveData(this, data, r);
-		notifier->setRequested(eSocketNotifier::Read|eSocketNotifier::Priority|eSocketNotifier::Write);
-		return;
+	if (what & eSocketNotifier::Read) {
+		__u8 data[4096];
+		int r;
+		r = ::read(fd, data, 4096);
+		if(r > 0) {
+//			int i;
+//			printf("> ");
+//			for(i=0;i<r;i++)
+//				printf("%02x ",data[i]);
+//			printf("\n");
+			eDVBCISession::receiveData(this, data, r);
+			eDVBCISession::pollAll();
+			return;
+		}
 	}
-
-	if(what == eSocketNotifier::Write) {
-		if(eDVBCISession::pollAll() == 0) {
-			notifier->setRequested(eSocketNotifier::Read | eSocketNotifier::Priority);
+	else if (what & eSocketNotifier::Write) {
+		if (!sendqueue.empty()) {
+			const queueData &qe = sendqueue.top();
+			int res = ::write(fd, qe.data, qe.len);
+			if (res >= 0 && (unsigned int)res == qe.len)
+			{
+				delete [] qe.data;
+				sendqueue.pop();
+			}
 		}
+		else
+			notifier->setRequested(eSocketNotifier::Read|eSocketNotifier::Priority);
 	}
 }
 
@@ -283,6 +510,7 @@ eDVBCISlot::eDVBCISlot(eMainloop *context, int nr)
 	application_manager = 0;
 	mmi_session = 0;
 	ca_manager = 0;
+	use_count = 0;
 	
 	slotid = nr;
 
@@ -291,23 +519,39 @@ eDVBCISlot::eDVBCISlot(eMainloop *context, int nr)
 	fd = ::open(filename, O_RDWR | O_NONBLOCK);
 
 	eDebug("eDVBCISlot has fd %d", fd);
-	
-	state = stateInserted;
+	state = stateInvalid;
 
 	if (fd >= 0)
 	{
-		notifier = new eSocketNotifier(context, fd, eSocketNotifier::Read | eSocketNotifier::Priority);
+		notifier = new eSocketNotifier(context, fd, eSocketNotifier::Read | eSocketNotifier::Priority | eSocketNotifier::Write);
 		CONNECT(notifier->activated, eDVBCISlot::data);
 	} else
 	{
 		perror(filename);
 	}
+
+	enableTS(0, 0);
 }
 
 eDVBCISlot::~eDVBCISlot()
 {
 }
 
+void eDVBCISlot::setAppManager( eDVBCIApplicationManagerSession *session )
+{
+	application_manager=session;
+}
+
+void eDVBCISlot::setMMIManager( eDVBCIMMISession *session )
+{
+	mmi_session = session;
+}
+
+void eDVBCISlot::setCAManager( eDVBCICAManagerSession *session )
+{
+	ca_manager = session;
+}
+
 int eDVBCISlot::getSlotID()
 {
 	return slotid;
@@ -317,14 +561,22 @@ int eDVBCISlot::reset()
 {
 	printf("edvbcislot: reset requested\n");
 
-	ioctl(fd, 0);
+	if (state == stateInvalid)
+	{
+		unsigned char buf[256];
+		eDebug("ci flush");
+		while(::read(fd, buf, 256)>0);
+		state = stateResetted;
+	}
 
-	return 0;
-}
+	while(sendqueue.size())
+	{
+		delete [] sendqueue.top().data;
+		sendqueue.pop();
+	}
+
+	ioctl(fd, 0);
 
-int eDVBCISlot::initialize()
-{
-	printf("edvbcislot: initialize()\n");
 	return 0;
 }
 
@@ -366,15 +618,34 @@ int eDVBCISlot::getMMIState()
 	return 0;
 }
 
-int eDVBCISlot::answerEnq(int answer, char *value)
+int eDVBCISlot::answerEnq(char *value)
 {
-	printf("edvbcislot: answerMMI(%d,%s)\n", answer, value);
+	printf("edvbcislot: answerENQ(%s)\n", value);
+
+	if(mmi_session)
+		mmi_session->answerEnq(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;
+	if (!ca_manager)
+	{
+		eDebug("no ca_manager (no CI plugged?)");
+		return -1;
+	}
+	const std::vector<uint16_t> &caids = ids.empty() ? ca_manager->getCAIDs() : ids;
 	ePtr<eTable<ProgramMapSection> > ptr;
 	if (pmthandler->getPMT(ptr))
 		return -1;
@@ -383,18 +654,34 @@ int eDVBCISlot::sendCAPMT(eDVBServicePMTHandler *pmthandler, const std::vector<u
 		eDVBTableSpec table_spec;
 		ptr->getSpec(table_spec);
 		int pmt_version = table_spec.version & 0x1F; // just 5 bits
-		if ( pmt_version == prev_sent_capmt_version )
+
+		eServiceReferenceDVB ref;
+		pmthandler->getServiceReference(ref);
+		uint16_t program_number = ref.getServiceID().get();
+		std::map<uint16_t, uint8_t>::iterator it =
+			running_services.find(program_number);
+
+		if ( it != running_services.end() &&
+			(pmt_version == it->second) &&
+			!(caids.size() == 1 && caids[0] == 0xFFFF) )
 		{
 			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 );
+
+//			eDebug("send %s capmt for service %04x",
+//				it != running_services.end() ? "UPDATE" : running_services.empty() ? "ONLY" : "ADD",
+//				program_number);
+
+			CaProgramMapSection capmt(*i++,
+				it != running_services.end() ? 0x05 /*update*/ : running_services.empty() ? 0x03 /*only*/ : 0x04 /*add*/, 0x01, caids );
 			while( i != ptr->getSections().end() )
 			{
 		//			eDebug("append");
@@ -404,37 +691,80 @@ int eDVBCISlot::sendCAPMT(eDVBServicePMTHandler *pmthandler, const std::vector<u
 #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 |= (raw_data[4+i] << (8 * i++));
+					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("");
+//			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)
+			if (caids.size() == 1 && caids[0] == 0xFFFF)
 			{
-				// TODO SEND buffer to CI ( add session number, add tag )
-				prev_sent_capmt_version = pmt_version;
+//				eDebugNoNewLine("SEND EMPTY CAPMT.. old version is %02x", raw_data[hlen+3]);
+				raw_data[hlen+3] &= ~0x3E;
+				raw_data[hlen+3] |= ((pmt_version+1) & 0x1F) << 1;
+//				eDebug(" new version is %02x", raw_data[hlen+3]);
 			}
+
+			//dont need tag and lenfield
+			ca_manager->sendCAPMT(raw_data + hlen, wp - hlen);
+			running_services[program_number] = pmt_version;
 		}
 	}
-	
+	return 0;
+}
+
+void eDVBCISlot::removeService(uint16_t program_number)
+{
+	if (program_number == 0xFFFF)
+		running_services.clear();  // remove all
+	else
+		running_services.erase(program_number);  // remove single service
+}
+
+int eDVBCISlot::enableTS(int enable, int tuner)
+{
+//	printf("!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!\n");
+//	printf("eDVBCISlot::enableTS(%d %d)\n", enable, tuner);
+
+	FILE *input0, *input1, *ci;
+	if((input0 = fopen("/proc/stb/tsmux/input0", "wb")) == NULL) {
+		printf("cannot open /proc/stb/tsmux/input0\n");
+		return 0;
+	}
+	if((input1 = fopen("/proc/stb/tsmux/input1", "wb")) == NULL) {
+		printf("cannot open /proc/stb/tsmux/input1\n");
+		return 0;
+	}
+	if((ci = fopen("/proc/stb/tsmux/input2", "wb")) == NULL) {
+		printf("cannot open /proc/stb/tsmux/input2\n");
+		return 0;
+	}
+
+	fprintf(ci, "%s", tuner==0 ? "A" : "B");  // configure CI data source (TunerA, TunerB)
+	fprintf(input0, "%s", tuner==0 && enable ? "CI" : "A"); // configure ATI input 0 data source
+	fprintf(input1, "%s", tuner==1 && enable ? "CI" : "B"); // configure ATI input 1 data source
+
+	fclose(input0);
+	fclose(input1);
+	fclose(ci);
+	return 0;
 }
 
 eAutoInitP0<eDVBCIInterfaces> init_eDVBCIInterfaces(eAutoInitNumbers::dvb, "CI Slots");