xrootd
|
#include <XrdXrootdProtocol.hh>
Classes | |
struct | RD_Table |
Public Member Functions | |
void | DoIt () |
XrdProtocol * | Match (XrdLink *lp) |
int | Process (XrdLink *lp) |
void | Recycle (XrdLink *lp, int consec, const char *reason) |
int | Stats (char *buff, int blen, int do_sync=0) |
XrdXrootdProtocol | operator= (const XrdXrootdProtocol &rhs) |
XrdXrootdProtocol () | |
~XrdXrootdProtocol () | |
Static Public Member Functions | |
static int | Configure (char *parms, XrdProtocol_Config *pi) |
static int | StatGen (struct stat &buf, char *xxBuff) |
Protected Attributes | |
int | numReads |
int | numReadP |
int | numWrites |
int | numFiles |
int | cumReads |
int | cumReadP |
int | cumWrites |
long long | totReadP |
XrdLink * | Link |
XrdBuffer * | argp |
XrdXrootdFileTable * | FTab |
XrdXrootdMonitor * | Monitor |
kXR_unt32 | monUID |
char | monFILE |
char | monIO |
char | Status |
unsigned char | CapVer |
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 = 0 |
static XrdXrootdFileLock * | Locker |
static XrdScheduler * | Sched |
static XrdBuffManager * | BPool |
static XrdSysError | eDest |
static const char * | myInst = 0 |
static const char * | TraceID = "Protocol" |
static char * | pidPath = strdup("/tmp") |
static int | myPID = static_cast<int>(getpid()) |
static 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 XrdXrootdJob * | JobCKS = 0 |
static char * | JobCKT = 0 |
static struct XrdXrootdProtocol::RD_Table | Route [RD_Num] |
static int | as_maxperlnk = 8 |
static int | as_maxperreq = 8 |
static int | as_maxpersrv = 4096 |
static int | as_miniosz = 32768 |
static int | as_minsfsz = 8192 |
static int | as_segsize = 131072 |
static int | as_maxstalls = 5 |
static int | as_force = 0 |
static int | as_noaio = 0 |
static int | as_nosf = 0 |
static int | as_syncw = 0 |
static int | maxBuffsz |
static int | maxTransz = 262144 |
static const int | maxRvecsz = 1024 |
static XrdXrootdStats * | SI |
static int | hcMax = 28657 |
static const int | maxStreams = 16 |
static const int | maxPio = 4 |
Private Types | |
enum | RD_func { RD_chmod = 0, RD_dirlist, RD_locate, RD_mkdir, RD_mv, RD_prepare, RD_prepstg, RD_rm, RD_rmdir, RD_stat, RD_open1, RD_open2, RD_open3, RD_open4, RD_Num } |
Private Member Functions | |
int | do_Admin () |
int | do_Auth () |
int | do_Bind () |
int | do_Chmod () |
int | do_CKsum (int canit) |
int | do_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 |
enum XrdXrootdProtocol::RD_func [private] |
XrdXrootdProtocol::~XrdXrootdProtocol | ( | ) | [inline] |
References Cleanup().
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(), snprintf, 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, EINPROGRESS, 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] |
void XrdXrootdProtocol::Cleanup | ( | ) | [private] |
References argp, AuthProt, BPool, XrdLink::Close(), XrdSecProtocol::Delete(), FTab, 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] |
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, CIA, Config(), XrdProtocol_Config::ConfigFN, XrdProtocol_Config::ConnMax, XrdNetSocket::Create(), DEBUG, XrdProtocol_Config::DebugON, XrdProtocol_Config::eDest, eDest, XrdSysError::Emsg(), XrdOucEnv::Export(), FSLib, XrdOucUtils::genPath(), XrdSfsFileSystem::getVersion(), XrdProtocol_Config::hailWait, hailWait, XrdXrootdAdmin::Init(), XrdXrootdMonitor::Init(), XrdXrootdFile::Init(), XrdXrootdAioReq::Init(), XrdXrootdXPath::Insert(), XrdNetDNS::IPAddr(), isRedir, JobCKS, Locker, XrdSysError::logger(), XrdMpx::Logger, maxBuffsz, XrdBuffManager::MaxSize(), maxTransz, XrdProtocol_Config::myAddr, XrdProtocol_Config::myInst, myInst, XrdProtocol_Config::myName, XrdProtocol_Config::NetTCP, XrdXrootdXPath::Next(), Notify, optind, XrdXrootdXPath::Opts(), osFS, XrdXrootdXPath::Path(), PidFile(), XrdProtocol_Config::Port, Port, ProtStack, XrdProtocol_Config::readWait, readWait, Route, RPList, 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, XrdSecProtocol::Authenticate(), AuthProt, XrdBuffer::buff, XrdSecBuffer::buffer, CIA, Client, ClientAuthRequest::credtype, XrdSecProtocol::Delete(), ClientRequestHdr::dlen, eDest, XrdSysError::Emsg(), eMsg, XrdSecProtocol::Entity, Entity, XrdOucErrInfo::getErrText(), XrdSecService::getProtocol(), ClientRequest::header, XrdLink::Host(), XrdLink::ID, kXR_authmore, kXR_NotAuthorized, kXR_ServerError, Link, XrdSysError::Log(), XrdSecEntity::name, XrdLink::Name(), numReads, XrdSecEntity::prot, Request, Response, XrdXrootdResponse::Send(), 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, CapVer, eDest, EINPROGRESS, 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, myPID, PathID, XrdXrootdSessID::Pid, pioFree, Request, Response, rindex, XrdXrootdResponse::Send(), ClientBindRequest::sessid, XrdLink::setID(), XrdXrootdSessID::Sid, Status, Stream, SYS_LOG_01, UPSTATS, 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, 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] |
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] |
References XrdSfsFile::close(), XrdXrootdMonitor::Close(), ClientRequest::close, XrdXrootdFileTable::Del(), XrdSfsFile::error, ClientCloseRequest::fhandle, XrdXrootdFile::FileID, FTab, XrdXrootdFileTable::Get(), XrdOucErrInfo::getErrText(), XrdXrootdFHandle::handle, kXR_FileNotOpen, kXR_FSError, Link, monFILE, Monitor, numFiles, XrdXrootdFile::readCnt, Request, Response, XrdXrootdResponse::Send(), XrdLink::Serialize(), SFS_OK, TRACEP, UPSTATS, XrdXrootdFile::writeCnt, and XrdXrootdFile::XrdSfsp.
Referenced by Process2().
int XrdXrootdProtocol::do_Dirlist | ( | ) | [private] |
References argp, XrdBuffer::buff, XrdSfsDirectory::close(), 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(), TRACEP, and vpEmsg().
Referenced by Process2().
int XrdXrootdProtocol::do_Endsess | ( | ) | [private] |
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, XrdLink::Terminate(), TRACEP, and UPSTATS.
Referenced by Process2().
int XrdXrootdProtocol::do_Getfile | ( | ) | [private] |
References ClientGetfileRequest::buffsz, ClientRequest::getfile, kXR_Unsupported, ClientGetfileRequest::options, Request, Response, XrdXrootdResponse::Send(), and UPSTATS.
Referenced by Process2().
int XrdXrootdProtocol::do_Locate | ( | ) | [private] |
References argp, XrdBuffer::buff, CRED, XrdSfsFileSystem::fsctl(), fsError(), XrdXrootdReqID::getID(), XrdLink::ID, kXR_nowait, kXR_redirect, kXR_refresh, Link, ClientRequest::locate, 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(), and XPList.
Referenced by Process2().
int XrdXrootdProtocol::do_Login | ( | ) | [private] |
References XrdXrootdMonitor::Alloc(), ClientLoginRequest::capver, CapVer, CIA, Client, eDest, Entity, XrdXrootdSessID::FD, XrdLink::FDnum(), XrdSecService::getParms(), ClientRequest::header, XrdLink::Host(), XrdLink::ID, XrdLink::Inst(), XrdXrootdSessID::Inst, iovec::iov_base, iovec::iov_len, kXR_InvalidRequest, kXR_useradmin, kXR_vermask, Link, XrdSysMutex::Lock(), XrdSysError::Log(), ClientRequest::login, XrdXrootdMonitor::Map(), monFILE, monIO, Monitor, monUID, XrdXrootdMonitor::monUSER, myPID, mySID, XrdXrootdSessID::Pid, ClientLoginRequest::pid, ReqID, Request, Response, ClientLoginRequest::role, XrdXrootdResponse::Send(), XrdXrootdReqID::setID(), XrdLink::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_Mkdir | ( | ) | [private] |
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] |
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] |
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, EINPROGRESS, 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(), argp, as_force, as_noaio, XrdBuffer::buff, ServerResponseBody_Open::cpsize, ServerResponseBody_Open::cptype, CRED, eDest, XrdSysError::Emsg(), XrdSfsFile::error, ServerResponseBody_Open::fhandle, XrdXrootdFile::FileID, fsError(), FTab, XrdSfsFile::getCXinfo(), XrdXrootdReqID::getID(), XrdLink::ID, 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(), XrdSfsFile::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(), 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, snprintf, Squash(), stat(), StatGen(), TRACEP, UPSTATS, XrdXrootdXPath::Validate(), vpEmsg(), XrdXrootdFile::XrdSfsp, XROOTD_MON_MAPPATH, and XROOTDXP_NOLK.
Referenced by Process2().
int XrdXrootdProtocol::do_Ping | ( | ) | [private] |
References Response, XrdXrootdResponse::Send(), and UPSTATS.
Referenced by Process2().
int XrdXrootdProtocol::do_Prepare | ( | ) | [private] |
References argp, XrdBuffer::buff, CRED, XrdLink::FDnum(), fsError(), XrdOucTokenizer::GetLine(), XrdXrootdResponse::ID(), XrdOucReqID::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(), Notify, XrdSfsPrep::notify, XrdSfsPrep::oinfo, ClientPrepareRequest::options, XrdSfsPrep::opts, 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(), TRACEI, XrdXrootdPrepArgs::user, and vpEmsg().
Referenced by Process2().
int XrdXrootdProtocol::do_Protocol | ( | ) | [private] |
References ServerResponseBody_Protocol::flags, isRedir, kXR_DataServer, kXR_LBalServer, Response, XrdXrootdResponse::Send(), UPSTATS, and XROOTD_VERSBIN.
Referenced by Process2().
int XrdXrootdProtocol::do_Putfile | ( | ) | [private] |
References ClientPutfileRequest::buffsz, kXR_Unsupported, ClientPutfileRequest::options, ClientRequest::putfile, Request, Response, XrdXrootdResponse::Send(), and UPSTATS.
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 XrdSfsFile::fctl(), ClientQueryRequest::fhandle, 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, TRACEP, UPSTATS, and XrdXrootdFile::XrdSfsp.
Referenced by Process2().
int XrdXrootdProtocol::do_Qopaque | ( | short | qopt | ) | [private] |
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] |
References argp, XrdBuffer::buff, CRED, XrdSfsFileSystem::fsctl(), fsError(), XrdLink::ID, kXR_redirect, Link, osFS, Port, RD_stat, Response, Route, rpCheck(), rpEmsg(), XrdXrootdResponse::Send(), SFS_FSCTL_STATLS, SFS_OK, Squash(), TRACEP, and vpEmsg().
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, 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] |
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_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, XrdXrootdFile::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] |
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 argp, XrdBuffer::bsize, XrdBuffer::buff, ClientRequestHdr::dlen, XrdSfsFile::error, readahead_list::fhandle, FTab, XrdXrootdFileTable::Get(), getBuff(), XrdOucErrInfo::getErrText(), XrdXrootdFHandle::handle, hcNext, hcNow, ClientRequest::header, kXR_ArgInvalid, kXR_ArgTooLong, kXR_FileNotOpen, kXR_FSError, kXR_NoMemory, kXR_oksofar, maxTransz, myFile, myIOLen, myOffset, numReads, readahead_list::offset, XrdSfsFile::read(), XrdXrootdFile::readCnt, Request, Response, readahead_list::rlen, XrdXrootdResponse::Send(), XrdXrootdFHandle::Set(), TRACEP, and XrdXrootdFile::XrdSfsp.
Referenced by Process2().
int XrdXrootdProtocol::do_Rm | ( | ) | [private] |
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] |
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] |
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::Alloc(), XrdXrootdMonitor::appID(), XrdOucTokenizer::GetToken(), XrdLink::ID, kXR_ArgInvalid, kXR_ArgMissing, Link, XrdXrootdMonitor::Map(), monFILE, XrdXrootdMonitor::monINFO, monIO, XrdXrootdMonitor::monIO, Monitor, monUID, XrdXrootdMonitor::monUSER, Response, XrdXrootdResponse::Send(), XrdXrootdMonitor::unAlloc(), XROOTD_MON_MAPINFO, and XROOTD_MON_MAPUSER.
Referenced by do_Set().
int XrdXrootdProtocol::do_Stat | ( | ) | [private] |
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(), XrdSfsFileSystem::stat(), ClientRequest::stat, stat(), StatGen(), TRACEP, and vpEmsg().
Referenced by Process2().
int XrdXrootdProtocol::do_Statx | ( | ) | [private] |
References argp, XrdBuffer::buff, CRED, fsError(), XrdXrootdReqID::getID(), XrdLink::ID, kXR_file, kXR_isDir, kXR_offline, Link, osFS, ReqID, Response, rpCheck(), rpEmsg(), S_ISDIR, XrdXrootdResponse::Send(), SFS_OK, Squash(), XrdSfsFileSystem::stat(), TRACEP, and vpEmsg().
Referenced by Process2().
int XrdXrootdProtocol::do_Sync | ( | ) | [private] |
References XrdSfsFile::error, ClientSyncRequest::fhandle, FTab, XrdXrootdFileTable::Get(), XrdOucErrInfo::getErrText(), XrdXrootdFHandle::handle, kXR_FileNotOpen, kXR_FSError, Request, Response, XrdXrootdResponse::Send(), SFS_OK, XrdSfsFile::sync(), ClientRequest::sync, TRACEP, UPSTATS, and XrdXrootdFile::XrdSfsp.
Referenced by Process2().
int XrdXrootdProtocol::do_Truncate | ( | ) | [private] |
References argp, XrdBuffer::buff, CRED, ClientRequestHdr::dlen, XrdSfsFile::error, ClientTruncateRequest::fhandle, fsError(), FTab, XrdXrootdFileTable::Get(), XrdOucErrInfo::getErrText(), XrdXrootdFHandle::handle, ClientRequest::header, XrdLink::ID, kXR_FileNotOpen, kXR_FSError, Link, ClientTruncateRequest::offset, osFS, Request, Response, rpCheck(), rpEmsg(), XrdXrootdResponse::Send(), SFS_OK, Squash(), TRACEP, XrdSfsFileSystem::truncate(), XrdSfsFile::truncate(), ClientRequest::truncate, UPSTATS, vpEmsg(), and XrdXrootdFile::XrdSfsp.
Referenced by Process2().
int XrdXrootdProtocol::do_Write | ( | ) | [private] |
References XrdXrootdMonitor::Add_wr(), 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(), 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] |
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] |
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] |
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::fsError | ( | int | rc, |
XrdOucErrInfo & | myError | ||
) | [private] |
References XrdOucEICB::Done(), eDest, XrdSysError::Emsg(), eMsg, XrdXrootdStats::errorCnt, XrdOucErrInfo::getErrCB(), XrdOucErrInfo::getErrText(), XrdXrootdResponse::ID(), kXR_redirect, kXR_ServerError, kXR_wait, kXR_waitresp, XProtocol::mapError(), Port, XrdXrootdStats::redirCnt, Response, XrdXrootdResponse::Send(), SFS_DATA, SFS_ERROR, SFS_REDIRECT, SFS_STALL, SFS_STARTED, SI, 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] |
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 | ) | [static, private] |
References Map_Mode.
Referenced by do_Chmod(), do_Mkdir(), and do_Open().
XrdProtocol * XrdXrootdProtocol::Match | ( | XrdLink * | lp | ) | [virtual] |
Implements XrdProtocol.
References Entity, ClientInitHandShake::fifth, ClientInitHandShake::first, ClientInitHandShake::fourth, hailWait, XrdLink::Host(), XrdSecEntity::host, isRedir, kXR_DataServer, kXR_LBalServer, Link, XrdLink::Peek(), XrdObjectQ< T >::Pop(), XrdSecEntity::prot, ProtStack, XrdLink::Recv(), Response, ROOTD_PQ, ClientInitHandShake::second, XrdLink::Send(), XrdXrootdResponse::Set(), XrdLink::setEtext(), ClientInitHandShake::third, UPSTATS, XrdXrootdProtocol(), and XROOTD_VERSBIN.
XrdXrootdProtocol XrdXrootdProtocol::operator= | ( | const XrdXrootdProtocol & | rhs | ) |
void XrdXrootdProtocol::PidFile | ( | void | ) | [static, private] |
References close, eDest, XrdSysError::Emsg(), XrdOucUtils::genPath(), XrdOucUtils::InstName(), XrdOucUtils::makePath(), open(), XrdOucUtils::pathMode, pidPath, snprintf, and write().
Referenced by Configure().
int XrdXrootdProtocol::Process | ( | XrdLink * | lp | ) | [virtual] |
Implements XrdProtocol.
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.
int XrdXrootdProtocol::Process2 | ( | ) | [private] |
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::Recycle | ( | XrdLink * | lp, |
int | consec, | ||
const char * | reason | ||
) | [virtual] |
Implements XrdProtocol.
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().
void XrdXrootdProtocol::Reset | ( | ) | [private] |
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] |
References index().
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, 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 * | fn | ) | [static, private] |
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] |
int XrdXrootdProtocol::Stats | ( | char * | buff, |
int | blen, | ||
int | do_sync = 0 |
||
) | [virtual] |
int XrdXrootdProtocol::vpEmsg | ( | const char * | op, |
char * | fn | ||
) | [private] |
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().
static int XrdXrootdProtocol::xapath | ( | XrdOucStream & | Config | ) | [static, private] |
int XrdXrootdProtocol::xasync | ( | XrdOucStream & | Config | ) | [static, private] |
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 | ) | [static, private] |
References XrdOuca2x::a2i(), eDest, XrdSysError::Emsg(), XrdOucStream::GetRest(), XrdOucStream::GetWord(), JobCKS, JobCKT, Sched, and XrdOucProg::Setup().
Referenced by Config().
int XrdXrootdProtocol::xexp | ( | XrdOucStream & | Config | ) | [static, private] |
References eDest, XrdSysError::Emsg(), XrdOucStream::GetWord(), XrdOucStream::RetToken(), strlcpy(), xexpdo(), and XROOTDXP_NOLK.
Referenced by Config().
int XrdXrootdProtocol::xexpdo | ( | char * | path, |
int | popt = 0 |
||
) | [static, private] |
References eDest, XrdSysError::Emsg(), XrdXrootdXPath::Insert(), rpCheck(), Squash(), and XPList.
Referenced by Configure(), and xexp().
int XrdXrootdProtocol::xfsl | ( | XrdOucStream & | Config | ) | [static, private] |
References chkfsV, eDest, XrdSysError::Emsg(), FSLib, XrdOucStream::GetWord(), rindex, and XrdSysError::Say().
Referenced by Config().
int XrdXrootdProtocol::xlog | ( | XrdOucStream & | Config | ) | [static, private] |
References eDest, XrdSysError::Emsg(), XrdOucStream::GetWord(), XrdSysError::setMsgMask(), SYS_LOG_01, and SYS_LOG_02.
Referenced by Config().
int XrdXrootdProtocol::xmon | ( | XrdOucStream & | Config | ) | [static, private] |
References XrdOuca2x::a2sz(), XrdOuca2x::a2tm(), XrdXrootdMonitor::Defaults(), eDest, XrdSysError::Emsg(), XrdOucStream::GetWord(), index(), XROOTD_MON_ALL, XROOTD_MON_FILE, XROOTD_MON_INFO, XROOTD_MON_IO, XROOTD_MON_STAGE, and XROOTD_MON_USER.
Referenced by Config().
int XrdXrootdProtocol::xpidf | ( | XrdOucStream & | Config | ) | [static, private] |
References eDest, XrdSysError::Emsg(), XrdOucStream::GetWord(), and pidPath.
Referenced by Config().
int XrdXrootdProtocol::xprep | ( | XrdOucStream & | Config | ) | [static, private] |
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 | ) | [static, private] |
References eDest, XrdSysError::Emsg(), XrdOucStream::GetWord(), index(), XrdXrootdXPath::Insert(), 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(), and xred_set().
Referenced by Config().
void XrdXrootdProtocol::xred_set | ( | RD_func | func, |
const char * | rHost, | ||
int | rPort | ||
) | [static, private] |
References XrdXrootdProtocol::RD_Table::Host, XrdXrootdProtocol::RD_Table::Port, and Route.
Referenced by xred().
int XrdXrootdProtocol::xsecl | ( | XrdOucStream & | Config | ) | [static, private] |
References eDest, XrdSysError::Emsg(), XrdOucStream::GetWord(), and SecLib.
Referenced by Config().
int XrdXrootdProtocol::xtrace | ( | XrdOucStream & | Config | ) | [static, private] |
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().
friend class XrdXrootdAdmin [friend] |
friend class XrdXrootdAioReq [friend] |
XrdNetSocket * XrdXrootdProtocol::AdminSock = 0 [static, protected] |
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 [static, protected] |
int XrdXrootdProtocol::as_maxperlnk = 8 [static, protected] |
Referenced by do_ReadAll(), do_Write(), and xasync().
int XrdXrootdProtocol::as_maxperreq = 8 [static, protected] |
Referenced by Configure(), and xasync().
int XrdXrootdProtocol::as_maxpersrv = 4096 [static, protected] |
Referenced by Configure(), and xasync().
int XrdXrootdProtocol::as_maxstalls = 5 [static, protected] |
Referenced by aio_WriteAll(), do_Write(), and xasync().
int XrdXrootdProtocol::as_miniosz = 32768 [static, protected] |
Referenced by Configure(), do_ReadAll(), do_Write(), and xasync().
int XrdXrootdProtocol::as_minsfsz = 8192 [static, protected] |
Referenced by do_ReadAll(), and xasync().
int XrdXrootdProtocol::as_noaio = 0 [static, protected] |
Referenced by Configure(), do_Open(), and xasync().
int XrdXrootdProtocol::as_nosf = 0 [static, protected] |
Referenced by Configure(), and xasync().
int XrdXrootdProtocol::as_segsize = 131072 [static, protected] |
Referenced by Configure(), and xasync().
int XrdXrootdProtocol::as_syncw = 0 [static, protected] |
Referenced by do_Write(), and xasync().
XrdSecProtocol* XrdXrootdProtocol::AuthProt [protected] |
Referenced by Cleanup(), do_Auth(), operator=(), and Reset().
XrdBuffManager * XrdXrootdProtocol::BPool [static, protected] |
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 [static, protected] |
Referenced by Configure(), and xfsl().
XrdSecService * XrdXrootdProtocol::CIA = 0 [static, protected] |
Referenced by Configure(), do_Auth(), and do_Login().
XrdSecEntity* XrdXrootdProtocol::Client [protected] |
Referenced by do_Auth(), do_Login(), XrdXrootdAdmin::do_Lsd(), operator=(), and Reset().
int XrdXrootdProtocol::cumReadP [protected] |
Referenced by XrdXrootdAdmin::do_Lsd(), Reset(), and Stats().
int XrdXrootdProtocol::cumReads [protected] |
Referenced by XrdXrootdAdmin::do_Lsd(), 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 [static, protected] |
XrdSecEntity XrdXrootdProtocol::Entity [protected] |
Referenced by do_Auth(), do_Login(), XrdXrootdAdmin::do_Lsd(), Match(), and Reset().
char * XrdXrootdProtocol::FSLib = 0 [static, protected] |
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_Sync(), do_Truncate(), do_Write(), and Reset().
int XrdXrootdProtocol::hailWait [static, protected] |
Referenced by Configure(), and Match().
int XrdXrootdProtocol::halfBSize [protected] |
int XrdXrootdProtocol::hcMax = 28657 [static, protected] |
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] |
char XrdXrootdProtocol::isActive [protected] |
Referenced by do_Offload(), do_OffloadIO(), Recycle(), and Reset().
char XrdXrootdProtocol::isBound [protected] |
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 [static, protected] |
Referenced by Configure(), do_Protocol(), and Match().
XrdXrootdJob * XrdXrootdProtocol::JobCKS = 0 [static, protected] |
Referenced by Configure(), do_CKsum(), and xcksum().
char * XrdXrootdProtocol::JobCKT = 0 [static, protected] |
Referenced by do_CKsum(), and xcksum().
XrdLink* XrdXrootdProtocol::Link [protected] |
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().
XrdXrootdFileLock * XrdXrootdProtocol::Locker [static, protected] |
Referenced by Configure(), and do_Open().
int XrdXrootdProtocol::maxBuffsz [static, protected] |
Referenced by Configure(), do_ReadAll(), do_WriteAll(), and XrdXrootdAioReq::Init().
const int XrdXrootdProtocol::maxPio = 4 [static, protected] |
Referenced by do_Bind(), and do_Qconf().
const int XrdXrootdProtocol::maxRvecsz = 1024 [static, protected] |
Referenced by do_Qconf().
const int XrdXrootdProtocol::maxStreams = 16 [static, protected] |
Referenced by Cleanup(), do_Bind(), do_Offload(), and do_Qconf().
int XrdXrootdProtocol::maxTransz = 262144 [static, protected] |
Referenced by Configure(), do_Qconf(), and do_ReadV().
char XrdXrootdProtocol::monFILE [protected] |
Referenced by do_Close(), do_Login(), XrdXrootdAdmin::do_Lsd(), do_Open(), do_Set_Mon(), and Reset().
char XrdXrootdProtocol::monIO [protected] |
Referenced by do_Login(), XrdXrootdAdmin::do_Lsd(), do_Read(), do_Set_Mon(), do_Write(), and Reset().
XrdXrootdMonitor* XrdXrootdProtocol::Monitor [protected] |
Referenced by Cleanup(), do_Close(), do_Login(), do_Open(), do_Read(), do_Set_Mon(), do_Write(), Recycle(), and Reset().
kXR_unt32 XrdXrootdProtocol::monUID [protected] |
Referenced by do_Login(), do_Set_Mon(), Recycle(), and Reset().
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] |
XrdXrootdFile* XrdXrootdProtocol::myFile [protected] |
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=().
const char * XrdXrootdProtocol::myInst = 0 [static, protected] |
Referenced by Configure(), and xprep().
int XrdXrootdProtocol::myIOLen [protected] |
long long XrdXrootdProtocol::myOffset [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(), operator=(), and Reset().
int XrdXrootdProtocol::myPID = static_cast<int>(getpid()) [static, protected] |
Referenced by do_Bind(), do_Endsess(), and do_Login().
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 [static, protected] |
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::numWrites [protected] |
Referenced by Cleanup(), XrdXrootdAdmin::do_Lsd(), do_Write(), Reset(), and Stats().
XrdSfsFileSystem * XrdXrootdProtocol::osFS [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(), do_Statx(), and do_Truncate().
short XrdXrootdProtocol::PathID [protected] |
char * XrdXrootdProtocol::pidPath = strdup("/tmp") [static, protected] |
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 [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(), fsError(), and xred().
Referenced by Recycle().
XrdObjectQ< XrdXrootdProtocol > XrdXrootdProtocol::ProtStack [static, private] |
Referenced by Configure(), Match(), and Recycle().
int XrdXrootdProtocol::readWait [static, protected] |
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(), 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_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] |
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] [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().
XrdXrootdXPath XrdXrootdProtocol::RPList [static, protected] |
Referenced by Configure(), do_Open(), and xred().
XrdScheduler * XrdXrootdProtocol::Sched [static, protected] |
Referenced by Configure(), do_Offload(), and xcksum().
char * XrdXrootdProtocol::SecLib = 0 [static, protected] |
Referenced by Configure(), and xsecl().
XrdXrootdStats * XrdXrootdProtocol::SI [static, protected] |
Referenced by Cleanup(), Configure(), do_Query(), do_ReadAll(), do_Write(), fsError(), XrdXrootdAioReq::Init(), and Stats().
char XrdXrootdProtocol::Status [protected] |
Referenced by Cleanup(), do_Auth(), do_Bind(), do_Login(), XrdXrootdAdmin::do_Lsd(), 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" [static, protected] |
int XrdXrootdProtocol::WANPort [static, protected] |
Referenced by Configure(), and do_Qconf().
int XrdXrootdProtocol::WANWindow [static, protected] |
Referenced by Configure(), and do_Qconf().
int XrdXrootdProtocol::Window [static, protected] |
Referenced by Configure(), and do_Qconf().
XrdXrootdXPath XrdXrootdProtocol::XPList [static, protected] |
Referenced by Configure(), do_Locate(), Squash(), and xexpdo().