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