XrdCmsProtocol Class Reference

#include <XrdCmsProtocol.hh>

Inheritance diagram for XrdCmsProtocol:

Collaboration diagram for XrdCmsProtocol:

Public Member Functions
	XrdCmsProtocol ()
	~XrdCmsProtocol ()
void	DoIt ()
int	Execute (XrdCmsRRData &Data)
XrdProtocol *	Match (XrdLink *lp)
int	Process (XrdLink *lp)
void	Recycle (XrdLink *lp, int consec, const char *reason)
void	Ref (int rcnt)
int	Stats (char *buff, int blen, int do_sync=0)
Public Member Functions inherited from XrdProtocol
	XrdProtocol (const char *jname)
virtual	~XrdProtocol ()
Public Member Functions inherited from XrdJob
	XrdJob (const char *desc="")
virtual	~XrdJob ()

Static Public Member Functions
static XrdCmsProtocol *	Alloc (const char *theRole="", XrdCmsManager *mP=0, const char *theMan=0, int thePort=0)

Friends
class	XrdCmsJob

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

Detailed Description

Definition at line 44 of file XrdCmsProtocol.hh.

Constructor & Destructor Documentation

XrdCmsProtocol()

XrdCmsProtocol::XrdCmsProtocol ( )

inline

Definition at line 66 of file XrdCmsProtocol.hh.

: XrdProtocol("cms protocol handler") {Init();}

References XrdProtocol::XrdProtocol().

Referenced by Alloc(), and XrdCmsJob.

Here is the call graph for this function:

Here is the caller graph for this function:

~XrdCmsProtocol()

XrdCmsProtocol::~XrdCmsProtocol ( )

inline

Definition at line 67 of file XrdCmsProtocol.hh.

{}

Member Function Documentation

Alloc()

XrdCmsProtocol * XrdCmsProtocol::Alloc ( const char * theRole = "", XrdCmsManager * mP = 0, const char * theMan = 0, int thePort = 0 )

static

Definition at line 892 of file XrdCmsProtocol.cc.

{
   XrdCmsProtocol *xp;
 
// Grab a protocol object and, if none, return a new one
//
   ProtMutex.Lock();
   if ((xp = ProtStack)) ProtStack = xp->ProtLink;
      else xp = new XrdCmsProtocol();
   ProtMutex.UnLock();
 
// Initialize the object if we actually got one
//
   if (!xp) Say.Emsg("Protocol","No more protocol objects.");
      else xp->Init(theRole, uMan, theMan, thePort);
 
// All done
//
   return xp;
}

References XrdCmsProtocol(), and XrdCms::Say.

Referenced by Match(), and XrdCmsSupervisor::Start().

Here is the call graph for this function:

Here is the caller graph for this function:

DoIt()

void XrdCmsProtocol::DoIt ( )

virtual

Implements XrdJob.

Definition at line 1063 of file XrdCmsProtocol.cc.

{
 
// If we have a role, then we should simply pander it
//
   if (myRole) Pander(myMan, myManPort);
}

Execute()

int XrdCmsProtocol::Execute

(

XrdCmsRRData &

Data

)

Definition at line 202 of file XrdCmsProtocol.cc.

{
   EPNAME("Execute");
   static kXR_unt32 theDelay = htonl(Config.SUPDelay);
   XrdCmsRouter::NodeMethod_t Method;
   const char *etxt;
 
// Check if we can continue
//
   if (CmsState.Suspended && Arg.Routing & XrdCmsRouting::Delayable)
      {Reply_Delay(Arg, theDelay); return 0;}
 
// Validate request code and execute the request. If successful, forward the
// request to subscribers of this node if the request is forwardable.
//
   if (!(Method = Router.getMethod(Arg.Request.rrCode)))
      Say.Emsg("Protocol", "invalid request code from", myNode->Ident);
      else if ((etxt = (myNode->*Method)(Arg)))
              if (*etxt == '!')
                 {DEBUGR(etxt+1 <<" delayed " <<Arg.waitVal <<" seconds");
                  return -EINPROGRESS;
                 } else if (*etxt == '.') return -ECONNABORTED;
                           else Reply_Error(Arg, kYR_EINVAL, etxt);
              else if (Arg.Routing & XrdCmsRouting::Forward && Cluster.NodeCnt
                   &&  !(Arg.Request.modifier & kYR_dnf)) Reissue(Arg);
   return 0;
}

References XrdCms::Cluster, XrdCms::CmsState, XrdCms::Config, DEBUGR, XrdCmsRouting::Delayable, EPNAME, XrdCmsRouting::Forward, XrdCms::kYR_dnf, XrdCms::kYR_EINVAL, XrdCms::CmsRRHdr::modifier, XrdCmsRRData::Request, XrdCms::Router, XrdCmsRRData::Routing, XrdCms::CmsRRHdr::rrCode, and XrdCms::Say.

Match()

XrdProtocol * XrdCmsProtocol::Match ( XrdLink * lp )

virtual

Implements XrdProtocol.

Definition at line 234 of file XrdCmsProtocol.cc.

{
CmsRRHdr          Hdr;
int               dlen;
 
// Peek at the first few bytes of data (shouldb be all zeroes)
//
   if ((dlen = lp->Peek((char *)&Hdr,sizeof(Hdr),readWait)) != sizeof(Hdr))
      {if (dlen <= 0) lp->setEtext("login not received");
       return (XrdProtocol *)0;
      }
 
// Verify that this is our protocol and whether a version1 client is here
//
   if (Hdr.streamid || Hdr.rrCode != kYR_login)
      {if (!strncmp((char *)&Hdr, "login ", 6))
          lp->setEtext("protocol version 1 unsupported");
       return (XrdProtocol *)0;
      }
 
// Return the protocol object
//
   return (XrdProtocol *)XrdCmsProtocol::Alloc();
}

References XrdProtocol::XrdProtocol(), Alloc(), XrdCms::kYR_login, XrdLink::Peek(), XrdCms::CmsRRHdr::rrCode, XrdLink::setEtext(), and XrdCms::CmsRRHdr::streamid.

Here is the call graph for this function:

Process()

int XrdCmsProtocol::Process ( XrdLink * lp )

virtual

Implements XrdProtocol.

Definition at line 468 of file XrdCmsProtocol.cc.

{
   const char *Reason;
   Bearing     myWay;
   int         tOut;
 
// Now admit the login
//
   Link = lp;
   if ((Routing=Admit()))
      {loggedIn = 1;
       if (RSlot) {myWay = isLateral; tOut = -1;}
          else    {myWay = isDown;    tOut = Config.AskPing*1000;}
       myNode->UnLock();
       if ((Reason = Dispatch(myWay, tOut, 2))) lp->setEtext(Reason);
       Cluster.SLock(true); myNode->isOffline = 1; Cluster.SLock(false);
      }
 
// Serialize all activity on the link before we proceed. This makes sure that
// there are no outstanding tasks initiated by this node. We don't need a node
// lock for this because we are no longer reading requests so no new tasks can
// be started. Since the node is marked bound, any attempt to reconnect will be
// rejected until we finish removing this node. We get the node lock afterwards.
//
   lp->Serialize();
   if (!myNode) return -1;
   Sync();
   myNode->Lock();
 
// Immediately terminate redirectors (they have an Rslot). The redirector node
// can be directly deleted as all references were serialized through the
// RTable and one we remove our node there can be no references left.
//
   if (RSlot)
      {RTable.Del(myNode); RSlot  = 0;
       myNode->UnLock(); delete myNode; myNode = 0;
       return -1;
      }
 
// We have a node that may or may not be in the cluster at this point, or may
// need to remain in the cluster as a shadow member. In any case, the node
// object lock will be released by Remove().
//
   if (myNode)
      {myNode->isConn = 0;
       if (myNode->isBound) Cluster.Remove(0, myNode, !loggedIn);
          else if (myNode->isGone) Cluster.Remove(myNode);
              else myNode->UnLock();
      }
 
// All done indicate the connection is dead
//
   return -1;
}

References XrdCms::Cluster, XrdCms::Config, XrdCms::RTable, XrdLink::Serialize(), and XrdLink::setEtext().

Here is the call graph for this function:

Recycle()

void XrdCmsProtocol::Recycle ( XrdLink * lp, int consec, const char * reason )

virtual

Implements XrdProtocol.

Definition at line 527 of file XrdCmsProtocol.cc.

{
   bool isLoggedIn = loggedIn != 0;
 
   ProtMutex.Lock();
   ProtLink  = ProtStack;
   ProtStack = this;
   ProtMutex.UnLock();
 
   if (!lp) return;
 
   if (isLoggedIn)
      if (reason) Say.Emsg("Protocol", lp->ID, "logged out;",   reason);
         else     Say.Emsg("Protocol", lp->ID, "logged out.");
      else
      if (reason) Say.Emsg("Protocol", lp->ID, "login failed;", reason);
}

References XrdLink::ID, and XrdCms::Say.

Ref()

void XrdCmsProtocol::Ref

(

int

rcnt

)

Definition at line 1105 of file XrdCmsProtocol.cc.

{
// Update the reference counter
//
   refMutex.Lock();
   refCount += rcnt;
 
// Check if someone is waiting for the count to drop to zero
//
   if (refWait && refCount <= 0) {refWait->Post(); refWait = 0;}
 
// All done
//
   refMutex.UnLock();
}

Stats()

int XrdCmsProtocol::Stats ( char * buff, int blen, int do_sync = 0 )

virtual

Implements XrdProtocol.

Definition at line 549 of file XrdCmsProtocol.cc.

{
 
// All the statistics are handled by the cluster
//
 
// If we are a manager then we have different information
//
   return (Config.asManager() ? Cluster.Statt(buff, blen)
                              : Cluster.Stats(buff, blen));
}

References XrdCms::Cluster, and XrdCms::Config.

Friends And Related Symbol Documentation

XrdCmsJob

friend class XrdCmsJob

friend

Definition at line 46 of file XrdCmsProtocol.hh.

References XrdCmsProtocol(), XrdProtocol::XrdProtocol(), and XrdCmsJob.

Referenced by XrdCmsJob.

---

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

• XrdCmsProtocol.hh
• XrdCmsProtocol.cc