#include <XrdXrootdProtocol.hh>
|
enum | RD_func {
RD_chmod = 0,
RD_chksum,
RD_dirlist,
RD_locate,
RD_mkdir,
RD_mv,
RD_prepare,
RD_prepstg,
RD_rm,
RD_rmdir,
RD_stat,
RD_trunc,
RD_ovld,
RD_open1,
RD_open2,
RD_open3,
RD_open4,
RD_Num
} |
|
|
int | do_Admin () |
|
int | do_Auth () |
|
int | do_Bind () |
|
int | do_Chmod () |
|
int | do_CKsum (int canit) |
|
int | do_CKsum (char *algT, const char *Path, char *Opaque) |
|
int | do_Close () |
|
int | do_Dirlist () |
|
int | do_DirStat (XrdSfsDirectory *dp, char *pbuff, char *opaque) |
|
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 (bool isQuery=false) |
|
int | do_Protocol (ServerResponseBody_Protocol *rsp=0) |
|
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 | do_WriteV () |
|
int | do_WriteVec () |
|
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, char opc, XrdOucErrInfo &myError, const char *Path, char *Cgi) |
|
int | fsOvrld (char opc, const char *Path, char *Cgi) |
|
int | fsRedirNoEnt (const char *eMsg, char *Cgi, int popt) |
|
int | getBuff (const int isRead, int Quantum) |
|
int | getData (const char *dtype, char *buff, int blen) |
|
void | logLogin (bool xauth=false) |
|
void | Reset () |
|
int | rpEmsg (const char *op, char *fn) |
|
int | vpEmsg (const char *op, char *fn) |
|
|
static int | CheckSum (XrdOucStream *, char **, int) |
|
static int | Config (const char *fn) |
|
static int | ConfigSecurity (XrdOucEnv &xEnv, const char *cfn) |
|
static int | mapMode (int mode) |
|
static void | PidFile () |
|
static int | rpCheck (char *fn, char **opaque) |
|
static int | Squash (char *) |
|
static int | xapath (XrdOucStream &Config) |
|
static int | xasync (XrdOucStream &Config) |
|
static int | xcksum (XrdOucStream &Config) |
|
static int | xdig (XrdOucStream &Config) |
|
static int | xexp (XrdOucStream &Config) |
|
static int | xexpdo (char *path, int popt=0) |
|
static int | xfsl (XrdOucStream &Config) |
|
static int | xfsL (XrdOucStream &Config, char *val, int lix) |
|
static int | xfso (XrdOucStream &Config) |
|
static int | xpidf (XrdOucStream &Config) |
|
static int | xprep (XrdOucStream &Config) |
|
static int | xlog (XrdOucStream &Config) |
|
static int | xmon (XrdOucStream &Config) |
|
static int | xred (XrdOucStream &Config) |
|
static bool | xred_php (char *val, char *hP[2], int rPort[2]) |
|
static void | xred_set (RD_func func, char *rHost[2], int rPort[2]) |
|
static bool | xred_xok (int func, char *rHost[2], int rPort[2]) |
|
static int | xsecl (XrdOucStream &Config) |
|
static int | xtrace (XrdOucStream &Config) |
|
static int | xlimit (XrdOucStream &Config) |
|
Enumerator |
---|
RD_chmod |
|
RD_chksum |
|
RD_dirlist |
|
RD_locate |
|
RD_mkdir |
|
RD_mv |
|
RD_prepare |
|
RD_prepstg |
|
RD_rm |
|
RD_rmdir |
|
RD_stat |
|
RD_trunc |
|
RD_ovld |
|
RD_open1 |
|
RD_open2 |
|
RD_open3 |
|
RD_open4 |
|
RD_Num |
|
XrdXrootdProtocol::XrdXrootdProtocol |
( |
| ) |
|
XrdXrootdProtocol::~XrdXrootdProtocol |
( |
| ) |
|
|
inline |
int XrdXrootdProtocol::aio_Error |
( |
const char * |
op, |
|
|
int |
ecode |
|
) |
| |
|
private |
int XrdXrootdProtocol::aio_Read |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::aio_Write |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::aio_WriteAll |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::aio_WriteCont |
( |
| ) |
|
|
private |
static int XrdXrootdProtocol::CheckSum |
( |
XrdOucStream * |
, |
|
|
char ** |
, |
|
|
int |
|
|
) |
| |
|
staticprivate |
void XrdXrootdProtocol::Cleanup |
( |
| ) |
|
|
private |
static int XrdXrootdProtocol::Config |
( |
const char * |
fn | ) |
|
|
staticprivate |
static int XrdXrootdProtocol::ConfigSecurity |
( |
XrdOucEnv & |
xEnv, |
|
|
const char * |
cfn |
|
) |
| |
|
staticprivate |
int XrdXrootdProtocol::do_Admin |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_Auth |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_Bind |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_Chmod |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_CKsum |
( |
int |
canit | ) |
|
|
private |
int XrdXrootdProtocol::do_CKsum |
( |
char * |
algT, |
|
|
const char * |
Path, |
|
|
char * |
Opaque |
|
) |
| |
|
private |
int XrdXrootdProtocol::do_Close |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_Dirlist |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_DirStat |
( |
XrdSfsDirectory * |
dp, |
|
|
char * |
pbuff, |
|
|
char * |
opaque |
|
) |
| |
|
private |
int XrdXrootdProtocol::do_Endsess |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_Getfile |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_Locate |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_Login |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_Mkdir |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_Mv |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_Offload |
( |
int |
pathID, |
|
|
int |
isRead |
|
) |
| |
|
private |
int XrdXrootdProtocol::do_OffloadIO |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_Open |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_Ping |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_Prepare |
( |
bool |
isQuery = false | ) |
|
|
private |
int XrdXrootdProtocol::do_Putfile |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_Qconf |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_Qfh |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_Qopaque |
( |
short |
| ) |
|
|
private |
int XrdXrootdProtocol::do_Qspace |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_Query |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_Qxattr |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_Read |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_ReadAll |
( |
int |
asyncOK = 1 | ) |
|
|
private |
int XrdXrootdProtocol::do_ReadNone |
( |
int & |
retc, |
|
|
int & |
pathID |
|
) |
| |
|
private |
int XrdXrootdProtocol::do_ReadV |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_Rm |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_Rmdir |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_Set |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_Stat |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_Statx |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_Sync |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_Truncate |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_Write |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_WriteAll |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_WriteCont |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_WriteNone |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_WriteSpan |
( |
| ) |
|
int XrdXrootdProtocol::do_WriteV |
( |
| ) |
|
|
private |
int XrdXrootdProtocol::do_WriteVec |
( |
| ) |
|
|
private |
void XrdXrootdProtocol::DoIt |
( |
| ) |
|
|
inlinevirtual |
int XrdXrootdProtocol::fsError |
( |
int |
rc, |
|
|
char |
opc, |
|
|
XrdOucErrInfo & |
myError, |
|
|
const char * |
Path, |
|
|
char * |
Cgi |
|
) |
| |
|
private |
int XrdXrootdProtocol::fsOvrld |
( |
char |
opc, |
|
|
const char * |
Path, |
|
|
char * |
Cgi |
|
) |
| |
|
private |
int XrdXrootdProtocol::fsRedirNoEnt |
( |
const char * |
eMsg, |
|
|
char * |
Cgi, |
|
|
int |
popt |
|
) |
| |
|
private |
int XrdXrootdProtocol::getBuff |
( |
const int |
isRead, |
|
|
int |
Quantum |
|
) |
| |
|
private |
int XrdXrootdProtocol::getData |
( |
const char * |
dtype, |
|
|
char * |
buff, |
|
|
int |
blen |
|
) |
| |
|
private |
void XrdXrootdProtocol::logLogin |
( |
bool |
xauth = false | ) |
|
|
private |
static int XrdXrootdProtocol::mapMode |
( |
int |
mode | ) |
|
|
staticprivate |
void XrdXrootdProtocol::MonAuth |
( |
| ) |
|
|
protected |
static void XrdXrootdProtocol::PidFile |
( |
| ) |
|
|
staticprivate |
int XrdXrootdProtocol::Process |
( |
XrdLink * |
lp | ) |
|
|
virtual |
int XrdXrootdProtocol::Process2 |
( |
| ) |
|
int XrdXrootdProtocol::ProcSig |
( |
| ) |
|
void XrdXrootdProtocol::Recycle |
( |
XrdLink * |
lp, |
|
|
int |
consec, |
|
|
const char * |
reason |
|
) |
| |
|
virtual |
void XrdXrootdProtocol::Reset |
( |
| ) |
|
|
private |
static int XrdXrootdProtocol::rpCheck |
( |
char * |
fn, |
|
|
char ** |
opaque |
|
) |
| |
|
staticprivate |
int XrdXrootdProtocol::rpEmsg |
( |
const char * |
op, |
|
|
char * |
fn |
|
) |
| |
|
private |
int XrdXrootdProtocol::SendFile |
( |
int |
fildes | ) |
|
|
virtual |
Send data to a client using the sendfile() system interface.
- Parameters
-
fildes | - The file descriptor to use to effect a sendfile() for all of the requested data. The original offset and length are used relative to this file descriptor. |
- Returns
- >0 - data has been sent in a previous call. This is indicative of a logic error in SendData() as only one call is allowed.
-
=0 - data has been sent.
-
<0 - A fatal transmission error occurred. SendData() should return SFS_ERROR to force the connection to be closed.
Implements XrdSfsDio.
int XrdXrootdProtocol::SendFile |
( |
XrdOucSFVec * |
sfvec, |
|
|
int |
sfvnum |
|
) |
| |
|
virtual |
Send data to a client using the sendfile() system interface.
- Parameters
-
sfvec | - One or more XrdOucSFVec elements describing what should be transferred. The first element of the vector must be available for use by the interface for proper framing. That is, start filling in elements at sfvec[1] and sfvnum should be the count of elements filled in plus 1. |
sfvnum | - total number of elements in sfvec and includes the first unused element. There is a maximum number of elements that the vector may have; defined inside XrdOucSFVec. |
- Returns
- >0 - either data has been sent in a previous call or the total amount of data in sfvec is greater than the original request. This is indicative of a SendData() logic error.
-
=0 - data has been sent.
-
<0 - A fatal transmission error occurred. SendData() should return SFS_ERROR to force the connection to be closed.
Implements XrdSfsDio.
void XrdXrootdProtocol::SetFD |
( |
int |
fildes | ) |
|
|
virtual |
Change the file descriptor setting and, consequently, interface processing.
- Parameters
-
fildes | - The file descriptor to use in the future, as follows: < 0 - Disable sendfile and always use read(). >= 0 - Enable sendfile and always use sendfile() w/o invoking this interface (i.e. fast path). |
Implements XrdSfsDio.
int XrdXrootdProtocol::SetSF |
( |
kXR_char * |
fhandle, |
|
|
bool |
seton = false |
|
) |
| |
|
protected |
static int XrdXrootdProtocol::Squash |
( |
char * |
| ) |
|
|
staticprivate |
static int XrdXrootdProtocol::StatGen |
( |
struct stat & |
buf, |
|
|
char * |
xxBuff |
|
) |
| |
|
static |
int XrdXrootdProtocol::Stats |
( |
char * |
buff, |
|
|
int |
blen, |
|
|
int |
do_sync = 0 |
|
) |
| |
|
virtual |
int XrdXrootdProtocol::vpEmsg |
( |
const char * |
op, |
|
|
char * |
fn |
|
) |
| |
|
private |
static int XrdXrootdProtocol::xapath |
( |
XrdOucStream & |
Config | ) |
|
|
staticprivate |
static int XrdXrootdProtocol::xasync |
( |
XrdOucStream & |
Config | ) |
|
|
staticprivate |
static int XrdXrootdProtocol::xcksum |
( |
XrdOucStream & |
Config | ) |
|
|
staticprivate |
static int XrdXrootdProtocol::xexpdo |
( |
char * |
path, |
|
|
int |
popt = 0 |
|
) |
| |
|
staticprivate |
static int XrdXrootdProtocol::xfsL |
( |
XrdOucStream & |
Config, |
|
|
char * |
val, |
|
|
int |
lix |
|
) |
| |
|
staticprivate |
static int XrdXrootdProtocol::xlimit |
( |
XrdOucStream & |
Config | ) |
|
|
staticprivate |
static int XrdXrootdProtocol::xpidf |
( |
XrdOucStream & |
Config | ) |
|
|
staticprivate |
static int XrdXrootdProtocol::xprep |
( |
XrdOucStream & |
Config | ) |
|
|
staticprivate |
static bool XrdXrootdProtocol::xred_php |
( |
char * |
val, |
|
|
char * |
hP[2], |
|
|
int |
rPort[2] |
|
) |
| |
|
staticprivate |
static void XrdXrootdProtocol::xred_set |
( |
RD_func |
func, |
|
|
char * |
rHost[2], |
|
|
int |
rPort[2] |
|
) |
| |
|
staticprivate |
static bool XrdXrootdProtocol::xred_xok |
( |
int |
func, |
|
|
char * |
rHost[2], |
|
|
int |
rPort[2] |
|
) |
| |
|
staticprivate |
static int XrdXrootdProtocol::xsecl |
( |
XrdOucStream & |
Config | ) |
|
|
staticprivate |
static int XrdXrootdProtocol::xtrace |
( |
XrdOucStream & |
Config | ) |
|
|
staticprivate |
int XrdXrootdProtocol::as_force |
|
staticprotected |
int XrdXrootdProtocol::as_maxperlnk |
|
staticprotected |
int XrdXrootdProtocol::as_maxperreq |
|
staticprotected |
int XrdXrootdProtocol::as_maxpersrv |
|
staticprotected |
int XrdXrootdProtocol::as_maxstalls |
|
staticprotected |
int XrdXrootdProtocol::as_miniosz |
|
staticprotected |
int XrdXrootdProtocol::as_minsfsz |
|
staticprotected |
int XrdXrootdProtocol::as_noaio |
|
staticprotected |
int XrdXrootdProtocol::as_nosf |
|
staticprotected |
int XrdXrootdProtocol::as_segsize |
|
staticprotected |
int XrdXrootdProtocol::as_syncw |
|
staticprotected |
unsigned char XrdXrootdProtocol::CapVer |
|
protected |
int XrdXrootdProtocol::clientPV |
|
protected |
int XrdXrootdProtocol::cumReadP |
|
protected |
int XrdXrootdProtocol::cumReads |
|
protected |
int XrdXrootdProtocol::cumReadV |
|
protected |
int XrdXrootdProtocol::cumSegsV |
|
protected |
int XrdXrootdProtocol::cumSegsW |
|
protected |
int XrdXrootdProtocol::cumWrites |
|
protected |
int XrdXrootdProtocol::cumWritV |
|
protected |
XrdSfsFileSystem* XrdXrootdProtocol::digFS |
|
staticprotected |
char* XrdXrootdProtocol::digLib |
|
staticprotected |
char* XrdXrootdProtocol::digParm |
|
staticprotected |
char XrdXrootdProtocol::doWrite |
|
protected |
char XrdXrootdProtocol::doWriteC |
|
protected |
char* XrdXrootdProtocol::FSLib[2] |
|
staticprotected |
int XrdXrootdProtocol::FSLvn[2] |
|
staticprotected |
int XrdXrootdProtocol::hailWait |
|
staticprotected |
int XrdXrootdProtocol::halfBSize |
|
protected |
int XrdXrootdProtocol::hcMax |
|
staticprotected |
int XrdXrootdProtocol::hcNext |
|
protected |
int XrdXrootdProtocol::hcNow |
|
protected |
int XrdXrootdProtocol::hcPrev |
|
protected |
char XrdXrootdProtocol::isActive |
|
protected |
char XrdXrootdProtocol::isBound |
|
protected |
char XrdXrootdProtocol::isDead |
|
protected |
char XrdXrootdProtocol::isNOP |
|
protected |
char XrdXrootdProtocol::isRedir |
|
staticprotected |
char XrdXrootdProtocol::JobCKCGI |
|
staticprotected |
char* XrdXrootdProtocol::JobCKT |
|
staticprotected |
char XrdXrootdProtocol::JobLCL |
|
staticprotected |
bool XrdXrootdProtocol::LimitError |
|
staticprotected |
int XrdXrootdProtocol::maxBuffsz |
|
staticprotected |
const int XrdXrootdProtocol::maxPio = 4 |
|
staticprotected |
const int XrdXrootdProtocol::maxRvecsz = 1024 |
|
staticprotected |
const int XrdXrootdProtocol::maxStreams = 16 |
|
staticprotected |
int XrdXrootdProtocol::maxTransz |
|
staticprotected |
const int XrdXrootdProtocol::maxWvecsz = 1024 |
|
staticprotected |
int XrdXrootdProtocol::myBlast |
|
protected |
int XrdXrootdProtocol::myBlen |
|
protected |
char* XrdXrootdProtocol::myBuff |
|
protected |
const char* XrdXrootdProtocol::myCName |
|
staticprotected |
int XrdXrootdProtocol::myCNlen |
|
staticprotected |
int XrdXrootdProtocol::myEInfo[2] |
const char* XrdXrootdProtocol::myInst |
|
staticprotected |
int XrdXrootdProtocol::myIOLen |
|
protected |
long long XrdXrootdProtocol::myOffset |
int XrdXrootdProtocol::myPID |
|
staticprotected |
int XrdXrootdProtocol::myRole |
|
staticprotected |
int XrdXrootdProtocol::myRolf |
|
staticprotected |
unsigned int XrdXrootdProtocol::mySID |
|
protected |
int XrdXrootdProtocol::myStalls |
|
protected |
long long XrdXrootdProtocol::myWVBytes |
char* XrdXrootdProtocol::Notify |
|
staticprotected |
int XrdXrootdProtocol::numFiles |
|
protected |
int XrdXrootdProtocol::numReadP |
|
protected |
int XrdXrootdProtocol::numReads |
|
protected |
int XrdXrootdProtocol::numReadV |
|
protected |
int XrdXrootdProtocol::numSegsV |
|
protected |
int XrdXrootdProtocol::numSegsW |
|
protected |
int XrdXrootdProtocol::numWrites |
|
protected |
int XrdXrootdProtocol::numWritV |
|
protected |
bool XrdXrootdProtocol::OD_Bypass |
|
staticprotected |
bool XrdXrootdProtocol::OD_Redir |
|
staticprotected |
int XrdXrootdProtocol::OD_Stall |
|
staticprotected |
XrdSfsFileSystem* XrdXrootdProtocol::osFS |
|
staticprotected |
short XrdXrootdProtocol::PathID |
|
protected |
char* XrdXrootdProtocol::pidPath |
|
staticprotected |
int XrdXrootdProtocol::Port |
|
staticprotected |
bool XrdXrootdProtocol::PrepareAlt |
|
staticprotected |
int XrdXrootdProtocol::PrepareCount |
|
protected |
int XrdXrootdProtocol::PrepareLimit |
|
staticprotected |
short XrdXrootdProtocol::rdType |
|
protected |
int XrdXrootdProtocol::readWait |
|
staticprotected |
int(XrdXrootdProtocol::* XrdXrootdProtocol::Resume)() |
|
protected |
int XrdXrootdProtocol::RQLxist |
|
staticprotected |
unsigned char XrdXrootdProtocol::rvSeq |
|
protected |
char* XrdXrootdProtocol::SecLib |
|
staticprotected |
char XrdXrootdProtocol::sigBuff[64] |
|
protected |
bool XrdXrootdProtocol::sigHere |
|
protected |
bool XrdXrootdProtocol::sigNeed |
|
protected |
bool XrdXrootdProtocol::sigRead |
|
protected |
bool XrdXrootdProtocol::sigWarn |
|
protected |
char XrdXrootdProtocol::Status |
|
protected |
long long XrdXrootdProtocol::totReadP |
|
protected |
const char* XrdXrootdProtocol::TraceID |
|
staticprotected |
int XrdXrootdProtocol::WANPort |
|
staticprotected |
int XrdXrootdProtocol::WANWindow |
|
staticprotected |
int XrdXrootdProtocol::Window |
|
staticprotected |
XrdXrootdWVInfo* XrdXrootdProtocol::wvInfo |
|
protected |
unsigned char XrdXrootdProtocol::wvSeq |
|
protected |
The documentation for this class was generated from the following file: