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 ()
- Public Member Functions inherited from XrdProtocol
 XrdProtocol (const char *jname)
virtual ~XrdProtocol ()
- Public Member Functions inherited from XrdJob
 XrdJob (const char *desc="")
virtual ~XrdJob ()

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 numReadV
int numSegsV
int numWrites
int numFiles
int cumReads
int cumReadP
int cumReadV
int cumSegsV
int cumWrites
long long totReadP
XrdLink * Link
XrdBuffer * argp
XrdXrootdFileTable * FTab
XrdXrootdMonitor::User Monitor
int clientPV
char Status
unsigned char CapVer
XrdSecEntity * Client
XrdSecProtocol * AuthProt
XrdSecEntity Entity
XrdXrootdAioReq * myAioReq
char * myBuff
int myBlen
int myBlast
int(XrdXrootdProtocol::* Resume )()
XrdXrootdFile * myFile
union {
   long long   myOffset
   int   myEInfo [2]
}; 
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 RQList
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 RQLxist = 0
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 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_chksum, RD_dirlist, RD_locate,
  RD_mkdir, RD_mv, RD_prepare, RD_prepstg,
  RD_rm, RD_rmdir, RD_stat, RD_trunc,
  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, char opc, XrdOucErrInfo &myError, const char *Path)
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_chksum 
RD_dirlist 
RD_locate 
RD_mkdir 
RD_mv 
RD_prepare 
RD_prepstg 
RD_rm 
RD_rmdir 
RD_stat 
RD_trunc 
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 XrdSysError::ec2text(), eDest, XrdSysError::Emsg(), XrdSfsFile::error, XrdSfsFile::FName(), XrdLink::ID, Link, myAioReq, myFile, XrdOucErrInfo::setErrInfo(), and XrdXrootdFile::XrdSfsp.

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 aio_WriteAll(), XrdXrootdAioReq::Alloc(), and myAioReq.

Referenced by do_Write().

int XrdXrootdProtocol::aio_WriteAll ( )
private

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

Referenced by aio_Write(), and aio_WriteCont().

int XrdXrootdProtocol::aio_WriteCont ( )
private

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

Referenced by aio_WriteAll().

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

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

Referenced by xcksum().

void XrdXrootdProtocol::Cleanup ( )
private

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

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

int XrdXrootdProtocol::Config ( const char *  fn)
staticprivate

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

Referenced by Configure().

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

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

Referenced by XrdgetProtocol().

int XrdXrootdProtocol::do_Admin ( )
private

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

Referenced by Process2().

int XrdXrootdProtocol::do_Auth ( )
private

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

Referenced by Process2().

int XrdXrootdProtocol::do_Bind ( )
private

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

Referenced by Process2().

int XrdXrootdProtocol::do_Chmod ( )
private

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

Referenced by Process2().

int XrdXrootdProtocol::do_CKsum ( int  canit)
private

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

Referenced by do_Query().

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

References XrdSfsFileSystem::chksum(), CRED, XrdSfsFileSystem::csGet, XrdXrootdMonitor::User::Did, fsError(), XrdOucErrInfo::getErrText(), XrdLink::ID, JobCKS, JobCKT, kXR_ChkSumErr, Link, Monitor, osFS, Response, XrdXrootdResponse::Send(), and XrdOucErrInfo::setErrInfo().

int XrdXrootdProtocol::do_Close ( )
private

References XrdXrootdMonitor::User::Agent, XrdOucStats::Bump(), XrdXrootdMonFile::Close(), XrdXrootdMonitor::Close(), XrdSfsFile::close(), ClientRequest::close, XrdXrootdFileTable::Del(), XrdSfsFile::error, ClientCloseRequest::fhandle, XrdXrootdFileStats::FileID, XrdXrootdMonitor::User::Files(), fsError(), XrdXrootdMonitor::User::Fstat(), FTab, XrdXrootdFileTable::Get(), XrdOucErrInfo::getErrText(), XrdXrootdFHandle::handle, kXR_FileNotOpen, kXR_FSError, Link, XrdXrootdStats::miscCnt, Monitor, numFiles, XrdXrootdMonStatXFR::read, XrdXrootdMonStatXFR::readv, Request, Response, XrdXrootdResponse::Send(), XrdLink::Serialize(), SFS_ERROR, SFS_OK, SFS_STALL, SI, XrdXrootdFile::Stats, TRACEP, XrdXrootdMonStatXFR::write, XrdXrootdFileStats::xfr, and XrdXrootdFile::XrdSfsp.

Referenced by Process2().

int XrdXrootdProtocol::do_Dirlist ( )
private

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

Referenced by Process2().

int XrdXrootdProtocol::do_Endsess ( )
private

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

Referenced by Process2().

int XrdXrootdProtocol::do_Getfile ( )
private

References ClientGetfileRequest::buffsz, XrdOucStats::Bump(), XrdXrootdStats::getfCnt, ClientRequest::getfile, kXR_Unsupported, ClientGetfileRequest::options, Request, Response, XrdXrootdResponse::Send(), and SI.

Referenced by Process2().

int XrdXrootdProtocol::do_Locate ( )
private

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

Referenced by Process2().

int XrdXrootdProtocol::do_Login ( )
private

References XrdXrootdMonitor::User::Auths(), XrdOucStats::Bump(), CapVer, ClientLoginRequest::capver, CIA, Client, eDest, Entity, XrdXrootdSessID::FD, XrdLink::FDnum(), XrdSecService::getParms(), ClientRequest::header, XrdLink::Host(), XrdLink::ID, XrdXrootdSessID::Inst, XrdLink::Inst(), kXR_InvalidRequest, kXR_useradmin, kXR_vermask, Link, XrdSysMutex::Lock(), XrdSysError::Log(), ClientRequest::login, XrdXrootdStats::LoginAT, XrdXrootdMonitor::User::Logins(), XrdXrootdStats::LoginUA, Monitor, myPID, mySID, XrdXrootdSessID::Pid, ClientLoginRequest::pid, XrdXrootdMonitor::User::Ready(), XrdXrootdMonitor::User::Register(), XrdXrootdMonitor::User::Report(), ReqID, Request, Response, ClientLoginRequest::role, XrdXrootdResponse::Send(), XrdXrootdReqID::setID(), XrdLink::setID(), SI, XrdXrootdSessID::Sid, Status, ClientRequestHdr::streamid, SYS_LOG_01, XrdSecEntity::tident, XrdSysMutex::UnLock(), ClientLoginRequest::username, XRD_ADMINUSER, XRD_LOGGEDIN, and XRD_NEED_AUTH.

Referenced by Process2().

int XrdXrootdProtocol::do_Mkdir ( )
private

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

Referenced by Process2().

int XrdXrootdProtocol::do_Mv ( )
private

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

Referenced by Process2().

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

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

Referenced by do_Read(), and do_Write().

int XrdXrootdProtocol::do_OffloadIO ( )
private

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

Referenced by do_Offload().

int XrdXrootdProtocol::do_Open ( )
private

References XrdXrootdFileTable::Add(), XrdXrootdMonitor::User::Agent, argp, as_force, as_noaio, XrdBuffer::buff, XrdOucStats::Bump(), ServerResponseBody_Open::cpsize, ServerResponseBody_Open::cptype, CRED, XrdXrootdMonitor::User::Did, eDest, XrdSysError::Emsg(), XrdSfsFile::error, ServerResponseBody_Open::fhandle, XrdXrootdFileStats::FileID, XrdXrootdMonitor::User::Files(), fsError(), XrdXrootdMonitor::User::Fstat(), FTab, XrdSfsFile::getCXinfo(), XrdXrootdReqID::getID(), XrdLink::ID, kXR_async, kXR_compress, kXR_delete, kXR_FileLocked, kXR_force, kXR_mkdir, kXR_new, kXR_NoMemory, kXR_open_read, kXR_open_updt, kXR_posc, kXR_redirect, kXR_refresh, kXR_replica, kXR_retstat, Link, XrdXrootdFileLock::Lock(), Locker, mapMode(), XrdXrootdMonitor::User::MapPath(), ClientOpenRequest::mode, Monitor, XrdXrootdFileStats::monLvl, XrdXrootdFileStats::monOn, XrdSfsFileSystem::newFile(), numFiles, XrdXrootdFileLock::numLocks(), XrdXrootdMonFile::Open(), XrdXrootdMonitor::Open(), XrdSfsFile::open(), ClientRequest::open, XrdXrootdStats::openCnt, ClientOpenRequest::options, opts, osFS, Port, RD_open1, XrdXrootdStats::Refresh, ReqID, Request, Response, Route, rpCheck(), rpEmsg(), RPList, XrdXrootdResponse::Send(), XrdLink::Serialize(), XrdOucErrInfo::setErrCB(), XrdLink::sfOK, SFS_O_CREAT, SFS_O_MKPTH, SFS_O_POSC, SFS_O_RAWIO, SFS_O_RDONLY, SFS_O_RDWR, SFS_O_REPLICA, SFS_O_RESET, SFS_O_TRUNC, SI, Squash(), stat(), StatGen(), XrdXrootdFile::Stats, TRACEP, XrdXrootdXPath::Validate(), vpEmsg(), XrdXrootdFile::XrdSfsp, XROOTD_MON_OPENC, XROOTD_MON_OPENR, XROOTD_MON_OPENW, and XROOTDXP_NOLK.

Referenced by Process2().

int XrdXrootdProtocol::do_Ping ( )
private

References XrdOucStats::Bump(), XrdXrootdStats::miscCnt, Response, XrdXrootdResponse::Send(), and SI.

Referenced by Process2().

int XrdXrootdProtocol::do_Prepare ( )
private

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

Referenced by Process2().

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

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

Referenced by Match(), and Process2().

int XrdXrootdProtocol::do_Putfile ( )
private

References ClientPutfileRequest::buffsz, XrdOucStats::Bump(), kXR_Unsupported, ClientPutfileRequest::options, XrdXrootdStats::putfCnt, ClientRequest::putfile, Request, Response, XrdXrootdResponse::Send(), and SI.

Referenced by Process2().

int XrdXrootdProtocol::do_Qconf ( )
private

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

Referenced by do_Query().

int XrdXrootdProtocol::do_Qfh ( )
private

References XrdOucStats::Bump(), XrdXrootdMonitor::User::Did, XrdSfsFile::fctl(), ClientQueryRequest::fhandle, fsError(), FTab, XrdXrootdFileTable::Get(), XrdXrootdReqID::getID(), XrdLink::ID, ClientQueryRequest::infotype, kXR_ArgMissing, kXR_FileNotOpen, kXR_Qvisa, Link, XrdXrootdStats::miscCnt, Monitor, ClientRequest::query, ReqID, Request, Response, XrdXrootdResponse::Send(), SFS_FCTL_STATV, SFS_OK, SI, TRACEP, XrdXrootdFile::XrdSfsp, and XROOTD_MON_QUERY.

Referenced by Process2().

int XrdXrootdProtocol::do_Qopaque ( short  qopt)
private

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

Referenced by do_Query().

int XrdXrootdProtocol::do_Qspace ( )
private

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

Referenced by do_Query().

int XrdXrootdProtocol::do_Query ( )
private

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

Referenced by Process2().

int XrdXrootdProtocol::do_Qxattr ( )
private

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

Referenced by do_Query().

int XrdXrootdProtocol::do_Read ( )
private

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

Referenced by Process2().

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

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

Referenced by do_OffloadIO(), and do_Read().

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

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

Referenced by do_Read().

int XrdXrootdProtocol::do_ReadV ( )
private

References XrdXrootdMonitor::Add_rd(), XrdXrootdMonitor::Add_rv(), XrdXrootdMonitor::User::Agent, argp, XrdBuffer::bsize, XrdBuffer::buff, ClientRequestHdr::dlen, XrdSfsFile::error, readahead_list::fhandle, XrdXrootdFileStats::FileID, fsError(), FTab, XrdXrootdFileTable::Get(), getBuff(), XrdXrootdFHandle::handle, hcNext, hcNow, ClientRequest::header, XrdXrootdMonitor::User::InOut(), kXR_ArgInvalid, kXR_ArgTooLong, kXR_FileNotOpen, kXR_NoMemory, kXR_oksofar, maxTransz, Monitor, myFile, myIOLen, myOffset, numReads, numReadV, numSegsV, readahead_list::offset, XrdSfsFile::read(), Request, Response, readahead_list::rlen, XrdXrootdFileStats::rvOps(), rvSeq, XrdXrootdResponse::Send(), XrdXrootdFHandle::Set(), XrdXrootdFile::Stats, TRACEP, XrdXrootdFile::XrdSfsp, XROOTD_MON_READU, and XROOTD_MON_READV.

Referenced by Process2().

int XrdXrootdProtocol::do_Rm ( )
private

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

Referenced by Process2().

int XrdXrootdProtocol::do_Rmdir ( )
private

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

Referenced by Process2().

int XrdXrootdProtocol::do_Set ( )
private

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

Referenced by Process2().

int XrdXrootdProtocol::do_Set_Mon ( XrdOucTokenizer &  setargs)
private

References XrdXrootdMonitor::User::Agent, XrdXrootdMonitor::appID(), XrdXrootdMonitor::User::Did, XrdXrootdMonitor::User::Disable(), XrdXrootdMonitor::User::Enable(), XrdOucTokenizer::GetToken(), XrdXrootdMonitor::User::Info(), XrdXrootdMonitor::User::InOut(), kXR_ArgInvalid, kXR_ArgMissing, XrdXrootdMonitor::User::Logins(), XrdXrootdMonitor::User::MapInfo(), MonAuth(), Monitor, Response, and XrdXrootdResponse::Send().

Referenced by do_Set().

int XrdXrootdProtocol::do_Stat ( )
private

References argp, XrdBuffer::buff, XrdOucStats::Bump(), CRED, XrdXrootdMonitor::User::Did, ClientRequestHdr::dlen, XrdSfsFile::error, ClientStatRequest::fhandle, XrdSfsFileSystem::fsctl(), fsError(), FTab, XrdXrootdFileTable::Get(), XrdXrootdReqID::getID(), XrdXrootdFHandle::handle, ClientRequest::header, XrdLink::ID, kXR_ArgMissing, kXR_FileNotOpen, kXR_redirect, kXR_vfs, Link, XrdXrootdStats::miscCnt, Monitor, myFile, ClientStatRequest::options, osFS, Port, RD_stat, ReqID, Request, Response, Route, rpCheck(), rpEmsg(), XrdXrootdResponse::Send(), SFS_FSCTL_STATFS, SFS_OK, SI, Squash(), XrdSfsFileSystem::stat(), XrdSfsFile::stat(), stat(), ClientRequest::stat, StatGen(), TRACEP, vpEmsg(), XrdXrootdFile::XrdSfsp, and XROOTD_MON_STAT.

Referenced by Process2().

int XrdXrootdProtocol::do_Statx ( )
private

References argp, XrdBuffer::buff, CRED, XrdXrootdMonitor::User::Did, fsError(), XrdXrootdReqID::getID(), XrdLink::ID, kXR_file, kXR_isDir, kXR_offline, kXR_redirect, Link, Monitor, osFS, Port, RD_stat, ReqID, Response, Route, rpCheck(), rpEmsg(), XrdXrootdResponse::Send(), SFS_OK, Squash(), XrdSfsFileSystem::stat(), TRACEP, vpEmsg(), and XROOTD_MON_STAT.

Referenced by Process2().

int XrdXrootdProtocol::do_Sync ( )
private

References XrdOucStats::Bump(), XrdSfsFile::error, ClientSyncRequest::fhandle, fsError(), FTab, XrdXrootdFileTable::Get(), XrdXrootdReqID::getID(), XrdXrootdFHandle::handle, kXR_FileNotOpen, ReqID, Request, Response, XrdXrootdResponse::Send(), XrdOucErrInfo::setErrCB(), SFS_OK, SI, XrdSfsFile::sync(), ClientRequest::sync, XrdXrootdStats::syncCnt, TRACEP, and XrdXrootdFile::XrdSfsp.

Referenced by Process2().

int XrdXrootdProtocol::do_Truncate ( )
private

References argp, XrdBuffer::buff, XrdOucStats::Bump(), CRED, XrdXrootdMonitor::User::Did, ClientRequestHdr::dlen, XrdSfsFile::error, ClientTruncateRequest::fhandle, fsError(), FTab, XrdXrootdFileTable::Get(), XrdXrootdFHandle::handle, ClientRequest::header, XrdLink::ID, kXR_FileNotOpen, kXR_redirect, Link, XrdXrootdStats::miscCnt, Monitor, ClientTruncateRequest::offset, osFS, Port, RD_trunc, Request, Response, Route, rpCheck(), rpEmsg(), XrdXrootdResponse::Send(), SFS_OK, SI, Squash(), TRACEP, XrdSfsFileSystem::truncate(), XrdSfsFile::truncate(), ClientRequest::truncate, vpEmsg(), XrdXrootdFile::XrdSfsp, and XROOTD_MON_TRUNC.

Referenced by Process2().

int XrdXrootdProtocol::do_Write ( )
private

References XrdXrootdMonitor::Add_wr(), XrdXrootdMonitor::User::Agent, aio_Write(), argp, as_maxperlnk, as_maxstalls, as_miniosz, as_syncw, XrdXrootdFile::AsyncMode, XrdXrootdStats::AsyncRej, ClientWriteRequest::dlen, ClientRequestHdr::dlen, do_Offload(), do_WriteAll(), do_WriteNone(), XrdSfsFile::error, ClientWriteRequest::fhandle, XrdXrootdFileStats::FileID, FTab, XrdXrootdFileTable::Get(), XrdXrootdFHandle::handle, ClientRequest::header, XrdXrootdMonitor::User::InOut(), kXR_FileNotOpen, Link, Monitor, myEInfo, myFile, myIOLen, myOffset, myStalls, numWrites, ClientWriteRequest::offset, ClientWriteRequest::pathid, Request, Response, XrdXrootdResponse::Send(), XrdOucErrInfo::setErrInfo(), XrdLink::setEtext(), SFS_ERROR, SI, XrdXrootdFile::Stats, TRACEP, XrdLink::UseCnt(), ClientRequest::write, XrdXrootdFileStats::wrOps(), and XrdXrootdFile::XrdSfsp.

Referenced by Process2().

int XrdXrootdProtocol::do_WriteAll ( )
private

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

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

int XrdXrootdProtocol::do_WriteCont ( )
private

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

Referenced by do_OffloadIO(), and do_WriteAll().

int XrdXrootdProtocol::do_WriteNone ( )
private

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

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

void XrdXrootdProtocol::DoIt ( )
inlinevirtual

Implements XrdJob.

References Resume.

int XrdXrootdProtocol::fsError ( int  rc,
char  opc,
XrdOucErrInfo &  myError,
const char *  Path 
)
private

References XrdXrootdMonitor::User::Did, XrdOucEICB::Done(), eDest, eMsg, XrdSysError::Emsg(), XrdXrootdStats::errorCnt, XrdOucErrInfo::getErrCB(), XrdOucErrInfo::getErrText(), XrdXrootdProtocol::RD_Table::Host, XrdXrootdResponse::ID(), kXR_NotFound, kXR_redirect, kXR_ServerError, kXR_wait, kXR_waitresp, XProtocol::mapError(), Monitor, Port, XrdXrootdProtocol::RD_Table::Port, XrdXrootdStats::redirCnt, XrdXrootdMonitor::Redirect(), Response, Route, RQList, RQLxist, XrdXrootdResponse::Send(), SFS_DATA, SFS_ERROR, SFS_REDIRECT, SFS_STALL, SFS_STARTED, SI, XrdXrootdStats::stallCnt, TRACEI, XrdXrootdXPath::Validate(), and XROOTD_MON_REDLOCAL.

Referenced by do_Chmod(), do_CKsum(), do_Close(), do_Dirlist(), do_Locate(), do_Mkdir(), do_Mv(), do_Open(), do_Prepare(), do_Qfh(), do_Qopaque(), do_Qspace(), do_Qxattr(), do_ReadAll(), do_ReadV(), do_Rm(), do_Rmdir(), do_Stat(), do_Statx(), do_Sync(), do_Truncate(), and do_WriteNone().

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

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

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

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

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

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

int XrdXrootdProtocol::mapMode ( int  mode)
staticprivate

References Map_Mode.

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

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

Implements XrdProtocol.

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

void XrdXrootdProtocol::MonAuth ( )
private

References XrdXrootdMonitor::User::Auths(), Client, Entity, XrdSecEntity::grps, XrdSecEntity::host, XrdSecEntity::moninfo, Monitor, XrdSecEntity::name, XrdSecEntity::prot, XrdXrootdMonitor::User::Report(), XrdSecEntity::role, and XrdSecEntity::vorg.

Referenced by do_Auth(), and do_Set_Mon().

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

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

void XrdXrootdProtocol::PidFile ( void  )
staticprivate

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

Referenced by Configure().

int XrdXrootdProtocol::Process ( XrdLink *  lp)
virtual

Implements XrdProtocol.

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

int XrdXrootdProtocol::Process2 ( )
private

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

Referenced by Process().

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

Implements XrdProtocol.

References XrdXrootdMonitor::User::Agent, Cleanup(), XrdXrootdMonitor::User::Clear(), XrdXrootdMonitor::User::Did, XrdXrootdMonFile::Disc(), XrdXrootdMonitor::Disc(), eDest, XrdXrootdMonitor::User::Fstat(), XrdLink::ID, isActive, isDead, Link, XrdSysMutex::Lock(), XrdSysError::Log(), XrdXrootdMonitor::User::Logins(), Monitor, ProtLink, ProtStack, XrdObjectQ< T >::Push(), Reset(), XrdSysTimer::s2hms(), XrdLink::setRef(), Status, Stream, streamMutex, SYS_LOG_02, XrdSysMutex::UnLock(), XRD_BOUNDPATH, XROOTD_MON_BOUNDP, and XROOTD_MON_FORCED.

Referenced by Cleanup().

void XrdXrootdProtocol::Reset ( )
private

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

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

int XrdXrootdProtocol::rpCheck ( char *  fn,
const char **  opaque 
)
staticprivate

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(), do_Truncate(), and xexpdo().

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

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

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)
staticprivate

References XrdXrootdXPath::Validate(), and XPList.

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(), do_Truncate(), and xexpdo().

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 cumReadP, cumReads, cumReadV, cumSegsV, cumWrites, XrdSysMutex::Lock(), numReadP, numReads, numReadV, numSegsV, numWrites, XrdXrootdStats::prerCnt, XrdXrootdStats::readCnt, XrdXrootdStats::rsegCnt, XrdXrootdStats::rvecCnt, SI, XrdXrootdStats::Stats(), XrdOucStats::statsMutex, XrdSysMutex::UnLock(), and XrdXrootdStats::writeCnt.

Referenced by do_ReadAll().

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

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

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)
staticprivate
int XrdXrootdProtocol::xasync ( XrdOucStream &  Config)
staticprivate

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

Referenced by Config().

int XrdXrootdProtocol::xcksum ( XrdOucStream &  Config)
staticprivate

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

Referenced by Config().

int XrdXrootdProtocol::xexp ( XrdOucStream &  Config)
staticprivate

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

Referenced by Config().

int XrdXrootdProtocol::xexpdo ( char *  path,
int  popt = 0 
)
staticprivate

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

Referenced by Configure(), and xexp().

int XrdXrootdProtocol::xfsl ( XrdOucStream &  Config)
staticprivate

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

Referenced by Config().

int XrdXrootdProtocol::xlog ( XrdOucStream &  Config)
staticprivate

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

Referenced by Config().

int XrdXrootdProtocol::xmon ( XrdOucStream &  Config)
staticprivate

References XrdOuca2x::a2i(), XrdOuca2x::a2sz(), XrdOuca2x::a2tm(), XrdXrootdMonitor::Defaults(), eDest, XrdSysError::Emsg(), XrdOucStream::GetWord(), XrdXrootdMonitor::rdrMax, XROOTD_MON_ALL, XROOTD_MON_AUTH, XROOTD_MON_FILE, XROOTD_MON_FSLFN, XROOTD_MON_FSOPS, XROOTD_MON_FSSSQ, XROOTD_MON_FSTA, XROOTD_MON_FSXFR, XROOTD_MON_INFO, XROOTD_MON_IO, XROOTD_MON_IOV, XROOTD_MON_REDR, and XROOTD_MON_USER.

Referenced by Config().

int XrdXrootdProtocol::xpidf ( XrdOucStream &  Config)
staticprivate

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

Referenced by Config().

int XrdXrootdProtocol::xprep ( XrdOucStream &  Config)
staticprivate

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

Referenced by Config().

int XrdXrootdProtocol::xred ( XrdOucStream &  Config)
staticprivate

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

Referenced by Config().

void XrdXrootdProtocol::xred_set ( RD_func  func,
const char *  rHost,
int  rPort 
)
staticprivate

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

Referenced by xred().

int XrdXrootdProtocol::xsecl ( XrdOucStream &  Config)
staticprivate

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

Referenced by Config().

int XrdXrootdProtocol::xtrace ( XrdOucStream &  Config)
staticprivate

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

Referenced by Config().

Friends And Related Function Documentation

friend class XrdXrootdAdmin
friend
friend class XrdXrootdAioReq
friend

Member Data Documentation

union { ... }
XrdNetSocket * XrdXrootdProtocol::AdminSock = 0
staticprotected

Referenced by Configure().

XrdBuffer* XrdXrootdProtocol::argp
protected

Referenced by Cleanup(), 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(), getBuff(), Process(), Process2(), and Reset().

int XrdXrootdProtocol::as_force = 0
staticprotected

Referenced by do_Open(), and xasync().

int XrdXrootdProtocol::as_maxperlnk = 8
staticprotected

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

int XrdXrootdProtocol::as_maxperreq = 8
staticprotected

Referenced by Configure(), and xasync().

int XrdXrootdProtocol::as_maxpersrv = 4096
staticprotected

Referenced by Configure(), and xasync().

int XrdXrootdProtocol::as_maxstalls = 5
staticprotected

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

int XrdXrootdProtocol::as_miniosz = 32768
staticprotected

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

int XrdXrootdProtocol::as_minsfsz = 8192
staticprotected

Referenced by do_ReadAll(), and xasync().

int XrdXrootdProtocol::as_noaio = 0
staticprotected

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

int XrdXrootdProtocol::as_nosf = 0
staticprotected

Referenced by Configure(), and xasync().

int XrdXrootdProtocol::as_segsize = 131072
staticprotected

Referenced by Configure(), and xasync().

int XrdXrootdProtocol::as_syncw = 0
staticprotected

Referenced by do_Write(), and xasync().

XrdSecProtocol* XrdXrootdProtocol::AuthProt
protected

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

XrdBuffManager * XrdXrootdProtocol::BPool
staticprotected

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

unsigned char XrdXrootdProtocol::CapVer
protected

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

char XrdXrootdProtocol::chkfsV = 0
staticprotected

Referenced by Configure(), and xfsl().

XrdSecService * XrdXrootdProtocol::CIA = 0
staticprotected

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

XrdSecEntity* XrdXrootdProtocol::Client
protected

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

int XrdXrootdProtocol::clientPV
protected

Referenced by do_Protocol(), and Reset().

int XrdXrootdProtocol::cumReadP
protected

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

int XrdXrootdProtocol::cumReads
protected

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

int XrdXrootdProtocol::cumReadV
protected

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

int XrdXrootdProtocol::cumSegsV
protected

Referenced by Reset(), and Stats().

int XrdXrootdProtocol::cumWrites
protected

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

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
staticprotected

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

XrdSecEntity XrdXrootdProtocol::Entity
protected

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

char * XrdXrootdProtocol::FSLib = 0
staticprotected

Referenced by Configure(), and xfsl().

XrdXrootdFileTable* XrdXrootdProtocol::FTab
protected

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

int XrdXrootdProtocol::hailWait
staticprotected

Referenced by Configure(), and Match().

int XrdXrootdProtocol::halfBSize
protected

Referenced by getBuff(), and Process().

int XrdXrootdProtocol::hcMax = 28657
staticprotected

Referenced by getBuff().

int XrdXrootdProtocol::hcNext
protected

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

int XrdXrootdProtocol::hcNow
protected

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

int XrdXrootdProtocol::hcPrev
protected

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

char XrdXrootdProtocol::isActive
protected

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

char XrdXrootdProtocol::isBound
protected

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

char XrdXrootdProtocol::isDead
protected

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

char XrdXrootdProtocol::isNOP
protected

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

char XrdXrootdProtocol::isRedir = 0
staticprotected

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

XrdXrootdJob * XrdXrootdProtocol::JobCKS = 0
staticprotected

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

char * XrdXrootdProtocol::JobCKT = 0
staticprotected

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

char XrdXrootdProtocol::JobLCL = 0
staticprotected

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

XrdLink* XrdXrootdProtocol::Link
protected

Referenced by aio_Error(), XrdXrootdAioReq::Alloc(), Cleanup(), 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_Stat(), do_Statx(), do_Truncate(), do_Write(), do_WriteNone(), getData(), Match(), operator=(), Process(), Process2(), Recycle(), and Reset().

XrdXrootdFileLock * XrdXrootdProtocol::Locker
staticprotected

Referenced by Configure(), and do_Open().

int XrdXrootdProtocol::maxBuffsz
staticprotected

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

const int XrdXrootdProtocol::maxPio = 4
staticprotected

Referenced by do_Bind(), and do_Qconf().

const int XrdXrootdProtocol::maxRvecsz = 1024
staticprotected

Referenced by do_Qconf().

const int XrdXrootdProtocol::maxStreams = 16
staticprotected

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

int XrdXrootdProtocol::maxTransz = 262144
staticprotected

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

XrdXrootdMonitor::User XrdXrootdProtocol::Monitor
protected

Referenced by Cleanup(), do_Auth(), do_Chmod(), do_CKsum(), do_Close(), do_Dirlist(), do_Locate(), do_Login(), XrdXrootdAdmin::do_Lsd(), do_Mkdir(), do_Mv(), do_Open(), do_Prepare(), do_Qfh(), do_Qopaque(), do_Qspace(), do_Qxattr(), do_Read(), do_ReadV(), do_Rm(), do_Rmdir(), do_Set_Mon(), do_Stat(), do_Statx(), do_Truncate(), do_Write(), fsError(), MonAuth(), and Recycle().

XrdXrootdAioReq* XrdXrootdProtocol::myAioReq
protected

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

int XrdXrootdProtocol::myBlast
protected

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

int XrdXrootdProtocol::myBlen
protected

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

char* XrdXrootdProtocol::myBuff
protected

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

int XrdXrootdProtocol::myEInfo[2]

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

XrdXrootdFile* XrdXrootdProtocol::myFile
protected

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

const char * XrdXrootdProtocol::myInst = 0
staticprotected

Referenced by Configure(), and xprep().

int XrdXrootdProtocol::myIOLen
protected

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

long long XrdXrootdProtocol::myOffset

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

int XrdXrootdProtocol::myPID = static_cast<int>(getpid())
staticprotected

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

int XrdXrootdProtocol::myRole = 0
staticprotected

Referenced by Configure(), and do_Protocol().

int XrdXrootdProtocol::myRolf = 0
staticprotected

Referenced by Configure().

unsigned int XrdXrootdProtocol::mySID
protected

Referenced by do_Login(), and Reset().

int XrdXrootdProtocol::myStalls
protected

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

char * XrdXrootdProtocol::Notify = 0
staticprotected

Referenced by Configure(), and do_Prepare().

int XrdXrootdProtocol::numFiles
protected

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

int XrdXrootdProtocol::numReadP
protected

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

int XrdXrootdProtocol::numReads
protected

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

int XrdXrootdProtocol::numReadV
protected

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

int XrdXrootdProtocol::numSegsV
protected

Referenced by do_ReadV(), Reset(), and Stats().

int XrdXrootdProtocol::numWrites
protected

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

XrdSfsFileSystem * XrdXrootdProtocol::osFS
staticprotected

Referenced by CheckSum(), Configure(), 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 do_Bind(), and Reset().

char * XrdXrootdProtocol::pidPath = strdup("/tmp")
staticprotected

Referenced by PidFile(), and xpidf().

XrdXrootdPio* XrdXrootdProtocol::pioFirst
protected

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

XrdXrootdPio* XrdXrootdProtocol::pioFree
protected

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

XrdXrootdPio* XrdXrootdProtocol::pioLast
protected

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

int XrdXrootdProtocol::Port
staticprotected

Referenced by Configure(), 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(), do_Truncate(), fsError(), and xred().

XrdObject<XrdXrootdProtocol> XrdXrootdProtocol::ProtLink
private

Referenced by Recycle().

XrdObjectQ< XrdXrootdProtocol > XrdXrootdProtocol::ProtStack
staticprivate

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

int XrdXrootdProtocol::readWait
staticprotected

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

XrdXrootdReqID XrdXrootdProtocol::ReqID
protected

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

ClientRequest XrdXrootdProtocol::Request
protected

Referenced by 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(), do_Write(), Match(), operator=(), Process(), Process2(), and Reset().

XrdXrootdResponse XrdXrootdProtocol::Response
protected

Referenced by XrdXrootdAioReq::Alloc(), 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(), Match(), operator=(), Process(), Process2(), rpEmsg(), and vpEmsg().

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

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

XrdSysSemaphore* XrdXrootdProtocol::reTry
protected

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

struct XrdXrootdProtocol::RD_Table XrdXrootdProtocol::Route[RD_Num]
staticprotected

Referenced by Configure(), 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(), do_Truncate(), fsError(), xred(), and xred_set().

XrdXrootdXPath XrdXrootdProtocol::RPList
staticprotected

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

XrdXrootdXPath XrdXrootdProtocol::RQList
staticprotected

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

int XrdXrootdProtocol::RQLxist = 0
staticprotected

Referenced by fsError(), and xred().

char XrdXrootdProtocol::rvSeq
protected

Referenced by do_ReadV(), and Reset().

XrdScheduler * XrdXrootdProtocol::Sched
staticprotected

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

char * XrdXrootdProtocol::SecLib = 0
staticprotected

Referenced by Configure(), and xsecl().

XrdXrootdStats * XrdXrootdProtocol::SI
staticprotected

Referenced by CheckSum(), Cleanup(), Configure(), do_Auth(), do_Bind(), do_Close(), do_Endsess(), do_Getfile(), do_Login(), do_Open(), do_Ping(), do_Protocol(), do_Putfile(), do_Qfh(), do_Query(), do_ReadAll(), do_Stat(), do_Sync(), do_Truncate(), do_Write(), fsError(), XrdXrootdAioReq::Init(), Match(), Process2(), and Stats().

char XrdXrootdProtocol::Status
protected

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

XrdXrootdProtocol* XrdXrootdProtocol::Stream[maxStreams]
protected

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

XrdSysMutex XrdXrootdProtocol::streamMutex
protected

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

long long XrdXrootdProtocol::totReadP
protected

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

const char * XrdXrootdProtocol::TraceID = "Protocol"
staticprotected
int XrdXrootdProtocol::WANPort
staticprotected

Referenced by Configure(), and do_Qconf().

int XrdXrootdProtocol::WANWindow
staticprotected

Referenced by Configure(), and do_Qconf().

int XrdXrootdProtocol::Window
staticprotected

Referenced by Configure(), and do_Qconf().

XrdXrootdXPath XrdXrootdProtocol::XPList
staticprotected

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

The documentation for this class was generated from the following files:
Generated by   doxygen 1.8.1.1