add possibility to playback ts files without entry in recordings.epl or without meta...

[enigma2.git] / lib / dvb / pmt.cpp

diff --git a/lib/dvb/pmt.cpp b/lib/dvb/pmt.cpp
index f77675414bee2e16796a2ccae39b6cf49953319d..4ce35394ac1facb74c1211c9c8873fb41798bda7 100644 (file)
--- a/lib/dvb/pmt.cpp
+++ b/lib/dvb/pmt.cpp
@@ -22,22 +22,7 @@ eDVBServicePMTHandler::eDVBServicePMTHandler()
 
 eDVBServicePMTHandler::~eDVBServicePMTHandler()
 {
-       if (m_ca_servicePtr)
-       {
-               eDebug("unregister caservice");
-               int demuxes[2] = {0,0};
-               uint8_t tmp;
-               m_demux->getCADemuxID(tmp);
-               demuxes[0]=tmp;
-               if (m_decode_demux_num != 0xFF)
-                       demuxes[1]=m_decode_demux_num;
-               else
-                       demuxes[1]=demuxes[0];
-               ePtr<eTable<ProgramMapSection> > ptr;
-               m_PMT.getCurrent(ptr);
-               eDVBCAService::unregister_service(m_reference, demuxes, ptr);
-               eDVBCIInterfaces::getInstance()->removePMTHandler(this);
-       }
+       free();
 }
 
 void eDVBServicePMTHandler::channelStateChanged(iDVBChannel *channel)
@@ -78,6 +63,9 @@ void eDVBServicePMTHandler::channelEvent(iDVBChannel *channel, int event)
        case iDVBChannel::evtEOF:
                serviceEvent(eventEOF);
                break;
+       case iDVBChannel::evtSOF:
+               serviceEvent(eventSOF);
+               break;
        default:
                break;
        }
@@ -134,6 +122,84 @@ void eDVBServicePMTHandler::PATready(int)
                                if (eServiceID((*program)->getProgramNumber()) == m_reference.getServiceID())
                                        pmtpid = (*program)->getProgramMapPid();
                }
+               if (pmtpid == -1)
+               {
+                       if ( m_reference.path.find(".ts") != std::string::npos ) // recorded ts
+                       {
+                               // we try to find manual the correct sid
+                               int fd = open( m_reference.path.c_str(), O_RDONLY|O_LARGEFILE );
+                               if ( fd < 0 )
+                                       eDebug("open %s failed");
+                               else
+                               {
+                                       eDebug("parse ts file for find the correct pmtpid");
+                                       unsigned char *buf = new unsigned char[256*1024]; // 256 kbyte
+                                       int rd=0;
+                                       while ( pmtpid == -1 && (rd < 1024*1024*5) )
+                                       {
+#define MAX_PIDS 64
+                                               int pids[MAX_PIDS];
+                                               int pididx=-1;
+                                               int r = ::read( fd, buf, 256*1024 );
+                                               if ( r <= 0 )
+                                                       break;
+                                               rd+=r;
+                                               int cnt=0;
+                                               while(cnt < r)
+                                               {
+                                                       while ( (buf[cnt] != 0x47) && ((cnt+188) < r) && (buf[cnt+188] != 0x47) )
+                                                       {
+//                                                             eDebug("search sync byte %02x %02x, %d %d", buf[cnt], buf[cnt+188], cnt+188, r);
+                                                               cnt++;
+                                                       }
+                                                       if ( buf[cnt] == 0x47 )
+                                                       {
+                                                               int pid = ((buf[cnt+1]&0x3F) << 8) | buf[cnt+2];
+                                                               int idx=0;
+                                                               while(idx <= pididx)  // check if we already have this pid
+                                                               {
+                                                                       if ( pids[idx] == pid )
+                                                                               break;
+                                                                       ++idx;
+                                                               }
+                                                               if (idx > pididx && (pididx+1) < MAX_PIDS)
+                                                               {
+                                                                       eDebug("found pid %04x", pid);
+                                                                       pids[++pididx]=pid;
+                                                               }
+                                                               cnt+=188;
+                                                       }
+                                                       else
+                                                               break;
+                                               }
+                                               while(pididx > -1 && pmtpid == -1)
+                                               {
+                                                       for (i = ptr->getSections().begin(); i != ptr->getSections().end() && pmtpid == -1; ++i)
+                                                       {
+                                                               const ProgramAssociationSection &pat = **i;
+                                                               ProgramAssociationConstIterator program;
+                                                               for (program = pat.getPrograms()->begin(); program != pat.getPrograms()->end(); ++program)
+                                                               {
+                                                                       int pid = (*program)->getProgramMapPid();
+                                                                       if ( pid == pids[pididx])
+                                                                       {
+                                                                               int sid = (*program)->getProgramNumber();
+                                                                               pmtpid = pid;
+                                                                               m_reference.setServiceID(eServiceID(sid));
+                                                                               eDebug("found pmt for service id %04x with pid %04x", sid, pid);
+                                                                               break;
+                                                                       }
+                                                               }
+                                                       }       
+                                                       --pididx;
+                                               }
+                                       }
+                                       delete [] buf;
+                                       close(fd);
+                               }
+                       }
+               }
+               
                if (pmtpid == -1)
                        serviceEvent(eventNoPATEntry);
                else
@@ -375,7 +441,7 @@ int eDVBServicePMTHandler::getPVRChannel(ePtr<iDVBPVRChannel> &pvr_channel)
                return -1;
 }
 
-int eDVBServicePMTHandler::tune(eServiceReferenceDVB &ref, int use_decode_demux)
+int eDVBServicePMTHandler::tune(eServiceReferenceDVB &ref, int use_decode_demux, eCueSheet *cue)
 {
        RESULT res;
        m_reference = ref;
@@ -397,7 +463,9 @@ int eDVBServicePMTHandler::tune(eServiceReferenceDVB &ref, int use_decode_demux)
                        eWarning("no .meta file found, trying original service ref.");
                else
                        m_reference = parser.m_ref;
-               
+
+//             eDebug("try %s", m_reference.toString().c_str());
+
                eDebug("alloc PVR");
                        /* allocate PVR */
                res = m_resourceManager->allocatePVRChannel(m_pvr_channel);
@@ -424,7 +492,10 @@ int eDVBServicePMTHandler::tune(eServiceReferenceDVB &ref, int use_decode_demux)
        }
 
        if (m_pvr_channel)
+       {
+               m_pvr_channel->setCueSheet(cue);
                m_pvr_channel->playFile(ref.path.c_str());
+       }
 
        ePtr<iDVBChannelList> db;
        if (!m_resourceManager->getChannelList(db))
@@ -435,6 +506,28 @@ int eDVBServicePMTHandler::tune(eServiceReferenceDVB &ref, int use_decode_demux)
 
 void eDVBServicePMTHandler::free()
 {
+       if (m_ca_servicePtr)
+       {
+               int demuxes[2] = {0,0};
+               uint8_t tmp;
+               m_demux->getCADemuxID(tmp);
+               demuxes[0]=tmp;
+               if (m_decode_demux_num != 0xFF)
+                       demuxes[1]=m_decode_demux_num;
+               else
+                       demuxes[1]=demuxes[0];
+               ePtr<eTable<ProgramMapSection> > ptr;
+               m_PMT.getCurrent(ptr);
+               eDVBCAService::unregister_service(m_reference, demuxes, ptr);
+               eDVBCIInterfaces::getInstance()->removePMTHandler(this);
+               m_ca_servicePtr = 0;
+       }
+
+       if (m_pvr_channel)
+       {
+               m_pvr_channel->stopFile();
+               m_pvr_channel->setCueSheet(0);
+       }
        m_PMT.stop();
        m_PAT.stop();
        m_service = 0;