#include <XrdCmsCluster.hh>

Collaboration diagram for XrdCmsCluster:

[legend]

Public Types
enum	CmsLSOpts { LS_NULL =0, LS_IPO =0x0100, LS_IDNT =0x0200, LS_ANY =0x0400, LS_IFMASK = 0x0f }

Public Member Functions
XrdCmsNode *	Add (XrdLink lp, int dport, int Status, int sport, const char theNID, const char *theIF)

virtual void	BlackList (XrdOucTList *blP)

SMask_t	Broadcast (SMask_t, const struct iovec *, int, int tot=0)

SMask_t	Broadcast (SMask_t smask, XrdCms::CmsRRHdr &Hdr, char *Data, int Dlen=0)

SMask_t	Broadcast (SMask_t smask, XrdCms::CmsRRHdr &Hdr, void *Data, int Dlen)

int	Broadsend (SMask_t smask, XrdCms::CmsRRHdr &Hdr, void *Data, int Dlen)

SMask_t	getMask (const XrdNetAddr *addr)

SMask_t	getMask (const char *Cid)

XrdCmsSelected *	List (SMask_t mask, CmsLSOpts opts, bool &oksel)

int	Locate (XrdCmsSelect &Sel)

void *	MonPerf ()

void *	MonRefs ()

long long	Refs ()

void	Remove (XrdCmsNode *theNode)

void	Remove (const char reason, XrdCmsNode theNode, int immed=0)

void	ResetRef (SMask_t smask, bool isLocked=false)

int	Select (XrdCmsSelect &Sel)

int	Select (SMask_t pmask, int &port, char *hbuff, int &hlen, int isrw, int isMulti, int ifWant)

void	SLock (bool dolock)

void	Space (XrdCms::SpaceData &sData, SMask_t smask)

int	Stats (char *bfr, int bln)

int	Statt (char *bfr, int bln)

	XrdCmsCluster ()

virtual	~XrdCmsCluster ()

Public Attributes
int	NodeCnt

Static Public Attributes
static const int	NotFound = -1

static const int	Wait4CBk = -2

static const int	RetryErr = -3

static const int	EReplete = -4

Private Types
enum	{ eExists, eDups, eROfs, eNoRep, eNoSel, eNoEnt }

Private Member Functions
XrdCmsNode *	AddAlt (XrdCmsClustID cidP, XrdLink lp, int port, int Status, int sport, const char theNID, const char theIF)

XrdCmsNode *	calcDelay (XrdCmsSelector &selR)

int	Drop (int sent, int sinst, XrdCmsDrop *djp=0)

void	Record (char path, const char reason, bool force=false)

bool	maxBits (SMask_t mVec, int mbits)

int	Multiple (SMask_t mVec)

int	SelFail (XrdCmsSelect &Sel, int rc)

int	SelNode (XrdCmsSelect &Sel, SMask_t pmask, SMask_t amask)

XrdCmsNode *	SelbyCost (SMask_t, XrdCmsSelector &selR)

XrdCmsNode *	SelbyLoad (SMask_t, XrdCmsSelector &selR)

XrdCmsNode *	SelbyRef (SMask_t, XrdCmsSelector &selR)

int	SelDFS (XrdCmsSelect &Sel, SMask_t amask, SMask_t &pmask, SMask_t &smask, int isRW)

void	sendAList (XrdLink *lp)

void	setAltMan (int snum, XrdLink *lp, int port)

int	Unreachable (XrdCmsSelect &Sel, bool none)

int	Unuseable (XrdCmsSelect &Sel)

Private Attributes
XrdSysMutex	XXMutex

XrdSysMutex	STMutex

XrdCmsNode *	NodeTab [STMax]

int	STHi

int	Reserved

long long	SelWcnt

long long	SelWtot

long long	SelRcnt

long long	SelRtot

long long	SelTcnt

char	AltMans [STMax *AltSize]

char *	AltMend

int	AltMent

SMask_t	peerHost

SMask_t	peerMask

Static Private Attributes
static const int	AltSize = 254

Friends
class	XrdCmsDrop

Member Enumeration Documentation

◆ anonymous enum

anonymous enum

private

Enumerator
eExists
eDups
eROfs
eNoRep
eNoSel
eNoEnt

◆ CmsLSOpts

enum XrdCmsCluster::CmsLSOpts

Enumerator
LS_NULL
LS_IPO
LS_IDNT
LS_ANY
LS_IFMASK

Constructor & Destructor Documentation

◆ XrdCmsCluster()

XrdCmsCluster::XrdCmsCluster ( )

◆ ~XrdCmsCluster()

virtual XrdCmsCluster::~XrdCmsCluster ( )

inlinevirtual

Member Function Documentation

◆ Add()

XrdCmsNode* XrdCmsCluster::Add	(	XrdLink *	lp,
		int	dport,
		int	Status,
		int	sport,
		const char *	theNID,
		const char *	theIF
	)

◆ AddAlt()

XrdCmsNode* XrdCmsCluster::AddAlt	(	XrdCmsClustID *	cidP,
		XrdLink *	lp,
		int	port,
		int	Status,
		int	sport,
		const char *	theNID,
		const char *	theIF
	)

private

◆ BlackList()

virtual void XrdCmsCluster::BlackList ( XrdOucTList * blP )

virtual

◆ Broadcast() [1/3]

SMask_t XrdCmsCluster::Broadcast	(	SMask_t	smask,
		XrdCms::CmsRRHdr &	Hdr,
		char *	Data,
		int	Dlen = `0`
	)

◆ Broadcast() [2/3]

SMask_t XrdCmsCluster::Broadcast	(	SMask_t	smask,
		XrdCms::CmsRRHdr &	Hdr,
		void *	Data,
		int	Dlen
	)

◆ Broadcast() [3/3]

SMask_t XrdCmsCluster::Broadcast	(	SMask_t	,
		const struct iovec *	,
		int	,
		int	tot = `0`
	)

◆ Broadsend()

int XrdCmsCluster::Broadsend	(	SMask_t	smask,
		XrdCms::CmsRRHdr &	Hdr,
		void *	Data,
		int	Dlen
	)

◆ calcDelay()

XrdCmsNode* XrdCmsCluster::calcDelay ( XrdCmsSelector & selR )

private

◆ Drop()

int XrdCmsCluster::Drop	(	int	sent,
		int	sinst,
		XrdCmsDrop *	djp = `0`
	)

private

◆ getMask() [1/2]

SMask_t XrdCmsCluster::getMask ( const char * Cid )

◆ getMask() [2/2]

SMask_t XrdCmsCluster::getMask ( const XrdNetAddr * addr )

◆ List()

XrdCmsSelected* XrdCmsCluster::List	(	SMask_t	mask,
		CmsLSOpts	opts,
		bool &	oksel
	)

◆ Locate()

int XrdCmsCluster::Locate ( XrdCmsSelect & Sel )

◆ maxBits()

bool XrdCmsCluster::maxBits	(	SMask_t	mVec,
		int	mbits
	)

private

◆ MonPerf()

void* XrdCmsCluster::MonPerf ( )

◆ MonRefs()

void* XrdCmsCluster::MonRefs ( )

◆ Multiple()

int XrdCmsCluster::Multiple ( SMask_t mVec )

private

◆ Record()

void XrdCmsCluster::Record	(	char *	path,
		const char *	reason,
		bool	force = `false`
	)

private

◆ Refs()

long long XrdCmsCluster::Refs ( )

inline

References SelRcnt, SelRtot, SelWcnt, and SelWtot.

◆ Remove() [1/2]

void XrdCmsCluster::Remove	(	const char *	reason,
		XrdCmsNode *	theNode,
		int	immed = `0`
	)

◆ Remove() [2/2]

void XrdCmsCluster::Remove ( XrdCmsNode * theNode )

◆ ResetRef()

void XrdCmsCluster::ResetRef	(	SMask_t	smask,
		bool	isLocked = `false`
	)

◆ SelbyCost()

XrdCmsNode* XrdCmsCluster::SelbyCost	(	SMask_t	,
		XrdCmsSelector &	selR
	)

private

◆ SelbyLoad()

XrdCmsNode* XrdCmsCluster::SelbyLoad	(	SMask_t	,
		XrdCmsSelector &	selR
	)

private

◆ SelbyRef()

XrdCmsNode* XrdCmsCluster::SelbyRef	(	SMask_t	,
		XrdCmsSelector &	selR
	)

private

◆ SelDFS()

int XrdCmsCluster::SelDFS	(	XrdCmsSelect &	Sel,
		SMask_t	amask,
		SMask_t &	pmask,
		SMask_t &	smask,
		int	isRW
	)

private

◆ Select() [1/2]

int XrdCmsCluster::Select	(	SMask_t	pmask,
		int &	port,
		char *	hbuff,
		int &	hlen,
		int	isrw,
		int	isMulti,
		int	ifWant
	)

◆ Select() [2/2]

int XrdCmsCluster::Select ( XrdCmsSelect & Sel )

◆ SelFail()

int XrdCmsCluster::SelFail	(	XrdCmsSelect &	Sel,
		int	rc
	)

private

◆ SelNode()

int XrdCmsCluster::SelNode	(	XrdCmsSelect &	Sel,
		SMask_t	pmask,
		SMask_t	amask
	)

private

◆ sendAList()

void XrdCmsCluster::sendAList ( XrdLink * lp )

private

◆ setAltMan()

void XrdCmsCluster::setAltMan	(	int	snum,
		XrdLink *	lp,
		int	port
	)

private

◆ SLock()

void XrdCmsCluster::SLock ( bool dolock )

inline

References XrdSysMutex::Lock(), STMutex, and XrdSysMutex::UnLock().

◆ Space()

void XrdCmsCluster::Space	(	XrdCms::SpaceData &	sData,
		SMask_t	smask
	)

◆ Stats()

int XrdCmsCluster::Stats	(	char *	bfr,
		int	bln
	)

◆ Statt()

int XrdCmsCluster::Statt	(	char *	bfr,
		int	bln
	)

◆ Unreachable()

int XrdCmsCluster::Unreachable	(	XrdCmsSelect &	Sel,
		bool	none
	)

private

◆ Unuseable()

int XrdCmsCluster::Unuseable ( XrdCmsSelect & Sel )

private

Friends And Related Function Documentation

◆ XrdCmsDrop

friend class XrdCmsDrop

friend

Member Data Documentation

◆ AltMans

char XrdCmsCluster::AltMans[STMax *AltSize]

private

◆ AltMend

char* XrdCmsCluster::AltMend

private

◆ AltMent

int XrdCmsCluster::AltMent

private

◆ AltSize

const int XrdCmsCluster::AltSize = 254

staticprivate

◆ EReplete

const int XrdCmsCluster::EReplete = -4

static

◆ NodeCnt

int XrdCmsCluster::NodeCnt

◆ NodeTab

XrdCmsNode* XrdCmsCluster::NodeTab[STMax]

private

◆ NotFound

const int XrdCmsCluster::NotFound = -1

static

◆ peerHost

SMask_t XrdCmsCluster::peerHost

private

◆ peerMask

SMask_t XrdCmsCluster::peerMask

private

◆ Reserved

int XrdCmsCluster::Reserved

private

◆ RetryErr

const int XrdCmsCluster::RetryErr = -3

static

◆ SelRcnt

long long XrdCmsCluster::SelRcnt

private

Referenced by Refs().

◆ SelRtot

long long XrdCmsCluster::SelRtot

private

Referenced by Refs().

◆ SelTcnt

long long XrdCmsCluster::SelTcnt

private

◆ SelWcnt

long long XrdCmsCluster::SelWcnt

private

Referenced by Refs().

◆ SelWtot

long long XrdCmsCluster::SelWtot

private

Referenced by Refs().

◆ STHi

int XrdCmsCluster::STHi

private

◆ STMutex

XrdSysMutex XrdCmsCluster::STMutex

private

Referenced by SLock().

◆ Wait4CBk

const int XrdCmsCluster::Wait4CBk = -2

static

◆ XXMutex

XrdSysMutex XrdCmsCluster::XXMutex

private

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

XrdCmsCluster.hh

Public Types

Public Member Functions

Public Attributes

Static Public Attributes

Private Types

Private Member Functions

Private Attributes

Static Private Attributes

Friends

Member Enumeration Documentation

◆ anonymous enum

◆ CmsLSOpts

Constructor & Destructor Documentation

◆ XrdCmsCluster()

◆ ~XrdCmsCluster()

Member Function Documentation

◆ Add()

◆ AddAlt()

◆ BlackList()

◆ Broadcast() [1/3]

◆ Broadcast() [2/3]

◆ Broadcast() [3/3]

◆ Broadsend()

◆ calcDelay()

◆ Drop()

◆ getMask() [1/2]

◆ getMask() [2/2]

◆ List()

◆ Locate()

◆ maxBits()

◆ MonPerf()

◆ MonRefs()

◆ Multiple()

◆ Record()

◆ Refs()

◆ Remove() [1/2]

◆ Remove() [2/2]

◆ ResetRef()

◆ SelbyCost()

◆ SelbyLoad()

◆ SelbyRef()

◆ SelDFS()

◆ Select() [1/2]

◆ Select() [2/2]

◆ SelFail()

◆ SelNode()

◆ sendAList()

◆ setAltMan()

◆ SLock()

◆ Space()

◆ Stats()

◆ Statt()

◆ Unreachable()

◆ Unuseable()

Friends And Related Function Documentation

◆ XrdCmsDrop

Member Data Documentation

◆ AltMans

◆ AltMend

◆ AltMent

◆ AltSize

◆ EReplete

◆ NodeCnt

◆ NodeTab

◆ NotFound

◆ peerHost

◆ peerMask

◆ Reserved

◆ RetryErr

◆ SelRcnt

◆ SelRtot

◆ SelTcnt

◆ SelWcnt

◆ SelWtot

◆ STHi

◆ STMutex

◆ Wait4CBk

◆ XXMutex