XrdOlbRRQ Class Reference

#include <XrdOlbRRQ.hh>

Collaboration diagram for XrdOlbRRQ:

List of all members.

Public Member Functions
short	Add (short Snum, XrdOlbRRQInfo *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 mask)
void *	Respond ()
void *	TimeOut ()
	XrdOlbRRQ ()
	~XrdOlbRRQ ()
Private Member Functions
XrdOlbRRQSlot *	sendLocInfo (XrdOlbRRQSlot *Sp)
void	sendResponse (XrdOlbRRQInfo *Info, int doredir)
Private Attributes
XrdSysMutex	myMutex
XrdSysSemaphore	isWaiting
XrdSysSemaphore	isReady
XrdOlbRRQSlot	Slot [numSlots]
XrdOucDLlist< XrdOlbRRQSlot >	waitQ
XrdOucDLlist< XrdOlbRRQSlot >	readyQ
struct iovec	redr_iov [redr_iov_cnt]
struct iovec	wait_iov [wait_iov_cnt]
char	hostbuff [288]
char	waitbuff [16]
int	Tslice
int	Tdelay
unsigned int	myClock
Static Private Attributes
static const int	numSlots = 1024
static const int	redr_iov_cnt = 3
static const int	wait_iov_cnt = 2

---

Constructor & Destructor Documentation

XrdOlbRRQ::XrdOlbRRQ

(

)

[inline]

XrdOlbRRQ::~XrdOlbRRQ

(

)

[inline]

---

Member Function Documentation

short XrdOlbRRQ::Add	(	short	Snum,
		XrdOlbRRQInfo *	ip
	)

References XrdOlbRRQSlot::Alloc(), XrdOlbRRQSlot::Cont, XrdOlbRRQSlot::Expire, XrdOucDLlist< T >::Insert(), isWaiting, XrdOlbRRQInfo::Key, XrdOlbRRQSlot::Link, XrdSysMutex::Lock(), myClock, myMutex, XrdSysSemaphore::Post(), XrdOucDLlist< T >::Prev(), XrdOucDLlist< T >::Singleton(), Slot, XrdOlbRRQSlot::slotNum, XrdSysMutex::UnLock(), and waitQ.

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

References Ready().

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

References hostbuff, iovec::iov_base, iovec::iov_len, redr_iov, XrdSysThread::Run(), Say, Tdelay, Tslice, wait_iov, waitbuff, XrdOlbRRQ_StartRespond(), and XrdOlbRRQ_StartTimeOut().

void XrdOlbRRQ::Ready	(	int	Snum,
		const void *	Key,
		SMask_t	mask
	)

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

Referenced by Del().

void * XrdOlbRRQ::Respond

(

)

References XrdOlbRRQSlot::Arg, XrdOlbRRQSlot::Cont, XrdOlbRRQSlot::Expire, hostbuff, XrdOlbRRQSlot::Info, iovec::iov_len, XrdOlbRRQInfo::isLU, isReady, XrdOlbRRQInfo::isRW, XrdOucDLlist< T >::Item(), XrdOlbRRQSlot::Link, XrdSysMutex::Lock(), XrdCms::Manager, myMutex, XrdOucDLlist< T >::Next(), readyQ, XrdOlbRRQSlot::Recycle(), redr_iov, XrdOucDLlist< T >::Remove(), sendLocInfo(), sendResponse(), XrdOucDLlist< T >::Singleton(), XrdSysMutex::UnLock(), and XrdSysSemaphore::Wait().

Referenced by XrdOlbRRQ_StartRespond().

XrdOlbRRQSlot * XrdOlbRRQ::sendLocInfo

(

XrdOlbRRQSlot *

Sp

)

[private]

References XrdOlbRRQInfo::Arg, XrdOlbRRQSlot::Arg, XrdOlbRRQSlot::Cont, XrdOlbServer::do_Locate(), XrdCmsRTable::Find(), XrdOlbRRQInfo::ID, XrdOlbRRQSlot::Info, XrdOlbRRQInfo::isLU, XrdCmsRTable::Lock(), XrdOlbRRQInfo::Rinst, XrdOlbRRQInfo::Rnum, XrdCms::RTable, sendResponse(), and XrdCmsRTable::UnLock().

Referenced by Respond().

void XrdOlbRRQ::sendResponse	(	XrdOlbRRQInfo *	Info,
		int	doredir
	)			[private]

References XrdCmsRTable::Find(), XrdOlbRRQInfo::ID, iovec::iov_base, iovec::iov_len, XrdCmsRTable::Lock(), redr_iov, redr_iov_cnt, XrdOlbRRQInfo::Rinst, XrdOlbRRQInfo::Rnum, XrdCms::RTable, XrdOlbServer::Send(), XrdCmsRTable::UnLock(), wait_iov, and wait_iov_cnt.

Referenced by Respond(), and sendLocInfo().

void * XrdOlbRRQ::TimeOut

(

)

References XrdOlbRRQSlot::Arg, XrdOlbRRQSlot::Expire, XrdOucDLlist< T >::Insert(), isReady, isWaiting, XrdOucDLlist< T >::Item(), XrdOlbRRQSlot::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 XrdOlbRRQ_StartTimeOut().

---

Member Data Documentation

char XrdOlbRRQ::hostbuff[288] [private]

Referenced by Init(), and Respond().

XrdSysSemaphore XrdOlbRRQ::isReady [private]

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

XrdSysSemaphore XrdOlbRRQ::isWaiting [private]

Referenced by Add(), and TimeOut().

unsigned int XrdOlbRRQ::myClock [private]

Referenced by Add(), and TimeOut().

XrdSysMutex XrdOlbRRQ::myMutex [private]

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

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

XrdOucDLlist<XrdOlbRRQSlot> XrdOlbRRQ::readyQ [private]

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

struct iovec XrdOlbRRQ::redr_iov[redr_iov_cnt] [private]

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

const int XrdOlbRRQ::redr_iov_cnt = 3 [static, private]

Referenced by sendResponse().

XrdOlbRRQSlot XrdOlbRRQ::Slot[numSlots] [private]

Referenced by Add(), and Ready().

int XrdOlbRRQ::Tdelay [private]

Referenced by Init().

int XrdOlbRRQ::Tslice [private]

Referenced by Init(), and TimeOut().

struct iovec XrdOlbRRQ::wait_iov[wait_iov_cnt] [private]

Referenced by Init(), and sendResponse().

const int XrdOlbRRQ::wait_iov_cnt = 2 [static, private]

Referenced by sendResponse().

char XrdOlbRRQ::waitbuff[16] [private]

Referenced by Init().

XrdOucDLlist<XrdOlbRRQSlot> XrdOlbRRQ::waitQ [private]

Referenced by Add(), and TimeOut().

---

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

• XrdOlbRRQ.hh
• XrdOlbRRQ.cc