MythTV
master
|
This is a specialization of DTVRecorder used to handle streams from ASI drivers. More...
#include <asirecorder.h>
Public Member Functions | |
ASIRecorder (TVRec *rec, ASIChannel *channel) | |
void | SetOptionsFromProfile (RecordingProfile *profile, const QString &videodev, const QString &audiodev, const QString &vbidev) override |
Sets basic recorder options. More... | |
void | run (void) override |
run() starts the recording process, and does not exit until the recording is complete. More... | |
bool | Open (void) |
bool | IsOpen (void) const |
void | Close (void) |
void | StartNewFile (void) override |
![]() | |
DTVRecorder (TVRec *rec) | |
~DTVRecorder () override | |
void | SetOption (const QString &name, const QString &value) override |
Set an specific option. More... | |
void | SetOption (const QString &name, int value) override |
handles the "wait_for_seqstart" option. More... | |
void | SetOptionsFromProfile (RecordingProfile *profile, const QString &videodev, const QString &audiodev, const QString &vbidev) override |
Sets basic recorder options. More... | |
bool | IsErrored (void) override |
Tells us whether an unrecoverable error has been encountered. More... | |
long long | GetFramesWritten (void) override |
Returns number of frames written to disk. More... | |
void | SetVideoFilters (QString &) override |
Tells recorder which filters to use. More... | |
void | Initialize (void) override |
This is called between SetOptionsFromProfile() and run() to initialize any devices, etc. More... | |
int | GetVideoFd (void) override |
Returns file descriptor of recorder device. More... | |
virtual void | SetStreamData (MPEGStreamData *data) |
MPEGStreamData * | GetStreamData (void) const |
void | Reset (void) override |
Reset the recorder to the startup state. More... | |
void | ClearStatistics (void) override |
RecordingQuality * | GetRecordingQuality (const RecordingInfo *r) const override |
Returns a report about the current recordings quality. More... | |
void | HandlePAT (const ProgramAssociationTable *_pat) override |
void | HandleCAT (const ConditionalAccessTable *) override |
void | HandlePMT (uint progNum, const ProgramMapTable *_pmt) override |
void | HandleEncryptionStatus (uint, bool) override |
void | HandleSingleProgramPAT (ProgramAssociationTable *pat, bool insert) override |
void | HandleSingleProgramPMT (ProgramMapTable *pmt, bool insert) override |
void | HandleSTT (const SystemTimeTable *) override |
void | HandleVCT (uint, const VirtualChannelTable *) override |
void | HandleMGT (const MasterGuideTable *) override |
void | HandleTDT (const TimeDateTable *) override |
void | HandleNIT (const NetworkInformationTable *) override |
void | HandleSDT (uint, const ServiceDescriptionTable *) override |
bool | ProcessTSPacket (const TSPacket &tspacket) override |
bool | ProcessVideoTSPacket (const TSPacket &tspacket) override |
bool | ProcessAudioTSPacket (const TSPacket &tspacket) override |
bool | ProcessAVTSPacket (const TSPacket &tspacket) |
Common code for processing either audio or video packets. More... | |
![]() | |
RecorderBase (TVRec *rec) | |
~RecorderBase () override | |
void | SetFrameRate (double rate) |
Sets the video frame rate. More... | |
void | SetRecording (const RecordingInfo *pginfo) |
Changes the Recording from the one set initially with SetOptionsFromProfile(). More... | |
void | SetRingBuffer (MythMediaBuffer *Buffer) |
Tells recorder to use an externally created ringbuffer. More... | |
void | SetBoolOption (const QString &name, bool value) |
Set an specific boolean option. More... | |
void | SetNextRecording (const RecordingInfo *ri, MythMediaBuffer *Buffer) |
Sets next recording info, to be applied as soon as practical. More... | |
long long | GetKeyframePosition (long long desired) const |
Returns closest keyframe position before the desired frame. More... | |
bool | GetKeyframePositions (long long start, long long end, frm_pos_map_t &map) const |
bool | GetKeyframeDurations (long long start, long long end, frm_pos_map_t &map) const |
virtual void | StopRecording (void) |
StopRecording() signals to the recorder that it should stop recording and exit cleanly. More... | |
virtual bool | IsRecording (void) |
Tells whether the StartRecorder() loop is running. More... | |
virtual bool | IsRecordingRequested (void) |
Tells us if StopRecording() has been called. More... | |
virtual void | Pause (bool clear=true) |
Pause tells recorder to pause, it should not block. More... | |
virtual void | Unpause (void) |
Unpause tells recorder to unpause. More... | |
virtual bool | IsPaused (bool holding_lock=false) const |
Returns true iff recorder is paused. More... | |
virtual bool | WaitForPause (std::chrono::milliseconds timeout=1s) |
WaitForPause blocks until recorder is actually paused, or timeout milliseconds elapse. More... | |
double | GetFrameRate (void) const |
Returns the latest frame rate. More... | |
virtual bool | CheckForRingBufferSwitch (void) |
If requested, switch to new RingBuffer/ProgramInfo objects. More... | |
void | SavePositionMap (bool force=false, bool finished=false) |
Save the seektable to the DB. More... | |
![]() | |
virtual void | HandleSplice (const SpliceInformationTable *) |
Private Attributes | |
ASIChannel * | m_channel {nullptr} |
ASIStreamHandler * | m_streamHandler {nullptr} |
Additional Inherited Members | |
![]() | |
enum | AspectRatio { ASPECT_UNKNOWN = 0x00, ASPECT_1_1 = 0x01, ASPECT_4_3 = 0x02, ASPECT_16_9 = 0x03, ASPECT_2_21_1 = 0x04, ASPECT_CUSTOM = 0x05 } |
![]() | |
static RecorderBase * | CreateRecorder (TVRec *tvrec, ChannelBase *channel, RecordingProfile &profile, const GeneralDBOptions &genOpt) |
![]() | |
virtual void | InitStreamData (void) |
void | FinishRecording (void) override |
Flushes the ringbuffer, and if this is not a live LiveTV recording saves the position map and filesize. More... | |
void | ResetForNewFile (void) override |
void | HandleKeyframe (int64_t extra) |
This save the current frame to the position maps and handles ringbuffer switching. More... | |
void | HandleTimestamps (int stream_id, int64_t pts, int64_t dts) |
void | UpdateFramesWritten (void) |
void | BufferedWrite (const TSPacket &tspacket, bool insert=false) |
bool | FindAudioKeyframes (const TSPacket *tspacket) |
bool | FindMPEG2Keyframes (const TSPacket *tspacket) |
Locates the keyframes and saves them to the position map. More... | |
bool | FindH2645Keyframes (const TSPacket *tspacket) |
void | HandleH2645Keyframe (void) |
This save the current frame to the position maps and handles ringbuffer switching. More... | |
void | FindPSKeyFrames (const uint8_t *buffer, uint len) override |
bool | FindOtherKeyframes (const TSPacket *tspacket) |
Non-Audio/Video data. More... | |
bool | CheckCC (uint pid, uint new_cnt) |
virtual QString | GetSIStandard (void) const |
virtual void | SetCAMPMT (const ProgramMapTable *) |
virtual void | UpdateCAMTimeOffset (void) |
![]() | |
void | SetIntOption (RecordingProfile *profile, const QString &name) |
Convenience function used to set integer options from a profile. More... | |
void | SetStrOption (RecordingProfile *profile, const QString &name) |
Convenience function used to set QString options from a profile. More... | |
virtual bool | PauseAndWait (std::chrono::milliseconds timeout=100ms) |
If m_requestPause is true, sets pause and blocks up to timeout milliseconds or until unpaused, whichever is sooner. More... | |
virtual void | SetRecordingStatus (RecStatus::Type status, const QString &file, int line) |
void | SetPositionMapType (MarkTypes type) |
Set seektable type. More... | |
void | AspectChange (uint aspect, long long frame) |
Note a change in aspect ratio in the recordedmark table. More... | |
void | ResolutionChange (uint width, uint height, long long frame) |
Note a change in video size in the recordedmark table. More... | |
void | FrameRateChange (uint framerate, uint64_t frame) |
Note a change in video frame rate in the recordedmark table. More... | |
void | VideoScanChange (SCAN_t scan, uint64_t frame) |
Note a change in video scan type in the recordedmark table. More... | |
void | VideoCodecChange (AVCodecID vCodec) |
Note a change in video codec. More... | |
void | AudioCodecChange (AVCodecID aCodec) |
Note a change in audio codec. More... | |
void | SetDuration (std::chrono::milliseconds duration) |
Note the total duration in the recordedmark table. More... | |
void | SetTotalFrames (uint64_t total_frames) |
Note the total frames in the recordedmark table. More... | |
void | TryWriteProgStartMark (const frm_pos_map_t &durationDeltaCopy) |
![]() | |
virtual | ~MPEGStreamListener ()=default |
![]() | |
virtual | ~MPEGSingleProgramStreamListener ()=default |
![]() | |
virtual | ~DVBMainStreamListener ()=default |
![]() | |
virtual | ~ATSCMainStreamListener ()=default |
![]() | |
virtual | ~TSPacketListener ()=default |
![]() | |
virtual | ~TSPacketListenerAV ()=default |
![]() | |
virtual | ~PSStreamListener ()=default |
![]() | |
int | m_streamFd {-1} |
QString | m_recordingType {"all"} |
MythTimer | m_pesTimer |
QElapsedTimer | m_audioTimer |
uint32_t | m_startCode {0xffffffff} |
int | m_firstKeyframe {-1} |
unsigned long long | m_lastGopSeen {0} |
unsigned long long | m_lastSeqSeen {0} |
unsigned long long | m_lastKeyframeSeen {0} |
unsigned int | m_audioBytesRemaining {0} |
unsigned int | m_videoBytesRemaining {0} |
unsigned int | m_otherBytesRemaining {0} |
int | m_progressiveSequence {0} |
int | m_repeatPict {0} |
bool | m_pesSynced {false} |
bool | m_seenSps {false} |
H2645Parser * | m_h2645Parser {nullptr} |
bool | m_waitForKeyframeOption {true} |
Wait for the a GOP/SEQ-start before sending data. More... | |
bool | m_hasWrittenOtherKeyframe {false} |
QString | m_error |
non-empty iff irrecoverable recording error detected More... | |
MPEGStreamData * | m_streamData {nullptr} |
bool | m_bufferPackets {false} |
std::vector< unsigned char > | m_payloadBuffer |
QRecursiveMutex | m_pidLock |
ProgramAssociationTable * | m_inputPat {nullptr} |
PAT on input side. More... | |
ProgramMapTable * | m_inputPmt {nullptr} |
PMT on input side. More... | |
bool | m_hasNoAV {false} |
bool | m_recordMpts {false} |
bool | m_recordMptsOnly {false} |
MythTimer | m_recordMptsTimer |
std::array< uint8_t, 0x1fff+1 > | m_streamId {0} |
std::array< uint8_t, 0x1fff+1 > | m_pidStatus {0} |
std::array< uint8_t, 0x1fff+1 > | m_continuityCounter {0} |
std::vector< TSPacket > | m_scratch |
int | m_minimumRecordingQuality {95} |
bool | m_usePts {false} |
std::array< uint64_t, 256 > | m_tsCount {0} |
std::array< int64_t, 256 > | m_tsLast {} |
std::array< int64_t, 256 > | m_tsFirst {} |
std::array< QDateTime, 256 > | m_tsFirstDt {} |
QAtomicInt | m_packetCount {0} |
QAtomicInt | m_continuityErrorCount {0} |
unsigned long long | m_framesSeenCount {0} |
unsigned long long | m_framesWrittenCount {0} |
double | m_totalDuration {0.0} |
double | m_tdBase {0.0} |
uint64_t | m_tdTickCount {0} |
FrameRate | m_tdTickFramerate {0} |
SCAN_t | m_scanType {SCAN_t::UNKNOWN_SCAN} |
bool | m_musicChoice {false} |
bool | m_useIForKeyframe {true} |
![]() | |
TVRec * | m_tvrec {nullptr} |
MythMediaBuffer * | m_ringBuffer {nullptr} |
bool | m_weMadeBuffer {true} |
AVContainer | m_containerFormat {formatUnknown} |
AVCodecID | m_primaryVideoCodec {AV_CODEC_ID_NONE} |
AVCodecID | m_primaryAudioCodec {AV_CODEC_ID_NONE} |
QString | m_videocodec {"rtjpeg"} |
QString | m_videodevice |
bool | m_ntsc {true} |
bool | m_ntscFrameRate {true} |
double | m_videoFrameRate {29.97} |
uint | m_videoAspect {0} |
uint | m_videoHeight {0} |
uint | m_videoWidth {0} |
FrameRate | m_frameRate {0} |
RecordingInfo * | m_curRecording {nullptr} |
QMutex | m_pauseLock |
bool | m_requestPause {false} |
bool | m_paused {false} |
QWaitCondition | m_pauseWait |
QWaitCondition | m_unpauseWait |
bool | m_requestRecording {false} |
True if API call has requested a recording be [re]started. More... | |
bool | m_recording {false} |
True while recording is actually being performed. More... | |
QWaitCondition | m_recordingWait |
QMutex | m_nextRingBufferLock |
MythMediaBuffer * | m_nextRingBuffer {nullptr} |
RecordingInfo * | m_nextRecording {nullptr} |
MythTimer | m_ringBufferCheckTimer |
MarkTypes | m_positionMapType {MARK_GOP_BYFRAME} |
QMutex | m_positionMapLock |
frm_pos_map_t | m_positionMap |
frm_pos_map_t | m_positionMapDelta |
frm_pos_map_t | m_durationMap |
frm_pos_map_t | m_durationMapDelta |
MythTimer | m_positionMapTimer |
qint64 | m_estimatedProgStartMS {0} |
long long | m_lastSavedKeyframe {0} |
long long | m_lastSavedDuration {0} |
QMutex | m_statisticsLock |
QAtomicInt | m_timeOfFirstDataIsSet |
QDateTime | m_timeOfFirstData |
QAtomicInt | m_timeOfLatestDataCount |
QAtomicInt | m_timeOfLatestDataPacketInterval |
QDateTime | m_timeOfLatestData |
MythTimer | m_timeOfLatestDataTimer |
RecordingGaps | m_recordingGaps |
![]() | |
static const uint | kMaxKeyFrameDistance = 80 |
If the number of regular frames detected since the last detected keyframe exceeds this value, then we begin marking random regular frames as keyframes. More... | |
static const unsigned char | kPayloadStartSeen = 0x2 |
![]() | |
static constexpr std::chrono::milliseconds | kTimeOfLatestDataIntervalTarget { 5s } |
timeOfLatest update interval target in milliseconds. More... | |
This is a specialization of DTVRecorder used to handle streams from ASI drivers.
This has been written and tested with the DVEO ASI hardware and drivers. Those particular drivers do not come with udev rules so you will need to create the following rule in /etc/udev/rules.d/99-asi.rules
SUBSYSTEM=="asi", OWNER="mythtv", GROUP="video", MODE="0660", RUN+="/etc/udev/asi.sh" OPTIONS+="last_rule"
Also, create a /etc/udev/asi.sh file with the following contents:
#!/bin/sh for VAL in buffers bufsize dev granularity mode null_packets timestamps transport uevent clock_source; do chown mythtv /sys/devices/*/*/*/dvbm/*/asi*/$VAL ; chgrp video /sys/devices/*/*/*/dvbm/*/asi*/$VAL ; chmod g+rw /sys/devices/*/*/*/dvbm/*/asi*/$VAL ; chmod g-x /sys/devices/*/*/*/dvbm/*/asi*/$VAL ; ls -l /sys/devices/*/*/*/dvbm/*/asi*/$VAL ; done
Be sure to mark asi.sh as executable with "chmod a+x /etc/udev/asi.sh" udev will silently ignore it if it is not marked.
This of course assumes you want MythTV to have access to all asi device, if this is not the case, you will need to write a more specific rule and modify the asi.sh to only grant permission on a specific asi revice
Definition at line 55 of file asirecorder.h.
ASIRecorder::ASIRecorder | ( | TVRec * | rec, |
ASIChannel * | channel | ||
) |
Definition at line 36 of file asirecorder.cpp.
|
overridevirtual |
Sets basic recorder options.
SetOptionsFromProfile is used to tell the recorder about the recording profile as well as the devices to use.
Implements RecorderBase.
Definition at line 57 of file asirecorder.cpp.
|
overridevirtual |
run() starts the recording process, and does not exit until the recording is complete.
Implements RecorderBase.
Definition at line 83 of file asirecorder.cpp.
bool ASIRecorder::Open | ( | void | ) |
Definition at line 169 of file asirecorder.cpp.
Referenced by run().
bool ASIRecorder::IsOpen | ( | void | ) | const |
Definition at line 188 of file asirecorder.cpp.
void ASIRecorder::Close | ( | void | ) |
Definition at line 193 of file asirecorder.cpp.
Referenced by run().
|
overridevirtual |
Reimplemented from RecorderBase.
Definition at line 69 of file asirecorder.cpp.
Referenced by run().
|
private |
Definition at line 73 of file asirecorder.h.
|
private |
Definition at line 74 of file asirecorder.h.
Referenced by Close(), IsOpen(), Open(), run(), and StartNewFile().