#include <XrdLinkCtl.hh>

Inheritance diagram for XrdLinkCtl:

Collaboration diagram for XrdLinkCtl:

Public Member Functions
	XrdLinkCtl ()
	Constructor.

Static Public Member Functions
static XrdLink *	Alloc (XrdNetAddr &peer, int opts=0)
static XrdLink *	fd2link (int fd)
static XrdLink *	fd2link (int fd, unsigned int inst)
static XrdPollInfo *	fd2PollInfo (int fd)
static XrdLink *	Find (int &curr, XrdLinkMatch *who=0)
static int	getName (int &curr, char bname, int blen, XrdLinkMatch who=0)
static void	idleScan ()
	Look for idle links and close hem down.
static bool	RegisterCloseRequestCb (XrdLink lp, XrdProtocol pp, bool(cb)(void ), void *cbarg)
static void	setKWT (int wkSec, int kwSec)
static int	Setup (int maxfds, int idlewt)
static void	SyncAll ()
	Synchronize statustics for ll links.
static void	Unhook (int fd)
	Unhook a link from the active table of links.

Static Public Attributes
static short	killWait = 3
	Link destruction control constants.
static short	waitKill = 4

Additional Inherited Members
Protected Types inherited from XrdLink
typedef XrdOucSFVec	sfVec
Protected Member Functions inherited from XrdLinkXeq
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)
	XrdLinkXeq ()
	~XrdLinkXeq ()
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)
bool	RegisterCloseRequestCb (XrdProtocol pp, bool(cb)(void ), void cbarg)
int	Send (const char *buff, int blen)
int	Send (const sfVec *sdP, int sdn)
int	Send (const struct iovec *iov, int iocnt, int bytes=0)
void	setID (const char *userid, int procid)
void	setLocation (XrdNetAddrInfo::LocInfo &loc)
bool	setNB ()
void	setProtName (const char *name)
XrdProtocol *	setProtocol (XrdProtocol *pp, bool push)
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 sfVec *sfP, int sfN)
int	TLS_Send (const struct iovec *iov, int iocnt, int bytes)
const char *	verTLS ()
Protected Member Functions inherited from XrdLink
	~XrdLink ()
void	ResetLink ()
int	Wait4Data (int timeout)
	XrdLink (XrdLinkXeq &lxq)
bool	Activate ()
XrdNetAddrInfo *	AddrInfo ()
void	armBridge ()
	Mark this link as an in-memory communications bridge (internal use only).
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.
bool	hasBridge () const
bool	hasTLS () const
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 sfVec *sdP, int sdn)
int	Send (const struct iovec *iov, int iocnt, int bytes=0)
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 ()
void	setProtName (const char *name)
XrdProtocol *	setProtocol (XrdProtocol *pp, bool runit=false, bool push=false)
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.
const char *	verTLS ()
Protected Member Functions inherited from XrdJob
	XrdJob (const char *desc="")
virtual	~XrdJob ()
Static Protected Member Functions inherited from XrdLinkXeq
static int	getName (int &curr, char bname, int blen, XrdLinkMatch who=0)
static int	Stats (char *buff, int blen, bool do_sync=false)
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)
Protected Attributes inherited from XrdLinkXeq
XrdNetAddr	Addr
long long	BytesIn
long long	BytesInTot
long long	BytesOut
long long	BytesOutTot
bool(*	CloseRequestCb )(void *)
void *	CloseRequestCbArg
int	HNlen
char	isIdle
bool	KeepFD
char	Lname [256]
bool	LockReads
XrdProtocol *	ProtoAlt
XrdProtocol *	Protocol
XrdSysMutex	rdMutex
XrdSendQ *	sendQ
int	SfIntr
int	stallCnt
int	stallCntTot
int	tardyCnt
int	tardyCntTot
XrdTlsSocket	tlsIO
char	Uname [24]
XrdSysMutex	wrMutex
XrdLinkInfo	LinkInfo
XrdPollInfo	PollInfo
Protected Attributes inherited from XrdLink
char *	HostName
unsigned int	Instance
bool	isBridged
bool	isTLS
XrdLinkXeq &	linkXQ
void *	rsvd1 [3]
char	rsvd2 [2]
char *	ID
	Pointer to the client's link identity.
Protected Attributes inherited from XrdJob
const char *	Comment
XrdJob *	NextJob
Static Protected Attributes inherited from XrdLinkXeq
static long long	LinkBytesIn = 0
static long long	LinkBytesOut = 0
static long long	LinkConTime = 0
static int	LinkCount = 0
static int	LinkCountMax = 0
static long long	LinkCountTot = 0
static int	LinkSfIntr = 0
static int	LinkStalls = 0
static int	LinkTimeOuts = 0
static XrdSysMutex	statsMutex
static const char *	TraceID = "LinkXeq"
Static Protected Attributes inherited from XrdLink
static bool	sfOK = false

Detailed Description

Definition at line 42 of file XrdLinkCtl.hh.

Constructor & Destructor Documentation

◆ XrdLinkCtl()

XrdLinkCtl::XrdLinkCtl ( )

inline

Constructor.

Definition at line 206 of file XrdLinkCtl.hh.

206{}

Referenced by Alloc(), Find(), getName(), idleScan(), and Setup().

Here is the caller graph for this function:

Member Function Documentation

◆ Alloc()

XrdLink * XrdLinkCtl::Alloc	(	XrdNetAddr &	peer,
		int	opts = 0 )

static

Definition at line 109 of file XrdLinkCtl.cc.

{
   XrdLinkCtl *lp;
   char hName[1024], *unp, buff[32];
   int bl, peerFD = peer.SockFD();
 
// Make sure that the incoming file descriptor can be handled
//
   if (peerFD < 0 || peerFD >= maxFD)
      {snprintf(hName, sizeof(hName), "%d", peerFD);
       Log.Emsg("Link", "attempt to alloc out of range FD -",hName);
       return (XrdLink *)0;
      }
 
// Make sure that the link slot is available
//
   LTMutex.Lock();
   if (LinkBat[peerFD])
      {LTMutex.UnLock();
       snprintf(hName, sizeof(hName), "%d", peerFD);
       Log.Emsg("Link", "attempt to reuse active link FD -",hName);
       return (XrdLink *)0;
      }
 
// Check if we already have a link object in this slot. If not, allocate
// a quantum of link objects and put them in the table.
//
   if (!(lp = LinkTab[peerFD]))
      {unsigned int i;
       XrdLinkCtl **blp, *nlp = new XrdLinkCtl[LinkAlloc]();
       if (!nlp)
          {LTMutex.UnLock();
           Log.Emsg("Link", ENOMEM, "create link");
           return (XrdLink *)0;
          }
       blp = &LinkTab[peerFD/LinkAlloc*LinkAlloc];
       for (i = 0; i < LinkAlloc; i++, blp++) *blp = &nlp[i];
       lp = LinkTab[peerFD];
      }
      else lp->Reset();
   LinkBat[peerFD] = XRDLINK_USED;
   if (peerFD > LTLast) LTLast = peerFD;
   LTMutex.UnLock();
 
// Establish the instance number of this link. This is will prevent us from
// sending asynchronous responses to the wrong client when the file descriptor
// gets reused for connections to the same host.
//
   instMutex.Lock();
   lp->Instance = myInstance++;
   instMutex.UnLock();
 
// Establish the address and connection name of this link
//
   peer.Format(hName, sizeof(hName), XrdNetAddr::fmtAuto,
                                     XrdNetAddr::old6Map4 | XrdNetAddr::noPort);
   lp->HostName = strdup(hName);
   lp->HNlen = strlen(hName);
   XrdNetTCP->Trim(hName);
   lp->Addr = peer;
   strlcpy(lp->Lname, hName, sizeof(lp->Lname));
   bl = sprintf(buff, "anon.0:%d", peerFD);
   unp = lp->Uname + sizeof(Uname) - bl - 1; // Solaris compatibility
   memcpy(unp, buff, bl);
   lp->ID = unp;
   lp->PollInfo.FD = lp->LinkInfo.FD = peerFD;
   lp->Comment = (const char *)unp;
 
// Set options as needed
//
   lp->LockReads = (0 != (opts & XRDLINK_RDLOCK));
   lp->KeepFD    = (0 != (opts & XRDLINK_NOCLOSE));
 
// Update statistics and return the link. We need to actually get the stats
// mutex even when using atomics because we need to use compound operations.
// The atomics will keep reporters from seeing partial results.
//
   statsMutex.Lock();
   AtomicInc(LinkCountTot);            // LinkCountTot++
   if (LinkCountMax <= AtomicInc(LinkCount)) LinkCountMax = LinkCount;
   statsMutex.UnLock();
   return lp;
}

References XrdLink::XrdLink(), XrdLinkCtl(), XrdLinkXeq::Addr, AtomicInc, XrdJob::Comment, XrdLinkInfo::FD, XrdPollInfo::FD, XrdNetAddrInfo::fmtAuto, XrdNetAddrInfo::Format(), XrdLinkXeq::HNlen, XrdLink::HostName, XrdLink::ID, XrdLink::Instance, XrdLinkXeq::KeepFD, XrdLinkXeq::LinkCount, XrdLinkXeq::LinkCountMax, XrdLinkXeq::LinkCountTot, XrdLinkXeq::LinkInfo, XrdLinkXeq::Lname, XrdSysMutex::Lock(), XrdLinkXeq::LockReads, XrdGlobal::Log, XrdNetAddrInfo::noPort, XrdNetAddrInfo::old6Map4, opts, XrdLinkXeq::PollInfo, XrdLinkXeq::Reset(), XrdNetAddrInfo::SockFD(), XrdLinkXeq::statsMutex, strlcpy(), XrdLinkXeq::Uname, XrdSysMutex::UnLock(), XRDLINK_NOCLOSE, XRDLINK_RDLOCK, and XrdGlobal::XrdNetTCP.

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

Here is the call graph for this function:

Here is the caller graph for this function:

◆ fd2link() [1/2]

XrdLink * XrdLinkCtl::fd2link ( int fd )

inlinestatic

Translate a file descriptor number to the corresponding link object.

Parameters

fd	The file descriptor number.

Returns: !0 Pointer to the link object. =0 The file descriptor is not associated with a link.

Definition at line 72 of file XrdLinkCtl.hh.

                 {if (fd < 0) fd = -fd;
                  return (fd <= LTLast && LinkBat[fd] ? LinkTab[fd] : 0);
                 }

References XrdLink::XrdLink().

Referenced by XrdXrootdResponse::Send(), and XrdLink::Terminate().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ fd2link() [2/2]

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

inlinestatic

Translate a file descriptor number and an instance to a link object.

Parameters

fd	The file descriptor number.
inst	The file descriptor number instance number.

Returns: !0 Pointer to the link object. =0 The file descriptor instance is not associated with a link.

Definition at line 87 of file XrdLinkCtl.hh.

                 {if (fd < 0) fd = -fd;
                  if (fd <= LTLast && LinkBat[fd] && LinkTab[fd]
                  && LinkTab[fd]->Instance == inst) return LinkTab[fd];
                  return (XrdLink *)0;
                 }

References XrdLink::XrdLink(), and XrdLink::Instance.

Here is the call graph for this function:

◆ fd2PollInfo()

XrdPollInfo * XrdLinkCtl::fd2PollInfo ( int fd )

inlinestatic

Translate a file descriptor number to the corresponding PollInfo object.

Parameters

fd	The file descriptor number.

Returns: !0 Pointer to the PollInfo object. =0 The file descriptor is not associated with a link.

Definition at line 103 of file XrdLinkCtl.hh.

                    {if (fd < 0) fd = -fd;
                     if (fd <= LTLast && LinkBat[fd])
                        return &(LinkTab[fd]->PollInfo);
                     return 0;
                    }

◆ Find()

XrdLink * XrdLinkCtl::Find	(	int &	curr,
		XrdLinkMatch *	who = 0 )

static

Find the next link matching certain attributes.

Parameters

curr	Is an internal tracking value that allows repeated calls. It must be set to a value of 0 or less on the initial call and not touched therafter unless a null pointer is returned.
who	If the object use to check if the link matches the wanted criterea (typically, client name and host name). If the ppointer is nil, the next link is always returned.

Returns: !0 Pointer to the link object that matches the criterea. The link's reference counter is increased to prevent it from being reused. A subsequent call will reduce the number. =0 No more links exist with the specified criterea.

Definition at line 202 of file XrdLinkCtl.cc.

{
   XrdLinkCtl *lp;
   const int MaxSeek = 16;
   unsigned int myINS;
   int i, seeklim = MaxSeek;
 
// Do initialization
//
   LTMutex.Lock();
   if (curr >= 0 && LinkTab[curr]) LinkTab[curr]->setRef(-1);
      else curr = -1;
 
// Find next matching link. Since this may take some time, we periodically
// release the LTMutex lock which drives up overhead but will still allow
// other critical operations to occur.
//
   for (i = curr+1; i <= LTLast; i++)
       {if ((lp = LinkTab[i]) && LinkBat[i] && lp->HostName)
           if (!who 
           ||   who->Match(lp->ID,lp->Lname-lp->ID-1,lp->HostName,lp->HNlen))
              {myINS = lp->Instance;
               LTMutex.UnLock();
               lp->setRef(1);
               curr = i;
               if (myINS == lp->Instance) return lp;
               LTMutex.Lock();
              }
        if (!seeklim--) {LTMutex.UnLock(); seeklim = MaxSeek; LTMutex.Lock();}
       }
 
// Done scanning the table
//
    LTMutex.UnLock();
    curr = -1;
    return 0;
}

References XrdLink::XrdLink(), XrdLinkCtl(), XrdLinkXeq::HNlen, XrdLink::HostName, XrdLink::ID, XrdLink::Instance, XrdLinkXeq::Lname, XrdLinkMatch::Match(), and XrdLink::setRef().

Referenced by XrdLink::Find().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ getName()

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

static

Find the next client name matching certain attributes.

Parameters

curr	Is an internal tracking value that allows repeated calls. It must be set to a value of 0 or less on the initial call and not touched therafter unless zero is returned.
bname	Pointer to a buffer where the name is to be returned.
blen	The length of the buffer.
who	If the object use to check if the link matches the wanted criterea (typically, client name and host name). If the pointer is nil, a match always occurs.

Returns: !0 The length of the name placed in the buffer. =0 No more links exist with the specified criterea.

Definition at line 248 of file XrdLinkCtl.cc.

{
   XrdLinkCtl *lp;
   const int MaxSeek = 16;
   int i, ulen = 0, seeklim = MaxSeek;
 
// Find next matching link. Since this may take some time, we periodically
// release the LTMutex lock which drives up overhead but will still allow
// other critical operations to occur.
//
   LTMutex.Lock();
   for (i = curr+1; i <= LTLast; i++)
       {if ((lp = LinkTab[i]) && LinkBat[i] && lp->HostName)
           if (!who 
           ||   who->Match(lp->ID,lp->Lname-lp->ID-1,lp->HostName,lp->HNlen))
              {ulen = lp->Client(nbuf, nbsz);
               LTMutex.UnLock();
               curr = i;
               return ulen;
              }
        if (!seeklim--) {LTMutex.UnLock(); seeklim = MaxSeek; LTMutex.Lock();}
       }
   LTMutex.UnLock();
 
// Done scanning the table
//
   curr = -1;
   return 0;
}

References XrdLinkCtl(), XrdLinkXeq::Client(), XrdLinkXeq::HNlen, XrdLink::HostName, XrdLink::ID, XrdLinkXeq::Lname, and XrdLinkMatch::Match().

Referenced by XrdLink::getName().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ idleScan()

void XrdLinkCtl::idleScan ( )

static

Look for idle links and close hem down.

Definition at line 285 of file XrdLinkCtl.cc.

{
   XrdLinkCtl *lp;
   int i, ltlast, lnum = 0, tmo = 0, tmod = 0;
 
// Get the current link high watermark
//
   LTMutex.Lock();
   ltlast = LTLast;
   LTMutex.UnLock();
 
// Scan across all links looking for idle links. Links are never deallocated
// so we don't need any special kind of lock for these
//
   for (i = 0; i <= ltlast; i++)
       {if (LinkBat[i] != XRDLINK_USED
        || !(lp = LinkTab[i])) continue;
        lnum++;
        lp->LinkInfo.opMutex.Lock();
        if (lp->isIdle) tmo++;
        lp->isIdle++;
        if ((int(lp->isIdle)) < idleTicks)
           {lp->LinkInfo.opMutex.UnLock(); continue;}
        lp->isIdle = 0;
        if (!(lp->PollInfo.Poller) || !(lp->PollInfo.isEnabled))
           Log.Emsg("LinkScan","Link",lp->ID,"is disabled and idle.");
           else if (lp->LinkInfo.InUse == 1)
                   {lp->PollInfo.Poller->Disable(lp->PollInfo, "idle timeout");
                    tmod++;
                   }
        lp->LinkInfo.opMutex.UnLock();
       }
 
// Trace what we did
//
   TRACE(CONN, lnum <<" links; " <<tmo <<" idle; " <<tmod <<" force closed");
}

References XrdLinkCtl(), XrdPoll::Disable(), XrdLink::ID, XrdLinkInfo::InUse, XrdPollInfo::isEnabled, XrdLinkXeq::isIdle, XrdLinkXeq::LinkInfo, XrdSysMutex::Lock(), XrdGlobal::Log, XrdLinkInfo::opMutex, XrdPollInfo::Poller, XrdLinkXeq::PollInfo, TRACE, and XrdSysMutex::UnLock().

Here is the call graph for this function:

◆ RegisterCloseRequestCb()

bool XrdLinkCtl::RegisterCloseRequestCb	(	XrdLink *	lp,
		XrdProtocol *	pp,
		bool(*	cb )(void *),
		void *	cbarg )

static

Regitsers an optional callback to be called if the Link determines it should Close. In case the callback returns false the Link will not Close itself, the Link should be Closed by an external call to Close.

Definition at line 407 of file XrdLinkCtl.cc.

{
   if (!lp) return false;
   XrdLinkXeq *xlp = (XrdLinkXeq*)lp;
   return xlp->RegisterCloseRequestCb(pp, cb, cbarg);
}

References XrdLink::XrdLink(), XrdLinkXeq::XrdLinkXeq(), and XrdLinkXeq::RegisterCloseRequestCb().

Here is the call graph for this function:

◆ setKWT()

void XrdLinkCtl::setKWT	(	int	wkSec,
		int	kwSec )

static

Set kill constants.

Parameters

wkSec	Seconds to wait for kill to happed,
kwSec	The minimum number of seconds to wait after killing a connection for it to end.

Definition at line 327 of file XrdLinkCtl.cc.

{
   if (wkSec > 0) waitKill = static_cast<short>(wkSec);
   if (kwSec > 0) killWait = static_cast<short>(kwSec);
}

References killWait, and waitKill.

◆ Setup()

int XrdLinkCtl::Setup	(	int	maxfds,
		int	idlewt )

static

Setup link processing.

Parameters

maxfds	The maximum number of connections to handle.
idlewt	The time interval to check for idle connections.

Returns: !0 Successful. =0 Setup failed.

Definition at line 337 of file XrdLinkCtl.cc.

{
   maxFD = maxfds;
   TRACE(DEBUG, "Allocating " <<LinkAlloc <<" link objects at a time");
 
// Create the link table
//
   if (!(LinkTab = (XrdLinkCtl **)malloc(maxfds*sizeof(XrdLinkCtl*)+LinkAlloc)))
      {Log.Emsg("Link", ENOMEM, "create LinkTab"); return 0;}
   memset((void *)LinkTab, 0, maxfds*sizeof(XrdLinkCtl *));
 
// Create the slot status table
//
   if (!(LinkBat = (char *)malloc(maxfds*sizeof(char)+LinkAlloc)))
      {Log.Emsg("Link", ENOMEM, "create LinkBat"); return 0;}
   memset((void *)LinkBat, XRDLINK_FREE, maxfds*sizeof(char));
 
// Create an idle connection scan job
//
   if (idlewait)
      {if ((idleCheck = idlewait/3)) idleTicks = 3;
          else {idleTicks = 1;
                idleCheck = idlewait;
               }
       LinkScan *ls = new LinkScan;
       Sched.Schedule((XrdJob *)ls, idleCheck+time(0));
      }
 
// All done
//
   return 1;
}

References XrdJob::XrdJob(), XrdLinkCtl(), DEBUG, XrdGlobal::Log, XrdGlobal::Sched, and TRACE.

Here is the call graph for this function:

◆ SyncAll()

void XrdLinkCtl::SyncAll ( )

static

Synchronize statustics for ll links.

Definition at line 374 of file XrdLinkCtl.cc.

{
   int myLTLast;
 
// Get the current last entry
//
   LTMutex.Lock(); myLTLast = LTLast; LTMutex.UnLock();
 
// Run through all the links and sync the statistics
//
   for (int i = 0; i <= myLTLast; i++)
       {if (LinkBat[i] == XRDLINK_USED && LinkTab[i]) LinkTab[i]->syncStats();}
}

Referenced by XrdLinkXeq::Stats().

Here is the caller graph for this function:

◆ Unhook()

void XrdLinkCtl::Unhook ( int fd )

static

Unhook a link from the active table of links.

Definition at line 392 of file XrdLinkCtl.cc.

{
 
// Indicate link no longer actvely neing used
//
   LTMutex.Lock();
   LinkBat[fd] = XRDLINK_FREE;
   if (fd == LTLast) while(LTLast && !(LinkBat[LTLast])) LTLast--;
   LTMutex.UnLock();
}

Referenced by XrdLinkXeq::Close().

Here is the caller graph for this function:

Member Data Documentation

◆ killWait

short XrdLinkCtl::killWait = 3

static

Link destruction control constants.

Definition at line 199 of file XrdLinkCtl.hh.

Referenced by setKWT(), and XrdLink::Terminate().

◆ waitKill

short XrdLinkCtl::waitKill = 4

static

Definition at line 200 of file XrdLinkCtl.hh.

Referenced by setKWT(), and XrdLink::Terminate().

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

	XRootD

Public Member Functions

Static Public Member Functions

Static Public Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ XrdLinkCtl()

Member Function Documentation

◆ Alloc()

◆ fd2link() [1/2]

◆ fd2link() [2/2]

◆ fd2PollInfo()

◆ Find()

◆ getName()

◆ idleScan()

◆ RegisterCloseRequestCb()

◆ setKWT()

◆ Setup()

◆ SyncAll()

◆ Unhook()

Member Data Documentation

◆ killWait

◆ waitKill