MPIParametersToParametersWorker.h

Go to the documentation of this file.

/*
    This software is Copyright by the Board of Trustees of Michigan
    State University (c) Copyright 2017.

    You may use this software under the terms of the GNU public license
    (GPL).  The terms of this license are described at:

     http://www.gnu.org/licenses/gpl.txt

     Authors:
             Ron Fox
             Giordano Cerriza
         FRIB
         Michigan State University
         East Lansing, MI 48824-1321
*/

#ifndef MPIPARAMETERSTOPARAMETERSWORKER_h
#define MPIPARAMETERSTOPARAMETERSWORKER_h
#include <vector>
#include <map>
#include <cstdint>

namespace frib {
    namespace analysis {
        class AbstractApplication;
        class CTreeParameter;
        
        struct _FRIB_MPI_ParameterDef;
        typedef _FRIB_MPI_ParameterDef
            FRIB_MPI_ParameterDef, *pFRIB_MPI_ParameterDef;
            
        struct _FRIB_MPI_VariableDef;
        typedef _FRIB_MPI_VariableDef
            FRIB_MPI_VariableDef, *pFRIB_MPI_VariableDef;
            
        struct _FRIB_MPI_Parameter_Value;
        typedef _FRIB_MPI_Parameter_Value
            FRIB_MPI_Parameter_Value, *pFRIB_MPI_Parameter_Value;

                    
        class CMPIParametersToParametersWorker  {
        public:
            typedef std::pair<std::string, double>   VariableInfo;   //units/value
        private:
            std::map<std::string, VariableInfo>   m_variableMap;
            std::vector<CTreeParameter*>          m_parameterMap;
            
            int                   m_argc;
            char**                m_argv;
            AbstractApplication*  m_pApp;
        public:
            CMPIParametersToParametersWorker(
                int argc, char** argv, AbstractApplication* pApp
            );
            virtual ~CMPIParametersToParametersWorker();
            
            virtual void operator()();
            virtual void process() = 0;
        protected:            
            VariableInfo* getVariable(const char* pVarName);
            void loadVariable(const char* pVarName);
            std::vector<std::string> getVariableNames();
        private:
            void receiveParameterDefinitions();
            void receiveVariableDefinitions();
            void receiveEvents();
            
            void loadTreeParameterMap(
                const std::vector<FRIB_MPI_ParameterDef>& params
            );
            void loadVariableMap(
                const std::vector<FRIB_MPI_VariableDef>& vars
            );
            void loadTreeParameters(
                const std::vector<FRIB_MPI_Parameter_Value>& params
            );
            void sendEventToFarmer(std::uint64_t trigger);
            void sendEndToFarmer();
            
        };
    }
}

#endif