MPIRawToParametersWorker.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 MPIRAWTOPARAMETERSWORKER_H
#define MPIRAWTOPARAMETERSWORKER_H
#include <stddef.h>
#include <vector>
#include <cstdint>


namespace frib {
    namespace analysis {
        class AbstractApplication;
        struct _FRIB_MPI_Message_Header;
        typedef struct _FRIB_MPI_Message_Header FRIB_MPI_Message_Header;
        struct _FRIB_MPI_Parameter_Value;
        typedef struct _FRIB_MPI_Parameter_Value FRIB_MPI_Parameter_Value;
        class CMPIRawToParametersWorker {
            AbstractApplication& m_App;
            int          m_rank;
            FRIB_MPI_Parameter_Value* m_pParameterBuffer;
            size_t       m_paramBufferSize;
        public:
            CMPIRawToParametersWorker(AbstractApplication& App);
            virtual ~CMPIRawToParametersWorker();
            virtual void operator()(int argc, char** argv);
            virtual void initializeUserCode(
                int argc, char** argv, AbstractApplication& pApp
            ) {}
            virtual void unpackData(const void* pData) = 0;
        private:
            void requestData();
            void getHeader(FRIB_MPI_Message_Header& header);
            void getData(void* pData, size_t nBytes);
            void forwardPassthrough(const void* pData, size_t nBytes);
            void sendParameters(const std::vector<std::pair<unsigned, double>>& event, std::uint64_t trigger);
            void sendEnd();
            void processDataBlock(const void* pData, size_t nBytes, std::uint64_t firstTrigger);
            void throwMPIError(int status, const char* prefix);
        };
        
    }
}
#endif