HG_REPOSITORIES/LPP/SciQLOP_Repos/SciQLop Files · core/src/Variable/VariableAcquisitionWorker.cpp

Uses new iterator in DataSeries.cpp...

Uses new iterator in DataSeries.cpp The code of the old iterator is deleted. The new iterator is now built from the Implementation of DataSeriesIteratorValue :: Impl for a DataSeries

perrinel - - Load All Authors

File last commit:

r545:4905fe79fee7


                r596:96f73c42ec59

Download file

             VariableAcquisitionWorker.cpp
        
                    225 lines
            
             | 8.7 KiB
            
                | text/x-c
            
             |
                CppLexer
            
             / core / src / Variable / VariableAcquisitionWorker.cpp
          
                    History
                
                 |
                  Source
                 | Raw
                 |Copy content
                 |Copy permalink

        perrinel
    
Add empty class VariableAcquisitionWorker

              r527
            
      #include "Variable/VariableAcquisitionWorker.h"

      #include "Variable/Variable.h"

        perrinel
    
Implementation of V5 acquisition

              r539
            
      #include <Data/AcquisitionRequest.h>

      #include <Data/SqpRange.h>

        perrinel
    
Add empty class VariableAcquisitionWorker

              r527
            
      #include <unordered_map>

        perrinel
    
Implementation of V5 acquisition

              r539
            
      #include <utility>

        perrinel
    
Add empty class VariableAcquisitionWorker

              r527
            
        perrinel
    
Implementation of V5 acquisition

              r539
            
      #include <QMutex>

      #include <QReadWriteLock>

        perrinel
    
Add empty class VariableAcquisitionWorker

              r527
            
      #include <QThread>

        perrinel
    
Implementation of V5 acquisition

              r539
            
        perrinel
    
Add empty class VariableAcquisitionWorker

              r527
            
      Q_LOGGING_CATEGORY(LOG_VariableAcquisitionWorker, "VariableAcquisitionWorker")

      struct VariableAcquisitionWorker::VariableAcquisitionWorkerPrivate {

        perrinel
    
Implementation of V5 acquisition

              r539
            
          explicit VariableAcquisitionWorkerPrivate() : m_Lock{QReadWriteLock::Recursive} {}

          void lockRead() { m_Lock.lockForRead(); }

          void lockWrite() { m_Lock.lockForWrite(); }

          void unlock() { m_Lock.unlock(); }

          void removeVariableRequest(QUuid vIdentifier);

          QMutex m_WorkingMutex;

          QReadWriteLock m_Lock;

          std::map<QUuid, QVector<AcquisitionDataPacket> > m_AcqIdentifierToAcqDataPacketVectorMap;

          std::map<QUuid, AcquisitionRequest> m_AcqIdentifierToAcqRequestMap;

          std::map<QUuid, std::pair<QUuid, QUuid> > m_VIdentifierToCurrrentAcqIdNextIdPairMap;

        perrinel
    
Add empty class VariableAcquisitionWorker

              r527
            
      };

      VariableAcquisitionWorker::VariableAcquisitionWorker(QObject *parent)

              : QObject{parent}, impl{spimpl::make_unique_impl<VariableAcquisitionWorkerPrivate>()}

      {

      }

        perrinel
    
Implementation of V5 acquisition

              r539
            
      VariableAcquisitionWorker::~VariableAcquisitionWorker()

      {

          qCInfo(LOG_VariableAcquisitionWorker()) << tr("VariableAcquisitionWorker destruction")

                                                  << QThread::currentThread();

          this->waitForFinish();

      }

      void VariableAcquisitionWorker::pushVariableRequest(QUuid vIdentifier, SqpRange rangeRequested,

        perrinel
    
Add empty class VariableAcquisitionWorker

              r527
            
                                                          SqpRange cacheRangeRequested,

                                                          DataProviderParameters parameters,

        perrinel
    
Implementation of V5 acquisition

              r539
            
                                                          std::shared_ptr<IDataProvider> provider)

      {

        perrinel
    
The dataSeries of a variable is now shared istead of uniq to avoid...

              r542
            
          qCInfo(LOG_VariableAcquisitionWorker())

        perrinel
    
Implementation of V5 acquisition

              r539
            
              << tr("TORM VariableAcquisitionWorker::pushVariableRequest ") << cacheRangeRequested;

          // Request creation

          auto acqRequest = AcquisitionRequest{};

          acqRequest.m_vIdentifier = vIdentifier;

          acqRequest.m_DataProviderParameters = parameters;

          acqRequest.m_RangeRequested = rangeRequested;

          acqRequest.m_CacheRangeRequested = cacheRangeRequested;

          acqRequest.m_Size = parameters.m_Times.size();

          acqRequest.m_Provider = provider;

          // Register request

          impl->lockWrite();

          impl->m_AcqIdentifierToAcqRequestMap.insert(

              std::make_pair(acqRequest.m_AcqIdentifier, acqRequest));

          auto it = impl->m_VIdentifierToCurrrentAcqIdNextIdPairMap.find(vIdentifier);

          if (it != impl->m_VIdentifierToCurrrentAcqIdNextIdPairMap.cend()) {

              // A current request already exists, we can replace the next one

              it->second.second = acqRequest.m_AcqIdentifier;

              impl->unlock();

          }

          else {

              // First request for the variable, it must be stored and executed

              impl->m_VIdentifierToCurrrentAcqIdNextIdPairMap.insert(

                  std::make_pair(vIdentifier, std::make_pair(acqRequest.m_AcqIdentifier, QUuid())));

              impl->unlock();

              QMetaObject::invokeMethod(this, "onExecuteRequest", Qt::QueuedConnection,

                                        Q_ARG(QUuid, acqRequest.m_AcqIdentifier));

          }

      }

      void VariableAcquisitionWorker::abortProgressRequested(QUuid vIdentifier)

      {

          // TODO

      }

      void VariableAcquisitionWorker::onVariableRetrieveDataInProgress(QUuid acqIdentifier,

                                                                       double progress)

      {

          // TODO

      }

      void VariableAcquisitionWorker::onVariableDataAcquired(QUuid acqIdentifier,

                                                             std::shared_ptr<IDataSeries> dataSeries,

                                                             SqpRange dataRangeAcquired)

        perrinel
    
Add empty class VariableAcquisitionWorker

              r527
            
      {

        perrinel
    
Implementation of V5 acquisition

              r539
            
          qCDebug(LOG_VariableAcquisitionWorker()) << tr("onVariableDataAcquired on range ")

                                                   << acqIdentifier << dataRangeAcquired;

          impl->lockWrite();

          auto aIdToARit = impl->m_AcqIdentifierToAcqRequestMap.find(acqIdentifier);

          if (aIdToARit != impl->m_AcqIdentifierToAcqRequestMap.cend()) {

              // Store the result

              auto dataPacket = AcquisitionDataPacket{};

              dataPacket.m_Range = dataRangeAcquired;

              dataPacket.m_DateSeries = dataSeries;

              auto aIdToADPVit = impl->m_AcqIdentifierToAcqDataPacketVectorMap.find(acqIdentifier);

              if (aIdToADPVit != impl->m_AcqIdentifierToAcqDataPacketVectorMap.cend()) {

                  // A current request result already exists, we can update it

                  aIdToADPVit->second.push_back(dataPacket);

              }

              else {

                  // First request result for the variable, it must be stored

                  impl->m_AcqIdentifierToAcqDataPacketVectorMap.insert(

                      std::make_pair(acqIdentifier, QVector<AcquisitionDataPacket>() << dataPacket));

              }

              // Decrement the counter of the request

              auto &acqRequest = aIdToARit->second;

              acqRequest.m_Size = acqRequest.m_Size - 1;

              // if the counter is 0, we can return data then run the next request if it exists and

              // removed the finished request

              if (acqRequest.m_Size == 0) {

                  // Return the data

                  aIdToADPVit = impl->m_AcqIdentifierToAcqDataPacketVectorMap.find(acqIdentifier);

                  if (aIdToADPVit != impl->m_AcqIdentifierToAcqDataPacketVectorMap.cend()) {

                      emit dataProvided(acqRequest.m_vIdentifier, acqRequest.m_RangeRequested,

                                        acqRequest.m_CacheRangeRequested, aIdToADPVit->second);

                  }

                  // Execute the next one

                  auto it

                      = impl->m_VIdentifierToCurrrentAcqIdNextIdPairMap.find(acqRequest.m_vIdentifier);

                  if (it != impl->m_VIdentifierToCurrrentAcqIdNextIdPairMap.cend()) {

                      if (it->second.second.isNull()) {

        perrinel
    
change grapheRange to graphRange

              r545
            
                          // There is no next request, we can remove the variable request

        perrinel
    
Implementation of V5 acquisition

              r539
            
                          impl->removeVariableRequest(acqRequest.m_vIdentifier);

                      }

                      else {

                          auto acqIdentifierToRemove = it->second.first;

                          // Move the next request to the current request

                          it->second.first = it->second.second;

                          it->second.second = QUuid();

                          // Remove AcquisitionRequest and results;

                          impl->m_AcqIdentifierToAcqRequestMap.erase(acqIdentifierToRemove);

                          impl->m_AcqIdentifierToAcqDataPacketVectorMap.erase(acqIdentifierToRemove);

                          // Execute the current request

                          QMetaObject::invokeMethod(this, "onExecuteRequest", Qt::QueuedConnection,

                                                    Q_ARG(QUuid, it->second.first));

                      }

                  }

                  else {

                      qCCritical(LOG_VariableAcquisitionWorker())

                          << tr("Impossible to execute the acquisition on an unfound variable ");

                  }

              }

          }

          else {

              qCCritical(LOG_VariableAcquisitionWorker())

                  << tr("Impossible to retrieve AcquisitionRequest for the incoming data");

          }

          impl->unlock();

      }

      void VariableAcquisitionWorker::onExecuteRequest(QUuid acqIdentifier)

      {

        perrinel
    
The dataSeries of a variable is now shared istead of uniq to avoid...

              r542
            
          qCInfo(LOG_VariableAcquisitionWorker()) << tr("onExecuteRequest") << QThread::currentThread();

        perrinel
    
Implementation of V5 acquisition

              r539
            
          impl->lockRead();

          auto it = impl->m_AcqIdentifierToAcqRequestMap.find(acqIdentifier);

          if (it != impl->m_AcqIdentifierToAcqRequestMap.cend()) {

              auto request = it->second;

              impl->unlock();

              request.m_Provider->requestDataLoading(acqIdentifier, request.m_DataProviderParameters);

          }

          else {

              impl->unlock();

              // TODO log no acqIdentifier recognized

          }

      }

      void VariableAcquisitionWorker::initialize()

      {

          qCDebug(LOG_VariableAcquisitionWorker()) << tr("VariableAcquisitionWorker init")

                                                   << QThread::currentThread();

          impl->m_WorkingMutex.lock();

          qCDebug(LOG_VariableAcquisitionWorker()) << tr("VariableAcquisitionWorker init END");

      }

      void VariableAcquisitionWorker::finalize()

      {

          impl->m_WorkingMutex.unlock();

      }

      void VariableAcquisitionWorker::waitForFinish()

      {

          QMutexLocker locker{&impl->m_WorkingMutex};

      }

      void VariableAcquisitionWorker::VariableAcquisitionWorkerPrivate::removeVariableRequest(

          QUuid vIdentifier)

      {

          lockWrite();

          auto it = m_VIdentifierToCurrrentAcqIdNextIdPairMap.find(vIdentifier);

          if (it != m_VIdentifierToCurrrentAcqIdNextIdPairMap.cend()) {

              // A current request already exists, we can replace the next one

              m_AcqIdentifierToAcqRequestMap.erase(it->second.first);

              m_AcqIdentifierToAcqDataPacketVectorMap.erase(it->second.first);

              m_AcqIdentifierToAcqRequestMap.erase(it->second.second);

              m_AcqIdentifierToAcqDataPacketVectorMap.erase(it->second.second);

          }

          m_VIdentifierToCurrrentAcqIdNextIdPairMap.erase(vIdentifier);

          unlock();

        perrinel
    
Add empty class VariableAcquisitionWorker

              r527
            
      }

	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

perrinel Add empty class VariableAcquisitionWorker	r527	#include "Variable/VariableAcquisitionWorker.h"

		#include "Variable/Variable.h"
perrinel Implementation of V5 acquisition	r539
		#include <Data/AcquisitionRequest.h>
		#include <Data/SqpRange.h>

perrinel Add empty class VariableAcquisitionWorker	r527	#include <unordered_map>
perrinel Implementation of V5 acquisition	r539	#include <utility>
perrinel Add empty class VariableAcquisitionWorker	r527
perrinel Implementation of V5 acquisition	r539	#include <QMutex>
		#include <QReadWriteLock>
perrinel Add empty class VariableAcquisitionWorker	r527	#include <QThread>
perrinel Implementation of V5 acquisition	r539
perrinel Add empty class VariableAcquisitionWorker	r527	Q_LOGGING_CATEGORY(LOG_VariableAcquisitionWorker, "VariableAcquisitionWorker")

		struct VariableAcquisitionWorker::VariableAcquisitionWorkerPrivate {

perrinel Implementation of V5 acquisition	r539	explicit VariableAcquisitionWorkerPrivate() : m_Lock{QReadWriteLock::Recursive} {}

		void lockRead() { m_Lock.lockForRead(); }
		void lockWrite() { m_Lock.lockForWrite(); }
		void unlock() { m_Lock.unlock(); }

		void removeVariableRequest(QUuid vIdentifier);

		QMutex m_WorkingMutex;
		QReadWriteLock m_Lock;

		std::map<QUuid, QVector<AcquisitionDataPacket> > m_AcqIdentifierToAcqDataPacketVectorMap;
		std::map<QUuid, AcquisitionRequest> m_AcqIdentifierToAcqRequestMap;
		std::map<QUuid, std::pair<QUuid, QUuid> > m_VIdentifierToCurrrentAcqIdNextIdPairMap;
perrinel Add empty class VariableAcquisitionWorker	r527	};


		VariableAcquisitionWorker::VariableAcquisitionWorker(QObject *parent)
		: QObject{parent}, impl{spimpl::make_unique_impl<VariableAcquisitionWorkerPrivate>()}
		{
		}

perrinel Implementation of V5 acquisition	r539	VariableAcquisitionWorker::~VariableAcquisitionWorker()
		{
		qCInfo(LOG_VariableAcquisitionWorker()) << tr("VariableAcquisitionWorker destruction")
		<< QThread::currentThread();
		this->waitForFinish();
		}


		void VariableAcquisitionWorker::pushVariableRequest(QUuid vIdentifier, SqpRange rangeRequested,
perrinel Add empty class VariableAcquisitionWorker	r527	SqpRange cacheRangeRequested,
		DataProviderParameters parameters,
perrinel Implementation of V5 acquisition	r539	std::shared_ptr<IDataProvider> provider)
		{
perrinel The dataSeries of a variable is now shared istead of uniq to avoid...	r542	qCInfo(LOG_VariableAcquisitionWorker())
perrinel Implementation of V5 acquisition	r539	<< tr("TORM VariableAcquisitionWorker::pushVariableRequest ") << cacheRangeRequested;

		// Request creation
		auto acqRequest = AcquisitionRequest{};
		acqRequest.m_vIdentifier = vIdentifier;
		acqRequest.m_DataProviderParameters = parameters;
		acqRequest.m_RangeRequested = rangeRequested;
		acqRequest.m_CacheRangeRequested = cacheRangeRequested;
		acqRequest.m_Size = parameters.m_Times.size();
		acqRequest.m_Provider = provider;

		// Register request
		impl->lockWrite();
		impl->m_AcqIdentifierToAcqRequestMap.insert(
		std::make_pair(acqRequest.m_AcqIdentifier, acqRequest));

		auto it = impl->m_VIdentifierToCurrrentAcqIdNextIdPairMap.find(vIdentifier);
		if (it != impl->m_VIdentifierToCurrrentAcqIdNextIdPairMap.cend()) {
		// A current request already exists, we can replace the next one
		it->second.second = acqRequest.m_AcqIdentifier;
		impl->unlock();
		}
		else {
		// First request for the variable, it must be stored and executed
		impl->m_VIdentifierToCurrrentAcqIdNextIdPairMap.insert(
		std::make_pair(vIdentifier, std::make_pair(acqRequest.m_AcqIdentifier, QUuid())));
		impl->unlock();

		QMetaObject::invokeMethod(this, "onExecuteRequest", Qt::QueuedConnection,
		Q_ARG(QUuid, acqRequest.m_AcqIdentifier));
		}
		}

		void VariableAcquisitionWorker::abortProgressRequested(QUuid vIdentifier)
		{
		// TODO
		}

		void VariableAcquisitionWorker::onVariableRetrieveDataInProgress(QUuid acqIdentifier,
		double progress)
		{
		// TODO
		}

		void VariableAcquisitionWorker::onVariableDataAcquired(QUuid acqIdentifier,
		std::shared_ptr<IDataSeries> dataSeries,
		SqpRange dataRangeAcquired)
perrinel Add empty class VariableAcquisitionWorker	r527	{
perrinel Implementation of V5 acquisition	r539	qCDebug(LOG_VariableAcquisitionWorker()) << tr("onVariableDataAcquired on range ")
		<< acqIdentifier << dataRangeAcquired;
		impl->lockWrite();
		auto aIdToARit = impl->m_AcqIdentifierToAcqRequestMap.find(acqIdentifier);
		if (aIdToARit != impl->m_AcqIdentifierToAcqRequestMap.cend()) {
		// Store the result
		auto dataPacket = AcquisitionDataPacket{};
		dataPacket.m_Range = dataRangeAcquired;
		dataPacket.m_DateSeries = dataSeries;

		auto aIdToADPVit = impl->m_AcqIdentifierToAcqDataPacketVectorMap.find(acqIdentifier);
		if (aIdToADPVit != impl->m_AcqIdentifierToAcqDataPacketVectorMap.cend()) {
		// A current request result already exists, we can update it
		aIdToADPVit->second.push_back(dataPacket);
		}
		else {
		// First request result for the variable, it must be stored
		impl->m_AcqIdentifierToAcqDataPacketVectorMap.insert(
		std::make_pair(acqIdentifier, QVector<AcquisitionDataPacket>() << dataPacket));
		}


		// Decrement the counter of the request
		auto &acqRequest = aIdToARit->second;
		acqRequest.m_Size = acqRequest.m_Size - 1;

		// if the counter is 0, we can return data then run the next request if it exists and
		// removed the finished request
		if (acqRequest.m_Size == 0) {
		// Return the data
		aIdToADPVit = impl->m_AcqIdentifierToAcqDataPacketVectorMap.find(acqIdentifier);
		if (aIdToADPVit != impl->m_AcqIdentifierToAcqDataPacketVectorMap.cend()) {
		emit dataProvided(acqRequest.m_vIdentifier, acqRequest.m_RangeRequested,
		acqRequest.m_CacheRangeRequested, aIdToADPVit->second);
		}

		// Execute the next one
		auto it
		= impl->m_VIdentifierToCurrrentAcqIdNextIdPairMap.find(acqRequest.m_vIdentifier);

		if (it != impl->m_VIdentifierToCurrrentAcqIdNextIdPairMap.cend()) {
		if (it->second.second.isNull()) {
perrinel change grapheRange to graphRange	r545	// There is no next request, we can remove the variable request
perrinel Implementation of V5 acquisition	r539	impl->removeVariableRequest(acqRequest.m_vIdentifier);
		}
		else {
		auto acqIdentifierToRemove = it->second.first;
		// Move the next request to the current request
		it->second.first = it->second.second;
		it->second.second = QUuid();
		// Remove AcquisitionRequest and results;
		impl->m_AcqIdentifierToAcqRequestMap.erase(acqIdentifierToRemove);
		impl->m_AcqIdentifierToAcqDataPacketVectorMap.erase(acqIdentifierToRemove);
		// Execute the current request
		QMetaObject::invokeMethod(this, "onExecuteRequest", Qt::QueuedConnection,
		Q_ARG(QUuid, it->second.first));
		}
		}
		else {
		qCCritical(LOG_VariableAcquisitionWorker())
		<< tr("Impossible to execute the acquisition on an unfound variable ");
		}
		}
		}
		else {
		qCCritical(LOG_VariableAcquisitionWorker())
		<< tr("Impossible to retrieve AcquisitionRequest for the incoming data");
		}
		impl->unlock();
		}

		void VariableAcquisitionWorker::onExecuteRequest(QUuid acqIdentifier)
		{
perrinel The dataSeries of a variable is now shared istead of uniq to avoid...	r542	qCInfo(LOG_VariableAcquisitionWorker()) << tr("onExecuteRequest") << QThread::currentThread();
perrinel Implementation of V5 acquisition	r539	impl->lockRead();
		auto it = impl->m_AcqIdentifierToAcqRequestMap.find(acqIdentifier);
		if (it != impl->m_AcqIdentifierToAcqRequestMap.cend()) {
		auto request = it->second;
		impl->unlock();
		request.m_Provider->requestDataLoading(acqIdentifier, request.m_DataProviderParameters);
		}
		else {
		impl->unlock();
		// TODO log no acqIdentifier recognized
		}
		}

		void VariableAcquisitionWorker::initialize()
		{
		qCDebug(LOG_VariableAcquisitionWorker()) << tr("VariableAcquisitionWorker init")
		<< QThread::currentThread();
		impl->m_WorkingMutex.lock();
		qCDebug(LOG_VariableAcquisitionWorker()) << tr("VariableAcquisitionWorker init END");
		}

		void VariableAcquisitionWorker::finalize()
		{
		impl->m_WorkingMutex.unlock();
		}

		void VariableAcquisitionWorker::waitForFinish()
		{
		QMutexLocker locker{&impl->m_WorkingMutex};
		}

		void VariableAcquisitionWorker::VariableAcquisitionWorkerPrivate::removeVariableRequest(
		QUuid vIdentifier)
		{
		lockWrite();
		auto it = m_VIdentifierToCurrrentAcqIdNextIdPairMap.find(vIdentifier);

		if (it != m_VIdentifierToCurrrentAcqIdNextIdPairMap.cend()) {
		// A current request already exists, we can replace the next one

		m_AcqIdentifierToAcqRequestMap.erase(it->second.first);
		m_AcqIdentifierToAcqDataPacketVectorMap.erase(it->second.first);

		m_AcqIdentifierToAcqRequestMap.erase(it->second.second);
		m_AcqIdentifierToAcqDataPacketVectorMap.erase(it->second.second);
		}
		m_VIdentifierToCurrrentAcqIdNextIdPairMap.erase(vIdentifier);
		unlock();
perrinel Add empty class VariableAcquisitionWorker	r527	}