XrdLink Class Reference

#include <XrdLink.hh>

Inheritance diagram for XrdLink:

Collaboration diagram for XrdLink:

List of all members.

Classes
struct	sfVec
Public Member Functions
void	Bind ()
void	Bind (pthread_t tid)
int	Client (char *buff, int blen)
int	Close (int defer=0)
void	DoIt ()
int	FDnum ()
int	getIOStats (long long &inbytes, long long &outbytes, int &numstall, int &numtardy)
XrdProtocol *	getProtocol ()
void	Hold (int lk)
unsigned int	Inst ()
int	isFlawed ()
int	isInstance (unsigned int inst)
const char *	Name (sockaddr *ipaddr=0)
const char *	Host (sockaddr *ipaddr=0)
int	Peek (char *buff, int blen, int timeout=-1)
int	Recv (char *buff, int blen)
int	Recv (char *buff, int blen, int timeout)
int	RecvAll (char *buff, int blen, int timeout=-1)
int	Send (const char *buff, int blen)
int	Send (const struct iovec *iov, int iocnt, int bytes=0)
int	Send (const struct sfVec *sdP, int sdn)
void	Serialize ()
int	setEtext (const char *text)
void	setID (const char *userid, int procid)
XrdProtocol *	setProtocol (XrdProtocol *pp)
void	setRef (int cnt)
void	syncStats (int *ctime=0)
int	Terminate (const XrdLink *owner, int fdnum, unsigned int inst)
time_t	timeCon ()
int	UseCnt ()
	XrdLink ()
	~XrdLink ()
Static Public Member Functions
static XrdLink *	Alloc (XrdNetPeer &Peer, int opts=0)
static XrdLink *	fd2link (int fd)
static XrdLink *	fd2link (int fd, unsigned int inst)
static XrdLink *	Find (int &curr, XrdLinkMatch *who=0)
static int	getName (int &curr, char *bname, int blen, XrdLinkMatch *who=0)
static void	setKWT (int wkSec, int kwSec)
static int	Setup (int maxfd, int idlewait)
static int	Stats (char *buff, int blen, int do_sync=0)
Public Attributes
char *	ID
Static Public Attributes
static const int	sfMax = 8
static int	sfOK = 0
Private Member Functions
void	Reset ()
int	sendData (const char *Buff, int Blen)
Private Attributes
long long	BytesIn
long long	BytesInTot
long long	BytesOut
long long	BytesOutTot
int	stallCnt
int	stallCntTot
int	tardyCnt
int	tardyCntTot
int	SfIntr
struct sockaddr	InetAddr
char	Uname [24]
char	Lname [232]
char *	HostName
int	HNlen
pthread_t	TID
XrdSysMutex	opMutex
XrdSysMutex	rdMutex
XrdSysMutex	wrMutex
XrdSysSemaphore	IOSemaphore
XrdSysCondVar *	KillcvP
XrdLink *	Next
XrdNetBuffer *	udpbuff
XrdProtocol *	Protocol
XrdProtocol *	ProtoAlt
XrdPoll *	Poller
struct pollfd *	PollEnt
char *	Etext
int	FD
unsigned int	Instance
time_t	conTime
int	InUse
int	doPost
char	LockReads
char	KeepFD
char	isEnabled
char	isIdle
char	inQ
char	tBound
char	KillCnt
Static Private Attributes
static XrdSysMutex	LTMutex
static XrdLink **	LinkTab
static char *	LinkBat
static unsigned int	LinkAlloc
static int	LTLast = -1
static const char *	TraceID = "Link"
static int	devNull = open("/dev/null", O_RDONLY)
static short	killWait = 3
static short	waitKill = 4
static long long	LinkBytesIn = 0
static long long	LinkBytesOut = 0
static long long	LinkConTime = 0
static long long	LinkCountTot = 0
static int	LinkCount = 0
static int	LinkCountMax = 0
static int	LinkTimeOuts = 0
static int	LinkStalls = 0
static int	LinkSfIntr = 0
static XrdSysMutex	statsMutex
static const char	KillMax = 60
static const char	KillMsk = 0x7f
static const char	KillXwt = 0x80
Friends
class	XrdLinkScan
class	XrdPoll
class	XrdPollPoll
class	XrdPollDev
class	XrdPollE

---

Constructor & Destructor Documentation

XrdLink::XrdLink

(

)

References Etext, HostName, and Reset().

Referenced by Setup().

XrdLink::~XrdLink

(

)

[inline]

---

Member Function Documentation

XrdLink * XrdLink::Alloc	(	XrdNetPeer &	Peer,
		int	opts = 0
	)		[static]

References AtomicBeg, AtomicEnd, AtomicInc, AtomicISM, XrdJob::Comment, XrdSysError::Emsg(), FD, XrdNetPeer::fd, XrdNetDNS::getHostName(), HNlen, HostName, ID, XrdNetPeer::InetAddr, InetAddr, XrdNetPeer::InetBuff, XrdNetPeer::InetName, Instance, KeepFD, LinkAlloc, LinkBat, LinkCount, LinkCountMax, LinkCountTot, LinkTab, Lname, XrdSysMutex::Lock(), LockReads, LTLast, LTMutex, Reset(), statsMutex, strlcpy(), XrdNet::Trim(), udpbuff, XrdSysMutex::UnLock(), XRDLINK_NOCLOSE, XRDLINK_RDLOCK, and XRDLINK_USED.

Referenced by XrdInet::Accept(), and XrdInet::Connect().

void XrdLink::Bind

(

)

References XrdSysThread::ID(), ID, XrdSysThread::Same(), XrdSysThread::Signal(), tBound, and TID.

Referenced by Close(), and XrdCmsClientMan::Hookup().

void XrdLink::Bind

(

pthread_t

tid

)

References tBound, and TID.

int XrdLink::Client	(	char *	buff,
		int	blen
	)

References HNlen, HostName, ID, and Lname.

Referenced by XrdXrootdAdmin::do_Lsd(), and getName().

int XrdLink::Close

(

int

defer = 0

)

References Bind(), close, DEBUG, XrdPoll::Detach(), devNull, XrdSysError::Emsg(), Etext, FD, ID, Instance, InUse, KeepFD, KillcvP, LinkBat, XrdSysMutex::Lock(), LTLast, LTMutex, opMutex, Poller, ProtoAlt, Protocol, XrdNetBuffer::Recycle(), XrdProtocol::Recycle(), Serialize(), XrdSysCondVar::Signal(), syncStats(), TRACEI, udpbuff, XrdSysCondVar::UnLock(), XrdSysMutex::UnLock(), and XRDLINK_FREE.

Referenced by XrdXrootdProtocol::Cleanup(), DoIt(), XrdCmsClientMan::Hookup(), XrdCmsClientMan::Send(), XrdCmsSupervisor::Start(), XrdCmsClientMan::Start(), XrdCmsClientMan::whatsUp(), and XrdCmsClientMan::~XrdCmsClientMan().

void XrdLink::DoIt

(

)

[virtual]

Implements XrdJob.

References XrdScheduler::canStick(), Close(), EINPROGRESS, XrdSysError::Emsg(), XrdPoll::Enable(), ID, Poller, XrdProtocol::Process(), and Protocol.

static XrdLink* XrdLink::fd2link

(

int

fd

)

[inline, static]

References LinkBat, LinkTab, and LTLast.

Referenced by XrdXrootdProtocol::do_Bind(), XrdPollPoll::doRequests(), XrdPollDev::doRequests(), XrdPollPoll::LogEvent(), XrdPollPoll::Recover(), XrdXrootdResponse::Send(), XrdPollDev::Start(), and Terminate().

static XrdLink* XrdLink::fd2link	(	int	fd,
		unsigned int	inst
	)		[inline, static]

References Instance, LinkBat, LinkTab, and LTLast.

int XrdLink::FDnum

(

)

[inline]

References FD.

Referenced by XrdPollE::Disable(), XrdXrootdProtocol::do_Bind(), XrdXrootdProtocol::do_Login(), XrdXrootdProtocol::do_Prepare(), XrdPollE::Enable(), XrdPollE::Include(), XrdRootdProtocol::Match(), XrdPollE::remFD(), XrdXrootdJob2Do::sendResult(), and XrdPollE::Start().

XrdLink * XrdLink::Find	(	int &	curr,
		XrdLinkMatch *	who = 0
	)		[static]

References HNlen, HostName, ID, Instance, LinkBat, LinkTab, Lname, XrdSysMutex::Lock(), LTLast, LTMutex, XrdLinkMatch::Match(), setRef(), and XrdSysMutex::UnLock().

Referenced by XrdXrootdAdmin::do_Lsd(), and XrdXrootdAdmin::sendResp().

int XrdLink::getIOStats	(	long long &	inbytes,
		long long &	outbytes,
		int &	numstall,
		int &	numtardy
	)		[inline]

References BytesIn, BytesInTot, BytesOut, BytesOutTot, InUse, stallCnt, stallCntTot, tardyCnt, and tardyCntTot.

Referenced by XrdXrootdAdmin::do_Lsd().

int XrdLink::getName	(	int &	curr,
		char *	bname,
		int	blen,
		XrdLinkMatch *	who = 0
	)		[static]

References Client(), HNlen, HostName, ID, LinkBat, LinkTab, Lname, XrdSysMutex::Lock(), LTLast, LTMutex, XrdLinkMatch::Match(), and XrdSysMutex::UnLock().

Referenced by XrdXrootdAdmin::do_Lsc().

XrdProtocol* XrdLink::getProtocol

(

)

[inline]

References Protocol.

Referenced by XrdXrootdAdmin::do_Lsd().

void XrdLink::Hold

(

int

lk

)

[inline]

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

const char* XrdLink::Host

(

sockaddr *

ipaddr = 0

)

[inline]

References HostName, and InetAddr.

Referenced by XrdCmsLogin::Admit(), XrdCmsSecurity::Authenticate(), XrdXrootdProtocol::do_Auth(), XrdXrootdProtocol::do_Bind(), XrdXrootdProtocol::do_Login(), XrdCmsSecurity::Identify(), XrdCmsNode::isNode(), XrdXrootdProtocol::Match(), and XrdCmsNode::setName().

unsigned int XrdLink::Inst

(

)

[inline]

References Instance.

Referenced by XrdXrootdJob2Do::addClient(), XrdXrootdAioReq::Alloc(), XrdXrootdJob2Do::delClient(), and XrdXrootdProtocol::do_Login().

int XrdLink::isFlawed

(

)

[inline]

References Etext.

Referenced by XrdProtLoad::Process().

int XrdLink::isInstance

(

unsigned int

inst

)

[inline]

References FD, and Instance.

Referenced by XrdXrootdAioReq::endRead(), XrdXrootdAioReq::endWrite(), XrdXrootdJob2Do::lstClient(), XrdXrootdResponse::Send(), and XrdXrootdJob2Do::verClient().

const char* XrdLink::Name

(

sockaddr *

ipaddr = 0

)

[inline]

References InetAddr, and Lname.

Referenced by XrdCmsManager::Add(), XrdCmsCluster::Add(), XrdCmsJob::Alloc(), XrdCmsSecurity::Authenticate(), XrdXrootdProtocol::do_Auth(), XrdCmsLogin::Emsg(), XrdRootdProtocol::Match(), XrdCmsClientMan::Receive(), and XrdCmsNode::setName().

int XrdLink::Peek	(	char *	buff,
		int	blen,
		int	timeout = -1
	)

References XrdSysError::Emsg(), FD, ID, isIdle, XrdSysMutexHelper::Lock(), LockReads, poll(), XrdPoll::Poll2Text(), POLLIN, POLLRDNORM, rdMutex, pollfd::revents, and ssize_t.

Referenced by XrdXrootdProtocol::Match(), XrdRootdProtocol::Match(), and XrdCmsProtocol::Match().

int XrdLink::Recv	(	char *	buff,
		int	blen
	)

References AtomicAdd, BytesIn, XrdSysError::Emsg(), FD, ID, isIdle, XrdSysMutex::Lock(), LockReads, rdMutex, read(), ssize_t, and XrdSysMutex::UnLock().

Referenced by XrdCmsTalk::Attend(), XrdXrootdProtocol::do_WriteNone(), XrdXrootdProtocol::getData(), and XrdXrootdProtocol::Match().

int XrdLink::Recv	(	char *	buff,
		int	blen,
		int	timeout
	)

References AtomicAdd, BytesIn, DEBUG, XrdSysError::Emsg(), FD, ID, isIdle, XrdSysMutexHelper::Lock(), LockReads, poll(), XrdPoll::Poll2Text(), POLLIN, POLLRDNORM, rdMutex, pollfd::revents, ssize_t, stallCnt, tardyCnt, and TRACEI.

int XrdLink::RecvAll	(	char *	buff,
		int	blen,
		int	timeout = -1
	)

References AtomicAdd, BytesIn, DEBUG, XrdSysError::Emsg(), ETIMEDOUT, FD, ID, isIdle, XrdSysMutex::Lock(), LockReads, poll(), XrdPoll::Poll2Text(), POLLIN, POLLRDNORM, rdMutex, pollfd::revents, ssize_t, TRACEI, and XrdSysMutex::UnLock().

Referenced by XrdCmsLogin::Login(), and XrdCmsClientMan::Receive().

void XrdLink::Reset

(

)

[private]

References BytesIn, BytesInTot, BytesOut, BytesOutTot, XrdJob::Comment, conTime, doPost, Etext, FD, HostName, ID, inQ, Instance, InUse, isEnabled, isIdle, KeepFD, KillCnt, KillcvP, Lname, LockReads, Next, PollEnt, Poller, ProtoAlt, Protocol, stallCnt, stallCntTot, tardyCnt, tardyCntTot, tBound, udpbuff, and Uname.

Referenced by Alloc(), and XrdLink().

int XrdLink::Send	(	const char *	buff,
		int	blen
	)

References AtomicAdd, BytesOut, XrdSysError::Emsg(), FD, ID, isIdle, XrdSysMutex::Lock(), ssize_t, XrdSysMutex::UnLock(), write(), and wrMutex.

Referenced by XrdCmsClientMan::chkStatus(), XrdCmsTalk::Complain(), XrdXrootdProtocol::Match(), XrdXrootdResponse::Push(), XrdCmsNode::Report_Usage(), XrdCmsTalk::Request(), XrdCmsTalk::Respond(), XrdXrootdResponse::Send(), XrdCmsNode::Send(), XrdCmsClientMan::Send(), XrdCmsCluster::sendAList(), XrdCmsLogin::sendData(), XrdXrootdAdmin::sendResp(), and XrdCmsState::sendState().

int XrdLink::Send	(	const struct iovec *	iov,
		int	iocnt,
		int	bytes = 0
	)

References AtomicAdd, BytesOut, XrdSysError::Emsg(), FD, ID, iovec::iov_base, iovec::iov_len, isIdle, XrdSysMutex::Lock(), ssize_t, XrdSysMutex::UnLock(), write(), writev, and wrMutex.

int XrdLink::Send	(	const struct sfVec *	sdP,
		int	sdn
	)

References AtomicAdd, XrdLink::sfVec::buffer, BytesOut, XrdSysError::Emsg(), FD, XrdLink::sfVec::fdnum, ID, isIdle, XrdSysMutex::Lock(), XrdLink::sfVec::offset, sendData(), XrdLink::sfVec::sendsz, SfIntr, sfMax, sfOK, ssize_t, XrdSysMutex::UnLock(), and wrMutex.

int XrdLink::sendData	(	const char *	Buff,
		int	Blen
	)		[private]

References FD, ssize_t, and write().

Referenced by Send().

void XrdLink::Serialize

(

)

References DEBUG, doPost, InUse, IOSemaphore, XrdSysMutex::Lock(), opMutex, TRACEI, XrdSysMutex::UnLock(), and XrdSysSemaphore::Wait().

Referenced by Close(), XrdXrootdProtocol::do_Close(), XrdXrootdProtocol::do_Open(), XrdCmsProtocol::Process(), and Terminate().

int XrdLink::setEtext

(

const char *

text

)

References Etext, XrdSysMutex::Lock(), opMutex, and XrdSysMutex::UnLock().

Referenced by XrdXrootdProtocol::do_Write(), XrdXrootdProtocol::do_WriteNone(), XrdXrootdProtocol::getData(), XrdXrootdProtocol::Match(), XrdRootdProtocol::Match(), XrdCmsProtocol::Match(), XrdXrootdProtocol::Process(), XrdProtLoad::Process(), XrdCmsProtocol::Process(), XrdXrootdProtocol::Process2(), XrdXrootdResponse::Push(), and XrdXrootdResponse::Send().

void XrdLink::setID	(	const char *	userid,
		int	procid
	)

References XrdJob::Comment, FD, ID, snprintf, and Uname.

Referenced by XrdCmsManager::Add(), XrdCmsSecurity::Authenticate(), XrdXrootdProtocol::do_Bind(), and XrdXrootdProtocol::do_Login().

void XrdLink::setKWT	(	int	wkSec,
		int	kwSec
	)		[static]

References killWait, and waitKill.

Referenced by XrdConfig::xtmo().

XrdProtocol * XrdLink::setProtocol

(

XrdProtocol *

pp

)

References XrdSysMutex::Lock(), opMutex, Protocol, and XrdSysMutex::UnLock().

Referenced by mainAccept(), mainAdmin(), XrdProtLoad::Process(), and XrdCmsSupervisor::Start().

void XrdLink::setRef

(

int

cnt

)

References DEBUG, doPost, XrdSysError::Emsg(), ID, InUse, IOSemaphore, XrdSysMutex::Lock(), opMutex, XrdSysSemaphore::Post(), TRACEI, and XrdSysMutex::UnLock().

Referenced by XrdXrootdAioReq::Alloc(), XrdCmsJob::Alloc(), XrdXrootdAdmin::do_Lsd(), XrdXrootdProtocol::do_Offload(), XrdXrootdProtocol::do_OffloadIO(), Find(), XrdXrootdProtocol::operator=(), XrdXrootdProtocol::Recycle(), XrdXrootdAioReq::Recycle(), and XrdXrootdResponse::Send().

int XrdLink::Setup	(	int	maxfd,
		int	idlewait
	)		[static]

References DEBUG, devNull, XrdSysError::Emsg(), F_SETFD, fcntl(), FD_CLOEXEC, LinkAlloc, LinkBat, LinkTab, XrdScheduler::Schedule(), TRACE, XrdLink(), XRDLINK_FREE, and XrdLinkScan.

Referenced by XrdConfig::Setup().

int XrdLink::Stats	(	char *	buff,
		int	blen,
		int	do_sync = 0
	)		[static]

References AtomicBeg, AtomicEnd, AtomicGet, LinkBat, LinkBytesIn, LinkBytesOut, LinkConTime, LinkCount, LinkCountMax, LinkCountTot, LinkSfIntr, LinkStalls, LinkTab, LinkTimeOuts, XrdSysMutex::Lock(), LTLast, LTMutex, snprintf, statsMutex, syncStats(), XrdSysMutex::UnLock(), and XRDLINK_USED.

void XrdLink::syncStats

(

int *

ctime = 0

)

References AtomicAdd, AtomicBeg, AtomicDTZ, AtomicEnd, AtomicFAZ, BytesIn, BytesInTot, BytesOut, BytesOutTot, conTime, LinkBytesIn, LinkBytesOut, LinkConTime, LinkCount, LinkSfIntr, LinkStalls, LinkTimeOuts, XrdSysMutex::Lock(), opMutex, Protocol, rdMutex, SfIntr, stallCnt, stallCntTot, XrdProtocol::Stats(), statsMutex, tardyCnt, tardyCntTot, XrdSysMutex::UnLock(), and wrMutex.

Referenced by Close(), and Stats().

int XrdLink::Terminate	(	const XrdLink *	owner,
		int	fdnum,
		unsigned int	inst
	)

References DEBUG, XrdPoll::Disable(), FD, fd2link(), ID, index(), Instance, InUse, isEnabled, KillCnt, KillcvP, KillMax, KillMsk, killWait, KillXwt, Lname, XrdSysCondVar::Lock(), XrdSysMutex::Lock(), opMutex, Poller, Protocol, Serialize(), snprintf, TRACEI, XrdSysCondVar::UnLock(), XrdSysMutex::UnLock(), XrdSysCondVar::Wait(), and waitKill.

Referenced by XrdXrootdProtocol::do_Endsess().

time_t XrdLink::timeCon

(

)

[inline]

References conTime.

Referenced by XrdXrootdAdmin::do_Lsd().

int XrdLink::UseCnt

(

)

[inline]

References InUse.

Referenced by XrdXrootdProtocol::do_ReadAll(), and XrdXrootdProtocol::do_Write().

---

Friends And Related Function Documentation

friend class XrdLinkScan [friend]

Referenced by Setup().

friend class XrdPoll [friend]

friend class XrdPollDev [friend]

friend class XrdPollE [friend]

friend class XrdPollPoll [friend]

---

Member Data Documentation

long long XrdLink::BytesIn [private]

Referenced by getIOStats(), Recv(), RecvAll(), Reset(), and syncStats().

long long XrdLink::BytesInTot [private]

Referenced by getIOStats(), Reset(), and syncStats().

long long XrdLink::BytesOut [private]

Referenced by getIOStats(), Reset(), Send(), and syncStats().

long long XrdLink::BytesOutTot [private]

Referenced by getIOStats(), Reset(), and syncStats().

time_t XrdLink::conTime [private]

Referenced by Reset(), syncStats(), and timeCon().

int XrdLink::devNull = open("/dev/null", O_RDONLY) [static, private]

Referenced by Close(), and Setup().

int XrdLink::doPost [private]

Referenced by Reset(), Serialize(), and setRef().

char* XrdLink::Etext [private]

Referenced by Close(), XrdPoll::Finish(), isFlawed(), Reset(), setEtext(), and XrdLink().

int XrdLink::FD [private]

Referenced by Alloc(), XrdPoll::Attach(), Close(), XrdPoll::Detach(), XrdPollPoll::Disable(), XrdPollE::Disable(), XrdPollDev::Disable(), XrdPollPoll::Enable(), XrdPollDev::Enable(), XrdPollPoll::Exclude(), FDnum(), XrdPoll::Finish(), XrdPollPoll::Include(), isInstance(), Peek(), Recv(), RecvAll(), Reset(), Send(), sendData(), setID(), and Terminate().

int XrdLink::HNlen [private]

Referenced by Alloc(), Client(), Find(), and getName().

char* XrdLink::HostName [private]

Referenced by Alloc(), Client(), Find(), getName(), Host(), Reset(), and XrdLink().

char* XrdLink::ID

Referenced by XrdCmsCluster::Add(), XrdXrootdProtocol::aio_Error(), XrdXrootdAio::Alloc(), Alloc(), Bind(), Client(), Close(), XrdPoll::Detach(), XrdPollPoll::Disable(), XrdPollE::Disable(), XrdPollDev::Disable(), XrdXrootdProtocol::do_Auth(), XrdXrootdProtocol::do_Chmod(), XrdXrootdProtocol::do_Dirlist(), XrdXrootdProtocol::do_Locate(), XrdXrootdProtocol::do_Login(), XrdXrootdProtocol::do_Mkdir(), XrdXrootdProtocol::do_Mv(), XrdXrootdProtocol::do_Open(), XrdXrootdProtocol::do_Prepare(), XrdXrootdProtocol::do_Qfh(), XrdXrootdProtocol::do_Qopaque(), XrdXrootdProtocol::do_Qspace(), XrdXrootdProtocol::do_Qxattr(), XrdXrootdProtocol::do_Rm(), XrdXrootdProtocol::do_Rmdir(), XrdXrootdProtocol::do_Set(), XrdXrootdProtocol::do_Set_Mon(), XrdXrootdProtocol::do_Stat(), XrdXrootdProtocol::do_Statx(), XrdXrootdProtocol::do_Truncate(), DoIt(), XrdPollPoll::dqLink(), XrdPollPoll::Enable(), XrdPollE::Enable(), XrdPollDev::Enable(), XrdXrootdAioReq::endWrite(), XrdPollPoll::Exclude(), XrdPollE::Exclude(), XrdPollDev::Exclude(), Find(), getName(), XrdLinkScan::idleScan(), XrdPollPoll::Include(), XrdPollE::Include(), XrdPollPoll::LogEvent(), XrdXrootdJob2Do::lstClient(), Peek(), XrdPollPoll::Recover(), Recv(), RecvAll(), XrdXrootdProtocol::Recycle(), XrdProtLoad::Recycle(), XrdCmsProtocol::Recycle(), XrdPollE::remFD(), Reset(), XrdXrootdAioReq::Scuttle(), Send(), XrdXrootdAdmin::sendResp(), XrdXrootdJob2Do::sendResult(), setID(), XrdCmsNode::setName(), setRef(), XrdPollPoll::Start(), XrdPollE::Start(), XrdPollDev::Start(), and Terminate().

struct sockaddr XrdLink::InetAddr [private]

Referenced by Alloc(), Host(), and Name().

char XrdLink::inQ [private]

Referenced by XrdPollPoll::Disable(), XrdPollPoll::dqLink(), XrdPollPoll::Enable(), XrdPollPoll::Exclude(), Reset(), and XrdPollPoll::Start().

unsigned int XrdLink::Instance [private]

Referenced by Alloc(), Close(), fd2link(), Find(), Inst(), isInstance(), Reset(), and Terminate().

int XrdLink::InUse [private]

Referenced by Close(), getIOStats(), XrdLinkScan::idleScan(), Reset(), Serialize(), setRef(), Terminate(), and UseCnt().

XrdSysSemaphore XrdLink::IOSemaphore [private]

Referenced by Serialize(), and setRef().

char XrdLink::isEnabled [private]

Referenced by XrdPollPoll::Disable(), XrdPollE::Disable(), XrdPollDev::Disable(), XrdPollPoll::doRequests(), XrdPollDev::doRequests(), XrdPollPoll::Enable(), XrdPollE::Enable(), XrdPollDev::Enable(), XrdPollPoll::Exclude(), XrdPollE::Exclude(), XrdPollDev::Exclude(), XrdLinkScan::idleScan(), XrdPollPoll::Recover(), Reset(), XrdPollPoll::Start(), XrdPollE::Start(), XrdPollDev::Start(), and Terminate().

char XrdLink::isIdle [private]

Referenced by XrdLinkScan::idleScan(), Peek(), Recv(), RecvAll(), Reset(), and Send().

char XrdLink::KeepFD [private]

Referenced by Alloc(), Close(), and Reset().

char XrdLink::KillCnt [private]

Referenced by Reset(), and Terminate().

XrdSysCondVar* XrdLink::KillcvP [private]

Referenced by Close(), Reset(), and Terminate().

const char XrdLink::KillMax = 60 [static, private]

Referenced by Terminate().

const char XrdLink::KillMsk = 0x7f [static, private]

Referenced by Terminate().

short XrdLink::killWait = 3 [static, private]

Referenced by setKWT(), and Terminate().

const char XrdLink::KillXwt = 0x80 [static, private]

Referenced by Terminate().

unsigned int XrdLink::LinkAlloc [static, private]

Referenced by Alloc(), and Setup().

char * XrdLink::LinkBat [static, private]

Referenced by Alloc(), Close(), fd2link(), Find(), getName(), XrdLinkScan::idleScan(), Setup(), and Stats().

long long XrdLink::LinkBytesIn = 0 [static, private]

Referenced by Stats(), and syncStats().

long long XrdLink::LinkBytesOut = 0 [static, private]

Referenced by Stats(), and syncStats().

long long XrdLink::LinkConTime = 0 [static, private]

Referenced by Stats(), and syncStats().

int XrdLink::LinkCount = 0 [static, private]

Referenced by Alloc(), Stats(), and syncStats().

int XrdLink::LinkCountMax = 0 [static, private]

Referenced by Alloc(), and Stats().

long long XrdLink::LinkCountTot = 0 [static, private]

Referenced by Alloc(), and Stats().

int XrdLink::LinkSfIntr = 0 [static, private]

Referenced by Stats(), and syncStats().

int XrdLink::LinkStalls = 0 [static, private]

Referenced by Stats(), and syncStats().

XrdLink ** XrdLink::LinkTab [static, private]

Referenced by Alloc(), fd2link(), Find(), getName(), Setup(), and Stats().

int XrdLink::LinkTimeOuts = 0 [static, private]

Referenced by Stats(), and syncStats().

char XrdLink::Lname[232] [private]

Referenced by Alloc(), Client(), Find(), getName(), Name(), Reset(), and Terminate().

char XrdLink::LockReads [private]

Referenced by Alloc(), Peek(), Recv(), RecvAll(), and Reset().

int XrdLink::LTLast = -1 [static, private]

Referenced by Alloc(), Close(), fd2link(), Find(), getName(), XrdLinkScan::idleScan(), and Stats().

XrdSysMutex XrdLink::LTMutex [static, private]

Referenced by Alloc(), Close(), Find(), getName(), and Stats().

XrdLink* XrdLink::Next [private]

Referenced by XrdPollPoll::dqLink(), XrdPollPoll::Enable(), Reset(), XrdPollPoll::Restart(), and XrdPollPoll::Start().

XrdSysMutex XrdLink::opMutex [private]

Referenced by Close(), Hold(), XrdLinkScan::idleScan(), Serialize(), setEtext(), setProtocol(), setRef(), syncStats(), and Terminate().

struct pollfd* XrdLink::PollEnt [private]

Referenced by XrdPollPoll::Disable(), XrdPollPoll::Enable(), XrdPollPoll::Exclude(), XrdPollPoll::Include(), Reset(), XrdPollPoll::Restart(), and XrdPollPoll::Start().

XrdPoll* XrdLink::Poller [private]

Referenced by XrdPoll::Attach(), Close(), XrdPoll::Detach(), DoIt(), XrdLinkScan::idleScan(), Reset(), and Terminate().

XrdProtocol* XrdLink::ProtoAlt [private]

Referenced by Close(), XrdPoll::Finish(), and Reset().

XrdProtocol* XrdLink::Protocol [private]

Referenced by Close(), DoIt(), XrdPoll::Finish(), getProtocol(), Reset(), setProtocol(), syncStats(), and Terminate().

XrdSysMutex XrdLink::rdMutex [private]

Referenced by Peek(), Recv(), RecvAll(), and syncStats().

int XrdLink::SfIntr [private]

Referenced by Send(), and syncStats().

const int XrdLink::sfMax = 8 [static]

Referenced by Send().

int XrdLink::sfOK = 0 [static]

Referenced by XrdXrootdProtocol::do_Open(), Send(), and XrdConfig::Setup().

int XrdLink::stallCnt [private]

Referenced by getIOStats(), Recv(), Reset(), and syncStats().

int XrdLink::stallCntTot [private]

Referenced by getIOStats(), Reset(), and syncStats().

XrdSysMutex XrdLink::statsMutex [static, private]

Referenced by Alloc(), Stats(), and syncStats().

int XrdLink::tardyCnt [private]

Referenced by getIOStats(), Recv(), Reset(), and syncStats().

int XrdLink::tardyCntTot [private]

Referenced by getIOStats(), Reset(), and syncStats().

char XrdLink::tBound [private]

Referenced by Bind(), and Reset().

pthread_t XrdLink::TID [private]

Referenced by Bind().

const char * XrdLink::TraceID = "Link" [static, private]

XrdNetBuffer* XrdLink::udpbuff [private]

Referenced by Alloc(), Close(), and Reset().

char XrdLink::Uname[24] [private]

Referenced by Reset(), and setID().

short XrdLink::waitKill = 4 [static, private]

Referenced by setKWT(), and Terminate().

XrdSysMutex XrdLink::wrMutex [private]

Referenced by Send(), and syncStats().

---

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

• XrdLink.hh
• XrdLink.cc