XrdCmsClustID Class Reference

#include <XrdCmsClustID.hh>

Collaboration diagram for XrdCmsClustID:

Public Member Functions
	XrdCmsClustID ()
	~XrdCmsClustID ()
bool	AddNode (XrdCmsNode *nP, bool isMan)
bool	Avail ()
bool	Exists (XrdLink *lp, const char *nid, int port)
bool	IsEmpty ()
bool	IsSingle ()
XrdCmsNode *	RemNode (XrdCmsNode *nP)
int	Slot ()

Static Public Member Functions
static XrdCmsClustID *	AddID (const char *cID)
static XrdCmsClustID *	Find (const char *cID)
static SMask_t	Mask (const char *cID)

Detailed Description

Definition at line 40 of file XrdCmsClustID.hh.

Constructor & Destructor Documentation

XrdCmsClustID()

XrdCmsClustID::XrdCmsClustID ( )

inline

Definition at line 64 of file XrdCmsClustID.hh.

                       : cidMask(0), cidName(0), ntSlot(-1), npNum(0)
                         {memset(nodeP, 0, sizeof(nodeP));}

Referenced by AddID().

Here is the caller graph for this function:

~XrdCmsClustID()

XrdCmsClustID::~XrdCmsClustID ( )

inline

Definition at line 67 of file XrdCmsClustID.hh.

{if (cidName) free(cidName);}

Member Function Documentation

AddID()

XrdCmsClustID * XrdCmsClustID::AddID ( const char *  cID )

static

Definition at line 57 of file XrdCmsClustID.cc.

{
   XrdCmsClustID *cidObj;
   const char *cHN;
   char *clustID;
 
// Massage the clusterid (it's in bi-compatible format)
//
   if ((cHN = rindex(cID, ' ')) && *(cHN+1)) cID = cHN+1;
   clustID = strdup(cID);
 
// Lock ourselves
//
   cidMtx.Lock();
 
// Allocate a new cluster ID object if we don't have one ready
//
   if (!cidFree) cidFree = new XrdCmsClustID();
 
// Attempt to add this object to our cid table
//
   if (!(cidObj = cidTab.Add(clustID, cidFree, 0, Hash_keep)))
      {cidObj = cidFree;
       cidObj->cidName = clustID;
       cidFree = new XrdCmsClustID();
      } else free(clustID);
 
// We can unlock now
//
   cidMtx.UnLock();
 
// Return the entry
//
   return cidObj;
}

References XrdCmsClustID(), and Hash_keep.

Referenced by XrdCmsCluster::Add().

Here is the call graph for this function:

Here is the caller graph for this function:

AddNode()

bool XrdCmsClustID::AddNode	(	XrdCmsNode *	nP,
		bool	isMan
	)

Definition at line 97 of file XrdCmsClustID.cc.

{
   EPNAME("AddNode");
   XrdSysMutexHelper cidHelper(cidMtx);
   int iNum, sNum;
 
// For servers we only add the identification mask
//
   if (!isMan)
      {cidMask |= nP->Mask();
       DEBUG("srv " <<nP->Ident <<" cluster " <<cidName <<" anum=" <<npNum);
       return true;
      }
 
// Make sure we have enough space in the table
//
   if (npNum >= altMax)
      {Say.Emsg("ClustID",cidName,"alternate table full; rejecting",nP->Name());
       return false;
      }
 
// Make sure the slot numbers match for this node
//
   sNum = nP->ID(iNum);
   if (npNum > 0 && ntSlot != sNum)
      {char buff[256];
       sprintf(buff,"cluster slot mismatch: %d != %d; rejecting",sNum,ntSlot);
       Say.Emsg("ClustID", cidName, buff, nP->Name());
       return false;
      }
 
// Add the entry to the table
//
   ntSlot = sNum;
   cidMask |= nP->Mask();
   nodeP[npNum++] = nP;
   DEBUG("man " <<nP->Ident <<" cluster " <<cidName <<" anum=" <<npNum);
   return true;
}

References DEBUG, XrdSysError::Emsg(), EPNAME, XrdCmsNode::ID(), XrdCmsNode::Ident, XrdCmsNode::Mask(), XrdCmsNode::Name(), and XrdCms::Say.

Referenced by XrdCmsCluster::Add().

Here is the call graph for this function:

Here is the caller graph for this function:

Avail()

bool XrdCmsClustID::Avail ( )

inline

Definition at line 48 of file XrdCmsClustID.hh.

{return npNum < altMax;}

Exists()

bool XrdCmsClustID::Exists	(	XrdLink *	lp,
		const char *	nid,
		int	port
	)

Definition at line 141 of file XrdCmsClustID.cc.

{
   XrdSysMutexHelper cidHelper(cidMtx);
 
// Simply scan the table to see if this node is present
//
   for (int i = 0; i <npNum; i++)
       {if (nodeP[i]->isNode(lp, nid, port)) return true;}
   return false;
}

Find()

XrdCmsClustID * XrdCmsClustID::Find ( const char *  cID )

static

Definition at line 156 of file XrdCmsClustID.cc.

{
   XrdCmsClustID *cidObj;
   const char *cHN;
 
// Massage the clusterid (it's in bi-compatible format)
//
   if ((cHN = rindex(cID, ' ')) && *(cHN+1)) cID = cHN+1;
 
// Lock ourselves
//
   cidMtx.Lock();
 
// Attempt to find the cluster object
//
   cidObj = cidTab.Find(cID);
 
// We can unlock now
//
   cidMtx.UnLock();
 
// Return the entry
//
   return cidObj;
}

References Find().

Referenced by XrdCmsCluster::Add(), Find(), and Mask().

Here is the call graph for this function:

Here is the caller graph for this function:

IsEmpty()

bool XrdCmsClustID::IsEmpty ( )

inline

Definition at line 56 of file XrdCmsClustID.hh.

{return npNum < 1;}

Referenced by XrdCmsCluster::Add().

Here is the caller graph for this function:

IsSingle()

bool XrdCmsClustID::IsSingle ( )

inline

Definition at line 58 of file XrdCmsClustID.hh.

{return npNum == 1;}

Referenced by XrdCmsCluster::Remove().

Here is the caller graph for this function:

Mask()

SMask_t XrdCmsClustID::Mask ( const char *  cID )

static

Definition at line 186 of file XrdCmsClustID.cc.

{
   XrdCmsClustID *cidObj;
   SMask_t        theMask;
   const char *cHN;
 
// Massage the clusterid (it's in bi-compatible format)
//
   if ((cHN = rindex(cID, ' ')) && *(cHN+1)) cID = cHN+1;
 
// Lock ourselves
//
   cidMtx.Lock();
 
// Attempt to find the cluster object
//
   if ((cidObj = cidTab.Find(cID))) theMask = cidObj->cidMask;
      else theMask = 0;
 
// We can unlock now
//
   cidMtx.UnLock();
 
// Return the mask
//
   return theMask;
}

References Find().

Referenced by XrdCmsCluster::getMask().

Here is the call graph for this function:

Here is the caller graph for this function:

RemNode()

XrdCmsNode * XrdCmsClustID::RemNode

(

XrdCmsNode *

nP

)

Definition at line 218 of file XrdCmsClustID.cc.

{
   EPNAME("RemNode");
   bool didRM = false;
 
// For servers we only need to remove the mask
//
   if (!(nP->isMan | nP->isPeer))
      {cidMask &= ~(nP->Mask());
       DEBUG("srv " <<nP->Ident <<" cluster " <<cidName <<" anum=" <<npNum);
       return 0;
      }
 
// Find the node to remove. This may require a fill in.
//
   for (int i = 0; i < npNum; i++)
       if (nP == nodeP[i])
          {npNum--;
           if (i < npNum && npNum) nodeP[i] = nodeP[npNum];
              else nodeP[i] = 0;
           didRM = true;
           break;
          }
 
// If there are no more nodes in this table, then remove the id mask
//
   if (!npNum) cidMask &= ~(nP->Mask());
 
// Do some debugging and return what we have in the table
//
   DEBUG("man " <<nP->Ident <<" cluster " <<cidName <<" anum=" <<npNum
         <<(didRM ? "" : " n/p"));
   return (npNum ? nodeP[0] : 0);
}

References DEBUG, EPNAME, XrdCmsNode::Ident, XrdCmsNode::isMan, XrdCmsNode::isPeer, and XrdCmsNode::Mask().

Referenced by XrdCmsNode::~XrdCmsNode(), and XrdCmsCluster::Remove().

Here is the call graph for this function:

Here is the caller graph for this function:

Slot()

int XrdCmsClustID::Slot ( )

inline

Definition at line 62 of file XrdCmsClustID.hh.

{return ntSlot;}

---

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

• XrdCmsClustID.hh
• XrdCmsClustID.cc