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 hardcoded recording file!");
108 ePtr<iDVBDemux> demux;
109 if (m_service_handler.getDataDemux(demux))
111 eDebug("eDVBServiceRecord - NO DEMUX available!");
114 demux->createTSRecorder(m_record);
117 eDebug("eDVBServiceRecord - no ts recorder available.");
120 m_record->setTargetFD(fd);
122 eDebug("starting recording..");
124 eDVBServicePMTHandler::program program;
125 if (m_service_handler.getProgramInfo(program))
126 eDebug("getting program info failed.");
129 std::set<int> pids_to_record;
131 pids_to_record.insert(0); // PAT
133 if (program.pmtPid != -1)
134 pids_to_record.insert(program.pmtPid); // PMT
136 eDebugNoNewLine("RECORD: have %d video stream(s)", program.videoStreams.size());
137 if (!program.videoStreams.empty())
139 eDebugNoNewLine(" (");
140 for (std::vector<eDVBServicePMTHandler::videoStream>::const_iterator
141 i(program.videoStreams.begin());
142 i != program.videoStreams.end(); ++i)
144 pids_to_record.insert(i->pid);
145 if (i != program.videoStreams.begin())
146 eDebugNoNewLine(", ");
147 eDebugNoNewLine("%04x", i->pid);
149 eDebugNoNewLine(")");
151 eDebugNoNewLine(", and %d audio stream(s)", program.audioStreams.size());
152 if (!program.audioStreams.empty())
154 eDebugNoNewLine(" (");
155 for (std::vector<eDVBServicePMTHandler::audioStream>::const_iterator
156 i(program.audioStreams.begin());
157 i != program.audioStreams.end(); ++i)
159 pids_to_record.insert(i->pid);
160 if (i != program.audioStreams.begin())
161 eDebugNoNewLine(", ");
162 eDebugNoNewLine("%04x", i->pid);
164 eDebugNoNewLine(")");
166 eDebugNoNewLine(", and the pcr pid is %04x", program.pcrPid);
167 if (program.pcrPid != 0x1fff)
168 pids_to_record.insert(program.pcrPid);
169 eDebug(", and the text pid is %04x", program.textPid);
170 if (program.textPid != -1)
171 pids_to_record.insert(program.textPid); // Videotext
173 /* find out which pids are NEW and which pids are obsolete.. */
174 std::set<int> new_pids, obsolete_pids;
176 std::set_difference(pids_to_record.begin(), pids_to_record.end(),
177 m_pids_active.begin(), m_pids_active.end(),
178 std::inserter(new_pids, new_pids.begin()));
181 m_pids_active.begin(), m_pids_active.end(),
182 pids_to_record.begin(), pids_to_record.end(),
183 std::inserter(new_pids, new_pids.begin())
186 for (std::set<int>::iterator i(new_pids.begin()); i != new_pids.end(); ++i)
188 eDebug("ADD PID: %04x", *i);
189 m_record->addPID(*i);
191 for (std::set<int>::iterator i(obsolete_pids.begin()); i != obsolete_pids.end(); ++i)
193 eDebug("REMOVED PID: %04x", *i);
194 m_record->removePID(*i);
197 m_pids_active = pids_to_record;
199 if (m_state != stateRecording)
202 m_state = stateRecording;