-// Copyright (C) 2007-2014 CEA/DEN, EDF R&D
+// Copyright (C) 2007-2020 CEA/DEN, EDF R&D
//
// This library is free software; you can redistribute it and/or
// modify it under the terms of the GNU Lesser General Public
#include <unistd.h>
#endif
+
+#ifdef OMPI_MAJOR_VERSION
+# if OMPI_MAJOR_VERSION >= 4
+# define MPI_ERROR_HANDLER(var) MPI_Comm_set_errhandler(MPI_COMM_WORLD, var)
+# else
+# define MPI_ERROR_HANDLER(var) MPI_Errhandler_set(MPI_COMM_WORLD, var)
+# endif
+#else // MPICH and other versions:
+# define MPI_ERROR_HANDLER(var) MPI_Errhandler_set(MPI_COMM_WORLD, var)
+#endif
+
MPI2Connector::MPI2Connector()
{
MPI_Comm_size( MPI_COMM_WORLD, &_nb_proc );
_srv = false;
MPI_Barrier(MPI_COMM_WORLD);
-
- MPI_Errhandler_set(MPI_COMM_WORLD, MPI_ERRORS_RETURN);
+ MPI_ERROR_HANDLER(MPI_ERRORS_RETURN);
if( _num_proc == 0 )
{
/* rank 0 try to be a server. If service is already published, try to be a cient */
throw std::exception();
}
}
- MPI_Errhandler_set(MPI_COMM_WORLD, MPI_ERRORS_ARE_FATAL);
+ MPI_ERROR_HANDLER(MPI_ERRORS_ARE_FATAL);
/* If rank 0 is server, all processes call MPI_Comm_accept */
/* If rank 0 is not server, all processes call MPI_Comm_connect */