VE7UWU/sdrangel
1
0
Fork 0
mirror of https://github.com/f4exb/sdrangel.git synced 2024-10-01 01:06:35 -04:00
Code Issues Projects Releases Wiki Activity

AFC: more debug messages

Browse Source
This commit is contained in:
f4exb 2022-02-27 19:26:18 +01:00
parent 16547b2468
commit c90d04e4b6
1 changed files with 35 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
plugins/feature/afc/afc.cpp
View File

@ -637,7 +637,11 @@ void AFC::trackerDeviceChange(int deviceIndex)
if (channel->getURI() == "sdrangel.channel.freqtracker") if (channel->getURI() == "sdrangel.channel.freqtracker")
{ {
MessageQueue *messageQueue = mainCore->getMessagePipes().registerChannelToFeature(channel, this, "settings"); ObjectPipe *pipe = mainCore->getMessagePipes2().registerProducerToConsumer(channel, this, "settings");
MessageQueue *messageQueue = qobject_cast<MessageQueue*>(pipe->m_element);
if (messageQueue)
{
QObject::connect( QObject::connect(
messageQueue, messageQueue,
&MessageQueue::messageEnqueued, &MessageQueue::messageEnqueued,
@ -645,6 +649,8 @@ void AFC::trackerDeviceChange(int deviceIndex)
[=](){ this->handleChannelMessageQueue(messageQueue); }, [=](){ this->handleChannelMessageQueue(messageQueue); },
Qt::QueuedConnection Qt::QueuedConnection
); );
}
m_trackerChannelAPI = channel; m_trackerChannelAPI = channel;
break; break;
} }
@ -668,7 +674,11 @@ void AFC::trackedDeviceChange(int deviceIndex)
if (channel->getURI() != "sdrangel.channel.freqtracker") if (channel->getURI() != "sdrangel.channel.freqtracker")
{ {
MessageQueue *messageQueue = mainCore->getMessagePipes().registerChannelToFeature(channel, this, "settings"); ObjectPipe *pipe = mainCore->getMessagePipes2().registerProducerToConsumer(channel, this, "settings");
MessageQueue *messageQueue = qobject_cast<MessageQueue*>(pipe->m_element);
if (messageQueue)
{
QObject::connect( QObject::connect(
messageQueue, messageQueue,
&MessageQueue::messageEnqueued, &MessageQueue::messageEnqueued,
@ -680,6 +690,7 @@ void AFC::trackedDeviceChange(int deviceIndex)
} }
} }
} }
}
void AFC::removeTrackerFeatureReference() void AFC::removeTrackerFeatureReference()
{ {
@ -688,12 +699,15 @@ void AFC::removeTrackerFeatureReference()
if (MainCore::instance()->existsChannel(m_trackerChannelAPI)) if (MainCore::instance()->existsChannel(m_trackerChannelAPI))
{ {
qDebug("AFC::removeTrackerFeatureReference: m_trackerChannelAPI: %s", qPrintable(m_trackerChannelAPI->objectName())); qDebug("AFC::removeTrackerFeatureReference: m_trackerChannelAPI: %s", qPrintable(m_trackerChannelAPI->objectName()));
MessageQueue *messageQueue ObjectPipe *pipe = MainCore::instance()->getMessagePipes2().unregisterProducerToConsumer(m_trackerChannelAPI, this, "settings");
= MainCore::instance()->getMessagePipes().unregisterChannelToFeature(m_trackerChannelAPI, this, "settings"); MessageQueue *messageQueue = qobject_cast<MessageQueue*>(pipe->m_element);
if (messageQueue) {
disconnect(messageQueue, SIGNAL(messageEnqueued()), this, SLOT(handleChannelMessageQueue(MessageQueue*))); disconnect(messageQueue, SIGNAL(messageEnqueued()), this, SLOT(handleChannelMessageQueue(MessageQueue*)));
} }
} }
} }
}
void AFC::removeTrackedFeatureReferences() void AFC::removeTrackedFeatureReferences()
{ {
@ -704,7 +718,7 @@ void AFC::removeTrackedFeatureReferences()
if (MainCore::instance()->existsChannel(channel)) if (MainCore::instance()->existsChannel(channel))
{ {
qDebug("AFC::removeTrackedFeatureReferences: channel: %s", qPrintable(channel->objectName())); qDebug("AFC::removeTrackedFeatureReferences: channel: %s", qPrintable(channel->objectName()));
MainCore::instance()->getMessagePipes().unregisterChannelToFeature(channel, this, "settings"); MainCore::instance()->getMessagePipes2().unregisterProducerToConsumer(channel, this, "settings");
} }
} }