#include <XrdLink.hh>
|
typedef XrdOucSFVec | sfVec |
|
|
XrdNetAddrInfo * | AddrInfo () |
|
int | Backlog () |
|
void | Bind () |
|
void | Bind (pthread_t tid) |
|
int | Client (char *buff, int blen) |
|
int | Close (int defer=0) |
|
void | DoIt () |
|
void | Enable () |
|
int | FDnum () |
|
int | getIOStats (long long &inbytes, long long &outbytes, int &numstall, int &numtardy) |
|
XrdProtocol * | getProtocol () |
|
void | Hold (int lk) |
|
const char * | Host () |
|
unsigned int | Inst () |
|
bool | isFlawed () |
|
bool | isInstance (unsigned int inst) |
|
const char * | Name () |
|
const XrdNetAddr * | NetAddr () |
|
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 sfVec *sdP, int sdn) |
|
void | Serialize () |
|
int | setEtext (const char *text) |
|
void | setID (const char *userid, int procid) |
|
void | setLocation (XrdNetAddrInfo::LocInfo &loc) |
|
bool | setNB () |
|
XrdProtocol * | setProtocol (XrdProtocol *pp) |
|
void | setRef (int cnt) |
|
void | Shutdown (bool getLock) |
|
void | syncStats (int *ctime=0) |
|
int | Terminate (const XrdLink *owner, int fdnum, unsigned int inst) |
|
time_t | timeCon () |
|
int | UseCnt () |
|
void | armBridge () |
|
int | hasBridge () |
|
| XrdLink () |
|
| ~XrdLink () |
|
|
static XrdLink * | Alloc (XrdNetAddr &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) |
|
◆ sfVec
◆ XrdLink()
◆ ~XrdLink()
◆ AddrInfo()
XrdNetAddrInfo* XrdLink::AddrInfo |
( |
| ) |
|
|
inline |
Obtain the address information for this link.
- Returns
- Pointer to the XrdAddrInfo object. The pointer is valid while the end-point is connected.
References Addr, Alloc(), and Backlog().
◆ Alloc()
static XrdLink* XrdLink::Alloc |
( |
XrdNetAddr & |
peer, |
|
|
int |
opts = 0 |
|
) |
| |
|
static |
Allocate a new link object.
- Parameters
-
peer | The connection information for the endpoint. |
opts | Processing options: XRDLINK_NOCLOSE - do not close the FD upon recycling. XRDLINK_RDLOCK - obtain a lock prior to reading data. |
- Returns
- !0 The pointer to the new object. =0 A new link object could not be allocated.
Referenced by AddrInfo().
◆ armBridge()
void XrdLink::armBridge |
( |
| ) |
|
|
inline |
◆ Backlog()
◆ Bind() [1/2]
◆ Bind() [2/2]
void XrdLink::Bind |
( |
pthread_t |
tid | ) |
|
|
inline |
◆ Client()
int XrdLink::Client |
( |
char * |
buff, |
|
|
int |
blen |
|
) |
| |
◆ Close()
int XrdLink::Close |
( |
int |
defer = 0 | ) |
|
◆ DoIt()
◆ Enable()
◆ fd2link() [1/2]
static XrdLink* XrdLink::fd2link |
( |
int |
fd | ) |
|
|
inlinestatic |
◆ fd2link() [2/2]
static XrdLink* XrdLink::fd2link |
( |
int |
fd, |
|
|
unsigned int |
inst |
|
) |
| |
|
inlinestatic |
◆ FDnum()
◆ Find()
◆ getIOStats()
int XrdLink::getIOStats |
( |
long long & |
inbytes, |
|
|
long long & |
outbytes, |
|
|
int & |
numstall, |
|
|
int & |
numtardy |
|
) |
| |
|
inline |
◆ getName()
static int XrdLink::getName |
( |
int & |
curr, |
|
|
char * |
bname, |
|
|
int |
blen, |
|
|
XrdLinkMatch * |
who = 0 |
|
) |
| |
|
static |
◆ getProtocol()
◆ hasBridge()
int XrdLink::hasBridge |
( |
| ) |
|
|
inline |
◆ Hold()
void XrdLink::Hold |
( |
int |
lk | ) |
|
|
inline |
◆ Host()
const char* XrdLink::Host |
( |
| ) |
|
|
inline |
Get the fully qualified name of the endpoint.
- Returns
- Pointer to fully qualified host name. The contents are valid while the endpoint is connected.
References HostName.
◆ Init() [1/2]
◆ Init() [2/2]
static void XrdLink::Init |
( |
XrdInet * |
iP | ) |
|
|
inlinestatic |
◆ Inst()
unsigned int XrdLink::Inst |
( |
| ) |
|
|
inline |
Obtain the link's instance number.
- Returns
- The link's instance number.
References Instance.
◆ isFlawed()
bool XrdLink::isFlawed |
( |
| ) |
|
|
inline |
Indicate whether or not the link has an outstanding error.
- Returns
- True the link has an outstanding error. the link has no outstanding error.
References Etext.
◆ isInstance()
bool XrdLink::isInstance |
( |
unsigned int |
inst | ) |
|
|
inline |
Indicate whether or not this link is of a particular instance. only be used for display and not for security purposes.
- Parameters
-
inst | the expected instance number. |
- Returns
- True the link matches the instance number. the link differs the instance number.
References FD, and Instance.
◆ Name()
const char* XrdLink::Name |
( |
| ) |
|
|
inline |
Obtain the domain trimmed name of the end-point. The returned value should only be used for display and not for security purposes.
- Returns
- Pointer to the name that remains valid during the link's lifetime.
References Lname.
◆ NetAddr()
const XrdNetAddr* XrdLink::NetAddr |
( |
| ) |
|
|
inline |
Obtain the network address object for this link. The returned value is valid as long as the end-point is connected. Otherwise, it may change.
- Returns
- Pointer to the object and remains valid during the link's lifetime.
References Addr, Peek(), Recv(), RecvAll(), and Send().
◆ Peek()
int XrdLink::Peek |
( |
char * |
buff, |
|
|
int |
blen, |
|
|
int |
timeout = -1 |
|
) |
| |
◆ Recv() [1/2]
int XrdLink::Recv |
( |
char * |
buff, |
|
|
int |
blen |
|
) |
| |
◆ Recv() [2/2]
int XrdLink::Recv |
( |
char * |
buff, |
|
|
int |
blen, |
|
|
int |
timeout |
|
) |
| |
◆ RecvAll()
int XrdLink::RecvAll |
( |
char * |
buff, |
|
|
int |
blen, |
|
|
int |
timeout = -1 |
|
) |
| |
◆ Reset()
◆ Send() [1/3]
int XrdLink::Send |
( |
const char * |
buff, |
|
|
int |
blen |
|
) |
| |
◆ Send() [2/3]
int XrdLink::Send |
( |
const struct iovec * |
iov, |
|
|
int |
iocnt, |
|
|
int |
bytes = 0 |
|
) |
| |
◆ Send() [3/3]
int XrdLink::Send |
( |
const sfVec * |
sdP, |
|
|
int |
sdn |
|
) |
| |
◆ sendData()
int XrdLink::sendData |
( |
const char * |
Buff, |
|
|
int |
Blen |
|
) |
| |
|
private |
◆ Serialize()
void XrdLink::Serialize |
( |
| ) |
|
◆ setEtext()
int XrdLink::setEtext |
( |
const char * |
text | ) |
|
◆ setID()
void XrdLink::setID |
( |
const char * |
userid, |
|
|
int |
procid |
|
) |
| |
◆ setKWT()
static void XrdLink::setKWT |
( |
int |
wkSec, |
|
|
int |
kwSec |
|
) |
| |
|
static |
◆ setLocation()
void XrdLink::setLocation |
( |
XrdNetAddrInfo::LocInfo & |
loc | ) |
|
|
inline |
◆ setNB()
◆ setProtocol()
◆ setRef()
void XrdLink::setRef |
( |
int |
cnt | ) |
|
◆ Setup()
static int XrdLink::Setup |
( |
int |
maxfd, |
|
|
int |
idlewait |
|
) |
| |
|
static |
◆ Shutdown()
void XrdLink::Shutdown |
( |
bool |
getLock | ) |
|
◆ Stats()
static int XrdLink::Stats |
( |
char * |
buff, |
|
|
int |
blen, |
|
|
int |
do_sync = 0 |
|
) |
| |
|
static |
◆ syncStats()
void XrdLink::syncStats |
( |
int * |
ctime = 0 | ) |
|
◆ Terminate()
int XrdLink::Terminate |
( |
const XrdLink * |
owner, |
|
|
int |
fdnum, |
|
|
unsigned int |
inst |
|
) |
| |
◆ timeCon()
time_t XrdLink::timeCon |
( |
| ) |
|
|
inline |
◆ UseCnt()
◆ XrdLinkScan
◆ XrdPoll
◆ XrdPollDev
◆ XrdPollE
◆ XrdPollPoll
◆ Addr
◆ BytesIn
long long XrdLink::BytesIn |
|
private |
◆ BytesInTot
long long XrdLink::BytesInTot |
|
private |
◆ BytesOut
long long XrdLink::BytesOut |
|
private |
◆ BytesOutTot
long long XrdLink::BytesOutTot |
|
private |
◆ conTime
◆ devNull
◆ doPost
◆ Etext
◆ FD
◆ HNlen
◆ HostName
◆ ID
◆ inQ
◆ Instance
unsigned int XrdLink::Instance |
|
private |
◆ InUse
◆ IOSemaphore
◆ isBridged
◆ isEnabled
◆ isIdle
◆ KeepFD
◆ KillCnt
◆ KillcvP
◆ KillMax
const char XrdLink::KillMax = 60 |
|
staticprivate |
◆ KillMsk
const char XrdLink::KillMsk = 0x7f |
|
staticprivate |
◆ killWait
◆ KillXwt
const char XrdLink::KillXwt = 0x80 |
|
staticprivate |
◆ LinkAlloc
unsigned int XrdLink::LinkAlloc |
|
staticprivate |
◆ LinkBat
◆ LinkBytesIn
long long XrdLink::LinkBytesIn |
|
staticprivate |
◆ LinkBytesOut
long long XrdLink::LinkBytesOut |
|
staticprivate |
◆ LinkConTime
long long XrdLink::LinkConTime |
|
staticprivate |
◆ LinkCount
◆ LinkCountMax
int XrdLink::LinkCountMax |
|
staticprivate |
◆ LinkCountTot
long long XrdLink::LinkCountTot |
|
staticprivate |
◆ LinkSfIntr
◆ LinkStalls
◆ LinkTab
◆ LinkTimeOuts
int XrdLink::LinkTimeOuts |
|
staticprivate |
◆ Lname
◆ LockReads
◆ LTLast
◆ LTMutex
◆ Next
◆ opMutex
◆ PollEnt
struct pollfd* XrdLink::PollEnt |
|
private |
◆ Poller
◆ ProtoAlt
◆ Protocol
◆ rdMutex
◆ sendQ
◆ SfIntr
◆ sfOK
◆ stallCnt
◆ stallCntTot
◆ statsMutex
◆ tardyCnt
◆ tardyCntTot
◆ TraceID
const char* XrdLink::TraceID |
|
staticprivate |
◆ Uname
◆ waitKill
◆ wrMutex
◆ XrdLog
◆ XrdNetTCP
XrdInet* XrdLink::XrdNetTCP |
|
staticprivate |
◆ XrdSched
◆ XrdTrace
The documentation for this class was generated from the following file: