xrootd
|
#include <XrdLink.hh>
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 |
XrdLink::~XrdLink | ( | ) | [inline] |
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().
int XrdLink::Client | ( | char * | buff, |
int | blen | ||
) |
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] |
int XrdLink::FDnum | ( | ) | [inline] |
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] |
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] |
const char* XrdLink::Name | ( | sockaddr * | ipaddr = 0 | ) | [inline] |
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.
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 | ||
) |
int XrdLink::sendData | ( | const char * | Buff, |
int | Blen | ||
) | [private] |
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] |
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.
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().
friend class XrdLinkScan [friend] |
Referenced by Setup().
friend class XrdPoll [friend] |
friend class XrdPollDev [friend] |
friend class XrdPollE [friend] |
friend class XrdPollPoll [friend] |
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] |
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] |
char* XrdLink::HostName [private] |
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] |
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] |
char XrdLink::KeepFD [private] |
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] |
char * XrdLink::LinkBat [static, private] |
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] |
long long XrdLink::LinkCountTot = 0 [static, private] |
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] |
int XrdLink::LinkTimeOuts = 0 [static, private] |
Referenced by Stats(), and syncStats().
char XrdLink::Lname[232] [private] |
int XrdLink::LTLast = -1 [static, private] |
XrdSysMutex XrdLink::LTMutex [static, private] |
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] |
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] |
pthread_t XrdLink::TID [private] |
Referenced by Bind().
const char * XrdLink::TraceID = "Link" [static, private] |
XrdNetBuffer* XrdLink::udpbuff [private] |
char XrdLink::Uname[24] [private] |
short XrdLink::waitKill = 4 [static, private] |
Referenced by setKWT(), and Terminate().
XrdSysMutex XrdLink::wrMutex [private] |
Referenced by Send(), and syncStats().