XrdCmsManager Class Reference

#include <XrdCmsManager.hh>

Collaboration diagram for XrdCmsManager:

Public Member Functions
	XrdCmsManager (XrdOucTList *mlP, int snum)
	~XrdCmsManager ()
XrdCmsNode *	Add (XrdLink *lp, int Lvl, bool &xit)
void	Delete (XrdCmsNode *nodeP)
void	Finished (const char *manP, int mPort)
void	Remove (XrdCmsNode *nP, const char *reason=0)
void	Rerun (char *newMans)
bool	Verify (XrdLink *lP, const char *sid, const char *sname)

Static Public Member Functions
static void	Inform (const char *What, const char *Data, int Dlen)
static void	Inform (const char *What, struct iovec *vP, int vN, int vT=0)
static void	Inform (XrdCms::CmsReqCode rCode, int rMod, const char *Arg=0, int Alen=0)
static void	Inform (XrdCms::CmsRRHdr &Hdr, const char *Arg=0, int Alen=0)
static bool	Present ()
static void	Reset ()
static bool	Start (const XrdOucTList *mL)

Public Attributes
XrdCmsManTree *	ManTree
XrdCmsManList *	myMans

Static Public Attributes
static const int	MTMax = 16

Friends
class	XrdCmsDelNode

Detailed Description

Definition at line 55 of file XrdCmsManager.hh.

Constructor & Destructor Documentation

XrdCmsManager()

XrdCmsManager::XrdCmsManager	(	XrdOucTList *	mlP,
		int	snum )

Definition at line 102 of file XrdCmsManager.cc.

{
     myMans    = 0;
     ManTree   = 0;
     curManCnt = 0;
     curManList= mlP;
     newManList= 0;
     theSite   = 0;
     theHost   = 0;
     theSID    = 0;
     siteID    = snum;
     wasRedir  = false;
}

References ManTree, and myMans.

Referenced by Start().

Here is the caller graph for this function:

~XrdCmsManager()

XrdCmsManager::~XrdCmsManager ( )

inline

Definition at line 89 of file XrdCmsManager.hh.

{} // This object should never be deleted

Member Function Documentation

Add()

XrdCmsNode * XrdCmsManager::Add	(	XrdLink *	lp,
		int	Lvl,
		bool &	xit )

Definition at line 120 of file XrdCmsManager.cc.

{
   EPNAME("Add")
   XrdCmsNode *nP;
   int i;
 
// Check if there is a pending reconfiguration. If so, return no node but
// tell the caller to finish so we can proceed with the reconfiguration
//
   MTMutex.Lock();
   lp->setID("manager",0);
   if (newManList) {MTMutex.UnLock(); xit = true; return 0;}
   xit = false;
 
// Find available ID for this node
//
   for (i = 0; i < MTMax; i++) if (!MastTab[i]) break;
 
// Check if we have too many here
//
   if (i >= MTMax)
      {MTMutex.UnLock();
       Say.Emsg("Manager", "Login to", lp->Name(), "failed; too many managers");
       return 0;
      }
 
// Obtain a new a new node object
//
   if (!(nP = new XrdCmsNode(lp, 0, 0, 0, Lvl, i)))
        {Say.Emsg("Manager", "Unable to obtain node object."); return 0;}
 
// Assign new manager
//
   MastTab[i] = nP;
   MastSID[i] = siteID;
   if (i > MTHi) MTHi = i;
   nP->isOffline  = 0;
   nP->isNoStage  = 0;
   nP->isBad      = 0;
   nP->isBound    = 1;
   nP->isConn     = 1;
   nP->isMan      = (Config.asManager() ? 1 : 0);
   nP->setManager(this);
   MTMutex.UnLock();
 
// Document login
//
   DEBUG(nP->Name() <<" to manager config; id=" <<i);
   return nP;
}

References XrdCms::Config, DEBUG, EPNAME, XrdCmsNode::isBad, XrdCmsNode::isBound, XrdCmsNode::isConn, XrdCmsNode::isMan, XrdCmsNode::isNoStage, XrdCmsNode::isOffline, XrdCmsNode::Lock(), MTMax, XrdCmsNode::Name(), XrdLink::Name(), XrdCms::Say, XrdLink::setID(), and XrdCmsNode::setManager().

Here is the call graph for this function:

Delete()

void XrdCmsManager::Delete

(

XrdCmsNode *

nodeP

)

Definition at line 175 of file XrdCmsManager.cc.

{
     new XrdCmsDelNode(nodeP);
}

References XrdCmsDelNode.

Here is the call graph for this function:

Finished()

void XrdCmsManager::Finished	(	const char *	manP,
		int	mPort )

Definition at line 184 of file XrdCmsManager.cc.

{
   XrdOucTList *mP;
   char mbuff[16];
 
// Indicate what we are disbanding
//
   sprintf(mbuff, ":%d", mPort);
   Say.Say("Config ", "Manager ", manP, mbuff, " unconfigured.");
 
// Serialize
//
   MTMutex.Lock();
 
// If this is this is the last manager connection and we have a pending new
// list of managers, run those now. We waited so as to not overwhelm the system.
//
   curManCnt--;
   if (curManCnt > 0 || !newManList) {MTMutex.UnLock(); return;}
 
// Remove all vestigial information
//
   for (int i = 0; i <= MTHi; i++)
       {if (MastSID[i] == siteID) {MastTab[i] = 0; MastSID[i] = 0;}}
 
// Readjust the high water mark
//
   while(MTHi >= 0 && !MastTab[MTHi]) MTHi--;
 
// Delete the current manager list, it is safe to do so
//
   while((mP = curManList)) {curManList = curManList->next; delete mP;}
   curManList = newManList;
   newManList = 0;
 
// Run the new manager setup
//
   Say.Say("Config ","Manager subsystem reconfiguration completed; restarting.");
   Run(curManList);
 
// All done
//
   MTMutex.UnLock();
}

References XrdCms::Say.

Inform() [1/4]

void XrdCmsManager::Inform ( const char * What, const char * Data, int Dlen )

static

Definition at line 233 of file XrdCmsManager.cc.

{
   EPNAME("Inform");
   XrdCmsNode *nP;
   int i;
 
// Obtain a lock on the table
//
   MTMutex.Lock();
 
// Run through the table looking for managers to send messages to
//
   for (i = 0; i <= MTHi; i++)
       {if ((nP=MastTab[i]) && !nP->isOffline)
           {nP->Lock();
            MTMutex.UnLock();
            DEBUG(nP->Name() <<" " <<What);
            nP->Send(Data, Dlen);
            nP->UnLock();
            MTMutex.Lock();
           }
       }
   MTMutex.UnLock();
}

References DEBUG, EPNAME, XrdCmsNode::isOffline, XrdCmsNode::Lock(), XrdCmsNode::Name(), XrdCmsNode::Send(), and XrdCmsNode::UnLock().

Referenced by XrdCmsNode::do_Gone(), XrdCmsNode::do_Have(), XrdCmsNode::do_Space(), Inform(), Inform(), XrdCmsState::Monitor(), XrdCmsAdmin::RelayAREvent(), and XrdCmsNode::Report_Usage().

Here is the call graph for this function:

Here is the caller graph for this function:

Inform() [2/4]

void XrdCmsManager::Inform ( const char * What, struct iovec * vP, int vN, int vT = 0 )

static

Definition at line 260 of file XrdCmsManager.cc.

{
   EPNAME("Inform");
   int i;
   XrdCmsNode *nP;
 
// Obtain a lock on the table
//
   MTMutex.Lock();
 
// Run through the table looking for managers to send messages to
//
   for (i = 0; i <= MTHi; i++)
       {if ((nP=MastTab[i]) && !nP->isOffline)
           {nP->Lock();
            MTMutex.UnLock();
            DEBUG(nP->Name() <<" " <<What);
            nP->Send(vP, vN, vT);
            nP->UnLock();
            MTMutex.Lock();
           }
       }
   MTMutex.UnLock();
}

References DEBUG, EPNAME, XrdCmsNode::isOffline, XrdCmsNode::Lock(), XrdCmsNode::Name(), XrdCmsNode::Send(), and XrdCmsNode::UnLock().

Here is the call graph for this function:

Inform() [3/4]

void XrdCmsManager::Inform ( XrdCms::CmsReqCode rCode, int rMod, const char * Arg = 0, int Alen = 0 )

static

Definition at line 287 of file XrdCmsManager.cc.

{
  CmsRRHdr Hdr = {0, (kXR_char)rCode, (kXR_char)rMod,
                    htons(static_cast<unsigned short>(Alen))};
    struct iovec ioV[2] = {{(char *)&Hdr, sizeof(Hdr)},
                           {(char *)Arg, (size_t)Alen}};
 
    Inform(Router.getName((int)rCode), ioV, (Arg ? 2 : 1), Alen+sizeof(Hdr));
}

References Inform(), and XrdCms::Router.

Here is the call graph for this function:

Inform() [4/4]

void XrdCmsManager::Inform ( XrdCms::CmsRRHdr & Hdr, const char * Arg = 0, int Alen = 0 )

static

Definition at line 300 of file XrdCmsManager.cc.

{
    struct iovec ioV[2] = {{(char *)&Hdr, sizeof(Hdr)},
                           {(char *)Arg, (size_t)Alen}};
 
    Hdr.datalen = htons(static_cast<unsigned short>(Alen));
 
    Inform(Router.getName(Hdr.rrCode), ioV, (Arg ? 2 : 1), Alen+sizeof(Hdr));
}

References XrdCms::CmsRRHdr::datalen, Inform(), XrdCms::Router, and XrdCms::CmsRRHdr::rrCode.

Here is the call graph for this function:

Present()

static bool XrdCmsManager::Present ( )

inlinestatic

Definition at line 76 of file XrdCmsManager.hh.

{return MTHi >= 0;};

Referenced by XrdCmsNode::do_Gone(), and XrdCmsNode::do_Have().

Here is the caller graph for this function:

Remove()

void XrdCmsManager::Remove	(	XrdCmsNode *	nP,
		const char *	reason = 0 )

Definition at line 314 of file XrdCmsManager.cc.

{
   EPNAME("Remove")
   int sinst, sent = nP->ID(sinst);
 
// Obtain a lock on the servtab
//
   MTMutex.Lock();
 
// Make sure this node is the right one
//
   if (!(nP == MastTab[sent]))
      {MTMutex.UnLock();
       DEBUG("manager " <<sent <<'.' <<sinst <<" failed.");
       return;
      }
 
// Remove node from the manager table
//
   MastTab[sent] = 0;
   MastSID[sent] = 0;
   nP->isOffline = 1;
   DEBUG("completed " <<nP->Name() <<" manager " <<sent <<'.' <<sinst);
 
// Readjust MTHi
//
   if (sent == MTHi) while(MTHi >= 0 && !MastTab[MTHi]) MTHi--;
   MTMutex.UnLock();
 
// Document removal
//                                                                             .
   if (reason) Say.Emsg("Manager", nP->Ident, "removed;", reason);
}

References DEBUG, EPNAME, XrdCmsNode::ID(), XrdCmsNode::Ident, XrdCmsNode::isOffline, XrdCmsNode::Name(), and XrdCms::Say.

Here is the call graph for this function:

Rerun()

void XrdCmsManager::Rerun

(

char *

newMans

)

Definition at line 352 of file XrdCmsManager.cc.

{
   static CmsDiscRequest discRequest = {{0, kYR_disc, 0, 0}};
   XrdOucTList *tP;
   const char *eText;
   char *hP;
   int newManCnt = 0;
 
// Lock ourselves
//
   MTMutex.Lock();
   wasRedir = true;
 
// If we already have a pending new sequence, then just return
//
   if (newManList) {MTMutex.UnLock(); return;}
 
// Indicate that we will be re-initialzing
//
   Say.Say("Config ", "Manager subsystem reconfiguring using ", newMans);
 
// Process the new man list
//
   XrdNetAddr manAddr;
   XrdOucTokenizer mList((char *)newMans);
   hP = mList.GetLine();
 
// Add each manager in the list. These have already been expanded and are
// gaurenteed to contain a port number as the list is provided by the cmsd.
// However, we will check for duplicates and ignore any overage.
//
   while((hP = mList.GetToken()))
        {if ((eText = manAddr.Set(hP)))
            {Say.Emsg("Config","Ignoring manager", hP, eText); continue;}
         tP = newManList;
         while(tP && strcmp(hP, tP->text)) tP = tP->next;
         if (tP) {Say.Emsg("Config","Ignoring duplicate manager", hP);
                  continue;
                 }
         if (newManCnt >=MTMax)
            {Say.Emsg("Config","Ignoring manager", hP,
                               "and remaining entries; limit exceeded!");
             break;
            }
         newManList = new XrdOucTList(manAddr.Name(),manAddr.Port(),newManList);
         newManCnt++;
        }
 
// If we have managers then tell the cluster builder to abort as we will
// be restarting this whole process (we don't want any hung nodes here).
//
   if (newManCnt) ManTree->Abort();
 
// Now run through the node table and doom all current site connections as we
// need to reinitialize the whole manager subsystem. Note that none of these
// objects can escape without us removing them from the table.
//
   if (newManCnt)
      {for (int i = 0; i <= MTHi; i++)
           if (MastTab[i] && (MastSID[i] == siteID))
              {MastTab[i]->isBad |= XrdCmsNode::isBlisted|XrdCmsNode::isDoomed;
               MastTab[i]->Send((char *)&discRequest, sizeof(discRequest));
              }
      }
 
// We are done
//
   MTMutex.UnLock();
}

References XrdOucTokenizer::GetLine(), XrdOucTokenizer::GetToken(), XrdCmsNode::isBlisted, XrdCmsNode::isDoomed, XrdCms::kYR_disc, ManTree, MTMax, XrdNetAddrInfo::Name(), XrdOucTList::next, XrdNetAddr::Port(), XrdCms::Say, XrdNetAddr::Set(), and XrdOucTList::text.

Here is the call graph for this function:

Reset()

void XrdCmsManager::Reset ( )

static

Definition at line 426 of file XrdCmsManager.cc.

{
   EPNAME("Reset");
   static CmsStatusRequest myState = {{0, kYR_status, 
                                       CmsStatusRequest::kYR_Reset, 0}};
   static const int        szReqst = sizeof(CmsStatusRequest);
   XrdCmsNode *nP;
   int i;
 
// Obtain a lock on the table
//
   MTMutex.Lock();
 
// Run through the table looking for managers to send a reset request
//
   for (i = 0; i <= MTHi; i++)
       {if ((nP=MastTab[i]) && !nP->isOffline && nP->isKnown)
           {nP->Lock();
            nP->isKnown = 0;
            MTMutex.UnLock();
            DEBUG("sent to " <<nP->Name());
            nP->Send((char *)&myState, szReqst);
            nP->UnLock();
            MTMutex.Lock();
           }
       }
   MTMutex.UnLock();
}

References DEBUG, EPNAME, XrdCmsNode::isKnown, XrdCmsNode::isOffline, XrdCms::CmsStatusRequest::kYR_Reset, XrdCms::kYR_status, XrdCmsNode::Lock(), XrdCmsNode::Name(), XrdCmsNode::Send(), and XrdCmsNode::UnLock().

Referenced by XrdCmsNode::do_Status().

Here is the call graph for this function:

Here is the caller graph for this function:

Start()

bool XrdCmsManager::Start ( const XrdOucTList * mL )

static

Definition at line 522 of file XrdCmsManager.cc.

{
   XrdOucTList *manVec[MTMax] = {0};
   XrdCmsManager *manP;
   char buff[1024];
   int n, sid, snum = 0, mtot = 0, mnum = 0, xnum = 0;
 
// If there is no manager list then we must not be connecting to anyone
//
   if (!mL) return true;
  
// Segregate the manager list by site and run them that way. Unfortunately,
// that means we have to copy the TList. This ok as this happens once.
//
   while(mL)
        {sid = mL->ival[1]; mtot++;
         if (sid >= MTMax)
            {sprintf(buff, "%d", sid);
             Say.Say("Config ", "Invalid site ID ", buff, " for ", mL->text);
            } else {
             manVec[sid] = new XrdOucTList(mL->text, mL->val, manVec[sid]);
             mnum++;
            }
          mL = mL->next;
        }
 
// Count how many sites we have
//
   for (n = 0; n < MTMax; n++) if (manVec[n]) snum++;
 
// Indicate what we are about to do
//
   snprintf(buff, sizeof(buff),"%d manager%s and %d site%s.", mnum,
                              (mnum != 1 ? "s":""), snum, (snum != 1 ? "s":""));
   Say.Say("Config Connecting to ", buff);
 
// Now run each one
//
   for (n = 0; n < MTMax; n++)
       {if (manVec[n])
           {manP = new XrdCmsManager(manVec[n], n);
            xnum += manP->Run(manVec[n]);
           }
       }
 
// Check if we should issue a warning
//
   if (xnum < mtot)
      {snprintf(buff, sizeof(buff), "%d of %d", xnum, mtot);
       Say.Say("Config Warning! Only ", buff, " manager(s) will be contacted!");
      }
 
// All done
//
   return xnum == mtot;
}

References XrdCmsManager(), MTMax, XrdOucTList::next, XrdCms::Say, and XrdOucTList::text.

Referenced by XrdCmsConfig::DoIt().

Here is the call graph for this function:

Here is the caller graph for this function:

Verify()

bool XrdCmsManager::Verify	(	XrdLink *	lP,
		const char *	sid,
		const char *	sname )

Definition at line 583 of file XrdCmsManager.cc.

{
   XrdSysMutexHelper hMutex(MTMutex);
   const char *sidP;
 
// Trim off the type of service in the sid
//
   if ((sidP = index(sid, ' '))) sidP++;
      else sidP = sid;
 
// If we have no sid, just record it
//
   if (!theSID)
      {theSID = strdup(sidP);
       if (theSite) free(theSite);
       theHost = strdup(lP->Host());
       theSite = (sname ? strdup(sname) : strdup("anonymous"));
       return true;
      }
 
// Make sure we are connecting to the same cluster as before
//
   if (!strcmp(theSID, sidP)) return true;
 
// Compute the offending site configuration
//
   char mBuff[1024];
   snprintf(mBuff,sizeof(mBuff),"%s for site %s; "
            "making file location unpredictable!", theHost,
            (wasRedir ? theSite : XrdCmsUtils::SiteName(siteID)));
 
// There seems to be a configuration error here
//
   Say.Emsg("Manager", lP->Host(), "manager configuration differs from", mBuff);
   return false;
}

References XrdLink::Host(), XrdCms::Say, and XrdCmsUtils::SiteName().

Here is the call graph for this function:

Friends And Related Symbol Documentation

XrdCmsDelNode

friend class XrdCmsDelNode

friend

Definition at line 58 of file XrdCmsManager.hh.

References XrdCmsDelNode.

Referenced by Delete(), and XrdCmsDelNode.

Member Data Documentation

ManTree

XrdCmsManTree* XrdCmsManager::ManTree

Definition at line 61 of file XrdCmsManager.hh.

Referenced by XrdCmsManager(), and Rerun().

MTMax

const int XrdCmsManager::MTMax = 16

static

Definition at line 63 of file XrdCmsManager.hh.

Referenced by Add(), Rerun(), and Start().

myMans

XrdCmsManList* XrdCmsManager::myMans

Definition at line 60 of file XrdCmsManager.hh.

Referenced by XrdCmsManager().

---

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

• XrdCmsManager.hh
• XrdCmsManager.cc