VE7UWU/sdrangel
1
0
Fork 0
mirror of https://github.com/f4exb/sdrangel.git synced 2026-06-01 21:54:55 -04:00
Code Issues Projects Releases Wiki Activity

Deep redesign: Init sequence review phase #5: fixed source message forwarding for BladeRF only

Browse Source
This commit is contained in:
f4exb
2015-08-19 09:24:44 +02:00
parent 1fdeaa62c3
commit 23c956cf17
3 changed files with 46 additions and 31 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sdrbase/dsp/dspengine.cpp
+8 -8
View File
@@ -403,9 +403,9 @@ DSPEngine::State DSPEngine::gotoInit()
(*it)->sendWaitSink(notif);
}
// pass sample rate to main window
// pass data to listeners
DSPEngineReport* rep = new DSPEngineReport(m_sampleRate, m_centerFrequency);
DSPSignalNotification* rep = new DSPSignalNotification(notif); // make a copy for the output queue
m_outputMessageQueue.push(rep);
return StReady;
@@ -653,25 +653,25 @@ void DSPEngine::handleSourceMessages()
m_sampleRate = notif->getSampleRate();
m_centerFrequency = notif->getFrequencyOffset();
qDebug() << " - DSPSignalNotification(" << m_sampleRate << "," << m_centerFrequency << ")";
qDebug() << "DSPEngine::handleSourceMessages: DSPSignalNotification(" << m_sampleRate << "," << m_centerFrequency << ")";
// forward source changes to sinks
// forward source changes to sinks with immediate execution
for(SampleSinks::const_iterator it = m_sampleSinks.begin(); it != m_sampleSinks.end(); it++)
{
qDebug() << " - forward message to " << (*it)->objectName().toStdString().c_str();
qDebug() << "DSPEngine::handleSourceMessages: forward message to " << (*it)->objectName().toStdString().c_str();
(*it)->handleMessage(*message);
}
for (ThreadedSampleSinks::const_iterator it = m_threadedSampleSinks.begin(); it != m_threadedSampleSinks.end(); ++it)
{
qDebug() << " - forward message to ThreadedSampleSink(" << (*it)->getSampleSinkObjectName().toStdString().c_str() << ")";
qDebug() << "DSPEngine::handleSourceMessages: forward message to ThreadedSampleSink(" << (*it)->getSampleSinkObjectName().toStdString().c_str() << ")";
(*it)->sendWaitSink(*message);
}
// forward changes to listeners
// forward changes to listeners on DSP output queue
DSPEngineReport* rep = new DSPEngineReport(m_sampleRate, m_centerFrequency);
DSPSignalNotification* rep = new DSPSignalNotification(*notif); // make a copy for the output queue
m_outputMessageQueue.push(rep);
}