##// END OF EJS Templates
HG_REPOSITORIES » LPP » SciQLOP_Repos » SciQLop
RSS
Exports core module as a shared library...
Exports core module as a shared library Export will be necessary to use anywhere constants that will be defined in core module (used for settings)
Alexandre Leroux - - Load All Authors

File last commit:

r452:158d38bb6d5a
r461:b8af3b4730c2
Show More
CosinusProvider.cpp
101 lines | 3.3 KiB | text/x-c | CppLexer
/ plugins / mockplugin / src / CosinusProvider.cpp
History | Source | Raw |Copy content |Copy permalink
Alexandre Leroux
Creates a default provider that will be returned by the mock plugin
 r128 #include "CosinusProvider.h"
#include <Data/DataProviderParameters.h>
#include <Data/ScalarSeries.h>
perrinel
Add cmath header missing
 r135 #include <cmath>
perrinel
Fix the cosinus bug....
 r298 #include <QDateTime>
perrinel
Add DownloadProgress emission for mock plugin
 r428 #include <QFuture>
perrinel
Add current progression for thread fix
 r364 #include <QThread>
perrinel
Add DownloadProgress emission for mock plugin
 r428 #include <QtConcurrent/QtConcurrent>
perrinel
Fix the cosinus bug....
 r298
perrinel
The cosinus provider can now handle data request
 r231 Q_LOGGING_CATEGORY(LOG_CosinusProvider, "CosinusProvider")
perrinel
Add DownloadProgress emission for mock plugin
 r428 std::shared_ptr<IDataSeries> CosinusProvider::retrieveData(QUuid token, const SqpDateTime &dateTime)
Alexandre Leroux
Creates a default provider that will be returned by the mock plugin
 r128 {
perrinel
Add DownloadProgress emission for mock plugin
 r428 // TODO: Add Mutex
perrinel
Fix the cosinus bug....
 r298 auto dataIndex = 0;
perrinel
The cosinus provider can now handle data request
 r231
// Gets the timerange from the parameters
perrinel
Fix the cosinus bug....
 r298 double freq = 100.0;
Alexandre Leroux
Updates cosinus provider...
 r452 double start = std::ceil(dateTime.m_TStart * freq); // 100 htz
double end = std::floor(dateTime.m_TEnd * freq); // 100 htz
perrinel
The cosinus provider can now handle data request
 r231
// We assure that timerange is valid
if (end < start) {
std::swap(start, end);
}
// Generates scalar series containing cosinus values (one value per second)
Alexandre Leroux
Updates cosinus provider...
 r452 auto dataCount = end - start;
perrinel
The cosinus provider can now handle data request
 r231
Alexandre Leroux
Updates cosinus provider...
 r452 auto xAxisData = QVector<double>{};
xAxisData.resize(dataCount);
auto valuesData = QVector<double>{};
valuesData.resize(dataCount);
perrinel
Add DownloadProgress emission for mock plugin
 r428
int progress = 0;
Alexandre Leroux
Updates cosinus provider...
 r452 auto progressEnd = dataCount;
perrinel
The cosinus provider can now handle data request
 r231 for (auto time = start; time < end; ++time, ++dataIndex) {
perrinel
Add DownloadProgress emission for mock plugin
 r428 auto it = m_VariableToEnableProvider.find(token);
if (it != m_VariableToEnableProvider.end() && it.value()) {
const auto timeOnFreq = time / freq;
Alexandre Leroux
Updates cosinus provider...
 r452
xAxisData.replace(dataIndex, timeOnFreq);
valuesData.replace(dataIndex, std::cos(timeOnFreq));
perrinel
Add DownloadProgress emission for mock plugin
 r428
// 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;
}
}
perrinel
The cosinus provider can now handle data request
 r231 }
perrinel
Add DownloadProgress emission for mock plugin
 r428 emit dataProvidedProgress(token, 0.0);
Alexandre Leroux
Updates cosinus provider...
 r452 return std::make_shared<ScalarSeries>(std::move(xAxisData), std::move(valuesData),
Unit{QStringLiteral("t"), true}, Unit{});
Alexandre Leroux
Creates a default provider that will be returned by the mock plugin
 r128 }
Alexandre Leroux
Use std::shared_ptr in CosinusProvider
 r310
Alexandre Leroux
Updates IDataProvider::requestDataLoading() method's signature...
 r408 void CosinusProvider::requestDataLoading(QUuid token, const DataProviderParameters &parameters)
Alexandre Leroux
Use std::shared_ptr in CosinusProvider
 r310 {
perrinel
Add DownloadProgress emission for mock plugin
 r428 // TODO: Add Mutex
m_VariableToEnableProvider[token] = true;
perrinel
Change info to debug on thread display log
 r367 qCDebug(LOG_CosinusProvider()) << "CosinusProvider::requestDataLoading"
<< QThread::currentThread()->objectName();
Alexandre Leroux
Use std::shared_ptr in CosinusProvider
 r310 // NOTE: Try to use multithread if possible
Alexandre Leroux
Updates IDataProvider::requestDataLoading() method's signature...
 r408 const auto times = parameters.m_Times;
perrinel
Add DownloadProgress emission for mock plugin
 r428
Alexandre Leroux
Updates IDataProvider::requestDataLoading() method's signature...
 r408 for (const auto &dateTime : qAsConst(times)) {
perrinel
Add DownloadProgress emission for mock plugin
 r428 if (m_VariableToEnableProvider[token]) {
auto scalarSeries = this->retrieveData(token, dateTime);
emit dataProvided(token, scalarSeries, dateTime);
}
Alexandre Leroux
Use std::shared_ptr in CosinusProvider
 r310 }
}
perrinel
Implement of the abort download process
 r422
void CosinusProvider::requestDataAborting(QUuid identifier)
{
perrinel
Add DownloadProgress emission for mock plugin
 r428 // TODO: Add Mutex
qCDebug(LOG_CosinusProvider()) << "CosinusProvider::requestDataAborting" << identifier
perrinel
Remove abort button validity when the progress is finished (eg. == 0)
 r432 << QThread::currentThread()->objectName();
perrinel
Add DownloadProgress emission for mock plugin
 r428 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 !!!");
}
perrinel
Implement of the abort download process
 r422 }