ThreadManager Class Reference

Thread manager. Responsable to manage the main thread and "speak" with the GUI. More...

#include <ThreadManager.h>

Inheritance diagram for ThreadManager:

Collaboration diagram for ThreadManager:

Public Slots
void	checkQuery (int px_ID, int currentLayerIndex, bool newRequest=true)
	Switch and control the access to pxQueryID and layerQueryPos members. More...
void	computeQuery (int px_ID, int currentLayerIndex)
	Compute the pixel query and return it to the GUI (with a signal) More...
void	retrieveScenarioNameFromGUI (const QString &scenarioName_h)

Signals
void	upgradeLogArea (const QString &logMessage)
void	upgradeMainSBLabelToGui (const QString &logMessage)
void	upgradeYearSBLabelToGui (const QString &logMessage)
void	addLayerToGui (QString layerName, QString layerLabel)
void	updatePixelToGui (QString layerName_h, int x_h, int y_h, QColor color)
void	updateImageToGui (QString layerName_h, QImage image_h)
void	setOutputDirNameToGui (string outputDirname_h)
void	setGUIUnsavedStatus (bool status_h)
void	setGUIMapDimension (int x_h, int y_h)
void	treeViewerItemChangeValueToGui (string itemID, string newValue)
void	treeViewerItemRemoveToGui (string itemID)
void	treeViewerAddItemToGui (string text, string itemID, string parentID)
void	fitInWindowToGui ()
void	queryRequestOnPx (int px_ID, int currentLayerIndex)
void	publishQueryResults (const QString &results)
void	activateTab (int pos_h)
void	resetGUIForNewSimulation ()
void	sendScenarioOptionsToGUI (const QVector< QString > &scenarios_h)

Public Member Functions
	ThreadManager ()
void	setMessage (const QString &message)
void	stop ()
void	deleteDeadOldPointers ()
	Useful for several model running without leaving the GUI. More...
void	pauseOrResume ()
void	pause ()
void	resume ()
void	refreshGUI ()
void	msgOut (const int msgCode_h, const string message_h)
void	addLayer (string layerName_h, string layerLabel_h)
void	updatePixel (string layerName_h, int x_h, int y_h, QColor color)
void	updateImage (string layerName_h, const QImage &image_h)
void	upgradeMainSBLabel (const string message_h)
void	upgradeYearSBLabel (int year)
string	getBaseDirectory ()
string	getInputFileName ()
string	getScenarioName ()
void	setScenarioName (const string &scenarioName_h)
void	setOutputDirName (string outputDirname_h)
void	setMDPointer (ModelData *MD_h)
	the regional data object.. More...
void	setGISPointer (Gis *GIS_h)
	GIS information and methods.. More...
void	setINITPointer (Init *INIT_h)
	the Init object, it schedule the pre-simulation phase.. More...
void	setTestPointer (Sandbox *TEST_h)
	the sandbox object for within-development quick tests More...
void	setSCDPointer (Scheduler *SCD_h)
	the scheduler object. It manage the simulation loops.. More...
void	setDOPointer (Output *DO_h)
	manage the printing of data needed for scenario-analisys. The "message output" (needed to see "what is it happening?" are instead simply printed with msgOut().. More...
void	setCOREPointer (ModelCore *CORE_h)
	Perform the algorithms of the model. More...
void	setSCOREPointer (ModelCoreSpatial *SCORE_h)
	Perform the algorithms of the model. More...
void	setOPTPointer (Ipopt::SmartPtr< Ipopt::TNLP > OPT_h)
	Perform the market optimisation. More...
void	setCBALPointer (Carbon *CBAL_h)
	Module that account for the Carbon Balance. More...
void	setInputFileName (QString inputFileName_h)
void	treeViewerChangeGeneralPropertyValue (string propertyName, string newValue)
void	fitInWindow ()
void	runFromConsole (QString inputFileName_h, QString scenarioName_h)
	Re-draw the map making it to fit (with the right proportions) to the widget. More...
bool	usingGUI ()
Public Member Functions inherited from BaseClass
	BaseClass ()
	~BaseClass ()
void	msgOut (const int &msgCode_h, const string &msg_h, const bool &refreshGUI_h=true) const
	Overloaded function to print the output log. More...
void	msgOut (const int &msgCode_h, const int &msg_h, const bool &refreshGUI_h=true) const
	Overloaded function to print the output log. More...
void	msgOut (const int &msgCode_h, const double &msg_h, const bool &refreshGUI_h=true) const
	Overloaded function to print the output log. More...
int	s2i (const string &string_h) const
	string to integer conversion More...
double	s2d (const string &string_h) const
	string to double conversion More...
double	s2d (const string &string_h, const bool &replaceComma) const
	string to double conversion More...
bool	s2b (const string &string_h) const
	string to bool conversion More...
string	i2s (const int &int_h) const
	integer to string conversion More...
string	d2s (const double &double_h) const
	double to string conversion More...
string	b2s (const bool &bool_h) const
	bool to string conversion More...
vector< int >	s2i (const vector< string > &string_h) const
	string to integer conversion (vector) More...
vector< double >	s2d (const vector< string > &string_h, const bool &replaceComma=false) const
	string to double conversion (vector) More...
vector< bool >	s2b (const vector< string > &string_h) const
	string to bool conversion (vector) More...
vector< string >	i2s (const vector< int > &int_h) const
	integer to string conversion (vector) More...
vector< string >	d2s (const vector< double > &double_h) const
	double to string conversion (vector) More...
vector< string >	b2s (const vector< bool > &bool_h) const
	bool to string conversion (vector) More...
int	getType (const string &type_h) const
	Return a type according to enum TYPE_* from a string (eg: "string" -> TYPE_STRING (2)) More...
void	refreshGUI () const
	Ping to periodically return the control to the GUI. More...
template<typename T >
string	toString (const T &x) const
template<typename T >
T	stringTo (const std::string &s) const
int	vSum (const vector< int > &vector_h) const
double	vSum (const vector< double > &vector_h) const
int	vSum (const vector< vector< int > > &vector_h) const
double	vSum (const vector< vector< double > > &vector_h) const
void	tokenize (const string &str, vector< string > &tokens, const string &delimiter=" ") const
	Tokenize a string using a delimiter (default is space) More...
void	untokenize (string &str, vector< string > &tokens, const string &delimiter=" ") const
template<typename K , typename V >
V	findMap (const map< K, V > &mymap, const K &key, const int &error_level=MSG_CRITICAL_ERROR, const V &notFoundValue=numeric_limits< V >::min()) const
	Lookup a map for a value. Return the value starting from the key. More...
template<typename K , typename V >
void	changeMapValue (map< K, V > &mymap, const K &key, const V &value, const int &error_level=MSG_CRITICAL_ERROR)
	Change the value stored in a map given the key and the new value. More...
template<typename K , typename V >
void	incrMapValue (map< K, V > &mymap, const K &key, const V &value, const int &error_level=MSG_CRITICAL_ERROR)
	Increments a value stored in a map of the specified value, given the key. More...
template<typename K , typename V >
void	incrOrAddMapValue (map< K, V > &mymap, const K &key, const V &value)
	Increments a value stored in a map of the specified value, given the key. More...
template<typename K , typename V >
void	resetMapValues (map< K, V > &mymap, const V &value)
	Reset all values stored in a map to the specified one. More...
template<typename K , typename V >
map< K, V >	vectorToMap (const vector< K > &keys, const V &value=0.0)
	Returns a map built using the given vector and the given (scalar) value as keys/values pairs. More...
template<typename T >
vector< T >	positionsToContent (const vector< T > &vector_h, const vector< int > &positions)
	Return a vector of content from a vector and a vector of positions (int) More...
template<typename V >
void	debugMap (const map< iisskey, V > &mymap)
	Debug a map. More...
template<typename K , typename V >
void	debugMap (const map< K, V > &mymap, const K &key)
template<typename K >
int	getMaxPos (const vector< K > &v)
	Returns the position of the maximum element in the vector (the last one in case of multiple equivalent maxima) More...
template<typename K >
int	getMinPos (const vector< K > &v)
	Returns the position of the minimum element in the vector (the first one in case of multiple equivalent minima) More...
template<typename K >
K	getMax (const vector< K > &v)
	Returns the value of the maximum element in the vector (the last one in case of multiple equivalent maxima) More...
template<typename K >
K	getMin (const vector< K > &v)
	Returns the value of the minimum element in the vector (the first one in case of multiple equivalent minima) More...
template<typename K >
double	getAvg (const vector< K > &v)
	Returns the average of the elements in the vector. More...
template<typename K >
double	getSd (const vector< K > &v, bool sample=true)
template<typename K >
int	getPos (const K &element, const vector< K > &v, const int &msgCode_h=MSG_CRITICAL_ERROR)
template<typename K >
bool	inVector (const K &element, const vector< K > &v)
double	normSample (const double &avg, const double &stdev, const double &minval=NULL, const double &maxval=NULL) const
	Sample from a normal distribution with bounds. Slower (double time, but still you see the diff only after milion of loops). More...
template<typename K >
K	normSample (normal_distribution< K > &d, std::mt19937 &gen, const K &minval=NULL, const K &maxval=NULL) const
	Sample from a normal distribution with bounds. Faster (half time) as the normal_distribution is made only once. More...
template<typename T >
std::string	toString (const T &x) const

Public Attributes
ModelData *	MD
	the model data object More...
Gis *	GIS
	GIS information and methods. More...
Init *	INIT
	the Init object (pre-simulation scheduler) More...
Scheduler *	SCD
	the scheduler object (simulation-loops scheduler) More...
Output *	DO
	data output More...
ModelCore *	CORE
	Core of the model. More...
ModelCoreSpatial *	SCORE
	Core of the model (spatial version) More...
Carbon *	CBAL
	Module for the Carbon Balance. More...
Sandbox *	TEST
	Various debugging code for development. More...
Ipopt::SmartPtr< Ipopt::TNLP >	OPT
	Market optimisation. More...
std::mt19937 *	gen
	used in the sampling from normal distribution More...

Protected Member Functions
void	run ()

Private Attributes
QString	messageStr
volatile bool	stopped
volatile bool	running
QString	inputFileName
QString	baseDirectory
QString	scenarioName
volatile int	pxQueryID
volatile int	layerQueryPos
QMutex	mutex
bool	GUI

Additional Inherited Members
Protected Attributes inherited from BaseClass
ThreadManager *	MTHREAD
	Pointer to the Thread manager. More...

Detailed Description

Thread manager. Responsable to manage the main thread and "speak" with the GUI.

ThreadManager is responsable for the actions on the main thread (run/pause/resume/stop) and to speack with the GUI using the signal/slot tecniques.

Author

Antonello Lobianco

Definition at line 65 of file ThreadManager.h.

Constructor & Destructor Documentation

ThreadManager

(

)

Definition at line 35 of file ThreadManager.cpp.

                            {
  running=false;
  stopped=false;
  layerQueryPos = -1;

  // initializing pointers...
  MD     = NULL;
  GIS    = NULL;
  INIT   = NULL;
  SCD    = NULL;
  DO     = NULL;
  CORE   = NULL;
  SCORE  = NULL;
  TEST   = NULL;
  CBAL   = NULL;
  //randev = NULL;
  gen    = NULL;
  
  GUI = false;

  scenarioName="";
  inputFileName="";
  baseDirectory="";

}

Member Function Documentation

void activateTab ( int  pos_h )

signal

void addLayer	(	string	layerName_h,
		string	layerLabel_h
	)

Definition at line 259 of file ThreadManager.cpp.

                                                              {
  QString layerName = layerName_h.c_str();
  QString layerLabel = layerLabel_h.c_str();
  emit addLayerToGui(layerName, layerLabel);
}

void addLayerToGui ( QString  layerName, QString  layerLabel  )

signal

void checkQuery ( int  px_ID, int  currentLayerIndex, bool  newRequest = true  )

slot

Switch and control the access to pxQueryID and layerQueryPos members.

checkQuery() is a function that can be called my the GUI trough a signal or from the running thread under refreshGUI(), and it is protected with a mutex.
It's role is to control the status of pxQueryID and layerQueryPos member variables.
If the call come from the GUI, it is a new request and we set them to the new values, otherwise we gonna see if they are just beed changed and if so (layerQueryPos>=0) we call computeQuery().

Definition at line 293 of file ThreadManager.cpp.

                                                                          {
  QMutexLocker locker(&mutex);
  if(newRequest){
    pxQueryID = px_ID;
    layerQueryPos = currentLayerIndex;
    if(stopped){computeQuery(pxQueryID, layerQueryPos);layerQueryPos = -1;} // model is stopped, no way the model thread will do the query work
    else{emit publishQueryResults("<i>..wait.. processing query..</i>");} // model is running.. it will be the model thread to execute the query    
    return;
  } else {
    if(layerQueryPos<0){
      return;
    } else {
      computeQuery(pxQueryID, layerQueryPos);
      layerQueryPos = -1;
      return;
    }
  }
}

void computeQuery ( int  px_ID, int  currentLayerIndex  )

slot

Compute the pixel query and return it to the GUI (with a signal)

Definition at line 313 of file ThreadManager.cpp.

                                                           {
  
  // IMPORTANT: this function is called at refreshGUI() times, so if there are output messages, call them with the option to NOT refresh the gui, otherwise we go to an infinite loop...

  vector<Layers*> layers;
  try {
    layers = GIS->getLayerPointers();
  }catch (...) {
    emit activateTab(2); // tell the gui to activate the 3rd page, those with the pixel info
    emit publishQueryResults("GIS pointer is dead.. maybe simulation has ended???");
    return;
  }
  QString result= "";
  int realID = GIS->sub2realID(px_ID);
  if (realID<0) {
    emit publishQueryResults("Query result: Spatial data is not yet ready in the model. Please click again later.");
    return; // on early stage we may have errors, and here we prevent this error to have further consequences.
  }
  Pixel* px;
  try {
    px = GIS->getPixel(realID);
  }catch (...) {
    emit activateTab(2); // tell the gui to activate the 3rd page, those with the pixel info
    emit publishQueryResults("Query result: Spatial data is not yet ready in the model. Please click again later.");
    return;
  }  
  result += "Pixel: ";
  result += i2s(realID).c_str();
  result += " (";
  result += i2s(px->getX()).c_str();
  result += ",";
  result += i2s(px->getY()).c_str();
  result += ")";
  result +="<p><table>";
  uint countVisibleLayers = 0;
  for (uint i=0;i<layers.size();i++){
    if(!layers[i]->getDisplay()){
      continue;
    }
    QString boldStart="";
    QString boldEnd = "";
    if (countVisibleLayers == currentLayerIndex){
      boldStart = "<b>";
      boldEnd   = "</b>";
    }
    result += "<tr>";
    string layerName = layers[i]->getName();
    double value = px->getDoubleValue(layerName);
    string category = layers[i]->getCategory(value);
    //QColor color = layers[i]->getColor(value);
    result += "<td>";
    result += boldStart;
    result += layerName.c_str();
    result += boldEnd;
    result += "</td><td>";
    result += boldStart;
    result += category.c_str();
    result += boldEnd;
    result += "</td>";
    result += "</tr>";
    if(layers[i]->getDisplay()){ // if not really needed, but ok if we decide to change and get displayed also hidden layers
      countVisibleLayers++;
    }
  }
  result += "</table>";
  emit activateTab(2); // tell the gui to activate the 3rd page, those with the pixel info
  emit publishQueryResults(result);
}

Here is the call graph for this function:

void deleteDeadOldPointers

(

)

Useful for several model running without leaving the GUI.

Delete the pointers (e.g. GIS) eventually remained from a previous run.
This function is called at the START of a new simulation, and it will check if model pointers (e.g. GIS) exist , and if so it will delete them.
This is useful when we keep the MainWindow open but we run the model for a second time.
Why we don't delete them at the end of a simulation, instead of deleting them on a new run? That's because we want let the user to interface with the model even when this is ended, w.g. for query the map.

Definition at line 165 of file ThreadManager.cpp.

                                    {
  if (DO) {delete DO; DO=0;}
  if (INIT) {delete INIT; INIT=0;}
  if (SCD) {delete SCD; SCD=0;}
  if (GIS) {delete GIS; GIS=0;}
  if (MD) {delete MD; MD=0;}
  if (CORE){delete CORE; CORE=0;}
  if (SCORE){delete SCORE; SCORE=0;}
  if (CBAL) {delete CBAL; CBAL=0;}
  //if (OPT) {delete OPT; OPT=0;} // not needed, it's a "smart point"
  if(TEST){delete TEST; TEST=0;}
  //if(randev){delete randev; randev=0;}
  if(gen){delete gen; gen=0;}
}

void fitInWindow ( )

inline

Definition at line 148 of file ThreadManager.h.

{emit fitInWindowToGui();}; ///< Re-draw the map making it to fit (with the right proportions) to the widget

void fitInWindowToGui ( )

signal

string getBaseDirectory ( )

inline

Definition at line 98 of file ThreadManager.h.

Referenced by ModelData::getTableFromFile(), ModelData::loadInput(), and MainProgram::MainProgram().

{return baseDirectory.toStdString();};

Here is the caller graph for this function:

string getInputFileName ( )

inline

Definition at line 99 of file ThreadManager.h.

Referenced by ModelData::loadInput().

{return inputFileName.toStdString();};

Here is the caller graph for this function:

string getScenarioName ( )

inline

Definition at line 100 of file ThreadManager.h.

Referenced by Output::commonInit(), ModelData::getScenarioIndex(), ModelData::loadInput(), Layers::print(), Layers::printBinMap(), ModelData::setDefaultSettings(), Init::setInitLevel1(), and ModelData::setScenarioData().

{return scenarioName.toStdString();};

Here is the caller graph for this function:

void msgOut	(	const int	msgCode_h,
		const string	message_h
	)

Definition at line 245 of file ThreadManager.cpp.

                                                                {
  QString message = message_h.c_str();
  emit upgradeLogArea(message);
  if (msgCode_h == 2){
    emit upgradeMainSBLabelToGui(message);
  }
}

void pause

(

)

Definition at line 203 of file ThreadManager.cpp.

                    {
  if(!stopped){
    if(running){
      running= false;
    }
    else {
      return;
    }
  }
  return;
}

void pauseOrResume

(

)

Definition at line 187 of file ThreadManager.cpp.

                            {
  if(!stopped){
    if(running){
      running= false;
      emit upgradeLogArea("PAUSE cliccked PAUSING");
    }
    else {
      running=true;
      emit upgradeLogArea("PAUSE cliccked RESUMING");
      emit setGUIUnsavedStatus(true);
    }
  }
  return;
}

void publishQueryResults ( const QString &  results )

signal

void queryRequestOnPx ( int  px_ID, int  currentLayerIndex  )

signal

void refreshGUI

(

)

Definition at line 230 of file ThreadManager.cpp.

                         {
    checkQuery(0,0,false);
    while (!running){
      if(stopped){
        break;
      }
    }
    if (stopped){
      emit upgradeLogArea("Model has been stopped.");
      running= false;
      throw(2);
    }
}

void resetGUIForNewSimulation ( )

signal

void resume

(

)

Definition at line 216 of file ThreadManager.cpp.

                     {
  if(!stopped){
    if(running){
      return;
    }
    else {
      running=true;
      emit setGUIUnsavedStatus(true);
    }
  }
  return;
}

void retrieveScenarioNameFromGUI ( const QString &  scenarioName_h )

slot

Definition at line 117 of file ThreadManager.cpp.

                                                                       {
  scenarioName = scenarioName_h;
  msgOut(MSG_INFO, "Selected scenario: "+scenarioName.toStdString());
  cout << "Selected scenario: "+scenarioName.toStdString() << endl;
  resume();
}

void run ( )

protected

Definition at line 66 of file ThreadManager.cpp.

                       {
  running=true;
  stopped=false;

  srand(1);
  GUI=true;

  emit upgradeLogArea("**INFO: Start running the model...");

  MainProgram* myProgram;
  try{
    deleteDeadOldPointers();
    emit resetGUIForNewSimulation();


    QFileInfo file(inputFileName);
    QDir baseDir = file.absoluteDir();
    baseDirectory = baseDir.absolutePath()+"/";
    myProgram = new MainProgram(this);

    //myProgram->setBaseDirectory(baseDirectory);
  
    vector<string> scenarios = MD->getScenarios();
    QVector<QString> qscenarios;
    for(uint i=0;i<scenarios.size();i++){
      qscenarios.push_back(scenarios.at(i).c_str());
    }
    running = false;
    emit sendScenarioOptionsToGUI(qscenarios);
    refreshGUI();

    myProgram->run();

    // Here the model has come to an end...
    running=false;
    stopped=true;
    delete myProgram;
    refreshGUI();
    
  }catch (...) {
      // Here the model has come to an end...
      running=false;
      stopped=true;
      delete myProgram;
      emit upgradeLogArea("**INFO: Model has stopped or rised an error (read previous line).");
  }  
  emit upgradeLogArea("**INFO: Model has ended.");
  
}

Here is the call graph for this function:

void runFromConsole	(	QString	inputFileName_h,
		QString	scenarioName_h
	)

Re-draw the map making it to fit (with the right proportions) to the widget.

Definition at line 125 of file ThreadManager.cpp.

Referenced by main().

                                                                            {
  try{
    GUI = false;
    scenarioName = scenarioName_h;
    inputFileName = inputFileName_h;
    QFileInfo file(inputFileName);
    QDir baseDir = file.absoluteDir();
    baseDirectory = baseDir.absolutePath()+"/";
    cout <<"Using base directory: "<< baseDirectory.toStdString() << endl;


    MainProgram* myProgram = new MainProgram(this);

    if( scenarioName_h == ""){ // if the scenario option has not been choosed, go for the first one!
      vector<string> scenarios = MD->getScenarios();
      scenarioName = scenarios.at(0).c_str();
    }

    //myProgram->setBaseDirectory(baseDirectory);
    myProgram->run();
  }catch (...) {
       exit(EXIT_FAILURE);
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

void sendScenarioOptionsToGUI ( const QVector< QString > &  scenarios_h )

signal

void setCBALPointer ( Carbon *  CBAL_h )

inline

Module that account for the Carbon Balance.

Definition at line 123 of file ThreadManager.h.

Referenced by MainProgram::run().

{CBAL=CBAL_h;};

Here is the caller graph for this function:

void setCOREPointer ( ModelCore *  CORE_h )

inline

Perform the algorithms of the model.

Definition at line 117 of file ThreadManager.h.

Referenced by MainProgram::run().

{CORE=CORE_h;};

Here is the caller graph for this function:

void setDOPointer ( Output *  DO_h )

inline

manage the printing of data needed for scenario-analisys. The "message output" (needed to see "what is it happening?" are instead simply printed with msgOut()..

Definition at line 115 of file ThreadManager.h.

Referenced by MainProgram::run().

{DO=DO_h;};

Here is the caller graph for this function:

void setGISPointer ( Gis *  GIS_h )

inline

GIS information and methods..

Definition at line 107 of file ThreadManager.h.

Referenced by MainProgram::run().

{GIS=GIS_h;};

Here is the caller graph for this function:

void setGUIMapDimension ( int  x_h, int  y_h  )

signal

void setGUIUnsavedStatus ( bool  status_h )

signal

void setINITPointer ( Init *  INIT_h )

inline

the Init object, it schedule the pre-simulation phase..

Definition at line 109 of file ThreadManager.h.

Referenced by MainProgram::run().

{INIT=INIT_h;};

Here is the caller graph for this function:

void setInputFileName

(

QString

inputFileName_h

)

Definition at line 151 of file ThreadManager.cpp.

                                                      {
  inputFileName= inputFileName_h;
  QFileInfo file(inputFileName);
  QDir baseDir = file.absoluteDir();
  baseDirectory = baseDir.absolutePath()+"/";
}

void setMDPointer ( ModelData *  MD_h )

inline

the regional data object..

Definition at line 105 of file ThreadManager.h.

Referenced by MainProgram::MainProgram().

{MD=MD_h;};

Here is the caller graph for this function:

void setMessage

(

const QString &

message

)

Definition at line 62 of file ThreadManager.cpp.

                                               {
    messageStr = message;
}

void setOPTPointer ( Ipopt::SmartPtr< Ipopt::TNLP >  OPT_h )

inline

Perform the market optimisation.

Definition at line 121 of file ThreadManager.h.

Referenced by MainProgram::run().

{OPT=OPT_h;};

Here is the caller graph for this function:

void setOutputDirName

(

string

outputDirname_h

)

Definition at line 254 of file ThreadManager.cpp.

Referenced by ModelData::setOutputDirectory().

                                                     {
  emit setOutputDirNameToGui(outputDirname_h);
}

Here is the caller graph for this function:

void setOutputDirNameToGui ( string  outputDirname_h )

signal

void setSCDPointer ( Scheduler *  SCD_h )

inline

the scheduler object. It manage the simulation loops..

Definition at line 113 of file ThreadManager.h.

Referenced by MainProgram::run().

{SCD=SCD_h;};

Here is the caller graph for this function:

void setScenarioName ( const string &  scenarioName_h )

inline

Definition at line 101 of file ThreadManager.h.

Referenced by Init::setInitLevel1().

{scenarioName=scenarioName_h.c_str();};

Here is the caller graph for this function:

void setSCOREPointer ( ModelCoreSpatial *  SCORE_h )

inline

Perform the algorithms of the model.

Definition at line 119 of file ThreadManager.h.

Referenced by MainProgram::run().

{SCORE=SCORE_h;};

Here is the caller graph for this function:

void setTestPointer ( Sandbox *  TEST_h )

inline

the sandbox object for within-development quick tests

Definition at line 111 of file ThreadManager.h.

Referenced by MainProgram::run().

{TEST=TEST_h;};

Here is the caller graph for this function:

void stop

(

)

Definition at line 181 of file ThreadManager.cpp.

                   {
    stopped = true;
  emit upgradeLogArea("STOP cliccked stopping");
}

void treeViewerAddItemToGui ( string  text, string  itemID, string  parentID  )

signal

void treeViewerChangeGeneralPropertyValue ( string  propertyName, string  newValue  )

inline

Definition at line 144 of file ThreadManager.h.

Referenced by Scheduler::run().

                                                                                               {
                          emit treeViewerItemChangeValueToGui("general_"+propertyName, newValue);};

Here is the caller graph for this function:

void treeViewerItemChangeValueToGui ( string  itemID, string  newValue  )

signal

void treeViewerItemRemoveToGui ( string  itemID )

signal

void updateImage	(	string	layerName_h,
		const QImage &	image_h
	)

Definition at line 271 of file ThreadManager.cpp.

                                                                   {
  emit updateImageToGui(layerName_h.c_str(), image_h);
}

void updateImageToGui ( QString  layerName_h, QImage  image_h  )

signal

void updatePixel	(	string	layerName_h,
		int	x_h,
		int	y_h,
		QColor	color
	)

Definition at line 266 of file ThreadManager.cpp.

                                                                              {
  emit updatePixelToGui(layerName_h.c_str(), x_h, y_h, color_h);
}

void updatePixelToGui ( QString  layerName_h, int  x_h, int  y_h, QColor  color  )

signal

void upgradeLogArea ( const QString &  logMessage )

signal

void upgradeMainSBLabel

(

const string

message_h

)

Definition at line 276 of file ThreadManager.cpp.

Referenced by Scheduler::run().

                                                       {
  emit upgradeMainSBLabelToGui(message_h.c_str());
}

Here is the caller graph for this function:

void upgradeMainSBLabelToGui ( const QString &  logMessage )

signal

void upgradeYearSBLabel

(

int

year

)

Definition at line 281 of file ThreadManager.cpp.

Referenced by Scheduler::run().

                                         {
  QString temp;
  temp= i2s(year).c_str();
  emit upgradeYearSBLabelToGui(temp);
}

Here is the caller graph for this function:

void upgradeYearSBLabelToGui ( const QString &  logMessage )

signal

bool usingGUI ( )

inline

Definition at line 150 of file ThreadManager.h.

{return GUI;};

Here is the call graph for this function:

Member Data Documentation

QString baseDirectory

private

Definition at line 188 of file ThreadManager.h.

Carbon* CBAL

Module for the Carbon Balance.

Definition at line 79 of file ThreadManager.h.

Referenced by ModelCoreSpatial::initialiseCarbonModule(), Output::printCarbonBalance(), and ModelCoreSpatial::registerCarbonEvents().

ModelCore* CORE

Core of the model.

Definition at line 77 of file ThreadManager.h.

Referenced by Scheduler::run(), and Init::setInitLevel3().

Output* DO

data output

Definition at line 76 of file ThreadManager.h.

Referenced by ModelCore::runInitPeriod(), ModelCoreSpatial::runInitPeriod(), ModelCore::runManagementModule(), ModelCore::runMarketModule(), ModelCoreSpatial::runMarketModule(), ModelCore::runSimulationYear(), ModelCoreSpatial::runSimulationYear(), Init::setInitLevel3(), Init::setInitLevel6(), and ModelCoreSpatial::sumRegionalForData().

std::mt19937* gen

used in the sampling from normal distribution

Definition at line 83 of file ThreadManager.h.

Referenced by Init::setInitLevel1().

Gis* GIS

GIS information and methods.

Definition at line 73 of file ThreadManager.h.

Referenced by ModelCoreSpatial::assignSpMultiplierPropToVols(), Pixel::changeValue(), Layers::countMyPixels(), Layers::getCategory(), Layers::getColor(), Pixel::getDoubleValue(), Pixel::getPathMortality(), Pixel::getPixelsAtDistLevel(), ModelCoreSpatial::initializePixelArea(), ModelCoreSpatial::initializePixelVolumes(), ModelCoreSpatial::loadExogenousForestLayers(), Layers::print(), Layers::printBinMap(), Output::printMaps(), Layers::randomShuffle(), Scheduler::run(), Init::setInitLevel1(), ModelRegion::setMyPixels(), ModelCore::updateMapAreas(), ModelCoreSpatial::updateMapAreas(), and ModelCoreSpatial::updateOtherMapData().

bool GUI

private

Definition at line 193 of file ThreadManager.h.

Init* INIT

the Init object (pre-simulation scheduler)

Definition at line 74 of file ThreadManager.h.

Referenced by MainProgram::run().

QString inputFileName

private

Definition at line 187 of file ThreadManager.h.

volatile int layerQueryPos

private

Definition at line 191 of file ThreadManager.h.

ModelData* MD

the model data object

Definition at line 72 of file ThreadManager.h.

Referenced by ModelCoreSpatial::assignSpMultiplierPropToVols(), ModelCoreSpatial::cacheDynamicSettings(), ModelCoreSpatial::cachePixelExogenousData(), ModelCore::cacheSettings(), ModelCoreSpatial::cacheSettings(), Output::commonInit(), ModelCoreSpatial::computeCumulativeData(), ModelCoreSpatial::computeInventary(), ModelRegion::getArea(), ModelData::getAvailableAliveTimber(), ModelData::getBoolSetting(), ModelData::getBoolVectorSetting(), ModelData::getDoubleSetting(), ModelData::getDoubleVectorSetting(), ModelData::getIntSetting(), ModelData::getIntVectorSetting(), Pixel::getMultiplier(), Output::getOutputFieldDelimiter(), Pixel::getPathMortality(), ModelData::getRegionIds(), ModelRegion::getSiblings(), Pixel::getSpModifier(), Pixel::getSTData(), Carbon::getStock(), ModelData::getStringSetting(), ModelData::getStringVectorSetting(), ModelCore::gfd(), ModelCoreSpatial::gfd(), ModelCore::gpd(), ModelCoreSpatial::gpd(), Carbon::HWP_eol2energy(), Carbon::initialiseDeathBiomassStocks(), Carbon::initialiseEmissionCounters(), Carbon::initialiseProductsStocks(), Output::initOutputForestData(), ModelCoreSpatial::loadExogenousForestLayers(), ModelData::loadInput(), MainProgram::MainProgram(), ModelRegion::ModelRegion(), Pixel::Pixel(), Output::print(), Layers::print(), Layers::printBinMap(), Output::printCarbonBalance(), Output::printDebugOutput(), Output::printDebugPixelValues(), Output::printDetailedHV(), Output::printFinalOutput(), Output::printForestData(), Output::printProductData(), ModelData::regId2RegSName(), Carbon::registerDeathBiomass(), Carbon::registerHarvesting(), Carbon::registerProducts(), Carbon::registerTransports(), ModelData::regSName2RegId(), ModelCoreSpatial::resetPixelValues(), Scheduler::run(), ModelCoreSpatial::runBiologicalModule(), ModelCore::runManagementModule(), ModelCoreSpatial::runManagementModule(), ModelCore::runMarketModule(), ModelCoreSpatial::runMarketModule(), Init::setInitLevel1(), Init::setInitLevel3(), ModelCore::sfd(), ModelCoreSpatial::sfd(), ModelCore::spd(), ModelCoreSpatial::spd(), ModelCoreSpatial::sumRegionalForData(), ModelCore::updateMapAreas(), ModelCoreSpatial::updateMapAreas(), and ModelCoreSpatial::updateOtherMapData().

QString messageStr

private

Definition at line 184 of file ThreadManager.h.

QMutex mutex

private

Definition at line 192 of file ThreadManager.h.

Ipopt::SmartPtr<Ipopt::TNLP> OPT

Market optimisation.

Definition at line 81 of file ThreadManager.h.

Referenced by ModelCore::runMarketModule(), and ModelCoreSpatial::runMarketModule().

volatile int pxQueryID

private

Definition at line 190 of file ThreadManager.h.

volatile bool running

private

Definition at line 186 of file ThreadManager.h.

Scheduler* SCD

the scheduler object (simulation-loops scheduler)

Definition at line 75 of file ThreadManager.h.

Referenced by ModelCoreSpatial::allocateHarvesting(), ModelCore::cacheSettings(), ModelCore::computeCumulativeData(), ModelCoreSpatial::computeCumulativeData(), ModelCoreSpatial::computeEconomicBalances(), ModelCore::computeInventary(), ModelCoreSpatial::computeInventary(), ModelData::getAllocableProductIdsFromDeathTimber(), ModelData::getBaseData(), Pixel::getMultiplier(), Pixel::getPathMortality(), Pixel::getSTData(), Carbon::getStock(), ModelData::getTimedData(), ModelCoreSpatial::getVHaByYear(), Carbon::HWP_eol2energy(), Carbon::initialiseDeathBiomassStocks(), ModelCoreSpatial::initialiseDeathTimber(), Carbon::initialiseProductsStocks(), Output::print(), Layers::print(), Layers::printBinMap(), Output::printCarbonBalance(), Output::printDebugOutput(), Output::printDebugPixelValues(), Output::printDetailedHV(), Output::printForestData(), Output::printMaps(), Output::printOptLog(), Output::printProductData(), Carbon::registerDeathBiomass(), Carbon::registerHarvesting(), Carbon::registerProducts(), ModelCore::runBiologicalModule(), ModelCoreSpatial::runBiologicalModule(), ModelCore::runInitPeriod(), ModelCoreSpatial::runInitPeriod(), ModelCore::runManagementModule(), ModelCoreSpatial::runManagementModule(), ModelCore::runMarketModule(), ModelCoreSpatial::runMarketModule(), ModelCore::runSimulationYear(), ModelCoreSpatial::runSimulationYear(), Init::setInitLevel1(), Init::setInitLevel5(), ModelData::setTimedData(), ModelCoreSpatial::sumRegionalForData(), ModelCore::updateMapAreas(), and ModelCoreSpatial::updateMapAreas().

QString scenarioName

private

Definition at line 189 of file ThreadManager.h.

ModelCoreSpatial* SCORE

Core of the model (spatial version)

Definition at line 78 of file ThreadManager.h.

Referenced by Scheduler::run(), and Init::setInitLevel3().

volatile bool stopped

private

Definition at line 185 of file ThreadManager.h.

Sandbox* TEST

Various debugging code for development.

Definition at line 80 of file ThreadManager.h.

Referenced by Init::setInitLevel1().

---

The documentation for this class was generated from the following files:

• /srv/datadisk03/home/ffsm/code/ffsm_pp/src/ThreadManager.h
• /srv/datadisk03/home/ffsm/code/ffsm_pp/src/ThreadManager.cpp