XrdLinkCtl.hh

Go to the documentation of this file.

#ifndef __XRD_LINKCTL_H__
#define __XRD_LINKCTL_H__
/******************************************************************************/
/*                                                                            */
/*                         X r d L i n k C t l . h h                          */
/*                                                                            */
/* (c) 2018 by the Board of Trustees of the Leland Stanford, Jr., University  */
/*   Produced by Andrew Hanushevsky for Stanford University under contract    */
/*              DE-AC02-76-SFO0515 with the Department of Energy              */
/*                                                                            */
/* This file is part of the XRootD software suite.                            */
/*                                                                            */
/* XRootD is free software: you can redistribute it and/or modify it under    */
/* the terms of the GNU Lesser General Public License as published by the     */
/* Free Software Foundation, either version 3 of the License, or (at your     */
/* option) any later version.                                                 */
/*                                                                            */
/* XRootD is distributed in the hope that it will be useful, but WITHOUT      */
/* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or      */
/* FITNESS FOR A PARTICULAR PURPOSE.  See the GNU Lesser General Public       */
/* License for more details.                                                  */
/*                                                                            */
/* You should have received a copy of the GNU Lesser General Public License   */
/* along with XRootD in a file called COPYING.LESSER (LGPL license) and file  */
/* COPYING (GPL license).  If not, see <http://www.gnu.org/licenses/>.        */
/*                                                                            */
/* The copyright holder's institutional names and contributor's names may not */
/* be used to endorse or promote products derived from this software without  */
/* specific prior written permission of the institution or contributor.       */
/******************************************************************************/
 
#include "Xrd/XrdLinkXeq.hh"
 
#include "XrdSys/XrdSysPthread.hh"
 
/******************************************************************************/
/*                      C l a s s   D e f i n i t i o n                       */
/******************************************************************************/
  
class XrdLinkMatch;
 
class XrdLinkCtl : protected XrdLinkXeq
{
public:
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
#define XRDLINK_RDLOCK  0x0001
#define XRDLINK_NOCLOSE 0x0002
 
static XrdLink *Alloc(XrdNetAddr &peer, int opts=0);
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
static XrdLink  *fd2link(int fd)
                 {if (fd < 0) fd = -fd;
                  return (fd <= LTLast && LinkBat[fd] ? LinkTab[fd] : 0);
                 }
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
static XrdLink  *fd2link(int fd, unsigned int inst)
                 {if (fd < 0) fd = -fd;
                  if (fd <= LTLast && LinkBat[fd] && LinkTab[fd]
                  && LinkTab[fd]->Instance == inst) return LinkTab[fd];
                  return (XrdLink *)0;
                 }
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
static XrdPollInfo *fd2PollInfo(int fd)
                    {if (fd < 0) fd = -fd;
                     if (fd <= LTLast && LinkBat[fd])
                        return &(LinkTab[fd]->PollInfo);
                     return 0;
                    }
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
static XrdLink  *Find(int &curr, XrdLinkMatch *who=0);
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
static int      getName(int &curr, char *bname, int blen, XrdLinkMatch *who=0);
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
static void     idleScan();
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
static void     setKWT(int wkSec, int kwSec);
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
static int      Setup(int maxfds, int idlewt);
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
static void     SyncAll();
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
static void     Unhook(int fd);
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
static short    killWait;  // Kill then wait;
static short    waitKill;  // Wait then kill
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
                XrdLinkCtl() {}
 
private:
               ~XrdLinkCtl() {}  // Is never deleted!
 
static XrdSysMutex   LTMutex;    // For the LinkTab only LTMutex->IOMutex allowed
static XrdLinkCtl  **LinkTab;
static char         *LinkBat;
static unsigned int  LinkAlloc;
static int           LTLast;
static int           maxFD;
static const char   *TraceID;
};
#endif