master.hpp

Go to the documentation of this file.

#include <mpi.h>
#include <sys/wait.h>
#include <sys/stat.h>
#include <sys/types.h> 
#include <vector>
#include <map>
#include <iostream>
#include <string>
#include <sstream>
#include <fstream>
#include <stdio.h>
#include <stdlib.h>
#include <iomanip>


#ifndef __MASTER_H__
#define __MASTER_H__

#include "step1_funcs.hpp"
#include "step2_funcs.hpp"
#include "mtrand.hpp"
#include "random.hpp"

#include "para_aux_funcs.hpp"
#include "step2readandwrite.hpp"
#include "runinfo.hpp"
#include "timing.hpp"





class master_process{
    
public:
    
//  master_process(communicator){
//      
//      /* Find out how many processes there are in the default
//       communicator */
//      MPI_Comm_size(MPI_COMM_WORLD, &this->numprocs);
//      
//      MPI_Comm_rank(MPI_COMM_WORLD,&this->myid);
//      
//      
//      this->called_dir = stackoverflow_getcwd();
//      this->homedir = getenv("HOME");
//      
//      this->num_active_workers = 0;
//  }
    
    master_process(){
        
        /* Find out how many processes there are in the default
         communicator */
        MPI_Comm_size(MPI_COMM_WORLD, &this->numprocs);
        
        MPI_Comm_rank(MPI_COMM_WORLD,&this->myid);
        
        
        this->called_dir = stackoverflow_getcwd();
        this->homedir = getenv("HOME");
        
        this->num_active_workers = 0;
    }
    
    
    void master_main(ProgSettings input_settings,
                                     runinfo input_p_info,
                                     timer & process_timer);
    
    
    
    
    
    
private:
    
    runinfo paramotopy_info; 
    ProgSettings paramotopy_settings; 
    
    std::vector< int > lastnumsent; 
    
    int numprocs;    
    
    int myid;        
    
    int numparam;        
    
    boost::filesystem::path filename;  
    
    int standardstep2;  
    
    int numfilesatatime;    
    int numfilesatatime_orig; 
    
    int terminationint;   
    int current_absolute_index;  
    
    
    boost::filesystem::path lastoutfilename;  
    boost::filesystem::path tmpfolder; 
    boost::filesystem::path called_dir;  
    boost::filesystem::path homedir; 
    
    std::ofstream mc_out_stream;  
    std::ifstream mc_in_stream; 
    
    std::vector< int > index_conversion_vector;// for the index making function

    
    std::map< int, bool> active_workers; 
    int num_active_workers;  
    
    
    
    void MasterSetup();
    
    
    
    //
    
    
    void SeedSwitch(timer & process_timer);
    
    
    void SeedBasic(timer & process_timer);
    
    void SeedSearch(timer & process_timer);
    
    

    
    
    
    
    
    //
    
    
    void LoopSwitch(timer & process_timer);
    
    
    void LoopBasic(timer & process_timer);
    
    void LoopSearch(timer & process_timer);
    
    
    
    
    
    //

    
    
    void CleanupSwitch(timer & process_timer);
    
    
    void CleanupBasic(timer & process_timer);
    
    
    void CleanupSearch(timer & process_timer);
    
    
    
    
    
    
    //
    
    void SendInput(timer & process_timer);
    
    void SendStart(timer & process_timer);
    
    
    
    
    
    
    
    
    //
    
    
    
    void NextRandomValue(int pointcounter, // localcounter tells which indices in tempsends
                                             double tempsends[]);
    
    
    
    
    void FormNextValues(int pointcounter,
                                            std::vector< std::vector< std::pair<double,double> > > Values,
                                            double tempsends[]);
    
    void FormNextValues_mc(int pointcounter,
                                                 double tempsends[]);

    
    
    void GetTerminationInt();
    
    void OpenMC();
    
    
    void SetTmpFolder();
    
    void SetUpFolders();
    
    void TerminateInactiveWorker(int worker_id,
                                                             timer & process_timer);
    
    
    void TerminateActiveWorker(int worker_id,
                                                         timer & process_timer);
    
    void ReadyCheck();
};









#endif