fix small bug introduced with v2 merging
[enigma2.git] / lib / dvb / pmt.cpp
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
6 eDVBServicePMTHandler::eDVBServicePMTHandler()
7 {
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);
13 }
14
15 void eDVBServicePMTHandler::channelStateChanged(iDVBChannel *channel)
16 {
17         int state;
18         channel->getState(state);
19         
20         if ((m_last_channel_state != iDVBChannel::state_ok)
21                 && (state == iDVBChannel::state_ok) && (!m_demux))
22         {
23                 if (m_channel)
24                         if (m_channel->getDemux(m_demux))
25                                 eDebug("shit it failed.. again.");
26                 
27                 if (m_demux)
28                 {       
29                         eDebug("ok ... now we start!!");
30                         m_PAT.begin(eApp, eDVBPATSpec(), m_demux);
31                 }
32         }
33 }
34
35 void eDVBServicePMTHandler::PMTready(int error)
36 {
37         if (error)
38                 serviceEvent(eventNoPMT);
39         else
40                 serviceEvent(eventNewProgramInfo);
41 }
42
43 void eDVBServicePMTHandler::PATready(int)
44 {
45         ePtr<eTable<ProgramAssociationTable> > ptr;
46         if (!m_PAT.getCurrent(ptr))
47         {
48                 int pmtpid = -1;
49                 ProgramAssociationTableConstIterator i;
50                 for (i = ptr->getSections().begin(); i != ptr->getSections().end(); ++i)
51                 {
52                         const ProgramAssociationTable &pat = **i;
53                         ProgramAssociationConstIterator program;
54                         for (program = pat.getPrograms()->begin(); program != pat.getPrograms()->end(); ++program)
55                                 if (eServiceID((*program)->getProgramNumber()) == m_reference.getServiceID())
56                                         pmtpid = (*program)->getProgramMapPid();
57                 }
58                 if (pmtpid == -1)
59                         serviceEvent(eventNoPATEntry);
60                 else
61                         m_PMT.begin(eApp, eDVBPMTSpec(pmtpid, m_reference.getServiceID().get()), m_demux);
62         } else
63                 serviceEvent(eventNoPAT);
64 }
65
66 int eDVBServicePMTHandler::getProgramInfo(struct program &program)
67 {
68         ePtr<eTable<ProgramMapTable> > ptr;
69         
70         program.videoStreams.clear();
71         program.audioStreams.clear();
72         program.pcrPid = -1;
73         
74         if (!m_PMT.getCurrent(ptr))
75         {
76                 ProgramMapTableConstIterator i;
77                 for (i = ptr->getSections().begin(); i != ptr->getSections().end(); ++i)
78                 {
79                         const ProgramMapTable &pmt = **i;
80                         program.pcrPid = pmt.getPcrPid();
81                         
82                         ElementaryStreamInfoConstIterator es;
83                         for (es = pmt.getEsInfo()->begin(); es != pmt.getEsInfo()->end(); ++es)
84                         {
85                                 int isaudio = 0, isvideo = 0;
86                                 videoStream video;
87                                 audioStream audio;
88                                 
89                                 video.pid = (*es)->getPid();
90                                 audio.pid = (*es)->getPid();
91                                 
92                                 switch ((*es)->getType())
93                                 {
94                                 case 0x01: // MPEG 1 video
95                                 case 0x02: // MPEG 2 video
96                                         isvideo = 1;
97                                         break;
98                                 case 0x03: // MPEG 1 audio
99                                 case 0x04: // MPEG 2 audio:
100                                         isaudio = 1;
101                                         audio.type = audioStream::atMPEG;
102                                         break;
103                                 }
104                                 if (isaudio)
105                                         program.audioStreams.push_back(audio);
106                                 if (isvideo)
107                                         program.videoStreams.push_back(video);
108                         }
109                 }
110                 return 0;
111         } else
112                 return -1;
113 }
114
115 int eDVBServicePMTHandler::getDemux(ePtr<iDVBDemux> &demux)
116 {
117         demux = m_demux;
118         if (demux)
119                 return 0;
120         else
121                 return -1;
122 }
123
124 int eDVBServicePMTHandler::tune(eServiceReferenceDVB &ref)
125 {
126         RESULT res;
127         m_channel = 0;
128         m_channelStateChanged_connection = 0;
129         m_reference = ref;
130         eDVBChannelID chid;
131         ref.getChannelID(chid);
132         res = m_resourceManager->allocateChannel(chid, m_channel);
133         eDebug("eDVBServicePMTHandler: tune %d", res);
134         if (m_channel)
135         {
136                 m_channel->connectStateChange(
137                         slot(*this, &eDVBServicePMTHandler::channelStateChanged), 
138                         m_channelStateChanged_connection);
139                 m_last_channel_state = -1;
140                 channelStateChanged(m_channel);
141         }
142         return res;
143 }