mirror of
				https://github.com/f4exb/sdrangel.git
				synced 2025-10-26 02:20:26 -04:00 
			
		
		
		
	
		
			
				
	
	
		
			886 lines
		
	
	
		
			30 KiB
		
	
	
	
		
			C++
		
	
	
	
	
	
			
		
		
	
	
			886 lines
		
	
	
		
			30 KiB
		
	
	
	
		
			C++
		
	
	
	
	
	
| ///////////////////////////////////////////////////////////////////////////////////
 | |
| // Copyright (C) 2018 Edouard Griffiths, F4EXB                                   //
 | |
| //                                                                               //
 | |
| // This program is free software; you can redistribute it and/or modify          //
 | |
| // it under the terms of the GNU General Public License as published by          //
 | |
| // the Free Software Foundation as version 3 of the License, or                  //
 | |
| // (at your option) any later version.                                           //
 | |
| //                                                                               //
 | |
| // This program is distributed in the hope that it will be useful,               //
 | |
| // but WITHOUT ANY WARRANTY; without even the implied warranty of                //
 | |
| // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the                  //
 | |
| // GNU General Public License V3 for more details.                               //
 | |
| //                                                                               //
 | |
| // You should have received a copy of the GNU General Public License             //
 | |
| // along with this program. If not, see <http://www.gnu.org/licenses/>.          //
 | |
| ///////////////////////////////////////////////////////////////////////////////////
 | |
| 
 | |
| #include <QMessageBox>
 | |
| #include <QCheckBox>
 | |
| 
 | |
| #include "dsp/dspengine.h"
 | |
| #include "dsp/dspcommands.h"
 | |
| #include "device/deviceapi.h"
 | |
| #include "device/deviceuiset.h"
 | |
| #include "util/simpleserializer.h"
 | |
| #include "ui_soapysdroutputgui.h"
 | |
| #include "gui/glspectrum.h"
 | |
| #include "gui/crightclickenabler.h"
 | |
| #include "gui/basicdevicesettingsdialog.h"
 | |
| #include "soapygui/discreterangegui.h"
 | |
| #include "soapygui/intervalrangegui.h"
 | |
| #include "soapygui/stringrangegui.h"
 | |
| #include "soapygui/dynamicitemsettinggui.h"
 | |
| #include "soapygui/intervalslidergui.h"
 | |
| #include "soapygui/complexfactorgui.h"
 | |
| #include "soapygui/arginfogui.h"
 | |
| #include "soapygui/dynamicargsettinggui.h"
 | |
| 
 | |
| #include "soapysdroutputgui.h"
 | |
| 
 | |
| SoapySDROutputGui::SoapySDROutputGui(DeviceUISet *deviceUISet, QWidget* parent) :
 | |
|     DeviceGUI(parent),
 | |
|     ui(new Ui::SoapySDROutputGui),
 | |
|     m_deviceUISet(deviceUISet),
 | |
|     m_forceSettings(true),
 | |
|     m_doApplySettings(true),
 | |
|     m_sampleSink(0),
 | |
|     m_sampleRate(0),
 | |
|     m_lastEngineState(DeviceAPI::StNotStarted),
 | |
|     m_antennas(0),
 | |
|     m_sampleRateGUI(0),
 | |
|     m_bandwidthGUI(0),
 | |
|     m_gainSliderGUI(0),
 | |
|     m_autoGain(0),
 | |
|     m_dcCorrectionGUI(0),
 | |
|     m_iqCorrectionGUI(0),
 | |
|     m_autoDCCorrection(0),
 | |
|     m_autoIQCorrection(0)
 | |
| {
 | |
|     m_sampleSink = (SoapySDROutput*) m_deviceUISet->m_deviceAPI->getSampleSink();
 | |
|     ui->setupUi(this);
 | |
| 
 | |
|     ui->centerFrequency->setColorMapper(ColorMapper(ColorMapper::GrayGold));
 | |
|     uint64_t f_min, f_max;
 | |
|     m_sampleSink->getFrequencyRange(f_min, f_max);
 | |
|     ui->centerFrequency->setValueRange(7, f_min/1000, f_max/1000);
 | |
| 
 | |
|     createCorrectionsControl();
 | |
|     createAntennasControl(m_sampleSink->getAntennas());
 | |
|     createRangesControl(&m_sampleRateGUI, m_sampleSink->getRateRanges(), "SR", "S/s");
 | |
|     createRangesControl(&m_bandwidthGUI, m_sampleSink->getBandwidthRanges(), "BW", "Hz");
 | |
|     createTunableElementsControl(m_sampleSink->getTunableElements());
 | |
|     createGlobalGainControl();
 | |
|     createIndividualGainsControl(m_sampleSink->getIndividualGainsRanges());
 | |
|     createArgumentsControl(m_sampleSink->getDeviceArgInfoList(), true);
 | |
|     createArgumentsControl(m_sampleSink->getStreamArgInfoList(), false);
 | |
|     m_sampleSink->initGainSettings(m_settings);
 | |
|     m_sampleSink->initTunableElementsSettings(m_settings);
 | |
|     m_sampleSink->initStreamArgSettings(m_settings);
 | |
|     m_sampleSink->initDeviceArgSettings(m_settings);
 | |
| 
 | |
|     if (m_sampleRateGUI) {
 | |
|         connect(m_sampleRateGUI, SIGNAL(valueChanged(double)), this, SLOT(sampleRateChanged(double)));
 | |
|     }
 | |
|     if (m_bandwidthGUI) {
 | |
|         connect(m_bandwidthGUI, SIGNAL(valueChanged(double)), this, SLOT(bandwidthChanged(double)));
 | |
|     }
 | |
| 
 | |
|     connect(&m_updateTimer, SIGNAL(timeout()), this, SLOT(updateHardware()));
 | |
|     connect(&m_statusTimer, SIGNAL(timeout()), this, SLOT(updateStatus()));
 | |
|     m_statusTimer.start(500);
 | |
| 
 | |
|     CRightClickEnabler *startStopRightClickEnabler = new CRightClickEnabler(ui->startStop);
 | |
|     connect(startStopRightClickEnabler, SIGNAL(rightClick(const QPoint &)), this, SLOT(openDeviceSettingsDialog(const QPoint &)));
 | |
| 
 | |
|     displaySettings();
 | |
| 
 | |
|     connect(&m_inputMessageQueue, SIGNAL(messageEnqueued()), this, SLOT(handleInputMessages()), Qt::QueuedConnection);
 | |
|     m_sampleSink->setMessageQueueToGUI(&m_inputMessageQueue);
 | |
| 
 | |
|     sendSettings();
 | |
| }
 | |
| 
 | |
| SoapySDROutputGui::~SoapySDROutputGui()
 | |
| {
 | |
|     delete ui;
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::destroy()
 | |
| {
 | |
|     delete this;
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::createRangesControl(
 | |
|         ItemSettingGUI **settingGUI,
 | |
|         const SoapySDR::RangeList& rangeList,
 | |
|         const QString& text,
 | |
|         const QString& unit)
 | |
| {
 | |
|     if (rangeList.size() == 0) { // return early if the range list is empty
 | |
|         return;
 | |
|     }
 | |
| 
 | |
|     bool rangeDiscrete = true; // discretes values
 | |
|     bool rangeInterval = true; // intervals
 | |
| 
 | |
|     for (const auto &it : rangeList)
 | |
|     {
 | |
|         if (it.minimum() != it.maximum()) {
 | |
|             rangeDiscrete = false;
 | |
|         } else {
 | |
|             rangeInterval = false;
 | |
|         }
 | |
|     }
 | |
| 
 | |
|     if (rangeDiscrete)
 | |
|     {
 | |
|         DiscreteRangeGUI *rangeGUI = new DiscreteRangeGUI(this);
 | |
|         rangeGUI->setLabel(text);
 | |
|         rangeGUI->setUnits(QString("k%1").arg(unit));
 | |
| 
 | |
|         for (const auto &it : rangeList) {
 | |
|             rangeGUI->addItem(QString("%1").arg(QString::number(it.minimum()/1000.0, 'f', 0)), it.minimum());
 | |
|         }
 | |
| 
 | |
|         *settingGUI = rangeGUI;
 | |
|         QVBoxLayout *layout = (QVBoxLayout *) ui->scrollAreaWidgetContents->layout();
 | |
|         layout->addWidget(rangeGUI);
 | |
|     }
 | |
|     else if (rangeInterval)
 | |
|     {
 | |
|         IntervalRangeGUI *rangeGUI = new IntervalRangeGUI(this);
 | |
|         rangeGUI->setLabel(text);
 | |
|         rangeGUI->setUnits(unit);
 | |
| 
 | |
|         for (const auto &it : rangeList) {
 | |
|             rangeGUI->addInterval(it.minimum(), it.maximum());
 | |
|         }
 | |
| 
 | |
|         rangeGUI->reset();
 | |
| 
 | |
|         *settingGUI = rangeGUI;
 | |
|         QVBoxLayout *layout = (QVBoxLayout *) ui->scrollAreaWidgetContents->layout();
 | |
|         layout->addWidget(rangeGUI);
 | |
|     }
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::createAntennasControl(const std::vector<std::string>& antennaList)
 | |
| {
 | |
|     if (antennaList.size() == 0) { // return early if the antenna list is empty
 | |
|         return;
 | |
|     }
 | |
| 
 | |
|     m_antennas = new StringRangeGUI(this);
 | |
|     m_antennas->setLabel(QString("RF out"));
 | |
|     m_antennas->setUnits(QString("Port"));
 | |
| 
 | |
|     for (const auto &it : antennaList) {
 | |
|         m_antennas->addItem(QString(it.c_str()), it);
 | |
|     }
 | |
| 
 | |
|     QVBoxLayout *layout = (QVBoxLayout *) ui->scrollAreaWidgetContents->layout();
 | |
|     layout->addWidget(m_antennas);
 | |
| 
 | |
|     connect(m_antennas, SIGNAL(valueChanged()), this, SLOT(antennasChanged()));
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::createTunableElementsControl(const std::vector<DeviceSoapySDRParams::FrequencySetting>& tunableElementsList)
 | |
| {
 | |
|     if (tunableElementsList.size() <= 1) { // This list is created for other elements than the main one (RF) which is always at index 0
 | |
|         return;
 | |
|     }
 | |
| 
 | |
|     std::vector<DeviceSoapySDRParams::FrequencySetting>::const_iterator it = tunableElementsList.begin() + 1;
 | |
| 
 | |
|     for (int i = 0; it != tunableElementsList.end(); ++it, i++)
 | |
|     {
 | |
|         if (it->m_ranges.size() == 0) { // skip empty ranges lists
 | |
|             continue;
 | |
|         }
 | |
| 
 | |
|         ItemSettingGUI *rangeGUI;
 | |
|         createRangesControl(
 | |
|                 &rangeGUI,
 | |
|                 it->m_ranges,
 | |
|                 QString("%1 freq").arg(it->m_name.c_str()),
 | |
|                 QString((it->m_name == "CORR") ? "ppm" : "Hz"));
 | |
|         DynamicItemSettingGUI *gui = new DynamicItemSettingGUI(rangeGUI, QString(it->m_name.c_str()));
 | |
|         m_tunableElementsGUIs.push_back(gui);
 | |
|         connect(m_tunableElementsGUIs.back(), SIGNAL(valueChanged(QString, double)), this, SLOT(tunableElementChanged(QString, double)));
 | |
|     }
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::createGlobalGainControl()
 | |
| {
 | |
|     m_gainSliderGUI = new IntervalSliderGUI(this);
 | |
|     int min, max;
 | |
|     m_sampleSink->getGlobalGainRange(min, max);
 | |
|     m_gainSliderGUI->setInterval(min, max);
 | |
|     m_gainSliderGUI->setLabel(QString("Global gain"));
 | |
|     m_gainSliderGUI->setUnits(QString(""));
 | |
| 
 | |
|     QVBoxLayout *layout = (QVBoxLayout *) ui->scrollAreaWidgetContents->layout();
 | |
| 
 | |
|     QFrame *line = new QFrame(this);
 | |
|     line->setFrameShape(QFrame::HLine);
 | |
|     line->setFrameShadow(QFrame::Sunken);
 | |
|     layout->addWidget(line);
 | |
| 
 | |
|     if (m_sampleSink->isAGCSupported())
 | |
|     {
 | |
|         m_autoGain = new QCheckBox(this);
 | |
|         m_autoGain->setText(QString("AGC"));
 | |
|         m_autoGain->setStyleSheet("QCheckBox::indicator::unchecked {background: rgb(79,79,79);} QCheckBox::indicator::checked {background: rgb(255, 157, 38);}");
 | |
|         layout->addWidget(m_autoGain);
 | |
| 
 | |
|         connect(m_autoGain, SIGNAL(toggled(bool)), this, SLOT(autoGainChanged(bool)));
 | |
|     }
 | |
| 
 | |
|     layout->addWidget(m_gainSliderGUI);
 | |
| 
 | |
|     connect(m_gainSliderGUI, SIGNAL(valueChanged(double)), this, SLOT(globalGainChanged(double)));
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::createIndividualGainsControl(const std::vector<DeviceSoapySDRParams::GainSetting>& individualGainsList)
 | |
| {
 | |
|     if (individualGainsList.size() == 0) { // Leave early if list of individual gains is empty
 | |
|         return;
 | |
|     }
 | |
| 
 | |
|     QVBoxLayout *layout = (QVBoxLayout *) ui->scrollAreaWidgetContents->layout();
 | |
|     std::vector<DeviceSoapySDRParams::GainSetting>::const_iterator it = individualGainsList.begin();
 | |
| 
 | |
|     for (int i = 0; it != individualGainsList.end(); ++it, i++)
 | |
|     {
 | |
|         IntervalSliderGUI *gainGUI = new IntervalSliderGUI(this);
 | |
|         gainGUI->setInterval(it->m_range.minimum(), it->m_range.maximum());
 | |
|         gainGUI->setLabel(QString("%1 gain").arg(it->m_name.c_str()));
 | |
|         gainGUI->setUnits(QString(""));
 | |
|         DynamicItemSettingGUI *gui = new DynamicItemSettingGUI(gainGUI, QString(it->m_name.c_str()));
 | |
|         layout->addWidget(gainGUI);
 | |
|         m_individualGainsGUIs.push_back(gui);
 | |
|         connect(m_individualGainsGUIs.back(), SIGNAL(valueChanged(QString, double)), this, SLOT(individualGainChanged(QString, double)));
 | |
|     }
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::createCorrectionsControl()
 | |
| {
 | |
|     QVBoxLayout *layout = (QVBoxLayout *) ui->scrollAreaWidgetContents->layout();
 | |
| 
 | |
|     if (m_sampleSink->hasDCCorrectionValue()) // complex GUI
 | |
|     {
 | |
|         m_dcCorrectionGUI = new ComplexFactorGUI(this);
 | |
|         m_dcCorrectionGUI->setLabel(QString("DC"));
 | |
|         m_dcCorrectionGUI->setAutomaticEnable(m_sampleSink->hasDCAutoCorrection());
 | |
|         layout->addWidget(m_dcCorrectionGUI);
 | |
| 
 | |
|         connect(m_dcCorrectionGUI, SIGNAL(moduleChanged(double)), this, SLOT(dcCorrectionModuleChanged(double)));
 | |
|         connect(m_dcCorrectionGUI, SIGNAL(argumentChanged(double)), this, SLOT(dcCorrectionArgumentChanged(double)));
 | |
| 
 | |
|         if (m_sampleSink->hasDCAutoCorrection()) {
 | |
|             connect(m_dcCorrectionGUI, SIGNAL(automaticChanged(bool)), this, SLOT(autoDCCorrectionChanged(bool)));
 | |
|         }
 | |
|     }
 | |
|     else if (m_sampleSink->hasDCAutoCorrection()) // simple checkbox
 | |
|     {
 | |
|         m_autoDCCorrection = new QCheckBox(this);
 | |
|         m_autoDCCorrection->setText(QString("Auto DC corr"));
 | |
|         m_autoDCCorrection->setToolTip(QString("Automatic hardware DC offset correction"));
 | |
|         m_autoDCCorrection->setStyleSheet("QCheckBox::indicator::unchecked {background: rgb(79,79,79);} QCheckBox::indicator::checked {background: rgb(255, 157, 38);}");
 | |
|         layout->addWidget(m_autoDCCorrection);
 | |
| 
 | |
|         connect(m_autoDCCorrection, SIGNAL(toggled(bool)), this, SLOT(autoDCCorrectionChanged(bool)));
 | |
|     }
 | |
| 
 | |
|     if (m_sampleSink->hasIQCorrectionValue()) // complex GUI
 | |
|     {
 | |
|         m_iqCorrectionGUI = new ComplexFactorGUI(this);
 | |
|         m_iqCorrectionGUI->setLabel(QString("IQ"));
 | |
|         m_iqCorrectionGUI->setAutomaticEnable(m_sampleSink->hasIQAutoCorrection());
 | |
|         layout->addWidget(m_iqCorrectionGUI);
 | |
| 
 | |
|         connect(m_iqCorrectionGUI, SIGNAL(moduleChanged(double)), this, SLOT(iqCorrectionModuleChanged(double)));
 | |
|         connect(m_iqCorrectionGUI, SIGNAL(argumentChanged(double)), this, SLOT(iqCorrectionArgumentChanged(double)));
 | |
| 
 | |
|         if (m_sampleSink->hasIQAutoCorrection()) {
 | |
|             connect(m_iqCorrectionGUI, SIGNAL(automaticChanged(bool)), this, SLOT(autoIQCorrectionChanged(bool)));
 | |
|         }
 | |
|     }
 | |
|     else if (m_sampleSink->hasIQAutoCorrection()) // simple checkbox
 | |
|     {
 | |
|         m_autoIQCorrection = new QCheckBox(this);
 | |
|         m_autoIQCorrection->setText(QString("Auto IQ corr"));
 | |
|         m_autoIQCorrection->setToolTip(QString("Automatic hardware IQ imbalance correction"));
 | |
|         m_autoIQCorrection->setStyleSheet("QCheckBox::indicator::unchecked {background: rgb(79,79,79);} QCheckBox::indicator::checked {background: rgb(255, 157, 38);}");
 | |
|         layout->addWidget(m_autoIQCorrection);
 | |
| 
 | |
|         connect(m_autoIQCorrection, SIGNAL(toggled(bool)), this, SLOT(autoIQCorrectionChanged(bool)));
 | |
|     }
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::createArgumentsControl(const SoapySDR::ArgInfoList& argInfoList, bool deviceArguments)
 | |
| {
 | |
|     if (argInfoList.size() == 0) { // return early if list is empty
 | |
|         return;
 | |
|     }
 | |
| 
 | |
|     QVBoxLayout *layout = (QVBoxLayout *) ui->scrollAreaWidgetContents->layout();
 | |
| 
 | |
|     QFrame *line = new QFrame(this);
 | |
|     line->setFrameShape(QFrame::HLine);
 | |
|     line->setFrameShadow(QFrame::Sunken);
 | |
|     layout->addWidget(line);
 | |
| 
 | |
|     std::vector<SoapySDR::ArgInfo>::const_iterator it = argInfoList.begin();
 | |
| 
 | |
|     for (; it != argInfoList.end(); ++it)
 | |
|     {
 | |
|         ArgInfoGUI::ArgInfoValueType valueType;
 | |
|         ArgInfoGUI *argGUI;
 | |
| 
 | |
|         if (it->type == SoapySDR::ArgInfo::BOOL) {
 | |
|             valueType = ArgInfoGUI::ArgInfoValueBool;
 | |
|         } else if (it->type == SoapySDR::ArgInfo::INT) {
 | |
|             valueType = ArgInfoGUI::ArgInfoValueInt;
 | |
|         } else if (it->type == SoapySDR::ArgInfo::FLOAT) {
 | |
|             valueType = ArgInfoGUI::ArgInfoValueFloat;
 | |
|         } else if (it->type == SoapySDR::ArgInfo::STRING) {
 | |
|             valueType = ArgInfoGUI::ArgInfoValueString;
 | |
|         } else {
 | |
|             continue;
 | |
|         }
 | |
| 
 | |
|         if (valueType == ArgInfoGUI::ArgInfoValueBool)
 | |
|         {
 | |
|             argGUI = new ArgInfoGUI(ArgInfoGUI::ArgInfoBinary, ArgInfoGUI::ArgInfoValueBool, this);
 | |
|         }
 | |
|         else if (it->options.size() == 0)
 | |
|         {
 | |
|             argGUI = new ArgInfoGUI(ArgInfoGUI::ArgInfoContinuous, valueType, this);
 | |
|         }
 | |
|         else
 | |
|         {
 | |
|             argGUI = new ArgInfoGUI(ArgInfoGUI::ArgInfoDiscrete, valueType, this);
 | |
|             std::vector<std::string>::const_iterator optionIt = it->options.begin();
 | |
|             std::vector<std::string>::const_iterator optionNameIt = it->optionNames.begin();
 | |
| 
 | |
|             for (int i = 0; optionIt != it->options.end(); ++optionIt, i++)
 | |
|             {
 | |
|                 QString name(optionNameIt == it->optionNames.end() ? optionIt->c_str() : optionNameIt->c_str());
 | |
| 
 | |
|                 if (optionNameIt != it->optionNames.end()) {
 | |
|                     ++optionNameIt;
 | |
|                 }
 | |
| 
 | |
|                 if (valueType == ArgInfoGUI::ArgInfoValueInt) {
 | |
|                     argGUI->addIntValue(name, atoi(optionIt->c_str()));
 | |
|                 } else if (valueType == ArgInfoGUI::ArgInfoValueFloat) {
 | |
|                     argGUI->addFloatValue(name, atof(optionIt->c_str()));
 | |
|                 } else if (valueType == ArgInfoGUI::ArgInfoValueString) {
 | |
|                     argGUI->addStringValue(name, QString(optionIt->c_str()));
 | |
|                 }
 | |
|             }
 | |
|         }
 | |
| 
 | |
|         if ((it->range.minimum() != 0) || (it->range.maximum() != 0)) {
 | |
|             argGUI->setRange(it->range.minimum(), it->range.maximum());
 | |
|         }
 | |
| 
 | |
|         argGUI->setLabel(QString(it->name.size() == 0 ? it->key.c_str() : it->name.c_str()));
 | |
|         argGUI->setUnits(QString(it->units.c_str()));
 | |
| 
 | |
|         if (it->description.size() != 0) {
 | |
|             argGUI->setToolTip(QString(it->description.c_str()));
 | |
|         }
 | |
| 
 | |
|         layout->addWidget(argGUI);
 | |
| 
 | |
|         DynamicArgSettingGUI *gui = new DynamicArgSettingGUI(argGUI, QString(it->key.c_str()));
 | |
| 
 | |
|         // This could be made more elegant but let's make it more simple
 | |
|         if (deviceArguments)
 | |
|         {
 | |
|             m_deviceArgsGUIs.push_back(gui);
 | |
|             connect(gui, SIGNAL(valueChanged(QString, QVariant)), this, SLOT(deviceArgChanged(QString, QVariant)));
 | |
|         }
 | |
|         else
 | |
|         {
 | |
|             m_streamArgsGUIs.push_back(gui);
 | |
|             connect(gui, SIGNAL(valueChanged(QString, QVariant)), this, SLOT(streamArgChanged(QString, QVariant)));
 | |
|         }
 | |
|     }
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::resetToDefaults()
 | |
| {
 | |
|     m_settings.resetToDefaults();
 | |
|     displaySettings();
 | |
|     sendSettings();
 | |
| }
 | |
| 
 | |
| QByteArray SoapySDROutputGui::serialize() const
 | |
| {
 | |
|     return m_settings.serialize();
 | |
| }
 | |
| 
 | |
| bool SoapySDROutputGui::deserialize(const QByteArray& data)
 | |
| {
 | |
|     if(m_settings.deserialize(data))
 | |
|     {
 | |
|         displaySettings();
 | |
|         m_forceSettings = true;
 | |
|         sendSettings();
 | |
|         return true;
 | |
|     }
 | |
|     else
 | |
|     {
 | |
|         resetToDefaults();
 | |
|         return false;
 | |
|     }
 | |
| }
 | |
| 
 | |
| 
 | |
| bool SoapySDROutputGui::handleMessage(const Message& message)
 | |
| {
 | |
|     if (SoapySDROutput::MsgConfigureSoapySDROutput::match(message))
 | |
|     {
 | |
|         const SoapySDROutput::MsgConfigureSoapySDROutput& cfg = (SoapySDROutput::MsgConfigureSoapySDROutput&) message;
 | |
|         m_settings = cfg.getSettings();
 | |
|         blockApplySettings(true);
 | |
|         displaySettings();
 | |
|         blockApplySettings(false);
 | |
| 
 | |
|         return true;
 | |
|     }
 | |
|     else if (SoapySDROutput::MsgReportGainChange::match(message))
 | |
|     {
 | |
|         const SoapySDROutput::MsgReportGainChange& report = (SoapySDROutput::MsgReportGainChange&) message;
 | |
|         const SoapySDROutputSettings& gainSettings = report.getSettings();
 | |
| 
 | |
|         if (report.getGlobalGain()) {
 | |
|             m_settings.m_globalGain = gainSettings.m_globalGain;
 | |
|         }
 | |
|         if (report.getIndividualGains()) {
 | |
|             m_settings.m_individualGains = gainSettings.m_individualGains;
 | |
|         }
 | |
| 
 | |
|         blockApplySettings(true);
 | |
|         displaySettings();
 | |
|         blockApplySettings(false);
 | |
| 
 | |
|         return true;
 | |
|     }
 | |
|     else if (DeviceSoapySDRShared::MsgReportDeviceArgsChange::match(message))
 | |
|     {
 | |
|         DeviceSoapySDRShared::MsgReportDeviceArgsChange& notif = (DeviceSoapySDRShared::MsgReportDeviceArgsChange&) message;
 | |
|         m_settings.m_deviceArgSettings = notif.getDeviceArgSettings();
 | |
|         displayDeviceArgsSettings();
 | |
| 
 | |
|         return true;
 | |
|     }
 | |
|     else if (SoapySDROutput::MsgStartStop::match(message))
 | |
|     {
 | |
|         SoapySDROutput::MsgStartStop& notif = (SoapySDROutput::MsgStartStop&) message;
 | |
|         blockApplySettings(true);
 | |
|         ui->startStop->setChecked(notif.getStartStop());
 | |
|         blockApplySettings(false);
 | |
| 
 | |
|         return true;
 | |
|     }
 | |
|     else
 | |
|     {
 | |
|         return false;
 | |
|     }
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::handleInputMessages()
 | |
| {
 | |
|     Message* message;
 | |
| 
 | |
|     while ((message = m_inputMessageQueue.pop()) != 0)
 | |
|     {
 | |
|         qDebug("SoapySDROutputGui::handleInputMessages: message: %s", message->getIdentifier());
 | |
| 
 | |
|         if (DSPSignalNotification::match(*message))
 | |
|         {
 | |
|             DSPSignalNotification* notif = (DSPSignalNotification*) message;
 | |
|             m_sampleRate = notif->getSampleRate();
 | |
|             m_deviceCenterFrequency = notif->getCenterFrequency();
 | |
|             qDebug("SoapySDROutputGui::handleInputMessages: DSPSignalNotification: SampleRate:%d, CenterFrequency:%llu", notif->getSampleRate(), notif->getCenterFrequency());
 | |
|             updateSampleRateAndFrequency();
 | |
| 
 | |
|             delete message;
 | |
|         }
 | |
|         else
 | |
|         {
 | |
|             if (handleMessage(*message))
 | |
|             {
 | |
|                 delete message;
 | |
|             }
 | |
|         }
 | |
|     }
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::sampleRateChanged(double sampleRate)
 | |
| {
 | |
|     m_settings.m_devSampleRate = round(sampleRate);
 | |
|     sendSettings();
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::antennasChanged()
 | |
| {
 | |
|     const std::string& antennaStr = m_antennas->getCurrentValue();
 | |
|     m_settings.m_antenna = QString(antennaStr.c_str());
 | |
|     sendSettings();
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::bandwidthChanged(double bandwidth)
 | |
| {
 | |
|     m_settings.m_bandwidth = round(bandwidth);
 | |
|     sendSettings();
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::tunableElementChanged(QString name, double value)
 | |
| {
 | |
|     m_settings.m_tunableElements[name] = value;
 | |
|     sendSettings();
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::globalGainChanged(double gain)
 | |
| {
 | |
|     m_settings.m_globalGain = round(gain);
 | |
|     sendSettings();
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::autoGainChanged(bool set)
 | |
| {
 | |
|     m_settings.m_autoGain = set;
 | |
|     sendSettings();
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::individualGainChanged(QString name, double value)
 | |
| {
 | |
|     m_settings.m_individualGains[name] = value;
 | |
|     sendSettings();
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::autoDCCorrectionChanged(bool set)
 | |
| {
 | |
|     m_settings.m_autoDCCorrection = set;
 | |
|     sendSettings();
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::autoIQCorrectionChanged(bool set)
 | |
| {
 | |
|     m_settings.m_autoIQCorrection = set;
 | |
|     sendSettings();
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::dcCorrectionModuleChanged(double value)
 | |
| {
 | |
|     std::complex<double> dcCorrection = std::polar<double>(value, arg(m_settings.m_dcCorrection));
 | |
|     m_settings.m_dcCorrection = dcCorrection;
 | |
|     sendSettings();
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::dcCorrectionArgumentChanged(double value)
 | |
| {
 | |
|     double angleInRadians = (value / 180.0) * M_PI;
 | |
|     std::complex<double> dcCorrection = std::polar<double>(abs(m_settings.m_dcCorrection), angleInRadians);
 | |
|     m_settings.m_dcCorrection = dcCorrection;
 | |
|     sendSettings();
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::iqCorrectionModuleChanged(double value)
 | |
| {
 | |
|     std::complex<double> iqCorrection = std::polar<double>(value, arg(m_settings.m_iqCorrection));
 | |
|     m_settings.m_iqCorrection = iqCorrection;
 | |
|     sendSettings();
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::iqCorrectionArgumentChanged(double value)
 | |
| {
 | |
|     double angleInRadians = (value / 180.0) * M_PI;
 | |
|     std::complex<double> iqCorrection = std::polar<double>(abs(m_settings.m_iqCorrection), angleInRadians);
 | |
|     m_settings.m_iqCorrection = iqCorrection;
 | |
|     sendSettings();
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::streamArgChanged(QString itemName, QVariant value)
 | |
| {
 | |
|     m_settings.m_streamArgSettings[itemName] = value;
 | |
|     sendSettings();
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::deviceArgChanged(QString itemName, QVariant value)
 | |
| {
 | |
|     m_settings.m_deviceArgSettings[itemName] = value;
 | |
|     sendSettings();
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::on_centerFrequency_changed(quint64 value)
 | |
| {
 | |
|     m_settings.m_centerFrequency = value * 1000;
 | |
|     sendSettings();
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::on_interp_currentIndexChanged(int index)
 | |
| {
 | |
|     if ((index <0) || (index > 6))
 | |
|         return;
 | |
|     m_settings.m_log2Interp = index;
 | |
|     sendSettings();
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::on_transverter_clicked()
 | |
| {
 | |
|     m_settings.m_transverterMode = ui->transverter->getDeltaFrequencyAcive();
 | |
|     m_settings.m_transverterDeltaFrequency = ui->transverter->getDeltaFrequency();
 | |
|     qDebug("SoapySDROutputGui::on_transverter_clicked: %lld Hz %s", m_settings.m_transverterDeltaFrequency, m_settings.m_transverterMode ? "on" : "off");
 | |
|     updateFrequencyLimits();
 | |
|     setCenterFrequencySetting(ui->centerFrequency->getValueNew());
 | |
|     sendSettings();
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::on_LOppm_valueChanged(int value)
 | |
| {
 | |
|     ui->LOppmText->setText(QString("%1").arg(QString::number(value/10.0, 'f', 1)));
 | |
|     m_settings.m_LOppmTenths = value;
 | |
|     sendSettings();
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::on_startStop_toggled(bool checked)
 | |
| {
 | |
|     if (m_doApplySettings)
 | |
|     {
 | |
|         SoapySDROutput::MsgStartStop *message = SoapySDROutput::MsgStartStop::create(checked);
 | |
|         m_sampleSink->getInputMessageQueue()->push(message);
 | |
|     }
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::displaySettings()
 | |
| {
 | |
|     blockApplySettings(true);
 | |
| 
 | |
|     ui->transverter->setDeltaFrequency(m_settings.m_transverterDeltaFrequency);
 | |
|     ui->transverter->setDeltaFrequencyActive(m_settings.m_transverterMode);
 | |
| 
 | |
|     updateFrequencyLimits();
 | |
| 
 | |
|     ui->centerFrequency->setValue(m_settings.m_centerFrequency / 1000);
 | |
| 
 | |
|     if (m_antennas) {
 | |
|         m_antennas->setValue(m_settings.m_antenna.toStdString());
 | |
|     }
 | |
|     if (m_sampleRateGUI)
 | |
|     {
 | |
|         m_sampleRateGUI->setValue(m_settings.m_devSampleRate);
 | |
|         m_settings.m_devSampleRate = m_sampleRateGUI->getCurrentValue();
 | |
|     }
 | |
|     if (m_bandwidthGUI)
 | |
|     {
 | |
|         m_bandwidthGUI->setValue(m_settings.m_bandwidth);
 | |
|         m_settings.m_bandwidth = m_bandwidthGUI->getCurrentValue();
 | |
|     }
 | |
|     if (m_gainSliderGUI)
 | |
|     {
 | |
|         m_gainSliderGUI->setValue(m_settings.m_globalGain);
 | |
|         m_settings.m_globalGain = m_gainSliderGUI->getCurrentValue();
 | |
|     }
 | |
|     if (m_autoGain) {
 | |
|         m_autoGain->setChecked(m_settings.m_autoGain);
 | |
|     }
 | |
| 
 | |
|     ui->interp->setCurrentIndex(m_settings.m_log2Interp);
 | |
| 
 | |
|     ui->LOppm->setValue(m_settings.m_LOppmTenths);
 | |
|     ui->LOppmText->setText(QString("%1").arg(QString::number(m_settings.m_LOppmTenths/10.0, 'f', 1)));
 | |
| 
 | |
|     displayTunableElementsControlSettings();
 | |
|     displayIndividualGainsControlSettings();
 | |
|     displayCorrectionsSettings();
 | |
|     displayStreamArgsSettings();
 | |
|     displayDeviceArgsSettings();
 | |
| 
 | |
|     blockApplySettings(false);
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::displayTunableElementsControlSettings()
 | |
| {
 | |
|     for (const auto &it : m_tunableElementsGUIs)
 | |
|     {
 | |
|         QMap<QString, double>::const_iterator elIt = m_settings.m_tunableElements.find(it->getName());
 | |
| 
 | |
|         if (elIt != m_settings.m_tunableElements.end()) {
 | |
|             it->setValue(*elIt);
 | |
|         }
 | |
|     }
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::displayIndividualGainsControlSettings()
 | |
| {
 | |
|     for (const auto &it : m_individualGainsGUIs)
 | |
|     {
 | |
|         QMap<QString, double>::iterator elIt = m_settings.m_individualGains.find(it->getName());
 | |
| 
 | |
|         if (elIt != m_settings.m_individualGains.end())
 | |
|         {
 | |
|             it->setValue(*elIt);
 | |
|             *elIt = it->getValue();
 | |
|         }
 | |
|     }
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::displayCorrectionsSettings()
 | |
| {
 | |
|     if (m_dcCorrectionGUI)
 | |
|     {
 | |
|         m_dcCorrectionGUI->setAutomatic(m_settings.m_autoDCCorrection);
 | |
|         m_dcCorrectionGUI->setModule(abs(m_settings.m_dcCorrection));
 | |
|         m_dcCorrectionGUI->setArgument(arg(m_settings.m_dcCorrection)*(180.0/M_PI));
 | |
|     }
 | |
| 
 | |
|     if (m_iqCorrectionGUI)
 | |
|     {
 | |
|         m_iqCorrectionGUI->setAutomatic(m_settings.m_autoIQCorrection);
 | |
|         m_iqCorrectionGUI->setModule(abs(m_settings.m_iqCorrection));
 | |
|         m_iqCorrectionGUI->setArgument(arg(m_settings.m_iqCorrection)*(180.0/M_PI));
 | |
|     }
 | |
| 
 | |
|     if (m_autoDCCorrection) {
 | |
|         m_autoDCCorrection->setChecked(m_settings.m_autoDCCorrection);
 | |
|     }
 | |
| 
 | |
|     if (m_autoIQCorrection) {
 | |
|         m_autoIQCorrection->setChecked(m_settings.m_autoIQCorrection);
 | |
|     }
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::displayStreamArgsSettings()
 | |
| {
 | |
|     for (const auto &it : m_streamArgsGUIs)
 | |
|     {
 | |
|         QMap<QString, QVariant>::iterator elIt = m_settings.m_streamArgSettings.find(it->getName());
 | |
| 
 | |
|         if (elIt != m_settings.m_streamArgSettings.end())
 | |
|         {
 | |
|             it->setValue(elIt.value());
 | |
|             *elIt = it->getValue();
 | |
|         }
 | |
|     }
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::displayDeviceArgsSettings()
 | |
| {
 | |
|     for (const auto &it : m_deviceArgsGUIs)
 | |
|     {
 | |
|         QMap<QString, QVariant>::iterator elIt = m_settings.m_deviceArgSettings.find(it->getName());
 | |
| 
 | |
|         if (elIt != m_settings.m_deviceArgSettings.end())
 | |
|         {
 | |
|             it->setValue(elIt.value());
 | |
|             *elIt = it->getValue();
 | |
|         }
 | |
|     }
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::sendSettings()
 | |
| {
 | |
|     if (!m_updateTimer.isActive()) {
 | |
|         m_updateTimer.start(100);
 | |
|     }
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::updateSampleRateAndFrequency()
 | |
| {
 | |
|     m_deviceUISet->getSpectrum()->setSampleRate(m_sampleRate);
 | |
|     m_deviceUISet->getSpectrum()->setCenterFrequency(m_deviceCenterFrequency);
 | |
|     ui->deviceRateText->setText(tr("%1k").arg(QString::number(m_sampleRate / 1000.0f, 'g', 5)));
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::updateFrequencyLimits()
 | |
| {
 | |
|     // values in kHz
 | |
|     uint64_t f_min, f_max;
 | |
|     qint64 deltaFrequency = m_settings.m_transverterMode ? m_settings.m_transverterDeltaFrequency/1000 : 0;
 | |
|     m_sampleSink->getFrequencyRange(f_min, f_max);
 | |
|     qint64 minLimit = f_min/1000 + deltaFrequency;
 | |
|     qint64 maxLimit = f_max/1000 + deltaFrequency;
 | |
| 
 | |
|     minLimit = minLimit < 0 ? 0 : minLimit > 9999999 ? 9999999 : minLimit;
 | |
|     maxLimit = maxLimit < 0 ? 0 : maxLimit > 9999999 ? 9999999 : maxLimit;
 | |
| 
 | |
|     qDebug("SoapySDRInputGui::updateFrequencyLimits: delta: %lld min: %lld max: %lld", deltaFrequency, minLimit, maxLimit);
 | |
| 
 | |
|     ui->centerFrequency->setValueRange(7, minLimit, maxLimit);
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::setCenterFrequencySetting(uint64_t kHzValue)
 | |
| {
 | |
|     int64_t centerFrequency = kHzValue*1000;
 | |
| 
 | |
|     m_settings.m_centerFrequency = centerFrequency < 0 ? 0 : (uint64_t) centerFrequency;
 | |
|     ui->centerFrequency->setToolTip(QString("Main center frequency in kHz (LO: %1 kHz)").arg(centerFrequency/1000));
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::updateHardware()
 | |
| {
 | |
|     if (m_doApplySettings)
 | |
|     {
 | |
|         qDebug() << "SoapySDROutputGui::updateHardware";
 | |
|         SoapySDROutput::MsgConfigureSoapySDROutput* message = SoapySDROutput::MsgConfigureSoapySDROutput::create(m_settings, m_forceSettings);
 | |
|         m_sampleSink->getInputMessageQueue()->push(message);
 | |
|         m_forceSettings = false;
 | |
|         m_updateTimer.stop();
 | |
|     }
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::updateStatus()
 | |
| {
 | |
|     int state = m_deviceUISet->m_deviceAPI->state();
 | |
| 
 | |
|     if(m_lastEngineState != state)
 | |
|     {
 | |
|         switch(state)
 | |
|         {
 | |
|             case DeviceAPI::StNotStarted:
 | |
|                 ui->startStop->setStyleSheet("QToolButton { background:rgb(79,79,79); }");
 | |
|                 break;
 | |
|             case DeviceAPI::StIdle:
 | |
|                 ui->startStop->setStyleSheet("QToolButton { background-color : blue; }");
 | |
|                 break;
 | |
|             case DeviceAPI::StRunning:
 | |
|                 ui->startStop->setStyleSheet("QToolButton { background-color : green; }");
 | |
|                 break;
 | |
|             case DeviceAPI::StError:
 | |
|                 ui->startStop->setStyleSheet("QToolButton { background-color : red; }");
 | |
|                 QMessageBox::information(this, tr("Message"), m_deviceUISet->m_deviceAPI->errorMessage());
 | |
|                 break;
 | |
|             default:
 | |
|                 break;
 | |
|         }
 | |
| 
 | |
|         m_lastEngineState = state;
 | |
|     }
 | |
| }
 | |
| 
 | |
| void SoapySDROutputGui::openDeviceSettingsDialog(const QPoint& p)
 | |
| {
 | |
|     BasicDeviceSettingsDialog dialog(this);
 | |
|     dialog.setUseReverseAPI(m_settings.m_useReverseAPI);
 | |
|     dialog.setReverseAPIAddress(m_settings.m_reverseAPIAddress);
 | |
|     dialog.setReverseAPIPort(m_settings.m_reverseAPIPort);
 | |
|     dialog.setReverseAPIDeviceIndex(m_settings.m_reverseAPIDeviceIndex);
 | |
| 
 | |
|     dialog.move(p);
 | |
|     dialog.exec();
 | |
| 
 | |
|     m_settings.m_useReverseAPI = dialog.useReverseAPI();
 | |
|     m_settings.m_reverseAPIAddress = dialog.getReverseAPIAddress();
 | |
|     m_settings.m_reverseAPIPort = dialog.getReverseAPIPort();
 | |
|     m_settings.m_reverseAPIDeviceIndex = dialog.getReverseAPIDeviceIndex();
 | |
| 
 | |
|     sendSettings();
 | |
| }
 |