MythTV  master
hdhrrecorder.cpp
Go to the documentation of this file.
1 
8 #include <chrono> // for milliseconds
9 #include <thread> // for sleep_for
10 
11 // MythTV includes
12 #include "hdhrstreamhandler.h"
13 #include "atscstreamdata.h"
14 #include "tsstreamdata.h"
15 #include "hdhrrecorder.h"
16 #include "hdhrchannel.h"
17 #include "io/mythmediabuffer.h"
18 #include "tv_rec.h"
19 #include "mythlogging.h"
20 
21 #define LOC QString("HDHRRec[%1]: ") \
22  .arg(m_tvrec ? m_tvrec->GetInputId() : -1)
23 
25 {
26  if (IsOpen())
27  {
28  LOG(VB_GENERAL, LOG_WARNING, LOC + "Card already open");
29  return true;
30  }
31 
33 
34  if (m_channel->GetFormat().compare("MPTS") == 0)
35  {
36  // MPTS only. Use TSStreamData to write out unfiltered data.
37  LOG(VB_RECORD, LOG_INFO, LOC + "Using TSStreamData");
39  m_recordMptsOnly = true;
40  m_recordMpts = false;
41  }
42 
46 
47  LOG(VB_RECORD, LOG_INFO, LOC + "HDHR opened successfully");
48 
49  return true;
50 }
51 
53 {
54  LOG(VB_RECORD, LOG_INFO, LOC + "Close() -- begin");
55 
56  if (IsOpen())
58  (m_tvrec ? m_tvrec->GetInputId() : -1));
59 
60  LOG(VB_RECORD, LOG_INFO, LOC + "Close() -- end");
61 }
62 
64 {
65  if (!m_recordMptsOnly)
66  {
67  if (m_recordMpts)
69 
70  // Make sure the first things in the file are a PAT & PMT
73  }
74 }
75 
77 {
78  LOG(VB_RECORD, LOG_INFO, LOC + "run -- begin");
79 
80  /* Create video socket. */
81  if (!Open())
82  {
83  m_error = "Failed to open HDHRRecorder device";
84  LOG(VB_GENERAL, LOG_ERR, LOC + m_error);
85  return;
86  }
87 
88  {
89  QMutexLocker locker(&m_pauseLock);
90  m_requestRecording = true;
91  m_recording = true;
92  m_recordingWait.wakeAll();
93  }
94 
95  // Listen for time table on DVB standard streams
96  if (m_channel && (m_channel->GetSIStandard() == "dvb"))
98 
99  // Gives errors about invalid PID but it does work...
100  if (m_recordMptsOnly)
101  m_streamData->AddListeningPID(0x2000);
102 
103  StartNewFile();
104 
108  (m_recordMpts) ? m_ringBuffer->GetFilename() : QString());
109 
110  while (IsRecordingRequested() && !IsErrored())
111  {
112  if (PauseAndWait())
113  continue;
114 
115  if (!IsRecordingRequested())
116  break;
117 
118  { // sleep 100 milliseconds unless StopRecording() or Unpause()
119  // is called, just to avoid running this too often.
120  QMutexLocker locker(&m_pauseLock);
122  continue;
123  m_unpauseWait.wait(&m_pauseLock, 100);
124  }
125 
126  if (!m_inputPmt && !m_recordMptsOnly)
127  {
128  LOG(VB_GENERAL, LOG_WARNING, LOC +
129  "Recording will not commence until a PMT is set.");
130  std::this_thread::sleep_for(std::chrono::milliseconds(5));
131  continue;
132  }
133 
134  if (!m_streamHandler->IsRunning())
135  {
136  m_error = "Stream handler died unexpectedly.";
137  LOG(VB_GENERAL, LOG_ERR, LOC + m_error);
138  }
139  }
140 
141  LOG(VB_RECORD, LOG_INFO, LOC + "run -- ending...");
142 
146 
147  Close();
148 
149  FinishRecording();
150 
151  QMutexLocker locker(&m_pauseLock);
152  m_recording = false;
153  m_recordingWait.wakeAll();
154 
155  LOG(VB_RECORD, LOG_INFO, LOC + "run -- end");
156 }
157 
159 {
160  QMutexLocker locker(&m_pauseLock);
161  if (m_requestPause)
162  {
163  if (!IsPaused(true))
164  {
166 
167  m_paused = true;
168  m_pauseWait.wakeAll();
169  if (m_tvrec)
171  }
172 
174  }
175 
176  if (!m_requestPause && IsPaused(true))
177  {
178  m_paused = false;
180  m_unpauseWait.wakeAll();
181  }
182 
183  return IsPaused(true);
184 }
185 
186 QString HDHRRecorder::GetSIStandard(void) const
187 {
188  return m_channel->GetSIStandard();
189 }
190 
191 /* vim: set expandtab tabstop=4 shiftwidth=4: */
DTVRecorder::HandleSingleProgramPMT
void HandleSingleProgramPMT(ProgramMapTable *pmt, bool insert) override
Definition: dtvrecorder.cpp:1334
hardwareprofile.smolt.timeout
float timeout
Definition: smolt.py:103
HDHRRecorder::PauseAndWait
bool PauseAndWait(int timeout=100) override
If m_requestPause is true, sets pause and blocks up to timeout milliseconds or until unpaused,...
Definition: hdhrrecorder.cpp:158
DTVRecorder::m_inputPmt
ProgramMapTable * m_inputPmt
PMT on input side.
Definition: dtvrecorder.h:174
HDHRRecorder::m_channel
HDHRChannel * m_channel
Definition: hdhrrecorder.h:39
DTVRecorder::ResetForNewFile
void ResetForNewFile(void) override
Definition: dtvrecorder.cpp:138
HDHRRecorder::Close
void Close(void)
Definition: hdhrrecorder.cpp:52
DTVRecorder::SetStreamData
virtual void SetStreamData(MPEGStreamData *data)
Definition: dtvrecorder.cpp:210
RecorderBase::m_tvrec
TVRec * m_tvrec
Definition: recorderbase.h:314
DTVRecorder::IsErrored
bool IsErrored(void) override
Tells us whether an unrecoverable error has been encountered.
Definition: dtvrecorder.h:47
atscstreamdata.h
DTVChannel::GetFormat
QString GetFormat(void)
Definition: dtvchannel.h:47
HDHRRecorder::GetSIStandard
QString GetSIStandard(void) const override
Definition: hdhrrecorder.cpp:186
LOG
#define LOG(_MASK_, _LEVEL_, _QSTRING_)
Definition: mythlogging.h:23
StreamHandler::AddNamedOutputFile
virtual bool AddNamedOutputFile(const QString &filename)
Called with _listener_lock locked just after adding new output file.
Definition: streamhandler.cpp:356
DTVRecorder::FinishRecording
void FinishRecording(void) override
Flushes the ringbuffer, and if this is not a live LiveTV recording saves the position map and filesiz...
Definition: dtvrecorder.cpp:124
MPEGStreamData::PMTSingleProgram
const ProgramMapTable * PMTSingleProgram(void) const
Definition: mpegstreamdata.h:262
StreamHandler::RemoveListener
virtual void RemoveListener(MPEGStreamData *data)
Definition: streamhandler.cpp:78
RecorderBase::m_pauseLock
QMutex m_pauseLock
Definition: recorderbase.h:337
RecorderBase::m_requestPause
bool m_requestPause
Definition: recorderbase.h:338
RecorderBase::m_recordingWait
QWaitCondition m_recordingWait
Definition: recorderbase.h:346
TVRec::RecorderPaused
void RecorderPaused(void)
This is a callback, called by the "recorder" instance when it has actually paused.
Definition: tv_rec.cpp:2947
MythMediaBuffer::GetFilename
QString GetFilename(void) const
Definition: mythmediabuffer.cpp:1748
TVRec::GetInputId
uint GetInputId(void) const
Returns the inputid.
Definition: tv_rec.h:234
RecorderBase::m_paused
bool m_paused
Definition: recorderbase.h:339
MPEGStreamData::PATSingleProgram
const ProgramAssociationTable * PATSingleProgram(void) const
Definition: mpegstreamdata.h:260
DTVRecorder::HandleSingleProgramPAT
void HandleSingleProgramPAT(ProgramAssociationTable *pat, bool insert) override
Definition: dtvrecorder.cpp:1314
mythlogging.h
HDHRStreamHandler::Return
static void Return(HDHRStreamHandler *&ref, int inputid)
Definition: hdhrstreamhandler.cpp:63
DTVRecorder::m_recordMptsOnly
bool m_recordMptsOnly
Definition: dtvrecorder.h:179
MPEGStreamData::RemoveWritingListener
void RemoveWritingListener(TSPacketListener *val)
Definition: mpegstreamdata.cpp:1629
RecorderBase::IsRecordingRequested
virtual bool IsRecordingRequested(void)
Tells us if StopRecording() has been called.
Definition: recorderbase.cpp:252
hdhrrecorder.h
HDHRRecorder::StartNewFile
void StartNewFile(void) override
Definition: hdhrrecorder.cpp:63
HDHRChannel::GetDevice
QString GetDevice(void) const override
Returns String representing device, useful for debugging.
Definition: hdhrchannel.h:35
LOC
#define LOC
-*- Mode: c++ -*- HDHRRecorder Copyright (c) 2006-2009 by Silicondust Engineering Ltd,...
Definition: hdhrrecorder.cpp:21
mythmediabuffer.h
DTVChannel::GetSIStandard
QString GetSIStandard(void) const
Returns PSIP table standard: MPEG, DVB, ATSC, or OpenCable.
Definition: dtvchannel.cpp:44
DVB_TDT_PID
@ DVB_TDT_PID
Definition: mpegtables.h:213
RecorderBase::m_pauseWait
QWaitCondition m_pauseWait
Definition: recorderbase.h:340
RecorderBase::m_ringBuffer
MythMediaBuffer * m_ringBuffer
Definition: recorderbase.h:315
MPEGStreamData::AddAVListener
void AddAVListener(TSPacketListenerAV *val)
Definition: mpegstreamdata.cpp:1643
DTVRecorder::m_streamData
MPEGStreamData * m_streamData
Definition: dtvrecorder.h:163
MPEGStreamData::AddWritingListener
void AddWritingListener(TSPacketListener *val)
Definition: mpegstreamdata.cpp:1618
DTVRecorder::m_error
QString m_error
non-empty iff irrecoverable recording error detected
Definition: dtvrecorder.h:161
DTVRecorder::m_recordMpts
bool m_recordMpts
Definition: dtvrecorder.h:178
HDHRRecorder::m_streamHandler
HDHRStreamHandler * m_streamHandler
Definition: hdhrrecorder.h:40
RecorderBase::m_recording
bool m_recording
True while recording is actually being performed.
Definition: recorderbase.h:345
tv_rec.h
ChannelBase::GetInputID
virtual int GetInputID(void) const
Definition: channelbase.h:67
MPEGStreamData::AddListeningPID
virtual void AddListeningPID(uint pid, PIDPriority priority=kPIDPriorityNormal)
Definition: mpegstreamdata.h:120
HDHRStreamHandler::Get
static HDHRStreamHandler * Get(const QString &devname, int inputid, int majorid)
Definition: hdhrstreamhandler.cpp:32
hdhrstreamhandler.h
StreamHandler::IsRunning
bool IsRunning(void) const
Definition: streamhandler.cpp:161
hdhrchannel.h
RecorderBase::m_unpauseWait
QWaitCondition m_unpauseWait
Definition: recorderbase.h:341
ChannelBase::GetMajorID
int GetMajorID(void)
Definition: channelbase.cpp:857
TSStreamData
Specialized version of MPEGStreamData which is used to 'blindly' record the entire MPTS transport fro...
Definition: tsstreamdata.h:12
MPEGStreamData::RemoveAVListener
void RemoveAVListener(TSPacketListenerAV *val)
Definition: mpegstreamdata.cpp:1654
HDHRStreamHandler::AddListener
void AddListener(MPEGStreamData *data, bool=false, bool=false, QString output_file=QString()) override
Definition: hdhrstreamhandler.h:53
HDHRRecorder::IsOpen
bool IsOpen(void) const
Definition: hdhrrecorder.h:28
HDHRRecorder::run
void run(void) override
run() starts the recording process, and does not exit until the recording is complete.
Definition: hdhrrecorder.cpp:76
RecorderBase::IsPaused
virtual bool IsPaused(bool holding_lock=false) const
Returns true iff recorder is paused.
Definition: recorderbase.cpp:284
tsstreamdata.h
HDHRRecorder::Open
bool Open(void)
Definition: hdhrrecorder.cpp:24
RecorderBase::m_requestRecording
bool m_requestRecording
True if API call has requested a recording be [re]started.
Definition: recorderbase.h:343