1 #ifndef __CMS_CLIENTMAN__
2 #define __CMS_CLIENTMAN__
64 int Send(
unsigned int &iMan,
char *msg,
int mlen=0);
65 int Send(
unsigned int &iMan,
const struct iovec *
iov,
66 int iovcnt,
int iotot=0);
73 if (!sVal)
return sVal;
83 int whatsUp(
const char *user,
const char *path,
XrdSysSemaphore syncResp
Definition: XrdCmsClientMan.hh:104
#define AtomicGet(x)
Definition: XrdSysAtomics.hh:71
int maxMsgID
Definition: XrdCmsClientMan.hh:122
char * Name()
Definition: XrdCmsClientMan.hh:59
int whatsUp(const char *user, const char *path, unsigned int iMan)
static void setConfig(const char *cfn)
Definition: XrdCmsClientMan.hh:81
Definition: YProtocol.hh:82
XrdOucBuffer * NetBuff
Definition: XrdCmsClientMan.hh:132
int manMask
Definition: XrdCmsClientMan.hh:114
static const char * ConfigFN
Definition: XrdCmsClientMan.hh:101
int waitTime()
Definition: XrdCmsClientMan.hh:86
int nrMax
Definition: XrdCmsClientMan.hh:121
int manPort()
Definition: XrdCmsClientMan.hh:62
int delayResp(XrdOucErrInfo &Resp)
static XrdSysMutex manMutex
Definition: XrdCmsClientMan.hh:98
int minDelay
Definition: XrdCmsClientMan.hh:125
int dally
Definition: XrdCmsClientMan.hh:115
#define AtomicBeg(Mtx)
Definition: XrdSysAtomics.hh:63
char * HPfx
Definition: XrdCmsClientMan.hh:111
static const int chkVal
Definition: XrdCmsClientMan.hh:102
int repWait
Definition: XrdCmsClientMan.hh:123
int RecvCnt
Definition: XrdCmsClientMan.hh:119
Definition: XrdSysPthread.hh:164
XrdSysMutex myData
Definition: XrdCmsClientMan.hh:108
char * Host
Definition: XrdCmsClientMan.hh:110
Definition: XrdOucIOVec.hh:65
#define AtomicEnd(Mtx)
Definition: XrdSysAtomics.hh:64
Definition: XrdLink.hh:51
static XrdInet * Network
Definition: XrdCmsClientMan.hh:100
int Port
Definition: XrdCmsClientMan.hh:112
Definition: XrdCmsResp.hh:123
Definition: XrdOucErrInfo.hh:100
Definition: XrdSysPthread.hh:493
static void setNetwork(XrdInet *nP)
Definition: XrdCmsClientMan.hh:79
XrdLink * Link
Definition: XrdCmsClientMan.hh:109
#define AtomicRet(mtx, x)
Definition: XrdSysAtomics.hh:76
int Suspend
Definition: XrdCmsClientMan.hh:118
static char doDebug
Definition: XrdCmsClientMan.hh:51
unsigned int manInst
Definition: XrdCmsClientMan.hh:113
int isActive()
Definition: XrdCmsClientMan.hh:55
static XrdOucBuffPool BuffPool
Definition: XrdCmsClientMan.hh:99
int SendCnt
Definition: XrdCmsClientMan.hh:120
Definition: XrdOucBuffer.hh:54
int repWMax
Definition: XrdCmsClientMan.hh:124
Definition: XrdOucBuffer.hh:140
char * NPfx()
Definition: XrdCmsClientMan.hh:60
int Send(unsigned int &iMan, char *msg, int mlen=0)
time_t lastUpdt
Definition: XrdCmsClientMan.hh:129
int chkCount
Definition: XrdCmsClientMan.hh:128
Definition: XrdCmsClientMan.hh:47
int Suspended()
Definition: XrdCmsClientMan.hh:70
int Silent
Definition: XrdCmsClientMan.hh:117
XrdCmsClientMan * nextManager()
Definition: XrdCmsClientMan.hh:57
XrdCmsClientMan * Next
Definition: XrdCmsClientMan.hh:107
XrdCms::CmsRRHdr Response
Definition: XrdCmsClientMan.hh:131
int Active
Definition: XrdCmsClientMan.hh:116
void setNext(XrdCmsClientMan *np)
Definition: XrdCmsClientMan.hh:77
int maxDelay
Definition: XrdCmsClientMan.hh:126
XrdCmsClientMan(char *host, int port, int cw, int nr, int rw, int rd)
int qTime
Definition: XrdCmsClientMan.hh:127
Definition: XrdInet.hh:47
XrdCmsRespQ RespQ
Definition: XrdCmsClientMan.hh:105
time_t lastTOut
Definition: XrdCmsClientMan.hh:130