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::XrdCmsClientMan	(	char *	host,
		int	port,
		int	cw,
		int	nr,
		int	rw,
		int	rd
	)

~XrdCmsClientMan()

XrdCmsClientMan::~XrdCmsClientMan

(

)

Member Function Documentation

chkStatus()

int XrdCmsClientMan::chkStatus ( )

private

Referenced by Suspended().

delayResp()

int XrdCmsClientMan::delayResp

(

XrdOucErrInfo &

Resp

)

Hookup()

int XrdCmsClientMan::Hookup ( )

private

isActive()

int XrdCmsClientMan::isActive ( )

inline

References Active, AtomicRet, and myData.

manPort()

int XrdCmsClientMan::manPort ( )

inline

References Port.

Name()

char * XrdCmsClientMan::Name ( )

inline

References Host.

nextManager()

XrdCmsClientMan * XrdCmsClientMan::nextManager ( )

inline

References Next.

NPfx()

char * XrdCmsClientMan::NPfx ( )

inline

References HPfx.

Receive()

int XrdCmsClientMan::Receive ( )

private

relayResp()

void XrdCmsClientMan::relayResp ( )

private

Send() [1/2]

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

Send() [2/2]

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

setConfig()

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

inlinestatic

References ConfigFN.

setNetwork()

static void XrdCmsClientMan::setNetwork ( XrdInet *  nP )

inlinestatic

References Network.

setNext()

void XrdCmsClientMan::setNext ( XrdCmsClientMan *  np )

inline

References Next.

setStatus()

void XrdCmsClientMan::setStatus ( )

private

Start()

void * XrdCmsClientMan::Start

(

)

Suspended()

int XrdCmsClientMan::Suspended ( )

inline

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

waitTime()

int XrdCmsClientMan::waitTime ( )

inline

References AtomicRet, myData, and repWait.

whatsUp()

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

Member Data Documentation

Active

int XrdCmsClientMan::Active

private

Referenced by isActive().

BuffPool

XrdOucBuffPool XrdCmsClientMan::BuffPool

staticprivate

chkCount

int XrdCmsClientMan::chkCount

private

chkVal

const int XrdCmsClientMan::chkVal = 256

staticprivate

ConfigFN

const char* XrdCmsClientMan::ConfigFN

staticprivate

Referenced by setConfig().

dally

int XrdCmsClientMan::dally

private

doDebug

char XrdCmsClientMan::doDebug

static

Host

char* XrdCmsClientMan::Host

private

Referenced by Name().

HPfx

char* XrdCmsClientMan::HPfx

private

Referenced by NPfx().

lastTOut

time_t XrdCmsClientMan::lastTOut

private

lastUpdt

time_t XrdCmsClientMan::lastUpdt

private

Link

XrdLink* XrdCmsClientMan::Link

private

manInst

unsigned int XrdCmsClientMan::manInst

private

manMask

int XrdCmsClientMan::manMask

private

manMutex

XrdSysMutex XrdCmsClientMan::manMutex

staticprivate

maxDelay

int XrdCmsClientMan::maxDelay

private

maxMsgID

int XrdCmsClientMan::maxMsgID

private

minDelay

int XrdCmsClientMan::minDelay

private

myData

XrdSysMutex XrdCmsClientMan::myData

private

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

NetBuff

XrdOucBuffer* XrdCmsClientMan::NetBuff

private

Network

XrdInet* XrdCmsClientMan::Network

staticprivate

Referenced by setNetwork().

Next

XrdCmsClientMan* XrdCmsClientMan::Next

private

Referenced by nextManager(), and setNext().

nrMax

int XrdCmsClientMan::nrMax

private

Port

int XrdCmsClientMan::Port

private

Referenced by manPort().

qTime

int XrdCmsClientMan::qTime

private

RecvCnt

int XrdCmsClientMan::RecvCnt

private

repWait

int XrdCmsClientMan::repWait

private

Referenced by waitTime().

repWMax

int XrdCmsClientMan::repWMax

private

Response

XrdCms::CmsRRHdr XrdCmsClientMan::Response

private

RespQ

XrdCmsRespQ XrdCmsClientMan::RespQ

private

SendCnt

int XrdCmsClientMan::SendCnt

private

Silent

int XrdCmsClientMan::Silent

private

Suspend

int XrdCmsClientMan::Suspend

private

Referenced by Suspended().

syncResp

XrdSysSemaphore XrdCmsClientMan::syncResp

private

---

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

• XrdCmsClientMan.hh