1 #ifndef __XRDCMSRRQ_HH__
2 #define __XRDCMSRRQ_HH__
110 void Del(
short Snum,
const void *Key);
112 int Init(
int Tint=0,
int Tdly=0);
unsigned int kXR_unt32
Definition: XPtypes.hh:90
#define STMax
Definition: XrdCmsTypes.hh:39
unsigned long long SMask_t
Definition: XrdCmsTypes.hh:33
Definition: XrdCmsRRQ.hh:47
char actR
Definition: XrdCmsRRQ.hh:56
~XrdCmsRRQInfo()
Definition: XrdCmsRRQ.hh:66
char minR
Definition: XrdCmsRRQ.hh:55
XrdCmsRRQInfo()
Definition: XrdCmsRRQ.hh:61
void * Key
Definition: XrdCmsRRQ.hh:49
SMask_t rwVec
Definition: XrdCmsRRQ.hh:59
short Rnum
Definition: XrdCmsRRQ.hh:52
char lsLU
Definition: XrdCmsRRQ.hh:57
XrdCmsRRQInfo(int rinst, short rnum, kXR_unt32 id, int minQ=0)
Definition: XrdCmsRRQ.hh:62
char isRW
Definition: XrdCmsRRQ.hh:53
int Rinst
Definition: XrdCmsRRQ.hh:51
char isLU
Definition: XrdCmsRRQ.hh:54
kXR_unt32 ID
Definition: XrdCmsRRQ.hh:50
char ifOP
Definition: XrdCmsRRQ.hh:58
Definition: XrdCmsRRQ.hh:74
unsigned int Expire
Definition: XrdCmsRRQ.hh:96
SMask_t Arg2
Definition: XrdCmsRRQ.hh:95
static XrdSysMutex myMutex
Definition: XrdCmsRRQ.hh:86
XrdCmsRRQSlot * LkUp
Definition: XrdCmsRRQ.hh:92
~XrdCmsRRQSlot()
Definition: XrdCmsRRQ.hh:82
int slotNum
Definition: XrdCmsRRQ.hh:97
static XrdCmsRRQSlot * Alloc(XrdCmsRRQInfo *Info)
static XrdCmsRRQSlot * freeSlot
Definition: XrdCmsRRQ.hh:87
XrdCmsRRQInfo Info
Definition: XrdCmsRRQ.hh:93
XrdOucDLlist< XrdCmsRRQSlot > Link
Definition: XrdCmsRRQ.hh:90
XrdCmsRRQSlot * Cont
Definition: XrdCmsRRQ.hh:91
static short initSlot
Definition: XrdCmsRRQ.hh:88
SMask_t Arg1
Definition: XrdCmsRRQ.hh:94
Definition: XrdCmsRRQ.hh:105
void sendRedResp(XrdCmsRRQSlot *rP)
int Init(int Tint=0, int Tdly=0)
int rdFast
Definition: XrdCmsRRQ.hh:179
char databuff[XrdCms::CmsLocateRequest::RHLen *STMax]
Definition: XrdCmsRRQ.hh:174
XrdCms::CmsResponse waitResp
Definition: XrdCmsRRQ.hh:171
void Statistics(Info &Data)
Definition: XrdCmsRRQ.hh:144
int rdSlow
Definition: XrdCmsRRQ.hh:180
XrdCmsRRQ()
Definition: XrdCmsRRQ.hh:148
XrdCms::CmsResponse redrResp
Definition: XrdCmsRRQ.hh:170
static const int iov_cnt
Definition: XrdCmsRRQ.hh:166
int luFast
Definition: XrdCmsRRQ.hh:177
XrdSysSemaphore isReady
Definition: XrdCmsRRQ.hh:162
XrdOucDLlist< XrdCmsRRQSlot > readyQ
Definition: XrdCmsRRQ.hh:165
struct iovec redr_iov[iov_cnt]
Definition: XrdCmsRRQ.hh:168
~XrdCmsRRQ()
Definition: XrdCmsRRQ.hh:151
int Tslice
Definition: XrdCmsRRQ.hh:181
XrdSysMutex myMutex
Definition: XrdCmsRRQ.hh:160
Info Stats
Definition: XrdCmsRRQ.hh:176
short Add(short Snum, XrdCmsRRQInfo *ip)
void sendLwtResp(XrdCmsRRQSlot *rP)
int Tdelay
Definition: XrdCmsRRQ.hh:182
void sendLocResp(XrdCmsRRQSlot *lP)
static const int numSlots
Definition: XrdCmsRRQ.hh:158
char hostbuff[288]
Definition: XrdCmsRRQ.hh:172
unsigned int myClock
Definition: XrdCmsRRQ.hh:183
struct iovec data_iov[iov_cnt]
Definition: XrdCmsRRQ.hh:167
void Del(short Snum, const void *Key)
XrdOucDLlist< XrdCmsRRQSlot > waitQ
Definition: XrdCmsRRQ.hh:164
XrdSysSemaphore isWaiting
Definition: XrdCmsRRQ.hh:161
int Ready(int Snum, const void *Key, SMask_t mask1, SMask_t mask2)
XrdCms::CmsResponse dataResp
Definition: XrdCmsRRQ.hh:169
int luSlow
Definition: XrdCmsRRQ.hh:178
XrdCmsRRQSlot Slot[numSlots]
Definition: XrdCmsRRQ.hh:163
Definition: XrdSysPthread.hh:165
void Lock()
Definition: XrdSysPthread.hh:222
void UnLock()
Definition: XrdSysPthread.hh:224
Definition: XrdSysPthread.hh:494
Definition: YProtocol.hh:78
Definition: XrdCmsRRQ.hh:119
long long luSlow
Definition: XrdCmsRRQ.hh:139
long long rdSlow
Definition: XrdCmsRRQ.hh:141
long long Resp
Definition: XrdCmsRRQ.hh:136
void Reset()
Definition: XrdCmsRRQ.hh:123
long long luFast
Definition: XrdCmsRRQ.hh:138
long long Add2Q
Definition: XrdCmsRRQ.hh:134
long long Multi
Definition: XrdCmsRRQ.hh:137
long long rdFast
Definition: XrdCmsRRQ.hh:140
Info()
Definition: XrdCmsRRQ.hh:120
long long PBack
Definition: XrdCmsRRQ.hh:135
static const int RHLen
Definition: YProtocol.hh:264
Definition: YProtocol.hh:168