parallel_utils.h

#ifndef NGEN_PARALLEL_UTILS_H
#define NGEN_PARALLEL_UTILS_H
 
#include <NGenConfig.h>
#if NGEN_WITH_MPI
 
#ifndef MPI_HF_SUB_CODE_GOOD
#define MPI_HF_SUB_CODE_GOOD 0
#endif
 
#ifndef MPI_HF_SUB_CODE_BAD
#define MPI_HF_SUB_CODE_BAD 1
#endif
 
#ifndef NGEN_MPI_DATA_TAG
#define NGEN_MPI_DATA_TAG 100
#endif
 
#ifndef NGEN_MPI_PROTOCOL_TAG
#define NGEN_MPI_PROTOCOL_TAG 101
#endif
 
#include <mpi.h>
#include <string>
#include <vector>
 
namespace parallel {
 
    bool mpiSyncStatusAnd(bool status, MPI_Comm comm, const std::string &taskDesc);
 
    bool mpiSyncStatusAnd(bool status, MPI_Comm comm);
 
    bool is_hydrofabric_subdivided(const std::string &catchmentDataFile, MPI_Comm comm, bool printMsg);
 
    void get_hosts_array(MPI_Comm comm, int *host_array);
 
    bool mpi_send_text_file(const char *fileName, MPI_Comm comm, const int destRank);
 
    bool mpi_recv_text_file(const char *fileName, MPI_Comm comm, const int srcRank);
 
    bool distribute_subdivided_hydrofabric_files(const std::string &baseCatchmentFile, const std::string &baseNexusFile,
                                                 const int sendingRank, MPI_Comm comm,
                                                 const int *hostIdForRank, bool syncReturnStatus, bool blockAll);
 
    bool subdivide_hydrofabric(MPI_Comm comm, const std::string &catchmentDataFile,
                               const std::string &nexusDataFile, const std::string &partitionConfigFile);
 
    std::vector<std::string> gather_strings(const std::vector<std::string>& local_strings, MPI_Comm comm);
 
    std::vector<std::string> broadcast_strings(const std::vector<std::string>& strings, MPI_Comm comm);
}
 
#endif // NGEN_WITH_MPI
 
#endif //NGEN_PARALLEL_UTILS_H