GIT_REPOSITORIES/LPP/Users/mperrinel/SciQLop-fork Files · core/include/Variable/VariableAcquisitionWorker.h

Adds the ability to force an acquisition pending for an operation (1)...

Adds the ability to force an acquisition pending for an operation (1) Creates struct that contains operation properties: - its weight - the flag to force acquisition waiting

perrinel - - Load All Authors

File last commit:

r761:ff170594501a


                r1249:b9a47ff1b9cc

Download file

             VariableAcquisitionWorker.h
        
                    66 lines
            
             | 1.9 KiB
            
                | text/x-c
            
             |
                CLexer
            
             / core / include / Variable / VariableAcquisitionWorker.h
          
                    History
                
                 |
                  Annotation
                 | Raw
                 |Copy content
                 |Copy permalink

      #ifndef SCIQLOP_VARIABLEACQUISITIONWORKER_H

      #define SCIQLOP_VARIABLEACQUISITIONWORKER_H

      #include "CoreGlobal.h"

      #include <Data/DataProviderParameters.h>

      #include <QLoggingCategory>

      #include <QObject>

      #include <QUuid>

      #include <Data/AcquisitionDataPacket.h>

      #include <Data/IDataSeries.h>

      #include <Data/SqpRange.h>

      #include <QLoggingCategory>

      #include <Common/spimpl.h>

      Q_DECLARE_LOGGING_CATEGORY(LOG_VariableAcquisitionWorker)

      class Variable;

      class IDataProvider;

      /// This class aims to handle all acquisition request

      class SCIQLOP_CORE_EXPORT VariableAcquisitionWorker : public QObject {

          Q_OBJECT

      public:

          explicit VariableAcquisitionWorker(QObject *parent = 0);

          virtual ~VariableAcquisitionWorker();

          QUuid pushVariableRequest(QUuid varRequestId, QUuid vIdentifier, SqpRange rangeRequested,

                                    SqpRange cacheRangeRequested, DataProviderParameters parameters,

                                    std::shared_ptr<IDataProvider> provider);

          void abortProgressRequested(QUuid vIdentifier);

          void initialize();

          void finalize();

      signals:

          void dataProvided(QUuid vIdentifier, const SqpRange &rangeRequested,

                            const SqpRange &cacheRangeRequested,

                            QVector<AcquisitionDataPacket> dataAcquired);

          void variableRequestInProgress(QUuid vIdentifier, double progress);

          void variableCanceledRequested(QUuid vIdentifier);

      public slots:

          void onVariableDataAcquired(QUuid acqIdentifier, std::shared_ptr<IDataSeries> dataSeries,

                                      SqpRange dataRangeAcquired);

          void onVariableRetrieveDataInProgress(QUuid acqIdentifier, double progress);

          void onVariableAcquisitionFailed(QUuid acqIdentifier);

      private:

          void waitForFinish();

          class VariableAcquisitionWorkerPrivate;

          spimpl::unique_impl_ptr<VariableAcquisitionWorkerPrivate> impl;

      private slots:

          void onExecuteRequest(QUuid acqIdentifier);

      };

      #endif // SCIQLOP_VARIABLEACQUISITIONWORKER_H

	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

				#ifndef SCIQLOP_VARIABLEACQUISITIONWORKER_H
				#define SCIQLOP_VARIABLEACQUISITIONWORKER_H

				#include "CoreGlobal.h"

				#include <Data/DataProviderParameters.h>
				#include <QLoggingCategory>
				#include <QObject>
				#include <QUuid>

				#include <Data/AcquisitionDataPacket.h>
				#include <Data/IDataSeries.h>
				#include <Data/SqpRange.h>

				#include <QLoggingCategory>

				#include <Common/spimpl.h>

				Q_DECLARE_LOGGING_CATEGORY(LOG_VariableAcquisitionWorker)

				class Variable;
				class IDataProvider;

				/// This class aims to handle all acquisition request
				class SCIQLOP_CORE_EXPORT VariableAcquisitionWorker : public QObject {
				Q_OBJECT
				public:
				explicit VariableAcquisitionWorker(QObject *parent = 0);
				virtual ~VariableAcquisitionWorker();

				QUuid pushVariableRequest(QUuid varRequestId, QUuid vIdentifier, SqpRange rangeRequested,
				SqpRange cacheRangeRequested, DataProviderParameters parameters,
				std::shared_ptr<IDataProvider> provider);

				void abortProgressRequested(QUuid vIdentifier);

				void initialize();
				void finalize();
				signals:
				void dataProvided(QUuid vIdentifier, const SqpRange &rangeRequested,
				const SqpRange &cacheRangeRequested,
				QVector<AcquisitionDataPacket> dataAcquired);

				void variableRequestInProgress(QUuid vIdentifier, double progress);


				void variableCanceledRequested(QUuid vIdentifier);


				public slots:
				void onVariableDataAcquired(QUuid acqIdentifier, std::shared_ptr<IDataSeries> dataSeries,
				SqpRange dataRangeAcquired);
				void onVariableRetrieveDataInProgress(QUuid acqIdentifier, double progress);
				void onVariableAcquisitionFailed(QUuid acqIdentifier);

				private:
				void waitForFinish();

				class VariableAcquisitionWorkerPrivate;
				spimpl::unique_impl_ptr<VariableAcquisitionWorkerPrivate> impl;

				private slots:
				void onExecuteRequest(QUuid acqIdentifier);
				};

				#endif // SCIQLOP_VARIABLEACQUISITIONWORKER_H