URANIE::MpiRelauncher::TMpiRun Class Reference

#include <TMpiRun.h>

Inheritance diagram for URANIE::MpiRelauncher::TMpiRun:

Collaboration diagram for URANIE::MpiRelauncher::TMpiRun:

Public Member Functions
	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 void	startSlave ()
virtual Bool_t	onMaster ()
virtual Bool_t	readyToGet ()
Public Member Functions inherited from URANIE::Relauncher::TSeparateRun
	TSeparateRun (URANIE::Relauncher::TEval *r)
virtual	~TSeparateRun ()
virtual void	stopSlave ()
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 ()

Protected Member Functions
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	_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 int	_count = 0

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

Constructor & Destructor Documentation

TMpiRun() [1/3]

URANIE::MpiRelauncher::TMpiRun::TMpiRun	(	URANIE::Relauncher::TEval *	r,
		int *	argc,
		char ***	argv
	)

References _comm, _count, _id, URANIE::Relauncher::TRun::_ncpus, URANIE::Relauncher::TSeparateRun::_run, URANIE::Relauncher::TSeparateRun::_sizein, and URANIE::Relauncher::TSeparateRun::_sizeout.

TMpiRun() [2/3]

URANIE::MpiRelauncher::TMpiRun::TMpiRun	(	URANIE::Relauncher::TEval *	r,
		Bool_t	init = kTRUE
	)

References _comm, _count, _id, URANIE::Relauncher::TRun::_ncpus, URANIE::Relauncher::TSeparateRun::_run, URANIE::Relauncher::TSeparateRun::_sizein, and URANIE::Relauncher::TSeparateRun::_sizeout.

TMpiRun() [3/3]

URANIE::MpiRelauncher::TMpiRun::TMpiRun	(	URANIE::Relauncher::TEval *	r,
		MPI_Comm	comm
	)

References _comm, _count, _id, URANIE::Relauncher::TRun::_ncpus, URANIE::Relauncher::TSeparateRun::_run, URANIE::Relauncher::TSeparateRun::_sizein, and URANIE::Relauncher::TSeparateRun::_sizeout.

~TMpiRun()

URANIE::MpiRelauncher::TMpiRun::~TMpiRun ( )

virtual

References _count, and URANIE::Relauncher::TSeparateRun::stopSlave().

Member Function Documentation

onMaster()

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

virtual

Implements URANIE::Relauncher::TRun.

Reimplemented in URANIE::MpiRelauncher::TBiMpiRun.

References _id.

readyToGet()

Bool_t URANIE::MpiRelauncher::TMpiRun::readyToGet ( )

virtual

Implements URANIE::Relauncher::TRun.

References _comm, and HEADER.

receive_header()

int URANIE::MpiRelauncher::TMpiRun::receive_header ( int  canal, int *  head, int  size  )

protectedvirtual

Implements URANIE::Relauncher::TSeparateRun.

References _comm, and HEADER.

Referenced by URANIE::MpiRelauncher::TBiMpiRun::leader_loop().

receive_value()

int URANIE::MpiRelauncher::TMpiRun::receive_value ( int  canal, double *  mesg, int  size  )

protectedvirtual

Implements URANIE::Relauncher::TSeparateRun.

References _comm, and VALUE.

Referenced by URANIE::MpiRelauncher::TBiMpiRun::leader_loop().

send_header()

int URANIE::MpiRelauncher::TMpiRun::send_header ( int  canal, int *  head, int  size  )

protectedvirtual

Implements URANIE::Relauncher::TSeparateRun.

References _comm, and HEADER.

Referenced by URANIE::MpiRelauncher::TBiMpiRun::leader_loop().

send_value()

int URANIE::MpiRelauncher::TMpiRun::send_value ( int  canal, double *  mesg, int  size  )

protectedvirtual

Implements URANIE::Relauncher::TSeparateRun.

References _comm, and VALUE.

startSlave()

void URANIE::MpiRelauncher::TMpiRun::startSlave ( void  )

virtual

Reimplemented from URANIE::Relauncher::TSeparateRun.

Reimplemented in URANIE::MpiRelauncher::TBiMpiRun.

References _id, URANIE::Relauncher::TRun::_ncpus, URANIE::Relauncher::TSeparateRun::_sleep, and URANIE::Relauncher::TSeparateRun::calcul_loop().

wait_service()

int URANIE::MpiRelauncher::TMpiRun::wait_service ( )

protectedvirtual

Implements URANIE::Relauncher::TSeparateRun.

References _comm, and HEADER.

Member Data Documentation

_comm

MPI_Comm URANIE::MpiRelauncher::TMpiRun::_comm

protected

Referenced by URANIE::MpiRelauncher::TBiMpiRun::calculSize(), readyToGet(), receive_header(), receive_value(), send_header(), send_value(), TMpiRun(), TMpiRun(), TMpiRun(), and wait_service().

_count

int URANIE::MpiRelauncher::TMpiRun::_count = 0

staticprotected

Referenced by TMpiRun(), TMpiRun(), TMpiRun(), and ~TMpiRun().

_id

int URANIE::MpiRelauncher::TMpiRun::_id

protected

Referenced by URANIE::MpiRelauncher::TBiMpiRun::calculSize(), onMaster(), startSlave(), TMpiRun(), TMpiRun(), and TMpiRun().