35 #include <netinet/in.h>
102 bool lsall=
false,
bool lsuniq=
false);
113 char *Avoid,
bool &doRedir);
130 void Disc(
const char *reason=0,
int needLock=1);
145 {
if (strcmp(
myNID, nid))
return 0;
146 if (*nid ==
'*')
return 1;
195 inline int Send(
const char *buff,
int blen=0)
197 inline int Send(
const struct iovec *
iov,
int iovcnt,
int iotot=0)
226 int port=0,
int lvl=0,
int id=-1);
235 const char *
fsFail(
const char *Who,
const char *What,
const char *Path,
int rc);
236 int getMode(
const char *theMode, mode_t &Mode);
237 int getSize(
const char *theSize,
long long &Size);
unsigned long long SMask_t
Definition: XrdCmsTypes.hh:33
Definition: XrdCmsBaseFS.hh:49
Definition: XrdCmsBaseFS.hh:88
Definition: XrdCmsClustID.hh:41
Definition: XrdCmsCluster.hh:114
friend class XrdCmsDrop
Definition: XrdCmsCluster.hh:116
Definition: XrdCmsManager.hh:56
Definition: XrdCmsNode.hh:57
char * myNID
Definition: XrdCmsNode.hh:259
const char * do_Pong(XrdCmsRRData &Arg)
char isPerm
Definition: XrdCmsNode.hh:72
void setManager(XrdCmsManager *mP)
Definition: XrdCmsNode.hh:200
static int do_SelPrep(XrdCmsPrepArgs &Arg)
char Rsvd[2]
Definition: XrdCmsNode.hh:276
int do_StateFWD(XrdCmsRRData &Arg)
XrdCmsNode * Next
Definition: XrdCmsNode.hh:247
const char * do_PrepAdd(XrdCmsRRData &Arg)
XrdNetIF netIF
Definition: XrdCmsNode.hh:245
int DiskMinF
Definition: XrdCmsNode.hh:88
int DiskFree
Definition: XrdCmsNode.hh:89
int RefTotR
Definition: XrdCmsNode.hh:270
static const char allowsRW
Definition: XrdCmsNode.hh:83
void g2nLock(XrdSysMutex &gMutex)
Definition: XrdCmsNode.hh:159
char * Ident
Definition: XrdCmsNode.hh:60
const char * do_Chmod(XrdCmsRRData &Arg)
const char * do_PrepDel(XrdCmsRRData &Arg)
int Instance
Definition: XrdCmsNode.hh:254
char isLocked
Definition: XrdCmsNode.hh:272
const char * do_Locate(XrdCmsRRData &Arg)
const char * do_Disc(XrdCmsRRData &Arg)
void setShare(int shrval)
Definition: XrdCmsNode.hh:204
const char * do_Try(XrdCmsRRData &Arg)
const char * do_StatFS(XrdCmsRRData &Arg)
int isNode(XrdLink *lp, const char *nid, int port)
Definition: XrdCmsNode.hh:143
void Ref2g(XrdSysMutex &gMutex)
Definition: XrdCmsNode.hh:157
int DiskNums
Definition: XrdCmsNode.hh:87
char isKnown
Definition: XrdCmsNode.hh:69
unsigned int ConfigID
Definition: XrdCmsNode.hh:91
char incUL
Definition: XrdCmsNode.hh:73
int myLoad
Definition: XrdCmsNode.hh:265
char isConn
Definition: XrdCmsNode.hh:70
const char * do_Mkpath(XrdCmsRRData &Arg)
XrdCmsDrop * DropJob
Definition: XrdCmsNode.hh:249
char TZValid
Definition: XrdCmsNode.hh:76
XrdSysCondVar nodeMutex
Definition: XrdCmsNode.hh:239
int Send(const char *buff, int blen=0)
Definition: XrdCmsNode.hh:195
static const char allowsSS
Definition: XrdCmsNode.hh:84
char isGone
Definition: XrdCmsNode.hh:71
int DiskUtil
Definition: XrdCmsNode.hh:90
int RefW
Definition: XrdCmsNode.hh:267
int do_SelAvoid(XrdCmsRRData &Arg, XrdCmsSelect &Sel, char *Avoid, bool &doRedir)
const char * fsFail(const char *Who, const char *What, const char *Path, int rc)
const char * do_Mkdir(XrdCmsRRData &Arg)
const char * do_Stats(XrdCmsRRData &Arg)
const char * do_Rm(XrdCmsRRData &Arg)
const char * do_Avail(XrdCmsRRData &Arg)
char Shrem
Definition: XrdCmsNode.hh:274
int setTZone(int tZone)
Definition: XrdCmsNode.hh:209
const char * do_Space(XrdCmsRRData &Arg)
const char * do_Ping(XrdCmsRRData &Arg)
time_t DropTime
Definition: XrdCmsNode.hh:248
char Share
Definition: XrdCmsNode.hh:273
int Inst()
Definition: XrdCmsNode.hh:134
unsigned short myVersion
Definition: XrdCmsNode.hh:257
char TimeZone
Definition: XrdCmsNode.hh:75
char isPeer
Definition: XrdCmsNode.hh:67
void g2Ref(XrdSysMutex &gMutex)
Definition: XrdCmsNode.hh:155
void setVersion(unsigned short vnum)
Definition: XrdCmsNode.hh:216
short subsPort
Definition: XrdCmsNode.hh:256
short RSlot
Definition: XrdCmsNode.hh:271
const char * do_Have(XrdCmsRRData &Arg)
int isNode(const XrdNetAddr *addr)
Definition: XrdCmsNode.hh:140
static const char isDisabled
Definition: XrdCmsNode.hh:79
char RoleID
Definition: XrdCmsNode.hh:74
int myNlen
Definition: XrdCmsNode.hh:261
int isNode(SMask_t smask)
Definition: XrdCmsNode.hh:138
SMask_t Mask()
Definition: XrdCmsNode.hh:153
int Send(const struct iovec *iov, int iovcnt, int iotot=0)
Definition: XrdCmsNode.hh:197
int getSize(const char *theSize, long long &Size)
void DeleteWarn(XrdSysMutex &gMutex, unsigned int &lkVal)
char isBad
Definition: XrdCmsNode.hh:62
void Lock(bool doinc)
Definition: XrdCmsNode.hh:177
char isOffline
Definition: XrdCmsNode.hh:63
const char * do_Load(XrdCmsRRData &Arg)
int RefTotW
Definition: XrdCmsNode.hh:268
char * myCID
Definition: XrdCmsNode.hh:258
static void Report_Usage(XrdLink *lp)
static void do_StateDFS(XrdCmsBaseFR *rP, int rc)
int RefR
Definition: XrdCmsNode.hh:269
static const char isSuspend
Definition: XrdCmsNode.hh:80
XrdCmsClustID * cidP
Definition: XrdCmsNode.hh:251
const char * do_Usage(XrdCmsRRData &Arg)
const char * do_State(XrdCmsRRData &Arg)
const char * do_Select(XrdCmsRRData &Arg)
unsigned int DiskTotal
Definition: XrdCmsNode.hh:86
int ID(int &INum)
Definition: XrdCmsNode.hh:132
const char * do_Update(XrdCmsRRData &Arg)
int myMass
Definition: XrdCmsNode.hh:266
static XrdSysMutex mlMutex
Definition: XrdCmsNode.hh:281
char * myName
Definition: XrdCmsNode.hh:260
char isNoStage
Definition: XrdCmsNode.hh:65
void Disc(const char *reason=0, int needLock=1)
char Shrip
Definition: XrdCmsNode.hh:275
const char * do_Gone(XrdCmsRRData &Arg)
int getMode(const char *theMode, mode_t &Mode)
int logload
Definition: XrdCmsNode.hh:263
const char * do_Trunc(XrdCmsRRData &Arg)
char isMan
Definition: XrdCmsNode.hh:66
unsigned int ulCount
Definition: XrdCmsNode.hh:241
int myCost
Definition: XrdCmsNode.hh:264
void setSlot(short rslot)
Definition: XrdCmsNode.hh:218
XrdCmsNode(XrdLink *lnkp, const char *theIF=0, const char *sid=0, int port=0, int lvl=0, int id=-1)
void UnLock()
Definition: XrdCmsNode.hh:185
XrdNetAddr netID
Definition: XrdCmsNode.hh:244
void ShowIF()
Definition: XrdCmsNode.hh:221
static int do_LocFmt(char *buff, XrdCmsSelected *sP, SMask_t pf, SMask_t wf, bool lsall=false, bool lsuniq=false)
void setName(XrdLink *lnkp, const char *theIF, int port)
const char * do_Status(XrdCmsRRData &Arg)
int myLevel
Definition: XrdCmsNode.hh:255
static const int fsL2PFail1
Definition: XrdCmsNode.hh:230
int fsExec(XrdOucProg *Prog, char *Arg1, char *Arg2=0)
XrdCmsManager * Manager
Definition: XrdCmsNode.hh:246
char isBound
Definition: XrdCmsNode.hh:68
static const char isDoomed
Definition: XrdCmsNode.hh:81
int NodeID
Definition: XrdCmsNode.hh:253
void n2gLock(XrdSysMutex &gMutex)
Definition: XrdCmsNode.hh:167
bool inDomain()
Definition: XrdCmsNode.hh:136
const char * do_Rmdir(XrdCmsRRData &Arg)
static const int fsL2PFail2
Definition: XrdCmsNode.hh:231
short getSlot()
Definition: XrdCmsNode.hh:219
const char * do_Mv(XrdCmsRRData &Arg)
int Shrin
Definition: XrdCmsNode.hh:277
void Delete(XrdSysMutex &gMutex)
XrdLink * Link
Definition: XrdCmsNode.hh:243
static const char isBlisted
Definition: XrdCmsNode.hh:78
char isRW
Definition: XrdCmsNode.hh:64
SMask_t NodeMask
Definition: XrdCmsNode.hh:252
char * Name()
Definition: XrdCmsNode.hh:151
static int LastFree
Definition: XrdCmsNode.hh:282
char hasNet
Definition: XrdCmsNode.hh:61
unsigned int lkCount
Definition: XrdCmsNode.hh:240
Definition: XrdCmsPrepArgs.hh:41
Definition: XrdCmsRRData.hh:52
Definition: XrdCmsSelect.hh:44
Definition: XrdCmsSelect.hh:102
Definition: XrdLink.hh:52
int Send(const char *buff, int blen)
const XrdNetAddr * NetAddr() const
int Same(const XrdNetAddrInfo *ipAddr, bool plusPort=false)
Definition: XrdNetAddr.hh:42
Definition: XrdNetIF.hh:49
void Display(const char *pfx="=====> ")
int Port()
Definition: XrdNetIF.hh:276
static bool InDomain(XrdNetAddrInfo *epaddr)
Definition: XrdOucProg.hh:38
Definition: XrdSysPthread.hh:79
void UnLock()
Definition: XrdSysPthread.hh:94
void Lock()
Definition: XrdSysPthread.hh:82
void Signal()
Definition: XrdSysPthread.hh:84
Definition: XrdSysPthread.hh:166
void Lock()
Definition: XrdSysPthread.hh:222
void UnLock()
Definition: XrdSysPthread.hh:224
Definition: XrdOucIOVec.hh:65