xrootd
|
#include <XrdLinkXeq.hh>
Public Member Functions | |
XrdNetAddrInfo * | AddrInfo () |
int | Backlog () |
int | Client (char *buff, int blen) |
int | Close (bool defer=false) |
void | DoIt () |
int | getIOStats (long long &inbytes, long long &outbytes, int &numstall, int &numtardy) |
XrdTlsPeerCerts * | getPeerCerts () |
XrdProtocol * | getProtocol () |
const char * | Name () const |
const XrdNetAddr * | NetAddr () const |
int | Peek (char *buff, int blen, int timeout=-1) |
int | Recv (char *buff, int blen) |
int | Recv (char *buff, int blen, int timeout) |
int | Recv (const struct iovec *iov, int iocnt, int timeout) |
int | RecvAll (char *buff, int blen, int timeout=-1) |
bool | Register (const char *hName) |
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 | setID (const char *userid, int procid) |
void | setLocation (XrdNetAddrInfo::LocInfo &loc) |
bool | setNB () |
XrdProtocol * | setProtocol (XrdProtocol *pp, bool push) |
void | setProtName (const char *name) |
bool | setTLS (bool enable, XrdTlsContext *ctx=0) |
void | Shutdown (bool getLock) |
void | syncStats (int *ctime=0) |
int | TLS_Peek (char *Buff, int Blen, int timeout) |
int | TLS_Recv (char *Buff, int Blen) |
int | TLS_Recv (char *Buff, int Blen, int timeout, bool havelock=false) |
int | TLS_Recv (const struct iovec *iov, int iocnt, int timeout) |
int | TLS_RecvAll (char *Buff, int Blen, int timeout) |
int | TLS_Send (const char *Buff, int Blen) |
int | TLS_Send (const struct iovec *iov, int iocnt, int bytes) |
int | TLS_Send (const sfVec *sfP, int sfN) |
const char * | verTLS () |
XrdLinkXeq () | |
~XrdLinkXeq () | |
Static Public Member Functions | |
static int | getName (int &curr, char *bname, int blen, XrdLinkMatch *who=0) |
static int | Stats (char *buff, int blen, bool do_sync=false) |
Public Attributes | |
XrdLinkInfo | LinkInfo |
XrdPollInfo | PollInfo |
Protected Member Functions | |
int | RecvIOV (const struct iovec *iov, int iocnt) |
void | Reset () |
int | sendData (const char *Buff, int Blen) |
int | SendIOV (const struct iovec *iov, int iocnt, int bytes) |
int | SFError (int rc) |
int | TLS_Error (const char *act, XrdTls::RC rc) |
bool | TLS_Write (const char *Buff, int Blen) |
Protected Member Functions inherited from XrdLink | |
~XrdLink () | |
void | ResetLink () |
int | Wait4Data (int timeout) |
bool | Activate () |
XrdNetAddrInfo * | AddrInfo () |
int | Backlog () |
int | Client (char *buff, int blen) |
int | Close (bool defer=false) |
void | Enable () |
Enable the link to field interrupts. | |
int | FDnum () |
int | getIOStats (long long &inbytes, long long &outbytes, int &numstall, int &numtardy) |
XrdTlsPeerCerts * | getPeerCerts () |
XrdProtocol * | getProtocol () |
Obtain current protocol object pointer. | |
void | Hold (bool lk) |
const char * | Host () const |
unsigned int | Inst () const |
bool | isFlawed () const |
bool | isInstance (unsigned int inst) const |
const char * | Name () const |
const XrdNetAddr * | NetAddr () const |
int | Peek (char *buff, int blen, int timeout=-1) |
int | Recv (char *buff, int blen) |
int | Recv (char *buff, int blen, int timeout) |
int | Recv (const struct iovec *iov, int iocnt, int timeout) |
int | RecvAll (char *buff, int blen, int timeout=-1) |
bool | Register (const char *hName) |
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 () |
Wait for all outstanding requests to be completed on the link. | |
int | setEtext (const char *text) |
void | setID (const char *userid, int procid) |
void | setLocation (XrdNetAddrInfo::LocInfo &loc) |
bool | setNB () |
XrdProtocol * | setProtocol (XrdProtocol *pp, bool runit=false, bool push=false) |
void | setProtName (const char *name) |
void | setRef (int cnt) |
bool | setTLS (bool enable, XrdTlsContext *ctx=0) |
Enable or disable TLS on the link. | |
void | Shutdown (bool getLock) |
void | syncStats (int *ctime=0) |
int | Terminate (const char *owner, int fdnum, unsigned int inst) |
time_t | timeCon () const |
Return the time the link was made active (i.e. time of connection). | |
int | UseCnt () const |
Return link's reference count. | |
void | armBridge () |
Mark this link as an in-memory communications bridge (internal use only). | |
bool | hasBridge () const |
bool | hasTLS () const |
const char * | verTLS () |
XrdLink (XrdLinkXeq &lxq) | |
Protected Member Functions inherited from XrdJob | |
XrdJob (const char *desc="") | |
virtual | ~XrdJob () |
Protected Attributes | |
long long | BytesIn |
long long | BytesInTot |
long long | BytesOut |
long long | BytesOutTot |
int | stallCnt |
int | stallCntTot |
int | tardyCnt |
int | tardyCntTot |
int | SfIntr |
XrdProtocol * | Protocol |
XrdProtocol * | ProtoAlt |
XrdTlsSocket | tlsIO |
XrdNetAddr | Addr |
XrdSysMutex | rdMutex |
XrdSysMutex | wrMutex |
XrdSendQ * | sendQ |
int | HNlen |
bool | LockReads |
bool | KeepFD |
char | isIdle |
char | Uname [24] |
char | Lname [256] |
Protected Attributes inherited from XrdLink | |
void * | rsvd1 [3] |
XrdLinkXeq & | linkXQ |
char * | HostName |
unsigned int | Instance |
bool | isBridged |
bool | isTLS |
char | rsvd2 [2] |
char * | ID |
Pointer to the client's link identity. | |
Protected Attributes inherited from XrdJob | |
XrdJob * | NextJob |
const char * | Comment |
Static Protected Attributes | |
static const char * | TraceID |
static long long | LinkBytesIn |
static long long | LinkBytesOut |
static long long | LinkConTime |
static long long | LinkCountTot |
static int | LinkCount |
static int | LinkCountMax |
static int | LinkTimeOuts |
static int | LinkStalls |
static int | LinkSfIntr |
static XrdSysMutex | statsMutex |
Static Protected Attributes inherited from XrdLink | |
static bool | sfOK |
Additional Inherited Members | |
Protected Types inherited from XrdLink | |
typedef XrdOucSFVec | sfVec |
Static Protected Member Functions inherited from XrdLink | |
static XrdLink * | Find (int &curr, XrdLinkMatch *who=0) |
static int | getName (int &curr, char *bname, int blen, XrdLinkMatch *who=0) |
static int | Stats (char *buff, int blen, bool do_sync=0) |
XrdLinkXeq::XrdLinkXeq | ( | ) |
|
inline |
|
inline |
References Addr.
int XrdLinkXeq::Backlog | ( | ) |
int XrdLinkXeq::Client | ( | char * | buff, |
int | blen | ||
) |
int XrdLinkXeq::Close | ( | bool | defer = false | ) |
|
virtual |
Reimplemented from XrdLink.
|
inline |
References BytesIn, BytesInTot, BytesOut, BytesOutTot, XrdLinkInfo::InUse, LinkInfo, stallCnt, stallCntTot, tardyCnt, and tardyCntTot.
|
static |
XrdTlsPeerCerts * XrdLinkXeq::getPeerCerts | ( | ) |
|
inline |
References Protocol.
|
inline |
References Lname.
|
inline |
References Addr.
int XrdLinkXeq::Peek | ( | char * | buff, |
int | blen, | ||
int | timeout = -1 |
||
) |
int XrdLinkXeq::Recv | ( | char * | buff, |
int | blen | ||
) |
int XrdLinkXeq::Recv | ( | char * | buff, |
int | blen, | ||
int | timeout | ||
) |
int XrdLinkXeq::Recv | ( | const struct iovec * | iov, |
int | iocnt, | ||
int | timeout | ||
) |
int XrdLinkXeq::RecvAll | ( | char * | buff, |
int | blen, | ||
int | timeout = -1 |
||
) |
|
protected |
bool XrdLinkXeq::Register | ( | const char * | hName | ) |
|
protected |
int XrdLinkXeq::Send | ( | const char * | buff, |
int | blen | ||
) |
int XrdLinkXeq::Send | ( | const sfVec * | sdP, |
int | sdn | ||
) |
int XrdLinkXeq::Send | ( | const struct iovec * | iov, |
int | iocnt, | ||
int | bytes = 0 |
||
) |
|
protected |
|
protected |
void XrdLinkXeq::setID | ( | const char * | userid, |
int | procid | ||
) |
|
inline |
References Addr, and XrdNetAddr::SetLocation().
bool XrdLinkXeq::setNB | ( | ) |
void XrdLinkXeq::setProtName | ( | const char * | name | ) |
XrdProtocol * XrdLinkXeq::setProtocol | ( | XrdProtocol * | pp, |
bool | push | ||
) |
bool XrdLinkXeq::setTLS | ( | bool | enable, |
XrdTlsContext * | ctx = 0 |
||
) |
|
protected |
void XrdLinkXeq::Shutdown | ( | bool | getLock | ) |
|
static |
void XrdLinkXeq::syncStats | ( | int * | ctime = 0 | ) |
|
protected |
int XrdLinkXeq::TLS_Peek | ( | char * | Buff, |
int | Blen, | ||
int | timeout | ||
) |
int XrdLinkXeq::TLS_Recv | ( | char * | Buff, |
int | Blen | ||
) |
int XrdLinkXeq::TLS_Recv | ( | char * | Buff, |
int | Blen, | ||
int | timeout, | ||
bool | havelock = false |
||
) |
int XrdLinkXeq::TLS_Recv | ( | const struct iovec * | iov, |
int | iocnt, | ||
int | timeout | ||
) |
int XrdLinkXeq::TLS_RecvAll | ( | char * | Buff, |
int | Blen, | ||
int | timeout | ||
) |
int XrdLinkXeq::TLS_Send | ( | const char * | Buff, |
int | Blen | ||
) |
int XrdLinkXeq::TLS_Send | ( | const sfVec * | sfP, |
int | sfN | ||
) |
int XrdLinkXeq::TLS_Send | ( | const struct iovec * | iov, |
int | iocnt, | ||
int | bytes | ||
) |
|
protected |
const char * XrdLinkXeq::verTLS | ( | ) |
|
protected |
Referenced by AddrInfo(), NetAddr(), and setLocation().
|
protected |
Referenced by getIOStats().
|
protected |
Referenced by getIOStats().
|
protected |
Referenced by getIOStats().
|
protected |
Referenced by getIOStats().
|
protected |
|
protected |
|
protected |
|
staticprotected |
|
staticprotected |
|
staticprotected |
|
staticprotected |
|
staticprotected |
|
staticprotected |
XrdLinkInfo XrdLinkXeq::LinkInfo |
Referenced by getIOStats().
|
staticprotected |
|
staticprotected |
|
staticprotected |
|
protected |
Referenced by Name().
|
protected |
XrdPollInfo XrdLinkXeq::PollInfo |
Referenced by XrdLinkCtl::fd2PollInfo().
|
protected |
|
protected |
Referenced by getProtocol().
|
protected |
|
protected |
|
protected |
|
protected |
Referenced by getIOStats().
|
protected |
Referenced by getIOStats().
|
staticprotected |
|
protected |
Referenced by getIOStats().
|
protected |
Referenced by getIOStats().
|
protected |
|
staticprotected |
|
protected |
|
protected |