18 #ifndef PLUGINS_CHANNELTX_REMOTESRC_REMOTESRCTHREAD_H_ 19 #define PLUGINS_CHANNELTX_REMOTESRC_REMOTESRCTHREAD_H_ 23 #include <QWaitCondition> 24 #include <QHostAddress> 51 m_startStop(startStop)
74 m_address.setAddress(address);
QWaitCondition m_startWaiter
void readPendingDatagrams()
QHostAddress getAddress() const
RemoteDataQueue * m_dataQueue
static MsgDataBind * create(const QString &address, uint16_t port)
static const uint32_t m_nbDataBlocks
number of data blocks in the ring buffer
void handleInputMessages()
#define MESSAGE_CLASS_DECLARATION
MessageQueue m_inputMessageQueue
void dataBind(const QString &address, uint16_t port)
static MsgStartStop * create(bool startStop)
RemoteDataBlock * m_dataBlocks[m_nbDataBlocks]
ring buffer of data blocks indexed by frame affinity
MsgDataBind(const QString &address, uint16_t port)
void startStop(bool start)
RemoteSourceThread(RemoteDataQueue *dataQueue, QObject *parent=0)
MsgStartStop(bool startStop)
bool getStartStop() const