URANIE::Relauncher::TThreadedRun Class Reference

#include <TThreadedRun.h>

Inheritance diagram for URANIE::Relauncher::TThreadedRun:

Collaboration diagram for URANIE::Relauncher::TThreadedRun:

Public Member Functions
	TThreadedRun (TEval *, long)
virtual	~TThreadedRun (void)
virtual void	startSlave (void)
virtual Bool_t	onMaster (void)
virtual void	stopSlave (void)
void	calcul_loop (int)
virtual void	put (long int, std::vector< URANIE::DataServer::UEntry * > *, std::vector< URANIE::DataServer::UEntry * > *, int=0)
virtual Bool_t	readyToGet ()
virtual int	get (long &)
Public Member Functions inherited from URANIE::Relauncher::TShareRun
	TShareRun (TEval *fun)
virtual	~TShareRun ()
virtual TEval *	getEval ()
virtual void	put (long, vector< URANIE::DataServer::UEntry * > *in, vector< URANIE::DataServer::UEntry * > *out, int icalc)=0
Public Member Functions inherited from URANIE::Relauncher::TRun
virtual	~TRun ()

Protected Member Functions
struct element	serviceGet ()
void	servicePut (long, int)

Protected Attributes
long	_nbnode
int	_runcore
pthread_mutex_t	_mutex_in
pthread_mutex_t	_mutex_out
pthread_cond_t	_invide
pthread_cond_t	_outvide
std::queue< struct element >	_qin
std::queue< struct relement >	_qout
std::vector< struct job >	_job
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

TThreadedRun()

URANIE::Relauncher::TThreadedRun::TThreadedRun	(	TEval *	user,
		long	nbnod
	)

References _invide, _mutex_in, _mutex_out, URANIE::Relauncher::TRun::_ncpus, _outvide, _runcore, and URANIE::Relauncher::TEval::isThreadSafe().

~TThreadedRun()

URANIE::Relauncher::TThreadedRun::~TThreadedRun ( void  )

virtual

References _invide, _mutex_in, _mutex_out, _outvide, and stopSlave().

Member Function Documentation

calcul_loop()

void URANIE::Relauncher::TThreadedRun::calcul_loop

(

int

id

)

References URANIE::Relauncher::TShareRun::_fun, URANIE::Relauncher::element::calcnb, URANIE::Relauncher::element::id, URANIE::Relauncher::element::inv, URANIE::Relauncher::element::outv, URANIE::Relauncher::TEval::rebuild(), serviceGet(), and servicePut().

Referenced by URANIE::Relauncher::calcul_loop_bg().

get()

int URANIE::Relauncher::TThreadedRun::get ( long &  id )

virtual

Implements URANIE::Relauncher::TRun.

References _mutex_out, _outvide, _qout, URANIE::Relauncher::relement::id, and URANIE::Relauncher::relement::stat.

onMaster()

Bool_t URANIE::Relauncher::TThreadedRun::onMaster ( void  )

virtual

Implements URANIE::Relauncher::TRun.

put()

void URANIE::Relauncher::TThreadedRun::put ( long int  , std::vector< URANIE::DataServer::UEntry * > *  , std::vector< URANIE::DataServer::UEntry * > *  , int  = 0  )

virtual

References _invide, _mutex_in, and _qin.

Referenced by stopSlave().

readyToGet()

Bool_t URANIE::Relauncher::TThreadedRun::readyToGet ( )

virtual

Implements URANIE::Relauncher::TRun.

References _qout.

serviceGet()

struct element URANIE::Relauncher::TThreadedRun::serviceGet ( )

protected

Referenced by calcul_loop().

servicePut()

void URANIE::Relauncher::TThreadedRun::servicePut ( long  id, int  ret  )

protected

References _mutex_out, _outvide, _qout, URANIE::Relauncher::relement::id, and URANIE::Relauncher::relement::stat.

Referenced by calcul_loop().

startSlave()

void URANIE::Relauncher::TThreadedRun::startSlave ( void  )

virtual

Implements URANIE::Relauncher::TRun.

References _job, URANIE::Relauncher::TRun::_ncpus, _runcore, and URANIE::Relauncher::calcul_loop_bg().

stopSlave()

void URANIE::Relauncher::TThreadedRun::stopSlave ( void  )

virtual

Implements URANIE::Relauncher::TRun.

References _job, _runcore, and put().

Referenced by ~TThreadedRun().

Member Data Documentation

_invide

pthread_cond_t URANIE::Relauncher::TThreadedRun::_invide

protected

Referenced by put(), TThreadedRun(), and ~TThreadedRun().

_job

std::vector<struct job> URANIE::Relauncher::TThreadedRun::_job

protected

Referenced by startSlave(), and stopSlave().

_mutex_in

pthread_mutex_t URANIE::Relauncher::TThreadedRun::_mutex_in

protected

Referenced by put(), TThreadedRun(), and ~TThreadedRun().

_mutex_out

pthread_mutex_t URANIE::Relauncher::TThreadedRun::_mutex_out

protected

Referenced by get(), servicePut(), TThreadedRun(), and ~TThreadedRun().

_nbnode

long URANIE::Relauncher::TThreadedRun::_nbnode

protected

_outvide

pthread_cond_t URANIE::Relauncher::TThreadedRun::_outvide

protected

Referenced by get(), servicePut(), TThreadedRun(), and ~TThreadedRun().

_qin

std::queue<struct element> URANIE::Relauncher::TThreadedRun::_qin

protected

Referenced by put().

_qout

std::queue<struct relement> URANIE::Relauncher::TThreadedRun::_qout

protected

Referenced by get(), readyToGet(), and servicePut().

_runcore

int URANIE::Relauncher::TThreadedRun::_runcore

protected

Referenced by startSlave(), stopSlave(), and TThreadedRun().