XrdXrootdProtocol Class Reference

#include <XrdXrootdProtocol.hh>

Inheritance diagram for XrdXrootdProtocol:

Collaboration diagram for XrdXrootdProtocol:

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

Additional Inherited Members
Public Attributes inherited from XrdJob
XrdJob *	NextJob
const char *	Comment

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(), XrdXrootdAioReq::Init(), 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(), XrdXrootdAioReq::Init(), 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:

• XrdXrootdProtocol.cc
• XrdXrootdProtocol.hh
• XrdXrootdConfig.cc
• XrdXrootdXeq.cc
• XrdXrootdXeqAio.cc