Parallel frontend that abstracts functionalities needed to spawn processes and handle communication. More...

Namespaces
namespace	detail

Classes
class	Message
	Hold the description and status of communication data. More...

struct	Mpi_typemap
	Communication datatype (note: this structure also works without MPI) More...

struct	Mpi_typemap< GpuComplex< T > >

struct	Mpi_typemap< ValLocPair< TV, TI > >

struct	ProcessTeam
	Provide functionalities needed to construct a team of processes to perform a particular job. More...

Functions
void	StartParallel (int argc=nullptr, char **argv=nullptr, MPI_Comm mpi_comm=MPI_COMM_WORLD)
	Perform any needed parallel initialization. This MUST be the first routine in this class called from within a program.

void	Gather (Real const sendbuf, int nsend, Real recvbuf, int root)

void	EndParallel ()
	Perform any needed parallel finalization. This MUST be the last routine in this class called from within a program.

void	Abort (int errorcode=SIGABRT, bool backtrace=true)
	Abort with specified error code.

const char *	ErrorString (int errorcode)
	ErrorString return string associated with error internal error condition.

void	Barrier (const std::string &message=Unnamed)

void	Barrier (const MPI_Comm &comm, const std::string &message=Unnamed)

Message	Abarrier ()

Message	Abarrier (const MPI_Comm &)

void	Test (MPI_Request &, int &, MPI_Status &)

void	Test (Vector< MPI_Request > &, int &, Vector< MPI_Status > &)

void	IProbe (int, int, int &, MPI_Status &)

void	IProbe (int, int, MPI_Comm, int &, MPI_Status &)

void	Comm_dup (MPI_Comm, MPI_Comm &)

void	ReduceRealSum (Vector< std::reference_wrapper< Real > > const &)

void	ReduceRealMax (Vector< std::reference_wrapper< Real > > const &)

void	ReduceRealMin (Vector< std::reference_wrapper< Real > > const &)

void	ReduceRealSum (Vector< std::reference_wrapper< Real > > const &, int)

void	ReduceRealMax (Vector< std::reference_wrapper< Real > > const &, int)

void	ReduceRealMin (Vector< std::reference_wrapper< Real > > const &, int)

void	ReduceLongAnd (Long &)

void	ReduceLongSum (Long &)

void	ReduceLongMax (Long &)

void	ReduceLongMin (Long &)

void	ReduceLongAnd (Long &, int)

void	ReduceLongSum (Long &, int)

void	ReduceLongMax (Long &, int)

void	ReduceLongMin (Long &, int)

void	ReduceLongAnd (Long *rvar, int cnt)

void	ReduceLongSum (Long *rvar, int cnt)

void	ReduceLongMax (Long *rvar, int cnt)

void	ReduceLongMin (Long *rvar, int cnt)

void	ReduceLongAnd (Long *rvar, int cnt, int cpu)

void	ReduceLongSum (Long *rvar, int cnt, int cpu)

void	ReduceLongMax (Long *rvar, int cnt, int cpu)

void	ReduceLongMin (Long *rvar, int cnt, int cpu)

void	ReduceLongAnd (Vector< std::reference_wrapper< Long > > const &rvar)

void	ReduceLongSum (Vector< std::reference_wrapper< Long > > const &rvar)

void	ReduceLongMax (Vector< std::reference_wrapper< Long > > const &rvar)

void	ReduceLongMin (Vector< std::reference_wrapper< Long > > const &rvar)

void	ReduceLongAnd (Vector< std::reference_wrapper< Long > > const &rvar, int cpu)

void	ReduceLongSum (Vector< std::reference_wrapper< Long > > const &rvar, int cpu)

void	ReduceLongMax (Vector< std::reference_wrapper< Long > > const &rvar, int cpu)

void	ReduceLongMin (Vector< std::reference_wrapper< Long > > const &rvar, int cpu)

void	ReduceIntSum (int &)

void	ReduceIntMax (int &)

void	ReduceIntMin (int &)

void	ReduceIntSum (int &, int)

void	ReduceIntMax (int &, int)

void	ReduceIntMin (int &, int)

void	ReduceIntSum (int *rvar, int cnt)

void	ReduceIntMax (int *rvar, int cnt)

void	ReduceIntMin (int *rvar, int cnt)

void	ReduceIntSum (int *rvar, int cnt, int cpu)

void	ReduceIntMax (int *rvar, int cnt, int cpu)

void	ReduceIntMin (int *rvar, int cnt, int cpu)

void	ReduceIntSum (Vector< std::reference_wrapper< int > > const &rvar)

void	ReduceIntMax (Vector< std::reference_wrapper< int > > const &rvar)

void	ReduceIntMin (Vector< std::reference_wrapper< int > > const &rvar)

void	ReduceIntSum (Vector< std::reference_wrapper< int > > const &rvar, int cpu)

void	ReduceIntMax (Vector< std::reference_wrapper< int > > const &rvar, int cpu)

void	ReduceIntMin (Vector< std::reference_wrapper< int > > const &rvar, int cpu)

void	ReduceBoolAnd (bool &)

void	ReduceBoolOr (bool &)

void	ReduceBoolAnd (bool &, int)

void	ReduceBoolOr (bool &, int)

void	Bcast (void *, int, MPI_Datatype, int, MPI_Comm)

double	second () noexcept
	Returns wall-clock seconds since start of execution.

void	Wait (MPI_Request &, MPI_Status &)

void	Waitall (Vector< MPI_Request > &, Vector< MPI_Status > &)

void	Waitany (Vector< MPI_Request > &, int &, MPI_Status &)

void	Waitsome (Vector< MPI_Request > &, int &, Vector< int > &, Vector< MPI_Status > &)

void	AMREX_FORT_NAME (BL_PD_BARRIER, bl_pd_barrier)()

void	AMREX_FORT_NAME (BL_PD_COMMUNICATOR, bl_pd_communicator)(void *vcomm)

void	AMREX_FORT_NAME (BL_PD_MYPROC, bl_pd_myproc)(int *myproc)

void	AMREX_FORT_NAME (BL_PD_NPROCS, bl_pd_nprocs)(int *nprocs)

void	AMREX_FORT_NAME (BL_PD_IOPROC, bl_pd_ioproc)(int *ioproc)

void	AMREX_FORT_NAME (BL_PD_IS_IOPROC, bl_pd_is_ioproc)(int *ioproc)

void	AMREX_FORT_NAME (BL_PD_SECOND, bl_pd_second)(double *r)

void	AMREX_FORT_NAME (BL_PD_REDUCE_REAL_MAX_TO_IOPROC, bl_pd_reduce_real_max_to_ioproc)(double *r)

void	AMREX_FORT_NAME (BL_PD_REDUCE_REAL_SUM_TO_IOPROC, bl_pd_reduce_real_sum_to_ioproc)(double *r)

void	AMREX_FORT_NAME (BL_PD_ABORT, bl_pd_abort)()

void	ReadAndBcastFile (const std::string &filename, Vector< char > &charBuf, bool bExitOnError=true, const MPI_Comm &comm=Communicator())

void	Initialize ()

void	Finalize ()

void	StartTeams ()
	Split the process pool into teams.

void	EndTeams ()

std::string	mpi_level_to_string (int mtlev)

const std::string	Unnamed ("Unnamed")
	Used as default argument to ParallelDescriptor::Barrier().

bool	UseGpuAwareMpi ()

int	MyProc () noexcept

int	MyProc (MPI_Comm comm) noexcept

int	MinTag () noexcept

int	MaxTag () noexcept

MPI_Comm	Communicator () noexcept

int	NProcsPerNode () noexcept

int	MyRankInNode () noexcept

int	NProcsPerProcessor () noexcept

int	MyRankInProcessor () noexcept

int	NProcs () noexcept

int	NProcs (MPI_Comm comm) noexcept

int	IOProcessorNumber () noexcept

bool	IOProcessor () noexcept
	Is this CPU the I/O Processor? To get the rank number, call IOProcessorNumber()

int	IOProcessorNumber (MPI_Comm comm) noexcept

bool	IOProcessor (MPI_Comm comm) noexcept

int	TeamSize () noexcept

int	NTeams () noexcept

int	MyTeamColor () noexcept

int	MyTeamLead () noexcept

int	MyRankInTeam () noexcept

int	TeamLead (int rank) noexcept

bool	isTeamLead () noexcept

bool	sameTeam (int rank) noexcept

bool	sameTeam (int rankA, int rankB) noexcept

int	RankInLeadComm (int rank) noexcept

bool	doTeamReduce () noexcept

const ProcessTeam &	MyTeam () noexcept

std::pair< int, int >	team_range (int begin, int end, int rit=-1, int nworkers=0) noexcept

template<typename F >
void	team_for (int begin, int end, const F &f)

template<typename F >
void	team_for (int begin, int end, int rit, const F &f)

template<typename F >
void	team_for (int begin, int end, int rit, int nworkers, const F &f)

template<typename T >
std::enable_if_t< std::is_floating_point_v< T > >	ReduceRealSum (T &rvar)
	Real sum reduction.

template<typename T >
std::enable_if_t< std::is_floating_point_v< T > >	ReduceRealSum (T *rvar, int cnt)

template<typename T >
std::enable_if_t< std::is_floating_point_v< T > >	ReduceRealSum (Vector< std::reference_wrapper< T > > const &rvar)

template<typename T >
std::enable_if_t< std::is_floating_point_v< T > >	ReduceRealSum (T &rvar, int cpu)
	Real sum reduction to specified cpu.

template<typename T >
std::enable_if_t< std::is_floating_point_v< T > >	ReduceRealSum (T *rvar, int cnt, int cpu)

template<typename T >
std::enable_if_t< std::is_floating_point_v< T > >	ReduceRealSum (Vector< std::reference_wrapper< T > > const &rvar, int cpu)

template<typename T >
std::enable_if_t< std::is_floating_point_v< T > >	ReduceRealMax (T &rvar)
	Real max reduction.

template<typename T >
std::enable_if_t< std::is_floating_point_v< T > >	ReduceRealMax (T *rvar, int cnt)

template<typename T >
std::enable_if_t< std::is_floating_point_v< T > >	ReduceRealMax (Vector< std::reference_wrapper< T > > const &rvar)

template<typename T >
std::enable_if_t< std::is_floating_point_v< T > >	ReduceRealMax (T &rvar, int cpu)
	Real max reduction to specified cpu.

template<typename T >
std::enable_if_t< std::is_floating_point_v< T > >	ReduceRealMax (T *rvar, int cnt, int cpu)

template<typename T >
std::enable_if_t< std::is_floating_point_v< T > >	ReduceRealMax (Vector< std::reference_wrapper< T > > const &rvar, int cpu)

template<typename T >
std::enable_if_t< std::is_floating_point_v< T > >	ReduceRealMin (T &rvar)
	Real min reduction.

template<typename T >
std::enable_if_t< std::is_floating_point_v< T > >	ReduceRealMin (T *rvar, int cnt)

template<typename T >
std::enable_if_t< std::is_floating_point_v< T > >	ReduceRealMin (Vector< std::reference_wrapper< T > > const &rvar)

template<typename T >
std::enable_if_t< std::is_floating_point_v< T > >	ReduceRealMin (T &rvar, int cpu)
	Real min reduction to specified cpu.

template<typename T >
std::enable_if_t< std::is_floating_point_v< T > >	ReduceRealMin (T *rvar, int cnt, int cpu)

template<typename T >
std::enable_if_t< std::is_floating_point_v< T > >	ReduceRealMin (Vector< std::reference_wrapper< T > > const &rvar, int cpu)

int	SeqNum () noexcept
	Returns sequential message sequence numbers, usually used as tags for send/recv.

template<class T >
Message	Asend (const T *, size_t n, int pid, int tag)

template<class T >
Message	Asend (const T *, size_t n, int pid, int tag, MPI_Comm comm)

template<class T >
Message	Asend (const std::vector< T > &buf, int pid, int tag)

template<class T >
Message	Arecv (T *, size_t n, int pid, int tag)

template<class T >
Message	Arecv (T *, size_t n, int pid, int tag, MPI_Comm comm)

template<class T >
Message	Arecv (std::vector< T > &buf, int pid, int tag)

template<class T >
Message	Send (const T *buf, size_t n, int dst_pid, int tag)

template<class T >
Message	Send (const T *buf, size_t n, int dst_pid, int tag, MPI_Comm comm)

template<class T >
Message	Send (const std::vector< T > &buf, int dst_pid, int tag)

template<class T >
Message	Recv (T *, size_t n, int pid, int tag)

template<class T >
Message	Recv (T *, size_t n, int pid, int tag, MPI_Comm comm)

template<class T >
Message	Recv (std::vector< T > &buf, int pid, int tag)

template<class T >
void	Bcast (T *, size_t n, int root=0)

template<class T >
void	Bcast (T *, size_t n, int root, const MPI_Comm &comm)

template<class T , class T1 >
void	Scatter (T , size_t n, const T1 , size_t n1, int root)

template<class T , class T1 >
void	Gather (const T , size_t n, T1 , size_t n1, int root)

template<class T >
std::vector< T >	Gather (const T &, int root)

template<class T >
void	Gatherv (const T send, int sc, T recv, const std::vector< int > &rc, const std::vector< int > &disp, int root)

template<class T >
void	GatherLayoutDataToVector (const LayoutData< T > &sendbuf, Vector< T > &recvbuf, int root)
	Gather LayoutData values to a vector on root.

template<typename T , typename F >
MPI_Op	Mpi_op ()

Variables
bool	use_gpu_aware_mpi = false

ProcessTeam	m_Team

MPI_Comm	m_comm = MPI_COMM_NULL

int	m_nprocs_per_node = 1

int	m_rank_in_node = 0

int	m_nprocs_per_processor = 1

int	m_rank_in_processor = 0

Vector< MPI_Datatype * >	m_mpi_types

Vector< MPI_Op * >	m_mpi_ops

int	m_MinTag = 1000

int	m_MaxTag = -1

const int	ioProcessor = 0
	The MPI rank number of the I/O Processor (probably rank 0). This rank is usually used to write to stdout.

Detailed Description

Parallel frontend that abstracts functionalities needed to spawn processes and handle communication.

Function Documentation

◆ Abarrier() [1/2]

Message amrex::ParallelDescriptor::Abarrier ( )

◆ Abarrier() [2/2]

Message amrex::ParallelDescriptor::Abarrier ( const MPI_Comm & )

◆ Abort()

void amrex::ParallelDescriptor::Abort	(	int	errorcode,
		bool	backtrace
	)

Abort with specified error code.

◆ AMREX_FORT_NAME() [1/10]

void amrex::ParallelDescriptor::AMREX_FORT_NAME	(	BL_PD_ABORT	,
		bl_pd_abort
	)

◆ AMREX_FORT_NAME() [2/10]

void amrex::ParallelDescriptor::AMREX_FORT_NAME	(	BL_PD_BARRIER	,
		bl_pd_barrier
	)

◆ AMREX_FORT_NAME() [3/10]

void amrex::ParallelDescriptor::AMREX_FORT_NAME	(	BL_PD_COMMUNICATOR	,
		bl_pd_communicator
	)

◆ AMREX_FORT_NAME() [4/10]

void amrex::ParallelDescriptor::AMREX_FORT_NAME	(	BL_PD_IOPROC	,
		bl_pd_ioproc
	)

◆ AMREX_FORT_NAME() [5/10]

void amrex::ParallelDescriptor::AMREX_FORT_NAME	(	BL_PD_IS_IOPROC	,
		bl_pd_is_ioproc
	)

◆ AMREX_FORT_NAME() [6/10]

void amrex::ParallelDescriptor::AMREX_FORT_NAME	(	BL_PD_MYPROC	,
		bl_pd_myproc
	)

◆ AMREX_FORT_NAME() [7/10]

void amrex::ParallelDescriptor::AMREX_FORT_NAME	(	BL_PD_NPROCS	,
		bl_pd_nprocs
	)

◆ AMREX_FORT_NAME() [8/10]

void amrex::ParallelDescriptor::AMREX_FORT_NAME	(	BL_PD_REDUCE_REAL_MAX_TO_IOPROC	,
		bl_pd_reduce_real_max_to_ioproc
	)

◆ AMREX_FORT_NAME() [9/10]

void amrex::ParallelDescriptor::AMREX_FORT_NAME	(	BL_PD_REDUCE_REAL_SUM_TO_IOPROC	,
		bl_pd_reduce_real_sum_to_ioproc
	)

◆ AMREX_FORT_NAME() [10/10]

void amrex::ParallelDescriptor::AMREX_FORT_NAME	(	BL_PD_SECOND	,
		bl_pd_second
	)

◆ Arecv() [1/3]

template<class T >

Message amrex::ParallelDescriptor::Arecv	(	std::vector< T > &	buf,
		int	pid,
		int	tag
	)

◆ Arecv() [2/3]

template<class T >

Message amrex::ParallelDescriptor::Arecv	(	T *	,
		size_t	n,
		int	pid,
		int	tag
	)

◆ Arecv() [3/3]

template<class T >

Message amrex::ParallelDescriptor::Arecv	(	T *	,
		size_t	n,
		int	pid,
		int	tag,
		MPI_Comm	comm
	)

◆ Asend() [1/3]

template<class T >

Message amrex::ParallelDescriptor::Asend	(	const std::vector< T > &	buf,
		int	pid,
		int	tag
	)

◆ Asend() [2/3]

template<class T >

Message amrex::ParallelDescriptor::Asend	(	const T *	,
		size_t	n,
		int	pid,
		int	tag
	)

◆ Asend() [3/3]

template<class T >

Message amrex::ParallelDescriptor::Asend	(	const T *	,
		size_t	n,
		int	pid,
		int	tag,
		MPI_Comm	comm
	)

◆ Bcast() [1/3]

template<class T >

void amrex::ParallelDescriptor::Bcast	(	T *	,
		size_t	n,
		int	root,
		const MPI_Comm &	comm
	)

◆ Bcast() [2/3]

template<class T >

void amrex::ParallelDescriptor::Bcast	(	T *	,
		size_t	n,
		int	root = `0`
	)

◆ Bcast() [3/3]

void amrex::ParallelDescriptor::Bcast	(	void *	,
		int	,
		MPI_Datatype	,
		int	,
		MPI_Comm
	)

◆ Comm_dup()

void amrex::ParallelDescriptor::Comm_dup	(	MPI_Comm	,
		MPI_Comm &
	)

◆ Communicator()

MPI_Comm amrex::ParallelDescriptor::Communicator ( )

inlinenoexcept

◆ doTeamReduce()

bool amrex::ParallelDescriptor::doTeamReduce ( )

inlinenoexcept

◆ EndParallel()

void amrex::ParallelDescriptor::EndParallel ( )

Perform any needed parallel finalization. This MUST be the last routine in this class called from within a program.

◆ EndTeams()

void amrex::ParallelDescriptor::EndTeams ( )

◆ ErrorString()

const char * amrex::ParallelDescriptor::ErrorString ( int )

ErrorString return string associated with error internal error condition.

◆ Finalize()

void amrex::ParallelDescriptor::Finalize ( )

◆ Gather() [1/2]

template<class T >

std::vector< T > amrex::ParallelDescriptor::Gather	(	const T &	t,
		int	root
	)

◆ Gather() [2/2]

template<class T , class T1 >

void amrex::ParallelDescriptor::Gather	(	const T *	t,
		size_t	n,
		T1 *	t1,
		size_t	n1,
		int	root
	)

◆ GatherLayoutDataToVector()

template<class T >

void amrex::ParallelDescriptor::GatherLayoutDataToVector	(	const LayoutData< T > &	sendbuf,
		Vector< T > &	recvbuf,
		int	root
	)

Gather LayoutData values to a vector on root.

◆ Gatherv()

template<class T >

void amrex::ParallelDescriptor::Gatherv	(	const T *	send,
		int	sc,
		T *	recv,
		const std::vector< int > &	rc,
		const std::vector< int > &	disp,
		int	root
	)

◆ Initialize()

void amrex::ParallelDescriptor::Initialize ( )

◆ IOProcessorNumber()

int amrex::ParallelDescriptor::IOProcessorNumber ( )

inlinenoexcept

◆ IProbe() [1/2]

void amrex::ParallelDescriptor::IProbe	(	int	,
		int	,
		int &	,
		MPI_Status &
	)

◆ IProbe() [2/2]

void amrex::ParallelDescriptor::IProbe	(	int	,
		int	,
		MPI_Comm	,
		int &	,
		MPI_Status &
	)

◆ isTeamLead()

bool amrex::ParallelDescriptor::isTeamLead ( )

inlinenoexcept

◆ MaxTag()

int amrex::ParallelDescriptor::MaxTag ( )

inlinenoexcept

◆ MinTag()

int amrex::ParallelDescriptor::MinTag ( )

inlinenoexcept

◆ mpi_level_to_string()

std::string amrex::ParallelDescriptor::mpi_level_to_string ( int mtlev )

Convert an MPI_THREAD_<X> level to string

Parameters

mtlev MPI_THREAD_<X> level

Returns: string representation of the equivalent MPI macro name

◆ Mpi_op()

template<typename T , typename F >

MPI_Op amrex::ParallelDescriptor::Mpi_op ( )

◆ MyRankInNode()

int amrex::ParallelDescriptor::MyRankInNode ( )

inlinenoexcept

Return the rank in a node defined by MPI_COMM_TYPE_SHARED. This might be the same or different from MyRankInProcessor based on MPI_Get_processor_name.

◆ MyRankInProcessor()

int amrex::ParallelDescriptor::MyRankInProcessor ( )

inlinenoexcept

Return the rank in a node defined by MPI_Get_processor_name. This might be the same or different from MyRankInNode based on MPI_COMM_TYPE_SHARED.

◆ MyRankInTeam()

int amrex::ParallelDescriptor::MyRankInTeam ( )

inlinenoexcept

◆ MyTeam()

const ProcessTeam & amrex::ParallelDescriptor::MyTeam ( )

inlinenoexcept

◆ MyTeamColor()

int amrex::ParallelDescriptor::MyTeamColor ( )

inlinenoexcept

◆ MyTeamLead()

int amrex::ParallelDescriptor::MyTeamLead ( )

inlinenoexcept

◆ NProcsPerNode()

int amrex::ParallelDescriptor::NProcsPerNode ( )

inlinenoexcept

Return the number of MPI ranks per node as defined by MPI_COMM_TYPE_SHARED. This might be the same or different from NProcsPerProcessor based on MPI_Get_processor_name.

◆ NProcsPerProcessor()

int amrex::ParallelDescriptor::NProcsPerProcessor ( )

inlinenoexcept

Return the number of MPI ranks per node as defined by MPI_Get_processor_name. This might be the same or different from NProcsPerNode based on MPI_COMM_TYPE_SHARED.

◆ NTeams()

int amrex::ParallelDescriptor::NTeams ( )

inlinenoexcept

◆ RankInLeadComm()

int amrex::ParallelDescriptor::RankInLeadComm ( int rank )

inlinenoexcept

◆ Recv() [1/3]

template<class T >

Message amrex::ParallelDescriptor::Recv	(	std::vector< T > &	buf,
		int	pid,
		int	tag
	)

◆ Recv() [2/3]

template<class T >

Message amrex::ParallelDescriptor::Recv	(	T *	,
		size_t	n,
		int	pid,
		int	tag
	)

◆ Recv() [3/3]

template<class T >

Message amrex::ParallelDescriptor::Recv	(	T *	,
		size_t	n,
		int	pid,
		int	tag,
		MPI_Comm	comm
	)

◆ ReduceRealMax() [1/2]

void amrex::ParallelDescriptor::ReduceRealMax ( Vector< std::reference_wrapper< Real > > const & )

◆ ReduceRealMax() [2/2]

void amrex::ParallelDescriptor::ReduceRealMax	(	Vector< std::reference_wrapper< Real > > const &	,
		int
	)

◆ ReduceRealMin() [1/2]

void amrex::ParallelDescriptor::ReduceRealMin ( Vector< std::reference_wrapper< Real > > const & )

◆ ReduceRealMin() [2/2]

void amrex::ParallelDescriptor::ReduceRealMin	(	Vector< std::reference_wrapper< Real > > const &	,
		int
	)

◆ ReduceRealSum() [1/2]

void amrex::ParallelDescriptor::ReduceRealSum ( Vector< std::reference_wrapper< Real > > const & )

◆ ReduceRealSum() [2/2]

void amrex::ParallelDescriptor::ReduceRealSum	(	Vector< std::reference_wrapper< Real > > const &	,
		int
	)

◆ sameTeam() [1/2]

bool amrex::ParallelDescriptor::sameTeam ( int rank )

inlinenoexcept

◆ sameTeam() [2/2]

bool amrex::ParallelDescriptor::sameTeam	(	int	rankA,
		int	rankB
	)

inlinenoexcept

◆ Scatter()

template<class T , class T1 >

void amrex::ParallelDescriptor::Scatter	(	T *	,
		size_t	n,
		const T1 *	,
		size_t	n1,
		int	root
	)

◆ second()

double amrex::ParallelDescriptor::second ( )

noexcept

Returns wall-clock seconds since start of execution.

◆ Send() [1/3]

template<class T >

Message amrex::ParallelDescriptor::Send	(	const std::vector< T > &	buf,
		int	dst_pid,
		int	tag
	)

◆ Send() [2/3]

template<class T >

Message amrex::ParallelDescriptor::Send	(	const T *	buf,
		size_t	n,
		int	dst_pid,
		int	tag
	)

◆ Send() [3/3]

template<class T >

Message amrex::ParallelDescriptor::Send	(	const T *	buf,
		size_t	n,
		int	dst_pid,
		int	tag,
		MPI_Comm	comm
	)

◆ SeqNum()

int amrex::ParallelDescriptor::SeqNum ( )

inlinenoexcept

Returns sequential message sequence numbers, usually used as tags for send/recv.

◆ StartParallel()

void amrex::ParallelDescriptor::StartParallel	(	int *	,
		char ***	,
		MPI_Comm
	)

Perform any needed parallel initialization. This MUST be the first routine in this class called from within a program.

BL_USE_MPI

◆ StartTeams()

void amrex::ParallelDescriptor::StartTeams ( )

Split the process pool into teams.

◆ team_for() [1/3]

template<typename F >

void amrex::ParallelDescriptor::team_for	(	int	begin,
		int	end,
		const F &	f
	)

◆ team_for() [2/3]

template<typename F >

void amrex::ParallelDescriptor::team_for	(	int	begin,
		int	end,
		int	rit,
		const F &	f
	)

◆ team_for() [3/3]

template<typename F >

void amrex::ParallelDescriptor::team_for	(	int	begin,
		int	end,
		int	rit,
		int	nworkers,
		const F &	f
	)

◆ team_range()

std::pair< int, int > amrex::ParallelDescriptor::team_range	(	int	begin,
		int	end,
		int	rit = `-1`,
		int	nworkers = `0`
	)

inlinenoexcept

◆ TeamLead()

int amrex::ParallelDescriptor::TeamLead ( int rank )

inlinenoexcept

◆ TeamSize()

int amrex::ParallelDescriptor::TeamSize ( )

inlinenoexcept

◆ Test() [1/2]

void amrex::ParallelDescriptor::Test	(	MPI_Request &	,
		int &	,
		MPI_Status &
	)

◆ Test() [2/2]

void amrex::ParallelDescriptor::Test	(	Vector< MPI_Request > &	,
		int &	,
		Vector< MPI_Status > &
	)

◆ Unnamed()

const std::string amrex::ParallelDescriptor::Unnamed ( "Unnamed" )

Used as default argument to ParallelDescriptor::Barrier().

◆ UseGpuAwareMpi()

bool amrex::ParallelDescriptor::UseGpuAwareMpi ( )

inline

◆ Wait()

void amrex::ParallelDescriptor::Wait	(	MPI_Request &	,
		MPI_Status &
	)

◆ Waitall()

void amrex::ParallelDescriptor::Waitall	(	Vector< MPI_Request > &	,
		Vector< MPI_Status > &
	)

◆ Waitany()

void amrex::ParallelDescriptor::Waitany	(	Vector< MPI_Request > &	,
		int &	,
		MPI_Status &
	)

◆ Waitsome()

void amrex::ParallelDescriptor::Waitsome	(	Vector< MPI_Request > &	,
		int &	,
		Vector< int > &	,
		Vector< MPI_Status > &
	)

Variable Documentation

◆ m_comm

MPI_Comm amrex::ParallelDescriptor::m_comm = MPI_COMM_NULL

◆ m_MaxTag

int amrex::ParallelDescriptor::m_MaxTag = -1

◆ m_MinTag

int amrex::ParallelDescriptor::m_MinTag = 1000

◆ m_mpi_ops

Vector< MPI_Op * > amrex::ParallelDescriptor::m_mpi_ops

◆ m_mpi_types

Vector< MPI_Datatype * > amrex::ParallelDescriptor::m_mpi_types

◆ m_nprocs_per_node

int amrex::ParallelDescriptor::m_nprocs_per_node = 1

◆ m_nprocs_per_processor

int amrex::ParallelDescriptor::m_nprocs_per_processor = 1

◆ m_rank_in_node

int amrex::ParallelDescriptor::m_rank_in_node = 0

◆ m_rank_in_processor

int amrex::ParallelDescriptor::m_rank_in_processor = 0

◆ m_Team

ProcessTeam amrex::ParallelDescriptor::m_Team

◆ use_gpu_aware_mpi

bool amrex::ParallelDescriptor::use_gpu_aware_mpi = false

Namespaces

Classes

Functions

Variables

Detailed Description

Function Documentation

◆ Abarrier() [1/2]

◆ Abarrier() [2/2]

◆ Abort()

◆ AMREX_FORT_NAME() [1/10]

◆ AMREX_FORT_NAME() [2/10]

◆ AMREX_FORT_NAME() [3/10]

◆ AMREX_FORT_NAME() [4/10]

◆ AMREX_FORT_NAME() [5/10]

◆ AMREX_FORT_NAME() [6/10]

◆ AMREX_FORT_NAME() [7/10]

◆ AMREX_FORT_NAME() [8/10]

◆ AMREX_FORT_NAME() [9/10]

◆ AMREX_FORT_NAME() [10/10]

◆ Arecv() [1/3]

◆ Arecv() [2/3]

◆ Arecv() [3/3]

◆ Asend() [1/3]

◆ Asend() [2/3]

◆ Asend() [3/3]

◆ Bcast() [1/3]

◆ Bcast() [2/3]

◆ Bcast() [3/3]

◆ Comm_dup()

◆ Communicator()

◆ doTeamReduce()

◆ EndParallel()

◆ EndTeams()

◆ ErrorString()

◆ Finalize()

◆ Gather() [1/2]

◆ Gather() [2/2]

◆ GatherLayoutDataToVector()

◆ Gatherv()

◆ Initialize()

◆ IOProcessorNumber()

◆ IProbe() [1/2]

◆ IProbe() [2/2]

◆ isTeamLead()

◆ MaxTag()

◆ MinTag()

◆ mpi_level_to_string()

◆ Mpi_op()

◆ MyRankInNode()

◆ MyRankInProcessor()

◆ MyRankInTeam()

◆ MyTeam()

◆ MyTeamColor()

◆ MyTeamLead()

◆ NProcsPerNode()

◆ NProcsPerProcessor()

◆ NTeams()

◆ RankInLeadComm()

◆ Recv() [1/3]

◆ Recv() [2/3]

◆ Recv() [3/3]

◆ ReduceRealMax() [1/2]

◆ ReduceRealMax() [2/2]

◆ ReduceRealMin() [1/2]

◆ ReduceRealMin() [2/2]

◆ ReduceRealSum() [1/2]

◆ ReduceRealSum() [2/2]

◆ sameTeam() [1/2]

◆ sameTeam() [2/2]

◆ Scatter()

◆ second()

◆ Send() [1/3]

◆ Send() [2/3]

◆ Send() [3/3]

◆ SeqNum()

◆ StartParallel()

◆ StartTeams()

◆ team_for() [1/3]

◆ team_for() [2/3]

◆ team_for() [3/3]