1 #include <lib/service/servicedvbrecord.h>
2 #include <lib/base/eerror.h>
3 #include <lib/dvb/epgcache.h>
6 DEFINE_REF(eDVBServiceRecord);
8 eDVBServiceRecord::eDVBServiceRecord(const eServiceReferenceDVB &ref): m_ref(ref)
10 CONNECT(m_service_handler.serviceEvent, eDVBServiceRecord::serviceEvent);
18 void eDVBServiceRecord::serviceEvent(int event)
20 eDebug("RECORD service event %d", event);
23 case eDVBServicePMTHandler::eventTuned:
27 if (m_state == stateRecording && m_want_record)
29 m_event((iRecordableService*)this, evTunedIn);
32 case eDVBServicePMTHandler::eventTuneFailed:
34 eDebug("record failed to tune");
35 m_event((iRecordableService*)this, evTuneFailed);
38 case eDVBServicePMTHandler::eventNewProgramInfo:
40 if (m_state == stateIdle)
42 else if (m_want_record) /* doRecord can be called from Prepared and Recording state */
44 m_event((iRecordableService*)this, evNewProgramInfo);
50 RESULT eDVBServiceRecord::prepare(const char *filename, time_t begTime, time_t endTime, int eit_event_id)
52 m_filename = filename;
53 if (m_state == stateIdle)
55 int ret = doPrepare();
58 eEPGCache::getInstance()->Lock();
59 const eit_event_struct *event = 0;
60 eServiceReferenceDVB ref = m_ref.getParentServiceReference();
63 if ( eit_event_id != -1 )
65 eDebug("query epg event id %d", eit_event_id);
66 eEPGCache::getInstance()->lookupEventId(ref, eit_event_id, event);
68 if ( !event && (begTime != -1 && endTime != -1) )
70 time_t queryTime = begTime + ((endTime-begTime)/2);
72 localtime_r(&begTime, &beg);
73 localtime_r(&endTime, &end);
74 localtime_r(&queryTime, &query);
75 eDebug("query stime %d:%d:%d, etime %d:%d:%d, qtime %d:%d:%d",
76 beg.tm_hour, beg.tm_min, beg.tm_sec,
77 end.tm_hour, end.tm_min, end.tm_sec,
78 query.tm_hour, query.tm_min, query.tm_sec);
79 eEPGCache::getInstance()->lookupEventTime(ref, queryTime, event);
83 eDebug("found event.. store to disc");
84 std::string fname = filename;
85 fname.erase(fname.length()-2, 2);
87 int fd = open(fname.c_str(), O_CREAT|O_WRONLY, 0777);
90 int evLen=HILO(event->descriptors_loop_length)+12/*EIT_LOOP_SIZE*/;
91 int wr = ::write( fd, (unsigned char*)event, evLen );
93 eDebug("eit write error (%m)");
97 eEPGCache::getInstance()->Unlock();
105 RESULT eDVBServiceRecord::start()
108 /* when tune wasn't yet successfully, doRecord stays in "prepared"-state which is fine. */
109 m_event((iRecordableService*)this, evStart);
114 RESULT eDVBServiceRecord::stop()
116 eDebug("stop recording!!");
117 m_event((iRecordableService*)this, evStop);
118 if (m_state == stateRecording)
122 if (m_target_fd >= 0)
124 ::close(m_target_fd);
127 m_state = statePrepared;
130 if (m_state == statePrepared)
135 m_event((iRecordableService*)this, evRecordStopped);
140 int eDVBServiceRecord::doPrepare()
142 /* allocate a ts recorder if we don't already have one. */
143 if (m_state == stateIdle)
145 m_pids_active.clear();
146 m_state = statePrepared;
147 return m_service_handler.tune(m_ref, 0);
152 int eDVBServiceRecord::doRecord()
154 int err = doPrepare();
157 m_error = errTuneFailed;
158 m_event((iRecordableService*)this, evRecordFailed);
163 return 0; /* try it again when we are tuned in */
165 if (!m_record && m_tuned)
167 eDebug("Recording to %s...", m_filename.c_str());
168 ::remove(m_filename.c_str());
169 int fd = ::open(m_filename.c_str(), O_WRONLY|O_CREAT|O_LARGEFILE, 0644);
172 eDebug("eDVBServiceRecord - can't open recording file!");
173 m_error = errOpenRecordFile;
174 m_event((iRecordableService*)this, evRecordFailed);
175 return errOpenRecordFile;
178 /* turn off kernel caching strategies */
179 posix_fadvise(fd, 0, 0, POSIX_FADV_RANDOM);
181 ePtr<iDVBDemux> demux;
182 if (m_service_handler.getDataDemux(demux))
184 eDebug("eDVBServiceRecord - NO DEMUX available!");
185 m_error = errNoDemuxAvailable;
186 m_event((iRecordableService*)this, evRecordFailed);
187 return errNoDemuxAvailable;
189 demux->createTSRecorder(m_record);
192 eDebug("eDVBServiceRecord - no ts recorder available.");
193 m_error = errNoTsRecorderAvailable;
194 m_event((iRecordableService*)this, evRecordFailed);
195 return errNoTsRecorderAvailable;
197 m_record->setTargetFD(fd);
198 m_record->setTargetFilename(m_filename.c_str());
201 eDebug("starting recording..");
203 eDVBServicePMTHandler::program program;
204 if (m_service_handler.getProgramInfo(program))
205 eDebug("getting program info failed.");
208 std::set<int> pids_to_record;
210 pids_to_record.insert(0); // PAT
212 if (program.pmtPid != -1)
213 pids_to_record.insert(program.pmtPid); // PMT
217 eDebugNoNewLine("RECORD: have %d video stream(s)", program.videoStreams.size());
218 if (!program.videoStreams.empty())
220 eDebugNoNewLine(" (");
221 for (std::vector<eDVBServicePMTHandler::videoStream>::const_iterator
222 i(program.videoStreams.begin());
223 i != program.videoStreams.end(); ++i)
225 pids_to_record.insert(i->pid);
227 if (timing_pid == -1)
230 if (i != program.videoStreams.begin())
231 eDebugNoNewLine(", ");
232 eDebugNoNewLine("%04x", i->pid);
234 eDebugNoNewLine(")");
236 eDebugNoNewLine(", and %d audio stream(s)", program.audioStreams.size());
237 if (!program.audioStreams.empty())
239 eDebugNoNewLine(" (");
240 for (std::vector<eDVBServicePMTHandler::audioStream>::const_iterator
241 i(program.audioStreams.begin());
242 i != program.audioStreams.end(); ++i)
244 pids_to_record.insert(i->pid);
246 if (timing_pid == -1)
249 if (i != program.audioStreams.begin())
250 eDebugNoNewLine(", ");
251 eDebugNoNewLine("%04x", i->pid);
253 eDebugNoNewLine(")");
255 if (!program.subtitleStreams.empty())
257 eDebugNoNewLine(" (");
258 for (std::vector<eDVBServicePMTHandler::subtitleStream>::const_iterator
259 i(program.subtitleStreams.begin());
260 i != program.subtitleStreams.end(); ++i)
262 pids_to_record.insert(i->pid);
264 if (i != program.subtitleStreams.begin())
265 eDebugNoNewLine(", ");
266 eDebugNoNewLine("%04x", i->pid);
268 eDebugNoNewLine(")");
270 eDebugNoNewLine(", and the pcr pid is %04x", program.pcrPid);
271 if (program.pcrPid != 0x1fff)
272 pids_to_record.insert(program.pcrPid);
273 eDebug(", and the text pid is %04x", program.textPid);
274 if (program.textPid != -1)
275 pids_to_record.insert(program.textPid); // Videotext
277 /* find out which pids are NEW and which pids are obsolete.. */
278 std::set<int> new_pids, obsolete_pids;
280 std::set_difference(pids_to_record.begin(), pids_to_record.end(),
281 m_pids_active.begin(), m_pids_active.end(),
282 std::inserter(new_pids, new_pids.begin()));
285 m_pids_active.begin(), m_pids_active.end(),
286 pids_to_record.begin(), pids_to_record.end(),
287 std::inserter(new_pids, new_pids.begin())
290 for (std::set<int>::iterator i(new_pids.begin()); i != new_pids.end(); ++i)
292 eDebug("ADD PID: %04x", *i);
293 m_record->addPID(*i);
295 for (std::set<int>::iterator i(obsolete_pids.begin()); i != obsolete_pids.end(); ++i)
297 eDebug("REMOVED PID: %04x", *i);
298 m_record->removePID(*i);
301 if (timing_pid != -1)
302 m_record->setTimingPID(timing_pid);
304 m_pids_active = pids_to_record;
306 if (m_state != stateRecording)
309 m_state = stateRecording;
313 m_event((iRecordableService*)this, evRecordRunning);
317 RESULT eDVBServiceRecord::frontendInfo(ePtr<iFrontendInformation> &ptr)
323 RESULT eDVBServiceRecord::connectEvent(const Slot2<void,iRecordableService*,int> &event, ePtr<eConnection> &connection)
325 connection = new eConnection((iRecordableService*)this, m_event.connect(event));