MythTV
master
|
#include <asistreamhandler.h>
Public Member Functions | |
void | AddListener (MPEGStreamData *data, bool=false, bool=false, const QString &output_file=QString()) override |
void | SetClockSource (ASIClockSource cs) |
void | SetRXMode (ASIRXMode m) |
Public Member Functions inherited from StreamHandler | |
virtual void | RemoveListener (MPEGStreamData *data) |
bool | IsRunning (void) const |
bool | HasError (void) const |
virtual bool | AddNamedOutputFile (const QString &filename) |
Called with _listener_lock locked just after adding new output file. More... | |
virtual void | RemoveNamedOutputFile (const QString &filename) |
Called with _listener_lock locked just before removing old output file. More... | |
Static Public Member Functions | |
static ASIStreamHandler * | Get (const QString &devname, int inputid) |
static void | Return (ASIStreamHandler *&ref, int inputid) |
Private Member Functions | |
ASIStreamHandler (const QString &device, int inputid) | |
bool | Open (void) |
void | Close (void) |
void | run (void) override |
Runs the Qt event loop unless we have a QRunnable, in which case we run the runnable run instead. More... | |
void | PriorityEvent (int fd) override |
void | SetRunningDesired (bool desired) override |
At minimum this sets _running_desired, this may also send signals to anything that might be blocking the run() loop. More... | |
Private Attributes | |
int | m_deviceNum {-1} |
int | m_bufSize {-1} |
int | m_numBuffers {-1} |
int | m_fd {-1} |
uint | m_packetSize {TSPacket::kSize} |
ASIClockSource | m_clockSource {kASIInternalClock} |
ASIRXMode | m_rxMode {kASIRXSyncOnActualConvertTo188} |
DeviceReadBuffer * | m_drb {nullptr} |
Static Private Attributes | |
static QMutex | s_handlersLock |
static QMap< QString, ASIStreamHandler * > | s_handlers |
static QMap< QString, uint > | s_handlersRefCnt |
Additional Inherited Members | |
Protected Types inherited from StreamHandler | |
using | StreamDataList = QHash< MPEGStreamData *, QString > |
Protected Member Functions inherited from StreamHandler | |
StreamHandler (QString device, int inputid) | |
~StreamHandler () override | |
void | Start (void) |
void | Stop (void) |
void | SetRunning (bool running, bool using_buffering, bool using_section_reader) |
bool | AddPIDFilter (PIDInfo *info) |
bool | RemovePIDFilter (uint pid) |
bool | RemoveAllPIDFilters (void) |
void | UpdateListeningForEIT (void) |
bool | UpdateFiltersFromStreamData (void) |
virtual bool | UpdateFilters (void) |
virtual void | CycleFiltersByPriority () |
PIDPriority | GetPIDPriority (uint pid) const |
void | ReaderPaused (int fd) override |
void | PriorityEvent (int fd) override |
virtual PIDInfo * | CreatePIDInfo (uint pid, uint stream_type, int pes_type) |
void | WriteMPTS (const unsigned char *buffer, uint len) |
Write out a copy of the raw MPTS. More... | |
Protected Member Functions inherited from MThread | |
int | exec (void) |
Enters the qt event loop. call exit or quit to exit thread. More... | |
MThread (const QString &objectName) | |
Standard constructor. More... | |
MThread (const QString &objectName, QRunnable *runnable) | |
Use this constructor if you want the default run() method to run the QRunnable's run() method instead of entering the Qt event loop. More... | |
virtual | ~MThread () |
MThread (const MThread &)=delete | |
MThread & | operator= (const MThread &)=delete |
void | RunProlog (void) |
Sets up a thread, call this if you reimplement run(). More... | |
void | RunEpilog (void) |
Cleans up a thread's resources, call this if you reimplement run(). More... | |
QThread * | qthread (void) |
Returns the thread, this will always return the same pointer no matter how often you restart the thread. More... | |
void | setObjectName (const QString &name) |
QString | objectName (void) const |
void | setPriority (QThread::Priority priority) |
QThread::Priority | priority (void) const |
bool | isFinished (void) const |
bool | isRunning (void) const |
void | setStackSize (uint stackSize) |
uint | stackSize (void) const |
void | exit (int retcode=0) |
Use this to exit from the thread if you are using a Qt event loop. More... | |
void | start (QThread::Priority p=QThread::InheritPriority) |
Tell MThread to start running the thread in the near future. More... | |
void | terminate (void) |
Kill a thread unsafely. More... | |
void | quit (void) |
calls exit(0) More... | |
bool | wait (std::chrono::milliseconds time=std::chrono::milliseconds::max()) |
Wait for the MThread to exit, with a maximum timeout. More... | |
Protected Member Functions inherited from DeviceReaderCB | |
virtual | ~DeviceReaderCB ()=default |
Static Protected Member Functions inherited from MThread | |
static void | setTerminationEnabled (bool enabled=true) |
static void | usleep (std::chrono::microseconds time) |
template<typename R , typename P > | |
static std::enable_if_t< std::chrono::treat_as_floating_point< R >::value, void > | usleep (std::chrono::duration< R, P > time) |
static void | ThreadSetup (const QString &name) |
This is to be called on startup in those few threads that haven't been ported to MThread. More... | |
static void | ThreadCleanup (void) |
This is to be called on exit in those few threads that haven't been ported to MThread. More... | |
static void | Cleanup (void) |
This will print out all the running threads, call exit(1) on each and then wait up to 5 seconds total for all the threads to exit. More... | |
static void | GetAllThreadNames (QStringList &list) |
static void | GetAllRunningThreadNames (QStringList &list) |
Protected Attributes inherited from StreamHandler | |
QString | m_device |
int | m_inputId |
bool | m_needsBuffering {false} |
bool | m_allowSectionReader {false} |
QMutex | m_addRmLock |
QMutex | m_startStopLock |
volatile bool | m_runningDesired {false} |
volatile bool | m_bError {false} |
bool | m_running {false} |
bool | m_restarting {false} |
bool | m_usingBuffering {false} |
bool | m_usingSectionReader {false} |
QWaitCondition | m_runningStateChanged |
QRecursiveMutex | m_pidLock |
std::vector< uint > | m_eitPids |
PIDInfoMap | m_pidInfo |
uint | m_openPidFilters {0} |
bool | m_filtersChanged {false} |
MythTimer | m_cycleTimer |
ThreadedFileWriter * | m_mptsTfw {nullptr} |
QSet< QString > | m_mptsFiles |
QString | m_mptsBaseFile |
QMutex | m_mptsLock |
QRecursiveMutex | m_listenerLock |
StreamDataList | m_streamDataList |
Protected Attributes inherited from MThread | |
MThreadInternal * | m_thread {nullptr} |
QRunnable * | m_runnable {nullptr} |
bool | m_prologExecuted {true} |
bool | m_epilogExecuted {true} |
Definition at line 43 of file asistreamhandler.h.
|
explicitprivate |
Definition at line 104 of file asistreamhandler.cpp.
Referenced by Get().
|
static |
Definition at line 33 of file asistreamhandler.cpp.
Referenced by ASISignalMonitor::ASISignalMonitor(), and ASIRecorder::Open().
|
static |
Definition at line 66 of file asistreamhandler.cpp.
Referenced by ASIRecorder::Close(), and ASISignalMonitor::~ASISignalMonitor().
|
inlineoverridevirtual |
Reimplemented from StreamHandler.
Definition at line 49 of file asistreamhandler.h.
Referenced by ASIRecorder::run(), and ASISignalMonitor::UpdateValues().
void ASIStreamHandler::SetClockSource | ( | ASIClockSource | cs | ) |
Definition at line 110 of file asistreamhandler.cpp.
void ASIStreamHandler::SetRXMode | ( | ASIRXMode | m | ) |
Definition at line 117 of file asistreamhandler.cpp.
|
private |
Definition at line 261 of file asistreamhandler.cpp.
Referenced by run().
|
private |
Definition at line 336 of file asistreamhandler.cpp.
|
overrideprivatevirtual |
Runs the Qt event loop unless we have a QRunnable, in which case we run the runnable run instead.
Reimplemented from MThread.
Definition at line 131 of file asistreamhandler.cpp.
|
overrideprivatevirtual |
Implements DeviceReaderCB.
Definition at line 345 of file asistreamhandler.cpp.
|
overrideprivatevirtual |
At minimum this sets _running_desired, this may also send signals to anything that might be blocking the run() loop.
Reimplemented from StreamHandler.
Definition at line 124 of file asistreamhandler.cpp.
|
private |
Definition at line 73 of file asistreamhandler.h.
Referenced by Open().
|
private |
Definition at line 74 of file asistreamhandler.h.
|
private |
Definition at line 75 of file asistreamhandler.h.
|
private |
Definition at line 76 of file asistreamhandler.h.
|
private |
Definition at line 77 of file asistreamhandler.h.
|
private |
Definition at line 78 of file asistreamhandler.h.
Referenced by SetClockSource().
|
private |
Definition at line 79 of file asistreamhandler.h.
Referenced by Open(), and SetRXMode().
|
private |
Definition at line 80 of file asistreamhandler.h.
Referenced by run(), and SetRunningDesired().
|
staticprivate |
Definition at line 83 of file asistreamhandler.h.
|
staticprivate |
Definition at line 84 of file asistreamhandler.h.
|
staticprivate |
Definition at line 85 of file asistreamhandler.h.