xrootd
Classes | Public Member Functions | Static Public Member Functions | Protected Attributes | Static Protected Attributes | Private Types | Private Member Functions | Static Private Member Functions | Private Attributes | Static Private Attributes | Friends
XrdXrootdProtocol Class Reference

#include <XrdXrootdProtocol.hh>

Inheritance diagram for XrdXrootdProtocol:
Inheritance graph
[legend]
Collaboration diagram for XrdXrootdProtocol:
Collaboration graph
[legend]

List of all members.

Classes

struct  RD_Table

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

static int Configure (char *parms, XrdProtocol_Config *pi)
static 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
int clientPV
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
char rvSeq
XrdXrootdReqID ReqID
ClientRequest Request
XrdXrootdResponse Response

Static Protected Attributes

static XrdXrootdXPath RPList
static XrdXrootdXPath XPList
static XrdSfsFileSystem * osFS
static XrdSecService * CIA = 0
static XrdXrootdFileLock * Locker
static XrdScheduler * Sched
static XrdBuffManager * BPool
static XrdSysError eDest
static const char * myInst = 0
static const char * TraceID = "Protocol"
static char * pidPath = strdup("/tmp")
static int myPID = static_cast<int>(getpid())
static int myRole = 0
static int myRolf = 0
static XrdNetSocket * AdminSock = 0
static int hailWait
static int readWait
static int Port
static int Window
static int WANPort
static int WANWindow
static char * SecLib = 0
static char * FSLib = 0
static char * Notify = 0
static char isRedir = 0
static char chkfsV = 0
static char JobLCL = 0
static char JobQCS = 0
static XrdXrootdJob * JobCKS = 0
static char * JobCKT = 0
static struct
XrdXrootdProtocol::RD_Table 		Route [RD_Num]
static int as_maxperlnk = 8
static int as_maxperreq = 8
static int as_maxpersrv = 4096
static int as_miniosz = 32768
static int as_minsfsz = 8192
static int as_segsize = 131072
static int as_maxstalls = 5
static int as_force = 0
static int as_noaio = 0
static int as_nosf = 0
static int as_syncw = 0
static int maxBuffsz
static int maxTransz = 262144
static const int maxRvecsz = 1024
static XrdXrootdStats * SI
static int hcMax = 28657
static const int maxStreams = 16
static 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_CKsum (const char *Path, const char *Opaque)
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 retRole=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 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)
void MonAuth ()
int Process2 ()
void Reset ()
int rpEmsg (const char *op, char *fn)
int vpEmsg (const char *op, char *fn)

Static Private Member Functions

static int CheckSum (XrdOucStream *, char **, int)
static int Config (const char *fn)
static int mapMode (int mode)
static void PidFile ()
static int rpCheck (char *fn, const char **opaque)
static int Squash (char *)
static int xapath (XrdOucStream &Config)
static int xasync (XrdOucStream &Config)
static int xcksum (XrdOucStream &Config)
static int xexp (XrdOucStream &Config)
static int xexpdo (char *path, int popt=0)
static int xfsl (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 void xred_set (RD_func func, const char *rHost, int rPort)
static int xsecl (XrdOucStream &Config)
static int xtrace (XrdOucStream &Config)

Private Attributes

XrdObject< XrdXrootdProtocol > ProtLink

Static Private Attributes

static XrdObjectQ
< XrdXrootdProtocol > 		ProtStack

Friends

class XrdXrootdAdmin
class XrdXrootdAioReq

Member Enumeration Documentation

enum XrdXrootdProtocol::RD_func [private]
Enumerator:
RD_chmod 
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 

Constructor & Destructor Documentation

XrdXrootdProtocol::XrdXrootdProtocol ( )

References Reset().

Referenced by Match().

XrdXrootdProtocol::~XrdXrootdProtocol ( ) [inline]

References Cleanup().

Member Function Documentation

int XrdXrootdProtocol::aio_Error ( const char *  op,
int  ecode 
) [private]

References eDest, XrdSysError::ec2text(), snprintf, myFile, XrdXrootdFile::XrdSfsp, XrdSfsFile::FName(), XrdSysError::Emsg(), Link, XrdLink::ID, XrdSfsFile::error, XrdOucErrInfo::setErrInfo(), and myAioReq.

Referenced by aio_WriteAll(), and aio_WriteCont().

int XrdXrootdProtocol::aio_Read ( ) [private]

References XrdXrootdAioReq::Alloc(), and XrdXrootdAioReq::Read().

Referenced by do_ReadAll().

int XrdXrootdProtocol::aio_Write ( ) [private]

References myAioReq, XrdXrootdAioReq::Alloc(), and aio_WriteAll().

Referenced by do_Write().

int XrdXrootdProtocol::aio_WriteAll ( ) [private]

References myStalls, myIOLen, myAioReq, XrdXrootdAioReq::getAio(), Resume, myBlen, EINPROGRESS, XrdXrootdAio::buffp, XrdBuffer::bsize, getData(), XrdBuffer::buff, aio_WriteCont(), myBlast, XrdXrootdAioReq::Push(), XrdXrootdAioReq::Recycle(), XrdSfsAio::sfsAio, aiocb::aio_nbytes, aiocb::aio_offset, myOffset, XrdXrootdAioReq::Write(), aio_Error(), and as_maxstalls.

Referenced by aio_Write(), and aio_WriteCont().

int XrdXrootdProtocol::aio_WriteCont ( ) [private]

References myAioReq, XrdXrootdAioReq::Pop(), XrdXrootdAioReq::Write(), myIOLen, myBlast, aio_Error(), myOffset, and aio_WriteAll().

Referenced by aio_WriteAll().

void XrdXrootdProtocol::Assign ( const XrdXrootdProtocol &  rhs) [private]
int XrdXrootdProtocol::CheckSum ( XrdOucStream *  Stream,
char **  argv,
int  argc 
) [static, private]

References XrdOucStream::PutLine(), osFS, XrdSfsFileSystem::chksum(), XrdSfsFileSystem::csCalc, JobCKT, XrdOucErrInfo::getErrText(), SI, and XrdXrootdStats::errorCnt.

Referenced by xcksum().

void XrdXrootdProtocol::Cleanup ( ) [private]

References argp, BPool, XrdBuffManager::Release(), FTab, isBound, Status, XRD_BOUNDPATH, streamMutex, XrdSysMutex::Lock(), maxStreams, Stream, isDead, Recycle(), Link, XrdLink::Close(), XrdSysMutex::UnLock(), SI, XrdXrootdStats::statsMutex, XrdXrootdStats::readCnt, numReads, XrdXrootdStats::writeCnt, numWrites, Monitor, XrdXrootdMonitor::unAlloc(), AuthProt, XrdSecProtocol::Delete(), pioFirst, XrdXrootdPio::Next, XrdXrootdPio::Recycle(), and pioFree.

Referenced by Recycle(), and ~XrdXrootdProtocol().

int XrdXrootdProtocol::Config ( const char *  fn) [static, private]

References eDest, open(), XrdSysError::Emsg(), XrdOucStream::Attach(), XrdOucStream::GetMyFirstWord(), TS_Xeq, xasync(), xcksum(), xexp(), xfsl(), xlog(), xmon(), xpidf(), xprep(), xred(), xsecl(), xtrace(), XrdSysError::Say(), and XrdOucStream::Echo().

Referenced by Configure().

int XrdXrootdProtocol::Configure ( char *  parms,
XrdProtocol_Config *  pi 
) [static]

References XrdSfsGetDefaultFileSystem(), XrdMpx::Logger, XrdXrootdloadSecurity(), XrdXrootdloadFileSystem(), optind, eDest, XrdSysError::logger(), XrdProtocol_Config::eDest, SI, XrdProtocol_Config::Stats, Sched, XrdProtocol_Config::Sched, BPool, XrdProtocol_Config::BPool, hailWait, XrdProtocol_Config::hailWait, readWait, XrdProtocol_Config::readWait, Port, XrdProtocol_Config::Port, myInst, XrdProtocol_Config::myInst, Window, XrdProtocol_Config::WSize, WANPort, XrdProtocol_Config::WANPort, WANWindow, XrdProtocol_Config::WANWSize, XrdXrootdInstance, XrdXrootdPort, XrdXrootdCallBack::setVals(), XrdSysError::Emsg(), XrdProtocol_Config::argc, XrdProtocol_Config::argv, XrdOucEnv::Export(), XrdSysError::Say(), xexpdo(), as_miniosz, as_segsize, maxTransz, maxBuffsz, XrdBuffManager::MaxSize(), XrdProtocol_Config::ConfigFN, Config(), XrdProtocol_Config::DebugON, XrdOucTrace::What, TRACE_ALL, XPList, XrdXrootdXPath::Next(), XrdXrootdXPath::Insert(), XrdXrootdXPath::Path(), SecLib, TRACE, DEBUG, CIA, FSLib, osFS, XrdOucEnv::PutPtr(), XrdProtocol_Config::NetTCP, XrdXrootdStats::setFS(), chkfsV, XrdSfsFileSystem::getVersion(), XrdVERSION, JobCKT, JobQCS, XrdSfsFileSystem::chksum(), XrdSfsFileSystem::csSize, JobLCL, JobCKS, as_noaio, XrdXrootdAioReq::Init(), as_maxperreq, as_maxpersrv, Locker, XrdXrootdFile::Init(), as_nosf, ProtStack, XrdObjectQ::Set(), TRACE_MEM, XrdProtocol_Config::ConnMax, XrdProtocol_Config::myName, XrdSysDNS::IPAddr(), XrdProtocol_Config::myAddr, Notify, RPList, XrdXrootdXPath::Opts(), Route, myRole, kXR_isServer, myRolf, kXR_DataServer, isRedir, kXR_isManager, kXR_LBalServer, kXR_attrMeta, kXR_attrProxy, XrdXrootdMonitor::Init(), XrdXrootdAdmin::addJob(), XrdOucUtils::genPath(), XrdProtocol_Config::AdmPath, AdminSock, XrdNetSocket::Create(), XrdProtocol_Config::AdmMode, XrdXrootdAdmin::Init(), and PidFile().

Referenced by XrdgetProtocol().

int XrdXrootdProtocol::do_Admin ( ) [private]

References Response, XrdXrootdResponse::Send(), and kXR_Unsupported.

Referenced by Process2().

int XrdXrootdProtocol::do_Auth ( ) [private]

References eMsg, CIA, Response, XrdXrootdResponse::Send(), Request, ClientRequest::header, ClientRequestHdr::dlen, argp, XrdBuffer::buff, AuthProt, Entity, XrdSecEntity::prot, ClientRequest::auth, ClientAuthRequest::credtype, XrdSecProtocol::Delete(), Link, XrdLink::Name(), XrdSecService::getProtocol(), XrdLink::Host(), XrdOucErrInfo::getErrText(), eDest, XrdSysError::Emsg(), kXR_NotAuthorized, XrdSecProtocol::Entity, XrdSecEntity::tident, XrdLink::ID, numReads, XrdSecProtocol::Authenticate(), Status, XRD_ADMINUSER, XRD_NEED_AUTH, Client, Monitor, XrdXrootdMonitor::monUSER, MonAuth(), XrdSecEntity::name, XrdSysError::Log(), SYS_LOG_01, TRACEP, XrdSecBuffer::size, kXR_authmore, XrdSecBuffer::buffer, kXR_ServerError, and XrdSysTimer::Snooze().

Referenced by Process2().

int XrdXrootdProtocol::do_Bind ( ) [private]

References Request, ClientRequest::bind, ClientBindRequest::sessid, UPSTATS, XrdXrootdSessID::FD, XrdLink::fd2link(), XrdXrootdSessID::Inst, Response, XrdXrootdResponse::Send(), kXR_NotFound, kXR_ArgInvalid, XRD_LOGGEDIN, XRD_NEED_AUTH, XrdXrootdSessID::Pid, myPID, XrdXrootdSessID::Sid, Link, XrdLink::Host(), kXR_NotAuthorized, maxStreams, kXR_NoMemory, Stream, isBound, PathID, XrdLink::FDnum(), eDest, XrdSysError::Log(), SYS_LOG_01, rindex, XrdLink::setID(), CapVer, Status, XRD_BOUNDPATH, pioFree, XrdXrootdPio::Alloc(), maxPio, kXR_ok, and EINPROGRESS.

Referenced by Process2().

int XrdXrootdProtocol::do_Chmod ( ) [private]

References Link, XrdLink::ID, Route, RD_chmod, Port, Response, XrdXrootdResponse::Send(), kXR_redirect, mapMode(), Request, ClientRequest::chmod, ClientChmodRequest::mode, rpCheck(), argp, XrdBuffer::buff, rpEmsg(), Squash(), vpEmsg(), osFS, XrdSfsFileSystem::chmod(), CRED, TRACEP, SFS_OK, and fsError().

Referenced by Process2().

int XrdXrootdProtocol::do_CKsum ( int  canit) [private]

References JobQCS, JobCKS, Response, XrdXrootdResponse::Send(), kXR_Unsupported, rpCheck(), argp, XrdBuffer::buff, rpEmsg(), Squash(), vpEmsg(), XrdXrootdJob::Cancel(), kXR_ServerError, JobCKT, XrdXrootdJob::Schedule(), CapVer, kXR_vermask, kXR_ver002, and JOB_Sync.

Referenced by do_Query().

int XrdXrootdProtocol::do_CKsum ( const char *  Path,
const char *  Opaque 
) [private]

References JobCKT, Link, XrdLink::ID, osFS, XrdSfsFileSystem::chksum(), XrdSfsFileSystem::csGet, CRED, XrdOucErrInfo::getErrText(), JobLCL, JobCKS, SI, XrdXrootdStats::errorCnt, Response, XrdXrootdResponse::Send(), XProtocol::mapError(), XrdOucErrInfo::setErrInfo(), and kXR_ChkSumErr.

int XrdXrootdProtocol::do_Close ( ) [private]

References Request, ClientRequest::close, ClientCloseRequest::fhandle, UPSTATS, FTab, XrdXrootdFileTable::Get(), XrdXrootdFHandle::handle, Response, XrdXrootdResponse::Send(), kXR_FileNotOpen, Link, XrdLink::Serialize(), monFILE, Monitor, XrdXrootdMonitor::Close(), XrdXrootdFile::FileID, XrdXrootdFile::readCnt, XrdXrootdFile::writeCnt, XrdXrootdFile::XrdSfsp, XrdSfsFile::close(), TRACEP, SFS_OK, kXR_FSError, XrdSfsFile::error, XrdOucErrInfo::getErrText(), XrdXrootdFileTable::Del(), and numFiles.

Referenced by Process2().

int XrdXrootdProtocol::do_Dirlist ( ) [private]

References Route, RD_dirlist, Port, Response, XrdXrootdResponse::Send(), kXR_redirect, rpCheck(), argp, XrdBuffer::buff, rpEmsg(), Squash(), vpEmsg(), osFS, XrdSfsFileSystem::newDir(), Link, XrdLink::ID, snprintf, eDest, XrdSysError::Emsg(), kXR_NoMemory, XrdSfsDirectory::open(), CRED, fsError(), XrdSfsDirectory::error, XrdSfsDirectory::nextEntry(), kXR_oksofar, XrdSfsDirectory::close(), and TRACEP.

Referenced by Process2().

int XrdXrootdProtocol::do_Endsess ( ) [private]

References UPSTATS, Request, ClientRequest::endsess, ClientEndsessRequest::sessid, XrdXrootdSessID::Pid, XrdXrootdSessID::FD, XrdXrootdSessID::Inst, TRACEP, myPID, Response, XrdXrootdResponse::Send(), Link, XrdLink::Terminate(), kXR_wait, kXR_NotAuthorized, kXR_NotFound, and kXR_Cancelled.

Referenced by Process2().

int XrdXrootdProtocol::do_Getfile ( ) [private]

References UPSTATS, Request, ClientRequest::getfile, ClientGetfileRequest::options, ClientGetfileRequest::buffsz, Response, XrdXrootdResponse::Send(), and kXR_Unsupported.

Referenced by Process2().

int XrdXrootdProtocol::do_Locate ( ) [private]

References opts, SFS_FSCTL_LOCATE, Path, argp, XrdBuffer::buff, Link, XrdLink::ID, ReqID, XrdXrootdReqID::getID(), Request, ClientRequest::locate, ClientLocateRequest::options, kXR_nowait, SFS_O_NOWAIT, kXR_refresh, SFS_O_RESET, TRACEP, Route, RD_locate, Port, Response, XrdXrootdResponse::Send(), kXR_redirect, XPList, XrdXrootdXPath::Next(), XrdXrootdXPath::Path(), SFS_O_TRUNC, rpCheck(), rpEmsg(), Squash(), vpEmsg(), osFS, XrdSfsFileSystem::fsctl(), CRED, and fsError().

Referenced by Process2().

int XrdXrootdProtocol::do_Login ( ) [private]

References Request, ClientRequest::login, ClientLoginRequest::username, UPSTATS, ClientLoginRequest::pid, Status, Response, XrdXrootdResponse::Send(), kXR_InvalidRequest, Link, XrdLink::setID(), CapVer, ClientLoginRequest::capver, kXR_vermask, XrdXrootdSessID::FD, XrdLink::FDnum(), XrdXrootdSessID::Inst, XrdLink::Inst(), XrdXrootdSessID::Pid, myPID, XrdSysMutex::Lock(), mySID, XrdSysMutex::UnLock(), XrdXrootdSessID::Sid, ClientLoginRequest::role, kXR_useradmin, XRD_ADMINUSER, CIA, XrdSecService::getParms(), XrdLink::Host(), iovec::iov_base, iovec::iov_len, XRD_LOGGEDIN, XRD_NEED_AUTH, Entity, XrdSecEntity::tident, XrdLink::ID, Client, Monitor, XrdXrootdMonitor::Alloc(), monFILE, monIO, XrdXrootdMonitor::monUSER, XrdXrootdMonitor::monAUTH, monUID, XrdXrootdMonitor::Map(), XROOTD_MON_MAPUSER, ReqID, XrdXrootdReqID::setID(), ClientRequest::header, ClientRequestHdr::streamid, eDest, XrdSysError::Log(), and SYS_LOG_01.

Referenced by Process2().

int XrdXrootdProtocol::do_Mkdir ( ) [private]

References Link, XrdLink::ID, Route, RD_mkdir, Port, Response, XrdXrootdResponse::Send(), kXR_redirect, mapMode(), Request, ClientRequest::mkdir, ClientMkdirRequest::mode, S_IRWXU, ClientMkdirRequest::options, kXR_mkdirpath, SFS_O_MKPTH, rpCheck(), argp, XrdBuffer::buff, rpEmsg(), Squash(), vpEmsg(), osFS, XrdSfsFileSystem::mkdir(), CRED, TRACEP, SFS_OK, and fsError().

Referenced by Process2().

int XrdXrootdProtocol::do_Mv ( ) [private]

References Link, XrdLink::ID, Route, RD_mv, Port, Response, XrdXrootdResponse::Send(), kXR_redirect, argp, XrdBuffer::buff, rpCheck(), rpEmsg(), Squash(), vpEmsg(), kXR_ArgMissing, osFS, XrdSfsFileSystem::rename(), CRED, TRACEP, SFS_OK, and fsError().

Referenced by Process2().

int XrdXrootdProtocol::do_Offload ( int  pathID,
int  isRead 
) [private]

References maxStreams, Stream, Response, XrdXrootdResponse::Send(), kXR_ArgInvalid, streamMutex, XrdSysMutex::Lock(), isDead, isNOP, XrdSysMutex::UnLock(), XrdXrootdResponse::StreamID(), isActive, myFile, myOffset, myIOLen, myBlen, doWrite, doWriteC, Resume, do_OffloadIO(), reTry, XrdXrootdResponse::Set(), Link, XrdLink::setRef(), Sched, XrdScheduler::Schedule(), XrdSysSemaphore::Wait(), pioFree, TRACEP, XrdXrootdPio::Next, XrdXrootdPio::Set(), pioLast, and pioFirst.

Referenced by do_Read(), and do_Write().

int XrdXrootdProtocol::do_OffloadIO ( ) [private]

References doWriteC, reTry, XrdSysSemaphore::Post(), doWrite, do_ReadAll(), do_WriteCont(), do_WriteAll(), Resume, streamMutex, XrdSysMutex::Lock(), pioFirst, XrdXrootdPio::Next, pioLast, myFile, XrdXrootdPio::myFile, myOffset, XrdXrootdPio::myOffset, myIOLen, XrdXrootdPio::myIOLen, XrdXrootdPio::isWrite, Response, XrdXrootdResponse::Set(), XrdXrootdPio::StreamID, pioFree, XrdSysMutex::UnLock(), isNOP, isActive, Stream, Link, XrdLink::setRef(), and EINPROGRESS.

Referenced by do_Offload().

int XrdXrootdProtocol::do_Open ( ) [private]

References opts, argp, XrdBuffer::buff, stat(), ServerResponseBody_Open::fhandle, UPSTATS, Request, ClientRequest::open, ClientOpenRequest::mode, ClientOpenRequest::options, mapMode(), S_IRUSR, S_IWUSR, kXR_open_read, SFS_O_RDONLY, kXR_open_updt, SFS_O_RDWR, kXR_new, SFS_O_CREAT, kXR_replica, SFS_O_REPLICA, kXR_mkdir, SFS_O_MKPTH, kXR_delete, SFS_O_TRUNC, kXR_compress, SFS_O_RAWIO, kXR_force, kXR_async, as_force, as_noaio, kXR_refresh, SFS_O_RESET, kXR_retstat, kXR_posc, SFS_O_POSC, TRACEP, rpCheck(), rpEmsg(), Route, RD_open1, RPList, XrdXrootdXPath::Validate(), Response, XrdXrootdResponse::Send(), kXR_redirect, Port, Squash(), vpEmsg(), osFS, XrdSfsFileSystem::newFile(), Link, XrdLink::ID, snprintf, eDest, XrdSysError::Emsg(), kXR_NoMemory, XrdSfsFile::error, XrdOucErrInfo::setErrCB(), ReqID, XrdXrootdReqID::getID(), XrdSfsFile::open(), CRED, fsError(), XrdLink::sfOK, XrdLink::Serialize(), XROOTDXP_NOLK, Locker, XrdXrootdFileLock::Lock(), XrdXrootdFile::XrdSfsp, kXR_FileLocked, FTab, XrdXrootdFileTable::Add(), XrdXrootdFileLock::numLocks(), XrdSfsFile::getCXinfo(), ServerResponseBody_Open::cptype, ServerResponseBody_Open::cpsize, StatGen(), iovec::iov_base, iovec::iov_len, monFILE, Monitor, XrdXrootdFile::FileID, XrdXrootdMonitor::Map(), XROOTD_MON_MAPPATH, XrdXrootdMonitor::Open(), and numFiles.

Referenced by Process2().

int XrdXrootdProtocol::do_Ping ( ) [private]

References UPSTATS, Response, and XrdXrootdResponse::Send().

Referenced by Process2().

int XrdXrootdProtocol::do_Prepare ( ) [private]

References opts, Link, XrdLink::ID, argp, XrdBuffer::buff, Request, ClientRequest::prepare, ClientPrepareRequest::options, Route, RD_prepstg, Port, kXR_stage, kXR_cancel, Response, XrdXrootdResponse::Send(), kXR_redirect, RD_prepare, XrdOucReqID::ID(), XrdSfsPrep::opts, Prep_STAGE, kXR_coloc, Prep_COLOC, XrdSfsPrep::reqid, XrdSfsPrep::paths, XrdSfsPrep::oinfo, Prep_PRTY0, kXR_fresh, Prep_FRESH, XrdSfsPrep::notify, XrdOucTokenizer::GetLine(), kXR_ArgMissing, XrdOucReqID::isMine(), kXR_ArgInvalid, TRACEI, XrdXrootdResponse::ID(), SFS_OK, osFS, XrdSfsFileSystem::prepare(), CRED, fsError(), XrdXrootdPrepare::Logdel(), rpCheck(), rpEmsg(), Squash(), vpEmsg(), kXR_notify, Notify, XrdLink::FDnum(), kXR_noerrs, Prep_SENDAOK, Prep_SENDACK, kXR_wmode, Prep_WMODE, XrdXrootdPrepArgs::reqid, XrdXrootdPrepArgs::user, XrdXrootdPrepArgs::paths, and XrdXrootdPrepare::Log().

Referenced by Process2().

int XrdXrootdProtocol::do_Protocol ( int  retRole = 0) [private]

References kXR_PROTOCOLVERSION, myRole, isRedir, kXR_LBalServer, kXR_DataServer, UPSTATS, Request, ClientRequest::protocol, ClientProtocolRequest::clientpv, Status, clientPV, ServerResponseBody_Protocol::flags, Response, and XrdXrootdResponse::Send().

Referenced by Match(), and Process2().

int XrdXrootdProtocol::do_Putfile ( ) [private]

References UPSTATS, Request, ClientRequest::putfile, ClientPutfileRequest::options, ClientPutfileRequest::buffsz, Response, XrdXrootdResponse::Send(), and kXR_Unsupported.

Referenced by Process2().

int XrdXrootdProtocol::do_Qconf ( ) [private]

References argp, XrdBuffer::buff, XrdOucTokenizer::GetLine(), XrdOucTokenizer::GetToken(), Response, XrdXrootdResponse::Send(), kXR_ArgMissing, TRACEP, DEBUG, maxStreams, maxPio, maxTransz, maxRvecsz, WANPort, WANWindow, Window, and kXR_ArgTooLong.

Referenced by do_Query().

int XrdXrootdProtocol::do_Qfh ( ) [private]

References SFS_FCTL_STATV, Link, XrdLink::ID, ReqID, XrdXrootdReqID::getID(), Request, ClientRequest::query, ClientQueryRequest::fhandle, ClientQueryRequest::infotype, UPSTATS, kXR_Qvisa, Response, XrdXrootdResponse::Send(), kXR_ArgMissing, FTab, XrdXrootdFileTable::Get(), kXR_FileNotOpen, XrdXrootdFile::XrdSfsp, XrdSfsFile::fctl(), TRACEP, SFS_OK, and fsError().

Referenced by Process2().

int XrdXrootdProtocol::do_Qopaque ( short  qopt) [private]

References Link, XrdLink::ID, Request, ClientRequest::query, ClientQueryRequest::dlen, kXR_Qopaque, XrdSfsFSctl::Arg1, argp, XrdBuffer::buff, XrdSfsFSctl::Arg1Len, XrdSfsFSctl::Arg2, SFS_FSCTL_PLUGIO, Route, RD_stat, Port, Response, XrdXrootdResponse::Send(), kXR_redirect, rpCheck(), rpEmsg(), Squash(), vpEmsg(), XrdSfsFSctl::Arg2Len, SFS_FSCTL_PLUGIN, osFS, XrdSfsFileSystem::FSctl(), CRED, TRACEP, SFS_OK, and fsError().

Referenced by do_Query().

int XrdXrootdProtocol::do_Qspace ( ) [private]

References SFS_FSCTL_STATLS, Link, XrdLink::ID, Route, RD_stat, Port, Response, XrdXrootdResponse::Send(), kXR_redirect, rpCheck(), argp, XrdBuffer::buff, rpEmsg(), Squash(), vpEmsg(), osFS, XrdSfsFileSystem::fsctl(), CRED, TRACEP, SFS_OK, and fsError().

Referenced by do_Query().

int XrdXrootdProtocol::do_Query ( ) [private]

References Request, ClientRequest::query, ClientQueryRequest::infotype, kXR_QStats, SI, XrdXrootdStats::Stats(), Response, ClientRequest::header, ClientRequestHdr::dlen, argp, XrdBuffer::buff, kXR_Qcksum, do_CKsum(), kXR_Qckscan, kXR_Qconfig, do_Qconf(), kXR_Qspace, do_Qspace(), kXR_Qxattr, do_Qxattr(), kXR_Qopaque, kXR_Qopaquf, do_Qopaque(), XrdXrootdResponse::Send(), and kXR_ArgInvalid.

Referenced by Process2().

int XrdXrootdProtocol::do_Qxattr ( ) [private]

References SFS_FSCTL_STATXA, Link, XrdLink::ID, ReqID, XrdXrootdReqID::getID(), Route, RD_stat, Port, Response, XrdXrootdResponse::Send(), kXR_redirect, rpCheck(), argp, XrdBuffer::buff, rpEmsg(), Squash(), vpEmsg(), osFS, XrdSfsFileSystem::fsctl(), CRED, TRACEP, and fsError().

Referenced by do_Query().

int XrdXrootdProtocol::do_Read ( ) [private]

References Request, ClientRequest::read, ClientReadRequest::fhandle, numReads, ClientRequest::header, ClientRequestHdr::dlen, do_ReadNone(), myIOLen, ClientReadRequest::rlen, ClientReadRequest::offset, myOffset, FTab, myFile, XrdXrootdFileTable::Get(), XrdXrootdFHandle::handle, Response, XrdXrootdResponse::Send(), kXR_FileNotOpen, TRACEP, monIO, Monitor, XrdXrootdMonitor::Add_rd(), XrdXrootdFile::FileID, do_Offload(), and do_ReadAll().

Referenced by Process2().

int XrdXrootdProtocol::do_ReadAll ( int  asyncOK = 1) [private]

References myIOLen, maxBuffsz, myFile, XrdXrootdFile::isMMapped, myOffset, XrdXrootdFile::fSize, Response, XrdXrootdResponse::Send(), XrdXrootdFile::mmAddr, XrdXrootdFile::sfEnabled, as_minsfsz, XrdXrootdFile::fdNum, XrdXrootdFile::AsyncMode, as_miniosz, Link, XrdLink::UseCnt(), as_maxperlnk, aio_Read(), SI, XrdXrootdStats::AsyncRej, argp, XrdBuffer::bsize, getBuff(), hcNow, hcNext, XrdBuffer::buff, XrdXrootdFile::XrdSfsp, XrdSfsFile::read(), XrdXrootdFile::readCnt, kXR_oksofar, kXR_FSError, XrdSfsFile::error, and XrdOucErrInfo::getErrText().

Referenced by do_OffloadIO(), and do_Read().

int XrdXrootdProtocol::do_ReadNone ( int &  retc,
int &  pathID 
) [private]

References Request, ClientRequest::header, ClientRequestHdr::dlen, argp, XrdBuffer::buff, read_args::pathid, Response, XrdXrootdResponse::Send(), kXR_ArgInvalid, myIOLen, readahead_list::rlen, readahead_list::offset, myOffset, XrdXrootdFHandle::handle, readahead_list::fhandle, TRACEP, FTab, myFile, XrdXrootdFileTable::Get(), kXR_FileNotOpen, XrdXrootdFile::XrdSfsp, XrdSfsFile::read(), and numReads.

Referenced by do_Read().

int XrdXrootdProtocol::do_ReadV ( ) [private]

References Request, ClientRequest::header, ClientRequestHdr::dlen, monIO, Monitor, Response, XrdXrootdResponse::Send(), kXR_ArgInvalid, kXR_ArgTooLong, argp, XrdBuffer::buff, maxTransz, readahead_list::rlen, kXR_NoMemory, XrdBuffer::bsize, getBuff(), hcNow, hcNext, FTab, kXR_FileNotOpen, rvSeq, XrdXrootdFHandle::Set(), readahead_list::fhandle, XrdXrootdFHandle::handle, XrdXrootdMonitor::Add_rv(), myFile, XrdXrootdFile::FileID, XrdXrootdFile::readCnt, XrdXrootdMonitor::Add_rd(), readahead_list::offset, XrdXrootdFileTable::Get(), myIOLen, myOffset, kXR_oksofar, TRACEP, XrdXrootdFile::XrdSfsp, XrdSfsFile::read(), numReads, kXR_FSError, XrdSfsFile::error, and XrdOucErrInfo::getErrText().

Referenced by Process2().

int XrdXrootdProtocol::do_Rm ( ) [private]

References Link, XrdLink::ID, Route, RD_rm, Port, Response, XrdXrootdResponse::Send(), kXR_redirect, rpCheck(), argp, XrdBuffer::buff, rpEmsg(), Squash(), vpEmsg(), osFS, XrdSfsFileSystem::rem(), CRED, TRACEP, SFS_OK, and fsError().

Referenced by Process2().

int XrdXrootdProtocol::do_Rmdir ( ) [private]

References Link, XrdLink::ID, Route, RD_rmdir, Port, Response, XrdXrootdResponse::Send(), kXR_redirect, rpCheck(), argp, XrdBuffer::buff, rpEmsg(), Squash(), vpEmsg(), osFS, XrdSfsFileSystem::remdir(), CRED, TRACEP, SFS_OK, and fsError().

Referenced by Process2().

int XrdXrootdProtocol::do_Set ( ) [private]

References argp, XrdBuffer::buff, XrdOucTokenizer::GetLine(), XrdOucTokenizer::GetToken(), Response, XrdXrootdResponse::Send(), kXR_ArgMissing, TRACEP, DEBUG, eDest, XrdSysError::Emsg(), Link, XrdLink::ID, do_Set_Mon(), and kXR_ArgInvalid.

Referenced by Process2().

int XrdXrootdProtocol::do_Set_Mon ( XrdOucTokenizer &  setargs) [private]

References XrdOucTokenizer::GetToken(), Response, XrdXrootdResponse::Send(), kXR_ArgMissing, XrdXrootdMonitor::monINFO, XrdXrootdMonitor::Map(), XROOTD_MON_MAPINFO, Link, XrdLink::ID, Monitor, XrdXrootdMonitor::Alloc(), XrdXrootdMonitor::monIO, XrdXrootdMonitor::appID(), monIO, monFILE, XrdXrootdMonitor::monUSER, monUID, MonAuth(), XrdXrootdMonitor::unAlloc(), and kXR_ArgInvalid.

Referenced by do_Set().

int XrdXrootdProtocol::do_Stat ( ) [private]

References SFS_FSCTL_STATFS, stat(), Link, XrdLink::ID, ReqID, XrdXrootdReqID::getID(), Route, RD_stat, Port, Response, XrdXrootdResponse::Send(), kXR_redirect, rpCheck(), argp, XrdBuffer::buff, rpEmsg(), Squash(), vpEmsg(), Request, ClientRequest::stat, ClientStatRequest::options, kXR_vfs, osFS, XrdSfsFileSystem::fsctl(), CRED, TRACEP, SFS_OK, XrdSfsFileSystem::stat(), StatGen(), and fsError().

Referenced by Process2().

int XrdXrootdProtocol::do_Statx ( ) [private]

References argp, XrdBuffer::buff, Link, XrdLink::ID, ReqID, XrdXrootdReqID::getID(), rpCheck(), rpEmsg(), Squash(), vpEmsg(), osFS, XrdSfsFileSystem::stat(), CRED, TRACEP, SFS_OK, fsError(), kXR_offline, S_ISDIR, kXR_isDir, kXR_file, Response, and XrdXrootdResponse::Send().

Referenced by Process2().

int XrdXrootdProtocol::do_Sync ( ) [private]

References Request, ClientRequest::sync, ClientSyncRequest::fhandle, UPSTATS, FTab, XrdXrootdFileTable::Get(), XrdXrootdFHandle::handle, Response, XrdXrootdResponse::Send(), kXR_FileNotOpen, XrdXrootdFile::XrdSfsp, XrdSfsFile::sync(), TRACEP, SFS_OK, kXR_FSError, XrdSfsFile::error, and XrdOucErrInfo::getErrText().

Referenced by Process2().

int XrdXrootdProtocol::do_Truncate ( ) [private]

References Request, ClientRequest::truncate, ClientTruncateRequest::fhandle, ClientTruncateRequest::offset, ClientRequest::header, ClientRequestHdr::dlen, UPSTATS, FTab, XrdXrootdFileTable::Get(), XrdXrootdFHandle::handle, Response, XrdXrootdResponse::Send(), kXR_FileNotOpen, XrdXrootdFile::XrdSfsp, XrdSfsFile::truncate(), TRACEP, SFS_OK, kXR_FSError, XrdSfsFile::error, XrdOucErrInfo::getErrText(), Link, XrdLink::ID, rpCheck(), argp, XrdBuffer::buff, rpEmsg(), Squash(), vpEmsg(), osFS, XrdSfsFileSystem::truncate(), CRED, and fsError().

Referenced by Process2().

int XrdXrootdProtocol::do_Write ( ) [private]

References Request, ClientRequest::write, ClientWriteRequest::fhandle, numWrites, myIOLen, ClientRequest::header, ClientRequestHdr::dlen, ClientWriteRequest::offset, myOffset, ClientWriteRequest::pathid, FTab, myFile, XrdXrootdFileTable::Get(), XrdXrootdFHandle::handle, argp, do_WriteNone(), Response, XrdXrootdResponse::Send(), kXR_FileNotOpen, Link, XrdLink::setEtext(), monIO, Monitor, XrdXrootdMonitor::Add_wr(), XrdXrootdFile::FileID, ClientWriteRequest::dlen, TRACEP, do_Offload(), XrdXrootdFile::AsyncMode, as_syncw, myStalls, as_maxstalls, as_miniosz, XrdLink::UseCnt(), as_maxperlnk, aio_Write(), SI, XrdXrootdStats::AsyncRej, XrdXrootdFile::writeCnt, and do_WriteAll().

Referenced by Process2().

int XrdXrootdProtocol::do_WriteAll ( ) [private]

References myIOLen, maxBuffsz, argp, XrdBuffer::bsize, getBuff(), hcNow, hcNext, getData(), XrdBuffer::buff, Resume, do_WriteCont(), myBlast, myStalls, myFile, XrdXrootdFile::XrdSfsp, XrdSfsFile::write(), myOffset, do_WriteNone(), Response, and XrdXrootdResponse::Send().

Referenced by do_OffloadIO(), do_Write(), and do_WriteCont().

int XrdXrootdProtocol::do_WriteCont ( ) [private]

References myFile, XrdXrootdFile::XrdSfsp, XrdSfsFile::write(), myOffset, argp, XrdBuffer::buff, myBlast, myIOLen, do_WriteNone(), do_WriteAll(), Response, and XrdXrootdResponse::Send().

Referenced by do_OffloadIO(), and do_WriteAll().

int XrdXrootdProtocol::do_WriteNone ( ) [private]

References myIOLen, argp, XrdBuffer::bsize, TRACEP, Link, XrdLink::Recv(), XrdBuffer::buff, readWait, XrdLink::setEtext(), myBlen, Resume, Response, XrdXrootdResponse::Send(), kXR_FSError, myFile, XrdXrootdFile::XrdSfsp, XrdSfsFile::error, and XrdOucErrInfo::getErrText().

Referenced by do_Write(), do_WriteAll(), and do_WriteCont().

void XrdXrootdProtocol::DoIt ( ) [inline, virtual]

Implements XrdJob.

References Resume.

int XrdXrootdProtocol::fsError ( int  rc,
XrdOucErrInfo &  myError 
) [private]

References eMsg, XrdOucErrInfo::getErrText(), SFS_ERROR, SI, XrdXrootdStats::errorCnt, XProtocol::mapError(), Response, XrdXrootdResponse::Send(), SFS_REDIRECT, XrdXrootdStats::redirCnt, Port, TRACEI, XrdXrootdResponse::ID(), kXR_redirect, SFS_STARTED, XrdXrootdStats::stallCnt, kXR_waitresp, XrdOucErrInfo::getErrCB(), XrdOucEICB::Done(), SFS_DATA, SFS_STALL, kXR_wait, eDest, XrdSysError::Emsg(), and kXR_ServerError.

Referenced by do_Chmod(), do_Dirlist(), do_Locate(), do_Mkdir(), do_Mv(), do_Open(), do_Prepare(), do_Qfh(), do_Qopaque(), do_Qspace(), do_Qxattr(), do_Rm(), do_Rmdir(), do_Stat(), do_Statx(), and do_Truncate().

int XrdXrootdProtocol::getBuff ( const int  isRead,
int  Quantum 
) [private]

References argp, XrdBuffer::bsize, hcNow, hcPrev, halfBSize, hcNext, hcMax, BPool, XrdBuffManager::Release(), XrdBuffManager::Obtain(), Response, XrdXrootdResponse::Send(), and kXR_NoMemory.

Referenced by do_ReadAll(), do_ReadV(), and do_WriteAll().

int XrdXrootdProtocol::getData ( const char *  dtype,
char *  buff,
int  blen 
) [private]

References Link, XrdLink::Recv(), readWait, XrdLink::setEtext(), myBuff, myBlen, and TRACEP.

Referenced by Process(), do_WriteAll(), and aio_WriteAll().

int XrdXrootdProtocol::mapMode ( int  mode) [static, private]

References Map_Mode.

Referenced by do_Chmod(), do_Mkdir(), and do_Open().

XrdProtocol * XrdXrootdProtocol::Match ( XrdLink *  lp) [virtual]

Implements XrdProtocol.

References kXR_PROTOCOLVERSION, isRedir, kXR_LBalServer, kXR_DataServer, XrdLink::Peek(), hailWait, XrdLink::setEtext(), ClientInitHandShake::fourth, ClientInitHandShake::fifth, ClientInitHandShake::first, ClientInitHandShake::second, ClientInitHandShake::third, ROOTD_PQ, ClientProtocolRequest::requestid, kXR_protocol, ClientProtocolRequest::dlen, XrdLink::Send(), Request, ClientProtocolRequest::streamid, do_Protocol(), XrdLink::Recv(), ProtStack, XrdObjectQ::Pop(), XrdXrootdProtocol(), UPSTATS, Link, Response, XrdXrootdResponse::Set(), Entity, XrdSecEntity::prot, XrdSecEntity::host, and XrdLink::Host().

void XrdXrootdProtocol::MonAuth ( ) [private]

References Client, Entity, snprintf, XrdSecEntity::prot, XrdSecEntity::name, XrdSecEntity::host, XrdSecEntity::vorg, XrdSecEntity::role, XrdSecEntity::grps, XrdSecEntity::moninfo, monUID, XrdXrootdMonitor::Map(), XROOTD_MON_MAPUSER, Link, and XrdLink::ID.

Referenced by do_Auth(), and do_Set_Mon().

XrdXrootdProtocol XrdXrootdProtocol::operator= ( const XrdXrootdProtocol &  rhs)

References Reset(), Link, XrdLink::setRef(), Status, myFile, myIOLen, myOffset, Response, Request, Client, and AuthProt.

void XrdXrootdProtocol::PidFile ( void  ) [static, private]

References XrdOucUtils::genPath(), pidPath, XrdOucUtils::InstName(), XrdOucUtils::makePath(), XrdOucUtils::pathMode, snprintf, open(), write(), close, eDest, and XrdSysError::Emsg().

Referenced by Configure().

int XrdXrootdProtocol::Process ( XrdLink *  lp) [virtual]

Implements XrdProtocol.

References Resume, myBlen, getData(), myBuff, myAioReq, XrdXrootdAioReq::Recycle(), Request, Response, XrdXrootdResponse::Set(), TRACEP, XrdXrootdResponse::Send(), kXR_ArgInvalid, Link, XrdLink::setEtext(), kXR_write, argp, XrdBuffer::bsize, BPool, XrdBuffManager::Release(), XrdBuffManager::Obtain(), kXR_ArgTooLong, hcNow, hcPrev, halfBSize, XrdBuffer::buff, and Process2().

int XrdXrootdProtocol::Process2 ( ) [private]

References Status, Request, ClientRequest::header, ClientRequestHdr::requestid, kXR_login, do_Login(), kXR_protocol, do_Protocol(), kXR_bind, do_Bind(), Response, XrdXrootdResponse::Send(), kXR_InvalidRequest, Link, XrdLink::setEtext(), kXR_read, do_Read(), kXR_readv, do_ReadV(), kXR_write, do_Write(), kXR_sync, do_Sync(), kXR_close, do_Close(), kXR_truncate, ClientRequestHdr::dlen, do_Truncate(), kXR_query, do_Qfh(), kXR_ping, do_Ping(), XRD_NEED_AUTH, kXR_auth, do_Auth(), kXR_endsess, do_Endsess(), argp, kXR_ArgMissing, ReqID, XrdXrootdReqID::setID(), ClientRequestHdr::streamid, kXR_open, do_Open(), kXR_getfile, do_Getfile(), kXR_putfile, do_Putfile(), UPSTATS, kXR_admin, XRD_ADMINUSER, do_Admin(), kXR_chmod, do_Chmod(), kXR_dirlist, do_Dirlist(), kXR_locate, do_Locate(), kXR_mkdir, do_Mkdir(), kXR_mv, do_Mv(), do_Query(), kXR_prepare, do_Prepare(), kXR_rm, do_Rm(), kXR_rmdir, do_Rmdir(), kXR_set, do_Set(), kXR_stat, do_Stat(), kXR_statx, and do_Statx().

Referenced by Process().

void XrdXrootdProtocol::Recycle ( XrdLink *  lp,
int  consec,
const char *  reason 
) [virtual]

Implements XrdProtocol.

References XrdSysTimer::s2hms(), snprintf, eDest, XrdSysError::Log(), SYS_LOG_02, XrdLink::ID, Status, XRD_BOUNDPATH, Stream, streamMutex, XrdSysMutex::Lock(), isDead, isActive, Link, XrdLink::setRef(), XrdSysMutex::UnLock(), XrdXrootdMonitor::monUSER, Monitor, XrdXrootdMonitor::Disc(), monUID, Cleanup(), Reset(), ProtStack, XrdObjectQ::Push(), and ProtLink.

Referenced by Cleanup().

void XrdXrootdProtocol::Reset ( ) [private]

References Status, argp, Link, FTab, Resume, myBuff, Request, myBlen, myBlast, myOffset, myIOLen, myStalls, myAioReq, numReads, numReadP, numWrites, numFiles, cumReads, cumReadP, cumWrites, totReadP, hcPrev, hcNext, hcNow, Monitor, monUID, monFILE, monIO, Client, AuthProt, mySID, CapVer, clientPV, reTry, PathID, rvSeq, pioFree, pioFirst, pioLast, isActive, isDead, isNOP, isBound, Entity, and Stream.

Referenced by XrdXrootdProtocol(), operator=(), and Recycle().

int XrdXrootdProtocol::rpCheck ( char *  fn,
const char **  opaque 
) [static, private]

References index().

Referenced by xexpdo(), do_Chmod(), do_CKsum(), do_Dirlist(), do_Locate(), do_Mkdir(), do_Mv(), do_Open(), do_Prepare(), do_Qopaque(), do_Qspace(), do_Qxattr(), do_Rm(), do_Rmdir(), do_Stat(), do_Statx(), and do_Truncate().

int XrdXrootdProtocol::rpEmsg ( const char *  op,
char *  fn 
) [private]

References snprintf, Response, XrdXrootdResponse::Send(), and kXR_NotAuthorized.

Referenced by do_Chmod(), do_CKsum(), do_Dirlist(), do_Locate(), do_Mkdir(), do_Mv(), do_Open(), do_Prepare(), do_Qopaque(), do_Qspace(), do_Qxattr(), do_Rm(), do_Rmdir(), do_Stat(), do_Statx(), and do_Truncate().

int XrdXrootdProtocol::Squash ( char *  fn) [static, private]

References XPList, and XrdXrootdXPath::Validate().

Referenced by xexpdo(), do_Chmod(), do_CKsum(), do_Dirlist(), do_Locate(), do_Mkdir(), do_Mv(), do_Open(), do_Prepare(), do_Qopaque(), do_Qspace(), do_Qxattr(), do_Rm(), do_Rmdir(), do_Stat(), do_Statx(), and do_Truncate().

static int XrdXrootdProtocol::StatGen ( struct stat &  buf,
char *  xxBuff 
) [static]

Referenced by do_Open(), and do_Stat().

int XrdXrootdProtocol::Stats ( char *  buff,
int  blen,
int  do_sync = 0 
) [virtual]

Implements XrdProtocol.

References SI, XrdXrootdStats::statsMutex, XrdSysMutex::Lock(), XrdXrootdStats::readCnt, numReads, cumReads, XrdXrootdStats::prerCnt, numReadP, cumReadP, XrdXrootdStats::writeCnt, numWrites, cumWrites, XrdSysMutex::UnLock(), and XrdXrootdStats::Stats().

int XrdXrootdProtocol::vpEmsg ( const char *  op,
char *  fn 
) [private]

References snprintf, Response, XrdXrootdResponse::Send(), and kXR_NotAuthorized.

Referenced by do_Chmod(), do_CKsum(), do_Dirlist(), do_Locate(), do_Mkdir(), do_Mv(), do_Open(), do_Prepare(), do_Qopaque(), do_Qspace(), do_Qxattr(), do_Rm(), do_Rmdir(), do_Stat(), do_Statx(), and do_Truncate().

static int XrdXrootdProtocol::xapath ( XrdOucStream &  Config) [static, private]
int XrdXrootdProtocol::xasync ( XrdOucStream &  Config) [static, private]

References XrdOucStream::GetWord(), eDest, XrdSysError::Emsg(), XrdOuca2x::a2sz(), XrdOuca2x::a2i(), BPool, XrdBuffManager::Recalc(), as_maxperlnk, as_maxperreq, as_maxpersrv, as_miniosz, as_segsize, as_maxstalls, as_force, as_noaio, as_syncw, as_nosf, and as_minsfsz.

Referenced by Config().

int XrdXrootdProtocol::xcksum ( XrdOucStream &  Config) [static, private]

References XrdOucStream::GetWord(), eDest, XrdSysError::Emsg(), XrdOuca2x::a2i(), JobCKT, XrdOucStream::GetRest(), JobLCL, CheckSum(), XrdOucProg::Setup(), JobCKS, and Sched.

Referenced by Config().

int XrdXrootdProtocol::xexp ( XrdOucStream &  Config) [static, private]

References XrdOucStream::GetWord(), eDest, XrdSysError::Emsg(), strlcpy(), XROOTDXP_NOLK, XrdOucStream::RetToken(), and xexpdo().

Referenced by Config().

int XrdXrootdProtocol::xexpdo ( char *  path,
int  popt = 0 
) [static, private]

References rpCheck(), eDest, XrdSysError::Emsg(), Squash(), XPList, and XrdXrootdXPath::Insert().

Referenced by Configure(), and xexp().

int XrdXrootdProtocol::xfsl ( XrdOucStream &  Config) [static, private]

References chkfsV, XrdOucStream::GetWord(), eDest, XrdSysError::Emsg(), rindex, XrdSysError::Say(), and FSLib.

Referenced by Config().

int XrdXrootdProtocol::xlog ( XrdOucStream &  Config) [static, private]

References SYS_LOG_02, SYS_LOG_01, XrdOucStream::GetWord(), eDest, XrdSysError::Emsg(), and XrdSysError::setMsgMask().

Referenced by Config().

int XrdXrootdProtocol::xmon ( XrdOucStream &  Config) [static, private]

References XrdOucStream::GetWord(), XROOTD_MON_ALL, XROOTD_MON_AUTH, eDest, XrdSysError::Emsg(), XrdOuca2x::a2tm(), XrdOuca2x::a2sz(), XROOTD_MON_FILE, XROOTD_MON_INFO, XROOTD_MON_IO, XROOTD_MON_IOV, XROOTD_MON_REDR, XROOTD_MON_STAGE, XROOTD_MON_USER, index(), and XrdXrootdMonitor::Defaults().

Referenced by Config().

int XrdXrootdProtocol::xpidf ( XrdOucStream &  Config) [static, private]

References XrdOucStream::GetWord(), eDest, XrdSysError::Emsg(), and pidPath.

Referenced by Config().

int XrdXrootdProtocol::xprep ( XrdOucStream &  Config) [static, private]

References XrdOucStream::GetWord(), eDest, XrdSysError::Emsg(), XrdOuca2x::a2tm(), XrdXrootdPrepare::setParms(), XrdOucUtils::genPath(), myInst, XrdOucUtils::makePath(), and XrdOucUtils::pathMode.

Referenced by Config().

int XrdXrootdProtocol::xred ( XrdOucStream &  Config) [static, private]

References RD_chmod, RD_dirlist, RD_locate, RD_mkdir, RD_mv, RD_prepare, RD_prepstg, RD_rm, RD_rmdir, RD_stat, XrdOucStream::GetWord(), eDest, XrdSysError::Emsg(), index(), strlcpy(), RD_open1, RD_Num, Route, Port, xred_set(), RPList, and XrdXrootdXPath::Insert().

Referenced by Config().

void XrdXrootdProtocol::xred_set ( RD_func  func,
const char *  rHost,
int  rPort 
) [static, private]

References Route, XrdXrootdProtocol::RD_Table::Host, and XrdXrootdProtocol::RD_Table::Port.

Referenced by xred().

int XrdXrootdProtocol::xsecl ( XrdOucStream &  Config) [static, private]

References XrdOucStream::GetWord(), eDest, XrdSysError::Emsg(), and SecLib.

Referenced by Config().

int XrdXrootdProtocol::xtrace ( XrdOucStream &  Config) [static, private]

References TRACE_ALL, TRACE_EMSG, TRACE_DEBUG, TRACE_FS, TRACE_LOGIN, TRACE_MEM, TRACE_STALL, TRACE_REDIR, TRACE_REQ, TRACE_RSP, XrdOucStream::GetWord(), eDest, XrdSysError::Emsg(), and XrdOucTrace::What.

Referenced by Config().

Friends And Related Function Documentation

friend class XrdXrootdAdmin [friend]
friend class XrdXrootdAioReq [friend]

Member Data Documentation

XrdNetSocket * XrdXrootdProtocol::AdminSock = 0 [static, protected]

Referenced by Configure().

XrdBuffer* XrdXrootdProtocol::argp [protected]

Referenced by Process(), Process2(), Cleanup(), Reset(), do_Auth(), do_Chmod(), do_CKsum(), do_Dirlist(), do_Locate(), do_Mkdir(), do_Mv(), do_Open(), do_Prepare(), do_Qconf(), do_Qopaque(), do_Qspace(), do_Query(), do_Qxattr(), do_ReadAll(), do_ReadNone(), do_ReadV(), do_Rm(), do_Rmdir(), do_Set(), do_Stat(), do_Statx(), do_Truncate(), do_Write(), do_WriteAll(), do_WriteCont(), do_WriteNone(), and getBuff().

int XrdXrootdProtocol::as_force = 0 [static, protected]

Referenced by xasync(), and do_Open().

int XrdXrootdProtocol::as_maxperlnk = 8 [static, protected]

Referenced by xasync(), do_ReadAll(), and do_Write().

int XrdXrootdProtocol::as_maxperreq = 8 [static, protected]

Referenced by Configure(), and xasync().

int XrdXrootdProtocol::as_maxpersrv = 4096 [static, protected]

Referenced by Configure(), and xasync().

int XrdXrootdProtocol::as_maxstalls = 5 [static, protected]

Referenced by xasync(), do_Write(), and aio_WriteAll().

int XrdXrootdProtocol::as_miniosz = 32768 [static, protected]

Referenced by Configure(), xasync(), do_ReadAll(), and do_Write().

int XrdXrootdProtocol::as_minsfsz = 8192 [static, protected]

Referenced by xasync(), and do_ReadAll().

int XrdXrootdProtocol::as_noaio = 0 [static, protected]

Referenced by Configure(), xasync(), and do_Open().

int XrdXrootdProtocol::as_nosf = 0 [static, protected]

Referenced by Configure(), and xasync().

int XrdXrootdProtocol::as_segsize = 131072 [static, protected]

Referenced by Configure(), and xasync().

int XrdXrootdProtocol::as_syncw = 0 [static, protected]

Referenced by xasync(), and do_Write().

XrdSecProtocol* XrdXrootdProtocol::AuthProt [protected]

Referenced by operator=(), Cleanup(), Reset(), and do_Auth().

XrdBuffManager * XrdXrootdProtocol::BPool [static, protected]

Referenced by Configure(), xasync(), Process(), Cleanup(), and getBuff().

unsigned char XrdXrootdProtocol::CapVer [protected]

Referenced by XrdXrootdAdmin::do_Lsd(), Reset(), do_Bind(), do_CKsum(), and do_Login().

char XrdXrootdProtocol::chkfsV = 0 [static, protected]

Referenced by Configure(), and xfsl().

XrdSecService * XrdXrootdProtocol::CIA = 0 [static, protected]

Referenced by Configure(), do_Auth(), and do_Login().

XrdSecEntity* XrdXrootdProtocol::Client [protected]

Referenced by XrdXrootdAdmin::do_Lsd(), operator=(), Reset(), do_Auth(), do_Login(), and MonAuth().

int XrdXrootdProtocol::clientPV [protected]

Referenced by Reset(), and do_Protocol().

int XrdXrootdProtocol::cumReadP [protected]

Referenced by XrdXrootdAdmin::do_Lsd(), Stats(), and Reset().

int XrdXrootdProtocol::cumReads [protected]

Referenced by XrdXrootdAdmin::do_Lsd(), Stats(), and Reset().

int XrdXrootdProtocol::cumWrites [protected]

Referenced by XrdXrootdAdmin::do_Lsd(), Stats(), and Reset().

char XrdXrootdProtocol::doWrite [protected]

Referenced by do_Offload(), and do_OffloadIO().

char XrdXrootdProtocol::doWriteC [protected]

Referenced by do_Offload(), and do_OffloadIO().

XrdSysError XrdXrootdProtocol::eDest [static, protected]

Referenced by Configure(), Config(), PidFile(), xasync(), xcksum(), xexp(), xexpdo(), xfsl(), xlog(), xmon(), xpidf(), xprep(), xred(), xsecl(), xtrace(), Recycle(), do_Auth(), do_Bind(), do_Dirlist(), do_Login(), do_Open(), do_Set(), fsError(), and aio_Error().

XrdSecEntity XrdXrootdProtocol::Entity [protected]

Referenced by XrdXrootdAdmin::do_Lsd(), Match(), Reset(), do_Auth(), do_Login(), and MonAuth().

char * XrdXrootdProtocol::FSLib = 0 [static, protected]

Referenced by Configure(), and xfsl().

XrdXrootdFileTable* XrdXrootdProtocol::FTab [protected]

Referenced by Cleanup(), Reset(), do_Close(), do_Open(), do_Qfh(), do_Read(), do_ReadNone(), do_ReadV(), do_Sync(), do_Truncate(), and do_Write().

int XrdXrootdProtocol::hailWait [static, protected]

Referenced by Configure(), and Match().

int XrdXrootdProtocol::halfBSize [protected]

Referenced by Process(), and getBuff().

int XrdXrootdProtocol::hcMax = 28657 [static, protected]

Referenced by getBuff().

int XrdXrootdProtocol::hcNext [protected]

Referenced by Reset(), do_ReadAll(), do_ReadV(), do_WriteAll(), and getBuff().

int XrdXrootdProtocol::hcNow [protected]

Referenced by Process(), Reset(), do_ReadAll(), do_ReadV(), do_WriteAll(), and getBuff().

int XrdXrootdProtocol::hcPrev [protected]

Referenced by Process(), Reset(), and getBuff().

char XrdXrootdProtocol::isActive [protected]

Referenced by Recycle(), Reset(), do_Offload(), and do_OffloadIO().

char XrdXrootdProtocol::isBound [protected]

Referenced by Cleanup(), Reset(), and do_Bind().

char XrdXrootdProtocol::isDead [protected]

Referenced by Recycle(), Cleanup(), Reset(), and do_Offload().

char XrdXrootdProtocol::isNOP [protected]

Referenced by Reset(), do_Offload(), and do_OffloadIO().

char XrdXrootdProtocol::isRedir = 0 [static, protected]

Referenced by Configure(), Match(), and do_Protocol().

XrdXrootdJob * XrdXrootdProtocol::JobCKS = 0 [static, protected]

Referenced by Configure(), xcksum(), and do_CKsum().

char * XrdXrootdProtocol::JobCKT = 0 [static, protected]

Referenced by Configure(), xcksum(), CheckSum(), and do_CKsum().

char XrdXrootdProtocol::JobLCL = 0 [static, protected]

Referenced by Configure(), xcksum(), and do_CKsum().

char XrdXrootdProtocol::JobQCS = 0 [static, protected]

Referenced by Configure(), and do_CKsum().

XrdLink* XrdXrootdProtocol::Link [protected]

Referenced by XrdXrootdAioReq::Alloc(), operator=(), Match(), Process(), Process2(), Recycle(), Cleanup(), getData(), Reset(), do_Auth(), do_Bind(), do_Chmod(), do_CKsum(), do_Close(), do_Dirlist(), do_Endsess(), do_Locate(), do_Login(), do_Mkdir(), do_Mv(), do_Offload(), do_OffloadIO(), do_Open(), do_Prepare(), do_Qfh(), do_Qopaque(), do_Qspace(), do_Qxattr(), do_ReadAll(), do_Rm(), do_Rmdir(), do_Set(), do_Set_Mon(), do_Stat(), do_Statx(), do_Truncate(), do_Write(), do_WriteNone(), MonAuth(), and aio_Error().

XrdXrootdFileLock * XrdXrootdProtocol::Locker [static, protected]

Referenced by Configure(), and do_Open().

int XrdXrootdProtocol::maxBuffsz [static, protected]

Referenced by XrdXrootdAioReq::Init(), Configure(), do_ReadAll(), and do_WriteAll().

const int XrdXrootdProtocol::maxPio = 4 [static, protected]

Referenced by do_Bind(), and do_Qconf().

const int XrdXrootdProtocol::maxRvecsz = 1024 [static, protected]

Referenced by do_Qconf().

const int XrdXrootdProtocol::maxStreams = 16 [static, protected]

Referenced by Cleanup(), do_Bind(), do_Offload(), and do_Qconf().

int XrdXrootdProtocol::maxTransz = 262144 [static, protected]

Referenced by Configure(), do_Qconf(), and do_ReadV().

char XrdXrootdProtocol::monFILE [protected]

Referenced by XrdXrootdAdmin::do_Lsd(), Reset(), do_Close(), do_Login(), do_Open(), and do_Set_Mon().

char XrdXrootdProtocol::monIO [protected]

Referenced by XrdXrootdAdmin::do_Lsd(), Reset(), do_Login(), do_Read(), do_ReadV(), do_Set_Mon(), and do_Write().

XrdXrootdMonitor* XrdXrootdProtocol::Monitor [protected]

Referenced by Recycle(), Cleanup(), Reset(), do_Auth(), do_Close(), do_Login(), do_Open(), do_Read(), do_ReadV(), do_Set_Mon(), and do_Write().

kXR_unt32 XrdXrootdProtocol::monUID [protected]

Referenced by Recycle(), Reset(), do_Login(), do_Set_Mon(), and MonAuth().

XrdXrootdAioReq* XrdXrootdProtocol::myAioReq [protected]

Referenced by Process(), Reset(), aio_Error(), aio_Write(), aio_WriteAll(), and aio_WriteCont().

int XrdXrootdProtocol::myBlast [protected]

Referenced by Reset(), do_WriteAll(), do_WriteCont(), aio_WriteAll(), and aio_WriteCont().

int XrdXrootdProtocol::myBlen [protected]

Referenced by Process(), getData(), Reset(), do_Offload(), do_WriteNone(), and aio_WriteAll().

char* XrdXrootdProtocol::myBuff [protected]

Referenced by Process(), getData(), and Reset().

XrdXrootdFile* XrdXrootdProtocol::myFile [protected]

Referenced by XrdXrootdAioReq::Alloc(), operator=(), do_Offload(), do_OffloadIO(), do_Read(), do_ReadAll(), do_ReadNone(), do_ReadV(), do_Write(), do_WriteAll(), do_WriteCont(), do_WriteNone(), and aio_Error().

const char * XrdXrootdProtocol::myInst = 0 [static, protected]

Referenced by Configure(), and xprep().

int XrdXrootdProtocol::myIOLen [protected]

Referenced by XrdXrootdAioReq::Alloc(), operator=(), Reset(), do_Offload(), do_OffloadIO(), do_Read(), do_ReadAll(), do_ReadNone(), do_ReadV(), do_Write(), do_WriteAll(), do_WriteCont(), do_WriteNone(), aio_WriteAll(), and aio_WriteCont().

long long XrdXrootdProtocol::myOffset [protected]

Referenced by XrdXrootdAioReq::Alloc(), operator=(), Reset(), do_Offload(), do_OffloadIO(), do_Read(), do_ReadAll(), do_ReadNone(), do_ReadV(), do_Write(), do_WriteAll(), do_WriteCont(), aio_WriteAll(), and aio_WriteCont().

int XrdXrootdProtocol::myPID = static_cast<int>(getpid()) [static, protected]

Referenced by do_Bind(), do_Endsess(), and do_Login().

int XrdXrootdProtocol::myRole = 0 [static, protected]

Referenced by Configure(), and do_Protocol().

int XrdXrootdProtocol::myRolf = 0 [static, protected]

Referenced by Configure().

unsigned int XrdXrootdProtocol::mySID [protected]

Referenced by Reset(), and do_Login().

int XrdXrootdProtocol::myStalls [protected]

Referenced by Reset(), do_Write(), do_WriteAll(), and aio_WriteAll().

char * XrdXrootdProtocol::Notify = 0 [static, protected]

Referenced by Configure(), and do_Prepare().

int XrdXrootdProtocol::numFiles [protected]

Referenced by XrdXrootdAdmin::do_Lsd(), Reset(), do_Close(), and do_Open().

int XrdXrootdProtocol::numReadP [protected]

Referenced by XrdXrootdAdmin::do_Lsd(), Stats(), and Reset().

int XrdXrootdProtocol::numReads [protected]

Referenced by XrdXrootdAdmin::do_Lsd(), Stats(), Cleanup(), Reset(), do_Auth(), do_Read(), do_ReadNone(), and do_ReadV().

int XrdXrootdProtocol::numWrites [protected]

Referenced by XrdXrootdAdmin::do_Lsd(), Stats(), Cleanup(), Reset(), and do_Write().

XrdSfsFileSystem * XrdXrootdProtocol::osFS [static, protected]

Referenced by Configure(), CheckSum(), do_Chmod(), do_CKsum(), do_Dirlist(), do_Locate(), do_Mkdir(), do_Mv(), do_Open(), do_Prepare(), do_Qopaque(), do_Qspace(), do_Qxattr(), do_Rm(), do_Rmdir(), do_Stat(), do_Statx(), and do_Truncate().

short XrdXrootdProtocol::PathID [protected]

Referenced by Reset(), and do_Bind().

char * XrdXrootdProtocol::pidPath = strdup("/tmp") [static, protected]

Referenced by PidFile(), and xpidf().

XrdXrootdPio* XrdXrootdProtocol::pioFirst [protected]

Referenced by Cleanup(), Reset(), do_Offload(), and do_OffloadIO().

XrdXrootdPio* XrdXrootdProtocol::pioFree [protected]

Referenced by Cleanup(), Reset(), do_Bind(), do_Offload(), and do_OffloadIO().

XrdXrootdPio* XrdXrootdProtocol::pioLast [protected]

Referenced by Reset(), do_Offload(), and do_OffloadIO().

int XrdXrootdProtocol::Port [static, protected]

Referenced by Configure(), xred(), do_Chmod(), do_Dirlist(), do_Locate(), do_Mkdir(), do_Mv(), do_Open(), do_Prepare(), do_Qopaque(), do_Qspace(), do_Qxattr(), do_Rm(), do_Rmdir(), do_Stat(), and fsError().

XrdObject<XrdXrootdProtocol> XrdXrootdProtocol::ProtLink [private]

Referenced by Recycle().

XrdObjectQ< XrdXrootdProtocol > XrdXrootdProtocol::ProtStack [static, private]

Referenced by Configure(), Match(), and Recycle().

int XrdXrootdProtocol::readWait [static, protected]

Referenced by Configure(), getData(), and do_WriteNone().

XrdXrootdReqID XrdXrootdProtocol::ReqID [protected]

Referenced by Process2(), do_Locate(), do_Login(), do_Open(), do_Qfh(), do_Qxattr(), do_Stat(), and do_Statx().

ClientRequest XrdXrootdProtocol::Request [protected]

Referenced by operator=(), Match(), Process(), Process2(), Reset(), do_Auth(), do_Bind(), do_Chmod(), do_Close(), do_Endsess(), do_Getfile(), do_Locate(), do_Login(), do_Mkdir(), do_Open(), do_Prepare(), do_Protocol(), do_Putfile(), do_Qfh(), do_Qopaque(), do_Query(), do_Read(), do_ReadNone(), do_ReadV(), do_Stat(), do_Sync(), do_Truncate(), and do_Write().

XrdXrootdResponse XrdXrootdProtocol::Response [protected]

Referenced by XrdXrootdAioReq::Alloc(), operator=(), Match(), Process(), Process2(), do_Admin(), do_Auth(), do_Bind(), do_Chmod(), do_CKsum(), do_Close(), do_Dirlist(), do_Endsess(), do_Getfile(), do_Locate(), do_Login(), do_Mkdir(), do_Mv(), do_Offload(), do_OffloadIO(), do_Open(), do_Ping(), do_Prepare(), do_Protocol(), do_Putfile(), do_Qconf(), do_Qfh(), do_Qopaque(), do_Qspace(), do_Query(), do_Qxattr(), do_Read(), do_ReadAll(), do_ReadNone(), do_ReadV(), do_Rm(), do_Rmdir(), do_Set(), do_Set_Mon(), do_Stat(), do_Statx(), do_Sync(), do_Truncate(), do_Write(), do_WriteAll(), do_WriteCont(), do_WriteNone(), fsError(), getBuff(), rpEmsg(), and vpEmsg().

int(XrdXrootdProtocol::* XrdXrootdProtocol::Resume)() [protected]

Referenced by Process(), Reset(), DoIt(), do_Offload(), do_OffloadIO(), do_WriteAll(), do_WriteNone(), and aio_WriteAll().

XrdSysSemaphore* XrdXrootdProtocol::reTry [protected]

Referenced by Reset(), do_Offload(), and do_OffloadIO().

struct XrdXrootdProtocol::RD_Table XrdXrootdProtocol::Route[RD_Num] [static, protected]

Referenced by Configure(), xred(), xred_set(), do_Chmod(), do_Dirlist(), do_Locate(), do_Mkdir(), do_Mv(), do_Open(), do_Prepare(), do_Qopaque(), do_Qspace(), do_Qxattr(), do_Rm(), do_Rmdir(), and do_Stat().

XrdXrootdXPath XrdXrootdProtocol::RPList [static, protected]

Referenced by Configure(), xred(), and do_Open().

char XrdXrootdProtocol::rvSeq [protected]

Referenced by Reset(), and do_ReadV().

XrdScheduler * XrdXrootdProtocol::Sched [static, protected]

Referenced by Configure(), xcksum(), and do_Offload().

char * XrdXrootdProtocol::SecLib = 0 [static, protected]

Referenced by Configure(), and xsecl().

XrdXrootdStats * XrdXrootdProtocol::SI [static, protected]

Referenced by Configure(), Stats(), CheckSum(), Cleanup(), do_CKsum(), do_Query(), do_ReadAll(), do_Write(), and fsError().

char XrdXrootdProtocol::Status [protected]

Referenced by XrdXrootdAdmin::do_Lsd(), operator=(), Process2(), Recycle(), Cleanup(), Reset(), do_Auth(), do_Bind(), do_Login(), and do_Protocol().

XrdXrootdProtocol* XrdXrootdProtocol::Stream[maxStreams] [protected]

Referenced by Recycle(), Cleanup(), Reset(), do_Bind(), do_Offload(), and do_OffloadIO().

XrdSysMutex XrdXrootdProtocol::streamMutex [protected]

Referenced by Recycle(), Cleanup(), do_Offload(), and do_OffloadIO().

long long XrdXrootdProtocol::totReadP [protected]

Referenced by XrdXrootdAdmin::do_Lsd(), and Reset().

const char * XrdXrootdProtocol::TraceID = "Protocol" [static, protected]
int XrdXrootdProtocol::WANPort [static, protected]

Referenced by Configure(), and do_Qconf().

int XrdXrootdProtocol::WANWindow [static, protected]

Referenced by Configure(), and do_Qconf().

int XrdXrootdProtocol::Window [static, protected]

Referenced by Configure(), and do_Qconf().

XrdXrootdXPath XrdXrootdProtocol::XPList [static, protected]

Referenced by Configure(), xexpdo(), do_Locate(), and Squash().

The documentation for this class was generated from the following files:
Generated on Wed Apr 11 2012 15:23:05 for xrootd by   doxygen 1.7.5