#include "REAL.H"
#include <string>
#include "Vector.H"
#include "MayDay.H"
#include "Misc.H"
#include "BaseNamespaceHeader.H"
#include "BaseNamespaceFooter.H"
#include "SPMDI.H"

Include dependency graph for SPMD.H:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
class	SerialTask

Macros
#define	_SPMD_H_

Functions
int	reportMPIStats ()

int	procID ()
	local process ID More...

int	CHprocID ()

unsigned int	numProc ()
	number of parallel processes More...

void	barrier (void)
	all ranks wait here to sync-up More...

template<class T >
int	linearSize (const T &inputT)

template<class T >
void	linearIn (T &a_outputT, const void *const inBuf)

template<class T >
void	linearOut (void *const a_outBuf, const T &inputT)

template<class T >
void	broadcast (T &a_inAndOut, int a_src)
	broadcast to every process More...

template<>
int	linearSize (const long long &a_input)

template<>
void	linearIn (long long &a_outputT, const void *const inBuf)

template<>
void	linearOut (void *const a_outBuf, const long long &a_inputT)

template<>
int	linearSize (const int &a_input)

template<>
int	linearSize (const unsigned long long &a_input)

template<>
void	linearIn (int &a_outputT, const void *const inBuf)

template<>
void	linearIn (unsigned long long &a_outputT, const void *const inBuf)

template<>
void	linearOut (void *const a_outBuf, const int &a_inputT)

template<>
void	linearOut (void *const a_outBuf, const unsigned long long &a_inputT)

template<>
int	linearSize (const long &a_input)

template<>
void	linearIn (long &a_outputT, const void *const inBuf)

template<>
void	linearOut (void *const a_outBuf, const long &a_inputT)

template<>
int	linearSize (const unsigned long &a_input)

template<>
void	linearIn (unsigned long &a_outputT, const void *const inBuf)

template<>
void	linearOut (void *const a_outBuf, const unsigned long &a_inputT)

template<>
int	linearSize (const float &a_input)

template<>
int	linearSize (const double &a_input)

template<>
void	linearIn (float &a_outputT, const void *const a_inBuf)

template<>
void	linearIn (double &a_outputT, const void *const a_inBuf)

template<>
void	linearOut (void *const a_outBuf, const float &a_inputT)

template<>
void	linearOut (void *const a_outBuf, const double &a_inputT)

template<>
int	linearSize (const std::string &a_input)

template<>
void	linearIn (std::string &a_outputT, const void *const a_inBuf)

template<>
void	linearOut (void *const a_outBuf, const std::string &a_inputT)

template<>
int	linearSize (const Vector< int > &a_input)

template<>
void	linearIn (Vector< int > &a_outputT, const void *const inBuf)

template<>
void	linearOut (void *const a_outBuf, const Vector< int > &a_inputT)

template<>
int	linearSize (const Vector< unsigned long long > &a_input)

template<>
void	linearIn (Vector< unsigned long long > &a_outputT, const void *const inBuf)

template<>
void	linearOut (void *const a_outBuf, const Vector< unsigned long long > &a_inputT)

template<>
int	linearSize (const Vector< long > &a_input)

template<>
void	linearIn (Vector< long > &a_outputT, const void *const inBuf)

template<>
void	linearOut (void *const a_outBuf, const Vector< long > &a_inputT)

template<>
int	linearSize (const Vector< float > &a_input)

template<>
void	linearIn (Vector< float > &a_outputT, const void *const inBuf)

template<>
void	linearOut (void *const a_outBuf, const Vector< float > &a_inputT)

template<>
int	linearSize (const Vector< double > &a_input)

template<>
void	linearIn (Vector< double > &a_outputT, const void *const inBuf)

template<>
void	linearOut (void *const a_outBuf, const Vector< double > &a_inputT)

template<>
int	linearSize (const Vector< std::string > &a_input)

template<>
void	linearIn (Vector< std::string > &a_outputT, const void *const inBuf)

template<>
void	linearOut (void *const a_outBuf, const Vector< std::string > &a_inputT)

template<>
int	linearSize (const Vector< Vector< int > > &a_input)

template<>
void	linearIn (Vector< Vector< int > > &a_outputT, const void *const inBuf)

template<>
void	linearOut (void *const a_outBuf, const Vector< Vector< int > > &a_inputT)

template<class T >
int	linearListSize (const Vector< T > &a_input)

template<class T >
void	linearListIn (Vector< T > &a_outputT, const void *const a_inBuf)

template<class T >
void	linearListOut (void *const a_outBuf, const Vector< T > &a_inputT)

int	GetPID (int rank)

int	GetRank (int pid)

int	uniqueProc (const SerialTask::task &a_task)

Variables
int	num_procs

unsigned long long	CH_MAX_MPI_MESSAGE_SIZE

unsigned long long	CH_MaxMPISendSize

unsigned long long	CH_MaxMPIRecvSize

Macro Definition Documentation

◆ _SPMD_H_

#define _SPMD_H_

Function Documentation

◆ reportMPIStats()

int reportMPIStats ( )

◆ procID()

int procID ( )

local process ID

Returns the ID of the locally running process in the range 0 <= procID() < numProc(). This has no relation to the operating system pid. There is always a procID() == 0.

Referenced by blockWriteBufferToFile(), CHprocID(), gatherBoxesAndOffsets(), linearOut(), MergeSolver< T >::solve(), write(), and WriteMultiData< T >::WriteMultiData().

◆ CHprocID()

int CHprocID ( )

inline

References barrier(), broadcast(), gather(), linearIn(), linearListIn(), linearListOut(), linearListSize(), linearOut(), linearSize(), numProc(), and procID().

◆ numProc()

unsigned int numProc ( )

number of parallel processes

Returns the number of parallel processes running. Always returns at least 1.

Referenced by CHprocID(), gatherBoxesAndOffsets(), getOffsets(), linearOut(), and BoxLayoutData< BaseFab< int > >::unpackReceivesToMe_append().

◆ barrier()

void barrier ( void )

inline

all ranks wait here to sync-up

All MPI ranks wait here to sync-up. Calls MPI_Barrier(comm)

Referenced by CHprocID(), and linearOut().

◆ linearSize() [1/16]

◆ linearIn() [1/16]

template<class T >

void linearIn	(	T &	a_outputT,
		const void *const	inBuf
	)

Referenced by CHprocID(), MiniIVFAB< Real >::linearIn(), BaseIVFAB< Real >::linearIn(), BaseIFFAB< FaceStencil >::linearIn(), MiniIFFAB< Real >::linearIn(), IrregTag::Entry::linearIn(), BaseFab< Real >::linearIn(), LDOperator< FArrayBox >::op(), and StdSetIVS::~StdSetIVS().

◆ linearOut() [1/16]

template<class T >

void linearOut	(	void *const	a_outBuf,
		const T &	inputT
	)

Referenced by CHprocID(), MiniIVFAB< Real >::linearOut(), BaseIVFAB< Real >::linearOut(), BaseIFFAB< FaceStencil >::linearOut(), IrregTag::Entry::linearOut(), MiniIFFAB< Real >::linearOut(), BaseFab< Real >::linearOut(), LDOperator< FArrayBox >::op(), and StdSetIVS::~StdSetIVS().

◆ broadcast()

template<class T >

void broadcast	(	T &	a_inAndOut,
		int	a_src
	)

inline

broadcast to every process

Broadcasts a_inAndOut to every process from process number a_src. It is an error if a_src < 0 or a_src >= numProc(). \

T must have have the following functions: \

int linearSize<T>(const T& inputT); \ void linearIn<T>(T& a_outputT, const void* const inBuf); \ void linearOut<T>(void* a_outBuf, const T& inputT); \

Referenced by CHprocID(), gatherBoxesAndOffsets(), getOffsets(), and linearOut().

◆ linearSize() [2/16]

template<>

int linearSize ( const long long & a_input )

◆ linearIn() [2/16]

template<>

void linearIn	(	long long &	a_outputT,
		const void *const	inBuf
	)

◆ linearOut() [2/16]

template<>

void linearOut	(	void *const	a_outBuf,
		const long long &	a_inputT
	)

◆ linearSize() [3/16]

template<>

int linearSize ( const int & a_input )

◆ linearSize() [4/16]

template<>

int linearSize ( const unsigned long long & a_input )

◆ linearIn() [3/16]

template<>

void linearIn	(	int &	a_outputT,
		const void *const	inBuf
	)

◆ linearIn() [4/16]

template<>

void linearIn	(	unsigned long long &	a_outputT,
		const void *const	inBuf
	)

◆ linearOut() [3/16]

template<>

void linearOut	(	void *const	a_outBuf,
		const int &	a_inputT
	)

◆ linearOut() [4/16]

template<>

void linearOut	(	void *const	a_outBuf,
		const unsigned long long &	a_inputT
	)

◆ linearSize() [5/16]

template<>

int linearSize ( const long & a_input )

◆ linearIn() [5/16]

template<>

void linearIn	(	long &	a_outputT,
		const void *const	inBuf
	)

◆ linearOut() [5/16]

template<>

void linearOut	(	void *const	a_outBuf,
		const long &	a_inputT
	)

◆ linearSize() [6/16]

template<>

int linearSize ( const unsigned long & a_input )

◆ linearIn() [6/16]

template<>

void linearIn	(	unsigned long &	a_outputT,
		const void *const	inBuf
	)

◆ linearOut() [6/16]

template<>

void linearOut	(	void *const	a_outBuf,
		const unsigned long &	a_inputT
	)

◆ linearSize() [7/16]

template<>

int linearSize ( const float & a_input )

◆ linearSize() [8/16]

template<>

int linearSize ( const double & a_input )

◆ linearIn() [7/16]

template<>

void linearIn	(	float &	a_outputT,
		const void *const	a_inBuf
	)

◆ linearIn() [8/16]

template<>

void linearIn	(	double &	a_outputT,
		const void *const	a_inBuf
	)

◆ linearOut() [7/16]

template<>

void linearOut	(	void *const	a_outBuf,
		const float &	a_inputT
	)

◆ linearOut() [8/16]

template<>

void linearOut	(	void *const	a_outBuf,
		const double &	a_inputT
	)

◆ linearSize() [9/16]

template<>

int linearSize ( const std::string & a_input )

◆ linearIn() [9/16]

template<>

void linearIn	(	std::string &	a_outputT,
		const void *const	a_inBuf
	)

◆ linearOut() [9/16]

template<>

void linearOut	(	void *const	a_outBuf,
		const std::string &	a_inputT
	)

◆ linearSize() [10/16]

template<>

int linearSize ( const Vector< int > & a_input )

◆ linearIn() [10/16]

template<>

void linearIn	(	Vector< int > &	a_outputT,
		const void *const	inBuf
	)

◆ linearOut() [10/16]

template<>

void linearOut	(	void *const	a_outBuf,
		const Vector< int > &	a_inputT
	)

◆ linearSize() [11/16]

template<>

int linearSize ( const Vector< unsigned long long > & a_input )

◆ linearIn() [11/16]

template<>

void linearIn	(	Vector< unsigned long long > &	a_outputT,
		const void *const	inBuf
	)

◆ linearOut() [11/16]

template<>

void linearOut	(	void *const	a_outBuf,
		const Vector< unsigned long long > &	a_inputT
	)

◆ linearSize() [12/16]

template<>

int linearSize ( const Vector< long > & a_input )

◆ linearIn() [12/16]

template<>

void linearIn	(	Vector< long > &	a_outputT,
		const void *const	inBuf
	)

◆ linearOut() [12/16]

template<>

void linearOut	(	void *const	a_outBuf,
		const Vector< long > &	a_inputT
	)

◆ linearSize() [13/16]

template<>

int linearSize ( const Vector< float > & a_input )

◆ linearIn() [13/16]

template<>

void linearIn	(	Vector< float > &	a_outputT,
		const void *const	inBuf
	)

◆ linearOut() [13/16]

template<>

void linearOut	(	void *const	a_outBuf,
		const Vector< float > &	a_inputT
	)

◆ linearSize() [14/16]

template<>

int linearSize ( const Vector< double > & a_input )

◆ linearIn() [14/16]

template<>

void linearIn	(	Vector< double > &	a_outputT,
		const void *const	inBuf
	)

◆ linearOut() [14/16]

template<>

void linearOut	(	void *const	a_outBuf,
		const Vector< double > &	a_inputT
	)

◆ linearSize() [15/16]

template<>

int linearSize ( const Vector< std::string > & a_input )

◆ linearIn() [15/16]

template<>

void linearIn	(	Vector< std::string > &	a_outputT,
		const void *const	inBuf
	)

◆ linearOut() [15/16]

template<>

void linearOut	(	void *const	a_outBuf,
		const Vector< std::string > &	a_inputT
	)

◆ linearSize() [16/16]

template<>

int linearSize ( const Vector< Vector< int > > & a_input )

◆ linearIn() [16/16]

template<>

void linearIn	(	Vector< Vector< int > > &	a_outputT,
		const void *const	inBuf
	)

◆ linearOut() [16/16]

template<>

void linearOut	(	void *const	a_outBuf,
		const Vector< Vector< int > > &	a_inputT
	)

◆ linearListSize()

template<class T >

int linearListSize ( const Vector< T > & a_input )

References linearSize(), and Vector< T >::size().

Referenced by CHprocID(), BaseIVFAB< Real >::linearIn(), BaseIFFAB< FaceStencil >::linearIn(), MiniIFFAB< Real >::linearIn(), BaseIVFAB< Real >::linearOut(), BaseIFFAB< FaceStencil >::linearOut(), MiniIFFAB< Real >::linearOut(), IFidTable::linearSize(), IrregTag::Entry::linearSize(), BaseIVFAB< Real >::size(), BaseIFFAB< FaceStencil >::size(), and MiniIFFAB< Real >::size().

◆ linearListIn()

template<class T >

void linearListIn	(	Vector< T > &	a_outputT,
		const void *const	a_inBuf
	)

References linearIn(), and Vector< T >::resize().

Referenced by CHprocID(), IFidTable::linearIn(), BaseIVFAB< Real >::linearIn(), BaseIFFAB< FaceStencil >::linearIn(), and MiniIFFAB< Real >::linearIn().

◆ linearListOut()

template<class T >

void linearListOut	(	void *const	a_outBuf,
		const Vector< T > &	a_inputT
	)

References linearOut(), linearSize(), and Vector< T >::size().

Referenced by CHprocID(), IFidTable::linearOut(), BaseIVFAB< Real >::linearOut(), BaseIFFAB< FaceStencil >::linearOut(), and MiniIFFAB< Real >::linearOut().

◆ GetPID()

int GetPID ( int rank )

◆ GetRank()

int GetRank ( int pid )

◆ uniqueProc()

int uniqueProc ( const SerialTask::task & a_task )

Referenced by getOffsets().

Variable Documentation

◆ num_procs

int num_procs

◆ CH_MAX_MPI_MESSAGE_SIZE

unsigned long long CH_MAX_MPI_MESSAGE_SIZE

Referenced by BoxLayoutData< BaseFab< int > >::unpackReceivesToMe_append().

◆ CH_MaxMPISendSize

unsigned long long CH_MaxMPISendSize

Referenced by linearOut(), and BoxLayoutData< BaseFab< int > >::unpackReceivesToMe_append().

◆ CH_MaxMPIRecvSize

unsigned long long CH_MaxMPIRecvSize

Referenced by linearOut(), and BoxLayoutData< BaseFab< int > >::unpackReceivesToMe_append().

Classes

Macros

Functions

Variables

Macro Definition Documentation

◆ _SPMD_H_

Function Documentation

◆ reportMPIStats()

◆ procID()

◆ CHprocID()

◆ numProc()

◆ barrier()

◆ linearSize() [1/16]

◆ linearIn() [1/16]

◆ linearOut() [1/16]

◆ broadcast()

◆ linearSize() [2/16]

◆ linearIn() [2/16]

◆ linearOut() [2/16]

◆ linearSize() [3/16]

◆ linearSize() [4/16]

◆ linearIn() [3/16]

◆ linearIn() [4/16]

◆ linearOut() [3/16]

◆ linearOut() [4/16]

◆ linearSize() [5/16]

◆ linearIn() [5/16]

◆ linearOut() [5/16]

◆ linearSize() [6/16]

◆ linearIn() [6/16]

◆ linearOut() [6/16]

◆ linearSize() [7/16]

◆ linearSize() [8/16]

◆ linearIn() [7/16]

◆ linearIn() [8/16]

◆ linearOut() [7/16]

◆ linearOut() [8/16]

◆ linearSize() [9/16]

◆ linearIn() [9/16]

◆ linearOut() [9/16]

◆ linearSize() [10/16]

◆ linearIn() [10/16]

◆ linearOut() [10/16]

◆ linearSize() [11/16]

◆ linearIn() [11/16]

◆ linearOut() [11/16]

◆ linearSize() [12/16]

◆ linearIn() [12/16]

◆ linearOut() [12/16]

◆ linearSize() [13/16]

◆ linearIn() [13/16]

◆ linearOut() [13/16]

◆ linearSize() [14/16]

◆ linearIn() [14/16]

◆ linearOut() [14/16]

◆ linearSize() [15/16]

◆ linearIn() [15/16]

◆ linearOut() [15/16]

◆ linearSize() [16/16]

◆ linearIn() [16/16]

◆ linearOut() [16/16]

◆ linearListSize()

◆ linearListIn()

◆ linearListOut()

◆ GetPID()

◆ GetRank()

◆ uniqueProc()

Variable Documentation

◆ num_procs

◆ CH_MAX_MPI_MESSAGE_SIZE

◆ CH_MaxMPISendSize

◆ CH_MaxMPIRecvSize