GIT_REPOSITORIES/LPP/Users/mperrinel/SciQLop-fork Files · plugins/mockplugin/src/CosinusProvider.cpp

Improves AMDA result parsing...

Improves AMDA result parsing Finds the unit among all the commented lines, in order to handle the case where the number of commented lines differs from one file to another

Alexandre Leroux - - Load All Authors

File last commit:

r491:0877c365bd5c


                r492:41e897ecff03

Download file

             CosinusProvider.cpp
        
                    100 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
    
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
            
      }

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages

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 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	}