CheckForErrors(ssize_t read_len, size_t requested_len, uint &errcnt) | DeviceReadBuffer | private |
Cleanup(void) | MThread | protectedstatic |
ClosePipes(void) const | DeviceReadBuffer | private |
DeviceReadBuffer(DeviceReaderCB *cb, bool use_poll=true, bool error_exit_on_poll_timeout=true) | DeviceReadBuffer | explicit |
exec(void) | MThread | protected |
exit(int retcode=0) | MThread | protected |
GetAllRunningThreadNames(QStringList &list) | MThread | protectedstatic |
GetAllThreadNames(QStringList &list) | MThread | protectedstatic |
GetContiguousUnused(void) const | DeviceReadBuffer | private |
GetUnused(void) const | DeviceReadBuffer | private |
GetUsed(void) const | DeviceReadBuffer | |
HandlePausing(void) | DeviceReadBuffer | private |
IncrReadPointer(uint len) | DeviceReadBuffer | private |
IncrWritePointer(uint len) | DeviceReadBuffer | private |
IsEOF(void) const | DeviceReadBuffer | |
IsErrored(void) const | DeviceReadBuffer | |
isFinished(void) const | MThread | protected |
IsOpen(void) const | DeviceReadBuffer | inlineprivate |
IsPaused(void) const | DeviceReadBuffer | |
IsPauseRequested(void) const | DeviceReadBuffer | private |
isRunning(void) const | MThread | protected |
IsRunning(void) const | DeviceReadBuffer | |
m_avgBufReadCnt | DeviceReadBuffer | private |
m_avgBufSleepCnt | DeviceReadBuffer | private |
m_avgBufWriteCnt | DeviceReadBuffer | private |
m_avgUsed | DeviceReadBuffer | private |
m_buffer | DeviceReadBuffer | private |
m_dataWait | DeviceReadBuffer | mutableprivate |
m_devBufferCount | DeviceReadBuffer | private |
m_devReadSize | DeviceReadBuffer | private |
m_doRun | DeviceReadBuffer | private |
m_endPtr | DeviceReadBuffer | private |
m_eof | DeviceReadBuffer | private |
m_epilogExecuted | MThread | protected |
m_error | DeviceReadBuffer | mutableprivate |
m_lastReport | DeviceReadBuffer | private |
m_lock | DeviceReadBuffer | mutableprivate |
m_maxPollWait | DeviceReadBuffer | private |
m_maxUsed | DeviceReadBuffer | private |
m_paused | DeviceReadBuffer | private |
m_pauseWait | DeviceReadBuffer | private |
m_pollTimeoutIsError | DeviceReadBuffer | private |
m_prologExecuted | MThread | protected |
m_readerCB | DeviceReadBuffer | private |
m_readPtr | DeviceReadBuffer | private |
m_readQuanta | DeviceReadBuffer | private |
m_readThreshold | DeviceReadBuffer | private |
m_requestPause | DeviceReadBuffer | private |
m_runnable | MThread | protected |
m_runWait | DeviceReadBuffer | private |
m_size | DeviceReadBuffer | private |
m_streamFd | DeviceReadBuffer | private |
m_thread | MThread | protected |
m_unpauseWait | DeviceReadBuffer | private |
m_used | DeviceReadBuffer | private |
m_usingPoll | DeviceReadBuffer | private |
m_videoDevice | DeviceReadBuffer | private |
m_wakePipe | DeviceReadBuffer | mutableprivate |
m_wakePipeFlags | DeviceReadBuffer | mutableprivate |
m_writePtr | DeviceReadBuffer | private |
MThread(const QString &objectName) | MThread | explicitprotected |
MThread(const QString &objectName, QRunnable *runnable) | MThread | explicitprotected |
MThread(const MThread &)=delete | MThread | protected |
objectName(void) const | MThread | protected |
operator=(const MThread &)=delete | MThread | protected |
Poll(void) const | DeviceReadBuffer | private |
priority(void) const | MThread | protected |
qthread(void) | MThread | protected |
quit(void) | MThread | protected |
Read(unsigned char *buf, uint count) | DeviceReadBuffer | |
ReportStats(void) | DeviceReadBuffer | private |
Reset(const QString &streamName, int streamfd) | DeviceReadBuffer | |
run(void) override | DeviceReadBuffer | privatevirtual |
RunEpilog(void) | MThread | protected |
RunProlog(void) | MThread | protected |
setObjectName(const QString &name) | MThread | protected |
SetPaused(bool val) | DeviceReadBuffer | private |
setPriority(QThread::Priority priority) | MThread | protected |
SetRequestPause(bool request) | DeviceReadBuffer | |
setStackSize(uint stackSize) | MThread | protected |
setTerminationEnabled(bool enabled=true) | MThread | protectedstatic |
Setup(const QString &streamName, int streamfd, uint readQuanta=sizeof(TSPacket), uint deviceBufferSize=0, uint deviceBufferCount=1) | DeviceReadBuffer | |
stackSize(void) const | MThread | protected |
Start(void) | DeviceReadBuffer | |
start(QThread::Priority p=QThread::InheritPriority) | MThread | protected |
Stop(void) | DeviceReadBuffer | |
terminate(void) | MThread | protected |
ThreadCleanup(void) | MThread | protectedstatic |
ThreadSetup(const QString &name) | MThread | protectedstatic |
usleep(std::chrono::microseconds time) | MThread | protectedstatic |
usleep(std::chrono::duration< R, P > time) | MThread | inlineprotectedstatic |
wait(std::chrono::milliseconds time=std::chrono::milliseconds::max()) | MThread | protected |
WaitForPaused(unsigned long timeout) | DeviceReadBuffer | |
WaitForUnpause(unsigned long timeout) | DeviceReadBuffer | |
WaitForUnused(uint needed) const | DeviceReadBuffer | private |
WaitForUsed(uint needed, std::chrono::milliseconds max_wait) const | DeviceReadBuffer | private |
WakePoll(void) const | DeviceReadBuffer | private |
~DeviceReadBuffer() override | DeviceReadBuffer | |
~MThread() | MThread | protectedvirtual |