xrootd
|
#include <XrdCmsRRQ.hh>
Classes | |
struct | Info |
Public Member Functions | |
short | Add (short Snum, XrdCmsRRQInfo *ip) |
void | Del (short Snum, const void *Key) |
int | Init (int Tint=0, int Tdly=0) |
int | Ready (int Snum, const void *Key, SMask_t mask1, SMask_t mask2) |
void * | Respond () |
void | Statistics (Info &Data) |
void * | TimeOut () |
XrdCmsRRQ () | |
~XrdCmsRRQ () | |
Private Member Functions | |
void | sendLocResp (XrdCmsRRQSlot *lP) |
void | sendLwtResp (XrdCmsRRQSlot *rP) |
void | sendRedResp (XrdCmsRRQSlot *rP) |
Private Attributes | |
XrdSysMutex | myMutex |
XrdSysSemaphore | isWaiting |
XrdSysSemaphore | isReady |
XrdCmsRRQSlot | Slot [numSlots] |
XrdOucDLlist< XrdCmsRRQSlot > | waitQ |
XrdOucDLlist< XrdCmsRRQSlot > | readyQ |
struct iovec | data_iov [iov_cnt] |
struct iovec | redr_iov [iov_cnt] |
XrdCms::CmsResponse | dataResp |
XrdCms::CmsResponse | redrResp |
XrdCms::CmsResponse | waitResp |
union { | |
char hostbuff [288] | |
char databuff [XrdCms::CmsLocateRequest::RHLen *STMax] | |
}; | |
Info | Stats |
int | luFast |
int | luSlow |
int | rdFast |
int | rdSlow |
int | Tslice |
int | Tdelay |
unsigned int | myClock |
Static Private Attributes | |
static const int | numSlots = 1024 |
static const int | iov_cnt = 2 |
|
inline |
|
inline |
short XrdCmsRRQ::Add | ( | short | Snum, |
XrdCmsRRQInfo * | ip | ||
) |
void XrdCmsRRQ::Del | ( | short | Snum, |
const void * | Key | ||
) |
int XrdCmsRRQ::Init | ( | int | Tint = 0 , |
int | Tdly = 0 |
||
) |
void* XrdCmsRRQ::Respond | ( | ) |
|
private |
|
private |
|
private |
|
inline |
References XrdSysMutex::Lock(), myMutex, Stats, and XrdSysMutex::UnLock().
void* XrdCmsRRQ::TimeOut | ( | ) |
union { ... } |
|
private |
char XrdCmsRRQ::databuff[XrdCms::CmsLocateRequest::RHLen *STMax] |
|
private |
char XrdCmsRRQ::hostbuff[288] |
|
staticprivate |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
Referenced by Statistics().
|
staticprivate |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
Referenced by Statistics().
|
private |
|
private |
|
private |
|
private |