slave.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>



#ifndef __SLAVE_H_INCLUDED__
#define __SLAVE_H_INCLUDED__


#include "step1_funcs.hpp"
#include "step2_funcs.hpp"
#include "mtrand.hpp"
#include "random.hpp"
#include "step2readandwrite.hpp"
#include "timing.hpp"
#include "datagatherer.hpp"


// you must include gmp pour include polysolve.
#include <gmp.h>

extern "C" {
#include "bertini.h"
}



class slave_process{
    
    
public:
    
    
    slave_process(){
        this->have_dotout = false;
        this->have_input = false;
        this->have_start = false;
        
        this->in_working_folder = false;
        /* 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->filename = "";
        this->numfilesatatime = -1;

        this->tmpfolder = "";
        
        this->numparam = -1;
        this->standardstep2 = -1;

    };
    
        void slave_main(ProgSettings input_settings,
                                    runinfo input_p_info,
                                    timer & process_timer);
    
    
    
private:
    
    runinfo paramotopy_info; 
    ProgSettings paramotopy_settings; 
    
    
    boost::filesystem::path filename;           
    int numfilesatatime;            
    int numfilesatatime_orig; 
    boost::filesystem::path called_dir;   
    boost::filesystem::path homedir;      
    
    boost::filesystem::path workingfolder;  
    
    boost::filesystem::path tmpfolder;          
    
    
    
    datagatherer slavegatherer;  
    
    unsigned int currentSeed;    
    int MPType;   
    
    
    int linenumber;  

    int numparam;  
    
    
    int numprocs;  

    
    int myid; 
    
    int standardstep2;   
    
    
    std::vector<std::string> numdotout;         
    std::vector<std::string> arrdotout;         
    std::vector<std::string> degdotout;         
    std::vector<std::string> namesdotout;       
    std::vector<std::string> config;                
    std::vector<std::string> funcinput;         
    std::vector<std::string> preproc_data;  
    

    bool have_dotout;           
    bool have_input;            
    char* input_file;       
    
    bool have_start;            
    char* start_file;       
    
    
    bool in_working_folder; 
    
    
    
    
    
    void SlaveSetup();
    
    
    
    
    
    //
    
    
    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 ReceiveInput(timer & process_timer);
    
    void ReceiveStart(timer & process_timer);
    
    
    void WriteStart();
    
    void WriteInput();
    
    void ReadDotOut();
    
    void WriteDotOut();
    
    
    void WriteNumDotOut(double current_params[]);
    
    
    void SetWorkingFolder();
    
    
    void PurgeWorkingFolder();
    
    void MoveToWorkingFolder();
    
    void GoCalledDir();
    
    
    void ReadyCheck();
    
    
};








#endif