mirror of
https://github.com/f4exb/sdrangel.git
synced 2024-10-01 17:26:40 -04:00
SDRdaemonSink: basic message receive from remote
This commit is contained in:
parent
9a8cc15d8f
commit
7b63657fb7
@ -522,7 +522,17 @@ void SDRdaemonSinkGui::tick()
|
|||||||
{
|
{
|
||||||
if ((++m_tickCount & 0xf) == 0)
|
if ((++m_tickCount & 0xf) == 0)
|
||||||
{
|
{
|
||||||
|
void *msgBuf = 0;
|
||||||
|
|
||||||
SDRdaemonSinkOutput::MsgConfigureSDRdaemonSinkStreamTiming* message = SDRdaemonSinkOutput::MsgConfigureSDRdaemonSinkStreamTiming::create();
|
SDRdaemonSinkOutput::MsgConfigureSDRdaemonSinkStreamTiming* message = SDRdaemonSinkOutput::MsgConfigureSDRdaemonSinkStreamTiming::create();
|
||||||
m_deviceSampleSink->getInputMessageQueue()->push(message);
|
m_deviceSampleSink->getInputMessageQueue()->push(message);
|
||||||
|
|
||||||
|
int len = nn_recv(m_nnSender, &msgBuf, NN_MSG, NN_DONTWAIT);
|
||||||
|
|
||||||
|
if ((len > 0) && msgBuf)
|
||||||
|
{
|
||||||
|
std::string msg((char *) msgBuf, len);
|
||||||
|
qDebug("SDRdaemonSinkGui::tick: received NN msg: %s", msg.c_str());
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -263,7 +263,7 @@ void UDPSinkFECWorker::encodeAndTransmit(UDPSinkFEC::SuperBlock *txBlockx, uint1
|
|||||||
|
|
||||||
if ((nbBlocksFEC == 0) || !m_cm256Valid)
|
if ((nbBlocksFEC == 0) || !m_cm256Valid)
|
||||||
{
|
{
|
||||||
qDebug("UDPSinkFECWorker::encodeAndTransmit: transmit frame without FEC to %s:%d", m_remoteAddress.toStdString().c_str(), m_remotePort);
|
// qDebug("UDPSinkFECWorker::encodeAndTransmit: transmit frame without FEC to %s:%d", m_remoteAddress.toStdString().c_str(), m_remotePort);
|
||||||
|
|
||||||
for (unsigned int i = 0; i < UDPSinkFEC::m_nbOriginalBlocks; i++)
|
for (unsigned int i = 0; i < UDPSinkFEC::m_nbOriginalBlocks; i++)
|
||||||
{
|
{
|
||||||
@ -307,7 +307,7 @@ void UDPSinkFECWorker::encodeAndTransmit(UDPSinkFEC::SuperBlock *txBlockx, uint1
|
|||||||
|
|
||||||
// Transmit all blocks
|
// Transmit all blocks
|
||||||
|
|
||||||
qDebug("UDPSinkFECWorker::encodeAndTransmit: transmit frame with FEC to %s:%d", m_remoteAddress.toStdString().c_str(), m_remotePort);
|
// qDebug("UDPSinkFECWorker::encodeAndTransmit: transmit frame with FEC to %s:%d", m_remoteAddress.toStdString().c_str(), m_remotePort);
|
||||||
|
|
||||||
for (int i = 0; i < cm256Params.OriginalCount + cm256Params.RecoveryCount; i++)
|
for (int i = 0; i < cm256Params.OriginalCount + cm256Params.RecoveryCount; i++)
|
||||||
{
|
{
|
||||||
|
Loading…
Reference in New Issue
Block a user