MythTV  master
Public Member Functions | Static Public Member Functions | Public Attributes | Protected Attributes | Private Member Functions | Private Attributes | Static Private Attributes | Friends | List of all members
SatIPStreamHandler Class Reference

#include <satipstreamhandler.h>

Inheritance diagram for SatIPStreamHandler:
Inheritance graph
[legend]
Collaboration diagram for SatIPStreamHandler:
Collaboration graph
[legend]

Public Member Functions

void AddListener (MPEGStreamData *data, bool=false, bool=false, const QString &output_file=QString()) override
 
bool UpdateFilters () override
 
bool Tune (const DTVMultiplex &tuning)
 
- 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 SatIPStreamHandlerGet (const QString &devname, int inputid)
 
static void Return (SatIPStreamHandler *&ref, int inputid)
 

Public Attributes

int m_inputId {0}
 

Protected Attributes

SatIPRTSPm_rtsp {nullptr}
 
- 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< uintm_eitPids
 
PIDInfoMap m_pidInfo
 
uint m_openPidFilters {0}
 
MythTimer m_cycleTimer
 
ThreadedFileWriterm_mptsTfw {nullptr}
 
QSet< QString > m_mptsFiles
 
QString m_mptsBaseFile
 
QMutex m_mptsLock
 
QRecursiveMutex m_listenerLock
 
StreamDataList m_streamDataList
 
- Protected Attributes inherited from MThread
MThreadInternalm_thread {nullptr}
 
QRunnable * m_runnable {nullptr}
 
bool m_prologExecuted {true}
 
bool m_epilogExecuted {true}
 

Private Member Functions

 SatIPStreamHandler (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...
 

Private Attributes

DTVTunerType m_tunerType
 
QString m_device
 
uint m_frontend {UINT_MAX}
 
QUrl m_baseurl
 
QUrl m_tuningurl
 
QUrl m_oldtuningurl
 
bool m_setupinvoked {false}
 
QRecursiveMutex m_tunelock
 
QStringList m_oldpids
 

Static Private Attributes

static QMap< QString, SatIPStreamHandler * > s_handlers
 
static QMap< QString, uints_handlersRefCnt
 
static QMutex s_handlersLock
 

Friends

class SatIPRTSPWriteHelper
 
class SatIPRTSPReadHelper
 
class SatIPSignalMonitor
 

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 void CycleFiltersByPriority ()
 
PIDPriority GetPIDPriority (uint pid) const
 
void ReaderPaused (int fd) override
 
void PriorityEvent (int fd) override
 
virtual PIDInfoCreatePIDInfo (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...
 
virtual void SetRunningDesired (bool desired)
 At minimum this sets _running_desired, this may also send signals to anything that might be blocking the run() loop. 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
 
MThreadoperator= (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)
 

Detailed Description

Definition at line 28 of file satipstreamhandler.h.

Constructor & Destructor Documentation

◆ SatIPStreamHandler()

SatIPStreamHandler::SatIPStreamHandler ( const QString &  device,
int  inputid 
)
explicitprivate

Definition at line 106 of file satipstreamhandler.cpp.

Referenced by Get().

Member Function Documentation

◆ Get()

SatIPStreamHandler * SatIPStreamHandler::Get ( const QString &  devname,
int  inputid 
)
static

◆ Return()

void SatIPStreamHandler::Return ( SatIPStreamHandler *&  ref,
int  inputid 
)
static

◆ AddListener()

void SatIPStreamHandler::AddListener ( MPEGStreamData data,
bool  = false,
bool  = false,
const QString &  output_file = QString() 
)
inlineoverridevirtual

◆ UpdateFilters()

bool SatIPStreamHandler::UpdateFilters ( )
overridevirtual

Reimplemented from StreamHandler.

Definition at line 118 of file satipstreamhandler.cpp.

Referenced by run().

◆ Tune()

bool SatIPStreamHandler::Tune ( const DTVMultiplex tuning)

Definition at line 215 of file satipstreamhandler.cpp.

Referenced by SatIPChannel::Tune().

◆ Open()

bool SatIPStreamHandler::Open ( void  )
private

Definition at line 306 of file satipstreamhandler.cpp.

◆ Close()

void SatIPStreamHandler::Close ( void  )
private

Definition at line 344 of file satipstreamhandler.cpp.

◆ run()

void SatIPStreamHandler::run ( void  )
overrideprivatevirtual

Runs the Qt event loop unless we have a QRunnable, in which case we run the runnable run instead.

Note
If you override this method you must call RunProlog before you do any work and RunEpilog before you exit the run method.

Reimplemented from MThread.

Definition at line 151 of file satipstreamhandler.cpp.

Friends And Related Function Documentation

◆ SatIPRTSPWriteHelper

friend class SatIPRTSPWriteHelper
friend

Definition at line 30 of file satipstreamhandler.h.

◆ SatIPRTSPReadHelper

friend class SatIPRTSPReadHelper
friend

Definition at line 31 of file satipstreamhandler.h.

◆ SatIPSignalMonitor

friend class SatIPSignalMonitor
friend

Definition at line 32 of file satipstreamhandler.h.

Member Data Documentation

◆ s_handlers

QMap< QString, SatIPStreamHandler * > SatIPStreamHandler::s_handlers
staticprivate

Definition at line 58 of file satipstreamhandler.h.

Referenced by Get(), and Return().

◆ s_handlersRefCnt

QMap< QString, uint > SatIPStreamHandler::s_handlersRefCnt
staticprivate

Definition at line 59 of file satipstreamhandler.h.

Referenced by Get(), and Return().

◆ s_handlersLock

QMutex SatIPStreamHandler::s_handlersLock
staticprivate

Definition at line 60 of file satipstreamhandler.h.

Referenced by Get(), and Return().

◆ m_inputId

int SatIPStreamHandler::m_inputId {0}

Definition at line 63 of file satipstreamhandler.h.

◆ m_tunerType

DTVTunerType SatIPStreamHandler::m_tunerType
private

Definition at line 66 of file satipstreamhandler.h.

Referenced by Open(), and Tune().

◆ m_device

QString SatIPStreamHandler::m_device
private

Definition at line 67 of file satipstreamhandler.h.

Referenced by Open(), and Return().

◆ m_frontend

uint SatIPStreamHandler::m_frontend {UINT_MAX}
private

Definition at line 68 of file satipstreamhandler.h.

Referenced by Open(), and Tune().

◆ m_baseurl

QUrl SatIPStreamHandler::m_baseurl
private

Definition at line 69 of file satipstreamhandler.h.

Referenced by Close(), Open(), and Tune().

◆ m_tuningurl

QUrl SatIPStreamHandler::m_tuningurl
private

Definition at line 70 of file satipstreamhandler.h.

Referenced by run(), and Tune().

◆ m_oldtuningurl

QUrl SatIPStreamHandler::m_oldtuningurl
private

Definition at line 71 of file satipstreamhandler.h.

Referenced by run(), and Tune().

◆ m_setupinvoked

bool SatIPStreamHandler::m_setupinvoked {false}
private

Definition at line 72 of file satipstreamhandler.h.

Referenced by run(), and Tune().

◆ m_tunelock

QRecursiveMutex SatIPStreamHandler::m_tunelock
private

Definition at line 76 of file satipstreamhandler.h.

Referenced by run(), and Tune().

◆ m_oldpids

QStringList SatIPStreamHandler::m_oldpids
private

Definition at line 78 of file satipstreamhandler.h.

Referenced by Tune(), and UpdateFilters().

◆ m_rtsp

SatIPRTSP* SatIPStreamHandler::m_rtsp {nullptr}
protected

The documentation for this class was generated from the following files: