AbstractAnalysisTimeStepThread.cpp

Go to the documentation of this file.

//SpikeStream includes
#include "AbstractAnalysisTimeStepThread.h"
#include "SpikeStreamException.h"
#include "Util.h"
using namespace spikestream;

//Qt includes
#include <QDebug>

//Other includes
#include <iostream>
using namespace std;


AbstractAnalysisTimeStepThread::AbstractAnalysisTimeStepThread(const DBInfo& netDBInfo, const DBInfo& archDBInfo, const DBInfo& anaDBInfo){
        //Store the database information
        this->networkDBInfo = netDBInfo;
        this->archiveDBInfo = archDBInfo;
        this->analysisDBInfo = anaDBInfo;

        //Initialize variables
        timeStep = -1;
}


AbstractAnalysisTimeStepThread::~AbstractAnalysisTimeStepThread(){
}


/*-------------------------------------------------------------*/
/*-------                 PUBLIC METHODS                 ------*/
/*-------------------------------------------------------------*/

void AbstractAnalysisTimeStepThread::clearError(){
        error = false;
        errorMessage = "";
}


void AbstractAnalysisTimeStepThread::prepareTimeStepAnalysis(const AnalysisInfo& anaInfo, int timeStep){
        this->analysisInfo = anaInfo;
        this->timeStep = timeStep;
}


void AbstractAnalysisTimeStepThread::stopThread(){
        stop = true;
}


/*----------------------------------------------------------*/
/*-----                 PRIVATE SLOTS                -----*/
/*----------------------------------------------------------*/

void AbstractAnalysisTimeStepThread::updateResults(){
        emit newResultsFound();
}


void AbstractAnalysisTimeStepThread::updateProgress(const QString& msg, unsigned int timeStep, unsigned int stepsCompleted, unsigned int totalSteps){
        emit progress(msg, timeStep, stepsCompleted, totalSteps);
}


/*----------------------------------------------------------*/
/*-----                 PRIVATE METHODS                -----*/
/*----------------------------------------------------------*/

void AbstractAnalysisTimeStepThread::setError(const QString& message){
        error = true;
        errorMessage = message;

        //exit this thread
        stopThread();
}