1 #include <lib/service/servicedvbrecord.h>
2 #include <lib/base/eerror.h>
3 #include <lib/dvb/epgcache.h>
4 #include <lib/dvb/metaparser.h>
5 #include <lib/base/httpstream.h>
10 #include <netinet/in.h>
13 #error no byte order defined!
16 DEFINE_REF(eDVBServiceRecord);
18 eDVBServiceRecord::eDVBServiceRecord(const eServiceReferenceDVB &ref, bool isstreamclient = false):
19 m_ref(ref),m_is_stream_client(isstreamclient)
21 CONNECT(m_service_handler.serviceEvent, eDVBServiceRecord::serviceEvent);
22 CONNECT(m_event_handler.m_eit_changed, eDVBServiceRecord::gotNewEvent);
33 void eDVBServiceRecord::serviceEvent(int event)
35 eDebug("RECORD service event %d", event);
38 case eDVBServicePMTHandler::eventTuned:
43 /* start feeding EIT updates */
44 ePtr<iDVBDemux> m_demux;
45 if (!m_service_handler.getDataDemux(m_demux))
47 eServiceReferenceDVB &ref = (eServiceReferenceDVB&) m_ref;
48 int sid = ref.getParentServiceID().get();
50 sid = ref.getServiceID().get();
51 if ( ref.getParentTransportStreamID().get() &&
52 ref.getParentTransportStreamID() != ref.getTransportStreamID() )
53 m_event_handler.startOther(m_demux, sid);
55 m_event_handler.start(m_demux, sid);
58 if (m_state == stateRecording && m_want_record)
60 m_event((iRecordableService*)this, evTunedIn);
63 case eDVBServicePMTHandler::eventTuneFailed:
65 eDebug("record failed to tune");
66 m_event((iRecordableService*)this, evTuneFailed);
69 case eDVBServicePMTHandler::eventNewProgramInfo:
71 if (m_state == stateIdle)
73 else if (m_want_record) /* doRecord can be called from Prepared and Recording state */
75 m_event((iRecordableService*)this, evNewProgramInfo);
78 case eDVBServicePMTHandler::eventMisconfiguration:
79 m_error = errMisconfiguration;
80 m_event((iRecordableService*)this, evTuneFailed);
82 case eDVBServicePMTHandler::eventNoResources:
83 m_error = errNoResources;
84 m_event((iRecordableService*)this, evTuneFailed);
89 RESULT eDVBServiceRecord::prepare(const char *filename, time_t begTime, time_t endTime, int eit_event_id, const char *name, const char *descr, const char *tags)
91 m_filename = filename;
94 if (m_state == stateIdle)
96 int ret = doPrepare();
99 eServiceReferenceDVB ref = m_ref.getParentServiceReference();
100 ePtr<eDVBResourceManager> res_mgr;
102 std::string service_data;
105 if (!eDVBResourceManager::getInstance(res_mgr))
107 ePtr<iDVBChannelList> db;
108 if (!res_mgr->getChannelList(db))
110 ePtr<eDVBService> service;
111 if (!db->getService(ref, service))
114 sprintf(tmp, "f:%x", service->m_flags);
117 for (int x=0; x < eDVBService::cacheMax; ++x)
119 int entry = service->getCacheEntry((eDVBService::cacheID)x);
122 sprintf(tmp, ",c:%02d%04x", x, entry);
129 meta.m_time_create = begTime;
132 meta.m_service_data = service_data;
136 meta.m_description = descr;
139 ret = meta.updateMeta(filename) ? -255 : 0;
142 const eit_event_struct *event = 0;
143 eEPGCache::getInstance()->Lock();
144 if ( eit_event_id != -1 )
146 eDebug("query epg event id %d", eit_event_id);
147 eEPGCache::getInstance()->lookupEventId(ref, eit_event_id, event);
149 if ( !event && (begTime != -1 && endTime != -1) )
151 time_t queryTime = begTime + ((endTime-begTime)/2);
153 localtime_r(&begTime, &beg);
154 localtime_r(&endTime, &end);
155 localtime_r(&queryTime, &query);
156 eDebug("query stime %d:%d:%d, etime %d:%d:%d, qtime %d:%d:%d",
157 beg.tm_hour, beg.tm_min, beg.tm_sec,
158 end.tm_hour, end.tm_min, end.tm_sec,
159 query.tm_hour, query.tm_min, query.tm_sec);
160 eEPGCache::getInstance()->lookupEventTime(ref, queryTime, event);
164 eDebug("found event.. store to disc");
165 std::string fname = filename;
166 fname.erase(fname.length()-2, 2);
168 int fd = open(fname.c_str(), O_CREAT|O_WRONLY, 0777);
171 int evLen=HILO(event->descriptors_loop_length)+12/*EIT_LOOP_SIZE*/;
172 int wr = ::write( fd, (unsigned char*)event, evLen );
174 eDebug("eit write error (%m)");
178 eEPGCache::getInstance()->Unlock();
186 RESULT eDVBServiceRecord::prepareStreaming()
190 if (m_state == stateIdle)
195 RESULT eDVBServiceRecord::start(bool simulate)
197 m_simulate = simulate;
199 /* when tune wasn't yet successfully, doRecord stays in "prepared"-state which is fine. */
200 m_event((iRecordableService*)this, evStart);
204 RESULT eDVBServiceRecord::stop()
207 eDebug("stop recording!");
208 if (m_state == stateRecording)
212 if (m_target_fd >= 0)
214 ::close(m_target_fd);
220 m_state = statePrepared;
221 } else if (!m_simulate)
222 eDebug("(was not recording)");
223 if (m_state == statePrepared)
228 m_event((iRecordableService*)this, evRecordStopped);
232 int eDVBServiceRecord::doPrepare()
234 /* allocate a ts recorder if we don't already have one. */
235 if (m_state == stateIdle)
237 bool isstreamclient = false;
238 m_pids_active.clear();
239 m_state = statePrepared;
240 ePtr<iTsSource> source;
241 if (!m_ref.path.empty())
243 if (m_is_stream_client)
245 isstreamclient = true;
246 eHttpStream *f = new eHttpStream();
247 f->open(m_ref.path.c_str());
248 source = ePtr<iTsSource>(f);
252 /* re-record a recording */
253 eRawFile *f = new eRawFile();
254 f->open(m_ref.path.c_str());
255 source = ePtr<iTsSource>(f);
258 return m_service_handler.tuneExt(m_ref, 0, source, m_ref.path.c_str(), 0, m_simulate, 0, isstreamclient);
263 int eDVBServiceRecord::doRecord()
265 int err = doPrepare();
268 m_error = errTuneFailed;
269 m_event((iRecordableService*)this, evRecordFailed);
274 return 0; /* try it again when we are tuned in */
276 if (!m_record && m_tuned && !m_streaming && !m_simulate)
278 eDebug("Recording to %s...", m_filename.c_str());
279 ::remove(m_filename.c_str());
280 int fd = ::open(m_filename.c_str(), O_WRONLY|O_CREAT|O_LARGEFILE, 0644);
283 eDebug("eDVBServiceRecord - can't open recording file!");
284 m_error = errOpenRecordFile;
285 m_event((iRecordableService*)this, evRecordFailed);
286 return errOpenRecordFile;
289 /* turn off kernel caching strategies */
290 posix_fadvise(fd, 0, 0, POSIX_FADV_RANDOM);
292 ePtr<iDVBDemux> demux;
293 if (m_service_handler.getDataDemux(demux))
295 eDebug("eDVBServiceRecord - NO DEMUX available!");
296 m_error = errNoDemuxAvailable;
297 m_event((iRecordableService*)this, evRecordFailed);
298 return errNoDemuxAvailable;
300 demux->createTSRecorder(m_record);
303 eDebug("eDVBServiceRecord - no ts recorder available.");
304 m_error = errNoTsRecorderAvailable;
305 m_event((iRecordableService*)this, evRecordFailed);
306 return errNoTsRecorderAvailable;
308 m_record->setTargetFD(fd);
309 m_record->setTargetFilename(m_filename.c_str());
310 m_record->connectEvent(slot(*this, &eDVBServiceRecord::recordEvent), m_con_record_event);
317 m_state = stateRecording;
318 eDebug("start streaming...");
321 eDebug("start recording...");
323 eDVBServicePMTHandler::program program;
324 if (m_service_handler.getProgramInfo(program))
325 eDebug("getting program info failed.");
328 std::set<int> pids_to_record;
330 pids_to_record.insert(0); // PAT
332 if (program.pmtPid != -1)
333 pids_to_record.insert(program.pmtPid); // PMT
335 int timing_pid = -1, timing_pid_type = -1;
337 eDebugNoNewLine("RECORD: have %zd video stream(s)", program.videoStreams.size());
338 if (!program.videoStreams.empty())
340 eDebugNoNewLine(" (");
341 for (std::vector<eDVBServicePMTHandler::videoStream>::const_iterator
342 i(program.videoStreams.begin());
343 i != program.videoStreams.end(); ++i)
345 pids_to_record.insert(i->pid);
347 if (timing_pid == -1)
350 timing_pid_type = i->type;
353 if (i != program.videoStreams.begin())
354 eDebugNoNewLine(", ");
355 eDebugNoNewLine("%04x", i->pid);
357 eDebugNoNewLine(")");
359 eDebugNoNewLine(", and %zd audio stream(s)", program.audioStreams.size());
360 if (!program.audioStreams.empty())
362 eDebugNoNewLine(" (");
363 for (std::vector<eDVBServicePMTHandler::audioStream>::const_iterator
364 i(program.audioStreams.begin());
365 i != program.audioStreams.end(); ++i)
367 pids_to_record.insert(i->pid);
369 if (timing_pid == -1)
372 timing_pid_type = -1;
375 if (i != program.audioStreams.begin())
376 eDebugNoNewLine(", ");
377 eDebugNoNewLine("%04x", i->pid);
379 eDebugNoNewLine(")");
381 if (!program.subtitleStreams.empty())
383 eDebugNoNewLine(" (");
384 for (std::vector<eDVBServicePMTHandler::subtitleStream>::const_iterator
385 i(program.subtitleStreams.begin());
386 i != program.subtitleStreams.end(); ++i)
388 pids_to_record.insert(i->pid);
390 if (i != program.subtitleStreams.begin())
391 eDebugNoNewLine(", ");
392 eDebugNoNewLine("%04x", i->pid);
394 eDebugNoNewLine(")");
396 eDebugNoNewLine(", and the pcr pid is %04x", program.pcrPid);
397 if (program.pcrPid != 0x1fff)
398 pids_to_record.insert(program.pcrPid);
399 eDebug(", and the text pid is %04x", program.textPid);
400 if (program.textPid != -1)
401 pids_to_record.insert(program.textPid); // Videotext
403 /* find out which pids are NEW and which pids are obsolete.. */
404 std::set<int> new_pids, obsolete_pids;
406 std::set_difference(pids_to_record.begin(), pids_to_record.end(),
407 m_pids_active.begin(), m_pids_active.end(),
408 std::inserter(new_pids, new_pids.begin()));
411 m_pids_active.begin(), m_pids_active.end(),
412 pids_to_record.begin(), pids_to_record.end(),
413 std::inserter(obsolete_pids, obsolete_pids.begin())
416 for (std::set<int>::iterator i(new_pids.begin()); i != new_pids.end(); ++i)
418 eDebug("ADD PID: %04x", *i);
419 m_record->addPID(*i);
422 for (std::set<int>::iterator i(obsolete_pids.begin()); i != obsolete_pids.end(); ++i)
424 eDebug("REMOVED PID: %04x", *i);
425 m_record->removePID(*i);
428 if (timing_pid != -1)
429 m_record->setTimingPID(timing_pid, timing_pid_type);
431 m_pids_active = pids_to_record;
433 if (m_state != stateRecording)
436 m_state = stateRecording;
441 m_event((iRecordableService*)this, evRecordRunning);
445 RESULT eDVBServiceRecord::frontendInfo(ePtr<iFrontendInformation> &ptr)
451 RESULT eDVBServiceRecord::connectEvent(const Slot2<void,iRecordableService*,int> &event, ePtr<eConnection> &connection)
453 connection = new eConnection((iRecordableService*)this, m_event.connect(event));
457 RESULT eDVBServiceRecord::stream(ePtr<iStreamableService> &ptr)
463 extern void PutToDict(ePyObject &dict, const char*key, long val); // defined in dvb/frontend.cpp
465 PyObject *eDVBServiceRecord::getStreamingData()
467 eDVBServicePMTHandler::program program;
468 if (!m_tuned || m_service_handler.getProgramInfo(program))
473 ePyObject r = program.createPythonObject();
474 ePtr<iDVBDemux> demux;
475 if (!m_service_handler.getDataDemux(demux))
478 if (!demux->getCADemuxID(demux_id))
479 PutToDict(r, "demux", demux_id);
485 void eDVBServiceRecord::recordEvent(int event)
489 case iDVBTSRecorder::eventWriteError:
490 eWarning("[eDVBServiceRecord] record write error");
492 m_event((iRecordableService*)this, evRecordWriteError);
495 eDebug("unhandled record event %d", event);
499 void eDVBServiceRecord::gotNewEvent()
501 ePtr<eServiceEvent> event_now;
502 m_event_handler.getEvent(event_now, 0);
507 int event_id = event_now->getEventId();
513 if (m_record->getCurrentPCR(p))
514 eDebug("getting PCR failed!");
517 m_event_timestamps[event_id] = p;
518 eDebug("pcr of eit change: %llx", p);
522 if (event_id != m_last_event_id)
523 eDebug("[eDVBServiceRecord] now running: %s (%d seconds)", event_now->getEventName().c_str(), event_now->getDuration());
525 m_last_event_id = event_id;
527 m_event((iRecordableService*)this, evNewEventInfo);
530 void eDVBServiceRecord::saveCutlist()
532 /* XXX: dupe of eDVBServicePlay::saveCuesheet, refactor plz */
533 std::string filename = m_filename + ".cuts";
537 if (tstools.openFile(m_filename.c_str()))
539 eDebug("[eDVBServiceRecord] saving cutlist failed because tstools failed");
543 FILE *f = fopen(filename.c_str(), "wb");
547 unsigned long long where;
550 for (std::map<int,pts_t>::iterator i(m_event_timestamps.begin()); i != m_event_timestamps.end(); ++i)
553 off_t offset = 0; // fixme, we need to note down both
554 if (tstools.fixupPTS(offset, p))
556 eDebug("[eDVBServiceRecord] fixing up PTS failed, not saving");
559 eDebug("fixed up %llx to %llx (offset %llx)", i->second, p, offset);
560 #if BYTE_ORDER == BIG_ENDIAN
565 what = htonl(2); /* mark */
566 fwrite(&where, sizeof(where), 1, f);
567 fwrite(&what, sizeof(what), 1, f);
574 RESULT eDVBServiceRecord::subServices(ePtr<iSubserviceList> &ptr)
580 int eDVBServiceRecord::getNumberOfSubservices()
582 ePtr<eServiceEvent> evt;
583 if (!m_event_handler.getEvent(evt, 0))
584 return evt->getNumOfLinkageServices();
588 RESULT eDVBServiceRecord::getSubservice(eServiceReference &sub, unsigned int n)
590 ePtr<eServiceEvent> evt;
591 if (!m_event_handler.getEvent(evt, 0))
593 if (!evt->getLinkageService(sub, m_ref, n))
596 sub.type=eServiceReference::idInvalid;