XrdCmsRRQ Class Reference

#include <XrdCmsRRQ.hh>

Collaboration diagram for XrdCmsRRQ:

List of all members.

Public Member Functions
short	Add (short Snum, XrdCmsRRQInfo *ip)
void	Del (short Snum, const void *Key)
int	Init (int Tint=0, int Tdly=0)
void	Ready (int Snum, const void *Key, SMask_t mask1, SMask_t mask2)
void *	Respond ()
void *	TimeOut ()
	XrdCmsRRQ ()
	~XrdCmsRRQ ()
Private Member Functions
void	sendLocResp (XrdCmsRRQSlot *lP)
void	sendResponse (XrdCmsRRQInfo *Info, int doredir, int totlen=0)
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]
};
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, XrdOucDLlist< T >::Insert(), XrdCmsRRQInfo::isLU, isWaiting, XrdCmsRRQInfo::Key, XrdCmsRRQSlot::Link, XrdCmsRRQSlot::LkUp, XrdSysMutex::Lock(), myClock, myMutex, XrdSysSemaphore::Post(), XrdOucDLlist< T >::Prev(), XrdOucDLlist< T >::Singleton(), Slot, XrdCmsRRQSlot::slotNum, XrdSysMutex::UnLock(), and waitQ.

Referenced by XrdOlbCache::Add2Q(), and XrdCmsCache::Add2Q().

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

References Ready().

Referenced by XrdCmsCache::Recycle(), and XrdOlbCInfo::~XrdOlbCInfo().

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

References data_iov, databuff, XrdCms::CmsRRHdr::datalen, dataResp, XrdCms::CmsResponse::Hdr, hostbuff, iovec::iov_base, iovec::iov_len, XrdCms::CmsRRHdr::modifier, redr_iov, redrResp, XrdCms::CmsRRHdr::rrCode, XrdSysThread::Run(), Say, XrdCms::CmsRRHdr::streamid, Tdelay, Tslice, XrdCms::CmsResponse::Val, waitResp, XrdCmsRRQ_StartRespond(), and XrdCmsRRQ_StartTimeOut().

Referenced by XrdOlbConfig::setupManager(), and XrdCmsConfig::setupManager().

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

References XrdCmsRRQSlot::Arg1, XrdCmsRRQSlot::Arg2, XrdCmsRRQSlot::Expire, XrdCmsRRQSlot::Info, XrdOucDLlist< T >::Insert(), isReady, XrdCmsRRQInfo::Key, XrdCmsRRQSlot::Link, XrdSysMutex::Lock(), myMutex, XrdSysSemaphore::Post(), XrdOucDLlist< T >::Prev(), readyQ, XrdOucDLlist< T >::Remove(), XrdOucDLlist< T >::Singleton(), Slot, and XrdSysMutex::UnLock().

Referenced by Del(), XrdOlbCache::Dispatch(), and XrdCmsCache::Dispatch().

void * XrdCmsRRQ::Respond

(

)

References XrdCmsRRQSlot::Arg1, XrdCmsRRQSlot::Arg2, XrdCms::Cluster, XrdCmsRRQSlot::Cont, XrdCms::CmsRRHdr::datalen, XrdCmsRRQSlot::Expire, XrdCms::CmsResponse::Hdr, hostbuff, XrdCmsRRQSlot::Info, iovec::iov_len, XrdCmsRRQInfo::isLU, isReady, XrdCmsRRQInfo::isRW, XrdOucDLlist< T >::Item(), XrdCmsRRQSlot::Link, XrdCmsRRQSlot::LkUp, XrdSysMutex::Lock(), myMutex, XrdOucDLlist< T >::Next(), XrdMonCtrCollector::port, readyQ, XrdCmsRRQSlot::Recycle(), redr_iov, redrResp, XrdOucDLlist< T >::Remove(), XrdCmsCluster::Select(), sendLocResp(), sendResponse(), XrdOucDLlist< T >::Singleton(), XrdSysMutex::UnLock(), XrdCms::CmsResponse::Val, and XrdSysSemaphore::Wait().

Referenced by XrdCmsRRQ_StartRespond().

void XrdCmsRRQ::sendLocResp

(

XrdCmsRRQSlot *

lP

)

[private]

References XrdCmsRRQSlot::Arg1, XrdCmsRRQSlot::Arg2, XrdCms::Cluster, XrdCmsRRQSlot::Cont, data_iov, databuff, XrdCms::CmsRRHdr::datalen, dataResp, XrdCmsNode::do_LocFmt(), XrdCmsRTable::Find(), XrdCms::CmsResponse::Hdr, XrdCmsRRQInfo::ID, XrdCmsRRQSlot::Info, iov_cnt, iovec::iov_len, XrdCmsCluster::List(), XrdCmsRTable::Lock(), XrdCmsCluster::LS_IPV6, XrdCmsRRQInfo::Rinst, XrdCmsRRQInfo::Rnum, XrdCms::RTable, XrdCmsRRQInfo::rwVec, XrdCmsNode::Send(), sendResponse(), XrdCms::CmsRRHdr::streamid, and XrdCmsRTable::UnLock().

Referenced by Respond().

void XrdCmsRRQ::sendResponse	(	XrdCmsRRQInfo *	Info,
		int	doredir,
		int	totlen = 0
	)			[private]

References XrdCmsRTable::Find(), XrdCms::CmsResponse::Hdr, XrdCmsRRQInfo::ID, iov_cnt, XrdCmsRTable::Lock(), redr_iov, redrResp, XrdCmsRRQInfo::Rinst, XrdCmsRRQInfo::Rnum, XrdCms::RTable, XrdCmsNode::Send(), XrdCms::CmsRRHdr::streamid, XrdCmsRTable::UnLock(), and waitResp.

Referenced by Respond(), and sendLocResp().

void * XrdCmsRRQ::TimeOut

(

)

References XrdCmsRRQSlot::Arg1, XrdCmsRRQSlot::Arg2, XrdCmsRRQSlot::Expire, XrdOucDLlist< T >::Insert(), isReady, isWaiting, XrdOucDLlist< T >::Item(), XrdCmsRRQSlot::Link, XrdSysMutex::Lock(), myClock, myMutex, XrdOucDLlist< T >::Next(), XrdSysSemaphore::Post(), XrdOucDLlist< T >::Prev(), readyQ, XrdOucDLlist< T >::Remove(), XrdOucDLlist< T >::Singleton(), Tslice, XrdSysMutex::UnLock(), XrdSysTimer::Wait(), XrdSysSemaphore::Wait(), and waitQ.

Referenced by XrdCmsRRQ_StartTimeOut().

---

Member Data Documentation

union { ... } [private]

struct iovec XrdCmsRRQ::data_iov[iov_cnt] [private]

Referenced by Init(), and sendLocResp().

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

Referenced by Init(), and sendLocResp().

XrdCms::CmsResponse XrdCmsRRQ::dataResp [private]

Referenced by Init(), and sendLocResp().

char XrdCmsRRQ::hostbuff[288]

Referenced by Init(), and Respond().

const int XrdCmsRRQ::iov_cnt = 2 [static, private]

Referenced by sendLocResp(), and sendResponse().

XrdSysSemaphore XrdCmsRRQ::isReady [private]

Referenced by Ready(), Respond(), and TimeOut().

XrdSysSemaphore XrdCmsRRQ::isWaiting [private]

Referenced by Add(), and TimeOut().

unsigned int XrdCmsRRQ::myClock [private]

Referenced by Add(), and TimeOut().

XrdSysMutex XrdCmsRRQ::myMutex [private]

Referenced by Add(), Ready(), Respond(), and TimeOut().

const int XrdCmsRRQ::numSlots = 1024 [static, private]

XrdOucDLlist<XrdCmsRRQSlot> XrdCmsRRQ::readyQ [private]

Referenced by Ready(), Respond(), and TimeOut().

struct iovec XrdCmsRRQ::redr_iov[iov_cnt] [private]

Referenced by Init(), Respond(), and sendResponse().

XrdCms::CmsResponse XrdCmsRRQ::redrResp [private]

Referenced by Init(), Respond(), and sendResponse().

XrdCmsRRQSlot XrdCmsRRQ::Slot[numSlots] [private]

Referenced by Add(), and Ready().

int XrdCmsRRQ::Tdelay [private]

Referenced by Init().

int XrdCmsRRQ::Tslice [private]

Referenced by Init(), and TimeOut().

XrdOucDLlist<XrdCmsRRQSlot> XrdCmsRRQ::waitQ [private]

Referenced by Add(), and TimeOut().

XrdCms::CmsResponse XrdCmsRRQ::waitResp [private]

Referenced by Init(), and sendResponse().

---

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

• XrdCmsRRQ.hh
• XrdCmsRRQ.cc