Deep redesign: fixed message dequeing so that non processed messages stay in queue

sdrbase/dsp/dspengine.cpp

@@ -608,13 +608,13 @@ void DSPEngine::handleSynchronousMessages()
 
 void DSPEngine::handleInputMessages()
 {
-	qDebug() << "DSPEngine::handleInputMessages";
-
 	Message* message;
+	int queueSize =  m_inputMessageQueue.size();
 
-	while ((message = m_inputMessageQueue.pop()) != 0)
+	for (int i = 0; i < queueSize; i++)
 	{
-		qDebug("DSPEngine::handleInputMessages: message: %s", message->getIdentifier());
+		message = m_inputMessageQueue.pop();
+		qDebug() << "DSPEngine::handleInputMessages: " << message->getIdentifier();
 
 		if (DSPConfigureCorrection::match(*message))
 		{
@@ -636,7 +636,11 @@ void DSPEngine::handleInputMessages()
 				m_imbalance = 65536;
 			}
 
-			delete message;
+			delete message; // delete
+		}
+		else
+		{
+			m_inputMessageQueue.push(message); // repush
 		}
 	}
 }
@@ -644,9 +648,11 @@ void DSPEngine::handleInputMessages()
 void DSPEngine::handleSourceMessages()
 {
 	Message *message;
+	int queueSize =  m_inputMessageQueue.size();
 
-	while ((message = m_sampleSource->getOutputMessageQueue()->pop()) != 0)
+	for (int i = 0; i < queueSize; i++)
 	{
+		message = m_inputMessageQueue.pop();
 		qDebug() << "DSPEngine::handleSourceMessages: " << message->getIdentifier();
 
 		if (DSPSignalNotification::match(*message))
@@ -683,6 +689,10 @@ void DSPEngine::handleSourceMessages()
 
 			delete message;
 		}
+		else
+		{
+			m_inputMessageQueue.push(message);
+		}
 	}
 }
 

sdrbase/dsp/samplesink.cpp

@@ -13,13 +13,20 @@ SampleSink::~SampleSink()
 void SampleSink::handleInputMessages()
 {
 	Message* message;
+	int queueSize = m_inputMessageQueue.size();
 
-	while ((message = m_inputMessageQueue.pop()) != 0)
+	for (int i = 0; i < queueSize; i++)
 	{
+		message = m_inputMessageQueue.pop();
+
 		if (handleMessage(*message))
 		{
 			delete message;
 		}
+		else
+		{
+			m_inputMessageQueue.push(message);
+		}
 	}
 }
 

sdrbase/dsp/samplesource.cpp

@@ -29,12 +29,19 @@ SampleSource::~SampleSource()
 void SampleSource::handleInputMessages()
 {
 	Message* message;
+	int queueSize = m_inputMessageQueue.size();
 
-	while ((message = m_inputMessageQueue.pop()) != 0)
+	for (int i = 0; i < queueSize; i++)
 	{
+		message = m_inputMessageQueue.pop();
+
 		if (handleMessage(*message))
 		{
 			delete message;
 		}
+		else
+		{
+			m_inputMessageQueue.push(message);
+		}
 	}
 }

sdrbase/mainwindow.cpp

@@ -332,12 +332,13 @@ void MainWindow::applySettings()
 void MainWindow::handleDSPMessages()
 {
 	Message* message;
+	MessageQueue* messageQueue = m_dspEngine->getOutputMessageQueue();
+	int queueSize =  messageQueue->size();
 
-	while ((message = m_dspEngine->getOutputMessageQueue()->pop()) != 0)
+	for (int i = 0; i < queueSize; i++)
 	{
-		qDebug("Message: %s", message->getIdentifier());
+		message = messageQueue->pop();
-
+		qDebug() << "MainWindow::handleDSPMessages: " << message->getIdentifier();
-		std::cerr << "MainWindow::handleDSPMessages: " << message->getIdentifier() << std::endl;
 
 		if (DSPSignalNotification::match(*message))
 		{
@@ -352,22 +353,31 @@ void MainWindow::handleDSPMessages()
 
 			delete message;
 		}
+		else
+		{
+			messageQueue->push(message);
+		}
 	}
 }
 
 void MainWindow::handleMessages()
 {
 	Message* message;
+	int queueSize =  m_inputMessageQueue.size();
 
-	while ((message = m_inputMessageQueue.pop()) != 0)
+	for (int i = 0; i < queueSize; i++)
 	{
-		qDebug("Message: %s", message->getIdentifier());
+		message = m_inputMessageQueue.pop();
-		std::cerr << "MainWindow::handleMessages: " << message->getIdentifier() << std::endl;
+		qDebug() << "MainWindow::handleMessages: " << message->getIdentifier();
 
-		if (!m_pluginManager->handleMessage(*message))
+		if (m_pluginManager->handleMessage(*message))
 		{
 			delete message;
 		}
+		else
+		{
+			m_inputMessageQueue.push(message);
+		}
 	}
 }
 

sdrbase/util/messagequeue.cpp

@@ -15,6 +15,7 @@
 // along with this program. If not, see <http://www.gnu.org/licenses/>.          //
 ///////////////////////////////////////////////////////////////////////////////////
 
+#include <QDebug>
 #include "util/messagequeue.h"
 #include "util/message.h"
 
@@ -31,6 +32,7 @@ MessageQueue::~MessageQueue()
 
 	while ((message = pop()) != 0)
 	{
+		qDebug() << "MessageQueue::~MessageQueue: message: " << message->getIdentifier() << " was still in queue";
 		delete message;
 	}
 }