URANIE::Relauncher::TSeparateRun Class Reference

#include <TSeparateRun.h>

Inheritance diagram for URANIE::Relauncher::TSeparateRun:

Collaboration diagram for URANIE::Relauncher::TSeparateRun:

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

Protected Member Functions
virtual int	wait_service ()=0
virtual int	send_header (int canal, int *head, int size)=0
virtual int	send_value (int canal, double *mesg, int size)=0
virtual int	receive_header (int canal, int *head, int size)=0
virtual int	receive_value (int canal, double *mesg, int size)=0
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	_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

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

Constructor & Destructor Documentation

TSeparateRun()

URANIE::Relauncher::TSeparateRun::TSeparateRun

(

URANIE::Relauncher::TEval *

r

)

References URANIE::Relauncher::TRun::_ncpus.

~TSeparateRun()

URANIE::Relauncher::TSeparateRun::~TSeparateRun ( )

virtual

Member Function Documentation

calcul_loop()

void URANIE::Relauncher::TSeparateRun::calcul_loop ( )

protected

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

Referenced by URANIE::MpiRelauncher::TMpiRun::startSlave(), URANIE::Relauncher::TSocketRun::startSlave(), and URANIE::MpiRelauncher::TBiMpiRun::startSlave().

empty_uentry()

void URANIE::Relauncher::TSeparateRun::empty_uentry ( TIter &  next, std::vector< URANIE::DataServer::UEntry * > &  dest  )

protected

Referenced by calcul_loop(), URANIE::MpiRelauncher::TBiMpiRun::calcul_loop(), and URANIE::MpiRelauncher::TBiMpiRun::leader_loop().

get()

int URANIE::Relauncher::TSeparateRun::get ( long &  idc )

virtual

Implements URANIE::Relauncher::TRun.

References _pend, _run, _sizein, _sizeout, _sleep, URANIE::Relauncher::element::calcnb, URANIE::Relauncher::element::id, URANIE::Relauncher::element::inv, URANIE::Relauncher::element::outv, receive_header(), receive_value(), send_uentry(), to_uentry(), and wait_service().

put()

void URANIE::Relauncher::TSeparateRun::put ( long  , vector< URANIE::DataServer::UEntry * > *  in, vector< URANIE::DataServer::UEntry * > *  out, int  = 0  )

virtual

Implements URANIE::Relauncher::TShareRun.

References _pend, _run, _sizein, _sleep, and send_uentry().

receive_header()

virtual int URANIE::Relauncher::TSeparateRun::receive_header ( int  canal, int *  head, int  size  )

protectedpure virtual

Implemented in URANIE::MpiRelauncher::TMpiRun, and URANIE::Relauncher::TSocketRun.

Referenced by calcul_loop(), and get().

receive_value()

virtual int URANIE::Relauncher::TSeparateRun::receive_value ( int  canal, double *  mesg, int  size  )

protectedpure virtual

Implemented in URANIE::MpiRelauncher::TMpiRun, and URANIE::Relauncher::TSocketRun.

Referenced by calcul_loop(), and get().

send_header()

virtual int URANIE::Relauncher::TSeparateRun::send_header ( int  canal, int *  head, int  size  )

protectedpure virtual

Implemented in URANIE::MpiRelauncher::TMpiRun, and URANIE::Relauncher::TSocketRun.

Referenced by calcul_loop(), send_uentry(), and stopSlave().

send_uentry()

void URANIE::Relauncher::TSeparateRun::send_uentry ( int  canal, int  ncalc, int  size, vector< URANIE::DataServer::UEntry * > *  in  )

protected

References send_header(), and send_value().

Referenced by calcul_loop(), get(), URANIE::MpiRelauncher::TBiMpiRun::leader_loop(), and put().

send_value()

virtual int URANIE::Relauncher::TSeparateRun::send_value ( int  canal, double *  mesg, int  size  )

protectedpure virtual

Implemented in URANIE::MpiRelauncher::TMpiRun, and URANIE::Relauncher::TSocketRun.

Referenced by send_uentry().

startSlave()

void URANIE::Relauncher::TSeparateRun::startSlave ( void  )

virtual

Implements URANIE::Relauncher::TRun.

Reimplemented in URANIE::MpiRelauncher::TMpiRun, URANIE::Relauncher::TSocketRun, and URANIE::MpiRelauncher::TBiMpiRun.

References URANIE::Relauncher::TShareRun::_fun, _sizein, _sizeout, URANIE::Relauncher::TEval::getInputList(), and URANIE::Relauncher::TEval::getOutputList().

Referenced by URANIE::Relauncher::TSocketRun::startSlave().

stopSlave()

void URANIE::Relauncher::TSeparateRun::stopSlave ( void  )

virtual

Implements URANIE::Relauncher::TRun.

Reimplemented in URANIE::MpiRelauncher::TBiMpiRun.

References URANIE::Relauncher::TRun::_ncpus, _sizein, URANIE::Relauncher::TRun::onMaster(), and send_header().

Referenced by URANIE::MpiRelauncher::TMpiRun::~TMpiRun().

to_uentry()

void URANIE::Relauncher::TSeparateRun::to_uentry ( int *  isz, double *  vals, std::vector< URANIE::DataServer::UEntry * > &  dest  )

protected

Referenced by calcul_loop(), URANIE::MpiRelauncher::TBiMpiRun::calcul_loop(), get(), and URANIE::MpiRelauncher::TBiMpiRun::leader_loop().

wait_service()

virtual int URANIE::Relauncher::TSeparateRun::wait_service ( )

protectedpure virtual

Implemented in URANIE::MpiRelauncher::TMpiRun, and URANIE::Relauncher::TSocketRun.

Referenced by get().

Member Data Documentation

_nbress

int URANIE::Relauncher::TSeparateRun::_nbress

protected

_pend

std::queue<element> URANIE::Relauncher::TSeparateRun::_pend

protected

Referenced by get(), and put().

_run

std::vector<struct element> URANIE::Relauncher::TSeparateRun::_run

protected

Referenced by get(), put(), URANIE::Relauncher::TSocketRun::startSlave(), URANIE::MpiRelauncher::TMpiRun::TMpiRun(), URANIE::MpiRelauncher::TMpiRun::TMpiRun(), and URANIE::MpiRelauncher::TMpiRun::TMpiRun().

_sizein

int URANIE::Relauncher::TSeparateRun::_sizein

protected

Referenced by calcul_loop(), URANIE::MpiRelauncher::TBiMpiRun::calcul_loop(), get(), URANIE::MpiRelauncher::TBiMpiRun::leader_loop(), put(), startSlave(), URANIE::MpiRelauncher::TBiMpiRun::startSlave(), stopSlave(), URANIE::MpiRelauncher::TBiMpiRun::stopSlave(), URANIE::MpiRelauncher::TMpiRun::TMpiRun(), URANIE::MpiRelauncher::TMpiRun::TMpiRun(), and URANIE::MpiRelauncher::TMpiRun::TMpiRun().

_sizeout

int URANIE::Relauncher::TSeparateRun::_sizeout

protected

Referenced by calcul_loop(), get(), URANIE::MpiRelauncher::TBiMpiRun::leader_loop(), startSlave(), URANIE::MpiRelauncher::TBiMpiRun::startSlave(), URANIE::MpiRelauncher::TMpiRun::TMpiRun(), URANIE::MpiRelauncher::TMpiRun::TMpiRun(), and URANIE::MpiRelauncher::TMpiRun::TMpiRun().

_sleep

std::queue<int> URANIE::Relauncher::TSeparateRun::_sleep

protected

Referenced by get(), put(), URANIE::MpiRelauncher::TMpiRun::startSlave(), URANIE::Relauncher::TSocketRun::startSlave(), and URANIE::MpiRelauncher::TBiMpiRun::startSlave().