XrdCmsState Class Reference

#include <XrdCmsState.hh>

Collaboration diagram for XrdCmsState:

Public Types
enum	StateType {   Active = 0 ,   Counts ,   FrontEnd ,   Space ,   Stage }

Public Member Functions
	XrdCmsState ()
	~XrdCmsState ()
void	Enable ()
void *	Monitor ()
int	Port ()
void	sendState (XrdLink *Link)
void	Set (int ncount)
void	Set (int ncount, int isman, const char *AdminPath)
void	Update (StateType StateT, int ActivVal, int StageVal=0)

Public Attributes
int	NoStaging
int	Suspended

Static Public Attributes
static const char	All_NoStage = 4
static const char	All_Suspend = 3
static const char	FES_Suspend = 2
static const char	SRV_Suspend = 1

Detailed Description

Definition at line 38 of file XrdCmsState.hh.

Member Enumeration Documentation

StateType

enum XrdCmsState::StateType

Enumerator
Active
Counts
FrontEnd
Space
Stage

Definition at line 56 of file XrdCmsState.hh.

{Active = 0, Counts, FrontEnd, Space, Stage};

Constructor & Destructor Documentation

XrdCmsState()

XrdCmsState::XrdCmsState

(

)

Definition at line 61 of file XrdCmsState.cc.

                         : mySemaphore(0)
{
   minNodeCnt   = 1;
   numActive    = 0;
   numStaging   = 0;
   currState    = All_NoStage | All_Suspend;
   prevState    = 0;
   Suspended    = All_Suspend;
   NoStaging    = All_NoStage;
   feOK         = 0;
   noSpace      = 0;
   adminNoStage = 0;
   adminSuspend = 0;
   NoStageFile  = "";
   SuspendFile  = "";
   isMan        = 0;
   dataPort     = 0;
   Enabled      = 0;
}

References All_NoStage, All_Suspend, NoStaging, and Suspended.

~XrdCmsState()

XrdCmsState::~XrdCmsState ( )

inline

Definition at line 61 of file XrdCmsState.hh.

{}

Member Function Documentation

Enable()

void XrdCmsState::Enable

(

)

Definition at line 85 of file XrdCmsState.cc.

{
   struct stat buff;
 
// Set correct admin staging state
//
   Update(Stage, stat(NoStageFile, &buff));
 
// Set correct admin suspend state
//
   Update(Active, stat(SuspendFile, &buff));
 
// We will force the information to be sent to interested parties by making
// the previous state different from the current state and enabling ourselves.
//
   myMutex.Lock();
   Enabled = 1;
   prevState = ~currState;
   mySemaphore.Post();
   myMutex.UnLock();
}

References Active, XrdSysMutex::Lock(), XrdSysSemaphore::Post(), Stage, stat, XrdSysMutex::UnLock(), and Update().

Referenced by XrdCmsConfig::DoIt().

Here is the call graph for this function:

Here is the caller graph for this function:

Monitor()

void * XrdCmsState::Monitor

(

)

Definition at line 111 of file XrdCmsState.cc.

{
   CmsStatusRequest myStatus = {{0, kYR_status, 0, 0}};
   int RTsend, theState, Changes, myPort;
 
// Do this forever (we are only posted when finally enabled)
//
   do {mySemaphore.Wait();
       myMutex.Lock(); 
       Changes   = currState ^ prevState;
       theState  = currState;
       prevState = currState;
       myPort    = dataPort;
       myMutex.UnLock();
 
       if (Changes && (myStatus.Hdr.modifier = Status(Changes, theState)))
          {if (myStatus.Hdr.modifier & CmsStatusRequest::kYR_Resume)
                    {myStatus.Hdr.streamid = htonl(myPort); RTsend = 1;}
               else {myStatus.Hdr.streamid = 0;
                     RTsend = (isMan > 0 ? (theState & SRV_Suspend) : 0);
                    }
           if (isMan && RTsend)
              RTable.Send("status", (char *)&myStatus, sizeof(myStatus));
           XrdCmsManager::Inform(myStatus.Hdr);
          }
      } while(1);
 
// All done
//
   return (void *)0;
}

References XrdCms::CmsStatusRequest::Hdr, XrdCmsManager::Inform(), XrdCms::CmsStatusRequest::kYR_Resume, XrdCms::kYR_status, XrdSysMutex::Lock(), XrdCms::CmsRRHdr::modifier, XrdCmsRTable::Send(), SRV_Suspend, XrdCms::CmsRRHdr::streamid, XrdSysMutex::UnLock(), and XrdSysSemaphore::Wait().

Referenced by XrdCmsStartMonStat().

Here is the call graph for this function:

Here is the caller graph for this function:

Port()

int XrdCmsState::Port

(

)

Definition at line 147 of file XrdCmsState.cc.

{
    int xPort;
 
    myMutex.Lock(); 
    xPort = dataPort;
    myMutex.UnLock();
    return xPort;
}

References XrdSysMutex::Lock(), and XrdSysMutex::UnLock().

Here is the call graph for this function:

sendState()

void XrdCmsState::sendState

(

XrdLink *

Link

)

Definition at line 161 of file XrdCmsState.cc.

{
   CmsStatusRequest myStatus = {{0, kYR_status, 0, 0}};
 
   myMutex.Lock();
   myStatus.Hdr.modifier  = Suspended
                          ? CmsStatusRequest::kYR_Suspend
                          : CmsStatusRequest::kYR_Resume;
 
   myStatus.Hdr.modifier |= NoStaging
                          ? CmsStatusRequest::kYR_noStage
                          : CmsStatusRequest::kYR_Stage;
 
   lp->Send((char *)&myStatus.Hdr, sizeof(myStatus.Hdr));
   myMutex.UnLock();
}

References XrdCms::CmsStatusRequest::Hdr, XrdCms::CmsStatusRequest::kYR_noStage, XrdCms::CmsStatusRequest::kYR_Resume, XrdCms::CmsStatusRequest::kYR_Stage, XrdCms::kYR_status, XrdCms::CmsStatusRequest::kYR_Suspend, XrdSysMutex::Lock(), XrdCms::CmsRRHdr::modifier, NoStaging, XrdLink::Send(), Suspended, and XrdSysMutex::UnLock().

Referenced by XrdCmsNode::do_Update().

Here is the call graph for this function:

Here is the caller graph for this function:

Set() [1/2]

void XrdCmsState::Set

(

int

ncount

)

Definition at line 182 of file XrdCmsState.cc.

{
 
// Set the node count (this requires a lock)
//
   myMutex.Lock(); 
   minNodeCnt = ncount;
   myMutex.UnLock();
}

References XrdSysMutex::Lock(), and XrdSysMutex::UnLock().

Referenced by XrdCmsCluster::Add(), and XrdCmsConfig::Configure2().

Here is the call graph for this function:

Here is the caller graph for this function:

Set() [2/2]

void XrdCmsState::Set	(	int	ncount,
		int	isman,
		const char *	AdminPath
	)

Definition at line 194 of file XrdCmsState.cc.

{
   char fnbuff[1048];
   int i;
 
// This is a configuration call no locks are required.
//
   minNodeCnt = ncount;
   isMan = isman;
   i = strlen(AdminPath);
   strcpy(fnbuff, AdminPath);
   if (AdminPath[i-1] != '/') fnbuff[i++] = '/';
   strcpy(fnbuff+i, "NOSTAGE");
   NoStageFile = strdup(fnbuff);
   strcpy(fnbuff+i, "SUSPEND");
   SuspendFile = strdup(fnbuff);
}

Update()

void XrdCmsState::Update	(	StateType	StateT,
		int	ActivVal,
		int	StageVal = 0
	)

Definition at line 258 of file XrdCmsState.cc.

{
  EPNAME("Update");
  const char *What;
  char newVal;
 
// Create new state
//
   myMutex.Lock();
   switch(StateT)
         {case Active:   if ((newVal = ActivCnt ? 0 : 1) != adminSuspend)
                            {     if ( newVal && !StageCnt) unlink(SuspendFile);
                             else if (!newVal || !StageCnt) unlink(SuspendFile);
                             else close(open(SuspendFile, O_WRONLY|O_CREAT,
                                                          S_IRUSR|S_IWUSR));
                             adminSuspend = newVal;
                            }
                         What = "Active";
                         break;
          case Counts:   numStaging += StageCnt;
                         numActive  += ActivCnt;
                         What = "Counts";
                         break;
          case FrontEnd: if ((feOK = (ActivCnt ? 1 : 0)) && StageCnt >= 0)
                            dataPort = StageCnt;
                         What = "FrontEnd";
                         break;
          case Space:    noSpace = (ActivCnt ? 0 : 1);
                         What = "Space";
                         break;
          case Stage:    if ((newVal = ActivCnt ? 0 : 1) != adminNoStage)
                            {if (newVal) unlink(NoStageFile);
                                else close(open(NoStageFile, O_WRONLY|O_CREAT,
                                                             S_IRUSR|S_IWUSR));
                             adminNoStage = newVal;
                            }
                         What = "Stage";
                         break;
          default:       Say.Emsg("State", "Invalid state update");
                         What = "Unknown";
                         break;
         }
 
   DEBUG(What <<" Parm1=" <<ActivCnt <<" Parm2=" <<StageCnt);
   currState=(numActive  < minNodeCnt   || adminSuspend ? SRV_Suspend:0)
            |(numStaging < 1 || noSpace || adminNoStage ? All_NoStage:0)
            |                                   ( !feOK ? FES_Suspend:0);
 
   Suspended = currState & All_Suspend;
   NoStaging = currState & All_NoStage;
 
// If any changes are noted then we must send out notifications
//
   if (currState != prevState && Enabled) mySemaphore.Post();
 
// All done
//
   myMutex.UnLock();
}

References Active, All_NoStage, All_Suspend, close, Counts, DEBUG, XrdSysError::Emsg(), EPNAME, FES_Suspend, FrontEnd, XrdSysMutex::Lock(), NoStaging, open, XrdSysSemaphore::Post(), XrdCms::Say, Space, SRV_Suspend, Stage, Suspended, unlink, and XrdSysMutex::UnLock().

Referenced by XrdCmsCluster::Add(), XrdCmsConfig::Configure2(), XrdCmsNode::do_Status(), XrdCmsConfig::DoIt(), Enable(), XrdCmsMeter::Init(), XrdCmsAdmin::Login(), XrdCmsAdmin::MonAds(), XrdCmsAdmin::Notes(), XrdCmsCluster::Remove(), and XrdCmsMeter::RunFS().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

All_NoStage

const char XrdCmsState::All_NoStage = 4

static

Definition at line 66 of file XrdCmsState.hh.

Referenced by XrdCmsState(), and Update().

All_Suspend

const char XrdCmsState::All_Suspend = 3

static

Definition at line 65 of file XrdCmsState.hh.

Referenced by XrdCmsState(), and Update().

FES_Suspend

const char XrdCmsState::FES_Suspend = 2

static

Definition at line 64 of file XrdCmsState.hh.

Referenced by Update().

NoStaging

int XrdCmsState::NoStaging

Definition at line 43 of file XrdCmsState.hh.

Referenced by XrdCmsState(), sendState(), and Update().

SRV_Suspend

const char XrdCmsState::SRV_Suspend = 1

static

Definition at line 63 of file XrdCmsState.hh.

Referenced by Monitor(), and Update().

Suspended

int XrdCmsState::Suspended

Definition at line 42 of file XrdCmsState.hh.

Referenced by XrdCmsState(), XrdCmsProtocol::Execute(), sendState(), and Update().

---

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

• XrdCmsState.hh
• XrdCmsState.cc