CosinusProvider.cpp
124 lines
| 4.5 KiB
| text/x-c
|
CppLexer
Alexandre Leroux
|
r128 | #include "CosinusProvider.h" | ||
|
Alexandre Leroux
|
r782 | #include "MockDefs.h" | ||
|
Alexandre Leroux
|
r128 | |||
| #include <Data/DataProviderParameters.h> | ||||
| #include <Data/ScalarSeries.h> | ||||
| r135 | #include <cmath> | |||
| r428 | #include <QFuture> | |||
| r364 | #include <QThread> | |||
| r428 | #include <QtConcurrent/QtConcurrent> | |||
| r298 | ||||
| r231 | Q_LOGGING_CATEGORY(LOG_CosinusProvider, "CosinusProvider") | |||
|
Alexandre Leroux
|
r712 | std::shared_ptr<IDataProvider> CosinusProvider::clone() const | ||
| { | ||||
| // No copy is made in clone | ||||
| return std::make_shared<CosinusProvider>(); | ||||
| } | ||||
| r539 | std::shared_ptr<IDataSeries> CosinusProvider::retrieveData(QUuid acqIdentifier, | |||
|
Alexandre Leroux
|
r781 | const SqpRange &dataRangeRequested, | ||
| const QVariantHash &data) | ||||
|
Alexandre Leroux
|
r128 | { | ||
| r428 | // TODO: Add Mutex | |||
| r298 | auto dataIndex = 0; | |||
| r231 | ||||
|
Alexandre Leroux
|
r782 | // Retrieves frequency | ||
| auto freqVariant = data.value(COSINUS_FREQUENCY_KEY, COSINUS_FREQUENCY_DEFAULT_VALUE); | ||||
| if (!freqVariant.canConvert<double>()) { | ||||
| qCCritical(LOG_CosinusProvider()) << tr("Can't retrieve data: invalid frequency"); | ||||
| return nullptr; | ||||
| } | ||||
| r231 | // Gets the timerange from the parameters | |||
|
Alexandre Leroux
|
r782 | double freq = freqVariant.toDouble(); | ||
| double start = std::ceil(dataRangeRequested.m_TStart * freq); | ||||
| double end = std::floor(dataRangeRequested.m_TEnd * freq); | ||||
| r231 | ||||
| // We assure that timerange is valid | ||||
| if (end < start) { | ||||
| std::swap(start, end); | ||||
| } | ||||
|
Alexandre Leroux
|
r745 | // Generates scalar series containing cosinus values (one value per second, end value is | ||
| // included) | ||||
| auto dataCount = end - start + 1; | ||||
| r231 | ||||
|
Alexandre Leroux
|
r694 | auto xAxisData = std::vector<double>{}; | ||
|
Alexandre Leroux
|
r452 | xAxisData.resize(dataCount); | ||
|
Alexandre Leroux
|
r694 | auto valuesData = std::vector<double>{}; | ||
|
Alexandre Leroux
|
r452 | valuesData.resize(dataCount); | ||
| r428 | ||||
| int progress = 0; | ||||
|
Alexandre Leroux
|
r452 | auto progressEnd = dataCount; | ||
|
Alexandre Leroux
|
r745 | for (auto time = start; time <= end; ++time, ++dataIndex) { | ||
| r539 | auto it = m_VariableToEnableProvider.find(acqIdentifier); | |||
| r428 | if (it != m_VariableToEnableProvider.end() && it.value()) { | |||
| const auto timeOnFreq = time / freq; | ||||
|
Alexandre Leroux
|
r452 | |||
|
Alexandre Leroux
|
r694 | xAxisData[dataIndex] = timeOnFreq; | ||
| valuesData[dataIndex] = std::cos(timeOnFreq); | ||||
| r428 | ||||
| // progression | ||||
| int currentProgress = (time - start) * 100.0 / progressEnd; | ||||
| if (currentProgress != progress) { | ||||
| progress = currentProgress; | ||||
| r539 | emit dataProvidedProgress(acqIdentifier, progress); | |||
| r750 | qCInfo(LOG_CosinusProvider()) << "TORM: CosinusProvider::retrieveData" | |||
| << QThread::currentThread()->objectName() << progress; | ||||
| // NOTE: Try to use multithread if possible | ||||
| r428 | } | |||
| } | ||||
| else { | ||||
| if (!it.value()) { | ||||
| qCDebug(LOG_CosinusProvider()) | ||||
| << "CosinusProvider::retrieveData: ARRET De l'acquisition detecté" | ||||
| << end - time; | ||||
| } | ||||
| } | ||||
| r231 | } | |||
| r750 | if (progress != 100) { | |||
| // We can close progression beacause all data has been retrieved | ||||
| emit dataProvidedProgress(acqIdentifier, 100); | ||||
| } | ||||
|
Alexandre Leroux
|
r452 | return std::make_shared<ScalarSeries>(std::move(xAxisData), std::move(valuesData), | ||
| Unit{QStringLiteral("t"), true}, Unit{}); | ||||
|
Alexandre Leroux
|
r128 | } | ||
|
Alexandre Leroux
|
r310 | |||
| r539 | void CosinusProvider::requestDataLoading(QUuid acqIdentifier, | |||
| const DataProviderParameters ¶meters) | ||||
|
Alexandre Leroux
|
r310 | { | ||
| r428 | // TODO: Add Mutex | |||
| r539 | m_VariableToEnableProvider[acqIdentifier] = true; | |||
| r548 | qCDebug(LOG_CosinusProvider()) << "TORM: CosinusProvider::requestDataLoading" | |||
| r367 | << QThread::currentThread()->objectName(); | |||
|
Alexandre Leroux
|
r310 | // NOTE: Try to use multithread if possible | ||
|
Alexandre Leroux
|
r408 | const auto times = parameters.m_Times; | ||
| r428 | ||||
|
Alexandre Leroux
|
r408 | for (const auto &dateTime : qAsConst(times)) { | ||
| r539 | if (m_VariableToEnableProvider[acqIdentifier]) { | |||
|
Alexandre Leroux
|
r781 | auto scalarSeries = this->retrieveData(acqIdentifier, dateTime, parameters.m_Data); | ||
| r548 | qCDebug(LOG_CosinusProvider()) << "TORM: CosinusProvider::dataProvided"; | |||
| r539 | emit dataProvided(acqIdentifier, scalarSeries, dateTime); | |||
| r428 | } | |||
|
Alexandre Leroux
|
r310 | } | ||
| } | ||||
| r422 | ||||
| r539 | void CosinusProvider::requestDataAborting(QUuid acqIdentifier) | |||
| r422 | { | |||
| r428 | // TODO: Add Mutex | |||
| r539 | qCDebug(LOG_CosinusProvider()) << "CosinusProvider::requestDataAborting" << acqIdentifier | |||
| r432 | << QThread::currentThread()->objectName(); | |||
| r539 | auto it = m_VariableToEnableProvider.find(acqIdentifier); | |||
| r428 | if (it != m_VariableToEnableProvider.end()) { | |||
| it.value() = false; | ||||
| } | ||||
| else { | ||||
| qCWarning(LOG_CosinusProvider()) | ||||
| << tr("Aborting progression of inexistant identifier detected !!!"); | ||||
| } | ||||
| r422 | } | |||
