52#ifdef HAVE_TEUCHOSCORE_KOKKOSCORE
53# include "Kokkos_Core.hpp"
66#ifdef HAVE_TEUCHOSCORE_KOKKOSCORE
70std::vector<std::string> GlobalMPISession::argvCopy_;
77 std::ostringstream
oss;
91 *out <<
"GlobalMPISession(): Error, MPI_Intialized() return true,"
92 <<
" calling std::terminate()!\n"
102 *out <<
"GlobalMPISession(): Error, MPI_Init() returned error code="
103 <<
mpierr <<
"!=0, calling std::terminate()!\n"
116 *out <<
"GlobalMPISession(): Error, MPI_Get_processor_name() error code="
117 <<
mpierr <<
"!=0, calling std::terminate()!\n"
123 oss <<
"Teuchos::GlobalMPISession::GlobalMPISession(): started processor with name "
128 oss <<
"Teuchos::GlobalMPISession::GlobalMPISession(): started serial run"
133#ifndef TEUCHOS_SUPPRESS_PROC_STARTUP_BANNER
137 const std::string
suppress_option(
"--teuchos-suppress-startup-banner");
145 (*
argv)[
i] = (*argv)[
i+1];
150 *out <<
oss.str() << std::flush;
155#ifdef HAVE_TEUCHOSCORE_KOKKOSCORE
179#ifdef HAVE_TEUCHOSCORE_KOKKOSCORE
180std::vector<std::string> GlobalMPISession::getArgv ()
190#ifdef HAVE_TEUCHOSCORE_KOKKOSCORE
192 if (Kokkos::is_initialized())
195 catch (
const std::runtime_error&
e) {
196 std::cerr <<
"Kokkos::finalize failed:\n"
203 const int mpierr = ::MPI_Finalize();
206 std::cerr <<
"Error code " <<
mpierr <<
" returned from MPI_Finalize()\n";
316 *out <<
"Error code=" <<
mpierr <<
" detected in MPI_Comm_rank()"
322 *out <<
"Error code=" <<
mpierr <<
" detected in MPI_Comm_size()"
A MPI utilities class, providing methods for initializing, finalizing, and querying the global MPI se...
int size(const Comm< Ordinal > &comm)
Get the number of processes in the communicator.
static int sum(int localVal)
Sum a set of integers across processes.
static void abort()
abort the program
static void barrier()
Call MPI_Barrier() on MPI_COMM_WORLD.
static int getRank()
The rank of the calling process in MPI_COMM_WORLD.
GlobalMPISession(int *argc, char ***argv, std::ostream *out=&std::cout)
Calls MPI_Init() if MPI is enabled.
static int getNProc()
The number of processes in MPI_COMM_WORLD.
static bool mpiIsInitialized()
Return whether MPI was initialized.
static void justInTimeInitialize()
static bool mpiIsFinalized_
static bool mpiIsFinalized()
Return whether MPI was already finalized.
static bool haveMPIState_
static void allGather(int localVal, const ArrayView< int > &allVals)
Global all-to-all of a set of integers across processes.
~GlobalMPISession()
Call MPI_Finalize() if MPI is enabled.
static void initialize(std::ostream *out)
Concrete serial communicator subclass.
#define TEUCHOS_ASSERT_EQUALITY(val1, val2)
This macro is checks that to numbers are equal and if not then throws an exception with a good error ...