/////////////////////////////////////////////////////////////////////////////////// // Copyright (C) 2015 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 // // // // 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 . // /////////////////////////////////////////////////////////////////////////////////// #include #include #include #include #include #include #include "ui_sdrdaemongui.h" #include "plugin/pluginapi.h" #include "gui/colormapper.h" #include "dsp/dspengine.h" #include "mainwindow.h" #include "util/simpleserializer.h" #include "sdrdaemongui.h" SDRdaemonGui::SDRdaemonGui(PluginAPI* pluginAPI, QWidget* parent) : QWidget(parent), ui(new Ui::SDRdaemonGui), m_pluginAPI(pluginAPI), m_sampleSource(NULL), m_acquisition(false), m_sampleRate(0), m_centerFrequency(0), m_startingTimeStamp(0), m_samplesCount(0), m_tickCount(0) { ui->setupUi(this); ui->centerFrequency->setColorMapper(ColorMapper(ColorMapper::ReverseGold)); ui->centerFrequency->setValueRange(7, 0, pow(10,7)); connect(&m_updateTimer, SIGNAL(timeout()), this, SLOT(updateHardware())); connect(&(m_pluginAPI->getMainWindow()->getMasterTimer()), SIGNAL(timeout()), this, SLOT(tick())); m_sampleSource = new SDRdaemonInput(m_pluginAPI->getMainWindow()->getMasterTimer()); connect(m_sampleSource->getOutputMessageQueueToGUI(), SIGNAL(messageEnqueued()), this, SLOT(handleSourceMessages())); DSPEngine::instance()->setSource(m_sampleSource); displaySettings(); } SDRdaemonGui::~SDRdaemonGui() { delete ui; } void SDRdaemonGui::destroy() { delete this; } void SDRdaemonGui::setName(const QString& name) { setObjectName(name); } QString SDRdaemonGui::getName() const { return objectName(); } void SDRdaemonGui::resetToDefaults() { displaySettings(); } QByteArray SDRdaemonGui::serialize() const { bool ok; SimpleSerializer s(1); s.writeString(1, ui->address->text()); uint32_t uintval = ui->port->text().toInt(&ok); if((!ok) || (uintval < 1024) || (uintval > 65535)) { uintval = 9090; } s.writeU32(2, uintval); return s.final(); } bool SDRdaemonGui::deserialize(const QByteArray& data) { SimpleDeserializer d(data); QString address; uint32_t uintval; quint16 port; if(!d.isValid()) { resetToDefaults(); return false; } if(d.getVersion() == 1) { uint32_t uintval; d.readString(1, &address, "127.0.0.1"); d.readU32(2, &uintval, 9090); if ((uintval > 1024) && (uintval < 65536)) { port = uintval; } else { port = 9090; } return true; } else { resetToDefaults(); return false; } ui->address->setText(address); ui->port->setText(QString::number(port)); } qint64 SDRdaemonGui::getCenterFrequency() const { return m_centerFrequency; } void SDRdaemonGui::setCenterFrequency(qint64 centerFrequency) { m_centerFrequency = centerFrequency; displaySettings(); } bool SDRdaemonGui::handleMessage(const Message& message) { if (SDRdaemonInput::MsgReportSDRdaemonAcquisition::match(message)) { m_acquisition = ((SDRdaemonInput::MsgReportSDRdaemonAcquisition&)message).getAcquisition(); updateWithAcquisition(); return true; } else if (SDRdaemonInput::MsgReportSDRdaemonStreamData::match(message)) { m_sampleRate = ((SDRdaemonInput::MsgReportSDRdaemonStreamData&)message).getSampleRate(); m_centerFrequency = ((SDRdaemonInput::MsgReportSDRdaemonStreamData&)message).getCenterFrequency(); m_startingTimeStamp = ((SDRdaemonInput::MsgReportSDRdaemonStreamData&)message).getStartingTimeStamp(); updateWithStreamData(); return true; } else if (SDRdaemonInput::MsgReportSDRdaemonStreamTiming::match(message)) { m_samplesCount = ((SDRdaemonInput::MsgReportSDRdaemonStreamTiming&)message).getSamplesCount(); updateWithStreamTime(); return true; } else { return false; } } void SDRdaemonGui::handleSourceMessages() { Message* message; while ((message = m_sampleSource->getOutputMessageQueueToGUI()->pop()) != 0) { qDebug("SDRdaemonGui::handleSourceMessages: message: %s", message->getIdentifier()); if (handleMessage(*message)) { delete message; } } } void SDRdaemonGui::displaySettings() { } void SDRdaemonGui::on_play_toggled(bool checked) { SDRdaemonInput::MsgConfigureSDRdaemonWork* message = SDRdaemonInput::MsgConfigureSDRdaemonWork::create(checked); m_sampleSource->getInputMessageQueue()->push(message); } void SDRdaemonGui::on_applyButton_clicked(bool checked) { configureUDPLink(); } void SDRdaemonGui::configureUDPLink() { bool ok; QString udpAddress = ui->address->text(); int udpPort = ui->port->text().toInt(&ok); if((!ok) || (udpPort < 1024) || (udpPort > 65535)) { udpPort = 9090; } qDebug() << "SDRdaemonGui::configureUDPLink: " << udpAddress.toStdString().c_str() << " : " << udpPort; SDRdaemonInput::MsgConfigureSDRdaemonUDPLink* message = SDRdaemonInput::MsgConfigureSDRdaemonUDPLink::create(udpAddress, udpPort); m_sampleSource->getInputMessageQueue()->push(message); } void SDRdaemonGui::updateWithAcquisition() { } void SDRdaemonGui::updateWithStreamData() { ui->centerFrequency->setValue(m_centerFrequency/1000); QString s = QString::number(m_sampleRate/1000.0, 'f', 0); ui->sampleRateText->setText(tr("%1k").arg(s)); updateWithStreamTime(); // TODO: remove when time data is implemented } void SDRdaemonGui::updateWithStreamTime() { int t_sec = 0; int t_msec = 0; if (m_sampleRate > 0){ t_msec = ((m_samplesCount * 1000) / m_sampleRate) % 1000; t_sec = m_samplesCount / m_sampleRate; } QTime t(0, 0, 0, 0); t = t.addSecs(t_sec); t = t.addMSecs(t_msec); QString s_time = t.toString("hh:mm:ss.zzz"); quint64 startingTimeStampMsec = m_startingTimeStamp * 1000; QDateTime dt = QDateTime::fromMSecsSinceEpoch(startingTimeStampMsec); dt = dt.addSecs(t_sec); dt = dt.addMSecs(t_msec); QString s_date = dt.toString("yyyyMMdd hh.mm.ss.zzz"); ui->absTimeText->setText(s_date); } void SDRdaemonGui::tick() { if ((++m_tickCount & 0xf) == 0) { SDRdaemonInput::MsgConfigureSDRdaemonStreamTiming* message = SDRdaemonInput::MsgConfigureSDRdaemonStreamTiming::create(); m_sampleSource->getInputMessageQueue()->push(message); } }