Up/Down channelizers: use input message queue for all message forwarding to sample source/sinks and do not forward unknown messages

This commit is contained in:
f4exb 2017-12-29 05:48:54 +01:00
parent cf79a7bb56
commit 906d04dd41
2 changed files with 22 additions and 18 deletions

View File

@ -123,7 +123,8 @@ bool DownChannelizer::handleMessage(const Message& cmd)
if (m_sampleSink != 0) if (m_sampleSink != 0)
{ {
m_sampleSink->handleMessage(notif); DSPSignalNotification* rep = new DSPSignalNotification(notif); // make a copy
m_sampleSink->getInputMessageQueue()->push(rep);
} }
emit inputSampleRateChanged(); emit inputSampleRateChanged();
@ -145,14 +146,15 @@ bool DownChannelizer::handleMessage(const Message& cmd)
} }
else else
{ {
if (m_sampleSink != 0) return false;
{ // if (m_sampleSink != 0)
return m_sampleSink->handleMessage(cmd); // {
} // return m_sampleSink->handleMessage(cmd);
else // }
{ // else
return false; // {
} // return false;
// }
} }
} }

View File

@ -135,7 +135,8 @@ bool UpChannelizer::handleMessage(const Message& cmd)
if (m_sampleSource != 0) if (m_sampleSource != 0)
{ {
m_sampleSource->handleMessage(notif); DSPSignalNotification* rep = new DSPSignalNotification(notif); // make a copy
m_sampleSource->getInputMessageQueue()->push(rep);
} }
emit outputSampleRateChanged(); emit outputSampleRateChanged();
@ -157,14 +158,15 @@ bool UpChannelizer::handleMessage(const Message& cmd)
} }
else else
{ {
if (m_sampleSource != 0) return false;
{ // if (m_sampleSource != 0)
return m_sampleSource->handleMessage(cmd); // {
} // return m_sampleSource->handleMessage(cmd);
else // }
{ // else
return false; // {
} // return false;
// }
} }
} }