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);
125 m_record->setTargetFilename(m_filename.c_str());
127 eDebug("starting recording..");
129 eDVBServicePMTHandler::program program;
130 if (m_service_handler.getProgramInfo(program))
131 eDebug("getting program info failed.");
134 std::set<int> pids_to_record;
136 pids_to_record.insert(0); // PAT
138 if (program.pmtPid != -1)
139 pids_to_record.insert(program.pmtPid); // PMT
143 eDebugNoNewLine("RECORD: have %d video stream(s)", program.videoStreams.size());
144 if (!program.videoStreams.empty())
146 eDebugNoNewLine(" (");
147 for (std::vector<eDVBServicePMTHandler::videoStream>::const_iterator
148 i(program.videoStreams.begin());
149 i != program.videoStreams.end(); ++i)
151 pids_to_record.insert(i->pid);
153 if (timing_pid == -1)
156 if (i != program.videoStreams.begin())
157 eDebugNoNewLine(", ");
158 eDebugNoNewLine("%04x", i->pid);
160 eDebugNoNewLine(")");
162 eDebugNoNewLine(", and %d audio stream(s)", program.audioStreams.size());
163 if (!program.audioStreams.empty())
165 eDebugNoNewLine(" (");
166 for (std::vector<eDVBServicePMTHandler::audioStream>::const_iterator
167 i(program.audioStreams.begin());
168 i != program.audioStreams.end(); ++i)
170 pids_to_record.insert(i->pid);
172 if (timing_pid == -1)
175 if (i != program.audioStreams.begin())
176 eDebugNoNewLine(", ");
177 eDebugNoNewLine("%04x", i->pid);
179 eDebugNoNewLine(")");
181 eDebugNoNewLine(", and the pcr pid is %04x", program.pcrPid);
182 if (program.pcrPid != 0x1fff)
183 pids_to_record.insert(program.pcrPid);
184 eDebug(", and the text pid is %04x", program.textPid);
185 if (program.textPid != -1)
186 pids_to_record.insert(program.textPid); // Videotext
188 /* find out which pids are NEW and which pids are obsolete.. */
189 std::set<int> new_pids, obsolete_pids;
191 std::set_difference(pids_to_record.begin(), pids_to_record.end(),
192 m_pids_active.begin(), m_pids_active.end(),
193 std::inserter(new_pids, new_pids.begin()));
196 m_pids_active.begin(), m_pids_active.end(),
197 pids_to_record.begin(), pids_to_record.end(),
198 std::inserter(new_pids, new_pids.begin())
201 for (std::set<int>::iterator i(new_pids.begin()); i != new_pids.end(); ++i)
203 eDebug("ADD PID: %04x", *i);
204 m_record->addPID(*i);
206 for (std::set<int>::iterator i(obsolete_pids.begin()); i != obsolete_pids.end(); ++i)
208 eDebug("REMOVED PID: %04x", *i);
209 m_record->removePID(*i);
212 if (timing_pid != -1)
213 m_record->setTimingPID(timing_pid);
215 m_pids_active = pids_to_record;
217 if (m_state != stateRecording)
220 m_state = stateRecording;