/////////////////////////////////////////////////////////////////////////////////// // Copyright (C) 2016 F4EXB // // written by Edouard Griffiths // // // // 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 #include #include "SWGChannelSettings.h" #include "SWGDSDDemodSettings.h" #include "SWGChannelReport.h" #include "SWGDSDDemodReport.h" #include "SWGRDSReport.h" #include "audio/audiooutput.h" #include "dsp/dspengine.h" #include "dsp/threadedbasebandsamplesink.h" #include "dsp/downchannelizer.h" #include "dsp/dspcommands.h" #include "device/devicesourceapi.h" #include "util/db.h" #include "dsddemod.h" MESSAGE_CLASS_DEFINITION(DSDDemod::MsgConfigureChannelizer, Message) MESSAGE_CLASS_DEFINITION(DSDDemod::MsgConfigureDSDDemod, Message) MESSAGE_CLASS_DEFINITION(DSDDemod::MsgConfigureMyPosition, Message) const QString DSDDemod::m_channelIdURI = "sdrangel.channel.dsddemod"; const QString DSDDemod::m_channelId = "DSDDemod"; const int DSDDemod::m_udpBlockSize = 512; DSDDemod::DSDDemod(DeviceSourceAPI *deviceAPI) : ChannelSinkAPI(m_channelIdURI), m_deviceAPI(deviceAPI), m_inputSampleRate(48000), m_inputFrequencyOffset(0), m_interpolatorDistance(0.0f), m_interpolatorDistanceRemain(0.0f), m_sampleCount(0), m_squelchCount(0), m_squelchGate(0), m_squelchLevel(1e-4), m_squelchOpen(false), m_squelchDelayLine(24000), m_audioFifo1(48000), m_audioFifo2(48000), m_scopeXY(0), m_scopeEnabled(true), m_dsdDecoder(), m_signalFormat(signalFormatNone), m_settingsMutex(QMutex::Recursive) { setObjectName(m_channelId); m_audioBuffer.resize(1<<14); m_audioBufferFill = 0; m_sampleBuffer = new FixReal[1<<17]; // 128 kS m_sampleBufferIndex = 0; m_scaleFromShort = SDR_RX_SAMP_SZ < sizeof(short)*8 ? 1 : 1<<(SDR_RX_SAMP_SZ - sizeof(short)*8); m_magsq = 0.0f; m_magsqSum = 0.0f; m_magsqPeak = 0.0f; m_magsqCount = 0; DSPEngine::instance()->getAudioDeviceManager()->addAudioSink(&m_audioFifo1, getInputMessageQueue()); DSPEngine::instance()->getAudioDeviceManager()->addAudioSink(&m_audioFifo2, getInputMessageQueue()); m_audioSampleRate = DSPEngine::instance()->getAudioDeviceManager()->getOutputSampleRate(); applyChannelSettings(m_inputSampleRate, m_inputFrequencyOffset, true); applySettings(m_settings, true); m_channelizer = new DownChannelizer(this); m_threadedChannelizer = new ThreadedBasebandSampleSink(m_channelizer, this); m_deviceAPI->addThreadedSink(m_threadedChannelizer); m_deviceAPI->addChannelAPI(this); m_networkManager = new QNetworkAccessManager(); connect(m_networkManager, SIGNAL(finished(QNetworkReply*)), this, SLOT(networkManagerFinished(QNetworkReply*))); } DSDDemod::~DSDDemod() { disconnect(m_networkManager, SIGNAL(finished(QNetworkReply*)), this, SLOT(networkManagerFinished(QNetworkReply*))); delete m_networkManager; delete[] m_sampleBuffer; DSPEngine::instance()->getAudioDeviceManager()->removeAudioSink(&m_audioFifo1); DSPEngine::instance()->getAudioDeviceManager()->removeAudioSink(&m_audioFifo2); m_deviceAPI->removeChannelAPI(this); m_deviceAPI->removeThreadedSink(m_threadedChannelizer); delete m_threadedChannelizer; delete m_channelizer; } void DSDDemod::configureMyPosition(MessageQueue* messageQueue, float myLatitude, float myLongitude) { Message* cmd = MsgConfigureMyPosition::create(myLatitude, myLongitude); messageQueue->push(cmd); } void DSDDemod::feed(const SampleVector::const_iterator& begin, const SampleVector::const_iterator& end, bool firstOfBurst) { (void) firstOfBurst; Complex ci; int samplesPerSymbol = m_dsdDecoder.getSamplesPerSymbol(); m_settingsMutex.lock(); m_scopeSampleBuffer.clear(); m_dsdDecoder.enableMbelib(!DSPEngine::instance()->hasDVSerialSupport()); // disable mbelib if DV serial support is present and activated else enable it for (SampleVector::const_iterator it = begin; it != end; ++it) { Complex c(it->real(), it->imag()); c *= m_nco.nextIQ(); if (m_interpolator.decimate(&m_interpolatorDistanceRemain, c, &ci)) { FixReal sample, delayedSample; qint16 sampleDSD; Real re = ci.real() / SDR_RX_SCALED; Real im = ci.imag() / SDR_RX_SCALED; Real magsq = re*re + im*im; m_movingAverage(magsq); m_magsqSum += magsq; if (magsq > m_magsqPeak) { m_magsqPeak = magsq; } m_magsqCount++; Real demod = m_phaseDiscri.phaseDiscriminator(ci) * m_settings.m_demodGain; // [-1.0:1.0] m_sampleCount++; // AF processing if (m_movingAverage.asDouble() > m_squelchLevel) { if (m_squelchGate > 0) { if (m_squelchCount < m_squelchGate*2) { m_squelchCount++; } m_squelchDelayLine.write(demod); m_squelchOpen = m_squelchCount > m_squelchGate; } else { m_squelchOpen = true; } } else { if (m_squelchGate > 0) { if (m_squelchCount > 0) { m_squelchCount--; } m_squelchDelayLine.write(0); m_squelchOpen = m_squelchCount > m_squelchGate; } else { m_squelchOpen = false; } } if (m_squelchOpen) { if (m_squelchGate > 0) { sampleDSD = m_squelchDelayLine.readBack(m_squelchGate) * 32768.0f; // DSD decoder takes int16 samples sample = m_squelchDelayLine.readBack(m_squelchGate) * SDR_RX_SCALEF; // scale to sample size } else { sampleDSD = demod * 32768.0f; // DSD decoder takes int16 samples sample = demod * SDR_RX_SCALEF; // scale to sample size } } else { sampleDSD = 0; sample = 0; } m_dsdDecoder.pushSample(sampleDSD); if (m_settings.m_enableCosineFiltering) { // show actual input to FSK demod sample = m_dsdDecoder.getFilteredSample() * m_scaleFromShort; } if (m_sampleBufferIndex < (1<<17)-1) { m_sampleBufferIndex++; } else { m_sampleBufferIndex = 0; } m_sampleBuffer[m_sampleBufferIndex] = sample; if (m_sampleBufferIndex < samplesPerSymbol) { delayedSample = m_sampleBuffer[(1<<17) - samplesPerSymbol + m_sampleBufferIndex]; // wrap } else { delayedSample = m_sampleBuffer[m_sampleBufferIndex - samplesPerSymbol]; } if (m_settings.m_syncOrConstellation) { Sample s(sample, m_dsdDecoder.getSymbolSyncSample() * m_scaleFromShort * 0.84); m_scopeSampleBuffer.push_back(s); } else { Sample s(sample, delayedSample); // I=signal, Q=signal delayed by 20 samples (2400 baud: lowest rate) m_scopeSampleBuffer.push_back(s); } if (DSPEngine::instance()->hasDVSerialSupport()) { if ((m_settings.m_slot1On) && m_dsdDecoder.mbeDVReady1()) { if (!m_settings.m_audioMute) { DSPEngine::instance()->pushMbeFrame( m_dsdDecoder.getMbeDVFrame1(), m_dsdDecoder.getMbeRateIndex(), m_settings.m_volume * 10.0, m_settings.m_tdmaStereo ? 1 : 3, // left or both channels m_settings.m_highPassFilter, m_audioSampleRate/8000, // upsample from native 8k &m_audioFifo1); } m_dsdDecoder.resetMbeDV1(); } if ((m_settings.m_slot2On) && m_dsdDecoder.mbeDVReady2()) { if (!m_settings.m_audioMute) { DSPEngine::instance()->pushMbeFrame( m_dsdDecoder.getMbeDVFrame2(), m_dsdDecoder.getMbeRateIndex(), m_settings.m_volume * 10.0, m_settings.m_tdmaStereo ? 2 : 3, // right or both channels m_settings.m_highPassFilter, m_audioSampleRate/8000, // upsample from native 8k &m_audioFifo2); } m_dsdDecoder.resetMbeDV2(); } } // if (DSPEngine::instance()->hasDVSerialSupport() && m_dsdDecoder.mbeDVReady1()) // { // if (!m_settings.m_audioMute) // { // DSPEngine::instance()->pushMbeFrame(m_dsdDecoder.getMbeDVFrame1(), m_dsdDecoder.getMbeRateIndex(), m_settings.m_volume, &m_audioFifo1); // } // // m_dsdDecoder.resetMbeDV1(); // } m_interpolatorDistanceRemain += m_interpolatorDistance; } } if (!DSPEngine::instance()->hasDVSerialSupport()) { if (m_settings.m_slot1On) { int nbAudioSamples; short *dsdAudio = m_dsdDecoder.getAudio1(nbAudioSamples); if (nbAudioSamples > 0) { if (!m_settings.m_audioMute) { m_audioFifo1.write((const quint8*) dsdAudio, nbAudioSamples); } m_dsdDecoder.resetAudio1(); } } if (m_settings.m_slot2On) { int nbAudioSamples; short *dsdAudio = m_dsdDecoder.getAudio2(nbAudioSamples); if (nbAudioSamples > 0) { if (!m_settings.m_audioMute) { m_audioFifo2.write((const quint8*) dsdAudio, nbAudioSamples); } m_dsdDecoder.resetAudio2(); } } // int nbAudioSamples; // short *dsdAudio = m_dsdDecoder.getAudio1(nbAudioSamples); // // if (nbAudioSamples > 0) // { // if (!m_settings.m_audioMute) { // uint res = m_audioFifo1.write((const quint8*) dsdAudio, nbAudioSamples, 10); // } // // m_dsdDecoder.resetAudio1(); // } } if ((m_scopeXY != 0) && (m_scopeEnabled)) { m_scopeXY->feed(m_scopeSampleBuffer.begin(), m_scopeSampleBuffer.end(), true); // true = real samples for what it's worth } m_settingsMutex.unlock(); } void DSDDemod::start() { m_audioFifo1.clear(); m_audioFifo2.clear(); m_phaseDiscri.reset(); applyChannelSettings(m_inputSampleRate, m_inputFrequencyOffset, true); } void DSDDemod::stop() { } bool DSDDemod::handleMessage(const Message& cmd) { qDebug() << "DSDDemod::handleMessage"; if (DownChannelizer::MsgChannelizerNotification::match(cmd)) { DownChannelizer::MsgChannelizerNotification& notif = (DownChannelizer::MsgChannelizerNotification&) cmd; qDebug() << "DSDDemod::handleMessage: MsgChannelizerNotification: inputSampleRate: " << notif.getSampleRate() << " inputFrequencyOffset: " << notif.getFrequencyOffset(); applyChannelSettings(notif.getSampleRate(), notif.getFrequencyOffset()); return true; } else if (MsgConfigureChannelizer::match(cmd)) { MsgConfigureChannelizer& cfg = (MsgConfigureChannelizer&) cmd; qDebug("DSDDemod::handleMessage: MsgConfigureChannelizer"); m_channelizer->configure(m_channelizer->getInputMessageQueue(), cfg.getSampleRate(), cfg.getCenterFrequency()); return true; } else if (MsgConfigureDSDDemod::match(cmd)) { MsgConfigureDSDDemod& cfg = (MsgConfigureDSDDemod&) cmd; qDebug("DSDDemod::handleMessage: MsgConfigureDSDDemod: m_rfBandwidth"); applySettings(cfg.getSettings(), cfg.getForce()); return true; } else if (MsgConfigureMyPosition::match(cmd)) { MsgConfigureMyPosition& cfg = (MsgConfigureMyPosition&) cmd; m_dsdDecoder.setMyPoint(cfg.getMyLatitude(), cfg.getMyLongitude()); return true; } else if (DSPConfigureAudio::match(cmd)) { DSPConfigureAudio& cfg = (DSPConfigureAudio&) cmd; uint32_t sampleRate = cfg.getSampleRate(); qDebug() << "DSDDemod::handleMessage: DSPConfigureAudio:" << " sampleRate: " << sampleRate; if (sampleRate != m_audioSampleRate) { applyAudioSampleRate(sampleRate); } return true; } else if (BasebandSampleSink::MsgThreadedSink::match(cmd)) { return true; } else if (DSPSignalNotification::match(cmd)) { return true; } else { return false; } } void DSDDemod::applyAudioSampleRate(int sampleRate) { int upsampling = sampleRate / 8000; qDebug("DSDDemod::applyAudioSampleRate: audio rate: %d upsample by %d", sampleRate, upsampling); if (sampleRate % 8000 != 0) { qDebug("DSDDemod::applyAudioSampleRate: audio will sound best with sample rates that are integer multiples of 8 kS/s"); } m_dsdDecoder.setUpsampling(upsampling); m_audioSampleRate = sampleRate; } void DSDDemod::applyChannelSettings(int inputSampleRate, int inputFrequencyOffset, bool force) { qDebug() << "DSDDemod::applyChannelSettings:" << " inputSampleRate: " << inputSampleRate << " inputFrequencyOffset: " << inputFrequencyOffset; if ((inputFrequencyOffset != m_inputFrequencyOffset) || (inputSampleRate != m_inputSampleRate) || force) { m_nco.setFreq(-inputFrequencyOffset, inputSampleRate); } if ((inputSampleRate != m_inputSampleRate) || force) { m_settingsMutex.lock(); m_interpolator.create(16, inputSampleRate, (m_settings.m_rfBandwidth) / 2.2); m_interpolatorDistanceRemain = 0; m_interpolatorDistance = (Real) inputSampleRate / (Real) 48000; m_settingsMutex.unlock(); } m_inputSampleRate = inputSampleRate; m_inputFrequencyOffset = inputFrequencyOffset; } void DSDDemod::applySettings(const DSDDemodSettings& settings, bool force) { qDebug() << "DSDDemod::applySettings: " << " m_inputFrequencyOffset: " << settings.m_inputFrequencyOffset << " m_rfBandwidth: " << settings.m_rfBandwidth << " m_fmDeviation: " << settings.m_fmDeviation << " m_demodGain: " << settings.m_demodGain << " m_volume: " << settings.m_volume << " m_baudRate: " << settings.m_baudRate << " m_squelchGate" << settings.m_squelchGate << " m_squelch: " << settings.m_squelch << " m_audioMute: " << settings.m_audioMute << " m_enableCosineFiltering: " << settings.m_enableCosineFiltering << " m_syncOrConstellation: " << settings.m_syncOrConstellation << " m_slot1On: " << settings.m_slot1On << " m_slot2On: " << settings.m_slot2On << " m_tdmaStereo: " << settings.m_tdmaStereo << " m_pllLock: " << settings.m_pllLock << " m_highPassFilter: "<< settings.m_highPassFilter << " m_audioDeviceName: " << settings.m_audioDeviceName << " m_traceLengthMutliplier: " << settings.m_traceLengthMutliplier << " m_traceStroke: " << settings.m_traceStroke << " m_traceDecay: " << settings.m_traceDecay << " force: " << force; QList reverseAPIKeys; if ((settings.m_inputFrequencyOffset != m_settings.m_inputFrequencyOffset) || force) { reverseAPIKeys.append("inputFrequencyOffset"); } if ((settings.m_demodGain != m_settings.m_demodGain) || force) { reverseAPIKeys.append("demodGain"); } if ((settings.m_audioMute != m_settings.m_audioMute) || force) { reverseAPIKeys.append("audioMute"); } if ((settings.m_syncOrConstellation != m_settings.m_syncOrConstellation) || force) { reverseAPIKeys.append("syncOrConstellation"); } if ((settings.m_slot1On != m_settings.m_slot1On) || force) { reverseAPIKeys.append("slot1On"); } if ((settings.m_slot2On != m_settings.m_slot2On) || force) { reverseAPIKeys.append("slot2On"); } if ((settings.m_demodGain != m_settings.m_demodGain) || force) { reverseAPIKeys.append("demodGain"); } if ((settings.m_traceLengthMutliplier != m_settings.m_traceLengthMutliplier) || force) { reverseAPIKeys.append("traceLengthMutliplier"); } if ((settings.m_rfBandwidth != m_settings.m_rfBandwidth) || force) { reverseAPIKeys.append("rfBandwidth"); m_settingsMutex.lock(); m_interpolator.create(16, m_inputSampleRate, (settings.m_rfBandwidth) / 2.2); m_interpolatorDistanceRemain = 0; m_interpolatorDistance = (Real) m_inputSampleRate / (Real) 48000; //m_phaseDiscri.setFMScaling((float) settings.m_rfBandwidth / (float) settings.m_fmDeviation); m_settingsMutex.unlock(); } if ((settings.m_fmDeviation != m_settings.m_fmDeviation) || force) { reverseAPIKeys.append("fmDeviation"); m_phaseDiscri.setFMScaling(48000.0f / (2.0f*settings.m_fmDeviation)); } if ((settings.m_squelchGate != m_settings.m_squelchGate) || force) { reverseAPIKeys.append("squelchGate"); m_squelchGate = 480 * settings.m_squelchGate; // gate is given in 10s of ms at 48000 Hz audio sample rate m_squelchCount = 0; // reset squelch open counter } if ((settings.m_squelch != m_settings.m_squelch) || force) { reverseAPIKeys.append("squelch"); // input is a value in dB m_squelchLevel = std::pow(10.0, settings.m_squelch / 10.0); } if ((settings.m_volume != m_settings.m_volume) || force) { reverseAPIKeys.append("volume"); m_dsdDecoder.setAudioGain(settings.m_volume); } if ((settings.m_baudRate != m_settings.m_baudRate) || force) { reverseAPIKeys.append("baudRate"); m_dsdDecoder.setBaudRate(settings.m_baudRate); } if ((settings.m_enableCosineFiltering != m_settings.m_enableCosineFiltering) || force) { reverseAPIKeys.append("enableCosineFiltering"); m_dsdDecoder.enableCosineFiltering(settings.m_enableCosineFiltering); } if ((settings.m_tdmaStereo != m_settings.m_tdmaStereo) || force) { reverseAPIKeys.append("tdmaStereo"); m_dsdDecoder.setTDMAStereo(settings.m_tdmaStereo); } if ((settings.m_pllLock != m_settings.m_pllLock) || force) { reverseAPIKeys.append("pllLock"); m_dsdDecoder.setSymbolPLLLock(settings.m_pllLock); } if ((settings.m_highPassFilter != m_settings.m_highPassFilter) || force) { reverseAPIKeys.append("highPassFilter"); m_dsdDecoder.useHPMbelib(settings.m_highPassFilter); } if ((settings.m_audioDeviceName != m_settings.m_audioDeviceName) || force) { reverseAPIKeys.append("audioDeviceName"); AudioDeviceManager *audioDeviceManager = DSPEngine::instance()->getAudioDeviceManager(); int audioDeviceIndex = audioDeviceManager->getOutputDeviceIndex(settings.m_audioDeviceName); //qDebug("AMDemod::applySettings: audioDeviceName: %s audioDeviceIndex: %d", qPrintable(settings.m_audioDeviceName), audioDeviceIndex); audioDeviceManager->addAudioSink(&m_audioFifo1, getInputMessageQueue(), audioDeviceIndex); audioDeviceManager->addAudioSink(&m_audioFifo2, getInputMessageQueue(), audioDeviceIndex); uint32_t audioSampleRate = audioDeviceManager->getOutputSampleRate(audioDeviceIndex); if (m_audioSampleRate != audioSampleRate) { applyAudioSampleRate(audioSampleRate); } } if (settings.m_useReverseAPI) { bool fullUpdate = ((m_settings.m_useReverseAPI != settings.m_useReverseAPI) && settings.m_useReverseAPI) || (m_settings.m_reverseAPIAddress != settings.m_reverseAPIAddress) || (m_settings.m_reverseAPIPort != settings.m_reverseAPIPort) || (m_settings.m_reverseAPIDeviceIndex != settings.m_reverseAPIDeviceIndex) || (m_settings.m_reverseAPIChannelIndex != settings.m_reverseAPIChannelIndex); webapiReverseSendSettings(reverseAPIKeys, settings, fullUpdate || force); } m_settings = settings; } QByteArray DSDDemod::serialize() const { return m_settings.serialize(); } bool DSDDemod::deserialize(const QByteArray& data) { if (m_settings.deserialize(data)) { MsgConfigureDSDDemod *msg = MsgConfigureDSDDemod::create(m_settings, true); m_inputMessageQueue.push(msg); return true; } else { m_settings.resetToDefaults(); MsgConfigureDSDDemod *msg = MsgConfigureDSDDemod::create(m_settings, true); m_inputMessageQueue.push(msg); return false; } } const char *DSDDemod::updateAndGetStatusText() { formatStatusText(); return m_formatStatusText; } void DSDDemod::formatStatusText() { switch (getDecoder().getSyncType()) { case DSDcc::DSDDecoder::DSDSyncDMRDataMS: case DSDcc::DSDDecoder::DSDSyncDMRDataP: case DSDcc::DSDDecoder::DSDSyncDMRVoiceMS: case DSDcc::DSDDecoder::DSDSyncDMRVoiceP: if (m_signalFormat != signalFormatDMR) { strcpy(m_formatStatusText, "Sta: __ S1: __________________________ S2: __________________________"); } switch (getDecoder().getStationType()) { case DSDcc::DSDDecoder::DSDBaseStation: memcpy(&m_formatStatusText[5], "BS ", 3); break; case DSDcc::DSDDecoder::DSDMobileStation: memcpy(&m_formatStatusText[5], "MS ", 3); break; default: memcpy(&m_formatStatusText[5], "NA ", 3); break; } memcpy(&m_formatStatusText[12], getDecoder().getDMRDecoder().getSlot0Text(), 26); memcpy(&m_formatStatusText[43], getDecoder().getDMRDecoder().getSlot1Text(), 26); m_signalFormat = signalFormatDMR; break; case DSDcc::DSDDecoder::DSDSyncDStarHeaderN: case DSDcc::DSDDecoder::DSDSyncDStarHeaderP: case DSDcc::DSDDecoder::DSDSyncDStarN: case DSDcc::DSDDecoder::DSDSyncDStarP: if (m_signalFormat != signalFormatDStar) { // 1 1 2 2 3 3 4 4 5 5 6 6 7 7 8 // 0....5....0....5....0....5....0....5....0....5....0....5....0....5....0....5....0.. strcpy(m_formatStatusText, "________/____>________|________>________|____________________|______:___/_____._"); // MY UR RPT1 RPT2 Info Loc Target } { const std::string& rpt1 = getDecoder().getDStarDecoder().getRpt1(); const std::string& rpt2 = getDecoder().getDStarDecoder().getRpt2(); const std::string& mySign = getDecoder().getDStarDecoder().getMySign(); const std::string& yrSign = getDecoder().getDStarDecoder().getYourSign(); if (rpt1.length() > 0) { // 0 or 8 memcpy(&m_formatStatusText[23], rpt1.c_str(), 8); } if (rpt2.length() > 0) { // 0 or 8 memcpy(&m_formatStatusText[32], rpt2.c_str(), 8); } if (yrSign.length() > 0) { // 0 or 8 memcpy(&m_formatStatusText[14], yrSign.c_str(), 8); } if (mySign.length() > 0) { // 0 or 13 memcpy(&m_formatStatusText[0], mySign.c_str(), 13); } memcpy(&m_formatStatusText[41], getDecoder().getDStarDecoder().getInfoText(), 20); memcpy(&m_formatStatusText[62], getDecoder().getDStarDecoder().getLocator(), 6); snprintf(&m_formatStatusText[69], 82-69, "%03d/%07.1f", getDecoder().getDStarDecoder().getBearing(), getDecoder().getDStarDecoder().getDistance()); } m_formatStatusText[82] = '\0'; m_signalFormat = signalFormatDStar; break; case DSDcc::DSDDecoder::DSDSyncDPMR: snprintf(m_formatStatusText, 82, "%s CC: %04d OI: %08d CI: %08d", DSDcc::DSDdPMR::dpmrFrameTypes[(int) getDecoder().getDPMRDecoder().getFrameType()], getDecoder().getDPMRDecoder().getColorCode(), getDecoder().getDPMRDecoder().getOwnId(), getDecoder().getDPMRDecoder().getCalledId()); m_signalFormat = signalFormatDPMR; break; case DSDcc::DSDDecoder::DSDSyncNXDNP: case DSDcc::DSDDecoder::DSDSyncNXDNN: if (getDecoder().getNXDNDecoder().getRFChannel() == DSDcc::DSDNXDN::NXDNRCCH) { // 1 1 2 2 3 3 4 4 5 5 6 6 7 7 8 // 0....5....0....5....0....5....0....5....0....5....0....5....0....5....0....5....0.. // RC r cc mm llllll ssss snprintf(m_formatStatusText, 82, "RC %s %02d %02X %06X %02X", getDecoder().getNXDNDecoder().isFullRate() ? "F" : "H", getDecoder().getNXDNDecoder().getRAN(), getDecoder().getNXDNDecoder().getMessageType(), getDecoder().getNXDNDecoder().getLocationId(), getDecoder().getNXDNDecoder().getServicesFlag()); } else if ((getDecoder().getNXDNDecoder().getRFChannel() == DSDcc::DSDNXDN::NXDNRTCH) || (getDecoder().getNXDNDecoder().getRFChannel() == DSDcc::DSDNXDN::NXDNRDCH)) { if (getDecoder().getNXDNDecoder().isIdle()) { snprintf(m_formatStatusText, 82, "%s IDLE", getDecoder().getNXDNDecoder().getRFChannelStr()); } else { // 1 1 2 2 3 3 4 4 5 5 6 6 7 7 8 // 0....5....0....5....0....5....0....5....0....5....0....5....0....5....0....5....0.. // Rx r cc mm sssss>gddddd snprintf(m_formatStatusText, 82, "%s %s %02d %02X %05d>%c%05d", getDecoder().getNXDNDecoder().getRFChannelStr(), getDecoder().getNXDNDecoder().isFullRate() ? "F" : "H", getDecoder().getNXDNDecoder().getRAN(), getDecoder().getNXDNDecoder().getMessageType(), getDecoder().getNXDNDecoder().getSourceId(), getDecoder().getNXDNDecoder().isGroupCall() ? 'G' : 'I', getDecoder().getNXDNDecoder().getDestinationId()); } } else { // 1 1 2 2 3 3 4 4 5 5 6 6 7 7 8 // 0....5....0....5....0....5....0....5....0....5....0....5....0....5....0....5....0.. // RU snprintf(m_formatStatusText, 82, "RU"); } m_signalFormat = signalFormatNXDN; break; case DSDcc::DSDDecoder::DSDSyncYSF: // 1 1 2 2 3 3 4 4 5 5 6 6 7 7 8 // 0....5....0....5....0....5....0....5....0....5....0....5....0....5....0....5....0.. // C V2 RI 0:7 WL000|ssssssssss>dddddddddd |UUUUUUUUUU>DDDDDDDDDD|44444 if (getDecoder().getYSFDecoder().getFICHError() == DSDcc::DSDYSF::FICHNoError) { snprintf(m_formatStatusText, 82, "%s ", DSDcc::DSDYSF::ysfChannelTypeText[(int) getDecoder().getYSFDecoder().getFICH().getFrameInformation()]); } else { snprintf(m_formatStatusText, 82, "%d ", (int) getDecoder().getYSFDecoder().getFICHError()); } snprintf(&m_formatStatusText[2], 80, "%s %s %d:%d %c%c", DSDcc::DSDYSF::ysfDataTypeText[(int) getDecoder().getYSFDecoder().getFICH().getDataType()], DSDcc::DSDYSF::ysfCallModeText[(int) getDecoder().getYSFDecoder().getFICH().getCallMode()], getDecoder().getYSFDecoder().getFICH().getBlockTotal(), getDecoder().getYSFDecoder().getFICH().getFrameTotal(), (getDecoder().getYSFDecoder().getFICH().isNarrowMode() ? 'N' : 'W'), (getDecoder().getYSFDecoder().getFICH().isInternetPath() ? 'I' : 'L')); if (getDecoder().getYSFDecoder().getFICH().isSquelchCodeEnabled()) { snprintf(&m_formatStatusText[14], 82-14, "%03d", getDecoder().getYSFDecoder().getFICH().getSquelchCode()); } else { strncpy(&m_formatStatusText[14], "---", 82-14); } char dest[13]; if (getDecoder().getYSFDecoder().radioIdMode()) { snprintf(dest, 12, "%-5s:%-5s", getDecoder().getYSFDecoder().getDestId(), getDecoder().getYSFDecoder().getSrcId()); } else { snprintf(dest, 11, "%-10s", getDecoder().getYSFDecoder().getDest()); } snprintf(&m_formatStatusText[17], 82-17, "|%-10s>%s|%-10s>%-10s|%-5s", getDecoder().getYSFDecoder().getSrc(), dest, getDecoder().getYSFDecoder().getUplink(), getDecoder().getYSFDecoder().getDownlink(), getDecoder().getYSFDecoder().getRem4()); m_signalFormat = signalFormatYSF; break; default: m_signalFormat = signalFormatNone; m_formatStatusText[0] = '\0'; break; } m_formatStatusText[82] = '\0'; // guard } int DSDDemod::webapiSettingsGet( SWGSDRangel::SWGChannelSettings& response, QString& errorMessage) { (void) errorMessage; response.setDsdDemodSettings(new SWGSDRangel::SWGDSDDemodSettings()); response.getDsdDemodSettings()->init(); webapiFormatChannelSettings(response, m_settings); return 200; } int DSDDemod::webapiSettingsPutPatch( bool force, const QStringList& channelSettingsKeys, SWGSDRangel::SWGChannelSettings& response, QString& errorMessage) { (void) errorMessage; DSDDemodSettings settings = m_settings; bool frequencyOffsetChanged = false; if (channelSettingsKeys.contains("inputFrequencyOffset")) { settings.m_inputFrequencyOffset = response.getDsdDemodSettings()->getInputFrequencyOffset(); frequencyOffsetChanged = true; } if (channelSettingsKeys.contains("rfBandwidth")) { settings.m_rfBandwidth = response.getDsdDemodSettings()->getRfBandwidth(); } if (channelSettingsKeys.contains("fmDeviation")) { settings.m_fmDeviation = response.getDsdDemodSettings()->getFmDeviation(); } if (channelSettingsKeys.contains("demodGain")) { settings.m_demodGain = response.getDsdDemodSettings()->getDemodGain(); } if (channelSettingsKeys.contains("volume")) { settings.m_volume = response.getDsdDemodSettings()->getVolume(); } if (channelSettingsKeys.contains("baudRate")) { settings.m_baudRate = response.getDsdDemodSettings()->getBaudRate(); } if (channelSettingsKeys.contains("squelchGate")) { settings.m_squelchGate = response.getDsdDemodSettings()->getSquelchGate(); } if (channelSettingsKeys.contains("squelch")) { settings.m_squelch = response.getDsdDemodSettings()->getSquelch(); } if (channelSettingsKeys.contains("audioMute")) { settings.m_audioMute = response.getDsdDemodSettings()->getAudioMute() != 0; } if (channelSettingsKeys.contains("enableCosineFiltering")) { settings.m_enableCosineFiltering = response.getDsdDemodSettings()->getEnableCosineFiltering() != 0; } if (channelSettingsKeys.contains("syncOrConstellation")) { settings.m_syncOrConstellation = response.getDsdDemodSettings()->getSyncOrConstellation() != 0; } if (channelSettingsKeys.contains("slot1On")) { settings.m_slot1On = response.getDsdDemodSettings()->getSlot1On() != 0; } if (channelSettingsKeys.contains("slot2On")) { settings.m_slot2On = response.getDsdDemodSettings()->getSlot2On() != 0; } if (channelSettingsKeys.contains("tdmaStereo")) { settings.m_tdmaStereo = response.getDsdDemodSettings()->getTdmaStereo() != 0; } if (channelSettingsKeys.contains("pllLock")) { settings.m_pllLock = response.getDsdDemodSettings()->getPllLock() != 0; } if (channelSettingsKeys.contains("rgbColor")) { settings.m_rgbColor = response.getDsdDemodSettings()->getRgbColor(); } if (channelSettingsKeys.contains("title")) { settings.m_title = *response.getDsdDemodSettings()->getTitle(); } if (channelSettingsKeys.contains("audioDeviceName")) { settings.m_audioDeviceName = *response.getDsdDemodSettings()->getAudioDeviceName(); } if (channelSettingsKeys.contains("highPassFilter")) { settings.m_highPassFilter = response.getDsdDemodSettings()->getHighPassFilter() != 0; } if (channelSettingsKeys.contains("traceLengthMutliplier")) { settings.m_traceLengthMutliplier = response.getDsdDemodSettings()->getTraceLengthMutliplier(); } if (channelSettingsKeys.contains("traceStroke")) { settings.m_traceStroke = response.getDsdDemodSettings()->getTraceStroke(); } if (channelSettingsKeys.contains("traceDecay")) { settings.m_traceDecay = response.getDsdDemodSettings()->getTraceDecay(); } if (channelSettingsKeys.contains("useReverseAPI")) { settings.m_useReverseAPI = response.getDsdDemodSettings()->getUseReverseApi() != 0; } if (channelSettingsKeys.contains("reverseAPIAddress")) { settings.m_reverseAPIAddress = *response.getDsdDemodSettings()->getReverseApiAddress() != 0; } if (channelSettingsKeys.contains("reverseAPIPort")) { settings.m_reverseAPIPort = response.getDsdDemodSettings()->getReverseApiPort(); } if (channelSettingsKeys.contains("reverseAPIDeviceIndex")) { settings.m_reverseAPIDeviceIndex = response.getDsdDemodSettings()->getReverseApiDeviceIndex(); } if (channelSettingsKeys.contains("reverseAPIChannelIndex")) { settings.m_reverseAPIChannelIndex = response.getDsdDemodSettings()->getReverseApiChannelIndex(); } if (frequencyOffsetChanged) { MsgConfigureChannelizer* channelConfigMsg = MsgConfigureChannelizer::create( m_audioSampleRate, settings.m_inputFrequencyOffset); m_inputMessageQueue.push(channelConfigMsg); } MsgConfigureDSDDemod *msg = MsgConfigureDSDDemod::create(settings, force); m_inputMessageQueue.push(msg); qDebug("DSDDemod::webapiSettingsPutPatch: forward to GUI: %p", m_guiMessageQueue); if (m_guiMessageQueue) // forward to GUI if any { MsgConfigureDSDDemod *msgToGUI = MsgConfigureDSDDemod::create(settings, force); m_guiMessageQueue->push(msgToGUI); } webapiFormatChannelSettings(response, settings); return 200; } int DSDDemod::webapiReportGet( SWGSDRangel::SWGChannelReport& response, QString& errorMessage) { (void) errorMessage; response.setDsdDemodReport(new SWGSDRangel::SWGDSDDemodReport()); response.getDsdDemodReport()->init(); webapiFormatChannelReport(response); return 200; } void DSDDemod::webapiFormatChannelSettings(SWGSDRangel::SWGChannelSettings& response, const DSDDemodSettings& settings) { response.getDsdDemodSettings()->setInputFrequencyOffset(settings.m_inputFrequencyOffset); response.getDsdDemodSettings()->setRfBandwidth(settings.m_rfBandwidth); response.getDsdDemodSettings()->setFmDeviation(settings.m_fmDeviation); response.getDsdDemodSettings()->setDemodGain(settings.m_demodGain); response.getDsdDemodSettings()->setVolume(settings.m_volume); response.getDsdDemodSettings()->setBaudRate(settings.m_baudRate); response.getDsdDemodSettings()->setSquelchGate(settings.m_squelchGate); response.getDsdDemodSettings()->setSquelch(settings.m_squelch); response.getDsdDemodSettings()->setAudioMute(settings.m_audioMute ? 1 : 0); response.getDsdDemodSettings()->setEnableCosineFiltering(settings.m_enableCosineFiltering ? 1 : 0); response.getDsdDemodSettings()->setSyncOrConstellation(settings.m_syncOrConstellation ? 1 : 0); response.getDsdDemodSettings()->setSlot1On(settings.m_slot1On ? 1 : 0); response.getDsdDemodSettings()->setSlot2On(settings.m_slot2On ? 1 : 0); response.getDsdDemodSettings()->setTdmaStereo(settings.m_tdmaStereo ? 1 : 0); response.getDsdDemodSettings()->setPllLock(settings.m_pllLock ? 1 : 0); response.getDsdDemodSettings()->setRgbColor(settings.m_rgbColor); if (response.getDsdDemodSettings()->getTitle()) { *response.getDsdDemodSettings()->getTitle() = settings.m_title; } else { response.getDsdDemodSettings()->setTitle(new QString(settings.m_title)); } if (response.getDsdDemodSettings()->getAudioDeviceName()) { *response.getDsdDemodSettings()->getAudioDeviceName() = settings.m_audioDeviceName; } else { response.getDsdDemodSettings()->setAudioDeviceName(new QString(settings.m_audioDeviceName)); } response.getDsdDemodSettings()->setHighPassFilter(settings.m_highPassFilter ? 1 : 0); response.getDsdDemodSettings()->setTraceLengthMutliplier(settings.m_traceLengthMutliplier); response.getDsdDemodSettings()->setTraceStroke(settings.m_traceStroke); response.getDsdDemodSettings()->setTraceDecay(settings.m_traceDecay); response.getDsdDemodSettings()->setUseReverseApi(settings.m_useReverseAPI ? 1 : 0); if (response.getDsdDemodSettings()->getReverseApiAddress()) { *response.getDsdDemodSettings()->getReverseApiAddress() = settings.m_reverseAPIAddress; } else { response.getDsdDemodSettings()->setReverseApiAddress(new QString(settings.m_reverseAPIAddress)); } response.getDsdDemodSettings()->setReverseApiPort(settings.m_reverseAPIPort); response.getDsdDemodSettings()->setReverseApiDeviceIndex(settings.m_reverseAPIDeviceIndex); response.getDsdDemodSettings()->setReverseApiChannelIndex(settings.m_reverseAPIChannelIndex); } void DSDDemod::webapiFormatChannelReport(SWGSDRangel::SWGChannelReport& response) { double magsqAvg, magsqPeak; int nbMagsqSamples; getMagSqLevels(magsqAvg, magsqPeak, nbMagsqSamples); response.getDsdDemodReport()->setChannelPowerDb(CalcDb::dbPower(magsqAvg)); response.getDsdDemodReport()->setAudioSampleRate(m_audioSampleRate); response.getDsdDemodReport()->setChannelSampleRate(m_inputSampleRate); response.getDsdDemodReport()->setSquelch(m_squelchOpen ? 1 : 0); response.getDsdDemodReport()->setPllLocked(getDecoder().getSymbolPLLLocked() ? 1 : 0); response.getDsdDemodReport()->setSlot1On(getDecoder().getVoice1On() ? 1 : 0); response.getDsdDemodReport()->setSlot2On(getDecoder().getVoice2On() ? 1 : 0); response.getDsdDemodReport()->setSyncType(new QString(getDecoder().getFrameTypeText())); response.getDsdDemodReport()->setInLevel(getDecoder().getInLevel()); response.getDsdDemodReport()->setCarierPosition(getDecoder().getCarrierPos()); response.getDsdDemodReport()->setZeroCrossingPosition(getDecoder().getZeroCrossingPos()); response.getDsdDemodReport()->setSyncRate(getDecoder().getSymbolSyncQuality()); response.getDsdDemodReport()->setStatusText(new QString(updateAndGetStatusText())); } void DSDDemod::webapiReverseSendSettings(QList& channelSettingsKeys, const DSDDemodSettings& settings, bool force) { SWGSDRangel::SWGChannelSettings *swgChannelSettings = new SWGSDRangel::SWGChannelSettings(); swgChannelSettings->setTx(0); swgChannelSettings->setChannelType(new QString("DSDDemod")); swgChannelSettings->setDsdDemodSettings(new SWGSDRangel::SWGDSDDemodSettings()); SWGSDRangel::SWGDSDDemodSettings *swgDSDDemodSettings = swgChannelSettings->getDsdDemodSettings(); // transfer data that has been modified. When force is on transfer all data except reverse API data if (channelSettingsKeys.contains("inputFrequencyOffset") || force) { swgDSDDemodSettings->setInputFrequencyOffset(settings.m_inputFrequencyOffset); } if (channelSettingsKeys.contains("rfBandwidth") || force) { swgDSDDemodSettings->setRfBandwidth(settings.m_rfBandwidth); } if (channelSettingsKeys.contains("fmDeviation") || force) { swgDSDDemodSettings->setFmDeviation(settings.m_fmDeviation); } if (channelSettingsKeys.contains("demodGain") || force) { swgDSDDemodSettings->setDemodGain(settings.m_demodGain); } if (channelSettingsKeys.contains("volume") || force) { swgDSDDemodSettings->setVolume(settings.m_volume); } if (channelSettingsKeys.contains("baudRate") || force) { swgDSDDemodSettings->setBaudRate(settings.m_baudRate); } if (channelSettingsKeys.contains("squelchGate") || force) { swgDSDDemodSettings->setSquelchGate(settings.m_squelchGate); } if (channelSettingsKeys.contains("squelch") || force) { swgDSDDemodSettings->setSquelch(settings.m_squelch); } if (channelSettingsKeys.contains("audioMute") || force) { swgDSDDemodSettings->setAudioMute(settings.m_audioMute ? 1 : 0); } if (channelSettingsKeys.contains("enableCosineFiltering") || force) { swgDSDDemodSettings->setEnableCosineFiltering(settings.m_enableCosineFiltering ? 1 : 0); } if (channelSettingsKeys.contains("syncOrConstellation") || force) { swgDSDDemodSettings->setSyncOrConstellation(settings.m_syncOrConstellation ? 1 : 0); } if (channelSettingsKeys.contains("slot1On") || force) { swgDSDDemodSettings->setSlot1On(settings.m_slot1On ? 1 : 0); } if (channelSettingsKeys.contains("slot2On") || force) { swgDSDDemodSettings->setSlot2On(settings.m_slot2On ? 1 : 0); } if (channelSettingsKeys.contains("tdmaStereo") || force) { swgDSDDemodSettings->setTdmaStereo(settings.m_tdmaStereo ? 1 : 0); } if (channelSettingsKeys.contains("pllLock") || force) { swgDSDDemodSettings->setPllLock(settings.m_pllLock ? 1 : 0); } if (channelSettingsKeys.contains("rgbColor") || force) { swgDSDDemodSettings->setRgbColor(settings.m_rgbColor); } if (channelSettingsKeys.contains("title") || force) { swgDSDDemodSettings->setTitle(new QString(settings.m_title)); } if (channelSettingsKeys.contains("audioDeviceName") || force) { swgDSDDemodSettings->setAudioDeviceName(new QString(settings.m_audioDeviceName)); } if (channelSettingsKeys.contains("highPassFilter") || force) { swgDSDDemodSettings->setHighPassFilter(settings.m_highPassFilter ? 1 : 0); } if (channelSettingsKeys.contains("traceLengthMutliplier") || force) { swgDSDDemodSettings->setTraceLengthMutliplier(settings.m_traceLengthMutliplier); } if (channelSettingsKeys.contains("traceStroke") || force) { swgDSDDemodSettings->setTraceStroke(settings.m_traceStroke); } if (channelSettingsKeys.contains("traceDecay") || force) { swgDSDDemodSettings->setTraceDecay(settings.m_traceDecay); } QString channelSettingsURL = QString("http://%1:%2/sdrangel/deviceset/%3/channel/%4/settings") .arg(settings.m_reverseAPIAddress) .arg(settings.m_reverseAPIPort) .arg(settings.m_reverseAPIDeviceIndex) .arg(settings.m_reverseAPIChannelIndex); m_networkRequest.setUrl(QUrl(channelSettingsURL)); m_networkRequest.setHeader(QNetworkRequest::ContentTypeHeader, "application/json"); QBuffer *buffer=new QBuffer(); buffer->open((QBuffer::ReadWrite)); buffer->write(swgChannelSettings->asJson().toUtf8()); buffer->seek(0); // Always use PATCH to avoid passing reverse API settings m_networkManager->sendCustomRequest(m_networkRequest, "PATCH", buffer); delete swgChannelSettings; } void DSDDemod::networkManagerFinished(QNetworkReply *reply) { QNetworkReply::NetworkError replyError = reply->error(); if (replyError) { qWarning() << "DSDDemod::networkManagerFinished:" << " error(" << (int) replyError << "): " << replyError << ": " << reply->errorString(); return; } QString answer = reply->readAll(); answer.chop(1); // remove last \n qDebug("DSDDemod::networkManagerFinished: reply:\n%s", answer.toStdString().c_str()); }