URANIE::MpiRelauncher::TBiMpiRun Class Reference

#include <TBiMpiRun.h>

Inheritance diagram for URANIE::MpiRelauncher::TBiMpiRun:

Collaboration diagram for URANIE::MpiRelauncher::TBiMpiRun:

Classes
class	NotInAMpiContext
class	UncorrectSize

Public Member Functions
	TBiMpiRun (URANIE::Relauncher::TEval *r, int sz, Bool_t init=kTRUE)
virtual	~TBiMpiRun (void)
virtual void	startSlave (void)
virtual Bool_t	onMaster (void)
virtual void	stopSlave (void)
Public Member Functions inherited from URANIE::MpiRelauncher::TMpiRun
	TMpiRun (URANIE::Relauncher::TEval *r, int *argc, char ***argv)
	TMpiRun (URANIE::Relauncher::TEval *r, Bool_t init=kTRUE)
	TMpiRun (URANIE::Relauncher::TEval *r, MPI_Comm comm)
virtual	~TMpiRun ()
virtual Bool_t	readyToGet ()
Public Member Functions inherited from URANIE::Relauncher::TSeparateRun
	TSeparateRun (URANIE::Relauncher::TEval *r)
virtual	~TSeparateRun ()
virtual void	put (long, vector< URANIE::DataServer::UEntry * > *in, vector< URANIE::DataServer::UEntry * > *out, int=0)
virtual int	get (long &)
Public Member Functions inherited from URANIE::Relauncher::TShareRun
	TShareRun (TEval *fun)
virtual	~TShareRun ()
virtual TEval *	getEval ()
Public Member Functions inherited from URANIE::Relauncher::TRun
virtual	~TRun ()

Static Public Member Functions
static MPI_Comm	getCalculMpiComm ()
static long	getCalculMpiCommPy ()
static bool	isBiMpi ()

Protected Member Functions
void	forward_header (int *buf, int siz)
void	forward_value (double *buf, int siz)
void	leader_loop (int grp)
void	calcul_loop (int grp)
void	calculSize (int siz)
Protected Member Functions inherited from URANIE::MpiRelauncher::TMpiRun
virtual int	wait_service ()
virtual int	send_header (int canal, int *head, int size)
virtual int	send_value (int canal, double *mesg, int size)
virtual int	receive_header (int canal, int *head, int size)
virtual int	receive_value (int canal, double *mesg, int size)
Protected Member Functions inherited from URANIE::Relauncher::TSeparateRun
void	send_uentry (int canal, int ncalc, int size, vector< URANIE::DataServer::UEntry * > *in)
void	to_uentry (int *isz, double *vals, std::vector< URANIE::DataServer::UEntry * > &dest)
void	empty_uentry (TIter &next, std::vector< URANIE::DataServer::UEntry * > &dest)
void	calcul_loop ()

Protected Attributes
int	_lowsz
int	_lowid
int	_topsz
int	_topid
Protected Attributes inherited from URANIE::MpiRelauncher::TMpiRun
int	_id
MPI_Comm	_comm
Protected Attributes inherited from URANIE::Relauncher::TSeparateRun
int	_sizein
int	_sizeout
int	_nbress
std::queue< element >	_pend
std::queue< int >	_sleep
std::vector< struct element >	_run
Protected Attributes inherited from URANIE::Relauncher::TShareRun
TEval *	_fun

Static Protected Attributes
static MPI_Comm	__intra
static bool	__isBiMpi =false
Static Protected Attributes inherited from URANIE::MpiRelauncher::TMpiRun
static int	_count = 0

Additional Inherited Members
Public Attributes inherited from URANIE::Relauncher::TRun
Int_t	_ncpus

Constructor & Destructor Documentation

TBiMpiRun()

URANIE::MpiRelauncher::TBiMpiRun::TBiMpiRun	(	URANIE::Relauncher::TEval *	r,
		int	sz,
		Bool_t	init = kTRUE
	)

References calculSize().

~TBiMpiRun()

URANIE::MpiRelauncher::TBiMpiRun::~TBiMpiRun ( void  )

virtual

Member Function Documentation

calcul_loop()

void URANIE::MpiRelauncher::TBiMpiRun::calcul_loop ( int  grp )

protected

References URANIE::Relauncher::TShareRun::_fun, URANIE::Relauncher::TSeparateRun::_sizein, URANIE::Relauncher::TSeparateRun::empty_uentry(), URANIE::Relauncher::TEval::eval(), forward_header(), forward_value(), URANIE::Relauncher::TEval::getInputList(), URANIE::Relauncher::TEval::getOutputList(), URANIE::Relauncher::TEval::rebuild(), and URANIE::Relauncher::TSeparateRun::to_uentry().

calculSize()

void URANIE::MpiRelauncher::TBiMpiRun::calculSize ( int  siz )

protected

References __intra, __isBiMpi, URANIE::MpiRelauncher::TMpiRun::_comm, URANIE::MpiRelauncher::TMpiRun::_id, _lowid, _lowsz, URANIE::Relauncher::TRun::_ncpus, _topid, and _topsz.

Referenced by TBiMpiRun().

forward_header()

void URANIE::MpiRelauncher::TBiMpiRun::forward_header ( int *  buf, int  siz  )

protected

References __intra.

Referenced by calcul_loop(), and leader_loop().

forward_value()

void URANIE::MpiRelauncher::TBiMpiRun::forward_value ( double *  buf, int  siz  )

protected

References __intra.

Referenced by calcul_loop(), and leader_loop().

getCalculMpiComm()

MPI_Comm URANIE::MpiRelauncher::TBiMpiRun::getCalculMpiComm ( )

static

References __intra, and __isBiMpi.

Referenced by URANIE::MpiRelauncher::TMpiLn2Eval::eval().

getCalculMpiCommPy()

long URANIE::MpiRelauncher::TBiMpiRun::getCalculMpiCommPy ( )

static

References __intra, and __isBiMpi.

isBiMpi()

bool URANIE::MpiRelauncher::TBiMpiRun::isBiMpi ( )

static

References __isBiMpi.

Referenced by URANIE::MpiRelauncher::TSubMpiRun::TSubMpiRun().

leader_loop()

void URANIE::MpiRelauncher::TBiMpiRun::leader_loop ( int  grp )

protected

References URANIE::Relauncher::TShareRun::_fun, URANIE::Relauncher::TSeparateRun::_sizein, URANIE::Relauncher::TSeparateRun::_sizeout, URANIE::Relauncher::TSeparateRun::empty_uentry(), URANIE::Relauncher::TEval::eval(), forward_header(), forward_value(), URANIE::Relauncher::TEval::getInputList(), URANIE::Relauncher::TEval::getOutputList(), URANIE::Relauncher::TEval::rebuild(), URANIE::MpiRelauncher::TMpiRun::receive_header(), URANIE::MpiRelauncher::TMpiRun::receive_value(), URANIE::MpiRelauncher::TMpiRun::send_header(), URANIE::Relauncher::TSeparateRun::send_uentry(), URANIE::Relauncher::TSeparateRun::to_uentry(), and URANIE::Relauncher::TEval::unbuild().

Referenced by startSlave().

onMaster()

Bool_t URANIE::MpiRelauncher::TBiMpiRun::onMaster ( void  )

virtual

Reimplemented from URANIE::MpiRelauncher::TMpiRun.

References _topid.

startSlave()

void URANIE::MpiRelauncher::TBiMpiRun::startSlave ( void  )

virtual

Reimplemented from URANIE::MpiRelauncher::TMpiRun.

References URANIE::Relauncher::TShareRun::_fun, _lowid, URANIE::Relauncher::TRun::_ncpus, URANIE::Relauncher::TSeparateRun::_sizein, URANIE::Relauncher::TSeparateRun::_sizeout, URANIE::Relauncher::TSeparateRun::_sleep, _topid, URANIE::Relauncher::TSeparateRun::calcul_loop(), URANIE::Relauncher::TEval::getInputList(), URANIE::Relauncher::TEval::getOutputList(), and leader_loop().

stopSlave()

void URANIE::MpiRelauncher::TBiMpiRun::stopSlave ( void  )

virtual

Reimplemented from URANIE::Relauncher::TSeparateRun.

References URANIE::Relauncher::TSeparateRun::_sizein, and URANIE::Relauncher::TRun::stopSlave().

Member Data Documentation

__intra

MPI_Comm URANIE::MpiRelauncher::TBiMpiRun::__intra

staticprotected

Referenced by calculSize(), forward_header(), forward_value(), getCalculMpiComm(), and getCalculMpiCommPy().

__isBiMpi

bool URANIE::MpiRelauncher::TBiMpiRun::__isBiMpi =false

staticprotected

Referenced by calculSize(), getCalculMpiComm(), getCalculMpiCommPy(), and isBiMpi().

_lowid

int URANIE::MpiRelauncher::TBiMpiRun::_lowid

protected

Referenced by calculSize(), and startSlave().

_lowsz

int URANIE::MpiRelauncher::TBiMpiRun::_lowsz

protected

Referenced by calculSize().

_topid

int URANIE::MpiRelauncher::TBiMpiRun::_topid

protected

Referenced by calculSize(), onMaster(), and startSlave().

_topsz

int URANIE::MpiRelauncher::TBiMpiRun::_topsz

protected

Referenced by calculSize().