/////////////////////////////////////////////////////////////////////////////////// // Copyright (C) 2017 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 "scopevisng.h" #include "dsp/dspcommands.h" #include "gui/glscopeng.h" MESSAGE_CLASS_DEFINITION(ScopeVisNG::MsgConfigureScopeVisNG, Message) MESSAGE_CLASS_DEFINITION(ScopeVisNG::MsgScopeVisNGAddTrigger, Message) MESSAGE_CLASS_DEFINITION(ScopeVisNG::MsgScopeVisNGChangeTrigger, Message) MESSAGE_CLASS_DEFINITION(ScopeVisNG::MsgScopeVisNGRemoveTrigger, Message) MESSAGE_CLASS_DEFINITION(ScopeVisNG::MsgScopeVisNGFocusOnTrigger, Message) MESSAGE_CLASS_DEFINITION(ScopeVisNG::MsgScopeVisNGAddTrace, Message) MESSAGE_CLASS_DEFINITION(ScopeVisNG::MsgScopeVisNGChangeTrace, Message) MESSAGE_CLASS_DEFINITION(ScopeVisNG::MsgScopeVisNGRemoveTrace, Message) MESSAGE_CLASS_DEFINITION(ScopeVisNG::MsgScopeVisNGFocusOnTrace, Message) const uint ScopeVisNG::m_traceChunkSize = 4800; ScopeVisNG::ScopeVisNG(GLScopeNG* glScope) : m_glScope(glScope), m_preTriggerDelay(0), m_currentTriggerIndex(0), m_focusedTriggerIndex(0), m_triggerState(TriggerUntriggered), m_focusedTraceIndex(0), m_traceSize(m_traceChunkSize), m_nbSamples(0), m_traceStart(true), m_traceFill(0), m_zTraceIndex(-1), m_timeOfsProMill(0), m_sampleRate(0), m_traceDiscreteMemory(10), m_freeRun(true), m_maxTraceDelay(0) { setObjectName("ScopeVisNG"); m_traceDiscreteMemory.resize(m_traceChunkSize); // arbitrary m_glScope->setTraces(&m_traces.m_tracesData, &m_traces.m_traces[0]); } ScopeVisNG::~ScopeVisNG() { } void ScopeVisNG::setSampleRate(int sampleRate) { if (sampleRate != m_sampleRate) { m_sampleRate = sampleRate; if (m_glScope) m_glScope->setSampleRate(m_sampleRate); } } void ScopeVisNG::configure(uint32_t traceSize, uint32_t timeOfsProMill, uint32_t triggerPre, bool freeRun) { Message* cmd = MsgConfigureScopeVisNG::create(traceSize, timeOfsProMill, triggerPre, freeRun); getInputMessageQueue()->push(cmd); } void ScopeVisNG::addTrace(const TraceData& traceData) { qDebug() << "ScopeVisNG::addTrace:" << " m_amp: " << traceData.m_amp << " m_ofs: " << traceData.m_ofs << " m_traceDelay: " << traceData.m_traceDelay; Message* cmd = MsgScopeVisNGAddTrace::create(traceData); getInputMessageQueue()->push(cmd); } void ScopeVisNG::changeTrace(const TraceData& traceData, uint32_t traceIndex) { qDebug() << "ScopeVisNG::changeTrace:" << " trace: " << traceIndex << " m_amp: " << traceData.m_amp << " m_ofs: " << traceData.m_ofs << " m_traceDelay: " << traceData.m_traceDelay; Message* cmd = MsgScopeVisNGChangeTrace::create(traceData, traceIndex); getInputMessageQueue()->push(cmd); } void ScopeVisNG::removeTrace(uint32_t traceIndex) { qDebug() << "ScopeVisNG::removeTrace:" << " trace: " << traceIndex; Message* cmd = MsgScopeVisNGRemoveTrace::create(traceIndex); getInputMessageQueue()->push(cmd); } void ScopeVisNG::focusOnTrace(uint32_t traceIndex) { Message* cmd = MsgScopeVisNGFocusOnTrace::create(traceIndex); getInputMessageQueue()->push(cmd); } void ScopeVisNG::addTrigger(const TriggerData& triggerData) { Message* cmd = MsgScopeVisNGAddTrigger::create(triggerData); getInputMessageQueue()->push(cmd); } void ScopeVisNG::changeTrigger(const TriggerData& triggerData, uint32_t triggerIndex) { Message* cmd = MsgScopeVisNGChangeTrigger::create(triggerData, triggerIndex); getInputMessageQueue()->push(cmd); } void ScopeVisNG::removeTrigger(uint32_t triggerIndex) { Message* cmd = MsgScopeVisNGRemoveTrigger::create(triggerIndex); getInputMessageQueue()->push(cmd); } void ScopeVisNG::focusOnTrigger(uint32_t triggerIndex) { Message* cmd = MsgScopeVisNGFocusOnTrigger::create(triggerIndex); getInputMessageQueue()->push(cmd); } void ScopeVisNG::feed(const SampleVector::const_iterator& cbegin, const SampleVector::const_iterator& end, bool positiveOnly) { if (m_freeRun) { m_triggerPoint = cbegin; } else if (m_triggerState == TriggerTriggered) { m_triggerPoint = cbegin; } else if (m_triggerState == TriggerUntriggered) { m_triggerPoint = end; } else if (m_triggerState == TriggerWait) { m_triggerPoint = end; } else { m_triggerPoint = cbegin; } // if (m_triggerState == TriggerNewConfig) // { // m_triggerState = TriggerUntriggered; // return; // } if ((m_triggerConditions.size() > 0) && (m_triggerState == TriggerWait)) { return; } if(!m_mutex.tryLock(2)) // prevent conflicts with configuration process return; SampleVector::const_iterator begin(cbegin); int triggerPointToEnd; while (begin < end) { if (begin + m_traceSize > end) { triggerPointToEnd = -1; processTrace(begin, end, triggerPointToEnd); if (triggerPointToEnd >= 0) { m_triggerPoint = end - triggerPointToEnd; } begin = end; } else { triggerPointToEnd = -1; processTrace(begin, begin + m_traceSize, triggerPointToEnd); if (triggerPointToEnd >= 0) { m_triggerPoint = begin + m_traceSize -triggerPointToEnd; } begin += m_traceSize; } } m_mutex.unlock(); } void ScopeVisNG::processTrace(const SampleVector::const_iterator& cbegin, const SampleVector::const_iterator& end, int& triggerPointToEnd) { SampleVector::const_iterator begin(cbegin); // memory storage m_traceDiscreteMemory.current().write(cbegin, end); if (m_traceDiscreteMemory.current().absoluteFill() < m_traceSize) { return; // not enough samples in memory } // trigger process if ((m_freeRun) || (m_triggerConditions.size() == 0)) // immediate re-trigger { if (m_triggerState == TriggerUntriggered) { m_traceStart = true; // start trace processing m_nbSamples = m_traceSize + m_maxTraceDelay; m_triggerState = TriggerTriggered; } } else { if ((m_triggerState == TriggerUntriggered) || (m_triggerState == TriggerDelay)) { TriggerCondition& triggerCondition = m_triggerConditions[m_currentTriggerIndex]; // current trigger condition while (begin < end) { if (m_triggerState == TriggerDelay) { if (triggerCondition.m_triggerDelayCount > 0) // skip samples during delay period { triggerCondition.m_triggerDelayCount--; ++begin; continue; } else // process trigger { if (nextTrigger()) // move to next trigger and keep going { m_triggerComparator.reset(); m_triggerState = TriggerUntriggered; ++begin; continue; } else // this was the last trigger then start trace { m_traceStart = true; // start trace processing m_nbSamples = m_traceSize + m_maxTraceDelay; m_triggerComparator.reset(); m_triggerState = TriggerTriggered; triggerPointToEnd = end - begin; break; } } } // look for trigger if (m_triggerComparator.triggered(*begin, triggerCondition)) { if (triggerCondition.m_triggerData.m_triggerDelay > 0) { triggerCondition.m_triggerDelayCount = triggerCondition.m_triggerData.m_triggerDelay; // initialize delayed samples counter m_triggerState = TriggerDelay; ++begin; continue; } if (nextTrigger()) // move to next trigger and keep going { m_triggerComparator.reset(); m_triggerState = TriggerUntriggered; } else // this was the last trigger then start trace { m_traceStart = true; // start trace processing m_nbSamples = m_traceSize + m_maxTraceDelay; m_triggerComparator.reset(); m_triggerState = TriggerTriggered; triggerPointToEnd = end - begin; break; } } ++begin; } } } // trace process if (m_glScope->getDataChanged()) // optimization: process trace only if required by glScope { m_triggerState = TriggerUntriggered; } if (m_triggerState == TriggerTriggered) { int remainder = -1; int count = end - begin; // number of samples in traceback buffer past the current point SampleVector::iterator mend = m_traceDiscreteMemory.current().current(); SampleVector::iterator mbegin = mend - count; if (m_traceStart) { // trace back if (m_maxTraceDelay > 0) { processTraces(mbegin - m_preTriggerDelay - m_maxTraceDelay, mbegin - m_preTriggerDelay, true); } // pre-trigger if (m_preTriggerDelay > 0) { remainder = processTraces(mbegin - m_preTriggerDelay, mbegin); } m_traceStart = false; } if (remainder < 0) { // live trace remainder = processTraces(mbegin, mend); } if (remainder >= 0) // finished { mbegin = mend - remainder; m_traceDiscreteMemory.current().m_endPoint = mbegin; m_traceDiscreteMemory.store(); // next memory trace m_triggerState = TriggerUntriggered; //if (m_glScope) m_glScope->incrementTraceCounter(); // process remainder recursively if (remainder != 0) { int mTriggerPointToEnd = -1; processTrace(mbegin, mend, mTriggerPointToEnd); if (mTriggerPointToEnd >= 0) { triggerPointToEnd = mTriggerPointToEnd; } //qDebug("ScopeVisNG::processTrace: process remainder recursively (%d %d)", mpoint, mTriggerPoint); } } } } bool ScopeVisNG::nextTrigger() { TriggerCondition& triggerCondition = m_triggerConditions[m_currentTriggerIndex]; // current trigger condition if (triggerCondition.m_triggerData.m_triggerRepeat > 0) { if (triggerCondition.m_triggerCounter < triggerCondition.m_triggerData.m_triggerRepeat) { triggerCondition.m_triggerCounter++; return true; // not final keep going } else { triggerCondition.m_triggerCounter = 0; // reset for next time } } if (m_currentTriggerIndex < m_triggerConditions.size() - 1) // check if next trigger is available { m_currentTriggerIndex++; return true; // not final keep going } else { // now this is really finished m_currentTriggerIndex = 0; return false; // final } } int ScopeVisNG::processTraces(const SampleVector::const_iterator& cbegin, const SampleVector::const_iterator& end, bool traceBack) { SampleVector::const_iterator begin(cbegin); int shift = (m_timeOfsProMill / 1000.0) * m_traceSize; while ((begin < end) && (m_nbSamples > 0)) { std::vector::iterator itCtl = m_traces.m_tracesControl.begin(); std::vector::iterator itData = m_traces.m_tracesData.begin(); std::vector::iterator itTrace = m_traces.m_traces[m_traces.currentBufferIndex()].begin(); for (; itCtl != m_traces.m_tracesControl.end(); ++itCtl, ++itData, ++itTrace) { if (traceBack && ((end - begin) > itData->m_traceDelay)) { // before start of trace continue; } if (itCtl->m_traceCount[m_traces.currentBufferIndex()] < m_traceSize) { ProjectionType projectionType = itData->m_projectionType; float v; if (projectionType == ProjectionMagLin) { v = (itCtl->m_projector.run(*begin) - itData->m_ofs)*itData->m_amp - 1.0f; } else if (projectionType == ProjectionMagDB) { // there is no processing advantage in direct calculation without projector // uint32_t magsq = begin->m_real*begin->m_real + begin->m_imag*begin->m_imag; // v = ((log10f(magsq/1073741824.0f)*0.2f - 2.0f*itData->m_ofs) + 2.0f)*itData->m_amp - 1.0f; float p = itCtl->m_projector.run(*begin) - (100.0f * itData->m_ofs); v = ((p/50.0f) + 2.0f)*itData->m_amp - 1.0f; } else { v = (itCtl->m_projector.run(*begin) - itData->m_ofs) * itData->m_amp; } if(v > 1.0f) { v = 1.0f; } else if (v < -1.0f) { v = -1.0f; } (*itTrace)[2*(itCtl->m_traceCount[m_traces.currentBufferIndex()])] = (itCtl->m_traceCount[m_traces.currentBufferIndex()] - shift); // display x (*itTrace)[2*(itCtl->m_traceCount[m_traces.currentBufferIndex()]) + 1] = v; // display y itCtl->m_traceCount[m_traces.currentBufferIndex()]++; } } ++begin; m_nbSamples--; } if (m_nbSamples == 0) // finished { //sqDebug("ScopeVisNG::processTraces: m_traceCount: %d", m_traces.m_tracesControl.begin()->m_traceCount[m_traces.currentBufferIndex()]); m_glScope->newTraces(&m_traces.m_traces[m_traces.currentBufferIndex()]); m_traces.switchBuffer(); return end - begin; // return remainder count } else { return -1; // mark not finished } } void ScopeVisNG::start() { } void ScopeVisNG::stop() { } bool ScopeVisNG::handleMessage(const Message& message) { qDebug() << "ScopeVisNG::handleMessage" << message.getIdentifier(); if (DSPSignalNotification::match(message)) { DSPSignalNotification& notif = (DSPSignalNotification&) message; setSampleRate(notif.getSampleRate()); qDebug() << "ScopeVisNG::handleMessage: DSPSignalNotification: m_sampleRate: " << m_sampleRate; return true; } else if (MsgConfigureScopeVisNG::match(message)) { QMutexLocker configLocker(&m_mutex); MsgConfigureScopeVisNG& conf = (MsgConfigureScopeVisNG&) message; uint32_t traceSize = conf.getTraceSize(); uint32_t timeOfsProMill = conf.getTimeOfsProMill(); uint32_t triggerPre = conf.getTriggerPre(); bool freeRun = conf.getFreeRun(); if (m_traceSize != traceSize) { m_traceSize = traceSize; m_traces.resize(m_traceSize); m_traceDiscreteMemory.resize(m_traceSize); initTraceBuffers(); if (m_glScope) { m_glScope->setTraceSize(m_traceSize); } } if (m_timeOfsProMill != timeOfsProMill) { m_timeOfsProMill = timeOfsProMill; if (m_glScope) { m_glScope->setTimeOfsProMill(m_timeOfsProMill); } } if (m_preTriggerDelay != triggerPre) { m_preTriggerDelay = triggerPre; m_glScope->setTriggerPre(m_preTriggerDelay); } if (freeRun != m_freeRun) { m_freeRun = freeRun; } qDebug() << "ScopeVisNG::handleMessage: MsgConfigureScopeVisNG:" << " m_traceSize: " << m_traceSize << " m_timeOfsProMill: " << m_timeOfsProMill << " m_preTriggerDelay: " << m_preTriggerDelay << " m_freeRun: " << m_freeRun; return true; } else if (MsgScopeVisNGAddTrigger::match(message)) { QMutexLocker configLocker(&m_mutex); MsgScopeVisNGAddTrigger& conf = (MsgScopeVisNGAddTrigger&) message; m_triggerConditions.push_back(TriggerCondition(conf.getTriggerData())); m_triggerConditions.back().initProjector(); return true; } else if (MsgScopeVisNGChangeTrigger::match(message)) { QMutexLocker configLocker(&m_mutex); MsgScopeVisNGChangeTrigger& conf = (MsgScopeVisNGChangeTrigger&) message; int triggerIndex = conf.getTriggerIndex(); if (triggerIndex < m_triggerConditions.size()) { m_triggerConditions[triggerIndex].setData(conf.getTriggerData()); if (triggerIndex == m_focusedTriggerIndex) { computeDisplayTriggerLevels(); m_glScope->setFocusedTriggerData(m_triggerConditions[m_focusedTriggerIndex].m_triggerData); m_glScope->updateDisplay(); } } return true; } else if (MsgScopeVisNGRemoveTrigger::match(message)) { QMutexLocker configLocker(&m_mutex); MsgScopeVisNGRemoveTrigger& conf = (MsgScopeVisNGRemoveTrigger&) message; int triggerIndex = conf.getTriggerIndex(); if (triggerIndex < m_triggerConditions.size()) { m_triggerConditions.erase(m_triggerConditions.begin() + triggerIndex); } return true; } else if (MsgScopeVisNGFocusOnTrigger::match(message)) { MsgScopeVisNGFocusOnTrigger& conf = (MsgScopeVisNGFocusOnTrigger&) message; int triggerIndex = conf.getTriggerIndex(); if (triggerIndex < m_triggerConditions.size()) { m_focusedTriggerIndex = triggerIndex; computeDisplayTriggerLevels(); m_glScope->setFocusedTriggerData(m_triggerConditions[m_focusedTriggerIndex].m_triggerData); m_glScope->updateDisplay(); } return true; } else if (MsgScopeVisNGAddTrace::match(message)) { QMutexLocker configLocker(&m_mutex); MsgScopeVisNGAddTrace& conf = (MsgScopeVisNGAddTrace&) message; m_traces.addTrace(conf.getTraceData(), m_traceSize); initTraceBuffers(); updateMaxTraceDelay(); computeDisplayTriggerLevels(); m_glScope->updateDisplay(); return true; } else if (MsgScopeVisNGChangeTrace::match(message)) { QMutexLocker configLocker(&m_mutex); MsgScopeVisNGChangeTrace& conf = (MsgScopeVisNGChangeTrace&) message; bool doComputeTriggerLevelsOnDisplay = m_traces.isVerticalDisplayChange(conf.getTraceData(), conf.getTraceIndex()); m_traces.changeTrace(conf.getTraceData(), conf.getTraceIndex()); updateMaxTraceDelay(); if (doComputeTriggerLevelsOnDisplay) computeDisplayTriggerLevels(); m_glScope->updateDisplay(); return true; } else if (MsgScopeVisNGRemoveTrace::match(message)) { QMutexLocker configLocker(&m_mutex); MsgScopeVisNGRemoveTrace& conf = (MsgScopeVisNGRemoveTrace&) message; m_traces.removeTrace(conf.getTraceIndex()); updateMaxTraceDelay(); computeDisplayTriggerLevels(); m_glScope->updateDisplay(); return true; } else if (MsgScopeVisNGFocusOnTrace::match(message)) { MsgScopeVisNGFocusOnTrace& conf = (MsgScopeVisNGFocusOnTrace&) message; int traceIndex = conf.getTraceIndex(); if (traceIndex < m_traces.m_tracesData.size()) { m_focusedTraceIndex = traceIndex; computeDisplayTriggerLevels(); m_glScope->setFocusedTraceIndex(m_focusedTraceIndex); m_glScope->updateDisplay(); } return true; } else { return false; } } void ScopeVisNG::updateMaxTraceDelay() { int maxTraceDelay = 0; bool allocateCache = false; uint32_t projectorCounts[(int) nbProjectionTypes]; memset(projectorCounts, 0, ((int) nbProjectionTypes)*sizeof(uint32_t)); std::vector::iterator itData = m_traces.m_tracesData.begin(); std::vector::iterator itCtrl = m_traces.m_tracesControl.begin(); for (; itData != m_traces.m_tracesData.end(); ++itData, ++itCtrl) { if (itData->m_traceDelay > maxTraceDelay) { maxTraceDelay = itData->m_traceDelay; } if (projectorCounts[(int) itData->m_projectionType] > 0) { allocateCache = true; itCtrl->m_projector.setCacheMaster(false); } else { itCtrl->m_projector.setCacheMaster(true); } projectorCounts[(int) itData->m_projectionType]++; } itCtrl = m_traces.m_tracesControl.begin(); for (; itCtrl != m_traces.m_tracesControl.end(); ++itCtrl) { if (allocateCache) { itCtrl->m_projector.setCache(m_projectorCache); } else { itCtrl->m_projector.setCache(0); } } m_maxTraceDelay = maxTraceDelay; } void ScopeVisNG::initTraceBuffers() { int shift = (m_timeOfsProMill / 1000.0) * m_traceSize; std::vector::iterator it0 = m_traces.m_traces[0].begin(); std::vector::iterator it1 = m_traces.m_traces[1].begin(); for (; it0 != m_traces.m_traces[0].end(); ++it0, ++it1) { for (int i = 0; i < m_traceSize; i++) { (*it0)[2*i] = (i - shift); // display x (*it0)[2*i + 1] = 0.0f; // display y (*it1)[2*i] = (i - shift); // display x (*it1)[2*i + 1] = 0.0f; // display y } } } void ScopeVisNG::computeDisplayTriggerLevels() { std::vector::iterator itData = m_traces.m_tracesData.begin(); for (; itData != m_traces.m_tracesData.end(); ++itData) { if ((m_focusedTriggerIndex < m_triggerConditions.size()) && (m_triggerConditions[m_focusedTriggerIndex].m_projector.getProjectionType() == itData->m_projectionType)) { float level = m_triggerConditions[m_focusedTriggerIndex].m_triggerData.m_triggerLevel; float levelPowerLin = level + 1.0f; float levelPowerdB = (100.0f * (level - 1.0f)); float v; if (itData->m_projectionType == ProjectionMagLin) { v = (levelPowerLin - itData->m_ofs)*itData->m_amp - 1.0f; } else if (itData->m_projectionType == ProjectionMagDB) { float ofsdB = itData->m_ofs * 100.0f; v = ((levelPowerdB + 100.0f - ofsdB)*itData->m_amp)/50.0f - 1.0f; } else { v = (level - itData->m_ofs) * itData->m_amp; } if(v > 1.0f) { v = 1.0f; } else if (v < -1.0f) { v = -1.0f; } itData->m_triggerDisplayLevel = v; } else { itData->m_triggerDisplayLevel = 2.0f; } } }