|
Public Member Functions |
void | DoIt () |
XrdProtocol * | Match (XrdLink *lp) |
int | Process (XrdLink *lp) |
void | Recycle (XrdLink *lp, int consec, const char *reason) |
int | Stats (char *buff, int blen, int do_sync=0) |
XrdXrootdProtocol | operator= (const XrdXrootdProtocol &rhs) |
| XrdXrootdProtocol () |
| ~XrdXrootdProtocol () |
Static Public Member Functions |
int | Configure (char *parms, XrdProtocol_Config *pi) |
int | StatGen (struct stat &buf, char *xxBuff) |
Protected Attributes |
int | numReads |
int | numReadP |
int | numWrites |
int | numFiles |
int | cumReads |
int | cumReadP |
int | cumWrites |
long long | totReadP |
XrdLink * | Link |
XrdBuffer * | argp |
XrdXrootdFileTable * | FTab |
XrdXrootdMonitor * | Monitor |
kXR_unt32 | monUID |
char | monFILE |
char | monIO |
char | Status |
unsigned char | CapVer |
XrdSecEntity * | Client |
XrdSecProtocol * | AuthProt |
XrdSecEntity | Entity |
XrdXrootdAioReq * | myAioReq |
char * | myBuff |
int | myBlen |
int | myBlast |
int(XrdXrootdProtocol::* | Resume )() |
XrdXrootdFile * | myFile |
long long | myOffset |
int | myIOLen |
int | myStalls |
int | hcPrev |
int | hcNext |
int | hcNow |
int | halfBSize |
XrdSysMutex | streamMutex |
XrdSysSemaphore * | reTry |
XrdXrootdProtocol * | Stream [maxStreams] |
unsigned int | mySID |
char | isActive |
char | isDead |
char | isBound |
char | isNOP |
XrdXrootdPio * | pioFirst |
XrdXrootdPio * | pioLast |
XrdXrootdPio * | pioFree |
short | PathID |
char | doWrite |
char | doWriteC |
XrdXrootdReqID | ReqID |
ClientRequest | Request |
XrdXrootdResponse | Response |
Static Protected Attributes |
XrdXrootdXPath | RPList |
XrdXrootdXPath | XPList |
XrdSfsFileSystem * | osFS |
XrdSecService * | CIA = 0 |
XrdXrootdFileLock * | Locker |
XrdScheduler * | Sched |
XrdBuffManager * | BPool |
XrdSysError | eDest |
const char * | myInst = 0 |
const char * | TraceID = "Protocol" |
char * | pidPath = strdup("/tmp") |
int | myPID = static_cast<int>(getpid()) |
XrdNetSocket * | AdminSock = 0 |
int | hailWait |
int | readWait |
int | Port |
int | Window |
int | WANPort |
int | WANWindow |
char * | SecLib = 0 |
char * | FSLib = 0 |
char * | Notify = 0 |
char | isRedir = 0 |
char | chkfsV = 0 |
XrdXrootdJob * | JobCKS = 0 |
char * | JobCKT = 0 |
XrdXrootdProtocol::RD_Table | Route [RD_Num] |
int | as_maxperlnk = 8 |
int | as_maxperreq = 8 |
int | as_maxpersrv = 4096 |
int | as_miniosz = 32768 |
int | as_minsfsz = 8192 |
int | as_segsize = 131072 |
int | as_maxstalls = 5 |
int | as_force = 0 |
int | as_noaio = 0 |
int | as_nosf = 0 |
int | as_syncw = 0 |
int | maxBuffsz |
int | maxTransz = 262144 |
const int | maxRvecsz = 1024 |
XrdXrootdStats * | SI |
int | hcMax = 28657 |
const int | maxStreams = 16 |
const int | maxPio = 4 |
Private Types |
enum | RD_func {
RD_chmod = 0,
RD_dirlist,
RD_locate,
RD_mkdir,
RD_mv,
RD_prepare,
RD_prepstg,
RD_rm,
RD_rmdir,
RD_stat,
RD_open1,
RD_open2,
RD_open3,
RD_open4,
RD_Num
} |
Private Member Functions |
int | do_Admin () |
int | do_Auth () |
int | do_Bind () |
int | do_Chmod () |
int | do_CKsum (int canit) |
int | do_Close () |
int | do_Dirlist () |
int | do_Endsess () |
int | do_Getfile () |
int | do_Login () |
int | do_Locate () |
int | do_Mkdir () |
int | do_Mv () |
int | do_Offload (int pathID, int isRead) |
int | do_OffloadIO () |
int | do_Open () |
int | do_Ping () |
int | do_Prepare () |
int | do_Protocol () |
int | do_Putfile () |
int | do_Qconf () |
int | do_Qfh () |
int | do_Qopaque (short) |
int | do_Qspace () |
int | do_Query () |
int | do_Qxattr () |
int | do_Read () |
int | do_ReadV () |
int | do_ReadAll (int asyncOK=1) |
int | do_ReadNone (int &retc, int &pathID) |
int | do_Rm () |
int | do_Rmdir () |
int | do_Set () |
int | do_Set_Mon (XrdOucTokenizer &setargs) |
int | do_Stat () |
int | do_Statx () |
int | do_Sync () |
int | do_Truncate () |
int | do_Write () |
int | do_WriteAll () |
int | do_WriteCont () |
int | do_WriteNone () |
int | aio_Error (const char *op, int ecode) |
int | aio_Read () |
int | aio_Write () |
int | aio_WriteAll () |
int | aio_WriteCont () |
void | Assign (const XrdXrootdProtocol &rhs) |
void | Cleanup () |
int | fsError (int rc, XrdOucErrInfo &myError) |
int | getBuff (const int isRead, int Quantum) |
int | getData (const char *dtype, char *buff, int blen) |
int | Process2 () |
void | Reset () |
int | rpEmsg (const char *op, char *fn) |
int | vpEmsg (const char *op, char *fn) |
Static Private Member Functions |
int | Config (const char *fn) |
int | mapMode (int mode) |
void | PidFile () |
int | rpCheck (char *fn, const char **opaque) |
int | Squash (char *) |
int | xapath (XrdOucStream &Config) |
int | xasync (XrdOucStream &Config) |
int | xcksum (XrdOucStream &Config) |
int | xexp (XrdOucStream &Config) |
int | xexpdo (char *path, int popt=0) |
int | xfsl (XrdOucStream &Config) |
int | xpidf (XrdOucStream &Config) |
int | xprep (XrdOucStream &Config) |
int | xlog (XrdOucStream &Config) |
int | xmon (XrdOucStream &Config) |
int | xred (XrdOucStream &Config) |
void | xred_set (RD_func func, const char *rHost, int rPort) |
int | xsecl (XrdOucStream &Config) |
int | xtrace (XrdOucStream &Config) |
Private Attributes |
XrdObject< XrdXrootdProtocol > | ProtLink |
Static Private Attributes |
XrdObjectQ< XrdXrootdProtocol > | ProtStack |
Friends |
class | XrdXrootdAdmin |
class | XrdXrootdAioReq |