8 #if HAVE_DVB_API_VERSION < 3
11 #ifndef DMX_SET_NEGFILTER_MASK
12 #define DMX_SET_NEGFILTER_MASK _IOW('o',48,uint8_t *)
18 unsigned int num; /* input : which STC? O..N */
19 unsigned int base; /* output: divisor for stc to get 90 kHz clock */
20 unsigned long long stc; /* output: src in 'base'*90 kHz units */
22 #define DMX_GET_STC _IOR('o', 50, struct dmx_stc)
26 #include <linux/dvb/dmx.h>
31 #define DMX_ADD_PID _IO('o', 51)
32 #define DMX_REMOVE_PID _IO('o', 52)
36 DMX_TAP_PES = DMX_PES_OTHER, /* for backward binary compat. */
45 #include <lib/base/eerror.h>
46 #include <lib/base/filepush.h>
47 #include <lib/dvb/idvb.h>
48 #include <lib/dvb/demux.h>
49 #include <lib/dvb/esection.h>
50 #include <lib/dvb/decoder.h>
51 #include <lib/dvb/pvrparse.h>
53 eDVBDemux::eDVBDemux(int adapter, int demux): adapter(adapter), demux(demux)
58 eDVBDemux::~eDVBDemux()
62 int eDVBDemux::openDemux(void)
65 #if HAVE_DVB_API_VERSION < 3
66 snprintf(filename, 128, "/dev/dvb/card%d/demux%d", adapter, demux);
68 snprintf(filename, 128, "/dev/dvb/adapter%d/demux%d", adapter, demux);
70 return ::open(filename, O_RDWR);
75 RESULT eDVBDemux::setSourceFrontend(int fenum)
77 #if HAVE_DVB_API_VERSION >= 3
79 int n = DMX_SOURCE_FRONT0 + fenum;
80 int res = ::ioctl(fd, DMX_SET_SOURCE, &n);
82 eDebug("DMX_SET_SOURCE failed! - %m");
91 RESULT eDVBDemux::setSourcePVR(int pvrnum)
93 #if HAVE_DVB_API_VERSION >= 3
95 int n = DMX_SOURCE_DVR0 + pvrnum;
96 int res = ::ioctl(fd, DMX_SET_SOURCE, &n);
104 RESULT eDVBDemux::createSectionReader(eMainloop *context, ePtr<iDVBSectionReader> &reader)
107 reader = new eDVBSectionReader(this, context, res);
113 RESULT eDVBDemux::createPESReader(eMainloop *context, ePtr<iDVBPESReader> &reader)
116 reader = new eDVBPESReader(this, context, res);
122 RESULT eDVBDemux::createTSRecorder(ePtr<iDVBTSRecorder> &recorder)
126 recorder = new eDVBTSRecorder(this);
130 RESULT eDVBDemux::getMPEGDecoder(ePtr<iTSMPEGDecoder> &decoder, int primary)
132 decoder = new eTSMPEGDecoder(this, primary ? 0 : 1);
136 RESULT eDVBDemux::getSTC(pts_t &pts, int num)
138 int fd = openDemux();
147 if (ioctl(fd, DMX_GET_STC, &stc) < 0)
149 eDebug("DMX_GET_STC failed!");
156 eDebug("DMX_GET_STC - %lld", pts);
162 RESULT eDVBDemux::flush()
164 // FIXME: implement flushing the PVR queue here.
170 RESULT eDVBDemux::connectEvent(const Slot1<void,int> &event, ePtr<eConnection> &conn)
172 conn = new eConnection(this, m_event.connect(event));
176 void eDVBSectionReader::data(int)
178 __u8 data[4096]; // max. section size
180 r = ::read(fd, data, 4096);
183 eWarning("ERROR reading section - %m\n");
188 // this check should never happen unless the driver is crappy!
190 if ((c = crc32((unsigned)-1, data, r)))
192 eDebug("crc32 failed! is %x\n", c);
199 eDebug("data.. but not active");
202 eDVBSectionReader::eDVBSectionReader(eDVBDemux *demux, eMainloop *context, RESULT &res): demux(demux)
205 fd = demux->openDemux();
209 notifier=new eSocketNotifier(context, fd, eSocketNotifier::Read, false);
210 CONNECT(notifier->activated, eDVBSectionReader::data);
219 DEFINE_REF(eDVBSectionReader)
221 eDVBSectionReader::~eDVBSectionReader()
229 RESULT eDVBSectionReader::start(const eDVBSectionFilterMask &mask)
236 #if HAVE_DVB_API_VERSION < 3
237 dmxSctFilterParams sct;
239 dmx_sct_filter_params sct;
243 #if HAVE_DVB_API_VERSION < 3
246 sct.flags = DMX_IMMEDIATE_START;
248 if (mask.flags & eDVBSectionFilterMask::rfCRC)
250 sct.flags |= DMX_CHECK_CRC;
255 memcpy(sct.filter.filter, mask.data, DMX_FILTER_SIZE);
256 memcpy(sct.filter.mask, mask.mask, DMX_FILTER_SIZE);
257 #if HAVE_DVB_API_VERSION >= 3
258 memcpy(sct.filter.mode, mask.mode, DMX_FILTER_SIZE);
259 if (::ioctl(fd, DMX_SET_BUFFER_SIZE, 8192*8) < 0)
260 eDebug("DMX_SET_BUFFER_SIZE failed(%m)");
263 res = ::ioctl(fd, DMX_SET_FILTER, &sct);
266 #if HAVE_DVB_API_VERSION < 3
267 res = ::ioctl(fd, DMX_SET_NEGFILTER_MASK, mask.mode);
270 res = ::ioctl(fd, DMX_START, 0);
281 RESULT eDVBSectionReader::stop()
287 ::ioctl(fd, DMX_STOP);
293 RESULT eDVBSectionReader::connectRead(const Slot1<void,const __u8*> &r, ePtr<eConnection> &conn)
295 conn = new eConnection(this, read.connect(r));
299 void eDVBPESReader::data(int)
305 r = ::read(m_fd, buffer, 16384);
310 if (errno == EAGAIN || errno == EINTR) /* ok */
312 eWarning("ERROR reading PES (fd=%d) - %m", m_fd);
319 eWarning("PES reader not active");
325 eDVBPESReader::eDVBPESReader(eDVBDemux *demux, eMainloop *context, RESULT &res): m_demux(demux)
328 m_fd = m_demux->openDemux();
332 ::ioctl(m_fd, DMX_SET_BUFFER_SIZE, 64*1024);
333 ::fcntl(m_fd, F_SETFL, O_NONBLOCK);
334 m_notifier = new eSocketNotifier(context, m_fd, eSocketNotifier::Read, false);
335 CONNECT(m_notifier->activated, eDVBPESReader::data);
344 DEFINE_REF(eDVBPESReader)
346 eDVBPESReader::~eDVBPESReader()
354 RESULT eDVBPESReader::start(int pid)
362 #if HAVE_DVB_API_VERSION < 3
363 dmxPesFilterParams flt;
365 flt.pesType = DMX_PES_OTHER;
367 dmx_pes_filter_params flt;
369 flt.pes_type = DMX_PES_OTHER;
373 flt.input = DMX_IN_FRONTEND;
374 flt.output = DMX_OUT_TAP;
376 flt.flags = DMX_IMMEDIATE_START;
378 res = ::ioctl(m_fd, DMX_SET_PES_FILTER, &flt);
381 eWarning("PES filter: DMX_SET_PES_FILTER - %m");
387 RESULT eDVBPESReader::stop()
393 ::ioctl(m_fd, DMX_STOP);
399 RESULT eDVBPESReader::connectRead(const Slot2<void,const __u8*,int> &r, ePtr<eConnection> &conn)
401 conn = new eConnection(this, m_read.connect(r));
405 class eDVBRecordFileThread: public eFilePushThread
408 eDVBRecordFileThread();
409 void setTimingPID(int pid);
411 void saveTimingInformation(const std::string &filename);
413 int filterRecordData(const unsigned char *data, int len, size_t ¤t_span_remaining);
415 eMPEGStreamParserTS m_ts_parser;
416 eMPEGStreamInformation m_stream_info;
417 off_t m_current_offset;
421 eDVBRecordFileThread::eDVBRecordFileThread()
422 :eFilePushThread(IOPRIO_CLASS_RT, 7), m_ts_parser(m_stream_info)
424 m_current_offset = 0;
427 void eDVBRecordFileThread::setTimingPID(int pid)
429 m_ts_parser.setPid(pid);
432 void eDVBRecordFileThread::saveTimingInformation(const std::string &filename)
434 m_stream_info.save(filename.c_str());
437 int eDVBRecordFileThread::filterRecordData(const unsigned char *data, int len, size_t ¤t_span_remaining)
439 m_ts_parser.parseData(m_current_offset, data, len);
441 m_current_offset += len;
446 DEFINE_REF(eDVBTSRecorder);
448 eDVBTSRecorder::eDVBTSRecorder(eDVBDemux *demux): m_demux(demux)
452 m_thread = new eDVBRecordFileThread();
453 CONNECT(m_thread->m_event, eDVBTSRecorder::filepushEvent);
455 m_demux->m_dvr_busy = 1;
459 eDVBTSRecorder::~eDVBTSRecorder()
464 m_demux->m_dvr_busy = 0;
468 RESULT eDVBTSRecorder::start()
473 if (m_target_fd == -1)
478 #if HAVE_DVB_API_VERSION < 3
479 snprintf(filename, 128, "/dev/dvb/card%d/dvr%d", m_demux->adapter, m_demux->demux);
481 snprintf(filename, 128, "/dev/dvb/adapter%d/dvr%d", m_demux->adapter, m_demux->demux);
483 m_source_fd = ::open(filename, O_RDONLY);
487 eDebug("FAILED to open dvr (%s) in ts recoder (%m)", filename);
491 snprintf(filename, 128, "/dev/dvb/adapter%d/demux%d", m_demux->adapter, m_demux->demux);
493 m_source_fd = ::open(filename, O_RDONLY);
497 eDebug("FAILED to open demux (%s) in ts recoder (%m)", filename);
501 ::ioctl(m_source_fd, DMX_SET_BUFFER_SIZE, 1024*1024);
503 dmx_pes_filter_params flt;
504 flt.pes_type = (dmx_pes_type_t)DMX_TAP_TS;
506 flt.input = DMX_IN_FRONTEND;
507 flt.output = DMX_OUT_TAP;
509 int res = ::ioctl(m_source_fd, DMX_SET_PES_FILTER, &flt);
512 eDebug("DMX_SET_PES_FILTER: %m");
513 ::close(m_source_fd);
517 ::ioctl(m_source_fd, DMX_START);
521 m_thread->start(m_source_fd, m_target_fd);
524 for (std::map<int,int>::iterator i(m_pids.begin()); i != m_pids.end(); ++i)
530 RESULT eDVBTSRecorder::addPID(int pid)
532 if (m_pids.find(pid) != m_pids.end())
535 m_pids.insert(std::pair<int,int>(pid, -1));
541 RESULT eDVBTSRecorder::removePID(int pid)
543 if (m_pids.find(pid) == m_pids.end())
553 RESULT eDVBTSRecorder::setTimingPID(int pid)
557 m_thread->setTimingPID(pid);
561 RESULT eDVBTSRecorder::setTargetFD(int fd)
567 RESULT eDVBTSRecorder::setTargetFilename(const char *filename)
569 m_target_filename = filename;
573 RESULT eDVBTSRecorder::setBoundary(off_t max)
575 return -1; // not yet implemented
578 RESULT eDVBTSRecorder::stop()
580 for (std::map<int,int>::iterator i(m_pids.begin()); i != m_pids.end(); ++i)
590 if (m_target_filename != "")
591 m_thread->saveTimingInformation(m_target_filename + ".ap");
596 RESULT eDVBTSRecorder::connectEvent(const Slot1<void,int> &event, ePtr<eConnection> &conn)
598 conn = new eConnection(this, m_event.connect(event));
602 RESULT eDVBTSRecorder::startPID(int pid)
605 int fd = m_demux->openDemux();
608 eDebug("FAILED to open demux in ts recoder (%m)");
612 #if HAVE_DVB_API_VERSION < 3
613 dmxPesFilterParams flt;
615 flt.pesType = DMX_PES_OTHER;
617 dmx_pes_filter_params flt;
619 flt.pes_type = DMX_PES_OTHER;
623 flt.input = DMX_IN_FRONTEND;
624 flt.output = DMX_OUT_TS_TAP;
626 flt.flags = DMX_IMMEDIATE_START;
628 int res = ::ioctl(fd, DMX_SET_PES_FILTER, &flt);
631 eDebug("set pes filter failed!");
638 if (::ioctl(m_source_fd, DMX_ADD_PID, pid) < 0) {
639 perror("DMX_ADD_PID");
640 if (errno == EAGAIN || errno == EINTR) {
652 void eDVBTSRecorder::stopPID(int pid)
655 if (m_pids[pid] != -1)
656 ::close(m_pids[pid]);
658 if (m_pids[pid] != -1)
661 if (::ioctl(m_source_fd, DMX_REMOVE_PID, pid) < 0) {
662 perror("DMX_REMOVE_PID");
663 if (errno == EAGAIN || errno == EINTR) {
675 void eDVBTSRecorder::filepushEvent(int event)
679 case eFilePushThread::evtWriteError:
680 m_event(eventWriteError);