MPIParameterDealer.h

/*
    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 MPIPARAMETERDEALER_H
#define MPIPARAMETERDEALER_H
#include <stddef.h>
#include <DataReader.h>
#include <mpi.h>

namespace frib {
    namespace analysis {
        class AbstractApplication;

        
        class CMPIParameterDealer {
        private:
            int    m_argc;
            char** m_argv;
            AbstractApplication* m_pApp;
            CDataReader* m_pReader;
            unsigned     m_nBlockSize;
            unsigned     m_nEndsLeft;
            
        public:
            CMPIParameterDealer(int argc, char** argv, AbstractApplication* pApp);
            virtual ~CMPIParameterDealer();
        private:
            CMPIParameterDealer(const CMPIParameterDealer& rhs);
            CMPIParameterDealer& operator=(const CMPIParameterDealer& rhs);
            int operator==(const CMPIParameterDealer& rhs);
            int operator!=(const CMPIParameterDealer& rhs);
        public:
            void operator()();
        private:
            virtual const char* getInputFile(int  argc, char** argv) const;
            virtual unsigned getBlockSize(int argc, char** argv) const;
            
            size_t sendDefinitions(const void* pData);
            size_t sendParameterDefs(const void* pData);
            size_t sendVariableValues(const void* pData);
            void sendData(size_t nItems, const void* pData);
            void sendWorkItem(const void* pData);
            void sendPassthrough(const void* pData);
            
            void sendAll(
                const void* pData, MPI_Datatype type, size_t numItems, int tag
            );
            void sendEofs();
            void sendEof();
        };
    }
}


#endif