CosinusProvider.cpp
95 lines
| 3.0 KiB
| text/x-c
|
CppLexer
Alexandre Leroux
|
r120 | #include "CosinusProvider.h" | ||
| #include <Data/DataProviderParameters.h> | ||||
| #include <Data/ScalarSeries.h> | ||||
| r127 | #include <cmath> | |||
| r276 | #include <QDateTime> | |||
| r394 | #include <QFuture> | |||
| r336 | #include <QThread> | |||
| r394 | #include <QtConcurrent/QtConcurrent> | |||
| r276 | ||||
| r215 | Q_LOGGING_CATEGORY(LOG_CosinusProvider, "CosinusProvider") | |||
| r394 | std::shared_ptr<IDataSeries> CosinusProvider::retrieveData(QUuid token, const SqpDateTime &dateTime) | |||
|
Alexandre Leroux
|
r120 | { | ||
| r394 | // TODO: Add Mutex | |||
| r276 | auto dataIndex = 0; | |||
| r215 | ||||
| // Gets the timerange from the parameters | ||||
| r276 | double freq = 100.0; | |||
| double start = dateTime.m_TStart * freq; // 100 htz | ||||
| double end = dateTime.m_TEnd * freq; // 100 htz | ||||
| r215 | ||||
| // We assure that timerange is valid | ||||
| if (end < start) { | ||||
| std::swap(start, end); | ||||
| } | ||||
| // Generates scalar series containing cosinus values (one value per second) | ||||
| auto scalarSeries | ||||
| = std::make_shared<ScalarSeries>(end - start, Unit{QStringLiteral("t"), true}, Unit{}); | ||||
| r394 | ||||
| int progress = 0; | ||||
| auto progressEnd = end - start; | ||||
| r215 | for (auto time = start; time < end; ++time, ++dataIndex) { | |||
| r394 | auto it = m_VariableToEnableProvider.find(token); | |||
| if (it != m_VariableToEnableProvider.end() && it.value()) { | ||||
| const auto timeOnFreq = time / freq; | ||||
| scalarSeries->setData(dataIndex, timeOnFreq, std::cos(timeOnFreq)); | ||||
| // progression | ||||
| int currentProgress = (time - start) * 100.0 / progressEnd; | ||||
| if (currentProgress != progress) { | ||||
| progress = currentProgress; | ||||
| emit dataProvidedProgress(token, progress); | ||||
| } | ||||
| } | ||||
| else { | ||||
| if (!it.value()) { | ||||
| qCDebug(LOG_CosinusProvider()) | ||||
| << "CosinusProvider::retrieveData: ARRET De l'acquisition detecté" | ||||
| << end - time; | ||||
| } | ||||
| } | ||||
| r215 | } | |||
| r394 | emit dataProvidedProgress(token, 0.0); | |||
|
Alexandre Leroux
|
r120 | return scalarSeries; | ||
| } | ||||
|
Alexandre Leroux
|
r287 | |||
|
Alexandre Leroux
|
r375 | void CosinusProvider::requestDataLoading(QUuid token, const DataProviderParameters ¶meters) | ||
|
Alexandre Leroux
|
r287 | { | ||
| r394 | // TODO: Add Mutex | |||
| m_VariableToEnableProvider[token] = true; | ||||
| r339 | qCDebug(LOG_CosinusProvider()) << "CosinusProvider::requestDataLoading" | |||
| << QThread::currentThread()->objectName(); | ||||
|
Alexandre Leroux
|
r287 | // NOTE: Try to use multithread if possible | ||
|
Alexandre Leroux
|
r375 | const auto times = parameters.m_Times; | ||
| r394 | ||||
|
Alexandre Leroux
|
r375 | for (const auto &dateTime : qAsConst(times)) { | ||
| r394 | if (m_VariableToEnableProvider[token]) { | |||
| auto scalarSeries = this->retrieveData(token, dateTime); | ||||
| emit dataProvided(token, scalarSeries, dateTime); | ||||
| } | ||||
|
Alexandre Leroux
|
r287 | } | ||
| } | ||||
| r388 | ||||
| void CosinusProvider::requestDataAborting(QUuid identifier) | ||||
| { | ||||
| r394 | // TODO: Add Mutex | |||
| qCDebug(LOG_CosinusProvider()) << "CosinusProvider::requestDataAborting" << identifier | ||||
| r398 | << QThread::currentThread()->objectName(); | |||
| r394 | auto it = m_VariableToEnableProvider.find(identifier); | |||
| if (it != m_VariableToEnableProvider.end()) { | ||||
| it.value() = false; | ||||
| } | ||||
| else { | ||||
| qCWarning(LOG_CosinusProvider()) | ||||
| << tr("Aborting progression of inexistant identifier detected !!!"); | ||||
| } | ||||
| r388 | } | |||
