30 m_deviceAPI(deviceAPI),
31 m_masterTimer(deviceAPI->getMasterTimer()),
32 m_masterTimerConnected(false),
36 m_dataAddress(QHostAddress::LocalHost),
37 m_remoteAddress(QHostAddress::LocalHost),
39 m_dataConnected(false),
42 m_sampleFifo(sampleFifo),
46 m_outputMessageQueueToGUI(0),
51 m_readLengthSamples(0),
54 m_converterBufferNbSamples(0),
55 m_throttleToggle(false),
56 m_autoCorrBuffer(true)
60 #ifdef USE_INTERNAL_TIMER 61 #warning "Uses internal timer" 76 #ifdef USE_INTERNAL_TIMER 85 qDebug(
"RemoteInputUDPHandler::start");
102 qDebug(
"RemoteInputUDPHandler::start: bind data socket to %s:%d",
m_dataAddress.toString().toStdString().c_str(),
m_dataPort);
107 qWarning(
"RemoteInputUDPHandler::start: cannot bind data port %d",
m_dataPort);
119 qDebug(
"RemoteInputUDPHandler::stop");
146 qDebug(
"RemoteInputUDPHandler::configureUDPLink: %s:%d", address.toStdString().c_str(), port);
151 qWarning(
"RemoteInputUDPHandler::configureUDPLink: invalid address %s. Set to localhost.", address.toStdString().c_str());
166 qint64 pendingDataSize =
m_dataSocket->pendingDatagramSize();
169 if (m_udpReadBytes == RemoteUdpSize) {
221 qDebug() <<
"RemoteInputUDPHandler::connectTimer";
222 #ifdef USE_INTERNAL_TIMER 223 #warning "Uses internal timer" 224 connect(
m_timer, SIGNAL(timeout()),
this, SLOT(
tick()));
236 qDebug() <<
"RemoteInputUDPHandler::disconnectTimer";
237 #ifdef USE_INTERNAL_TIMER 238 #warning "Uses internal timer" 239 disconnect(
m_timer, SIGNAL(timeout()),
this, SLOT(
tick()));
318 qWarning(
"RemoteInputUDPHandler::tick: unexpected sample size in stream: %d bits", (
int) metaData.
m_sampleBits);
331 int framesDecodingStatus;
340 if (minNbBlocks < nbOriginalBlocks) {
341 framesDecodingStatus = 0;
342 }
else if (minNbBlocks < nbOriginalBlocks + nbFECblocks) {
343 framesDecodingStatus = 1;
345 framesDecodingStatus = 2;
352 framesDecodingStatus,
353 minNbBlocks == nbOriginalBlocks + nbFECblocks,
void push(Message *message, bool emitSignal=true)
Push message onto queue.
uint write(const quint8 *data, uint count)
MessageQueue * getDeviceEngineInputMessageQueue()
Device engine message queue.