18 #ifndef PLUGINS_SAMPLESINK_REMOTEOUTPUT_UDPSINKFECWORKER_H_ 19 #define PLUGINS_SAMPLESINK_REMOTEOUTPUT_UDPSINKFECWORKER_H_ 24 #include <QWaitCondition> 25 #include <QHostAddress> 27 #include "cm256cc/cm256.h" 68 m_nbBlocksFEC(nbBlocksFEC),
70 m_frameIndex(frameIndex)
111 m_startStop(startStop)
QWaitCondition m_startWaiter
static MsgStartStop * create(bool startStop)
bool getStartStop() const
QHostAddress m_remoteHostAddress
void pushTxFrame(RemoteSuperBlock *txBlocks, uint32_t nbBlocksFEC, uint32_t txDelay, uint16_t frameIndex)
static MsgUDPFECEncodeAndSend * create(RemoteSuperBlock *txBlocks, uint32_t nbBlocksFEC, uint32_t txDelay, uint16_t frameIndex)
MsgStartStop(bool startStop)
void encodeAndTransmit(RemoteSuperBlock *txBlockx, uint16_t frameIndex, uint32_t nbBlocksFEC, uint32_t txDelay)
uint32_t getNbBlocsFEC() const
void startStop(bool start)
#define MESSAGE_CLASS_DECLARATION
MessageQueue m_inputMessageQueue
Queue for asynchronous inbound communication.
void handleInputMessages()
void setRemoteAddress(const QString &address, uint16_t port)
RemoteSuperBlock * getTxBlocks() const
CM256 m_cm256
CM256 library object.
uint16_t getFrameIndex() const
uint32_t getTxDelay() const
bool m_cm256Valid
true if CM256 library is initialized correctly
MsgUDPFECEncodeAndSend(RemoteSuperBlock *txBlocks, uint32_t nbBlocksFEC, uint32_t txDelay, uint16_t frameIndex)
RemoteSuperBlock * m_txBlockx