#include <XrdLinkXeq.hh>

Inheritance diagram for XrdLinkXeq:

[legend]

Collaboration diagram for XrdLinkXeq:

[legend]

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)

Constructor & Destructor Documentation

◆ XrdLinkXeq()

XrdLinkXeq::XrdLinkXeq ( )

◆ ~XrdLinkXeq()

XrdLinkXeq::~XrdLinkXeq ( )

inline

Member Function Documentation

◆ AddrInfo()

XrdNetAddrInfo * XrdLinkXeq::AddrInfo ( )

inline

References Addr.

◆ Backlog()

int XrdLinkXeq::Backlog ( )

◆ Client()

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

◆ Close()

int XrdLinkXeq::Close ( bool defer = false )

◆ DoIt()

void XrdLinkXeq::DoIt ( )

virtual

Reimplemented from XrdLink.

◆ getIOStats()

int XrdLinkXeq::getIOStats	(	long long &	inbytes,
		long long &	outbytes,
		int &	numstall,
		int &	numtardy
	)

inline

References BytesIn, BytesInTot, BytesOut, BytesOutTot, XrdLinkInfo::InUse, LinkInfo, stallCnt, stallCntTot, tardyCnt, and tardyCntTot.

◆ getName()

static int XrdLinkXeq::getName	(	int &	curr,
		char *	bname,
		int	blen,
		XrdLinkMatch *	who = `0`
	)

static

◆ getPeerCerts()

XrdTlsPeerCerts * XrdLinkXeq::getPeerCerts ( )

◆ getProtocol()

XrdProtocol * XrdLinkXeq::getProtocol ( )

inline

References Protocol.

◆ Name()

const char * XrdLinkXeq::Name ( ) const

inline

References Lname.

◆ NetAddr()

const XrdNetAddr * XrdLinkXeq::NetAddr ( ) const

inline

References Addr.

◆ Peek()

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

◆ Recv() [1/3]

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

◆ Recv() [2/3]

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

◆ Recv() [3/3]

int XrdLinkXeq::Recv	(	const struct iovec *	iov,
		int	iocnt,
		int	timeout
	)

◆ RecvAll()

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

◆ RecvIOV()

int XrdLinkXeq::RecvIOV	(	const struct iovec *	iov,
		int	iocnt
	)

protected

◆ Register()

bool XrdLinkXeq::Register ( const char * hName )

◆ Reset()

void XrdLinkXeq::Reset ( )

protected

◆ Send() [1/3]

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

◆ Send() [2/3]

int XrdLinkXeq::Send	(	const sfVec *	sdP,
		int	sdn
	)

◆ Send() [3/3]

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

◆ sendData()

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

protected

◆ SendIOV()

int XrdLinkXeq::SendIOV	(	const struct iovec *	iov,
		int	iocnt,
		int	bytes
	)

protected

◆ setID()

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

◆ setLocation()

void XrdLinkXeq::setLocation ( XrdNetAddrInfo::LocInfo & loc )

inline

References Addr, and XrdNetAddr::SetLocation().

◆ setNB()

bool XrdLinkXeq::setNB ( )

◆ setProtName()

void XrdLinkXeq::setProtName ( const char * name )

◆ setProtocol()

XrdProtocol * XrdLinkXeq::setProtocol	(	XrdProtocol *	pp,
		bool	push
	)

◆ setTLS()

bool XrdLinkXeq::setTLS	(	bool	enable,
		XrdTlsContext *	ctx = `0`
	)

◆ SFError()

int XrdLinkXeq::SFError ( int rc )

protected

◆ Shutdown()

void XrdLinkXeq::Shutdown ( bool getLock )

◆ Stats()

static int XrdLinkXeq::Stats	(	char *	buff,
		int	blen,
		bool	do_sync = `false`
	)

static

◆ syncStats()

void XrdLinkXeq::syncStats ( int * ctime = 0 )

◆ TLS_Error()

int XrdLinkXeq::TLS_Error	(	const char *	act,
		XrdTls::RC	rc
	)

protected

◆ TLS_Peek()

int XrdLinkXeq::TLS_Peek	(	char *	Buff,
		int	Blen,
		int	timeout
	)

◆ TLS_Recv() [1/3]

int XrdLinkXeq::TLS_Recv	(	char *	Buff,
		int	Blen
	)

◆ TLS_Recv() [2/3]

int XrdLinkXeq::TLS_Recv	(	char *	Buff,
		int	Blen,
		int	timeout,
		bool	havelock = `false`
	)

◆ TLS_Recv() [3/3]

int XrdLinkXeq::TLS_Recv	(	const struct iovec *	iov,
		int	iocnt,
		int	timeout
	)

◆ TLS_RecvAll()

int XrdLinkXeq::TLS_RecvAll	(	char *	Buff,
		int	Blen,
		int	timeout
	)

◆ TLS_Send() [1/3]

int XrdLinkXeq::TLS_Send	(	const char *	Buff,
		int	Blen
	)

◆ TLS_Send() [2/3]

int XrdLinkXeq::TLS_Send	(	const sfVec *	sfP,
		int	sfN
	)

◆ TLS_Send() [3/3]

int XrdLinkXeq::TLS_Send	(	const struct iovec *	iov,
		int	iocnt,
		int	bytes
	)

◆ TLS_Write()

bool XrdLinkXeq::TLS_Write	(	const char *	Buff,
		int	Blen
	)

protected

◆ verTLS()

const char * XrdLinkXeq::verTLS ( )

Member Data Documentation

◆ Addr

XrdNetAddr XrdLinkXeq::Addr

protected

Referenced by AddrInfo(), NetAddr(), and setLocation().

◆ BytesIn

long long XrdLinkXeq::BytesIn

protected

Referenced by getIOStats().

◆ BytesInTot

long long XrdLinkXeq::BytesInTot

protected

Referenced by getIOStats().

◆ BytesOut

long long XrdLinkXeq::BytesOut

protected

Referenced by getIOStats().

◆ BytesOutTot

long long XrdLinkXeq::BytesOutTot

protected

Referenced by getIOStats().

◆ HNlen

int XrdLinkXeq::HNlen

protected

◆ isIdle

char XrdLinkXeq::isIdle

protected

◆ KeepFD

bool XrdLinkXeq::KeepFD

protected

◆ LinkBytesIn

long long XrdLinkXeq::LinkBytesIn

staticprotected

◆ LinkBytesOut

long long XrdLinkXeq::LinkBytesOut

staticprotected

◆ LinkConTime

long long XrdLinkXeq::LinkConTime

staticprotected

◆ LinkCount

int XrdLinkXeq::LinkCount

staticprotected

◆ LinkCountMax

int XrdLinkXeq::LinkCountMax

staticprotected

◆ LinkCountTot

long long XrdLinkXeq::LinkCountTot

staticprotected

◆ LinkInfo

XrdLinkInfo XrdLinkXeq::LinkInfo

Referenced by getIOStats().

◆ LinkSfIntr

int XrdLinkXeq::LinkSfIntr

staticprotected

◆ LinkStalls

int XrdLinkXeq::LinkStalls

staticprotected

◆ LinkTimeOuts

int XrdLinkXeq::LinkTimeOuts

staticprotected

◆ Lname

char XrdLinkXeq::Lname[256]

protected

Referenced by Name().

◆ LockReads

bool XrdLinkXeq::LockReads

protected

◆ PollInfo

XrdPollInfo XrdLinkXeq::PollInfo

Referenced by XrdLinkCtl::fd2PollInfo().

◆ ProtoAlt

XrdProtocol* XrdLinkXeq::ProtoAlt

protected

◆ Protocol

XrdProtocol* XrdLinkXeq::Protocol

protected

Referenced by getProtocol().

◆ rdMutex

XrdSysMutex XrdLinkXeq::rdMutex

protected

◆ sendQ

XrdSendQ* XrdLinkXeq::sendQ

protected

◆ SfIntr

int XrdLinkXeq::SfIntr

protected

◆ stallCnt

int XrdLinkXeq::stallCnt

protected

Referenced by getIOStats().

◆ stallCntTot

int XrdLinkXeq::stallCntTot

protected

Referenced by getIOStats().

◆ statsMutex

XrdSysMutex XrdLinkXeq::statsMutex

staticprotected

◆ tardyCnt

int XrdLinkXeq::tardyCnt

protected

Referenced by getIOStats().

◆ tardyCntTot

int XrdLinkXeq::tardyCntTot

protected

Referenced by getIOStats().

◆ tlsIO

XrdTlsSocket XrdLinkXeq::tlsIO

protected

◆ TraceID

const char* XrdLinkXeq::TraceID

staticprotected

◆ Uname

char XrdLinkXeq::Uname[24]

protected

◆ wrMutex

XrdSysMutex XrdLinkXeq::wrMutex

protected

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

XrdLinkXeq.hh

Public Member Functions

Static Public Member Functions

Public Attributes

Protected Member Functions

Protected Attributes

Static Protected Attributes

Additional Inherited Members

Constructor & Destructor Documentation

◆ XrdLinkXeq()

◆ ~XrdLinkXeq()

Member Function Documentation

◆ AddrInfo()

◆ Backlog()

◆ Client()

◆ Close()

◆ DoIt()

◆ getIOStats()

◆ getName()

◆ getPeerCerts()

◆ getProtocol()

◆ Name()

◆ NetAddr()

◆ Peek()

◆ Recv() [1/3]

◆ Recv() [2/3]

◆ Recv() [3/3]

◆ RecvAll()

◆ RecvIOV()

◆ Register()

◆ Reset()

◆ Send() [1/3]

◆ Send() [2/3]

◆ Send() [3/3]

◆ sendData()

◆ SendIOV()

◆ setID()

◆ setLocation()

◆ setNB()

◆ setProtName()

◆ setProtocol()

◆ setTLS()

◆ SFError()

◆ Shutdown()

◆ Stats()

◆ syncStats()

◆ TLS_Error()

◆ TLS_Peek()

◆ TLS_Recv() [1/3]

◆ TLS_Recv() [2/3]

◆ TLS_Recv() [3/3]

◆ TLS_RecvAll()

◆ TLS_Send() [1/3]

◆ TLS_Send() [2/3]

◆ TLS_Send() [3/3]

◆ TLS_Write()

◆ verTLS()

Member Data Documentation

◆ Addr

◆ BytesIn

◆ BytesInTot

◆ BytesOut

◆ BytesOutTot

◆ HNlen

◆ isIdle

◆ KeepFD

◆ LinkBytesIn

◆ LinkBytesOut

◆ LinkConTime

◆ LinkCount

◆ LinkCountMax

◆ LinkCountTot

◆ LinkInfo

◆ LinkSfIntr

◆ LinkStalls

◆ LinkTimeOuts

◆ Lname

◆ LockReads

◆ PollInfo

◆ ProtoAlt

◆ Protocol