XrdLink Class Reference

#include <XrdLink.hh>

Inheritance diagram for XrdLink:

Collaboration diagram for XrdLink:

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 Member Functions inherited from XrdJob
	XrdJob (const char *desc="")
virtual	~XrdJob ()

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
Private Attributes inherited from XrdJob
XrdJob *	NextJob
const char *	Comment

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 AtomicInc, XrdJob::Comment, XrdSysError::Emsg(), XrdNetPeer::fd, FD, XrdSysDNS::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, XRDLINK_USED, XrdLog, and XrdNetTCP.

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

void XrdLink::Bind

(

)

References tBound.

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(), XRDLINK_FREE, and XrdLog.

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(), XrdSysError::Emsg(), XrdPoll::Enable(), ID, Poller, XrdProtocol::Process(), Protocol, XrdLog, and XrdSched.

static XrdLink* XrdLink::fd2link ( int  fd )

inlinestatic

References LinkBat, LinkTab, and LTLast.

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

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

inlinestatic

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

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

inlinestatic

References XrdLog, XrdSched, and XrdTrace.

Referenced by XrdConfig::Setup().

static void XrdLink::Init ( XrdInet *  iP )

inlinestatic

References XrdNetTCP.

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, XrdPoll::Poll2Text(), rdMutex, and XrdLog.

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

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

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

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, XrdPoll::Poll2Text(), rdMutex, stallCnt, tardyCnt, TRACEI, and XrdLog.

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

References AtomicAdd, BytesIn, DEBUG, XrdSysError::Emsg(), FD, ID, isIdle, XrdSysMutex::Lock(), LockReads, XrdPoll::Poll2Text(), rdMutex, TRACEI, XrdSysMutex::UnLock(), and XrdLog.

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, SfIntr, 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(), XrdSysMutex::UnLock(), write(), wrMutex, and XrdLog.

Referenced by XrdCmsClientMan::chkStatus(), XrdCmsTalk::Complain(), XrdXrootdProtocol::Match(), XrdXrootdResponse::Push(), XrdCmsNode::Report_Usage(), XrdCmsTalk::Request(), XrdCmsTalk::Respond(), XrdXrootdResponse::Send(), XrdCmsClientMan::Send(), XrdCmsNode::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, isIdle, XrdSysMutex::Lock(), XrdSysMutex::UnLock(), write(), writev(), wrMutex, and XrdLog.

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, XrdSysMutex::UnLock(), wrMutex, and XrdLog.

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

private

References FD, 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(), XrdRootdProtocol::Match(), XrdCmsProtocol::Match(), XrdXrootdProtocol::Match(), XrdProtLoad::Process(), XrdCmsProtocol::Process(), XrdXrootdProtocol::Process(), XrdXrootdProtocol::Process2(), XrdXrootdResponse::Push(), and XrdXrootdResponse::Send().

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

References XrdJob::Comment, FD, ID, 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, XrdSysMutex::UnLock(), and XrdLog.

Referenced by XrdCmsJob::Alloc(), XrdXrootdAioReq::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(), fcntl(), LinkAlloc, LinkBat, LinkTab, XrdScheduler::Schedule(), TRACE, XrdLink(), XRDLINK_FREE, XrdLinkScan, XrdLog, XrdSched, and XrdTrace.

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, statsMutex, syncStats(), XrdSysMutex::UnLock(), and XRDLINK_USED.

Referenced by XrdStats::Stats().

void XrdLink::syncStats

(

int *

ctime = 0

)

References AtomicAdd, AtomicBeg, AtomicDec, 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, Instance, InUse, isEnabled, KillCnt, KillcvP, KillMax, KillMsk, killWait, KillXwt, Lname, XrdSysCondVar::Lock(), XrdSysMutex::Lock(), opMutex, Poller, Protocol, Serialize(), 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)

staticprivate

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(), XrdPollDev::Disable(), XrdPollE::Disable(), XrdPollPoll::Disable(), XrdPollDev::Enable(), XrdPollPoll::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(), Alloc(), XrdXrootdAio::Alloc(), Client(), Close(), XrdPoll::Detach(), XrdPollDev::Disable(), XrdPollE::Disable(), XrdPollPoll::Disable(), 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_Stat(), XrdXrootdProtocol::do_Statx(), XrdXrootdProtocol::do_Truncate(), DoIt(), XrdPollPoll::dqLink(), XrdPollDev::Enable(), XrdPollPoll::Enable(), XrdPollE::Enable(), XrdXrootdAioReq::endWrite(), XrdPollDev::Exclude(), XrdPollPoll::Exclude(), XrdPollE::Exclude(), Find(), getName(), XrdLinkScan::idleScan(), XrdPollPoll::Include(), XrdPollE::Include(), XrdPollPoll::LogEvent(), XrdXrootdJob2Do::lstClient(), Peek(), XrdPollPoll::Recover(), Recv(), RecvAll(), XrdProtLoad::Recycle(), XrdCmsProtocol::Recycle(), XrdXrootdProtocol::Recycle(), XrdPollE::remFD(), Reset(), XrdXrootdAioReq::Scuttle(), Send(), XrdXrootdAdmin::sendResp(), XrdXrootdJob2Do::sendResult(), setID(), XrdCmsNode::setName(), setRef(), XrdPollDev::Start(), XrdPollPoll::Start(), XrdPollE::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 XrdPollDev::Disable(), XrdPollE::Disable(), XrdPollPoll::Disable(), XrdPollDev::doRequests(), XrdPollPoll::doRequests(), XrdPollDev::Enable(), XrdPollE::Enable(), XrdPollPoll::Enable(), XrdPollDev::Exclude(), XrdPollE::Exclude(), XrdPollPoll::Exclude(), XrdLinkScan::idleScan(), XrdPollPoll::Recover(), Reset(), XrdPollDev::Start(), XrdPollPoll::Start(), XrdPollE::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

staticprivate

Referenced by Terminate().

const char XrdLink::KillMsk = 0x7f

staticprivate

Referenced by Terminate().

short XrdLink::killWait = 3

staticprivate

Referenced by setKWT(), and Terminate().

const char XrdLink::KillXwt = 0x80

staticprivate

Referenced by Terminate().

unsigned int XrdLink::LinkAlloc

staticprivate

Referenced by Alloc(), and Setup().

char * XrdLink::LinkBat

staticprivate

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

long long XrdLink::LinkBytesIn = 0

staticprivate

Referenced by Stats(), and syncStats().

long long XrdLink::LinkBytesOut = 0

staticprivate

Referenced by Stats(), and syncStats().

long long XrdLink::LinkConTime = 0

staticprivate

Referenced by Stats(), and syncStats().

int XrdLink::LinkCount = 0

staticprivate

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

int XrdLink::LinkCountMax = 0

staticprivate

Referenced by Alloc(), and Stats().

long long XrdLink::LinkCountTot = 0

staticprivate

Referenced by Alloc(), and Stats().

int XrdLink::LinkSfIntr = 0

staticprivate

Referenced by Stats(), and syncStats().

int XrdLink::LinkStalls = 0

staticprivate

Referenced by Stats(), and syncStats().

XrdLink ** XrdLink::LinkTab

staticprivate

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

int XrdLink::LinkTimeOuts = 0

staticprivate

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

staticprivate

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

XrdSysMutex XrdLink::LTMutex

staticprivate

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 Reset(), 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

staticprivate

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"

staticprivate

XrdNetBuffer* XrdLink::udpbuff

private

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

char XrdLink::Uname[24]

private

Referenced by Reset(), and setID().

short XrdLink::waitKill = 4

staticprivate

Referenced by setKWT(), and Terminate().

XrdSysMutex XrdLink::wrMutex

private

Referenced by Send(), and syncStats().

XrdSysError * XrdLink::XrdLog = 0

staticprivate

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

XrdInet * XrdLink::XrdNetTCP = 0

staticprivate

Referenced by Alloc(), and Init().

XrdScheduler * XrdLink::XrdSched = 0

staticprivate

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

XrdOucTrace * XrdLink::XrdTrace = 0

staticprivate

Referenced by Init(), and Setup().

---

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

• XrdLink.hh
• XrdLink.cc