gsMpi.h

Go to the documentation of this file.

 
#pragma once
 
#include <gsCore/gsForwardDeclarations.h>
 
#ifdef GISMO_WITH_MPI
#include <string.h>
#include <mpi.h>
// #if MPI_VERSION < 2
// #  ifdef _MSC_VER
// #    pragma message ("The MPI version is older than MPI-2.")
// #  else
// #    warning "The MPI version is older than MPI-2."
// #  endif
//#endif
#include <gsParallel/gsMpiTraits.h>
#include <gsParallel/gsBinaryFunctions.h>
#endif
 
#include <gsParallel/gsMpiComm.h>
 
namespace gismo
{
 
class gsMpi;
 
GISMO_EXPORT gsMpi & gsMpiSingleton(const int& argc, char** argv);
 
class gsMpi
{
 
public:
      
    friend GISMO_EXPORT gsMpi & gsMpiSingleton(const int& argc, char** argv);
    
#   ifdef GISMO_WITH_MPI
    typedef MPI_Comm Communicator;
#   else
    typedef gsSerialComm Communicator;
#   endif
 
    static Communicator worldComm()
    {
#   ifdef GISMO_WITH_MPI
        return MPI_COMM_WORLD;
#   else
        return localComm();
#   endif
    }
 
    static Communicator localComm()
    {
        return gsSerialComm();
    }
    
    static gsMpi& init(const int& argc = 0, char** argv = NULL)
    {
        GISMO_ASSERT( 0 == argc || NULL!=argv, "Need both argc and argv (or none)");
        return gsMpiSingleton(argc,argv);
    }
    
    static int worldRank () { return gsMpiComm(worldComm()).rank(); }
    static int worldSize () { return gsMpiComm(worldComm()).size(); }
 
    static inline double wallTime()
    {
#   ifdef GISMO_WITH_MPI
        return MPI_Wtime();
#    else
        return 0;
#    endif
    }
 
    static inline std::string getProcessorName()
    {
#   ifdef GISMO_WITH_MPI
        char processor_name[MPI_MAX_PROCESSOR_NAME];
        int name_len;
        MPI_Get_processor_name(processor_name, &name_len);
        return std::string(processor_name, name_len);
#    else
 
        //linux: gethostname(processor_name, HOST_NAME_MAX);
        //mswin: GetComputerName(processor_name, &name_len)
        return "SingleCPU";
#    endif
    }
 
    bool initialized() const
    {
#   ifdef GISMO_WITH_MPI
        int init = -1;
        MPI_Initialized( &init );
        return (0 != init);
#    endif
        return false;
    }
    
private:
 
    gsMpi();
    
    gsMpi(const int& argc, char** argv)
    {
        initMpi(const_cast<int*>(&argc), argv);
    }
 
    void initMpi(int * argc = NULL, char** argv = NULL) const
    {
#   ifdef GISMO_WITH_MPI
        if( !initialized() )
        {
#ifdef _OPENMP
            // Initialize MPI with multi-threading support
            char* thread_level = getenv("GISMO_MPI_THREAD_LEVEL");
            const int req_level = ( NULL != thread_level ? atoi(getenv("GISMO_MPI_THREAD_LEVEL")) : 0);
            int MPI_thread_required = MPI_THREAD_SINGLE, MPI_thread_provided;
            switch(req_level)
            {
            case 0:
                MPI_thread_required = MPI_THREAD_SINGLE;
                break;
            case 1:
                MPI_thread_required = MPI_THREAD_FUNNELED;
                break;
            case 2:
                MPI_thread_required = MPI_THREAD_SERIALIZED;
                break;
            case 3:
                MPI_thread_required = MPI_THREAD_MULTIPLE;
                break;
            default:
                GISMO_ERROR("Invalid value for environment variable GISMO_MPI_THREAD_LEVEL");
            };
 
            const int init = MPI_Init_thread(argc, &argv, MPI_thread_required, &MPI_thread_provided);
            GISMO_ENSURE(MPI_SUCCESS==init &&
                         MPI_thread_required <= MPI_thread_provided, "MPI failed to initialize");
#else
            //Note: valgrind false positive here, see
            // https://www.open-mpi.org/faq/?category=debugging#valgrind_clean
            const int init = MPI_Init(argc, &argv);
            GISMO_ENSURE(MPI_SUCCESS==init, "MPI failed to initialize");
#endif
        }
#       ifndef NDEBUG
        MPI_Comm_create_errhandler(gsMpiComm::ErrCallBack, &gsMpiComm::ErrHandler);
        MPI_Comm_set_errhandler(worldComm(), gsMpiComm::ErrHandler);
#       endif
#   else
        GISMO_UNUSED(argc);
        GISMO_UNUSED(argv);
#   endif
        //gsDebug << "Called  MPI_Init on p=" << rank_ << "!" << std::endl;
    }
    
    ~gsMpi()
    {
#   ifdef GISMO_WITH_MPI
        int wasFinalized = -1;
        MPI_Finalized( &wasFinalized );
        if( 0 == wasFinalized)
        {
            MPI_Finalize();
        }
#    endif
        //gsDebug << "Called MPI_Finalize on p=" << rank_ << "!" <<std::endl;
    }
    
    gsMpi(const gsMpi&);
    gsMpi& operator=(const gsMpi&);
 
};
 
}