URANIE::Relauncher::TSocketRun Class Reference

#include <TSocketRun.h>

Inheritance diagram for URANIE::Relauncher::TSocketRun:

Collaboration diagram for URANIE::Relauncher::TSocketRun:

Public Member Functions
	TSocketRun (URANIE::Relauncher::TEval *r, int p=5432)
virtual	~TSocketRun ()
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
TServerSocket *	_sserv
TMonitor *	_moni
std::vector< TSocket * >	_sclient
const char *	_conn
int	_port
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

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

Constructor & Destructor Documentation

TSocketRun()

URANIE::Relauncher::TSocketRun::TSocketRun	(	URANIE::Relauncher::TEval *	r,
		int	p = 5432
	)

References _conn, _moni, and _sserv.

~TSocketRun()

URANIE::Relauncher::TSocketRun::~TSocketRun ( )

virtual

References _moni, URANIE::Relauncher::TRun::_ncpus, _sclient, and _sserv.

Member Function Documentation

onMaster()

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

virtual

Implements URANIE::Relauncher::TRun.

References _sserv.

readyToGet()

Bool_t URANIE::Relauncher::TSocketRun::readyToGet ( )

virtual

Implements URANIE::Relauncher::TRun.

References _moni.

receive_header()

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

protectedvirtual

Implements URANIE::Relauncher::TSeparateRun.

References _sclient.

receive_value()

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

protectedvirtual

Implements URANIE::Relauncher::TSeparateRun.

References _sclient.

send_header()

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

protectedvirtual

Implements URANIE::Relauncher::TSeparateRun.

References _sclient.

send_value()

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

protectedvirtual

Implements URANIE::Relauncher::TSeparateRun.

References _sclient.

startSlave()

void URANIE::Relauncher::TSocketRun::startSlave ( void  )

virtual

Reimplemented from URANIE::Relauncher::TSeparateRun.

References _conn, _moni, URANIE::Relauncher::TRun::_ncpus, _port, URANIE::Relauncher::TSeparateRun::_run, _sclient, URANIE::Relauncher::TSeparateRun::_sleep, _sserv, URANIE::Relauncher::TSeparateRun::calcul_loop(), URANIE::Relauncher::TSeparateRun::startSlave(), and TIMEOUT.

wait_service()

int URANIE::Relauncher::TSocketRun::wait_service ( )

protectedvirtual

Implements URANIE::Relauncher::TSeparateRun.

References _moni, URANIE::Relauncher::TRun::_ncpus, and _sclient.

Member Data Documentation

_conn

const char* URANIE::Relauncher::TSocketRun::_conn

protected

Referenced by startSlave(), and TSocketRun().

_moni

TMonitor* URANIE::Relauncher::TSocketRun::_moni

protected

Referenced by readyToGet(), startSlave(), TSocketRun(), wait_service(), and ~TSocketRun().

_port

int URANIE::Relauncher::TSocketRun::_port

protected

Referenced by startSlave().

_sclient

std::vector<TSocket *> URANIE::Relauncher::TSocketRun::_sclient

protected

Referenced by receive_header(), receive_value(), send_header(), send_value(), startSlave(), wait_service(), and ~TSocketRun().

_sserv

TServerSocket* URANIE::Relauncher::TSocketRun::_sserv

protected

Referenced by onMaster(), startSlave(), TSocketRun(), and ~TSocketRun().