1 #include <lib/service/servicedvbrecord.h>
2 #include <lib/base/eerror.h>
6 DEFINE_REF(eDVBServiceRecord);
8 eDVBServiceRecord::eDVBServiceRecord(const eServiceReferenceDVB &ref): m_ref(ref)
10 CONNECT(m_service_handler.serviceEvent, eDVBServiceRecord::serviceEvent);
16 void eDVBServiceRecord::serviceEvent(int event)
18 eDebug("RECORD service event %d", event);
21 case eDVBServicePMTHandler::eventTuned:
25 if (m_state == stateRecording && m_want_record)
29 case eDVBServicePMTHandler::eventNewProgramInfo:
31 if (m_state == stateIdle)
33 else if (m_want_record) /* doRecord can be called from Prepared and Recording state */
40 RESULT eDVBServiceRecord::prepare(const char *filename)
42 m_filename = filename;
43 if (m_state == stateIdle)
49 RESULT eDVBServiceRecord::start()
52 /* when tune wasn't yet successfully, doRecord stays in "prepared"-state which is fine. */
57 RESULT eDVBServiceRecord::stop()
59 eDebug("stop recording!!");
60 if (m_state == stateRecording)
64 m_state = statePrepared;
67 if (m_state == statePrepared)
76 int eDVBServiceRecord::doPrepare()
78 /* allocate a ts recorder if we don't already have one. */
79 if (m_state == stateIdle)
81 m_pids_active.clear();
82 m_state = statePrepared;
83 return m_service_handler.tune(m_ref, 0);
88 int eDVBServiceRecord::doRecord()
90 int err = doPrepare();
95 return 0; /* try it again when we are tuned in */
97 if (!m_record && m_tuned)
100 eDebug("Recording to %s...", m_filename.c_str());
101 ::remove(m_filename.c_str());
102 int fd = ::open(m_filename.c_str(), O_WRONLY|O_CREAT|O_LARGEFILE, 0644);
105 eDebug("eDVBServiceRecord - can't open recording file!");
109 /* turn off kernel caching strategies */
110 posix_fadvise(fd, 0, 0, POSIX_FADV_RANDOM);
112 ePtr<iDVBDemux> demux;
113 if (m_service_handler.getDataDemux(demux))
115 eDebug("eDVBServiceRecord - NO DEMUX available!");
118 demux->createTSRecorder(m_record);
121 eDebug("eDVBServiceRecord - no ts recorder available.");
124 m_record->setTargetFD(fd);
126 eDebug("starting recording..");
128 eDVBServicePMTHandler::program program;
129 if (m_service_handler.getProgramInfo(program))
130 eDebug("getting program info failed.");
133 std::set<int> pids_to_record;
135 pids_to_record.insert(0); // PAT
137 if (program.pmtPid != -1)
138 pids_to_record.insert(program.pmtPid); // PMT
142 eDebugNoNewLine("RECORD: have %d video stream(s)", program.videoStreams.size());
143 if (!program.videoStreams.empty())
145 eDebugNoNewLine(" (");
146 for (std::vector<eDVBServicePMTHandler::videoStream>::const_iterator
147 i(program.videoStreams.begin());
148 i != program.videoStreams.end(); ++i)
150 pids_to_record.insert(i->pid);
152 if (timing_pid == -1)
155 if (i != program.videoStreams.begin())
156 eDebugNoNewLine(", ");
157 eDebugNoNewLine("%04x", i->pid);
159 eDebugNoNewLine(")");
161 eDebugNoNewLine(", and %d audio stream(s)", program.audioStreams.size());
162 if (!program.audioStreams.empty())
164 eDebugNoNewLine(" (");
165 for (std::vector<eDVBServicePMTHandler::audioStream>::const_iterator
166 i(program.audioStreams.begin());
167 i != program.audioStreams.end(); ++i)
169 pids_to_record.insert(i->pid);
171 if (timing_pid == -1)
174 if (i != program.audioStreams.begin())
175 eDebugNoNewLine(", ");
176 eDebugNoNewLine("%04x", i->pid);
178 eDebugNoNewLine(")");
180 eDebugNoNewLine(", and the pcr pid is %04x", program.pcrPid);
181 if (program.pcrPid != 0x1fff)
182 pids_to_record.insert(program.pcrPid);
183 eDebug(", and the text pid is %04x", program.textPid);
184 if (program.textPid != -1)
185 pids_to_record.insert(program.textPid); // Videotext
187 /* find out which pids are NEW and which pids are obsolete.. */
188 std::set<int> new_pids, obsolete_pids;
190 std::set_difference(pids_to_record.begin(), pids_to_record.end(),
191 m_pids_active.begin(), m_pids_active.end(),
192 std::inserter(new_pids, new_pids.begin()));
195 m_pids_active.begin(), m_pids_active.end(),
196 pids_to_record.begin(), pids_to_record.end(),
197 std::inserter(new_pids, new_pids.begin())
200 for (std::set<int>::iterator i(new_pids.begin()); i != new_pids.end(); ++i)
202 eDebug("ADD PID: %04x", *i);
203 m_record->addPID(*i);
205 for (std::set<int>::iterator i(obsolete_pids.begin()); i != obsolete_pids.end(); ++i)
207 eDebug("REMOVED PID: %04x", *i);
208 m_record->removePID(*i);
211 if (timing_pid != -1)
212 m_record->setTimingPID(timing_pid);
214 m_pids_active = pids_to_record;
216 if (m_state != stateRecording)
219 m_state = stateRecording;