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	Init (XrdSysError *eP, XrdOucTrace *tP, XrdScheduler *sP)
static void	Init (XrdInet *iP)
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 XrdSysError *	XrdLog = 0
static XrdOucTrace *	XrdTrace = 0
static XrdScheduler *	XrdSched = 0
static XrdInet *	XrdNetTCP = 0
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 LTMutex, XrdSysMutex::Lock(), LinkBat, XrdNetPeer::fd, XrdSysMutex::UnLock(), XrdLog, XrdSysError::Emsg(), LinkTab, LinkAlloc, Reset(), XRDLINK_USED, LTLast, Instance, InetAddr, XrdNetPeer::InetAddr, XrdNetPeer::InetName, strlcpy(), Lname, XrdSysDNS::getHostName(), HostName, HNlen, XrdNetTCP, XrdNet::Trim(), ID, FD, udpbuff, XrdNetPeer::InetBuff, XrdJob::Comment, LockReads, XRDLINK_RDLOCK, KeepFD, XRDLINK_NOCLOSE, AtomicBeg, statsMutex, AtomicInc, LinkCountTot, AtomicISM, LinkCount, LinkCountMax, and AtomicEnd.

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

void XrdLink::Bind

(

)

References tBound.

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

void XrdLink::Bind

(

pthread_t

tid

)

References TID, and tBound.

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

References Lname, ID, HNlen, and HostName.

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

int XrdLink::Close

(

int

defer = 0

)

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

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

void XrdLink::DoIt

(

)

[virtual]

Implements XrdJob.

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

static XrdLink* XrdLink::fd2link

(

int

fd

)

[inline, static]

References LTLast, LinkBat, and LinkTab.

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

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

References LTLast, LinkBat, LinkTab, and Instance.

int XrdLink::FDnum

(

)

[inline]

References FD.

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

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

References LTMutex, XrdSysMutex::Lock(), LinkTab, setRef(), LTLast, LinkBat, HostName, XrdLinkMatch::Match(), ID, Lname, HNlen, Instance, 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, stallCnt, stallCntTot, tardyCnt, tardyCntTot, and InUse.

Referenced by XrdXrootdAdmin::do_Lsd().

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

References LTMutex, XrdSysMutex::Lock(), LTLast, LinkTab, LinkBat, HostName, XrdLinkMatch::Match(), ID, Lname, HNlen, Client(), 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 opMutex, XrdSysMutex::Lock(), and XrdSysMutex::UnLock().

const char* XrdLink::Host

(

sockaddr *

ipaddr = 0

)

[inline]

References InetAddr, and HostName.

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

static void XrdLink::Init	(	XrdSysError *	eP,
		XrdOucTrace *	tP,
		XrdScheduler *	sP
	)		[inline, static]

References XrdLog, XrdTrace, and XrdSched.

Referenced by XrdConfig::Setup().

static void XrdLink::Init

(

XrdInet *

iP

)

[inline, static]

References XrdNetTCP.

unsigned int XrdLink::Inst

(

)

[inline]

References Instance.

Referenced by XrdXrootdAioReq::Alloc(), XrdXrootdJob2Do::addClient(), 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(), XrdXrootdJob2Do::verClient(), and XrdXrootdResponse::Send().

const char* XrdLink::Name

(

sockaddr *

ipaddr = 0

)

[inline]

References InetAddr, and Lname.

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

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

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

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

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

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

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

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

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

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

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

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

void XrdLink::Reset

(

)

[private]

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

Referenced by XrdLink(), and Alloc().

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

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

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

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

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

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

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

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

References ssize_t, write(), and FD.

Referenced by Send().

void XrdLink::Serialize

(

)

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

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

int XrdLink::setEtext

(

const char *

text

)

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

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

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

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

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

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

References waitKill, and killWait.

Referenced by XrdConfig::xtmo().

XrdProtocol * XrdLink::setProtocol

(

XrdProtocol *

pp

)

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

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

void XrdLink::setRef

(

int

cnt

)

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

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

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

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

Referenced by XrdConfig::Setup().

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

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

void XrdLink::syncStats

(

int *

ctime = 0

)

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

Referenced by Close(), and Stats().

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

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

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 Reset(), Recv(), RecvAll(), syncStats(), and getIOStats().

long long XrdLink::BytesInTot [private]

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

long long XrdLink::BytesOut [private]

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

long long XrdLink::BytesOutTot [private]

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

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 XrdLink(), Reset(), Close(), setEtext(), isFlawed(), and XrdPoll::Finish().

int XrdLink::FD [private]

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

int XrdLink::HNlen [private]

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

char* XrdLink::HostName [private]

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

char* XrdLink::ID

Referenced by XrdCmsCluster::Add(), XrdCmsNode::setName(), XrdCmsProtocol::Recycle(), Reset(), Alloc(), Client(), Close(), DoIt(), Find(), getName(), Peek(), Recv(), RecvAll(), Send(), setID(), setRef(), Terminate(), XrdLinkScan::idleScan(), XrdPoll::Detach(), XrdPollDev::Disable(), XrdPollDev::Enable(), XrdPollDev::Exclude(), XrdPollDev::Start(), XrdPollE::Disable(), XrdPollE::Enable(), XrdPollE::Exclude(), XrdPollE::Include(), XrdPollE::remFD(), XrdPollE::Start(), XrdPollPoll::Include(), XrdPollPoll::Disable(), XrdPollPoll::Enable(), XrdPollPoll::Exclude(), XrdPollPoll::Start(), XrdPollPoll::dqLink(), XrdPollPoll::LogEvent(), XrdPollPoll::Recover(), XrdProtLoad::Recycle(), XrdXrootdAdmin::sendResp(), XrdXrootdAio::Alloc(), XrdXrootdAioReq::endWrite(), XrdXrootdAioReq::Scuttle(), XrdXrootdJob2Do::lstClient(), XrdXrootdJob2Do::sendResult(), XrdXrootdProtocol::Recycle(), XrdXrootdProtocol::do_Auth(), XrdXrootdProtocol::do_Chmod(), XrdXrootdProtocol::do_CKsum(), 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(), XrdXrootdProtocol::MonAuth(), and XrdXrootdProtocol::aio_Error().

struct sockaddr XrdLink::InetAddr [private]

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

char XrdLink::inQ [private]

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

unsigned int XrdLink::Instance [private]

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

int XrdLink::InUse [private]

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

XrdSysSemaphore XrdLink::IOSemaphore [private]

Referenced by Serialize(), and setRef().

char XrdLink::isEnabled [private]

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

char XrdLink::isIdle [private]

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

char XrdLink::KeepFD [private]

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

char XrdLink::KillCnt [private]

Referenced by Reset(), and Terminate().

XrdSysCondVar* XrdLink::KillcvP [private]

Referenced by Reset(), Close(), 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(), Find(), getName(), Setup(), Stats(), XrdLinkScan::idleScan(), and fd2link().

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(), Find(), getName(), Setup(), Stats(), XrdLinkScan::idleScan(), and fd2link().

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

Referenced by Stats(), and syncStats().

char XrdLink::Lname[232] [private]

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

char XrdLink::LockReads [private]

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

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

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

XrdSysMutex XrdLink::LTMutex [static, private]

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

XrdLink* XrdLink::Next [private]

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

XrdSysMutex XrdLink::opMutex [private]

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

struct pollfd* XrdLink::PollEnt [private]

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

XrdPoll* XrdLink::Poller [private]

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

XrdProtocol* XrdLink::ProtoAlt [private]

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

XrdProtocol* XrdLink::Protocol [private]

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

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 XrdConfig::Setup(), Send(), and XrdXrootdProtocol::do_Open().

int XrdLink::stallCnt [private]

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

int XrdLink::stallCntTot [private]

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

XrdSysMutex XrdLink::statsMutex [static, private]

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

int XrdLink::tardyCnt [private]

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

int XrdLink::tardyCntTot [private]

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

char XrdLink::tBound [private]

Referenced by Reset(), and Bind().

pthread_t XrdLink::TID [private]

Referenced by Bind().

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

XrdNetBuffer* XrdLink::udpbuff [private]

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

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().

XrdSysError * XrdLink::XrdLog = 0 [static, private]

Referenced by Alloc(), Close(), DoIt(), Peek(), Recv(), RecvAll(), Send(), Setup(), setRef(), and Init().

XrdInet * XrdLink::XrdNetTCP = 0 [static, private]

Referenced by Alloc(), and Init().

XrdScheduler * XrdLink::XrdSched = 0 [static, private]

Referenced by DoIt(), Setup(), and Init().

XrdOucTrace * XrdLink::XrdTrace = 0 [static, private]

Referenced by Setup(), and Init().

---

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

• XrdLink.hh
• XrdLink.cc