XrdCmsUtils Class Reference

#include <XrdCmsUtils.hh>

Collaboration diagram for XrdCmsUtils:

Public Member Functions
	XrdCmsUtils ()
	~XrdCmsUtils ()

Static Public Member Functions
static XrdCmsPerfMon *	loadPerfMon (XrdSysError *eDest, const char *libPath, XrdVersionInfo &urVer)
	Load the performance monitor plugin.
static bool	ParseMan (XrdSysError *eDest, XrdOucTList **oldMans, char *hSpec, char *hPort, int *sPort=0, bool hush=false)
static char *	ParseManPort (XrdSysError *eDest, XrdOucStream &CFile, char *hSpec)
static const char *	SiteName (int snum)

Detailed Description

Definition at line 40 of file XrdCmsUtils.hh.

Constructor & Destructor Documentation

XrdCmsUtils()

XrdCmsUtils::XrdCmsUtils ( )

inline

Definition at line 112 of file XrdCmsUtils.hh.

{}

~XrdCmsUtils()

XrdCmsUtils::~XrdCmsUtils

(

)

References eDest.

Member Function Documentation

loadPerfMon()

XrdCmsPerfMon * XrdCmsUtils::loadPerfMon ( XrdSysError * eDest, const char * libPath, XrdVersionInfo & urVer )

static

Load the performance monitor plugin.

Parameters

eDest	Pointer to the error message object to route messages.
libPath	A pointer to the shared library path.
urVer	Reference to the caller's version number.

Returns

Pointer to the performance monitor object or nil upon failure.

Definition at line 108 of file XrdCmsUtils.cc.

{
   XrdOucPinLoader perfLib(eDest, &urVer, "cms.perf", libPath);
 
   XrdCmsPerfMon **perfMon = (XrdCmsPerfMon**)perfLib.Resolve("XrdCmsPerfMonitor");
 
   return (perfMon ? *perfMon : 0);
}

References eDest, and XrdOucPinLoader::Resolve().

Referenced by XrdCmsClientConfig::Configure(), and XrdCmsMeter::Monitor().

Here is the call graph for this function:

Here is the caller graph for this function:

ParseMan()

bool XrdCmsUtils::ParseMan ( XrdSysError * eDest, XrdOucTList ** oldMans, char * hSpec, char * hPort, int * sPort = 0, bool hush = false )

static

Obtain and merge a new manager list with an existing list.

Parameters

eDest	Pointer to the error message object to route messages.
oldMans	A pointer to the existing list of managers, if any. If oldMans is nil, then the hSpec/hPort/sPort is processed but no list is returned.
hSpec	the host specification suitable for XrdNetAddr.Set(). The hSpec may end with a '+' indicating that all addresses assigned to hSpec be considered for inclusion.
hPort	the port specification which can be a text number or a service name (e.g. xroot).
sPort	If not nil, the *sPort will be set to the numeric hPort if the IP address in one of the entries matches the host address. Otherwise, the value is unchanged.
hush	When true does not print the dns name to host mappings.

Returns

Success: True and if oldMans is supplied, the additional entries that do not duplicate existing entries are added to the front. Note: *oldMans->val is the port number. *oldMans->text is the host name. The list of objects belongs to the caller. Failure: False. Any existing list is not modified. However, sPort may be updated, if correct, even when false is returned.

Definition at line 123 of file XrdCmsUtils.cc.

{
   static const size_t maxSNLen = 63;
   XrdOucTList *newMans, *newP, *oldP, *appList = (oldMans ? *oldMans : 0);
   XrdOucTList *sP = siteList;
   const char *eText;
   char *plus, *atsn, *iName = 0;
   int nPort, maxIP = 1, snum = 0;
   bool isBad;
 
// Generate local site name if we haven't done so yet
//
   if (!siteList) siteList = GetLocalSite();
 
// Handle site qualification first
//
   if ((atsn = index(hPort, '@')))
      {if (*(atsn+1) == '\0')
          {eDest->Emsg("Config", "site name missing for",  hSpec); return 0;}
       *atsn++ = 0;
       if (strlen(atsn) > maxSNLen)
          {eDest->Emsg("Config", "site name too long for", hSpec); return 0;}
       while(sP && strcmp(sP->text, atsn)) sP = sP->next;
       if (sP) snum = sP->val;
          else {siteIndex++;
                siteList = new XrdOucTList(atsn, siteIndex, siteList);
                snum = siteIndex;
               }
      }
 
// Handle scope qualification next
//
   if ((iName = index(hPort, '%')))
      {if (*(iName+1) == '\0')
          {eDest->Emsg("Config", "instance name missing for", hSpec); return 0;}
       *iName++ = 0;
       const char *xName = getenv("XRDNAME");
       if (!xName || strcmp(xName, iName)) sPort = 0;
      }
 
// Check if this is a multi request
//
   if (!(plus = index(hSpec, '+')) || *(plus+1) != 0) plus = 0;
      else {*plus = 0; maxIP = 8;
            if (XrdNetAddr::DynDNS())
               {eDest->Emsg("Config", "Hostname globbing is not supported "
                                      "via dynamic DNS!");
                return false;
               }
           }
 
// Check if the port was specified
//
   if (isdigit(*hPort))
      {if (XrdOuca2x::a2i(*eDest,"manager port",hPort,&nPort,1,65535))
           return false;
      } else {
       if (!(nPort = XrdNetUtils::ServPort(hPort, "tcp")))
          {eDest->Emsg("Config", "Unable to find tcp service",hPort,".");
           return false;
          }
      }
 
// Obtain the list. We can't fully resolve this now if we are using a dynamic
// DNS so that part will have to wait.
//
   if (XrdNetAddr::DynDNS())
      {if (sPort)
          {XrdNetAddr myAddr(0), urAddr;
           if (!urAddr.Set(hSpec, 0) && myAddr.Same(&urAddr)) *sPort = nPort;
          }
       newMans = new XrdOucTList(hSpec, nPort);
      } else {
       if (!(newMans = XrdNetUtils::Hosts(hSpec, nPort, maxIP, sPort, &eText)))
          {char buff[1024];
           snprintf(buff,sizeof(buff),"'%s'; %c%s",hSpec,tolower(*eText),eText+1);
           eDest->Emsg("Config", "Unable to add host", buff);
           return false;
          }
      }
 
// If there is no pointer to a list, then the caller merely wanted sPort
//
   if (!oldMans)
      {while((newP = newMans)) {newMans = newMans->next; delete newP;}
       return true;
      }
 
// Merge new list with old list
//
   while((newP = newMans))
        {newMans = newMans->next;
         newP->ival[1] = snum;
         oldP = *oldMans;
         while(oldP)
              {if (newP->val == oldP->val && !strcmp(newP->text, oldP->text))
                  {eDest->Say("Config warning: duplicate manager ",newP->text);
                   delete newP;
                   break;
                  }
               oldP = oldP->next;
              }
         if (!oldP)
            {if (!plus || strcmp(hSpec, newP->text)) isBad = false;
                else {eDest->Say("Config warning: "
                                 "Cyclic DNS registration for ",newP->text,"\n"
                                 "Config warning: This cluster will exhibit "
                                 "undefined behaviour!!!");
                      isBad = true;
                     }
             appList = SInsert(appList, newP);
             if (plus && !hush) Display(eDest, hSpec, newP->text, isBad);
            }
        }
 
// Set the new list and return
//
   *oldMans = appList;
   return true;
}

References XrdOuca2x::a2i(), Display(), XrdNetAddr::DynDNS(), eDest, XrdNetUtils::Hosts(), XrdOucTList::next, XrdNetUtils::ServPort(), XrdNetAddr::Set(), and XrdOucTList::text.

Here is the call graph for this function:

ParseManPort()

char * XrdCmsUtils::ParseManPort ( XrdSysError * eDest, XrdOucStream & CFile, char * hSpec )

static

Obtain the port for a manager specification

Parameters

eDest	Pointer to the error message object to route messages.
CFile	The configuration file stream.
hSpec	The initial manager specification which may or may not have the port number in it.

Returns

Success: Pointer to a copy of the port specification. The caller is responsible for freeing it using free(). Failure: A nil pointer. An error message has already been issued.

Definition at line 249 of file XrdCmsUtils.cc.

{
   char *pSpec;
 
// Screen out IPV6 specifications
//
   if (*hSpec == '[')
      {if (!(pSpec = index(hSpec, ']')))
          {eDest->Emsg("Config", "Invalid manager specification -",hSpec);
           return 0;
          }
      } else pSpec = hSpec;
 
// Grab the port number if in the host name. Otherwise make sure it follows.
//
         if ((pSpec = index(pSpec, ':')))
            {if (!(*(pSpec+1))) pSpec = 0;
                else *pSpec++ = '\0';
            }
    else if (!(pSpec = CFile.GetWord()) || !strcmp(pSpec, "if")) pSpec = 0;
 
// We should have a port specification now
//
   if (!pSpec) {eDest->Emsg("Config", "manager port not specified for", hSpec);
                return 0;
               }
 
// All is well
//
   return strdup(pSpec);
}

References eDest, and XrdOucStream::GetWord().

Here is the call graph for this function:

SiteName()

const char * XrdCmsUtils::SiteName ( int snum )

static

Translate site number to site name.

Parameters

snum	The site number.

Returns

Pointer to the corresponding site name (anonymous if none).

Definition at line 310 of file XrdCmsUtils.cc.

{
   XrdOucTList *sP = siteList;
 
// Find matching site
//
   while(sP && snum != sP->val) sP = sP->next;
 
// Return result
//
   return (sP ? sP->text : "anonymous");
}

References XrdOucTList::next, and XrdOucTList::text.

Referenced by XrdCmsManager::Verify().

Here is the caller graph for this function:

---

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

• XrdCmsUtils.hh
• XrdCmsUtils.cc