XrdCmsProtocol Class Reference

#include <XrdCmsProtocol.hh>

Inheritance diagram for XrdCmsProtocol:

Collaboration diagram for XrdCmsProtocol:

Public Member Functions
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)
	XrdCmsProtocol ()
	~XrdCmsProtocol ()
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)

Private Types
enum	Bearing { isDown, isLateral, isUp }

Private Member Functions
XrdCmsRouting *	Admit ()
XrdCmsRouting *	Admit_DataServer (int)
XrdCmsRouting *	Admit_Redirector (int)
XrdCmsRouting *	Admit_Supervisor (int)
SMask_t	AddPath (XrdCmsNode *nP, const char *pType, const char *Path)
int	Authenticate ()
void	ConfigCheck (unsigned char *theConfig)
const char *	Dispatch (Bearing cDir, int maxWait, int maxTries)
void	Init (const char *iRole="?", XrdCmsManager *uMan=0, const char *iMan="?", int iPort=0)
XrdCmsRouting *	Login_Failed (const char *Reason)
void	Pander (const char *manager, int mport)
void	Reissue (XrdCmsRRData &Data)
void	Reply_Delay (XrdCmsRRData &Data, kXR_unt32 theDelay)
void	Reply_Error (XrdCmsRRData &Data, int ecode, const char *etext)
bool	SendPing ()
void	Sync ()

Private Attributes
XrdCmsProtocol *	ProtLink
XrdCmsRouting *	Routing
XrdSysMutex	refMutex
XrdSysSemaphore *	refWait
XrdLink *	Link
const char *	myRole
XrdCmsNode *	myNode
XrdCmsManager *	Manager
const char *	myMan
int	myManPort
int	refCount
short	RSlot
char	loggedIn
bool	isNBSQ

Static Private Attributes
static XrdSysMutex	ProtMutex
static XrdCmsProtocol *	ProtStack
static XrdCmsParser	ProtArgs
static const int	maxReqSize = 16384
static int	readWait

Friends
class	XrdCmsJob

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

Member Enumeration Documentation

enum XrdCmsProtocol::Bearing

private

Enumerator
isDown
isLateral
isUp

Constructor & Destructor Documentation

XrdCmsProtocol::XrdCmsProtocol ( )

inline

References Init().

XrdCmsProtocol::~XrdCmsProtocol ( )

inline

Member Function Documentation

SMask_t XrdCmsProtocol::AddPath ( XrdCmsNode *  nP, const char *  pType, const char *  Path  )

private

XrdCmsRouting* XrdCmsProtocol::Admit ( )

private

XrdCmsRouting* XrdCmsProtocol::Admit_DataServer ( int  )

private

XrdCmsRouting* XrdCmsProtocol::Admit_Redirector ( int  )

private

XrdCmsRouting* XrdCmsProtocol::Admit_Supervisor ( int  )

private

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

static

int XrdCmsProtocol::Authenticate ( )

private

void XrdCmsProtocol::ConfigCheck ( unsigned char *  theConfig )

private

const char* XrdCmsProtocol::Dispatch ( Bearing  cDir, int  maxWait, int  maxTries  )

private

void XrdCmsProtocol::DoIt ( )

virtual

Implements XrdJob.

int XrdCmsProtocol::Execute

(

XrdCmsRRData &

Data

)

void XrdCmsProtocol::Init ( const char *  iRole = "?", XrdCmsManager *  uMan = 0, const char *  iMan = "?", int  iPort = 0  )

private

Referenced by XrdCmsProtocol().

XrdCmsRouting* XrdCmsProtocol::Login_Failed ( const char *  Reason )

private

XrdProtocol* XrdCmsProtocol::Match ( XrdLink *  lp )

virtual

Implements XrdProtocol.

void XrdCmsProtocol::Pander ( const char *  manager, int  mport  )

private

int XrdCmsProtocol::Process ( XrdLink *  lp )

virtual

Implements XrdProtocol.

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

virtual

Implements XrdProtocol.

void XrdCmsProtocol::Ref

(

int

rcnt

)

void XrdCmsProtocol::Reissue ( XrdCmsRRData &  Data )

private

void XrdCmsProtocol::Reply_Delay ( XrdCmsRRData &  Data, kXR_unt32  theDelay  )

private

void XrdCmsProtocol::Reply_Error ( XrdCmsRRData &  Data, int  ecode, const char *  etext  )

private

bool XrdCmsProtocol::SendPing ( )

private

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

virtual

Implements XrdProtocol.

void XrdCmsProtocol::Sync ( )

private

Friends And Related Function Documentation

friend class XrdCmsJob

friend

Member Data Documentation

bool XrdCmsProtocol::isNBSQ

private

XrdLink* XrdCmsProtocol::Link

private

char XrdCmsProtocol::loggedIn

private

XrdCmsManager* XrdCmsProtocol::Manager

private

const int XrdCmsProtocol::maxReqSize = 16384

staticprivate

const char* XrdCmsProtocol::myMan

private

int XrdCmsProtocol::myManPort

private

XrdCmsNode* XrdCmsProtocol::myNode

private

const char* XrdCmsProtocol::myRole

private

XrdCmsParser XrdCmsProtocol::ProtArgs

staticprivate

XrdCmsProtocol* XrdCmsProtocol::ProtLink

private

XrdSysMutex XrdCmsProtocol::ProtMutex

staticprivate

XrdCmsProtocol* XrdCmsProtocol::ProtStack

staticprivate

int XrdCmsProtocol::readWait

staticprivate

int XrdCmsProtocol::refCount

private

XrdSysMutex XrdCmsProtocol::refMutex

private

XrdSysSemaphore* XrdCmsProtocol::refWait

private

XrdCmsRouting* XrdCmsProtocol::Routing

private

short XrdCmsProtocol::RSlot

private

---

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

• XrdCmsProtocol.hh