xrootd: XrdOdcManager Class Reference

#include <XrdOdcManager.hh>

Collaboration diagram for XrdOdcManager:

Collaboration graph

List of all members.

Public Member Functions
int	delayResp (XrdOucErrInfo &Resp)
void	relayResp (int msgid, char *msg)
int	isActive ()
XrdOdcManager *	nextManager ()
char *	Name ()
char *	NPfx ()
int	Send (char *msg, int mlen=0)
int	Send (const struct iovec *iov, int iovcnt)
void	setTID (pthread_t tid)
void *	Start ()
void	setNext (XrdOdcManager *np)
void	whatsUp ()
	XrdOdcManager (XrdSysError erp, char host, int port, int cw, int nr)
	~XrdOdcManager ()
Private Member Functions
void	Hookup ()
void	Sleep (int slpsec)
char *	Receive (int &msgid)
Private Attributes
XrdSysSemaphore	syncResp
XrdOdcRespQ	RespQ
XrdOdcManager *	Next
XrdSysMutex	myData
XrdSysError *	eDest
XrdNetLink *	Link
XrdNetWork *	Network
char *	Host
char *	HPfx
int	Port
pthread_t	mytid
int	dally
int	Active
int	Silent
int	nrMax
int	maxMsgID

Constructor & Destructor Documentation

XrdOdcManager::XrdOdcManager	(	XrdSysError *	erp,
		char *	host,
		int	port,
		int	cw,
		int	nr
	)

References Active, dally, eDest, Host, HPfx, index(), Link, mytid, Network, nrMax, Port, and Silent.

XrdOdcManager::~XrdOdcManager ( )

References Host, HPfx, XrdSysThread::Kill(), Link, mytid, Network, and XrdNetLink::Recycle().

Member Function Documentation

int XrdOdcManager::delayResp ( XrdOucErrInfo & Resp )

References XrdOdcRespQ::Add(), XrdOdcResp::Alloc(), eDest, XrdSysError::Emsg(), XrdOucErrInfo::getErrText(), XrdOucErrInfo::getErrUser(), Host, maxMsgID, XrdSysSemaphore::Post(), XrdOdcRespQ::Purge(), RespQ, XrdOucErrInfo::setErrInfo(), and syncResp.

Referenced by XrdOdcFinderRMT::send2Man().

void XrdOdcManager::Hookup ( ) [private]

References Active, XrdNetWork::Connect(), dally, eDest, XrdSysError::Emsg(), Host, Link, XrdSysMutex::Lock(), myData, Network, opts, Port, XrdNetLink::Recycle(), XrdNetLink::Send(), Silent, Sleep(), and XrdSysMutex::UnLock().

Referenced by Start().

int XrdOdcManager::isActive ( ) [inline]

References Active.

Referenced by XrdOdcFinderRMT::SelectManager().

char* XrdOdcManager::Name ( ) [inline]

References Host.

Referenced by XrdOdcFinderRMT::Prepare().

XrdOdcManager* XrdOdcManager::nextManager ( ) [inline]

References Next.

Referenced by XrdOdcFinderRMT::SelectManager(), and XrdOdcFinderRMT::~XrdOdcFinderRMT().

char* XrdOdcManager::NPfx ( ) [inline]

References HPfx.

Referenced by XrdOdcFinderRMT::send2Man().

char * XrdOdcManager::Receive ( int & msgid ) [private]

References DEBUG, eDest, XrdSysError::Emsg(), EPNAME, XrdNetLink::GetLine(), XrdNetLink::GetToken(), Host, Link, XrdNetLink::Name(), and Silent.

Referenced by Start().

void XrdOdcManager::relayResp	(	int	msgid,
		char *	msg
	)

References DEBUG, EPNAME, Host, HPfx, XrdOdcRespQ::Rem(), XrdOdcResp::Reply(), and RespQ.

Referenced by Start().

int XrdOdcManager::Send	(	const struct iovec *	iov,
		int	iovcnt
	)

References Active, XrdNetLink::Close(), Link, XrdSysMutex::Lock(), myData, XrdNetLink::Send(), and XrdSysMutex::UnLock().

int XrdOdcManager::Send	(	char *	msg,
		int	mlen = `0`
	)

References Active, XrdNetLink::Close(), Link, XrdSysMutex::Lock(), myData, XrdNetLink::Send(), and XrdSysMutex::UnLock().

Referenced by XrdOdcFinderRMT::Forward(), XrdOdcFinderRMT::Prepare(), and XrdOdcFinderRMT::send2Man().

void XrdOdcManager::setNext ( XrdOdcManager * np ) [inline]

References Next.

Referenced by XrdOdcFinderRMT::StartManagers().

void XrdOdcManager::setTID ( pthread_t tid ) [inline]

References mytid.

void XrdOdcManager::Sleep ( int slpsec ) [private]

References eDest, and XrdSysError::Emsg().

Referenced by Hookup(), and Start().

void * XrdOdcManager::Start ( )

References Active, dally, eDest, XrdSysError::Emsg(), Hookup(), Host, XrdNetLink::LastError(), Link, XrdSysMutex::Lock(), myData, Receive(), XrdNetLink::Recycle(), relayResp(), XrdOdcMsg::Reply(), Sleep(), syncResp, XrdSysMutex::UnLock(), and XrdSysSemaphore::Wait().

Referenced by XrdOdcStartManager().

void XrdOdcManager::whatsUp ( )

References Active, XrdNetLink::Close(), Link, XrdSysMutex::Lock(), myData, nrMax, Silent, and XrdSysMutex::UnLock().

Referenced by XrdOdcFinderRMT::send2Man().

Member Data Documentation

int XrdOdcManager::Active [private]

Referenced by Hookup(), isActive(), Send(), Start(), whatsUp(), and XrdOdcManager().

int XrdOdcManager::dally [private]

Referenced by Hookup(), Start(), and XrdOdcManager().

XrdSysError* XrdOdcManager::eDest [private]

Referenced by delayResp(), Hookup(), Receive(), Sleep(), Start(), and XrdOdcManager().

char* XrdOdcManager::Host [private]

Referenced by delayResp(), Hookup(), Name(), Receive(), relayResp(), Start(), XrdOdcManager(), and ~XrdOdcManager().

char* XrdOdcManager::HPfx [private]

Referenced by NPfx(), relayResp(), XrdOdcManager(), and ~XrdOdcManager().

XrdNetLink* XrdOdcManager::Link [private]

Referenced by Hookup(), Receive(), Send(), Start(), whatsUp(), XrdOdcManager(), and ~XrdOdcManager().

int XrdOdcManager::maxMsgID [private]

Referenced by delayResp().

XrdSysMutex XrdOdcManager::myData [private]

Referenced by Hookup(), Send(), Start(), and whatsUp().

pthread_t XrdOdcManager::mytid [private]

Referenced by setTID(), XrdOdcManager(), and ~XrdOdcManager().

XrdNetWork* XrdOdcManager::Network [private]

Referenced by Hookup(), XrdOdcManager(), and ~XrdOdcManager().

XrdOdcManager* XrdOdcManager::Next [private]

Referenced by nextManager(), and setNext().

int XrdOdcManager::nrMax [private]

Referenced by whatsUp(), and XrdOdcManager().

int XrdOdcManager::Port [private]

Referenced by Hookup(), and XrdOdcManager().

XrdOdcRespQ XrdOdcManager::RespQ [private]

Referenced by delayResp(), and relayResp().

int XrdOdcManager::Silent [private]

Referenced by Hookup(), Receive(), whatsUp(), and XrdOdcManager().

XrdSysSemaphore XrdOdcManager::syncResp [private]

Referenced by delayResp(), and Start().

The documentation for this class was generated from the following files: