#include <XrdCmsCluster.hh>
|
XrdCmsNode * | Add (XrdLink *lp, int dport, int Status, int sport, const char *theNID, const char *theIF) |
|
virtual void | BlackList (XrdOucTList *blP) |
|
SMask_t | Broadcast (SMask_t, const struct iovec *, int, int tot=0) |
|
SMask_t | Broadcast (SMask_t smask, XrdCms::CmsRRHdr &Hdr, char *Data, int Dlen=0) |
|
SMask_t | Broadcast (SMask_t smask, XrdCms::CmsRRHdr &Hdr, void *Data, int Dlen) |
|
int | Broadsend (SMask_t smask, XrdCms::CmsRRHdr &Hdr, void *Data, int Dlen) |
|
SMask_t | getMask (const XrdNetAddr *addr) |
|
SMask_t | getMask (const char *Cid) |
|
XrdCmsSelected * | List (SMask_t mask, CmsLSOpts opts, bool &oksel) |
|
int | Locate (XrdCmsSelect &Sel) |
|
void * | MonPerf () |
|
void * | MonRefs () |
|
long long | Refs () |
|
void | Remove (XrdCmsNode *theNode) |
|
void | Remove (const char *reason, XrdCmsNode *theNode, int immed=0) |
|
void | ResetRef (SMask_t smask, bool isLocked=false) |
|
int | Select (XrdCmsSelect &Sel) |
|
int | Select (SMask_t pmask, int &port, char *hbuff, int &hlen, int isrw, int isMulti, int ifWant) |
|
void | SLock (bool dolock, bool wrmode=true) |
|
void | Space (XrdCms::SpaceData &sData, SMask_t smask) |
|
int | Stats (char *bfr, int bln) |
|
int | Statt (char *bfr, int bln) |
|
| XrdCmsCluster () |
|
virtual | ~XrdCmsCluster () |
|
|
XrdCmsNode * | AddAlt (XrdCmsClustID *cidP, XrdLink *lp, int port, int Status, int sport, const char *theNID, const char *theIF) |
|
XrdCmsNode * | calcDelay (XrdCmsSelector &selR) |
|
int | Drop (int sent, int sinst, XrdCmsDrop *djp=0) |
|
void | Record (char *path, const char *reason, bool force=false) |
|
bool | maxBits (SMask_t mVec, int mbits) |
|
int | Multiple (SMask_t mVec) |
|
int | SelFail (XrdCmsSelect &Sel, int rc) |
|
int | SelNode (XrdCmsSelect &Sel, SMask_t pmask, SMask_t amask) |
|
XrdCmsNode * | SelbyCost (SMask_t, XrdCmsSelector &selR) |
|
XrdCmsNode * | SelbyLoad (SMask_t, XrdCmsSelector &selR) |
|
XrdCmsNode * | SelbyRef (SMask_t, XrdCmsSelector &selR) |
|
int | SelDFS (XrdCmsSelect &Sel, SMask_t amask, SMask_t &pmask, SMask_t &smask, int isRW) |
|
void | sendAList (XrdLink *lp) |
|
void | setAltMan (int snum, XrdLink *lp, int port) |
|
int | Unreachable (XrdCmsSelect &Sel, bool none) |
|
int | Unuseable (XrdCmsSelect &Sel) |
|
◆ anonymous enum
Enumerator |
---|
eExists | |
eDups | |
eROfs | |
eNoRep | |
eNoSel | |
eNoEnt | |
◆ CmsLSOpts
Enumerator |
---|
LS_NULL | |
LS_IPO | |
LS_IDNT | |
LS_ANY | |
LS_IFMASK | |
◆ XrdCmsCluster()
XrdCmsCluster::XrdCmsCluster |
( |
| ) |
|
◆ ~XrdCmsCluster()
virtual XrdCmsCluster::~XrdCmsCluster |
( |
| ) |
|
|
inlinevirtual |
◆ Add()
XrdCmsNode * XrdCmsCluster::Add |
( |
XrdLink * |
lp, |
|
|
int |
dport, |
|
|
int |
Status, |
|
|
int |
sport, |
|
|
const char * |
theNID, |
|
|
const char * |
theIF |
|
) |
| |
◆ AddAlt()
◆ BlackList()
virtual void XrdCmsCluster::BlackList |
( |
XrdOucTList * |
blP | ) |
|
|
virtual |
◆ Broadcast() [1/3]
◆ Broadcast() [2/3]
◆ Broadcast() [3/3]
SMask_t XrdCmsCluster::Broadcast |
( |
SMask_t |
, |
|
|
const struct iovec * |
, |
|
|
int |
, |
|
|
int |
tot = 0 |
|
) |
| |
◆ Broadsend()
◆ calcDelay()
◆ Drop()
int XrdCmsCluster::Drop |
( |
int |
sent, |
|
|
int |
sinst, |
|
|
XrdCmsDrop * |
djp = 0 |
|
) |
| |
|
private |
◆ getMask() [1/2]
SMask_t XrdCmsCluster::getMask |
( |
const char * |
Cid | ) |
|
◆ getMask() [2/2]
◆ List()
◆ Locate()
◆ maxBits()
bool XrdCmsCluster::maxBits |
( |
SMask_t |
mVec, |
|
|
int |
mbits |
|
) |
| |
|
private |
◆ MonPerf()
void * XrdCmsCluster::MonPerf |
( |
| ) |
|
◆ MonRefs()
void * XrdCmsCluster::MonRefs |
( |
| ) |
|
◆ Multiple()
int XrdCmsCluster::Multiple |
( |
SMask_t |
mVec | ) |
|
|
private |
◆ Record()
void XrdCmsCluster::Record |
( |
char * |
path, |
|
|
const char * |
reason, |
|
|
bool |
force = false |
|
) |
| |
|
private |
◆ Refs()
long long XrdCmsCluster::Refs |
( |
| ) |
|
|
inline |
◆ Remove() [1/2]
void XrdCmsCluster::Remove |
( |
const char * |
reason, |
|
|
XrdCmsNode * |
theNode, |
|
|
int |
immed = 0 |
|
) |
| |
◆ Remove() [2/2]
void XrdCmsCluster::Remove |
( |
XrdCmsNode * |
theNode | ) |
|
◆ ResetRef()
void XrdCmsCluster::ResetRef |
( |
SMask_t |
smask, |
|
|
bool |
isLocked = false |
|
) |
| |
◆ SelbyCost()
◆ SelbyLoad()
◆ SelbyRef()
◆ SelDFS()
◆ Select() [1/2]
int XrdCmsCluster::Select |
( |
SMask_t |
pmask, |
|
|
int & |
port, |
|
|
char * |
hbuff, |
|
|
int & |
hlen, |
|
|
int |
isrw, |
|
|
int |
isMulti, |
|
|
int |
ifWant |
|
) |
| |
◆ Select() [2/2]
◆ SelFail()
◆ SelNode()
◆ sendAList()
void XrdCmsCluster::sendAList |
( |
XrdLink * |
lp | ) |
|
|
private |
◆ setAltMan()
void XrdCmsCluster::setAltMan |
( |
int |
snum, |
|
|
XrdLink * |
lp, |
|
|
int |
port |
|
) |
| |
|
private |
◆ SLock()
void XrdCmsCluster::SLock |
( |
bool |
dolock, |
|
|
bool |
wrmode = true |
|
) |
| |
|
inline |
◆ Space()
◆ Stats()
int XrdCmsCluster::Stats |
( |
char * |
bfr, |
|
|
int |
bln |
|
) |
| |
◆ Statt()
int XrdCmsCluster::Statt |
( |
char * |
bfr, |
|
|
int |
bln |
|
) |
| |
◆ Unreachable()
int XrdCmsCluster::Unreachable |
( |
XrdCmsSelect & |
Sel, |
|
|
bool |
none |
|
) |
| |
|
private |
◆ Unuseable()
◆ XrdCmsDrop
◆ AltMans
◆ AltMend
char* XrdCmsCluster::AltMend |
|
private |
◆ AltMent
int XrdCmsCluster::AltMent |
|
private |
◆ AltSize
const int XrdCmsCluster::AltSize = 254 |
|
staticprivate |
◆ EReplete
const int XrdCmsCluster::EReplete = -4 |
|
static |
◆ NodeCnt
int XrdCmsCluster::NodeCnt |
◆ NodeTab
◆ NotFound
const int XrdCmsCluster::NotFound = -1 |
|
static |
◆ peerHost
◆ peerMask
◆ Reserved
int XrdCmsCluster::Reserved |
|
private |
◆ RetryErr
const int XrdCmsCluster::RetryErr = -3 |
|
static |
◆ SelRtot
◆ SelTcnt
◆ SelWtot
◆ STHi
◆ STMutex
◆ Wait4CBk
const int XrdCmsCluster::Wait4CBk = -2 |
|
static |
The documentation for this class was generated from the following file: