xrootd: XrdCmsRRQ Class Reference

xrootd

#include <XrdCmsRRQ.hh>

Collaboration diagram for XrdCmsRRQ:

Collaboration graph

Classes
struct	Info

Public Member Functions
short	Add (short Snum, XrdCmsRRQInfo *ip)

void	Del (short Snum, const void *Key)

int	Init (int Tint=0, int Tdly=0)

int	Ready (int Snum, const void *Key, SMask_t mask1, SMask_t mask2)

void *	Respond ()

void	Statistics (Info &Data)

void *	TimeOut ()

	XrdCmsRRQ ()

	~XrdCmsRRQ ()

Private Member Functions
void	sendLocResp (XrdCmsRRQSlot *lP)

void	sendLwtResp (XrdCmsRRQSlot *rP)

void	sendRedResp (XrdCmsRRQSlot *rP)

Private Attributes
XrdSysMutex	myMutex

XrdSysSemaphore	isWaiting

XrdSysSemaphore	isReady

XrdCmsRRQSlot	Slot [numSlots]

XrdOucDLlist< XrdCmsRRQSlot >	waitQ

XrdOucDLlist< XrdCmsRRQSlot >	readyQ

struct iovec	data_iov [iov_cnt]

struct iovec	redr_iov [iov_cnt]

XrdCms::CmsResponse	dataResp

XrdCms::CmsResponse	redrResp

XrdCms::CmsResponse	waitResp

union {
char hostbuff [288]

char databuff [XrdCms::CmsLocateRequest::RILen *STMax]

};

Info	Stats

int	luFast

int	luSlow

int	rdFast

int	rdSlow

int	Tslice

int	Tdelay

unsigned int	myClock

Static Private Attributes
static const int	numSlots = 1024

static const int	iov_cnt = 2

Constructor & Destructor Documentation

XrdCmsRRQ::XrdCmsRRQ ( )

inline

XrdCmsRRQ::~XrdCmsRRQ ( )

inline

Member Function Documentation

short XrdCmsRRQ::Add	(	short	Snum,
		XrdCmsRRQInfo *	ip
	)

References XrdCmsRRQSlot::Alloc(), XrdCmsRRQSlot::Cont, XrdCmsRRQSlot::Expire, XrdCmsRRQInfo::isLU, XrdCmsRRQInfo::Key, XrdCmsRRQSlot::Link, XrdCmsRRQSlot::LkUp, and XrdCmsRRQSlot::slotNum.

Referenced by XrdCmsCache::Add2Q().

void XrdCmsRRQ::Del	(	short	Snum,
		const void *	Key
	)

Referenced by XrdCmsCache::Recycle().

int XrdCmsRRQ::Init	(	int	Tint = `0`,
		int	Tdly = `0`
	)

References XrdSysError::Emsg(), XrdCms::kYR_data, XrdCms::kYR_redirect, XrdCms::kYR_wait, XrdSysThread::Run(), XrdCms::Say, XrdCmsRRQ_StartRespond(), and XrdCmsRRQ_StartTimeOut().

Referenced by XrdCmsConfig::setupManager().

int XrdCmsRRQ::Ready	(	int	Snum,
		const void *	Key,
		SMask_t	mask1,
		SMask_t	mask2
	)

References XrdCmsRRQInfo::actR, XrdCmsRRQSlot::Arg1, XrdCmsRRQSlot::Arg2, XrdCmsRRQSlot::Expire, XrdCmsRRQSlot::Info, XrdCmsRRQInfo::Key, XrdCmsRRQSlot::Link, XrdCmsRRQInfo::minR, and XrdOucDLlist< T >::Remove().

Referenced by XrdCmsCache::Dispatch().

void * XrdCmsRRQ::Respond ( )

References XrdCmsRRQSlot::Arg1, XrdCmsRRQSlot::Arg2, XrdCmsRRQSlot::Cont, XrdCmsRRQSlot::Expire, XrdCmsRRQSlot::Info, XrdCmsRRQInfo::isLU, XrdCmsRRQSlot::Link, XrdCmsRRQSlot::LkUp, XrdCmsRRQSlot::Recycle(), and XrdOucDLlist< T >::Remove().

Referenced by XrdCmsRRQ_StartRespond().

void XrdCmsRRQ::sendLocResp ( XrdCmsRRQSlot * lP )

private

References XrdCmsRRQSlot::Arg1, XrdCmsRRQSlot::Arg2, XrdCms::Cluster, XrdCmsNode::do_LocFmt(), XrdCmsRTable::Find(), XrdCmsRRQInfo::ID, XrdCmsRRQSlot::Info, XrdCmsCluster::List(), XrdCmsRRQSlot::LkUp, XrdCmsRTable::Lock(), XrdCmsCluster::LS_IPO, XrdCmsRRQInfo::Rinst, XrdCmsRRQInfo::Rnum, XrdCms::RTable, XrdCmsRRQInfo::rwVec, XrdCmsNode::Send(), and XrdCmsRTable::UnLock().

void XrdCmsRRQ::sendLwtResp ( XrdCmsRRQSlot * rP )

private

References XrdCmsRTable::Find(), XrdCmsRRQInfo::ID, XrdCmsRRQSlot::Info, XrdCmsRRQSlot::LkUp, XrdCmsRTable::Lock(), XrdCmsRRQInfo::Rinst, XrdCmsRRQInfo::Rnum, XrdCms::RTable, XrdCmsNode::Send(), and XrdCmsRTable::UnLock().

void XrdCmsRRQ::sendRedResp ( XrdCmsRRQSlot * rP )

private

References XrdCmsRRQInfo::actR, XrdCmsRRQSlot::Arg1, XrdCms::Cluster, XrdCmsRRQSlot::Cont, XrdCmsRTable::Find(), XrdCmsRRQInfo::ID, XrdCmsRRQSlot::Info, XrdCmsRRQInfo::isRW, XrdCmsRTable::Lock(), XrdMonCtrCollector::port, XrdCmsRRQInfo::Rinst, XrdCmsRRQInfo::Rnum, XrdCms::RTable, XrdCmsCluster::Select(), XrdCmsNode::Send(), and XrdCmsRTable::UnLock().

void XrdCmsRRQ::Statistics ( Info & Data )

inline

References XrdSysMutex::Lock(), myMutex, Stats, and XrdSysMutex::UnLock().

Referenced by XrdCmsCluster::Statt().

void * XrdCmsRRQ::TimeOut ( )

References XrdCmsRRQSlot::Expire, XrdCmsRRQSlot::Link, XrdOucDLlist< T >::Remove(), and XrdSysTimer::Wait().

Referenced by XrdCmsRRQ_StartTimeOut().

Member Data Documentation

union { ... }

struct iovec XrdCmsRRQ::data_iov[iov_cnt]

private

char XrdCmsRRQ::databuff[XrdCms::CmsLocateRequest::RILen *STMax]

XrdCms::CmsResponse XrdCmsRRQ::dataResp

private

char XrdCmsRRQ::hostbuff[288]

const int XrdCmsRRQ::iov_cnt = 2

staticprivate

XrdSysSemaphore XrdCmsRRQ::isReady

private

XrdSysSemaphore XrdCmsRRQ::isWaiting

private

int XrdCmsRRQ::luFast

private

int XrdCmsRRQ::luSlow

private

unsigned int XrdCmsRRQ::myClock

private

XrdSysMutex XrdCmsRRQ::myMutex

private

Referenced by Statistics().

const int XrdCmsRRQ::numSlots = 1024

staticprivate

int XrdCmsRRQ::rdFast

private

int XrdCmsRRQ::rdSlow

private

XrdOucDLlist<XrdCmsRRQSlot> XrdCmsRRQ::readyQ

private

struct iovec XrdCmsRRQ::redr_iov[iov_cnt]

private

XrdCms::CmsResponse XrdCmsRRQ::redrResp

private

XrdCmsRRQSlot XrdCmsRRQ::Slot[numSlots]

private

Info XrdCmsRRQ::Stats

private

Referenced by Statistics().

int XrdCmsRRQ::Tdelay

private

int XrdCmsRRQ::Tslice

private

XrdOucDLlist<XrdCmsRRQSlot> XrdCmsRRQ::waitQ

private

XrdCms::CmsResponse XrdCmsRRQ::waitResp

private

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