XrdNetRefresh Class Reference

#include <XrdNetRefresh.hh>

Inheritance diagram for XrdNetRefresh:

Collaboration diagram for XrdNetRefresh:

Public Member Functions
	XrdNetRefresh ()
virtual	~XrdNetRefresh ()
virtual void	DoIt () override
Public Member Functions inherited from XrdJob
	XrdJob (const char *desc="")
virtual	~XrdJob ()

Static Public Member Functions
static bool	Register (XrdNetPeer &Peer)
static void	Start (XrdSysLogger *logP, XrdScheduler *sP)
static void	UnRegister (int fd)

Additional Inherited Members
Public Attributes inherited from XrdJob
const char *	Comment
XrdJob *	NextJob

Detailed Description

Definition at line 39 of file XrdNetRefresh.hh.

Constructor & Destructor Documentation

XrdNetRefresh()

XrdNetRefresh::XrdNetRefresh ( )

inline

Definition at line 51 of file XrdNetRefresh.hh.

: XrdJob("NetRefresh") {}

~XrdNetRefresh()

virtual XrdNetRefresh::~XrdNetRefresh ( )

inlinevirtual

Definition at line 52 of file XrdNetRefresh.hh.

{}

Member Function Documentation

DoIt()

void XrdNetRefresh::DoIt ( )

overridevirtual

Implements XrdJob.

Definition at line 94 of file XrdNetRefresh.cc.

{
 
// Run the address updater
//
   Update();
 
// Reschedule ourselves
//
   schedP->Schedule(this, time(0)+udpRefr);
}

References XrdOfsPrepGPIReal::schedP, XrdScheduler::Schedule(), and XrdNetSocketCFG::udpRefr.

Here is the call graph for this function:

Register()

bool XrdNetRefresh::Register ( XrdNetPeer &  Peer )

static

Definition at line 120 of file XrdNetRefresh.cc.

{
   static unsigned int INum = 0;
 
// Make sure we have a valid hostname
//
   if (!Peer.InetName) return RegFail("hostname missing");
 
   if (index(Peer.InetName, '!')) return RegFail("invalid hostname");
 
// Make sure file discriptor is not negative
//
   if (Peer.fd < 0) return RegFail("invalid socket descriptor");
 
// Make sure the file descriptor is a UDP socket
//
   struct stat Stat;
   fstat(Peer.fd, &Stat);
   if (!S_ISSOCK(Stat.st_mode)) return RegFail("not a socket");
 
   int sockType;
   socklen_t stLen = sizeof(sockType);
 
   if (getsockopt(Peer.fd, SOL_SOCKET, SO_TYPE, (void*)&sockType, &stLen)
   || sockType != SOCK_DGRAM) return RegFail("not a UDP socket");
 
// Constrcut a new info structure to insert into the map
//
   RefInfo newRef(Peer.InetName, INum++);
 
// Add port number to the registration name (v4 and v6 ports are the same)
//
   newRef.destHN.append(":");
   newRef.destHN.append(std::to_string(ntohs(Peer.Inet.v4.sin_port)));
 
// Lock the map
//
   XrdSysMutexHelper mHelp(refMTX);
 
// Attempt to insert the element, verify that it happened
//
   auto ret = fd2Info.insert(std::pair<int, RefInfo>(Peer.fd, newRef));
   if (ret.second==false)
      {char buff[32];
       snprintf(buff, sizeof(buff), "(%d)", Peer.fd);
       eDest.Emsg("Refresh", "Peer cannot be registered"
                              "duplicate socket descriptor", buff);
       return false;
      }
 
// All done, it went well
//
   return true;
}

References eDest, XrdSysError::Emsg(), XrdNetPeer::fd, fstat, XrdNetPeer::Inet, XrdNetPeer::InetName, Stat, stat, and XrdNetSockAddr::v4.

Referenced by XrdNetMsg::XrdNetMsg().

Here is the call graph for this function:

Here is the caller graph for this function:

Start()

void XrdNetRefresh::Start ( XrdSysLogger *  logP, XrdScheduler *  sP  )

static

Definition at line 179 of file XrdNetRefresh.cc.

{
// Set pointers we will need
//
   eDest.logger(logP);
   schedP = sP;
 
// We allocate an instance of this object so that we can schedule it.
//
   NetRefresh = new XrdNetRefresh();
 
// Now schedule it to refresh UDP destinations
//
   schedP->Schedule(NetRefresh, time(0)+udpRefr);
}  

References eDest, XrdSysError::logger(), XrdNetSocketCFG::NetRefresh, XrdOfsPrepGPIReal::schedP, XrdScheduler::Schedule(), and XrdNetSocketCFG::udpRefr.

Referenced by XrdConfig::Configure().

Here is the call graph for this function:

Here is the caller graph for this function:

UnRegister()

void XrdNetRefresh::UnRegister ( int  fd )

static

Definition at line 199 of file XrdNetRefresh.cc.

{
   XrdSysMutexHelper mHelp(refMTX);
 
// Attempt to delete the fd from out set
//
   if (!fd2Info.erase(fd))
      {char buff[32];
       snprintf(buff, sizeof(buff), "%d)", fd);
       eDest.Emsg("Refresh", "Atempt to unregisted non-existent fd:",buff);
      }
}

References eDest, and XrdSysError::Emsg().

Referenced by XrdNetMsg::~XrdNetMsg().

Here is the call graph for this function:

Here is the caller graph for this function:

---

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

• XrdNetRefresh.hh
• XrdNetRefresh.cc