#include <XrdXrootdProtocol.hh>
Inheritance diagram for XrdXrootdProtocol:
Public Member Functions | |
| void | DoIt () |
| XrdProtocol * | Match (XrdLink *lp) |
| int | Process (XrdLink *lp) |
| void | Recycle (XrdLink *lp, int consec, const char *reason) |
| int | Stats (char *buff, int blen, int do_sync=0) |
| XrdXrootdProtocol | operator= (const XrdXrootdProtocol &rhs) |
| XrdXrootdProtocol () | |
| ~XrdXrootdProtocol () | |
Static Public Member Functions | |
| static int | Configure (char *parms, XrdProtocol_Config *pi) |
| static int | mapError (int rc) |
| static int | StatGen (struct stat &buf, char *xxBuff) |
Protected Attributes | |
| int | numReads |
| int | numReadP |
| int | numWrites |
| int | numFiles |
| int | cumReads |
| int | cumReadP |
| int | cumWrites |
| long long | totReadP |
| XrdLink * | Link |
| XrdBuffer * | argp |
| XrdXrootdFileTable * | FTab |
| XrdXrootdMonitor * | Monitor |
| kXR_unt32 | monUID |
| char | monFILE |
| char | monIO |
| char | Status |
| unsigned char | CapVer |
| XrdSecEntity * | Client |
| XrdSecProtocol * | AuthProt |
| XrdSecEntity | Entity |
| XrdXrootdAioReq * | myAioReq |
| char * | myBuff |
| int | myBlen |
| int | myBlast |
| int(XrdXrootdProtocol::* | Resume )() |
| XrdXrootdFile * | myFile |
| long long | myOffset |
| int | myIOLen |
| int | myStalls |
| int | hcPrev |
| int | hcNext |
| int | hcNow |
| int | halfBSize |
| XrdSysMutex | streamMutex |
| XrdSysSemaphore * | reTry |
| XrdXrootdProtocol * | Stream [maxStreams] |
| unsigned int | mySID |
| char | isActive |
| char | isDead |
| char | isBound |
| char | isNOP |
| XrdXrootdPio * | pioFirst |
| XrdXrootdPio * | pioLast |
| XrdXrootdPio * | pioFree |
| short | PathID |
| char | doWrite |
| char | doWriteC |
| XrdXrootdReqID | ReqID |
| ClientRequest | Request |
| XrdXrootdResponse | Response |
Static Protected Attributes | |
| static XrdXrootdXPath | RPList |
| static XrdXrootdXPath | XPList |
| static XrdSfsFileSystem * | osFS |
| static XrdSecService * | CIA |
| static XrdXrootdFileLock * | Locker |
| static XrdScheduler * | Sched |
| static XrdBuffManager * | BPool |
| static XrdSysError | eDest |
| static const char * | myInst |
| static const char * | TraceID |
| static char * | pidPath |
| static int | myPID |
| static XrdNetSocket * | AdminSock |
| static int | hailWait |
| static int | readWait |
| static int | Port |
| static int | Window |
| static int | WANPort |
| static int | WANWindow |
| static char * | SecLib |
| static char * | FSLib |
| static char * | Notify |
| static char | isRedir |
| static char | chkfsV |
| static XrdXrootdJob * | JobCKS |
| static char * | JobCKT |
| static struct XrdXrootdProtocol::RD_Table | Route [RD_Num] |
| static int | as_maxperlnk |
| static int | as_maxperreq |
| static int | as_maxpersrv |
| static int | as_miniosz |
| static int | as_minsfsz |
| static int | as_segsize |
| static int | as_maxstalls |
| static int | as_force |
| static int | as_noaio |
| static int | as_nosf |
| static int | as_syncw |
| static int | maxBuffsz |
| static int | maxTransz |
| static const int | maxRvecsz = 1024 |
| static XrdXrootdStats * | SI |
| static int | hcMax |
| static const int | maxStreams = 16 |
| static const int | maxPio = 4 |
Private Types | |
| enum | RD_func |
Private Member Functions | |
| int | do_Admin () |
| int | do_Auth () |
| int | do_Bind () |
| int | do_Chmod () |
| int | do_CKsum (int canit) |
| int | do_Close () |
| int | do_Dirlist () |
| int | do_Endsess () |
| int | do_Getfile () |
| int | do_Login () |
| int | do_Locate () |
| int | do_Mkdir () |
| int | do_Mv () |
| int | do_Offload (int pathID, int isRead) |
| int | do_OffloadIO () |
| int | do_Open () |
| int | do_Ping () |
| int | do_Prepare () |
| int | do_Protocol () |
| int | do_Putfile () |
| int | do_Qconf () |
| int | do_Qfh () |
| int | do_Qopaque (short) |
| int | do_Qspace () |
| int | do_Query () |
| int | do_Qxattr () |
| int | do_Read () |
| int | do_ReadV () |
| int | do_ReadAll (int asyncOK=1) |
| int | do_ReadNone (int &retc, int &pathID) |
| int | do_Rm () |
| int | do_Rmdir () |
| int | do_Set () |
| int | do_Set_Mon (XrdOucTokenizer &setargs) |
| int | do_Stat () |
| int | do_Statx () |
| int | do_Sync () |
| int | do_Truncate () |
| int | do_Write () |
| int | do_WriteAll () |
| int | do_WriteCont () |
| int | do_WriteNone () |
| int | aio_Error (const char *op, int ecode) |
| int | aio_Read () |
| int | aio_Write () |
| int | aio_WriteAll () |
| int | aio_WriteCont () |
| void | Assign (const XrdXrootdProtocol &rhs) |
| void | Cleanup () |
| int | fsError (int rc, XrdOucErrInfo &myError) |
| int | getBuff (const int isRead, int Quantum) |
| int | getData (const char *dtype, char *buff, int blen) |
| int | Process2 () |
| void | Reset () |
| int | rpEmsg (const char *op, char *fn) |
| int | vpEmsg (const char *op, char *fn) |
Static Private Member Functions | |
| 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 |
Classes | |
| struct | RD_Table |
Definition at line 84 of file XrdXrootdProtocol.cc.
enum XrdXrootdProtocol::RD_func [private] |
Definition at line 99 of file XrdXrootdProtocol.hh.
| XrdXrootdProtocol::XrdXrootdProtocol | ( | ) |
Definition at line 163 of file XrdXrootdProtocol.cc.
References Reset().
Referenced by Match(), and XrdgetProtocol().
| XrdXrootdProtocol::~XrdXrootdProtocol | ( | ) | [inline] |
| int XrdXrootdProtocol::Configure | ( | char * | parms, | |
| XrdProtocol_Config * | pi | |||
| ) | [static] |
Definition at line 97 of file XrdXrootdConfig.cc.
References XrdXrootdAdmin::addJob(), AdminSock, as_maxperreq, as_maxpersrv, as_miniosz, as_noaio, as_nosf, as_segsize, BPool, c, chkfsV, CIA, Config(), XrdNetSocket::Create(), DEBUG, eDest, XrdSysError::Emsg(), XrdOucEnv::Export(), free(), FSLib, XrdOucUtils::genPath(), getenv(), XrdSfsFileSystem::getVersion(), hailWait, i, if(), XrdXrootdAioReq::Init(), XrdXrootdFile::Init(), XrdXrootdAdmin::Init(), XrdXrootdMonitor::Init(), XrdXrootdXPath::Insert(), XrdNetDNS::IPAddr(), isRedir, JobCKS, k, Locker, Logger, XrdSysError::logger(), malloc(), maxBuffsz, XrdBuffManager::MaxSize(), maxTransz, myInst, n, XrdXrootdXPath::Next(), Notify, optind, XrdXrootdXPath::Opts(), osFS, XrdXrootdXPath::Path(), pi, PidFile(), Port, ProtStack, readWait, Route, RPList, XrdSysError::Say(), Sched, SecLib, XrdObjectQ< T >::Set(), XrdXrootdStats::setFS(), XrdXrootdCallBack::setVals(), SI, sprintf(), strcpy(), TRACE, TRACE_ALL, TRACE_MEM, WANPort, WANWindow, XrdOucTrace::What, Window, xexpdo(), XPList, XrdSfsGetDefaultFileSystem(), XrdXrootdInstance, XrdXrootdloadFileSystem(), XrdXrootdloadSecurity(), XrdXrootdNetwork, XrdXrootdPort, XrdXrootdPrepQ, XrdXrootdReqID, and XrdXrootdTrace.
Referenced by XrdgetProtocol().
| void XrdXrootdProtocol::DoIt | ( | ) | [inline, virtual] |
| XrdProtocol * XrdXrootdProtocol::Match | ( | XrdLink * | lp | ) | [virtual] |
Implements XrdProtocol.
Definition at line 201 of file XrdXrootdProtocol.cc.
References Entity, hailWait, XrdSecEntity::host, XrdLink::Host(), isRedir, kXR_DataServer, kXR_LBalServer, Link, XrdLink::Peek(), XrdObjectQ< T >::Pop(), XrdSecEntity::prot, ProtStack, XrdLink::Recv(), Response, ROOTD_PQ, XrdLink::Send(), XrdXrootdResponse::Set(), XrdLink::setEtext(), strcpy(), UPSTATS, XrdXrootdProtocol(), and XROOTD_VERSBIN.
| int XrdXrootdProtocol::Process | ( | XrdLink * | lp | ) | [virtual] |
Implements XrdProtocol.
Definition at line 273 of file XrdXrootdProtocol.cc.
References argp, BPool, XrdBuffer::bsize, XrdBuffer::buff, getData(), halfBSize, hcNow, hcPrev, kXR_ArgInvalid, kXR_ArgTooLong, kXR_write, Link, myAioReq, myBlen, myBuff, XrdBuffManager::Obtain(), Process2(), XrdXrootdAioReq::Recycle(), XrdBuffManager::Release(), Request, Response, Resume, XrdXrootdResponse::Send(), XrdXrootdResponse::Set(), XrdLink::setEtext(), and TRACEP.
| void XrdXrootdProtocol::Recycle | ( | XrdLink * | lp, | |
| int | consec, | |||
| const char * | reason | |||
| ) | [virtual] |
Implements XrdProtocol.
Definition at line 446 of file XrdXrootdProtocol.cc.
References Cleanup(), XrdXrootdMonitor::Disc(), eDest, XrdLink::ID, isActive, isDead, Link, XrdSysMutex::Lock(), XrdSysError::Log(), Monitor, monUID, XrdXrootdMonitor::monUSER, ProtLink, ProtStack, XrdObjectQ< T >::Push(), Reset(), XrdSysTimer::s2hms(), XrdLink::setRef(), snprintf, Status, Stream, streamMutex, SYS_LOG_02, XrdSysMutex::UnLock(), and XRD_BOUNDPATH.
Referenced by Cleanup().
| int XrdXrootdProtocol::Stats | ( | char * | buff, | |
| int | blen, | |||
| int | do_sync = 0 | |||
| ) | [virtual] |
Implements XrdProtocol.
Definition at line 499 of file XrdXrootdProtocol.cc.
References cumReadP, cumReads, cumWrites, XrdSysMutex::Lock(), numReadP, numReads, numWrites, XrdXrootdStats::prerCnt, XrdXrootdStats::readCnt, SI, XrdXrootdStats::Stats(), XrdXrootdStats::statsMutex, XrdSysMutex::UnLock(), and XrdXrootdStats::writeCnt.
| int XrdXrootdProtocol::mapError | ( | int | rc | ) | [static] |
Definition at line 2331 of file XrdXrootdXeq.cc.
References ENETUNREACH, ENOBUFS, ETXTBSY, kXR_ArgTooLong, kXR_FSError, kXR_inProgress, kXR_InvalidRequest, kXR_IOError, kXR_isDirectory, kXR_NoMemory, kXR_noserver, kXR_NoSpace, kXR_NotAuthorized, kXR_NotFile, and kXR_NotFound.
Referenced by fsError(), XrdXrootdCallBack::sendError(), and XrdXrootdAioReq::sendError().
| static int XrdXrootdProtocol::StatGen | ( | struct stat & | buf, | |
| char * | xxBuff | |||
| ) | [static] |
| XrdXrootdProtocol XrdXrootdProtocol::operator= | ( | const XrdXrootdProtocol & | rhs | ) |
| int XrdXrootdProtocol::do_Admin | ( | ) | [private] |
Definition at line 80 of file XrdXrootdXeq.cc.
References kXR_Unsupported, Response, and XrdXrootdResponse::Send().
Referenced by Process2().
| int XrdXrootdProtocol::do_Auth | ( | ) | [private] |
Definition at line 89 of file XrdXrootdXeq.cc.
References argp, ClientRequest::auth, XrdSecProtocol::Authenticate(), AuthProt, XrdBuffer::buff, XrdSecBuffer::buffer, CIA, Client, ClientAuthRequest::credtype, XrdSecProtocol::Delete(), ClientRequestHdr::dlen, eDest, eMsg, XrdSysError::Emsg(), XrdSecProtocol::Entity, Entity, XrdSecService::getProtocol(), ClientRequest::header, XrdLink::Host(), XrdLink::ID, kXR_authmore, kXR_NotAuthorized, kXR_ServerError, Link, XrdSysError::Log(), n, XrdLink::Name(), XrdSecEntity::name, numReads, XrdSecEntity::prot, Request, Response, XrdXrootdResponse::Send(), XrdSecBuffer::size, XrdSysTimer::Snooze(), Status, strcpy(), SYS_LOG_01, TRACEP, XRD_ADMINUSER, and XRD_NEED_AUTH.
Referenced by Process2().
| int XrdXrootdProtocol::do_Bind | ( | ) | [private] |
Definition at line 171 of file XrdXrootdXeq.cc.
References XrdXrootdPio::Alloc(), ClientRequest::bind, CapVer, eDest, EINPROGRESS, XrdXrootdSessID::FD, XrdLink::fd2link(), XrdLink::FDnum(), free(), XrdLink::Host(), i, XrdXrootdSessID::Inst, isBound, kXR_ArgInvalid, kXR_NoMemory, kXR_NotAuthorized, kXR_NotFound, kXR_ok, Link, XrdSysError::Log(), maxPio, maxStreams, myPID, NULL, PathID, XrdXrootdSessID::Pid, pioFree, Request, Response, rindex, XrdXrootdResponse::Send(), ClientBindRequest::sessid, XrdLink::setID(), XrdXrootdSessID::Sid, sprintf(), Status, Stream, strtol(), SYS_LOG_01, UPSTATS, XRD_BOUNDPATH, XRD_LOGGEDIN, and XRD_NEED_AUTH.
Referenced by Process2().
| int XrdXrootdProtocol::do_Chmod | ( | ) | [private] |
Definition at line 271 of file XrdXrootdXeq.cc.
References argp, XrdBuffer::buff, ClientRequest::chmod, XrdSfsFileSystem::chmod(), CRED, fsError(), XrdLink::ID, kXR_redirect, Link, mapMode(), ClientChmodRequest::mode, osFS, Port, RD_chmod, Request, Response, Route, rpCheck(), rpEmsg(), XrdXrootdResponse::Send(), SFS_OK, Squash(), TRACEP, and vpEmsg().
Referenced by Process2().
| int XrdXrootdProtocol::do_CKsum | ( | int | canit | ) | [private] |
Definition at line 303 of file XrdXrootdXeq.cc.
References argp, XrdBuffer::buff, XrdXrootdJob::Cancel(), CapVer, JOB_Sync, JobCKS, JobCKT, kXR_Unsupported, kXR_ver002, kXR_vermask, Response, rpCheck(), rpEmsg(), XrdXrootdJob::Schedule(), XrdXrootdResponse::Send(), Squash(), and vpEmsg().
Referenced by do_Query().
| int XrdXrootdProtocol::do_Close | ( | ) | [private] |
Definition at line 341 of file XrdXrootdXeq.cc.
References ClientRequest::close, XrdXrootdMonitor::Close(), XrdXrootdFileTable::Del(), ClientCloseRequest::fhandle, fp, FTab, XrdXrootdFileTable::Get(), XrdXrootdFHandle::handle, kXR_FileNotOpen, kXR_FSError, Link, monFILE, Monitor, numFiles, Request, Response, XrdXrootdResponse::Send(), XrdLink::Serialize(), SFS_OK, TRACEP, and UPSTATS.
Referenced by Process2().
| int XrdXrootdProtocol::do_Dirlist | ( | ) | [private] |
Definition at line 384 of file XrdXrootdXeq.cc.
References argp, XrdBuffer::buff, XrdSfsDirectory::close(), xmlio::cnt, CRED, eDest, XrdSysError::Emsg(), XrdSfsDirectory::error, fsError(), XrdLink::ID, kXR_NoMemory, kXR_oksofar, kXR_redirect, Link, XrdSfsFileSystem::newDir(), XrdSfsDirectory::nextEntry(), XrdSfsDirectory::open(), osFS, Port, RD_dirlist, Response, Route, rpCheck(), rpEmsg(), XrdXrootdResponse::Send(), snprintf, Squash(), strcpy(), TRACEP, and vpEmsg().
Referenced by Process2().
| int XrdXrootdProtocol::do_Endsess | ( | ) | [private] |
Definition at line 455 of file XrdXrootdXeq.cc.
References ClientRequest::endsess, XrdXrootdSessID::FD, XrdXrootdSessID::Inst, kXR_Cancelled, kXR_NotAuthorized, kXR_NotFound, kXR_wait, Link, myPID, XrdXrootdSessID::Pid, Request, Response, XrdXrootdResponse::Send(), ClientEndsessRequest::sessid, strerror(), XrdLink::Terminate(), TRACEP, and UPSTATS.
Referenced by Process2().
| int XrdXrootdProtocol::do_Getfile | ( | ) | [private] |
Definition at line 505 of file XrdXrootdXeq.cc.
References ClientGetfileRequest::buffsz, ClientRequest::getfile, int, kXR_Unsupported, ClientGetfileRequest::options, Request, Response, XrdXrootdResponse::Send(), and UPSTATS.
Referenced by Process2().
| int XrdXrootdProtocol::do_Login | ( | ) | [private] |
Definition at line 577 of file XrdXrootdXeq.cc.
References XrdXrootdMonitor::Alloc(), ClientLoginRequest::capver, CapVer, CIA, Client, eDest, Entity, XrdXrootdSessID::FD, XrdLink::FDnum(), XrdSecService::getParms(), ClientRequest::header, XrdLink::Host(), XrdLink::ID, XrdXrootdSessID::Inst, XrdLink::Inst(), int, iovec::iov_base, iovec::iov_len, kXR_InvalidRequest, kXR_useradmin, kXR_vermask, Link, XrdSysMutex::Lock(), XrdSysError::Log(), ClientRequest::login, XrdXrootdMonitor::Map(), XrdXrootdMonitor::monFILE, monFILE, monIO, XrdXrootdMonitor::monIO, Monitor, monUID, XrdXrootdMonitor::monUSER, myPID, mySID, XrdXrootdSessID::Pid, ClientLoginRequest::pid, ReqID, Request, Response, ClientLoginRequest::role, XrdXrootdResponse::Send(), XrdLink::setID(), XrdXrootdReqID::setID(), XrdXrootdSessID::Sid, Status, ClientRequestHdr::streamid, SYS_LOG_01, XrdSecEntity::tident, XrdSysMutex::UnLock(), UPSTATS, ClientLoginRequest::username, XRD_ADMINUSER, XRD_LOGGEDIN, XRD_NEED_AUTH, and XROOTD_MON_MAPUSER.
Referenced by Process2().
| int XrdXrootdProtocol::do_Locate | ( | ) | [private] |
Definition at line 525 of file XrdXrootdXeq.cc.
References argp, XrdBuffer::buff, CRED, XrdSfsFileSystem::fsctl(), fsError(), XrdXrootdReqID::getID(), XrdLink::ID, int, kXR_nowait, kXR_redirect, kXR_refresh, Link, ClientRequest::locate, XrdXrootdXPath::Next(), ClientLocateRequest::options, opts, osFS, Path, XrdXrootdXPath::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(), and XPList.
Referenced by Process2().
| int XrdXrootdProtocol::do_Mkdir | ( | ) | [private] |
Definition at line 677 of file XrdXrootdXeq.cc.
References argp, XrdBuffer::buff, CRED, fsError(), XrdLink::ID, kXR_mkdirpath, kXR_redirect, Link, mapMode(), XrdSfsFileSystem::mkdir(), ClientRequest::mkdir, ClientMkdirRequest::mode, ClientMkdirRequest::options, osFS, Port, RD_mkdir, Request, Response, Route, rpCheck(), rpEmsg(), S_IRWXU, XrdXrootdResponse::Send(), SFS_O_MKPTH, SFS_OK, Squash(), TRACEP, and vpEmsg().
Referenced by Process2().
| int XrdXrootdProtocol::do_Mv | ( | ) | [private] |
Definition at line 711 of file XrdXrootdXeq.cc.
References argp, XrdBuffer::buff, CRED, fsError(), XrdLink::ID, kXR_ArgMissing, kXR_redirect, Link, osFS, Port, RD_mv, XrdSfsFileSystem::rename(), Response, Route, rpCheck(), rpEmsg(), XrdXrootdResponse::Send(), SFS_OK, Squash(), TRACEP, and vpEmsg().
Referenced by Process2().
| int XrdXrootdProtocol::do_Offload | ( | int | pathID, | |
| int | isRead | |||
| ) | [private] |
Definition at line 758 of file XrdXrootdXeq.cc.
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] |
Definition at line 834 of file XrdXrootdXeq.cc.
References do_ReadAll(), do_WriteAll(), do_WriteCont(), doWrite, doWriteC, EINPROGRESS, isActive, isNOP, XrdXrootdPio::isWrite, Link, XrdSysMutex::Lock(), myFile, XrdXrootdPio::myFile, myIOLen, XrdXrootdPio::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] |
Definition at line 883 of file XrdXrootdXeq.cc.
References XrdXrootdFileTable::Add(), argp, as_force, as_noaio, XrdBuffer::buff, ServerResponseBody_Open::cpsize, ServerResponseBody_Open::cptype, CRED, eDest, XrdSysError::Emsg(), ServerResponseBody_Open::fhandle, XrdXrootdFile::FileID, fp, fsError(), FTab, XrdXrootdReqID::getID(), XrdLink::ID, int, iovec::iov_base, iovec::iov_len, 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, XrdXrootdMonitor::Map(), mapMode(), ClientOpenRequest::mode, monFILE, Monitor, XrdSfsFileSystem::newFile(), numFiles, XrdXrootdFileLock::numLocks(), XrdXrootdMonitor::Open(), ClientRequest::open, ClientOpenRequest::options, opts, osFS, Port, RD_open1, ReqID, Request, Response, Route, rpCheck(), rpEmsg(), RPList, S_IRUSR, S_IWUSR, XrdXrootdResponse::Send(), XrdLink::Serialize(), 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, snprintf, Squash(), stat, StatGen(), TRACEP, UPSTATS, usage, XrdXrootdXPath::Validate(), vpEmsg(), XrdXrootdFile::XrdSfsp, XROOTD_MON_MAPPATH, and XROOTDXP_NOLK.
Referenced by Process2().
| int XrdXrootdProtocol::do_Ping | ( | ) | [private] |
Definition at line 1076 of file XrdXrootdXeq.cc.
References Response, XrdXrootdResponse::Send(), and UPSTATS.
Referenced by Process2().
| int XrdXrootdProtocol::do_Prepare | ( | ) | [private] |
Definition at line 1092 of file XrdXrootdXeq.cc.
References argp, XrdBuffer::buff, CRED, XrdLink::FDnum(), fsError(), XrdXrootdResponse::ID(), XrdLink::ID, XrdOucReqID::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(), Notify, XrdSfsPrep::notify, XrdSfsPrep::oinfo, ClientPrepareRequest::options, XrdSfsPrep::opts, opts, osFS, pathlist, XrdSfsPrep::paths, XrdXrootdPrepArgs::paths, Port, Prep_COLOC, Prep_FRESH, Prep_PRTY0, Prep_SENDACK, Prep_SENDAOK, Prep_STAGE, Prep_WMODE, ClientRequest::prepare, XrdSfsFileSystem::prepare(), RD_prepare, RD_prepstg, XrdSfsPrep::reqid, XrdXrootdPrepArgs::reqid, Request, Response, Route, rpCheck(), rpEmsg(), XrdXrootdResponse::Send(), SFS_OK, sprintf(), Squash(), TRACEI, XrdXrootdPrepArgs::user, and vpEmsg().
Referenced by Process2().
| int XrdXrootdProtocol::do_Protocol | ( | ) | [private] |
Definition at line 1198 of file XrdXrootdXeq.cc.
References ServerResponseBody_Protocol::flags, isRedir, kXR_DataServer, kXR_LBalServer, Response, XrdXrootdResponse::Send(), UPSTATS, and XROOTD_VERSBIN.
Referenced by Process2().
| int XrdXrootdProtocol::do_Putfile | ( | ) | [private] |
Definition at line 1218 of file XrdXrootdXeq.cc.
References ClientPutfileRequest::buffsz, int, kXR_Unsupported, ClientPutfileRequest::options, ClientRequest::putfile, Request, Response, XrdXrootdResponse::Send(), and UPSTATS.
Referenced by Process2().
| int XrdXrootdProtocol::do_Qconf | ( | ) | [private] |
Definition at line 1238 of file XrdXrootdXeq.cc.
References argp, XrdBuffer::buff, DEBUG, XrdOucTokenizer::GetLine(), XrdOucTokenizer::GetToken(), kXR_ArgMissing, kXR_ArgTooLong, maxPio, maxRvecsz, maxStreams, maxTransz, n, Response, XrdXrootdResponse::Send(), sprintf(), strcpy(), TRACEP, val, WANPort, WANWindow, and Window.
Referenced by do_Query().
| int XrdXrootdProtocol::do_Qfh | ( | ) | [private] |
Definition at line 1305 of file XrdXrootdXeq.cc.
References ClientQueryRequest::fhandle, fp, fsError(), FTab, XrdXrootdFileTable::Get(), XrdXrootdReqID::getID(), XrdLink::ID, ClientQueryRequest::infotype, kXR_ArgMissing, kXR_FileNotOpen, kXR_Qvisa, Link, ClientRequest::query, ReqID, Request, Response, XrdXrootdResponse::Send(), SFS_FCTL_STATV, SFS_OK, short, TRACEP, and UPSTATS.
Referenced by Process2().
| int XrdXrootdProtocol::do_Qopaque | ( | short | ) | [private] |
Definition at line 1349 of file XrdXrootdXeq.cc.
References XrdSfsFSctl::Arg1, XrdSfsFSctl::Arg1Len, XrdSfsFSctl::Arg2, XrdSfsFSctl::Arg2Len, argp, XrdBuffer::buff, CRED, ClientQueryRequest::dlen, XrdSfsFileSystem::FSctl(), fsError(), XrdLink::ID, kXR_Qopaque, kXR_redirect, Link, 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] |
Definition at line 1396 of file XrdXrootdXeq.cc.
References argp, XrdBuffer::buff, CRED, XrdSfsFileSystem::fsctl(), fsError(), XrdLink::ID, kXR_redirect, Link, n, osFS, Port, RD_stat, Response, Route, rpCheck(), rpEmsg(), XrdXrootdResponse::Send(), SFS_FSCTL_STATLS, SFS_OK, Squash(), strcpy(), TRACEP, and vpEmsg().
Referenced by do_Query().
| int XrdXrootdProtocol::do_Query | ( | ) | [private] |
Definition at line 1432 of file XrdXrootdXeq.cc.
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(), short, SI, and XrdXrootdStats::Stats().
Referenced by Process2().
| int XrdXrootdProtocol::do_Qxattr | ( | ) | [private] |
Definition at line 1461 of file XrdXrootdXeq.cc.
References argp, XrdBuffer::buff, CRED, XrdSfsFileSystem::fsctl(), fsError(), XrdXrootdReqID::getID(), XrdLink::ID, kXR_redirect, Link, osFS, Port, RD_stat, ReqID, Response, Route, rpCheck(), rpEmsg(), XrdXrootdResponse::Send(), SFS_FSCTL_STATXA, Squash(), TRACEP, and vpEmsg().
Referenced by do_Query().
| int XrdXrootdProtocol::do_Read | ( | ) | [private] |
Definition at line 1490 of file XrdXrootdXeq.cc.
References XrdXrootdMonitor::Add_rd(), ClientRequestHdr::dlen, do_Offload(), do_ReadAll(), do_ReadNone(), ClientReadRequest::fhandle, XrdXrootdFile::FileID, FTab, XrdXrootdFileTable::Get(), XrdXrootdFHandle::handle, ClientRequest::header, kXR_FileNotOpen, monIO, Monitor, myFile, myIOLen, myOffset, numReads, ClientReadRequest::offset, ClientRequest::read, Request, Response, ClientReadRequest::rlen, XrdXrootdResponse::Send(), and TRACEP.
Referenced by Process2().
| int XrdXrootdProtocol::do_ReadV | ( | ) | [private] |
Definition at line 1645 of file XrdXrootdXeq.cc.
References argp, XrdBuffer::bsize, XrdBuffer::buff, ClientRequestHdr::dlen, XrdSfsFile::error, FTab, XrdXrootdFileTable::Get(), getBuff(), XrdOucErrInfo::getErrText(), XrdXrootdFHandle::handle, hcNext, hcNow, ClientRequest::header, kXR_ArgInvalid, kXR_ArgTooLong, kXR_FileNotOpen, kXR_FSError, kXR_NoMemory, kXR_oksofar, maxRvecsz, maxTransz, myFile, myIOLen, myOffset, numReads, XrdSfsFile::read(), XrdXrootdFile::readCnt, Request, Response, readahead_list::rlen, XrdXrootdResponse::Send(), XrdXrootdFHandle::Set(), TRACEP, and XrdXrootdFile::XrdSfsp.
Referenced by Process2().
| int XrdXrootdProtocol::do_ReadAll | ( | int | asyncOK = 1 |
) | [private] |
Definition at line 1541 of file XrdXrootdXeq.cc.
References aio_Read(), argp, as_maxperlnk, as_miniosz, as_minsfsz, XrdXrootdFile::AsyncMode, XrdXrootdStats::AsyncRej, XrdBuffer::bsize, XrdBuffer::buff, XrdSfsFile::error, XrdXrootdFile::fdNum, XrdXrootdFile::fSize, fSize, getBuff(), XrdOucErrInfo::getErrText(), hcNext, hcNow, XrdXrootdFile::isMMapped, kXR_FSError, kXR_oksofar, Link, maxBuffsz, XrdXrootdFile::mmAddr, myFile, myIOLen, myOffset, XrdSfsFile::read(), XrdXrootdFile::readCnt, Response, XrdXrootdResponse::Send(), XrdXrootdFile::sfEnabled, SI, XrdLink::UseCnt(), and XrdXrootdFile::XrdSfsp.
Referenced by do_OffloadIO(), and do_Read().
| int XrdXrootdProtocol::do_ReadNone | ( | int & | retc, | |
| int & | pathID | |||
| ) | [private] |
Definition at line 1598 of file XrdXrootdXeq.cc.
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_Rm | ( | ) | [private] |
Definition at line 1759 of file XrdXrootdXeq.cc.
References argp, XrdBuffer::buff, CRED, fsError(), XrdLink::ID, kXR_redirect, Link, osFS, Port, RD_rm, XrdSfsFileSystem::rem(), Response, Route, rpCheck(), rpEmsg(), XrdXrootdResponse::Send(), SFS_OK, Squash(), TRACEP, and vpEmsg().
Referenced by Process2().
| int XrdXrootdProtocol::do_Rmdir | ( | ) | [private] |
Definition at line 1790 of file XrdXrootdXeq.cc.
References argp, XrdBuffer::buff, CRED, fsError(), XrdLink::ID, kXR_redirect, Link, osFS, Port, RD_rmdir, XrdSfsFileSystem::remdir(), Response, Route, rpCheck(), rpEmsg(), XrdXrootdResponse::Send(), SFS_OK, Squash(), TRACEP, and vpEmsg().
Referenced by Process2().
| int XrdXrootdProtocol::do_Set | ( | ) | [private] |
Definition at line 1821 of file XrdXrootdXeq.cc.
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(), TRACEP, and val.
Referenced by Process2().
| int XrdXrootdProtocol::do_Set_Mon | ( | XrdOucTokenizer & | setargs | ) | [private] |
Definition at line 1855 of file XrdXrootdXeq.cc.
References XrdXrootdMonitor::Alloc(), XrdXrootdMonitor::appID(), XrdOucTokenizer::GetToken(), XrdLink::ID, kXR_ArgInvalid, kXR_ArgMissing, Link, XrdXrootdMonitor::Map(), XrdXrootdMonitor::monFILE, monFILE, XrdXrootdMonitor::monINFO, XrdXrootdMonitor::monIO, monIO, Monitor, monUID, XrdXrootdMonitor::monUSER, Response, XrdXrootdResponse::Send(), XrdXrootdMonitor::unAlloc(), val, XROOTD_MON_MAPINFO, and XROOTD_MON_MAPUSER.
Referenced by do_Set().
| int XrdXrootdProtocol::do_Stat | ( | ) | [private] |
Definition at line 1917 of file XrdXrootdXeq.cc.
References argp, XrdBuffer::buff, CRED, XrdSfsFileSystem::fsctl(), fsError(), XrdXrootdReqID::getID(), XrdLink::ID, kXR_redirect, kXR_vfs, Link, ClientStatRequest::options, osFS, Port, RD_stat, ReqID, Request, Response, Route, rpCheck(), rpEmsg(), XrdXrootdResponse::Send(), SFS_FSCTL_STATFS, SFS_OK, Squash(), stat, ClientRequest::stat, XrdSfsFileSystem::stat(), StatGen(), TRACEP, and vpEmsg().
Referenced by Process2().
| int XrdXrootdProtocol::do_Statx | ( | ) | [private] |
Definition at line 1955 of file XrdXrootdXeq.cc.
References argp, XrdBuffer::buff, CRED, fsError(), XrdXrootdReqID::getID(), XrdLink::ID, kXR_file, kXR_isDir, kXR_offline, Link, osFS, pathlist, ReqID, Response, rpCheck(), rpEmsg(), S_ISDIR, XrdXrootdResponse::Send(), SFS_OK, Squash(), XrdSfsFileSystem::stat(), TRACEP, and vpEmsg().
Referenced by Process2().
| int XrdXrootdProtocol::do_Sync | ( | ) | [private] |
Definition at line 1989 of file XrdXrootdXeq.cc.
References ClientSyncRequest::fhandle, fp, FTab, XrdXrootdFileTable::Get(), XrdXrootdFHandle::handle, kXR_FileNotOpen, kXR_FSError, Request, Response, XrdXrootdResponse::Send(), SFS_OK, ClientRequest::sync, TRACEP, and UPSTATS.
Referenced by Process2().
| int XrdXrootdProtocol::do_Truncate | ( | ) | [private] |
Definition at line 2020 of file XrdXrootdXeq.cc.
References argp, XrdBuffer::buff, CRED, ClientRequestHdr::dlen, ClientTruncateRequest::fhandle, fp, fsError(), FTab, XrdXrootdFileTable::Get(), XrdXrootdFHandle::handle, ClientRequest::header, XrdLink::ID, kXR_FileNotOpen, kXR_FSError, Link, ClientTruncateRequest::offset, osFS, Request, Response, rpCheck(), rpEmsg(), XrdXrootdResponse::Send(), SFS_OK, Squash(), TRACEP, ClientRequest::truncate, XrdSfsFileSystem::truncate(), UPSTATS, and vpEmsg().
Referenced by Process2().
| int XrdXrootdProtocol::do_Write | ( | ) | [private] |
Definition at line 2079 of file XrdXrootdXeq.cc.
References XrdXrootdMonitor::Add_wr(), aio_Write(), argp, as_maxperlnk, as_maxstalls, as_miniosz, as_syncw, XrdXrootdFile::AsyncMode, XrdXrootdStats::AsyncRej, ClientRequestHdr::dlen, ClientWriteRequest::dlen, do_Offload(), do_WriteAll(), do_WriteNone(), ClientWriteRequest::fhandle, XrdXrootdFile::FileID, FTab, XrdXrootdFileTable::Get(), XrdXrootdFHandle::handle, ClientRequest::header, kXR_FileNotOpen, Link, monIO, Monitor, myFile, myIOLen, myOffset, myStalls, numWrites, ClientWriteRequest::offset, ClientWriteRequest::pathid, Request, Response, XrdXrootdResponse::Send(), XrdLink::setEtext(), SI, TRACEP, XrdLink::UseCnt(), ClientRequest::write, and XrdXrootdFile::writeCnt.
Referenced by Process2().
| int XrdXrootdProtocol::do_WriteAll | ( | ) | [private] |
Definition at line 2140 of file XrdXrootdXeq.cc.
References argp, XrdBuffer::bsize, XrdBuffer::buff, do_WriteCont(), do_WriteNone(), getBuff(), getData(), hcNext, hcNow, maxBuffsz, myBlast, 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] |
Definition at line 2183 of file XrdXrootdXeq.cc.
References argp, XrdBuffer::buff, do_WriteAll(), do_WriteNone(), myBlast, myFile, myIOLen, myOffset, Response, XrdXrootdResponse::Send(), XrdSfsFile::write(), and XrdXrootdFile::XrdSfsp.
Referenced by do_OffloadIO(), and do_WriteAll().
| int XrdXrootdProtocol::do_WriteNone | ( | ) | [private] |
Definition at line 2204 of file XrdXrootdXeq.cc.
References argp, XrdBuffer::bsize, XrdBuffer::buff, XrdSfsFile::error, XrdOucErrInfo::getErrText(), kXR_FSError, Link, myBlen, myFile, myIOLen, readWait, XrdLink::Recv(), Response, Resume, XrdXrootdResponse::Send(), XrdLink::setEtext(), TRACEP, and XrdXrootdFile::XrdSfsp.
Referenced by do_Write(), do_WriteAll(), and do_WriteCont().
| int XrdXrootdProtocol::aio_Error | ( | const char * | op, | |
| int | ecode | |||
| ) | [private] |
Definition at line 37 of file XrdXrootdXeqAio.cc.
References buffer, XrdSysError::ec2text(), eDest, XrdSysError::Emsg(), XrdSfsFile::error, XrdSfsFile::FName(), XrdLink::ID, Link, myAioReq, myFile, XrdOucErrInfo::setErrInfo(), snprintf, sprintf(), and XrdXrootdFile::XrdSfsp.
Referenced by aio_WriteAll(), and aio_WriteCont().
| int XrdXrootdProtocol::aio_Read | ( | ) | [private] |
Definition at line 83 of file XrdXrootdXeqAio.cc.
References XrdXrootdAioReq::Alloc(), and XrdXrootdAioReq::Read().
Referenced by do_ReadAll().
| int XrdXrootdProtocol::aio_Write | ( | ) | [private] |
Definition at line 117 of file XrdXrootdXeqAio.cc.
References aio_WriteAll(), XrdXrootdAioReq::Alloc(), and myAioReq.
Referenced by do_Write().
| int XrdXrootdProtocol::aio_WriteAll | ( | ) | [private] |
Definition at line 160 of file XrdXrootdXeqAio.cc.
References aio_Error(), aiocb::aio_nbytes, aiocb::aio_offset, aio_WriteCont(), as_maxstalls, XrdBuffer::bsize, XrdBuffer::buff, XrdXrootdAio::buffp, EINPROGRESS, XrdXrootdAioReq::getAio(), getData(), myAioReq, myBlast, myBlen, myIOLen, myOffset, myStalls, XrdXrootdAioReq::Push(), XrdXrootdAioReq::Recycle(), Resume, XrdSfsAio::sfsAio, size_t, and XrdXrootdAioReq::Write().
Referenced by aio_Write(), and aio_WriteCont().
| int XrdXrootdProtocol::aio_WriteCont | ( | ) | [private] |
Definition at line 212 of file XrdXrootdXeqAio.cc.
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] |
| void XrdXrootdProtocol::Cleanup | ( | ) | [private] |
Definition at line 526 of file XrdXrootdProtocol.cc.
References argp, AuthProt, BPool, XrdLink::Close(), XrdSecProtocol::Delete(), FTab, i, isBound, isDead, Link, XrdSysMutex::Lock(), maxStreams, Monitor, XrdXrootdPio::Next, numReads, numWrites, pioFirst, pioFree, XrdXrootdStats::readCnt, XrdXrootdPio::Recycle(), Recycle(), XrdBuffManager::Release(), SI, XrdXrootdStats::statsMutex, Status, Stream, streamMutex, XrdXrootdMonitor::unAlloc(), XrdSysMutex::UnLock(), XrdXrootdStats::writeCnt, and XRD_BOUNDPATH.
Referenced by Recycle(), and ~XrdXrootdProtocol().
| int XrdXrootdProtocol::Config | ( | const char * | fn | ) | [static, private] |
Definition at line 320 of file XrdXrootdConfig.cc.
References eDest, XrdSysError::Emsg(), getenv(), open, XrdSysError::Say(), TS_Xeq, xasync(), xcksum(), xexp(), xfsl(), xlog(), xmon(), xpidf(), xprep(), xred(), xsecl(), and xtrace().
Referenced by Configure(), xasync(), xcksum(), xexp(), xfsl(), xlog(), xmon(), xpidf(), xprep(), xred(), xsecl(), and xtrace().
| int XrdXrootdProtocol::fsError | ( | int | rc, | |
| XrdOucErrInfo & | myError | |||
| ) | [private] |
Definition at line 2235 of file XrdXrootdXeq.cc.
References XrdOucEICB::Done(), eDest, eMsg, XrdSysError::Emsg(), XrdXrootdStats::errorCnt, XrdOucErrInfo::getErrCB(), XrdOucErrInfo::getErrText(), XrdXrootdResponse::ID(), kXR_redirect, kXR_ServerError, kXR_wait, kXR_waitresp, mapError(), Port, XrdXrootdStats::redirCnt, Response, XrdXrootdResponse::Send(), SFS_DATA, SFS_ERROR, SFS_REDIRECT, SFS_STALL, SFS_STARTED, SI, sprintf(), XrdXrootdStats::stallCnt, and TRACEI.
Referenced by do_Chmod(), do_Dirlist(), do_Locate(), do_Mkdir(), do_Mv(), do_Open(), do_Prepare(), do_Qfh(), do_Qopaque(), do_Qspace(), do_Qxattr(), do_Rm(), do_Rmdir(), do_Stat(), do_Statx(), and do_Truncate().
| int XrdXrootdProtocol::getBuff | ( | const int | isRead, | |
| int | Quantum | |||
| ) | [private] |
Definition at line 2300 of file XrdXrootdXeq.cc.
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] |
Definition at line 580 of file XrdXrootdProtocol.cc.
References Link, myBlen, myBuff, readWait, XrdLink::Recv(), XrdLink::setEtext(), and TRACEP.
Referenced by aio_WriteAll(), do_WriteAll(), and Process().
| int XrdXrootdProtocol::mapMode | ( | int | mode | ) | [static, private] |
Definition at line 2358 of file XrdXrootdXeq.cc.
Referenced by do_Chmod(), do_Mkdir(), and do_Open().
| void XrdXrootdProtocol::PidFile | ( | ) | [static, private] |
Definition at line 370 of file XrdXrootdConfig.cc.
References close, eDest, XrdSysError::Emsg(), free(), XrdOucUtils::genPath(), XrdOucUtils::InstName(), XrdOucUtils::makePath(), open, XrdOucUtils::pathMode, pidPath, snprintf, and write.
Referenced by Configure().
| int XrdXrootdProtocol::Process2 | ( | ) | [private] |
Definition at line 333 of file XrdXrootdProtocol.cc.
References argp, 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, ReqID, Request, ClientRequestHdr::requestid, Response, XrdXrootdResponse::Send(), XrdLink::setEtext(), XrdXrootdReqID::setID(), Status, ClientRequestHdr::streamid, UPSTATS, XRD_ADMINUSER, and XRD_NEED_AUTH.
Referenced by Process().
| void XrdXrootdProtocol::Reset | ( | ) | [private] |
Definition at line 604 of file XrdXrootdProtocol.cc.
References argp, AuthProt, CapVer, Client, cumReadP, cumReads, cumWrites, Entity, FTab, hcNext, hcNow, hcPrev, isActive, isBound, isDead, isNOP, Link, monFILE, monIO, Monitor, monUID, myAioReq, myBlast, myBlen, myBuff, myIOLen, myOffset, mySID, myStalls, numFiles, numReadP, numReads, numWrites, PathID, pioFirst, pioFree, pioLast, Request, Resume, reTry, Status, Stream, and totReadP.
Referenced by operator=(), Recycle(), and XrdXrootdProtocol().
| int XrdXrootdProtocol::rpCheck | ( | char * | fn, | |
| const char ** | opaque | |||
| ) | [static, private] |
Definition at line 2377 of file XrdXrootdXeq.cc.
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] |
Definition at line 2399 of file XrdXrootdXeq.cc.
References kXR_NotAuthorized, Response, XrdXrootdResponse::Send(), and snprintf.
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::vpEmsg | ( | const char * | op, | |
| char * | fn | |||
| ) | [private] |
Definition at line 2449 of file XrdXrootdXeq.cc.
References kXR_NotAuthorized, Response, XrdXrootdResponse::Send(), and snprintf.
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 * | ) | [static, private] |
Definition at line 2411 of file XrdXrootdXeq.cc.
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::xapath | ( | XrdOucStream & | Config | ) | [static, private] |
| int XrdXrootdProtocol::xasync | ( | XrdOucStream & | Config | ) | [static, private] |
Definition at line 425 of file XrdXrootdConfig.cc.
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, Config(), eDest, XrdSysError::Emsg(), i, int, XrdBuffManager::Recalc(), sprintf(), and val.
Referenced by Config().
| int XrdXrootdProtocol::xcksum | ( | XrdOucStream & | Config | ) | [static, private] |
Definition at line 528 of file XrdXrootdConfig.cc.
References XrdOuca2x::a2i(), Config(), eDest, XrdSysError::Emsg(), free(), JobCKS, JobCKT, Sched, and XrdOucProg::Setup().
Referenced by Config().
| int XrdXrootdProtocol::xexp | ( | XrdOucStream & | Config | ) | [static, private] |
Definition at line 579 of file XrdXrootdConfig.cc.
References Config(), eDest, XrdSysError::Emsg(), strlcpy(), val, xexpdo(), and XROOTDXP_NOLK.
Referenced by Config().
| int XrdXrootdProtocol::xexpdo | ( | char * | path, | |
| int | popt = 0 | |||
| ) | [static, private] |
Definition at line 605 of file XrdXrootdConfig.cc.
References eDest, XrdSysError::Emsg(), XrdXrootdXPath::Insert(), rpCheck(), Squash(), and XPList.
Referenced by Configure(), and xexp().
| int XrdXrootdProtocol::xfsl | ( | XrdOucStream & | Config | ) | [static, private] |
Definition at line 634 of file XrdXrootdConfig.cc.
References chkfsV, Config(), eDest, XrdSysError::Emsg(), free(), FSLib, rindex, XrdSysError::Say(), and val.
Referenced by Config().
| int XrdXrootdProtocol::xpidf | ( | XrdOucStream & | Config | ) | [static, private] |
Definition at line 834 of file XrdXrootdConfig.cc.
References Config(), eDest, XrdSysError::Emsg(), free(), pidPath, and val.
Referenced by Config().
| int XrdXrootdProtocol::xprep | ( | XrdOucStream & | Config | ) | [static, private] |
Definition at line 865 of file XrdXrootdConfig.cc.
References XrdOuca2x::a2tm(), Config(), eDest, XrdSysError::Emsg(), XrdOucUtils::genPath(), keep, XrdOucUtils::makePath(), myInst, XrdOucUtils::pathMode, XrdXrootdPrepare::setParms(), and val.
Referenced by Config().
| int XrdXrootdProtocol::xlog | ( | XrdOucStream & | Config | ) | [static, private] |
Definition at line 672 of file XrdXrootdConfig.cc.
References Config(), eDest, XrdSysError::Emsg(), i, XrdSysError::setMsgMask(), SYS_LOG_01, SYS_LOG_02, and val.
Referenced by Config().
| int XrdXrootdProtocol::xmon | ( | XrdOucStream & | Config | ) | [static, private] |
Definition at line 728 of file XrdXrootdConfig.cc.
References XrdOuca2x::a2sz(), XrdOuca2x::a2tm(), Config(), XrdXrootdMonitor::Defaults(), eDest, XrdSysError::Emsg(), free(), i, val, XROOTD_MON_ALL, XROOTD_MON_FILE, XROOTD_MON_INFO, XROOTD_MON_IO, XROOTD_MON_STAGE, and XROOTD_MON_USER.
Referenced by Config().
| int XrdXrootdProtocol::xred | ( | XrdOucStream & | Config | ) | [static, private] |
Definition at line 929 of file XrdXrootdConfig.cc.
References Config(), eDest, XrdSysError::Emsg(), i, XrdXrootdXPath::Insert(), k, Port, RD_chmod, RD_dirlist, RD_locate, RD_mkdir, RD_mv, RD_Num, RD_open1, RD_prepare, RD_prepstg, RD_rm, RD_rmdir, RD_stat, Route, RPList, strlcpy(), val, and xred_set().
Referenced by Config().
| void XrdXrootdProtocol::xred_set | ( | RD_func | func, | |
| const char * | rHost, | |||
| int | rPort | |||
| ) | [static, private] |
Definition at line 1001 of file XrdXrootdConfig.cc.
References free(), XrdXrootdProtocol::RD_Table::Host, XrdXrootdProtocol::RD_Table::Port, and Route.
Referenced by xred().
| int XrdXrootdProtocol::xsecl | ( | XrdOucStream & | Config | ) | [static, private] |
Definition at line 1023 of file XrdXrootdConfig.cc.
References Config(), eDest, XrdSysError::Emsg(), free(), SecLib, and val.
Referenced by Config().
| int XrdXrootdProtocol::xtrace | ( | XrdOucStream & | Config | ) | [static, private] |
Definition at line 1054 of file XrdXrootdConfig.cc.
References Config(), eDest, XrdSysError::Emsg(), i, TRACE_ALL, TRACE_DEBUG, TRACE_EMSG, TRACE_FS, TRACE_LOGIN, TRACE_MEM, TRACE_REDIR, TRACE_REQ, TRACE_RSP, TRACE_STALL, val, XrdOucTrace::What, and XrdXrootdTrace.
Referenced by Config().
friend class XrdXrootdAdmin [friend] |
Definition at line 72 of file XrdXrootdProtocol.hh.
friend class XrdXrootdAioReq [friend] |
Definition at line 73 of file XrdXrootdProtocol.hh.
XrdObjectQ< XrdXrootdProtocol > XrdXrootdProtocol::ProtStack [static, private] |
Definition at line 181 of file XrdXrootdProtocol.hh.
Referenced by Configure(), Match(), and Recycle().
XrdXrootdXPath XrdXrootdProtocol::RPList [static, protected] |
Definition at line 186 of file XrdXrootdProtocol.hh.
Referenced by Configure(), do_Open(), and xred().
XrdXrootdXPath XrdXrootdProtocol::XPList [static, protected] |
Definition at line 187 of file XrdXrootdProtocol.hh.
Referenced by Configure(), do_Locate(), Squash(), and xexpdo().
XrdSfsFileSystem * XrdXrootdProtocol::osFS [static, protected] |
Definition at line 188 of file XrdXrootdProtocol.hh.
Referenced by Configure(), do_Chmod(), do_Dirlist(), do_Locate(), do_Mkdir(), do_Mv(), do_Open(), do_Prepare(), do_Qopaque(), do_Qspace(), do_Qxattr(), do_Rm(), do_Rmdir(), do_Stat(), do_Statx(), and do_Truncate().
XrdSecService * XrdXrootdProtocol::CIA [static, protected] |
Definition at line 189 of file XrdXrootdProtocol.hh.
Referenced by Configure(), do_Auth(), and do_Login().
XrdXrootdFileLock * XrdXrootdProtocol::Locker [static, protected] |
XrdScheduler * XrdXrootdProtocol::Sched [static, protected] |
Definition at line 191 of file XrdXrootdProtocol.hh.
Referenced by Configure(), do_Offload(), XrdXrootdAioReq::Init(), and xcksum().
XrdBuffManager * XrdXrootdProtocol::BPool [static, protected] |
Definition at line 192 of file XrdXrootdProtocol.hh.
Referenced by Cleanup(), Configure(), getBuff(), XrdXrootdAioReq::Init(), Process(), and xasync().
XrdSysError XrdXrootdProtocol::eDest [static, protected] |
Definition at line 193 of file XrdXrootdProtocol.hh.
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().
const char * XrdXrootdProtocol::myInst [static, protected] |
const char * XrdXrootdProtocol::TraceID [static, protected] |
Definition at line 195 of file XrdXrootdProtocol.hh.
char * XrdXrootdProtocol::pidPath [static, protected] |
int XrdXrootdProtocol::myPID [static, protected] |
Definition at line 197 of file XrdXrootdProtocol.hh.
Referenced by do_Bind(), do_Endsess(), and do_Login().
XrdNetSocket * XrdXrootdProtocol::AdminSock [static, protected] |
int XrdXrootdProtocol::hailWait [static, protected] |
int XrdXrootdProtocol::readWait [static, protected] |
Definition at line 206 of file XrdXrootdProtocol.hh.
Referenced by Configure(), do_WriteNone(), and getData().
int XrdXrootdProtocol::Port [static, protected] |
Definition at line 207 of file XrdXrootdProtocol.hh.
Referenced by Configure(), do_Chmod(), do_Dirlist(), do_Locate(), do_Mkdir(), do_Mv(), do_Open(), do_Prepare(), do_Qopaque(), do_Qspace(), do_Qxattr(), do_Rm(), do_Rmdir(), do_Stat(), fsError(), and xred().
int XrdXrootdProtocol::Window [static, protected] |
int XrdXrootdProtocol::WANPort [static, protected] |
int XrdXrootdProtocol::WANWindow [static, protected] |
char * XrdXrootdProtocol::SecLib [static, protected] |
char * XrdXrootdProtocol::FSLib [static, protected] |
char * XrdXrootdProtocol::Notify [static, protected] |
char XrdXrootdProtocol::isRedir [static, protected] |
Definition at line 214 of file XrdXrootdProtocol.hh.
Referenced by Configure(), do_Protocol(), and Match().
char XrdXrootdProtocol::chkfsV [static, protected] |
XrdXrootdJob * XrdXrootdProtocol::JobCKS [static, protected] |
Definition at line 216 of file XrdXrootdProtocol.hh.
Referenced by Configure(), do_CKsum(), and xcksum().
char * XrdXrootdProtocol::JobCKT [static, protected] |
struct XrdXrootdProtocol::RD_Table XrdXrootdProtocol::Route[RD_Num] [static, protected] |
Referenced by Configure(), do_Chmod(), do_Dirlist(), do_Locate(), do_Mkdir(), do_Mv(), do_Open(), do_Prepare(), do_Qopaque(), do_Qspace(), do_Qxattr(), do_Rm(), do_Rmdir(), do_Stat(), xred(), and xred_set().
int XrdXrootdProtocol::as_maxperlnk [static, protected] |
Definition at line 225 of file XrdXrootdProtocol.hh.
Referenced by do_ReadAll(), do_Write(), and xasync().
int XrdXrootdProtocol::as_maxperreq [static, protected] |
int XrdXrootdProtocol::as_maxpersrv [static, protected] |
int XrdXrootdProtocol::as_miniosz [static, protected] |
Definition at line 228 of file XrdXrootdProtocol.hh.
Referenced by Configure(), do_ReadAll(), do_Write(), and xasync().
int XrdXrootdProtocol::as_minsfsz [static, protected] |
int XrdXrootdProtocol::as_segsize [static, protected] |
int XrdXrootdProtocol::as_maxstalls [static, protected] |
Definition at line 231 of file XrdXrootdProtocol.hh.
Referenced by aio_WriteAll(), do_Write(), and xasync().
int XrdXrootdProtocol::as_force [static, protected] |
int XrdXrootdProtocol::as_noaio [static, protected] |
Definition at line 233 of file XrdXrootdProtocol.hh.
Referenced by Configure(), do_Open(), and xasync().
int XrdXrootdProtocol::as_nosf [static, protected] |
int XrdXrootdProtocol::as_syncw [static, protected] |
int XrdXrootdProtocol::maxBuffsz [static, protected] |
Definition at line 236 of file XrdXrootdProtocol.hh.
Referenced by Configure(), do_ReadAll(), do_WriteAll(), and XrdXrootdAioReq::Init().
int XrdXrootdProtocol::maxTransz [static, protected] |
Definition at line 237 of file XrdXrootdProtocol.hh.
Referenced by Configure(), do_Qconf(), and do_ReadV().
const int XrdXrootdProtocol::maxRvecsz = 1024 [static, protected] |
XrdXrootdStats * XrdXrootdProtocol::SI [static, protected] |
Definition at line 242 of file XrdXrootdProtocol.hh.
Referenced by Cleanup(), Configure(), do_Query(), do_ReadAll(), do_Write(), fsError(), XrdXrootdAioReq::Init(), and Stats().
int XrdXrootdProtocol::numReads [protected] |
Definition at line 243 of file XrdXrootdProtocol.hh.
Referenced by Cleanup(), do_Auth(), XrdXrootdAdmin::do_Lsd(), do_Read(), do_ReadNone(), do_ReadV(), Reset(), and Stats().
int XrdXrootdProtocol::numReadP [protected] |
Definition at line 244 of file XrdXrootdProtocol.hh.
Referenced by XrdXrootdAdmin::do_Lsd(), Reset(), and Stats().
int XrdXrootdProtocol::numWrites [protected] |
Definition at line 245 of file XrdXrootdProtocol.hh.
Referenced by Cleanup(), XrdXrootdAdmin::do_Lsd(), do_Write(), Reset(), and Stats().
int XrdXrootdProtocol::numFiles [protected] |
Definition at line 246 of file XrdXrootdProtocol.hh.
Referenced by do_Close(), XrdXrootdAdmin::do_Lsd(), do_Open(), and Reset().
int XrdXrootdProtocol::cumReads [protected] |
Definition at line 248 of file XrdXrootdProtocol.hh.
Referenced by XrdXrootdAdmin::do_Lsd(), Reset(), and Stats().
int XrdXrootdProtocol::cumReadP [protected] |
Definition at line 249 of file XrdXrootdProtocol.hh.
Referenced by XrdXrootdAdmin::do_Lsd(), Reset(), and Stats().
int XrdXrootdProtocol::cumWrites [protected] |
Definition at line 250 of file XrdXrootdProtocol.hh.
Referenced by XrdXrootdAdmin::do_Lsd(), Reset(), and Stats().
long long XrdXrootdProtocol::totReadP [protected] |
Definition at line 251 of file XrdXrootdProtocol.hh.
Referenced by XrdXrootdAdmin::do_Lsd(), and Reset().
XrdLink* XrdXrootdProtocol::Link [protected] |
Definition at line 255 of file XrdXrootdProtocol.hh.
Referenced by aio_Error(), XrdXrootdAioReq::Alloc(), Cleanup(), do_Auth(), do_Bind(), do_Chmod(), do_Close(), do_Dirlist(), do_Endsess(), do_Locate(), do_Login(), do_Mkdir(), do_Mv(), do_Offload(), do_OffloadIO(), do_Open(), do_Prepare(), do_Qfh(), do_Qopaque(), do_Qspace(), do_Qxattr(), do_ReadAll(), do_Rm(), do_Rmdir(), do_Set(), do_Set_Mon(), do_Stat(), do_Statx(), do_Truncate(), do_Write(), do_WriteNone(), getData(), Match(), operator=(), Process(), Process2(), Recycle(), and Reset().
XrdBuffer* XrdXrootdProtocol::argp [protected] |
Definition at line 256 of file XrdXrootdProtocol.hh.
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().
XrdXrootdFileTable* XrdXrootdProtocol::FTab [protected] |
Definition at line 257 of file XrdXrootdProtocol.hh.
Referenced by Cleanup(), do_Close(), do_Open(), do_Qfh(), do_Read(), do_ReadNone(), do_ReadV(), do_Sync(), do_Truncate(), do_Write(), and Reset().
XrdXrootdMonitor* XrdXrootdProtocol::Monitor [protected] |
Definition at line 258 of file XrdXrootdProtocol.hh.
Referenced by Cleanup(), do_Close(), do_Login(), do_Open(), do_Read(), do_Set_Mon(), do_Write(), Recycle(), and Reset().
kXR_unt32 XrdXrootdProtocol::monUID [protected] |
Definition at line 259 of file XrdXrootdProtocol.hh.
Referenced by do_Login(), do_Set_Mon(), Recycle(), and Reset().
char XrdXrootdProtocol::monFILE [protected] |
Definition at line 260 of file XrdXrootdProtocol.hh.
Referenced by do_Close(), do_Login(), XrdXrootdAdmin::do_Lsd(), do_Open(), do_Set_Mon(), and Reset().
char XrdXrootdProtocol::monIO [protected] |
Definition at line 261 of file XrdXrootdProtocol.hh.
Referenced by do_Login(), XrdXrootdAdmin::do_Lsd(), do_Read(), do_Set_Mon(), do_Write(), and Reset().
char XrdXrootdProtocol::Status [protected] |
Definition at line 262 of file XrdXrootdProtocol.hh.
Referenced by Cleanup(), do_Auth(), do_Bind(), do_Login(), XrdXrootdAdmin::do_Lsd(), operator=(), Process2(), Recycle(), and Reset().
unsigned char XrdXrootdProtocol::CapVer [protected] |
Definition at line 263 of file XrdXrootdProtocol.hh.
Referenced by do_Bind(), do_CKsum(), do_Login(), XrdXrootdAdmin::do_Lsd(), and Reset().
XrdSecEntity* XrdXrootdProtocol::Client [protected] |
Definition at line 267 of file XrdXrootdProtocol.hh.
Referenced by do_Auth(), do_Login(), XrdXrootdAdmin::do_Lsd(), operator=(), and Reset().
XrdSecProtocol* XrdXrootdProtocol::AuthProt [protected] |
Definition at line 268 of file XrdXrootdProtocol.hh.
Referenced by Cleanup(), do_Auth(), operator=(), and Reset().
XrdSecEntity XrdXrootdProtocol::Entity [protected] |
Definition at line 269 of file XrdXrootdProtocol.hh.
Referenced by do_Auth(), do_Login(), XrdXrootdAdmin::do_Lsd(), Match(), and Reset().
XrdXrootdAioReq* XrdXrootdProtocol::myAioReq [protected] |
Definition at line 273 of file XrdXrootdProtocol.hh.
Referenced by aio_Error(), aio_Write(), aio_WriteAll(), aio_WriteCont(), Process(), and Reset().
char* XrdXrootdProtocol::myBuff [protected] |
Definition at line 274 of file XrdXrootdProtocol.hh.
int XrdXrootdProtocol::myBlen [protected] |
Definition at line 275 of file XrdXrootdProtocol.hh.
Referenced by aio_WriteAll(), do_Offload(), do_WriteNone(), getData(), Process(), and Reset().
int XrdXrootdProtocol::myBlast [protected] |
Definition at line 276 of file XrdXrootdProtocol.hh.
Referenced by aio_WriteAll(), aio_WriteCont(), do_WriteAll(), do_WriteCont(), and Reset().
int(XrdXrootdProtocol::* XrdXrootdProtocol::Resume)() [protected] |
Referenced by aio_WriteAll(), do_Offload(), do_OffloadIO(), do_WriteAll(), do_WriteNone(), DoIt(), Process(), and Reset().
XrdXrootdFile* XrdXrootdProtocol::myFile [protected] |
Definition at line 278 of file XrdXrootdProtocol.hh.
Referenced by aio_Error(), XrdXrootdAioReq::Alloc(), do_Offload(), do_OffloadIO(), do_Read(), do_ReadAll(), do_ReadNone(), do_ReadV(), do_Write(), do_WriteAll(), do_WriteCont(), do_WriteNone(), and operator=().
long long XrdXrootdProtocol::myOffset [protected] |
Definition at line 279 of file XrdXrootdProtocol.hh.
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::myIOLen [protected] |
Definition at line 280 of file XrdXrootdProtocol.hh.
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().
int XrdXrootdProtocol::myStalls [protected] |
Definition at line 281 of file XrdXrootdProtocol.hh.
Referenced by aio_WriteAll(), do_Write(), do_WriteAll(), and Reset().
int XrdXrootdProtocol::hcMax [static, protected] |
int XrdXrootdProtocol::hcPrev [protected] |
Definition at line 286 of file XrdXrootdProtocol.hh.
int XrdXrootdProtocol::hcNext [protected] |
Definition at line 287 of file XrdXrootdProtocol.hh.
Referenced by do_ReadAll(), do_ReadV(), do_WriteAll(), getBuff(), and Reset().
int XrdXrootdProtocol::hcNow [protected] |
Definition at line 288 of file XrdXrootdProtocol.hh.
Referenced by do_ReadAll(), do_ReadV(), do_WriteAll(), getBuff(), Process(), and Reset().
int XrdXrootdProtocol::halfBSize [protected] |
const int XrdXrootdProtocol::maxStreams = 16 [static, protected] |
Definition at line 293 of file XrdXrootdProtocol.hh.
Referenced by Cleanup(), do_Bind(), do_Offload(), and do_Qconf().
XrdSysMutex XrdXrootdProtocol::streamMutex [protected] |
Definition at line 294 of file XrdXrootdProtocol.hh.
Referenced by Cleanup(), do_Offload(), do_OffloadIO(), and Recycle().
XrdSysSemaphore* XrdXrootdProtocol::reTry [protected] |
Definition at line 295 of file XrdXrootdProtocol.hh.
Referenced by do_Offload(), do_OffloadIO(), and Reset().
XrdXrootdProtocol* XrdXrootdProtocol::Stream[maxStreams] [protected] |
Definition at line 296 of file XrdXrootdProtocol.hh.
Referenced by Cleanup(), do_Bind(), do_Offload(), do_OffloadIO(), Recycle(), and Reset().
unsigned int XrdXrootdProtocol::mySID [protected] |
char XrdXrootdProtocol::isActive [protected] |
Definition at line 298 of file XrdXrootdProtocol.hh.
Referenced by do_Offload(), do_OffloadIO(), Recycle(), and Reset().
char XrdXrootdProtocol::isDead [protected] |
Definition at line 299 of file XrdXrootdProtocol.hh.
Referenced by Cleanup(), do_Offload(), Recycle(), and Reset().
char XrdXrootdProtocol::isBound [protected] |
Definition at line 300 of file XrdXrootdProtocol.hh.
char XrdXrootdProtocol::isNOP [protected] |
Definition at line 301 of file XrdXrootdProtocol.hh.
Referenced by do_Offload(), do_OffloadIO(), and Reset().
const int XrdXrootdProtocol::maxPio = 4 [static, protected] |
XrdXrootdPio* XrdXrootdProtocol::pioFirst [protected] |
Definition at line 304 of file XrdXrootdProtocol.hh.
Referenced by Cleanup(), do_Offload(), do_OffloadIO(), and Reset().
XrdXrootdPio* XrdXrootdProtocol::pioLast [protected] |
Definition at line 305 of file XrdXrootdProtocol.hh.
Referenced by do_Offload(), do_OffloadIO(), and Reset().
XrdXrootdPio* XrdXrootdProtocol::pioFree [protected] |
Definition at line 306 of file XrdXrootdProtocol.hh.
Referenced by Cleanup(), do_Bind(), do_Offload(), do_OffloadIO(), and Reset().
short XrdXrootdProtocol::PathID [protected] |
char XrdXrootdProtocol::doWrite [protected] |
Definition at line 309 of file XrdXrootdProtocol.hh.
Referenced by do_Offload(), and do_OffloadIO().
char XrdXrootdProtocol::doWriteC [protected] |
Definition at line 310 of file XrdXrootdProtocol.hh.
Referenced by do_Offload(), and do_OffloadIO().
XrdXrootdReqID XrdXrootdProtocol::ReqID [protected] |
Definition at line 314 of file XrdXrootdProtocol.hh.
Referenced by do_Locate(), do_Login(), do_Open(), do_Qfh(), do_Qxattr(), do_Stat(), do_Statx(), and Process2().
ClientRequest XrdXrootdProtocol::Request [protected] |
Definition at line 315 of file XrdXrootdProtocol.hh.
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_Putfile(), do_Qfh(), do_Qopaque(), do_Query(), do_Read(), do_ReadNone(), do_ReadV(), do_Stat(), do_Sync(), do_Truncate(), do_Write(), operator=(), Process(), Process2(), and Reset().
XrdXrootdResponse XrdXrootdProtocol::Response [protected] |
Definition at line 316 of file XrdXrootdProtocol.hh.
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().
1.5.1