xrootd
|
#include <XrdCmsNode.hh>
Public Member Functions | |
const char * | do_Avail (XrdCmsRRData &Arg) |
const char * | do_Chmod (XrdCmsRRData &Arg) |
const char * | do_Disc (XrdCmsRRData &Arg) |
const char * | do_Gone (XrdCmsRRData &Arg) |
const char * | do_Have (XrdCmsRRData &Arg) |
const char * | do_Load (XrdCmsRRData &Arg) |
const char * | do_Locate (XrdCmsRRData &Arg) |
const char * | do_Mkdir (XrdCmsRRData &Arg) |
const char * | do_Mkpath (XrdCmsRRData &Arg) |
const char * | do_Mv (XrdCmsRRData &Arg) |
const char * | do_Ping (XrdCmsRRData &Arg) |
const char * | do_Pong (XrdCmsRRData &Arg) |
const char * | do_PrepAdd (XrdCmsRRData &Arg) |
const char * | do_PrepDel (XrdCmsRRData &Arg) |
const char * | do_Rm (XrdCmsRRData &Arg) |
const char * | do_Rmdir (XrdCmsRRData &Arg) |
int | do_SelAvoid (XrdCmsRRData &Arg, XrdCmsSelect &Sel, char *Avoid, bool &doRedir) |
const char * | do_Select (XrdCmsRRData &Arg) |
const char * | do_Space (XrdCmsRRData &Arg) |
const char * | do_State (XrdCmsRRData &Arg) |
int | do_StateFWD (XrdCmsRRData &Arg) |
const char * | do_StatFS (XrdCmsRRData &Arg) |
const char * | do_Stats (XrdCmsRRData &Arg) |
const char * | do_Status (XrdCmsRRData &Arg) |
const char * | do_Trunc (XrdCmsRRData &Arg) |
const char * | do_Try (XrdCmsRRData &Arg) |
const char * | do_Update (XrdCmsRRData &Arg) |
const char * | do_Usage (XrdCmsRRData &Arg) |
void | Delete (XrdSysRWLock &gMutex) |
void | Delete (XrdSysMutex &gMutex) |
void | Delete (XrdSysFusedMutex &gMutex) |
void | Disc (const char *reason=0, int needLock=1) |
int | ID (int &INum) |
int | Inst () |
bool | inDomain () |
int | isNode (SMask_t smask) |
int | isNode (const XrdNetAddr *addr) |
int | isNode (XrdLink *lp, const char *nid, int port) |
char * | Name () |
SMask_t | Mask () |
void | g2nLock (XrdSysRWLock &gMutex) |
void | n2gLock (XrdSysRWLock &gMutex, bool rdlock=false) |
void | Lock () |
void | UnLock () |
void | Ref () |
void | unRef () |
int | Send (const char *buff, int blen=0) |
int | Send (const struct iovec *iov, int iovcnt, int iotot=0) |
void | setManager (XrdCmsManager *mP) |
void | setName (XrdLink *lnkp, const char *theIF, int port) |
void | setShare (int shrval) |
int | setTZone (int tZone) |
void | setVersion (unsigned short vnum) |
void | setSlot (short rslot) |
short | getSlot () |
void | ShowIF () |
void | SyncSpace () |
XrdCmsNode (XrdLink *lnkp, const char *theIF=0, const char *sid=0, int port=0, int lvl=0, int id=-1) | |
~XrdCmsNode () | |
Static Public Member Functions | |
static int | do_LocFmt (char *buff, XrdCmsSelected *sP, SMask_t pf, SMask_t wf, bool lsall=false, bool lsuniq=false) |
static int | do_SelPrep (XrdCmsPrepArgs &Arg) |
static void | do_StateDFS (XrdCmsBaseFR *rP, int rc) |
static void | Report_Usage (XrdLink *lp) |
Public Attributes | |
char * | Ident = 0 |
char | hasNet = 0 |
char | isBad = 0 |
char | isOffline |
char | isRW = 0 |
char | isNoStage = 0 |
char | isMan = 0 |
char | isPeer = 0 |
char | isBound = 0 |
char | isKnown = 0 |
char | isConn = 0 |
char | isGone = 0 |
char | isPerm = 0 |
char | rsvd = 0 |
char | RoleID = 0 |
char | TimeZone = 0 |
char | TZValid = 0 |
unsigned int | DiskTotal = 0 |
int | DiskNums = 0 |
int | DiskMinF = 0 |
int | DiskFree = 0 |
int | DiskUtil = 0 |
unsigned int | ConfigID = 0 |
Static Public Attributes | |
static const char | isBlisted = 0x01 |
static const char | isDisabled = 0x02 |
static const char | isSuspend = 0x04 |
static const char | isDoomed = 0x08 |
static const char | allowsRW = 0x01 |
static const char | allowsSS = 0x02 |
Private Member Functions | |
void | DeleteWarn (unsigned int lkVal) |
int | fsExec (XrdOucProg *Prog, char *Arg1, char *Arg2=0) |
const char * | fsFail (const char *Who, const char *What, const char *Path, int rc) |
int | getMode (const char *theMode, mode_t &Mode) |
int | getSize (const char *theSize, long long &Size) |
void | setHash (XrdCmsSelect &Sel, int acount) |
Private Attributes | |
XrdSysMutex | nodeMutex |
RAtomic_uint | refCnt {0} |
XrdLink * | Link |
XrdNetAddr | netID |
XrdNetIF | netIF |
XrdCmsManager * | Manager = 0 |
time_t | DropTime = 0 |
XrdCmsDrop * | DropJob = 0 |
XrdCmsClustID * | cidP = 0 |
SMask_t | NodeMask |
int | NodeID |
int | Instance |
int | myLevel |
short | subsPort = 0 |
unsigned short | myVersion |
char * | myCID |
char * | myNID |
char * | myName = 0 |
int | myNlen = 0 |
int | logload |
int | myCost = 0 |
int | myLoad = 0 |
int | myMass = 0 |
RAtomic_int | RefW {0} |
RAtomic_int | RefTotW {0} |
RAtomic_int | RefR {0} |
RAtomic_int | RefTotR {0} |
short | RSlot = 0 |
char | Share = 0 |
RAtomic_char | Shrem {0} |
RAtomic_char | Shrin {0} |
char | Shrip = 0 |
char | Rsvd [3] |
Static Private Attributes | |
static const int | fsL2PFail1 = 999991 |
static const int | fsL2PFail2 = 999992 |
static XrdSysMutex | mlMutex |
static int | LastFree |
Friends | |
class | XrdCmsCluster |
XrdCmsNode::XrdCmsNode | ( | XrdLink * | lnkp, |
const char * | theIF = 0 , |
||
const char * | sid = 0 , |
||
int | port = 0 , |
||
int | lvl = 0 , |
||
int | id = -1 |
||
) |
XrdCmsNode::~XrdCmsNode | ( | ) |
void XrdCmsNode::Delete | ( | XrdSysFusedMutex & | gMutex | ) |
|
inline |
References Delete().
|
inline |
|
private |
void XrdCmsNode::Disc | ( | const char * | reason = 0 , |
int | needLock = 1 |
||
) |
const char * XrdCmsNode::do_Avail | ( | XrdCmsRRData & | Arg | ) |
const char * XrdCmsNode::do_Chmod | ( | XrdCmsRRData & | Arg | ) |
const char * XrdCmsNode::do_Disc | ( | XrdCmsRRData & | Arg | ) |
const char * XrdCmsNode::do_Gone | ( | XrdCmsRRData & | Arg | ) |
const char * XrdCmsNode::do_Have | ( | XrdCmsRRData & | Arg | ) |
const char * XrdCmsNode::do_Load | ( | XrdCmsRRData & | Arg | ) |
const char * XrdCmsNode::do_Locate | ( | XrdCmsRRData & | Arg | ) |
|
static |
const char * XrdCmsNode::do_Mkdir | ( | XrdCmsRRData & | Arg | ) |
const char * XrdCmsNode::do_Mkpath | ( | XrdCmsRRData & | Arg | ) |
const char * XrdCmsNode::do_Mv | ( | XrdCmsRRData & | Arg | ) |
const char * XrdCmsNode::do_Ping | ( | XrdCmsRRData & | Arg | ) |
const char * XrdCmsNode::do_Pong | ( | XrdCmsRRData & | Arg | ) |
const char * XrdCmsNode::do_PrepAdd | ( | XrdCmsRRData & | Arg | ) |
const char * XrdCmsNode::do_PrepDel | ( | XrdCmsRRData & | Arg | ) |
const char * XrdCmsNode::do_Rm | ( | XrdCmsRRData & | Arg | ) |
const char * XrdCmsNode::do_Rmdir | ( | XrdCmsRRData & | Arg | ) |
int XrdCmsNode::do_SelAvoid | ( | XrdCmsRRData & | Arg, |
XrdCmsSelect & | Sel, | ||
char * | Avoid, | ||
bool & | doRedir | ||
) |
const char * XrdCmsNode::do_Select | ( | XrdCmsRRData & | Arg | ) |
|
static |
Referenced by XrdCmsPrepArgs::DoIt().
const char * XrdCmsNode::do_Space | ( | XrdCmsRRData & | Arg | ) |
const char * XrdCmsNode::do_State | ( | XrdCmsRRData & | Arg | ) |
|
static |
int XrdCmsNode::do_StateFWD | ( | XrdCmsRRData & | Arg | ) |
const char * XrdCmsNode::do_StatFS | ( | XrdCmsRRData & | Arg | ) |
const char * XrdCmsNode::do_Stats | ( | XrdCmsRRData & | Arg | ) |
const char * XrdCmsNode::do_Status | ( | XrdCmsRRData & | Arg | ) |
const char * XrdCmsNode::do_Trunc | ( | XrdCmsRRData & | Arg | ) |
const char * XrdCmsNode::do_Try | ( | XrdCmsRRData & | Arg | ) |
const char * XrdCmsNode::do_Update | ( | XrdCmsRRData & | Arg | ) |
const char * XrdCmsNode::do_Usage | ( | XrdCmsRRData & | Arg | ) |
|
private |
|
private |
|
inline |
References XrdSysMutex::Lock(), nodeMutex, refCnt, and XrdSysRWLock::UnLock().
|
private |
|
private |
|
inline |
References RSlot.
|
inline |
References XrdNetIF::InDomain(), netID, and netIF.
|
inline |
References Instance.
|
inline |
References netID, and XrdNetAddrInfo::Same().
|
inline |
References myNID, XrdLink::NetAddr(), netID, netIF, XrdNetIF::Port(), and XrdNetAddrInfo::Same().
|
inline |
References XrdSysMutex::Lock(), nodeMutex, and refCnt.
|
inline |
References nodeMutex, XrdSysRWLock::ReadLock(), refCnt, XrdSysMutex::UnLock(), and XrdSysRWLock::WriteLock().
|
inline |
References myName.
|
inline |
References refCnt.
|
static |
|
inline |
References isOffline, Link, and XrdLink::Send().
|
inline |
References isOffline, Link, and XrdLink::Send().
|
private |
|
inline |
References Manager.
void XrdCmsNode::setName | ( | XrdLink * | lnkp, |
const char * | theIF, | ||
int | port | ||
) |
|
inline |
References RSlot.
|
inline |
References myVersion.
|
inline |
References XrdNetIF::Display(), and netIF.
void XrdCmsNode::SyncSpace | ( | ) |
|
inline |
References nodeMutex, refCnt, and XrdSysMutex::UnLock().
|
inline |
References refCnt.
|
friend |
|
static |
|
static |
|
private |
unsigned int XrdCmsNode::ConfigID = 0 |
int XrdCmsNode::DiskFree = 0 |
int XrdCmsNode::DiskMinF = 0 |
int XrdCmsNode::DiskNums = 0 |
unsigned int XrdCmsNode::DiskTotal = 0 |
int XrdCmsNode::DiskUtil = 0 |
|
private |
|
private |
|
staticprivate |
|
staticprivate |
char XrdCmsNode::hasNet = 0 |
char* XrdCmsNode::Ident = 0 |
char XrdCmsNode::isBad = 0 |
|
static |
char XrdCmsNode::isBound = 0 |
char XrdCmsNode::isConn = 0 |
|
static |
|
static |
char XrdCmsNode::isGone = 0 |
char XrdCmsNode::isKnown = 0 |
char XrdCmsNode::isMan = 0 |
char XrdCmsNode::isNoStage = 0 |
char XrdCmsNode::isPeer = 0 |
char XrdCmsNode::isPerm = 0 |
char XrdCmsNode::isRW = 0 |
|
static |
|
staticprivate |
|
private |
|
private |
Referenced by setManager().
|
staticprivate |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
Referenced by Name().
|
private |
Referenced by isNode().
|
private |
|
private |
Referenced by setVersion().
|
private |
Referenced by inDomain(), isNode(), and isNode().
|
private |
Referenced by inDomain(), isNode(), and ShowIF().
|
private |
Referenced by ID().
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
char XrdCmsNode::RoleID = 0 |
char XrdCmsNode::rsvd = 0 |
|
private |
|
private |
Referenced by setShare().
|
private |
Referenced by setShare().
|
private |
|
private |
Referenced by setShare().
|
private |
char XrdCmsNode::TimeZone = 0 |
Referenced by setTZone().
char XrdCmsNode::TZValid = 0 |
Referenced by setTZone().