1 #include <lib/base/eerror.h>
2 #include <lib/dvb/pmt.h>
3 #include <lib/dvb/specs.h>
4 #include <lib/dvb/dvb.h>
6 eDVBServicePMTHandler::eDVBServicePMTHandler()
8 ePtr<eDVBResourceManager> mgr;
9 eDVBResourceManager::getInstance(mgr);
10 m_resourceManager = mgr;
11 CONNECT(m_PMT.tableReady, eDVBServicePMTHandler::PMTready);
12 CONNECT(m_PAT.tableReady, eDVBServicePMTHandler::PATready);
15 void eDVBServicePMTHandler::channelStateChanged(iDVBChannel *channel)
18 channel->getState(state);
20 if ((m_last_channel_state != iDVBChannel::state_ok)
21 && (state == iDVBChannel::state_ok) && (!m_demux))
24 if (m_channel->getDemux(m_demux))
25 eDebug("shit it failed.. again.");
27 serviceEvent(eventTuned);
31 eDebug("ok ... now we start!!");
33 /* emit */ m_resourceManager->m_channelRunning(channel);
35 m_PAT.begin(eApp, eDVBPATSpec(), m_demux);
40 void eDVBServicePMTHandler::PMTready(int error)
43 serviceEvent(eventNoPMT);
45 serviceEvent(eventNewProgramInfo);
48 void eDVBServicePMTHandler::PATready(int)
51 ePtr<eTable<ProgramAssociationTable> > ptr;
52 if (!m_PAT.getCurrent(ptr))
55 ProgramAssociationTableConstIterator i;
56 for (i = ptr->getSections().begin(); i != ptr->getSections().end(); ++i)
58 const ProgramAssociationTable &pat = **i;
59 ProgramAssociationConstIterator program;
60 for (program = pat.getPrograms()->begin(); program != pat.getPrograms()->end(); ++program)
61 if (eServiceID((*program)->getProgramNumber()) == m_reference.getServiceID())
62 pmtpid = (*program)->getProgramMapPid();
65 serviceEvent(eventNoPATEntry);
67 m_PMT.begin(eApp, eDVBPMTSpec(pmtpid, m_reference.getServiceID().get()), m_demux);
69 serviceEvent(eventNoPAT);
72 int eDVBServicePMTHandler::getProgramInfo(struct program &program)
75 ePtr<eTable<ProgramMapTable> > ptr;
77 program.videoStreams.clear();
78 program.audioStreams.clear();
81 if (!m_PMT.getCurrent(ptr))
83 ProgramMapTableConstIterator i;
84 for (i = ptr->getSections().begin(); i != ptr->getSections().end(); ++i)
86 const ProgramMapTable &pmt = **i;
87 program.pcrPid = pmt.getPcrPid();
89 ElementaryStreamInfoConstIterator es;
90 for (es = pmt.getEsInfo()->begin(); es != pmt.getEsInfo()->end(); ++es)
92 int isaudio = 0, isvideo = 0;
96 video.pid = (*es)->getPid();
97 audio.pid = (*es)->getPid();
99 switch ((*es)->getType())
101 case 0x01: // MPEG 1 video
102 case 0x02: // MPEG 2 video
105 case 0x03: // MPEG 1 audio
106 case 0x04: // MPEG 2 audio:
108 audio.type = audioStream::atMPEG;
112 program.audioStreams.push_back(audio);
114 program.videoStreams.push_back(video);
122 int eDVBServicePMTHandler::getDemux(ePtr<iDVBDemux> &demux)
131 int eDVBServicePMTHandler::tune(eServiceReferenceDVB &ref)
136 // ref.path = "/viva.ts"; // hrhr.
138 /* is this a normal (non PVR) channel? */
139 if (ref.path.empty())
142 ref.getChannelID(chid);
143 res = m_resourceManager->allocateChannel(chid, m_channel);
148 res = m_resourceManager->allocatePVRChannel(m_pvr_channel);
150 eDebug("allocatePVRChannel failed!\n");
151 m_channel = m_pvr_channel;
156 m_channel->connectStateChange(
157 slot(*this, &eDVBServicePMTHandler::channelStateChanged),
158 m_channelStateChanged_connection);
159 m_last_channel_state = -1;
160 channelStateChanged(m_channel);
164 m_pvr_channel->playFile(ref.path.c_str());