Go to the documentation of this file. 1 #ifndef __CMS_CLUSTER__H
2 #define __CMS_CLUSTER__H
36 #include <netinet/in.h>
123 int sport,
const char *theNID,
const char *theIF);
134 char *Data,
int Dlen=0);
137 void *Data,
int Dlen);
142 void *Data,
int Dlen);
192 int isrw,
int isMulti,
int ifWant);
207 int Stats(
char *bfr,
int bln);
208 int Statt(
char *bfr,
int bln);
215 int sport,
const char *theNID,
const char *theIF);
218 void Record(
char *path,
const char *reason,
bool force=
false);
void Space(XrdCms::SpaceData &sData, SMask_t smask)
SpaceData()
Definition: XrdCmsCluster.hh:95
XrdCmsNode * SelbyRef(SMask_t, XrdCmsSelector &selR)
@ eNoEnt
Definition: XrdCmsCluster.hh:221
int wNum
Definition: XrdCmsCluster.hh:89
void Record(char *path, const char *reason, bool force=false)
SMask_t peerMask
Definition: XrdCmsCluster.hh:262
XrdCmsNode * AddAlt(XrdCmsClustID *cidP, XrdLink *lp, int port, int Status, int sport, const char *theNID, const char *theIF)
long long TotFr
Definition: XrdCmsCluster.hh:86
#define STMax
Definition: XrdCmsTypes.hh:39
XrdCmsSelected * List(SMask_t mask, CmsLSOpts opts, bool &oksel)
@ LS_NULL
Definition: XrdCmsCluster.hh:154
~SpaceData()
Definition: XrdCmsCluster.hh:98
Definition: XrdCmsSelect.hh:43
unsigned long long SMask_t
Definition: XrdCmsTypes.hh:33
Definition: XrdSysPthread.hh:165
int wMinF
Definition: XrdCmsCluster.hh:87
int Unuseable(XrdCmsSelect &Sel)
int doReset
Definition: XrdCmsCluster.hh:243
int Unreachable(XrdCmsSelect &Sel, bool none)
@ LS_IFMASK
Definition: XrdCmsCluster.hh:155
@ eNoRep
Definition: XrdCmsCluster.hh:221
char AltMans[STMax *AltSize]
Definition: XrdCmsCluster.hh:254
static const int CMS_hasAlts
Definition: XrdCmsCluster.hh:77
@ LS_ANY
Definition: XrdCmsCluster.hh:155
int Stats(char *bfr, int bln)
static const int CMS_Perm
Definition: XrdCmsCluster.hh:66
@ eDups
Definition: XrdCmsCluster.hh:221
void ResetRef(SMask_t smask)
char * AltMend
Definition: XrdCmsCluster.hh:255
Definition: XrdCmsCluster.hh:81
long long SelTcnt
Definition: XrdCmsCluster.hh:248
int Broadsend(SMask_t smask, XrdCms::CmsRRHdr &Hdr, void *Data, int Dlen)
bool maxBits(SMask_t mVec, int mbits)
static const int RetryOut
Definition: XrdCmsCluster.hh:188
static const int CMS_noStage
Definition: XrdCmsCluster.hh:64
static const int CMS_isPeer
Definition: XrdCmsCluster.hh:69
Definition: XrdCmsNode.hh:56
int SelFail(XrdCmsSelect &Sel, int rc)
int wFree
Definition: XrdCmsCluster.hh:88
void sendAList(XrdLink *lp)
int STHi
Definition: XrdCmsCluster.hh:242
int SelNode(XrdCmsSelect &Sel, SMask_t pmask, SMask_t amask)
long long SelRcnt
Definition: XrdCmsCluster.hh:246
Definition: XrdCmsCluster.hh:113
Definition: YProtocol.hh:82
static const int CMS_isSuper
Definition: XrdCmsCluster.hh:72
SMask_t Broadcast(SMask_t, const struct iovec *, int, int tot=0)
SMask_t getMask(const XrdNetAddr *addr)
Definition: YProtocol.hh:77
int SelDFS(XrdCmsSelect &Sel, SMask_t amask, SMask_t &pmask, SMask_t &smask, int isRW)
XrdCmsNode * SelbyLoad(SMask_t, XrdCmsSelector &selR)
#define XRDOUC_ENUM_OPERATORS(T)
Definition: XrdOucEnum.hh:22
XrdCmsNode * calcDelay(XrdCmsSelector &selR)
int Statt(char *bfr, int bln)
friend class XrdCmsDrop
Definition: XrdCmsCluster.hh:116
void setAltMan(int snum, XrdLink *lp, int port)
static const int CMS_isMan
Definition: XrdCmsCluster.hh:67
Definition: XrdCmsBaseFS.hh:48
long long SelRtot
Definition: XrdCmsCluster.hh:247
Definition: XrdCmsClustID.hh:40
@ LS_IDNT
Definition: XrdCmsCluster.hh:154
static const int CMS_isVers3
Definition: XrdCmsCluster.hh:74
Definition: XrdLink.hh:63
void SLock(bool dolock)
Definition: XrdCmsCluster.hh:196
static const int AltSize
Definition: XrdCmsCluster.hh:236
Definition: XrdCmsSelect.hh:101
long long SelWcnt
Definition: XrdCmsCluster.hh:244
@ eROfs
Definition: XrdCmsCluster.hh:221
static const int CMS_Lost
Definition: XrdCmsCluster.hh:68
XrdCmsNode * NodeTab[STMax]
Definition: XrdCmsCluster.hh:240
void Remove(XrdCmsNode *theNode)
int Locate(XrdCmsSelect &Sel)
int Drop(int sent, int sinst, XrdCmsDrop *djp=0)
static const int CMS_isProxy
Definition: XrdCmsCluster.hh:70
static const int CMS_noSpace
Definition: XrdCmsCluster.hh:71
int sUtil
Definition: XrdCmsCluster.hh:93
int Select(XrdCmsSelect &Sel)
void UnLock()
Definition: XrdSysPthread.hh:222
XrdCmsNode * Add(XrdLink *lp, int dport, int Status, int sport, const char *theNID, const char *theIF)
@ LS_IPO
Definition: XrdCmsCluster.hh:154
static const int RetryErr
Definition: XrdCmsCluster.hh:187
long long SelWtot
Definition: XrdCmsCluster.hh:245
void Lock()
Definition: XrdSysPthread.hh:220
Definition: XrdCmsSelect.hh:138
long long Refs()
Definition: XrdCmsCluster.hh:173
long long Total
Definition: XrdCmsCluster.hh:85
SMask_t peerHost
Definition: XrdCmsCluster.hh:261
virtual void BlackList(XrdOucTList *blP)
XrdSysMutex STMutex
Definition: XrdCmsCluster.hh:239
int Multiple(SMask_t mVec)
int sNum
Definition: XrdCmsCluster.hh:92
XrdSysMutex XXMutex
Definition: XrdCmsCluster.hh:238
static const int CMS_notServ
Definition: XrdCmsCluster.hh:76
int wUtil
Definition: XrdCmsCluster.hh:90
Definition: XrdNetAddr.hh:41
static const int CMS_Suspend
Definition: XrdCmsCluster.hh:65
@ eNoSel
Definition: XrdCmsCluster.hh:221
int sFree
Definition: XrdCmsCluster.hh:91
SMask_t resetMask
Definition: XrdCmsCluster.hh:260
Definition: XrdOucTList.hh:41
int NodeCnt
Definition: XrdCmsCluster.hh:118
XrdCmsNode * SelbyCost(SMask_t, XrdCmsSelector &selR)
int AltMent
Definition: XrdCmsCluster.hh:256
@ eExists
Definition: XrdCmsCluster.hh:221
virtual ~XrdCmsCluster()
Definition: XrdCmsCluster.hh:211
CmsLSOpts
Definition: XrdCmsCluster.hh:154