1 #include <lib/base/eerror.h>
2 #include <lib/dvb/pmt.h>
3 #include <lib/dvb/specs.h>
4 #include <lib/dvb/dvb.h>
5 #include <lib/dvb/metaparser.h>
7 eDVBServicePMTHandler::eDVBServicePMTHandler()
9 ePtr<eDVBResourceManager> mgr;
10 eDVBResourceManager::getInstance(mgr);
11 m_resourceManager = mgr;
12 CONNECT(m_PMT.tableReady, eDVBServicePMTHandler::PMTready);
13 CONNECT(m_PAT.tableReady, eDVBServicePMTHandler::PATready);
16 void eDVBServicePMTHandler::channelStateChanged(iDVBChannel *channel)
19 channel->getState(state);
21 if ((m_last_channel_state != iDVBChannel::state_ok)
22 && (state == iDVBChannel::state_ok) && (!m_demux))
25 if (m_channel->getDemux(m_demux))
26 eDebug("shit it failed.. again.");
28 serviceEvent(eventTuned);
32 eDebug("ok ... now we start!!");
34 /* emit */ m_resourceManager->m_channelRunning(channel);
36 m_PAT.begin(eApp, eDVBPATSpec(), m_demux);
41 void eDVBServicePMTHandler::PMTready(int error)
44 serviceEvent(eventNoPMT);
46 serviceEvent(eventNewProgramInfo);
49 void eDVBServicePMTHandler::PATready(int)
52 ePtr<eTable<ProgramAssociationTable> > ptr;
53 if (!m_PAT.getCurrent(ptr))
56 ProgramAssociationTableConstIterator i;
57 for (i = ptr->getSections().begin(); i != ptr->getSections().end(); ++i)
59 const ProgramAssociationTable &pat = **i;
60 ProgramAssociationConstIterator program;
61 for (program = pat.getPrograms()->begin(); program != pat.getPrograms()->end(); ++program)
62 if (eServiceID((*program)->getProgramNumber()) == m_reference.getServiceID())
63 pmtpid = (*program)->getProgramMapPid();
66 serviceEvent(eventNoPATEntry);
68 m_PMT.begin(eApp, eDVBPMTSpec(pmtpid, m_reference.getServiceID().get()), m_demux);
70 serviceEvent(eventNoPAT);
73 int eDVBServicePMTHandler::getProgramInfo(struct program &program)
76 ePtr<eTable<ProgramMapTable> > ptr;
78 program.videoStreams.clear();
79 program.audioStreams.clear();
82 if (!m_PMT.getCurrent(ptr))
84 ProgramMapTableConstIterator i;
85 for (i = ptr->getSections().begin(); i != ptr->getSections().end(); ++i)
87 const ProgramMapTable &pmt = **i;
88 program.pcrPid = pmt.getPcrPid();
90 ElementaryStreamInfoConstIterator es;
91 for (es = pmt.getEsInfo()->begin(); es != pmt.getEsInfo()->end(); ++es)
93 int isaudio = 0, isvideo = 0;
97 video.pid = (*es)->getPid();
98 audio.pid = (*es)->getPid();
100 switch ((*es)->getType())
102 case 0x01: // MPEG 1 video
103 case 0x02: // MPEG 2 video
106 case 0x03: // MPEG 1 audio
107 case 0x04: // MPEG 2 audio:
109 audio.type = audioStream::atMPEG;
113 program.audioStreams.push_back(audio);
115 program.videoStreams.push_back(video);
123 int eDVBServicePMTHandler::getDemux(ePtr<iDVBDemux> &demux)
132 int eDVBServicePMTHandler::tune(eServiceReferenceDVB &ref)
137 // ref.path = "/viva.ts"; // hrhr.
139 /* is this a normal (non PVR) channel? */
140 if (ref.path.empty())
143 ref.getChannelID(chid);
144 res = m_resourceManager->allocateChannel(chid, m_channel);
147 eDVBMetaParser parser;
149 if (parser.parseFile(ref.path))
150 eWarning("no .meta file found, trying original service ref.");
152 m_reference = parser.m_ref;
156 res = m_resourceManager->allocatePVRChannel(m_pvr_channel);
158 eDebug("allocatePVRChannel failed!\n");
159 m_channel = m_pvr_channel;
164 m_channel->connectStateChange(
165 slot(*this, &eDVBServicePMTHandler::channelStateChanged),
166 m_channelStateChanged_connection);
167 m_last_channel_state = -1;
168 channelStateChanged(m_channel);
172 m_pvr_channel->playFile(ref.path.c_str());