AnalysisRunner.h

Go to the documentation of this file.

#ifndef ANALYSISRUNNER_H
#define ANALYSISRUNNER_H

//SpikeStream includes
#include "AbstractAnalysisTimeStepThread.h"
#include "DBInfo.h"

//Qt includes
#include <QHash>
#include <QString>
#include <QThread>
#include <QMutex>

namespace spikestream {

        class AnalysisRunner : public QThread {
                Q_OBJECT

                public:
                        AnalysisRunner(const DBInfo& netDBInfo, const DBInfo& archDBInfo, const DBInfo& anaDBInfo);
                        ~AnalysisRunner();
                        QString getErrorMessage() { return errorMessage; }
                        bool isError() { return error; }
                        void prepareAnalysisTask(const AnalysisInfo& anaInfo, int firstTimeStep, int lastTimeStep);
                        void reset();
                        void run();
                        void setError(const QString& message);
                        void setTimeStepThreadCreationFunction(AbstractAnalysisTimeStepThread* (*createAnalysisTimeStepThread)(const DBInfo& netDBInfo, const DBInfo& archDBInfo, const DBInfo& anaDBInfo));
                        void stop();

                signals:
                        void newResultsFound();
                        void progress(const QString& msg, unsigned int timeStep, unsigned int stepsCompleted, unsigned int totalSteps);
                        void timeStepComplete(unsigned int timeStep);

                private slots:
                        void threadFinished();
                        void updateResults();
                        void updateProgress(const QString& msg, unsigned int timeStep, unsigned int stepsCompleted, unsigned int totalSteps);

                private:
                        //========================  VARAIBLES  =========================
                        AnalysisInfo analysisInfo;

                        DBInfo networkDBInfo;

                        DBInfo archiveDBInfo;

                        DBInfo analysisDBInfo;

                        bool error;

                        QString errorMessage;

                        int firstTimeStep;

                        int lastTimeStep;

                        int nextTimeStep;

                        QHash<int, AbstractAnalysisTimeStepThread*> subThreadMap;

                        QMutex mutex;

                        bool stopThread;

                        AbstractAnalysisTimeStepThread* (*createAnalysisTimeStepThread)(const DBInfo& netDBInfo, const DBInfo& archDBInfo, const DBInfo& anaDBInfo);


                        //=========================  METHODS  ===========================
                        void clearError();
                        int getNextTimeStep();
                        void startAnalysisTimeStepThread(int timeStep);
                        bool subThreadsRunning();
        };

}

#endif//ANALYSISRUNNER_H