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>
6 #include <dvbsi++/ca_program_map_section.h>
8 eDVBServicePMTHandler::eDVBServicePMTHandler(int record)
9 :m_pmt_pid(0xFFFF), m_ca_servicePtr(0)
12 eDVBResourceManager::getInstance(m_resourceManager);
13 CONNECT(m_PMT.tableReady, eDVBServicePMTHandler::PMTready);
14 CONNECT(m_PAT.tableReady, eDVBServicePMTHandler::PATready);
15 eDebug("new PMT handler record: %d", m_record);
18 eDVBServicePMTHandler::~eDVBServicePMTHandler()
20 eDebug("delete PMT handler record: %d", m_record);
21 delete m_ca_servicePtr;
24 void eDVBServicePMTHandler::channelStateChanged(iDVBChannel *channel)
27 channel->getState(state);
29 if ((m_last_channel_state != iDVBChannel::state_ok)
30 && (state == iDVBChannel::state_ok) && (!m_demux))
33 if (m_channel->getDemux(m_demux, m_record ? 0 : iDVBChannel::capDecode))
34 eDebug("Allocating a demux for now tuned-in channel failed.");
36 serviceEvent(eventTuned);
40 eDebug("ok ... now we start!!");
42 /* emit */ m_resourceManager->m_channelRunning(channel);
44 m_PAT.begin(eApp, eDVBPATSpec(), m_demux);
46 if ( m_service && !m_service->cacheEmpty() )
47 serviceEvent(eventNewProgramInfo);
49 } else if ((m_last_channel_state != iDVBChannel::state_failed) &&
50 (state == iDVBChannel::state_failed))
52 eDebug("tune failed.");
53 serviceEvent(eventTuneFailed);
57 void eDVBServicePMTHandler::PMTready(int error)
60 serviceEvent(eventNoPMT);
63 serviceEvent(eventNewProgramInfo);
64 if (!m_pvr_channel && !m_ca_servicePtr) // don't send campmt to camd.socket for playbacked services
65 m_ca_servicePtr = new eDVBCAService(*this);
67 m_ca_servicePtr->buildCAPMT();
71 void eDVBServicePMTHandler::PATready(int)
74 ePtr<eTable<ProgramAssociationSection> > ptr;
75 if (!m_PAT.getCurrent(ptr))
78 std::vector<ProgramAssociationSection*>::const_iterator i;
79 for (i = ptr->getSections().begin(); i != ptr->getSections().end(); ++i)
81 const ProgramAssociationSection &pat = **i;
82 ProgramAssociationConstIterator program;
83 for (program = pat.getPrograms()->begin(); program != pat.getPrograms()->end(); ++program)
84 if (eServiceID((*program)->getProgramNumber()) == m_reference.getServiceID())
85 pmtpid = (*program)->getProgramMapPid();
88 serviceEvent(eventNoPATEntry);
91 m_PMT.begin(eApp, eDVBPMTSpec(pmtpid, m_reference.getServiceID().get()), m_demux);
95 serviceEvent(eventNoPAT);
98 int eDVBServicePMTHandler::getProgramInfo(struct program &program)
100 ePtr<eTable<ProgramMapSection> > ptr;
102 program.videoStreams.clear();
103 program.audioStreams.clear();
105 program.pmtPid = m_pmt_pid < 0x1fff ? m_pmt_pid : -1;
107 if (!m_PMT.getCurrent(ptr))
109 std::vector<ProgramMapSection*>::const_iterator i;
110 for (i = ptr->getSections().begin(); i != ptr->getSections().end(); ++i)
112 const ProgramMapSection &pmt = **i;
113 program.pcrPid = pmt.getPcrPid();
115 ElementaryStreamInfoConstIterator es;
116 for (es = pmt.getEsInfo()->begin(); es != pmt.getEsInfo()->end(); ++es)
118 int isaudio = 0, isvideo = 0;
122 video.pid = (*es)->getPid();
123 audio.pid = (*es)->getPid();
125 switch ((*es)->getType())
127 case 0x01: // MPEG 1 video
128 case 0x02: // MPEG 2 video
131 case 0x03: // MPEG 1 audio
132 case 0x04: // MPEG 2 audio:
134 audio.type = audioStream::atMPEG;
138 program.audioStreams.push_back(audio);
140 program.videoStreams.push_back(video);
145 else if ( m_service && !m_service->cacheEmpty() )
147 int vpid = m_service->getCachePID(eDVBService::cVPID),
148 apid_ac3 = m_service->getCachePID(eDVBService::cAPID),
149 apid_mpeg = m_service->getCachePID(eDVBService::cAC3PID),
150 pcrpid = m_service->getCachePID(eDVBService::cPCRPID),
156 program.videoStreams.push_back(s);
159 if ( apid_ac3 != -1 )
162 s.type = audioStream::atAC3;
164 program.audioStreams.push_back(s);
167 if ( apid_mpeg != -1 )
170 s.type = audioStream::atMPEG;
172 program.audioStreams.push_back(s);
178 program.pcrPid = pcrpid;
186 int eDVBServicePMTHandler::getDemux(ePtr<iDVBDemux> &demux)
195 int eDVBServicePMTHandler::getPVRChannel(ePtr<iDVBPVRChannel> &pvr_channel)
197 pvr_channel = m_pvr_channel;
204 int eDVBServicePMTHandler::tune(eServiceReferenceDVB &ref)
209 /* is this a normal (non PVR) channel? */
210 if (ref.path.empty())
213 ref.getChannelID(chid);
214 res = m_resourceManager->allocateChannel(chid, m_channel);
215 eDebug("allocate Channel: res %d", res);
218 eDVBMetaParser parser;
220 if (parser.parseFile(ref.path))
221 eWarning("no .meta file found, trying original service ref.");
223 m_reference = parser.m_ref;
227 res = m_resourceManager->allocatePVRChannel(m_pvr_channel);
229 eDebug("allocatePVRChannel failed!\n");
230 m_channel = m_pvr_channel;
235 m_channel->connectStateChange(
236 slot(*this, &eDVBServicePMTHandler::channelStateChanged),
237 m_channelStateChanged_connection);
238 m_last_channel_state = -1;
239 channelStateChanged(m_channel);
242 serviceEvent(eventTuneFailed);
247 m_pvr_channel->playFile(ref.path.c_str());
249 ePtr<iDVBChannelList> db;
250 if (!m_resourceManager->getChannelList(db))
251 db->getService((eServiceReferenceDVB&)m_reference, m_service);
256 void eDVBCAService::Connect()
258 memset(&m_servaddr, 0, sizeof(struct sockaddr_un));
259 m_servaddr.sun_family = AF_UNIX;
260 strcpy(m_servaddr.sun_path, "/tmp/camd.socket");
261 m_clilen = sizeof(m_servaddr.sun_family) + strlen(m_servaddr.sun_path);
262 m_sock = socket(PF_UNIX, SOCK_STREAM, 0);
263 connect(m_sock, (struct sockaddr *) &m_servaddr, m_clilen);
264 fcntl(m_sock, F_SETFL, O_NONBLOCK);
266 setsockopt(m_sock, SOL_SOCKET, SO_REUSEADDR, &val, 4);
269 void eDVBCAService::buildCAPMT()
271 ePtr<eTable<ProgramMapSection> > ptr;
273 if (m_parent.m_PMT.getCurrent(ptr))
276 std::vector<ProgramMapSection*>::const_iterator i=ptr->getSections().begin();
277 if ( i != ptr->getSections().end() )
279 CaProgramMapSection capmt(*i++, m_capmt == NULL ? 0x03 /*only*/: 0x05 /*update*/, 0x01 );
281 while( i != ptr->getSections().end() )
287 // add our private descriptors to capmt
290 tmp[0]=0x84; // pmt pid
292 tmp[2]=m_parent.m_pmt_pid>>8;
293 tmp[3]=m_parent.m_pmt_pid&0xFF;
294 capmt.injectDescriptor(tmp, false);
296 tmp[0] = 0x82; // demux
298 m_parent.m_demux->getCADemuxID(tmp[3]); // read section data from demux number
299 tmp[2] = 1 << tmp[3]; // descramble bitmask
300 capmt.injectDescriptor(tmp, false);
302 tmp[0] = 0x81; // dvbnamespace
304 tmp[2] = m_parent.m_reference.getDVBNamespace().get()>>24;
305 tmp[3]=(m_parent.m_reference.getDVBNamespace().get()>>16)&0xFF;
306 tmp[4]=(m_parent.m_reference.getDVBNamespace().get()>>8)&0xFF;
307 tmp[5]=m_parent.m_reference.getDVBNamespace().get()&0xFF;
308 tmp[6]=m_parent.m_reference.getTransportStreamID().get()>>8;
309 tmp[7]=m_parent.m_reference.getTransportStreamID().get()&0xFF;
310 tmp[8]=m_parent.m_reference.getOriginalNetworkID().get()>>8;
311 tmp[9]=m_parent.m_reference.getOriginalNetworkID().get()&0xFF;
312 capmt.injectDescriptor(tmp, false);
315 m_capmt = new uint8_t[2048];
317 capmt.writeToBuffer(m_capmt);
320 if ( m_sendstate != 0xFFFFFFFF )
325 void eDVBCAService::sendCAPMT()
327 if ( m_sendstate && m_sendstate != 0xFFFFFFFF ) // broken pipe retry
334 if ( m_capmt[3] & 0x80 )
337 int lenbytes = m_capmt[3] & ~0x80;
339 wp |= (m_capmt[4+i] << (8 * i++));
349 if ( write(m_sock, m_capmt, wp) == wp )
351 m_sendstate=0xFFFFFFFF;
352 eDebug("[eDVBCAHandler] send %d bytes",wp);
354 for(int i=0;i<wp;i++)
355 eDebugNoNewLine("%02x ", m_capmt[i]);
365 m_retryTimer.start(0,true);
366 // eDebug("[eDVBCAHandler] send failed .. immediate retry");
369 m_retryTimer.start(5000,true);
370 // eDebug("[eDVBCAHandler] send failed .. retry in 5 sec");