1 #include <lib/base/eerror.h>
2 #include <lib/base/object.h>
4 #include <lib/service/servicedvb.h>
5 #include <lib/service/service.h>
6 #include <lib/base/init_num.h>
7 #include <lib/base/init.h>
9 #include <lib/dvb/dvb.h>
10 #include <lib/dvb/db.h>
12 #include <lib/service/servicedvbrecord.h>
13 #include <lib/dvb/metaparser.h>
14 #include <lib/dvb/tstools.h>
16 class eStaticServiceDVBInformation: public iStaticServiceInformation
18 DECLARE_REF(eStaticServiceDVBInformation);
20 RESULT getName(const eServiceReference &ref, std::string &name);
21 int getLength(const eServiceReference &ref);
24 DEFINE_REF(eStaticServiceDVBInformation);
26 RESULT eStaticServiceDVBInformation::getName(const eServiceReference &ref, std::string &name)
28 if ( !ref.name.empty() )
37 int eStaticServiceDVBInformation::getLength(const eServiceReference &ref)
42 class eStaticServiceDVBBouquetInformation: public iStaticServiceInformation
44 DECLARE_REF(eStaticServiceDVBBouquetInformation);
46 RESULT getName(const eServiceReference &ref, std::string &name);
47 int getLength(const eServiceReference &ref);
50 DEFINE_REF(eStaticServiceDVBBouquetInformation);
52 RESULT eStaticServiceDVBBouquetInformation::getName(const eServiceReference &ref, std::string &name)
54 ePtr<iDVBChannelList> db;
55 ePtr<eDVBResourceManager> res;
58 if ((err = eDVBResourceManager::getInstance(res)) != 0)
60 eDebug("eStaticServiceDVBBouquetInformation::getName failed.. no resource manager!");
63 if ((err = res->getChannelList(db)) != 0)
65 eDebug("eStaticServiceDVBBouquetInformation::getName failed.. no channel list!");
70 if ((err = db->getBouquet(ref, bouquet)) != 0)
72 eDebug("eStaticServiceDVBBouquetInformation::getName failed.. getBouquet failed!");
76 if ( bouquet && bouquet->m_bouquet_name.length() )
78 name = "[Bouquet] " + bouquet->m_bouquet_name;
85 int eStaticServiceDVBBouquetInformation::getLength(const eServiceReference &ref)
90 class eStaticServiceDVBPVRInformation: public iStaticServiceInformation
92 DECLARE_REF(eStaticServiceDVBPVRInformation);
93 eServiceReference m_ref;
94 eDVBMetaParser m_parser;
96 eStaticServiceDVBPVRInformation(const eServiceReference &ref);
97 RESULT getName(const eServiceReference &ref, std::string &name);
98 int getLength(const eServiceReference &ref);
101 DEFINE_REF(eStaticServiceDVBPVRInformation);
103 eStaticServiceDVBPVRInformation::eStaticServiceDVBPVRInformation(const eServiceReference &ref)
106 m_parser.parseFile(ref.path);
109 RESULT eStaticServiceDVBPVRInformation::getName(const eServiceReference &ref, std::string &name)
111 ASSERT(ref == m_ref);
112 name = m_parser.m_name.size() ? m_parser.m_name : ref.path;
116 int eStaticServiceDVBPVRInformation::getLength(const eServiceReference &ref)
118 ASSERT(ref == m_ref);
122 if (tstools.openFile(ref.path.c_str()))
126 if (tstools.calcLen(len))
134 class eDVBPVRServiceOfflineOperations: public iServiceOfflineOperations
136 DECLARE_REF(eDVBPVRServiceOfflineOperations);
137 eServiceReferenceDVB m_ref;
139 eDVBPVRServiceOfflineOperations(const eServiceReference &ref);
141 RESULT deleteFromDisk(int simulate);
142 RESULT getListOfFilenames(std::list<std::string> &);
145 DEFINE_REF(eDVBPVRServiceOfflineOperations);
147 eDVBPVRServiceOfflineOperations::eDVBPVRServiceOfflineOperations(const eServiceReference &ref): m_ref((const eServiceReferenceDVB&)ref)
151 RESULT eDVBPVRServiceOfflineOperations::deleteFromDisk(int simulate)
157 std::list<std::string> res;
158 if (getListOfFilenames(res))
161 /* TODO: deferred removing.. */
162 for (std::list<std::string>::iterator i(res.begin()); i != res.end(); ++i)
164 eDebug("Removing %s...", i->c_str());
165 ::unlink(i->c_str());
172 RESULT eDVBPVRServiceOfflineOperations::getListOfFilenames(std::list<std::string> &res)
175 res.push_back(m_ref.path);
176 res.push_back(m_ref.path + ".meta");
180 DEFINE_REF(eServiceFactoryDVB)
182 eServiceFactoryDVB::eServiceFactoryDVB()
184 ePtr<eServiceCenter> sc;
186 eServiceCenter::getPrivInstance(sc);
188 sc->addServiceFactory(eServiceFactoryDVB::id, this);
191 eServiceFactoryDVB::~eServiceFactoryDVB()
193 ePtr<eServiceCenter> sc;
195 eServiceCenter::getPrivInstance(sc);
197 sc->removeServiceFactory(eServiceFactoryDVB::id);
200 DEFINE_REF(eDVBServiceList);
202 eDVBServiceList::eDVBServiceList(const eServiceReference &parent): m_parent(parent)
206 eDVBServiceList::~eDVBServiceList()
210 RESULT eDVBServiceList::startQuery()
212 ePtr<iDVBChannelList> db;
213 ePtr<eDVBResourceManager> res;
216 if ((err = eDVBResourceManager::getInstance(res)) != 0)
218 eDebug("no resource manager");
221 if ((err = res->getChannelList(db)) != 0)
223 eDebug("no channel list");
227 ePtr<eDVBChannelQuery> q;
229 if (!m_parent.path.empty())
231 eDVBChannelQuery::compile(q, m_parent.path);
234 eDebug("compile query failed");
239 if ((err = db->startQuery(m_query, q, m_parent)) != 0)
241 eDebug("startQuery failed");
248 RESULT eDVBServiceList::getContent(std::list<eServiceReference> &list)
250 eServiceReferenceDVB ref;
255 while (!m_query->getNextResult(ref))
260 RESULT eDVBServiceList::getNext(eServiceReference &ref)
265 return m_query->getNextResult((eServiceReferenceDVB&)ref);
268 int eDVBServiceList::compareLessEqual(const eServiceReference &a, const eServiceReference &b)
270 return m_query->compareLessEqual((const eServiceReferenceDVB&)a, (const eServiceReferenceDVB&)b);
273 RESULT eDVBServiceList::startEdit(ePtr<iMutableServiceList> &res)
275 if (m_parent.flags & eServiceReference::flagDirectory) // bouquet
277 ePtr<iDVBChannelList> db;
278 ePtr<eDVBResourceManager> resm;
280 if (eDVBResourceManager::getInstance(resm) || resm->getChannelList(db))
283 if (db->getBouquet(m_parent, m_bouquet) != 0)
294 RESULT eDVBServiceList::addService(eServiceReference &ref)
298 return m_bouquet->addService(ref);
301 RESULT eDVBServiceList::removeService(eServiceReference &ref)
305 return m_bouquet->removeService(ref);
308 RESULT eDVBServiceList::moveService(eServiceReference &ref, int pos)
312 return m_bouquet->moveService(ref, pos);
315 RESULT eDVBServiceList::flushChanges()
319 return m_bouquet->flushChanges();
322 RESULT eServiceFactoryDVB::play(const eServiceReference &ref, ePtr<iPlayableService> &ptr)
324 ePtr<eDVBService> service;
325 int r = lookupService(service, ref);
328 // check resources...
329 ptr = new eDVBServicePlay(ref, service);
333 RESULT eServiceFactoryDVB::record(const eServiceReference &ref, ePtr<iRecordableService> &ptr)
335 if (ref.path.empty())
337 ptr = new eDVBServiceRecord((eServiceReferenceDVB&)ref);
346 RESULT eServiceFactoryDVB::list(const eServiceReference &ref, ePtr<iListableService> &ptr)
348 ePtr<eDVBServiceList> list = new eDVBServiceList(ref);
349 if (list->startQuery())
359 RESULT eServiceFactoryDVB::info(const eServiceReference &ref, ePtr<iStaticServiceInformation> &ptr)
361 /* is a listable service? */
362 if ((ref.flags & eServiceReference::flagDirectory) == eServiceReference::flagDirectory) // bouquet
364 if ( !ref.name.empty() ) // satellites or providers list
365 ptr = new eStaticServiceDVBInformation;
366 else // a dvb bouquet
367 ptr = new eStaticServiceDVBBouquetInformation;
370 else if (!ref.path.empty()) /* do we have a PVR service? */
372 ptr = new eStaticServiceDVBPVRInformation(ref);
375 else // normal dvb service
377 ePtr<eDVBService> service;
378 int r = lookupService(service, ref);
379 if (r) // no eDVBService avail for this reference ( Linkage Services... )
380 ptr = new eStaticServiceDVBInformation;
382 /* eDVBService has the iStaticServiceInformation interface, so we pass it here. */
388 RESULT eServiceFactoryDVB::offlineOperations(const eServiceReference &ref, ePtr<iServiceOfflineOperations> &ptr)
390 if (ref.path.empty())
396 ptr = new eDVBPVRServiceOfflineOperations(ref);
401 RESULT eServiceFactoryDVB::lookupService(ePtr<eDVBService> &service, const eServiceReference &ref)
403 // TODO: handle the listing itself
404 // if (ref.... == -1) .. return "... bouquets ...";
405 // could be also done in another serviceFactory (with seperate ID) to seperate actual services and lists
407 ePtr<iDVBChannelList> db;
408 ePtr<eDVBResourceManager> res;
411 if ((err = eDVBResourceManager::getInstance(res)) != 0)
413 eDebug("no resource manager");
416 if ((err = res->getChannelList(db)) != 0)
418 eDebug("no channel list");
422 /* we are sure to have a ..DVB reference as the info() call was forwarded here according to it's ID. */
423 if ((err = db->getService((eServiceReferenceDVB&)ref, service)) != 0)
425 eDebug("getService failed!");
432 eDVBServicePlay::eDVBServicePlay(const eServiceReference &ref, eDVBService *service):
433 m_reference(ref), m_dvb_service(service), m_service_handler(0), m_is_paused(0)
435 m_is_pvr = !ref.path.empty();
437 CONNECT(m_service_handler.serviceEvent, eDVBServicePlay::serviceEvent);
438 CONNECT(m_event_handler.m_eit_changed, eDVBServicePlay::gotNewEvent);
441 eDVBServicePlay::~eDVBServicePlay()
445 void eDVBServicePlay::gotNewEvent()
449 ePtr<eServiceEvent> m_event_now, m_event_next;
450 getEvent(m_event_now, 0);
451 getEvent(m_event_next, 1);
454 eDebug("now running: %s (%d seconds :)", m_event_now->m_event_name.c_str(), m_event_now->m_duration);
456 eDebug("next running: %s (%d seconds :)", m_event_next->m_event_name.c_str(), m_event_next->m_duration);
458 m_event((iPlayableService*)this, evUpdatedEventInfo);
461 void eDVBServicePlay::serviceEvent(int event)
465 case eDVBServicePMTHandler::eventTuned:
467 ePtr<iDVBDemux> m_demux;
468 if (!m_service_handler.getDemux(m_demux))
470 // eventStartedEventAcquisition
471 m_event_handler.start(m_demux, ((eServiceReferenceDVB&)m_reference).getServiceID().get());
476 case eDVBServicePMTHandler::eventTuneFailed:
478 eDebug("DVB service failed to tune");
479 m_event((iPlayableService*)this, evTuneFailed);
482 case eDVBServicePMTHandler::eventNewProgramInfo:
484 int vpid = -1, apid = -1, apidtype = -1, pcrpid = -1;
485 eDVBServicePMTHandler::program program;
486 if (m_service_handler.getProgramInfo(program))
487 eDebug("getting program info failed.");
490 eDebugNoNewLine("have %d video stream(s)", program.videoStreams.size());
491 if (!program.videoStreams.empty())
493 eDebugNoNewLine(" (");
494 for (std::vector<eDVBServicePMTHandler::videoStream>::const_iterator
495 i(program.videoStreams.begin());
496 i != program.videoStreams.end(); ++i)
500 if (i != program.videoStreams.begin())
501 eDebugNoNewLine(", ");
502 eDebugNoNewLine("%04x", i->pid);
504 eDebugNoNewLine(")");
506 eDebugNoNewLine(", and %d audio stream(s)", program.audioStreams.size());
507 if (!program.audioStreams.empty())
509 eDebugNoNewLine(" (");
510 for (std::vector<eDVBServicePMTHandler::audioStream>::const_iterator
511 i(program.audioStreams.begin());
512 i != program.audioStreams.end(); ++i)
519 if (i != program.audioStreams.begin())
520 eDebugNoNewLine(", ");
521 eDebugNoNewLine("%04x", i->pid);
523 eDebugNoNewLine(")");
525 eDebug(", and the pcr pid is %04x", program.pcrPid);
526 if (program.pcrPid != 0x1fff)
527 pcrpid = program.pcrPid;
532 ePtr<iDVBDemux> demux;
533 m_service_handler.getDemux(demux);
535 demux->getMPEGDecoder(m_decoder);
540 m_decoder->setVideoPID(vpid);
541 m_current_audio_stream = 0;
542 m_decoder->setAudioPID(apid, apidtype);
544 m_decoder->setSyncPCR(pcrpid);
546 m_decoder->setSyncPCR(-1);
548 // how we can do this better?
549 // update cache pid when the user changed the audio track or video track
550 // TODO handling of difference audio types.. default audio types..
552 /* don't worry about non-existing services, nor pvr services */
553 if (m_dvb_service && !m_is_pvr)
555 m_dvb_service->setCachePID(eDVBService::cVPID, vpid);
556 m_dvb_service->setCachePID(eDVBService::cAPID, apid);
557 m_dvb_service->setCachePID(eDVBService::cPCRPID, pcrpid);
566 RESULT eDVBServicePlay::start()
569 eDebug("starting DVB service");
570 r = m_service_handler.tune((eServiceReferenceDVB&)m_reference);
571 eDebug("tune result: %d", r);
572 m_event(this, evStart);
576 RESULT eDVBServicePlay::stop()
578 eDebug("stopping..");
582 RESULT eDVBServicePlay::connectEvent(const Slot2<void,iPlayableService*,int> &event, ePtr<eConnection> &connection)
584 connection = new eConnection((iPlayableService*)this, m_event.connect(event));
588 RESULT eDVBServicePlay::pause(ePtr<iPauseableService> &ptr)
600 RESULT eDVBServicePlay::seek(ePtr<iSeekableService> &ptr)
612 RESULT eDVBServicePlay::getLength(pts_t &len)
614 ePtr<iDVBPVRChannel> pvr_channel;
616 if (m_service_handler.getPVRChannel(pvr_channel))
618 eDebug("getPVRChannel failed!");
622 return pvr_channel->getLength(len);
625 RESULT eDVBServicePlay::pause()
627 if (!m_is_paused && m_decoder)
630 return m_decoder->freeze(0);
635 RESULT eDVBServicePlay::unpause()
637 if (m_is_paused && m_decoder)
640 return m_decoder->unfreeze();
645 RESULT eDVBServicePlay::seekTo(pts_t to)
650 RESULT eDVBServicePlay::seekRelative(int direction, pts_t to)
652 eDebug("eDVBServicePlay::seekRelative: jump %d, %lld", direction, to);
654 ePtr<iDVBPVRChannel> pvr_channel;
656 if (m_service_handler.getPVRChannel(pvr_channel))
661 ePtr<iDVBDemux> demux;
662 m_service_handler.getDemux(demux);
666 return pvr_channel->seekTo(demux, 1, to);
669 RESULT eDVBServicePlay::getPlayPosition(pts_t &pos)
671 ePtr<iDVBPVRChannel> pvr_channel;
673 if (m_service_handler.getPVRChannel(pvr_channel))
676 ePtr<iDVBDemux> demux;
677 m_service_handler.getDemux(demux);
681 return pvr_channel->getCurrentPosition(demux, pos);
684 RESULT eDVBServicePlay::frontendStatusInfo(ePtr<iFrontendStatusInformation> &ptr)
690 RESULT eDVBServicePlay::info(ePtr<iServiceInformation> &ptr)
696 RESULT eDVBServicePlay::audioTracks(ePtr<iAudioTrackSelection> &ptr)
702 RESULT eDVBServicePlay::getName(std::string &name)
706 m_dvb_service->getName(m_reference, name);
710 name = "DVB service";
714 RESULT eDVBServicePlay::getEvent(ePtr<eServiceEvent> &evt, int nownext)
716 return m_event_handler.getEvent(evt, nownext);
719 int eDVBServicePlay::getInfo(int w)
721 eDVBServicePMTHandler::program program;
723 if (m_service_handler.getProgramInfo(program))
728 case sVideoPID: if (program.videoStreams.empty()) return -1; return program.videoStreams[0].pid;
729 case sAudioPID: if (program.audioStreams.empty()) return -1; return program.audioStreams[m_current_audio_stream].pid;
730 case sPCRPID: return program.pcrPid;
731 case sPMTPID: return program.pmtPid;
732 case sTXTPID: return -1;
734 case sSID: return ((const eServiceReferenceDVB&)m_reference).getServiceID().get();
735 case sONID: return ((const eServiceReferenceDVB&)m_reference).getOriginalNetworkID().get();
736 case sTSID: return ((const eServiceReferenceDVB&)m_reference).getTransportStreamID().get();
737 case sNamespace: return ((const eServiceReferenceDVB&)m_reference).getDVBNamespace().get();
738 case sProvider: if (!m_dvb_service) return -1; return -2;
744 std::string eDVBServicePlay::getInfoString(int w)
749 if (!m_dvb_service) return "";
750 return m_dvb_service->m_provider_name;
756 int eDVBServicePlay::getNumberOfTracks()
758 eDVBServicePMTHandler::program program;
759 if (m_service_handler.getProgramInfo(program))
761 return program.audioStreams.size();
764 RESULT eDVBServicePlay::selectTrack(unsigned int i)
766 int ret = selectAudioStream(i);
768 if (m_decoder->start())
774 RESULT eDVBServicePlay::getTrackInfo(struct iAudioTrackInfo &info, unsigned int i)
776 eDVBServicePMTHandler::program program;
778 if (m_service_handler.getProgramInfo(program))
781 if (i >= program.audioStreams.size())
784 if (program.audioStreams[i].type == eDVBServicePMTHandler::audioStream::atMPEG)
785 info.m_description = "MPEG";
786 else if (program.audioStreams[i].type == eDVBServicePMTHandler::audioStream::atAC3)
787 info.m_description = "AC3";
788 else if (program.audioStreams[i].type == eDVBServicePMTHandler::audioStream::atDTS)
789 info.m_description = "DTS";
791 info.m_description = "???";
793 /* CHECK here for component tag override. */
794 info.m_language = program.audioStreams[i].language_code;
799 int eDVBServicePlay::selectAudioStream(int i)
801 eDVBServicePMTHandler::program program;
803 if (m_service_handler.getProgramInfo(program))
806 if (i >= program.audioStreams.size())
812 if (m_decoder->setAudioPID(program.audioStreams[i].pid, program.audioStreams[i].type))
815 m_current_audio_stream = i;
820 int eDVBServicePlay::getFrontendInfo(int w)
824 eUsePtr<iDVBChannel> channel;
825 if(m_service_handler.getChannel(channel))
827 ePtr<iDVBFrontend> fe;
828 if(channel->getFrontend(fe))
830 return fe->readFrontendData(w);
833 DEFINE_REF(eDVBServicePlay)
835 eAutoInitPtr<eServiceFactoryDVB> init_eServiceFactoryDVB(eAutoInitNumbers::service+1, "eServiceFactoryDVB");