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