XrdCmsClientMan Class Reference

#include <XrdCmsClientMan.hh>

Collaboration diagram for XrdCmsClientMan:

Public Member Functions
int	delayResp (XrdOucErrInfo &Resp)
int	isActive ()
XrdCmsClientMan *	nextManager ()
char *	Name ()
char *	NPfx ()
int	manPort ()
int	Send (unsigned int &iMan, char *msg, int mlen=0)
int	Send (unsigned int &iMan, const struct iovec *iov, int iovcnt, int iotot=0)
void *	Start ()
int	Suspended ()
void	setNext (XrdCmsClientMan *np)
int	whatsUp (const char *user, const char *path, unsigned int iMan)
int	waitTime ()
	XrdCmsClientMan (char *host, int port, int cw, int nr, int rw, int rd)
	~XrdCmsClientMan ()

Static Public Member Functions
static void	setNetwork (XrdInet *nP)
static void	setConfig (const char *cfn)

Static Public Attributes
static char	doDebug

Private Member Functions
int	Hookup ()
int	Receive ()
void	relayResp ()
int	chkStatus ()
void	setStatus ()

Private Attributes
XrdSysSemaphore	syncResp
XrdCmsRespQ	RespQ
XrdCmsClientMan *	Next
XrdSysMutex	myData
XrdLink *	Link
char *	Host
char *	HPfx
int	Port
unsigned int	manInst
int	manMask
int	dally
int	Active
int	Silent
int	Suspend
int	RecvCnt
int	SendCnt
int	nrMax
int	maxMsgID
int	repWait
int	repWMax
int	minDelay
int	maxDelay
int	qTime
int	chkCount
time_t	lastUpdt
time_t	lastTOut
XrdCms::CmsRRHdr	Response
XrdOucBuffer *	NetBuff

Static Private Attributes
static XrdSysMutex	manMutex
static XrdOucBuffPool	BuffPool
static XrdInet *	Network
static const char *	ConfigFN
static const int	chkVal = 256

Constructor & Destructor Documentation

XrdCmsClientMan::XrdCmsClientMan	(	char *	host,
		int	port,
		int	cw,
		int	nr,
		int	rw,
		int	rd
	)

XrdCmsClientMan::~XrdCmsClientMan

(

)

Member Function Documentation

int XrdCmsClientMan::chkStatus ( )

private

Referenced by Suspended().

int XrdCmsClientMan::delayResp

(

XrdOucErrInfo &

Resp

)

int XrdCmsClientMan::Hookup ( )

private

int XrdCmsClientMan::isActive ( )

inline

References Active, AtomicRet, and myData.

int XrdCmsClientMan::manPort ( )

inline

References Port.

char* XrdCmsClientMan::Name ( )

inline

References Host.

XrdCmsClientMan* XrdCmsClientMan::nextManager ( )

inline

References Next.

char* XrdCmsClientMan::NPfx ( )

inline

References HPfx.

int XrdCmsClientMan::Receive ( )

private

void XrdCmsClientMan::relayResp ( )

private

int XrdCmsClientMan::Send	(	unsigned int &	iMan,
		char *	msg,
		int	mlen = 0
	)

int XrdCmsClientMan::Send	(	unsigned int &	iMan,
		const struct iovec *	iov,
		int	iovcnt,
		int	iotot = 0
	)

static void XrdCmsClientMan::setConfig ( const char *  cfn )

inlinestatic

References ConfigFN.

static void XrdCmsClientMan::setNetwork ( XrdInet *  nP )

inlinestatic

References Network.

void XrdCmsClientMan::setNext ( XrdCmsClientMan *  np )

inline

References Next.

void XrdCmsClientMan::setStatus ( )

private

void* XrdCmsClientMan::Start

(

)

int XrdCmsClientMan::Suspended ( )

inline

References AtomicBeg, AtomicEnd, AtomicGet, chkStatus(), myData, and Suspend.

int XrdCmsClientMan::waitTime ( )

inline

References AtomicRet, myData, and repWait.

int XrdCmsClientMan::whatsUp	(	const char *	user,
		const char *	path,
		unsigned int	iMan
	)

Member Data Documentation

int XrdCmsClientMan::Active

private

Referenced by isActive().

XrdOucBuffPool XrdCmsClientMan::BuffPool

staticprivate

int XrdCmsClientMan::chkCount

private

const int XrdCmsClientMan::chkVal = 256

staticprivate

const char* XrdCmsClientMan::ConfigFN

staticprivate

Referenced by setConfig().

int XrdCmsClientMan::dally

private

char XrdCmsClientMan::doDebug

static

char* XrdCmsClientMan::Host

private

Referenced by Name().

char* XrdCmsClientMan::HPfx

private

Referenced by NPfx().

time_t XrdCmsClientMan::lastTOut

private

time_t XrdCmsClientMan::lastUpdt

private

XrdLink* XrdCmsClientMan::Link

private

unsigned int XrdCmsClientMan::manInst

private

int XrdCmsClientMan::manMask

private

XrdSysMutex XrdCmsClientMan::manMutex

staticprivate

int XrdCmsClientMan::maxDelay

private

int XrdCmsClientMan::maxMsgID

private

int XrdCmsClientMan::minDelay

private

XrdSysMutex XrdCmsClientMan::myData

private

Referenced by isActive(), Suspended(), and waitTime().

XrdOucBuffer* XrdCmsClientMan::NetBuff

private

XrdInet* XrdCmsClientMan::Network

staticprivate

Referenced by setNetwork().

XrdCmsClientMan* XrdCmsClientMan::Next

private

Referenced by nextManager(), and setNext().

int XrdCmsClientMan::nrMax

private

int XrdCmsClientMan::Port

private

Referenced by manPort().

int XrdCmsClientMan::qTime

private

int XrdCmsClientMan::RecvCnt

private

int XrdCmsClientMan::repWait

private

Referenced by waitTime().

int XrdCmsClientMan::repWMax

private

XrdCms::CmsRRHdr XrdCmsClientMan::Response

private

XrdCmsRespQ XrdCmsClientMan::RespQ

private

int XrdCmsClientMan::SendCnt

private

int XrdCmsClientMan::Silent

private

int XrdCmsClientMan::Suspend

private

Referenced by Suspended().

XrdSysSemaphore XrdCmsClientMan::syncResp

private

---

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

• XrdCmsClientMan.hh