xrootd
|
#include <XrdOssApi.hh>
Public Member Functions | |
virtual XrdOssDF * | newDir (const char *tident) |
virtual XrdOssDF * | newFile (const char *tident) |
int | Chmod (const char *, mode_t mode) |
int | Configure (const char *, XrdSysError &) |
void | Config_Display (XrdSysError &) |
virtual int | Create (const char *, const char *, mode_t, XrdOucEnv &, int opts=0) |
int | GenLocalPath (const char *, char *) |
int | GenRemotePath (const char *, char *) |
int | Init (XrdSysLogger *, const char *) |
int | IsRemote (const char *path) |
int | Lfn2Pfn (const char *Path, char *buff, int blen) |
int | Mkdir (const char *, mode_t mode, int mkpath=0) |
int | Mkpath (const char *, mode_t mode) |
unsigned long long | PathOpts (const char *path) |
int | Reloc (const char *tident, const char *path, const char *cgName, const char *anchor=0) |
int | Remdir (const char *, int Opts=0) |
int | Rename (const char *, const char *) |
virtual int | Stage (const char *, const char *, XrdOucEnv &, int, mode_t, unsigned long long) |
void * | Stage_In (void *carg) |
int | Stat (const char *, struct stat *, int opts=0) |
int | StatFS (const char *path, char *buff, int &blen) |
int | StatFS (const char *path, unsigned long long &Opt, long long &fSize, long long &fSpace) |
int | StatLS (XrdOucEnv &env, const char *path, char *buff, int &blen) |
int | StatVS (XrdOssVSInfo *sP, const char *sname=0, int updt=0) |
int | StatXA (const char *path, char *buff, int &blen) |
int | StatXP (const char *path, unsigned long long &attr) |
int | Truncate (const char *, unsigned long long Size) |
int | Unlink (const char *, int Opts=0) |
int | Stats (char *bp, int bl) |
int | MSS_Closedir (void *) |
int | MSS_Create (const char *path, mode_t, XrdOucEnv &) |
void * | MSS_Opendir (const char *, int &rc) |
int | MSS_Readdir (void *fd, char *buff, int blen) |
int | MSS_Remdir (const char *, const char *) |
int | MSS_Rename (const char *, const char *) |
int | MSS_Stat (const char *, struct stat *buff=0) |
int | MSS_Unlink (const char *) |
XrdOssSys () | |
virtual | ~XrdOssSys () |
Static Public Member Functions | |
static int | AioInit () |
Public Attributes | |
char * | ConfigFN |
int | Hard_FD_Limit |
int | MaxTwiddle |
char * | LocalRoot |
char * | RemoteRoot |
int | StageRealTime |
int | StageAsync |
int | StageCreate |
int | StageFormat |
char * | StageCmd |
char * | StageMsg |
XrdOucMsubs * | StageSnd |
XrdFrmProxy * | StageFrm |
char * | StageEvents |
int | StageEvSize |
int | StageActLen |
char * | StageAction |
char * | StageArg [MaxArgs] |
int | StageAln [MaxArgs] |
int | StageAnum |
char * | RSSCmd |
int | isMSSC |
int | RSSTout |
long long | MaxSize |
int | FDFence |
int | FDLimit |
unsigned long long | DirFlags |
int | Trace |
int | Solitary |
char * | CompSuffix |
int | CompSuflen |
int | OptFlags |
char * | N2N_Lib |
char * | N2N_Parms |
XrdOucName2Name * | lcl_N2N |
XrdOucName2Name * | rmt_N2N |
XrdOucName2Name * | the_N2N |
XrdOucPListAnchor | RPList |
OssDPath * | DPList |
int | lenDP |
short | numDP |
short | numCG |
Static Public Attributes | |
static int | AioAllOk = 0 |
static char | tryMmap = 0 |
static char | chkMmap = 0 |
static const int | MaxArgs = 15 |
Protected Member Functions | |
int | Alloc_Cache (const char *, mode_t, XrdOucEnv &) |
int | Alloc_Local (const char *, mode_t, XrdOucEnv &) |
int | BreakLink (const char *local_path, struct stat &statbuff) |
int | CalcTime () |
int | CalcTime (XrdOssStage_Req *req) |
void | doScrub () |
int | Find (XrdOssStage_Req *req, void *carg) |
int | getCname (const char *path, struct stat *sbuff, char *cgbuff) |
int | getStats (char *buff, int blen) |
int | GetFile (XrdOssStage_Req *req) |
int | getID (const char *, XrdOucEnv &, char *, int) |
time_t | HasFile (const char *fn, const char *sfx, time_t *mTime=0) |
int | Stage_QT (const char *, const char *, XrdOucEnv &, int, mode_t) |
int | Stage_RT (const char *, const char *, XrdOucEnv &, unsigned long long) |
void | ConfigMio (XrdSysError &Eroute) |
int | ConfigN2N (XrdSysError &Eroute) |
int | ConfigProc (XrdSysError &Eroute) |
void | ConfigSpace () |
void | ConfigSpace (const char *Lfn) |
void | ConfigSpath (XrdSysError &Eroute, const char *Pn, unsigned long long &Fv, int noMSS) |
int | ConfigStage (XrdSysError &Eroute) |
int | ConfigStageC (XrdSysError &Eroute) |
void | ConfigStats (XrdSysError &Eroute) |
void | ConfigStats (dev_t Devnum, char *lP) |
int | ConfigXeq (char *, XrdOucStream &, XrdSysError &) |
void | List_Path (const char *, const char *, unsigned long long, XrdSysError &) |
int | xalloc (XrdOucStream &Config, XrdSysError &Eroute) |
int | xcache (XrdOucStream &Config, XrdSysError &Eroute) |
int | xcompdct (XrdOucStream &Config, XrdSysError &Eroute) |
int | xcachescan (XrdOucStream &Config, XrdSysError &Eroute) |
int | xdefault (XrdOucStream &Config, XrdSysError &Eroute) |
int | xfdlimit (XrdOucStream &Config, XrdSysError &Eroute) |
int | xmaxsz (XrdOucStream &Config, XrdSysError &Eroute) |
int | xmemf (XrdOucStream &Config, XrdSysError &Eroute) |
int | xnml (XrdOucStream &Config, XrdSysError &Eroute) |
int | xpath (XrdOucStream &Config, XrdSysError &Eroute) |
int | xspace (XrdOucStream &Config, XrdSysError &Eroute, int *isCD=0) |
int | xspaceBuild (char *grp, char *fn, int isxa, XrdSysError &Eroute) |
int | xstg (XrdOucStream &Config, XrdSysError &Eroute) |
int | xusage (XrdOucStream &Config, XrdSysError &Eroute) |
int | xtrace (XrdOucStream &Config, XrdSysError &Eroute) |
int | xxfr (XrdOucStream &Config, XrdSysError &Eroute) |
int | tranmode (char *) |
int | MSS_Xeq (XrdOucStream **xfd, int okerr, const char *cmd, const char *arg1=0, const char *arg2=0) |
int | RenameLink (char *old_path, char *new_path) |
int | RenameLink2 (int Llen, char *oLnk, char *old_path, char *nLnk, char *new_path) |
Protected Attributes | |
long long | minalloc |
int | ovhalloc |
int | fuzalloc |
int | cscanint |
int | xfrspeed |
int | xfrovhd |
int | xfrhold |
int | xfrkeep |
int | xfrthreads |
int | xfrtcount |
long long | pndbytes |
long long | stgbytes |
long long | totbytes |
int | totreqs |
int | badreqs |
XrdOucProg * | StageProg |
XrdOucProg * | RSSProg |
char * | UDir |
char * | QFile |
XrdOssSys::XrdOssSys | ( | ) |
References badreqs, chkMmap, CompSuffix, CompSuflen, ConfigFN, cscanint, DirFlags, DPList, FDFence, FDLimit, fuzalloc, isMSSC, lcl_N2N, lenDP, LocalRoot, MaxSize, MaxTwiddle, minalloc, N2N_Lib, N2N_Parms, numCG, numDP, OptFlags, ovhalloc, pndbytes, QFile, RemoteRoot, rmt_N2N, RSSCmd, RSSTout, Solitary, StageAction, StageActLen, StageAsync, StageCmd, StageCreate, StageEvents, StageEvSize, StageFrm, StageMsg, StageRealTime, StageSnd, stgbytes, the_N2N, totbytes, totreqs, tryMmap, UDir, xfrhold, xfrkeep, xfrovhd, xfrspeed, xfrtcount, xfrthreads, and XrdOssFDLIMIT.
virtual XrdOssSys::~XrdOssSys | ( | ) | [inline, virtual] |
int XrdOssSys::AioInit | ( | ) | [static] |
References AioAllOk, DEBUG, XrdSysError::Emsg(), EPNAME, XrdSysThread::Run(), and XrdOssAioWait().
Referenced by Configure().
References XrdOuca2x::a2ll(), XrdOssCache::Alloc(), XrdOssCache::allocInfo::aMode, XrdOssCache::allocInfo::cgName, XrdOssCache::allocInfo::cgPath, XrdOssCache::allocInfo::cgPlen, XrdOssCache::allocInfo::cgPsfx, XrdOssCache::allocInfo::cgSize, close, DEBUG, EPNAME, XrdOucEnv::Get(), XrdOssSpace::minSNbsz, OSS_ASIZE, OSS_CGROUP, XrdOssCache::Parse(), unlink(), XRDOSS_E8018, and XrdOssOK.
Referenced by Create().
int XrdOssSys::BreakLink | ( | const char * | local_path, |
struct stat & | statbuff | ||
) | [protected] |
References XrdOssCache::Adjust(), DEBUG, XrdSysError::Emsg(), EPNAME, stat(), XrdOssPath::Trim2Base(), unlink(), and XrdOssPath::xChar.
Referenced by Unlink().
int XrdOssSys::CalcTime | ( | ) | [protected] |
References EINPROGRESS, and StageAsync.
Referenced by Stage_QT(), and Stage_RT().
int XrdOssSys::CalcTime | ( | XrdOssStage_Req * | req | ) | [protected] |
int XrdOssSys::Chmod | ( | const char * | path, |
mode_t | mode | ||
) | [virtual] |
Implements XrdOss.
References lcl_N2N, XrdOucName2Name::lfn2pfn(), and XrdOssOK.
void XrdOssSys::Config_Display | ( | XrdSysError & | Eroute | ) |
References CompSuffix, ConfigFN, cscanint, DirFlags, Display(), FDFence, FDLimit, XrdOucPListAnchor::First(), XrdOucPList::Flag(), fuzalloc, XrdOssCache::List(), List_Path(), LocalRoot, MaxSize, minalloc, N2N_Lib, XrdOucPList::Next(), ovhalloc, XrdOucPList::Path(), RemoteRoot, RPList, RSSCmd, XrdSysError::Say(), snprintf, StageAsync, StageCmd, StageCreate, StageMsg, XrdOucTrace::What, xfrhold, xfrovhd, xfrspeed, xfrthreads, XrdOssConfig_Val, and XrdOssConfig_Vop.
Referenced by Configure().
void XrdOssSys::ConfigMio | ( | XrdSysError & | Eroute | ) | [protected] |
References chkMmap, DirFlags, XrdOucPListAnchor::First(), XrdOucPList::Flag(), XrdOssMio::isAuto(), XrdOssMio::isOn(), XrdOucPList::Next(), RPList, XrdSysError::Say(), XrdOssMio::Set(), XrdOucPList::Set(), tryMmap, XRDEXP_FORCERO, XRDEXP_MEMAP, XRDEXP_MKEEP, XRDEXP_MLOK, XRDEXP_MMAP, and XRDEXP_NOTRW.
Referenced by Configure().
int XrdOssSys::ConfigN2N | ( | XrdSysError & | Eroute | ) | [protected] |
References ConfigFN, XrdOucEnv::Export(), XrdSysPlugin::getPlugin(), lcl_N2N, LocalRoot, N2N_Lib, N2N_Parms, RemoteRoot, rmt_N2N, the_N2N, XrdOucgetName2Name(), and XrdOucgetName2NameArgs.
Referenced by ConfigProc().
int XrdOssSys::ConfigProc | ( | XrdSysError & | Eroute | ) | [protected] |
References XrdOucStream::Attach(), XrdOucStream::Close(), XrdCms::Config, ConfigFN, ConfigN2N(), ConfigXeq(), XrdOucStream::Echo(), XrdSysError::Emsg(), XrdOucStream::GetMyFirstWord(), XrdOucStream::LastError(), LocalRoot, N2N_Lib, open(), RemoteRoot, XrdSysError::Say(), xpath(), and XrdOssOK.
Referenced by Configure().
void XrdOssSys::ConfigSpace | ( | ) | [protected] |
References XrdOucPListAnchor::First(), XrdOucPList::Flag(), XrdOucPList::Next(), OptFlags, XrdOucPList::Path(), RPList, XRDEXP_INPLACE, XRDEXP_NOTRW, XRDEXP_PURGE, XRDEXP_STAGE, and XrdOss_CacheFS.
Referenced by Configure().
void XrdOssSys::ConfigSpace | ( | const char * | Lfn | ) | [protected] |
References XrdOssCache_FS::Add(), GenLocalPath(), rindex, and stat().
void XrdOssSys::ConfigSpath | ( | XrdSysError & | Eroute, |
const char * | Pn, | ||
unsigned long long & | Fv, | ||
int | noMSS | ||
) | [protected] |
References DirFlags, XrdSysError::Say(), XRDEXP_CHECK_X, XRDEXP_MAKELF, XRDEXP_MASKSHIFT, XRDEXP_MIG, XRDEXP_NOCHECK, XRDEXP_NODREAD, XRDEXP_NOTRW, XRDEXP_PURGE, and XRDEXP_RCREATE.
Referenced by ConfigStage().
int XrdOssSys::ConfigStage | ( | XrdSysError & | Eroute | ) | [protected] |
References ConfigSpath(), ConfigStageC(), XrdOucPListAnchor::Default(), DirFlags, XrdSysError::Emsg(), XrdOucPListAnchor::First(), XrdOucPList::Flag(), XrdFrmProxy::Init(), XrdOucUtils::InstName(), XrdSysError::logger(), XrdOucPList::Next(), XrdFrmProxy::opStg, XrdOucPList::Path(), RPList, RSSCmd, RSSProg, S_IROTH, S_IRWXG, S_IRWXU, S_IXOTH, XrdSysError::Say(), XrdOucPList::Set(), XrdOucProg::Setup(), Solitary, StageAction, StageActLen, StageAsync, StageCmd, StageCreate, StageEvents, StageEvSize, StageFrm, StageRealTime, TRACE_Debug, XrdOucTrace::What, XRDEXP_MAKELF, XRDEXP_MASKSHIFT, XRDEXP_MIG, XRDEXP_NOCHECK, XRDEXP_NODREAD, XRDEXP_NOTRW, XRDEXP_PURGE, XRDEXP_RCREATE, and XRDEXP_STAGE.
Referenced by Configure().
int XrdOssSys::ConfigStageC | ( | XrdSysError & | Eroute | ) | [protected] |
References XrdSysError::Emsg(), index(), XrdOucMsubs::Parse(), rindex, XrdSysThread::Run(), XrdOucProg::Setup(), StageCmd, StageFormat, StageMsg, StageProg, StageRealTime, StageSnd, XrdOucProg::Start(), xfrtcount, xfrthreads, and XrdOssxfr().
Referenced by ConfigStage().
void XrdOssSys::ConfigStats | ( | XrdSysError & | Eroute | ) | [protected] |
References DPList, XrdOucPListAnchor::First(), XrdOssCache_Group::fsgroups, GenLocalPath(), lenDP, XrdOucPList::Next(), XrdOssCache_Group::next, numCG, numDP, XrdOucPList::Path(), rindex, RPList, and stat().
Referenced by Configure().
void XrdOssSys::ConfigStats | ( | dev_t | Devnum, |
char * | lP | ||
) | [protected] |
References GenLocalPath(), rindex, and stat().
int XrdOssSys::Configure | ( | const char * | configfn, |
XrdSysError & | Eroute | ||
) |
References XrdSysError::addTable(), AioInit(), Config_Display(), ConfigFN, ConfigMio(), ConfigProc(), ConfigSpace(), ConfigStage(), ConfigStats(), cscanint, DirFlags, XrdSysError::Emsg(), FDFence, FDLimit, fuzalloc, Hard_FD_Limit, Init(), minalloc, ovhalloc, QFile, RPList, XrdSysThread::Run(), XrdSysError::Say(), XrdOucPList::Set(), Solitary, TRACE_ALL, UDir, XrdOucTrace::What, XRDOSS_EBASE, XRDOSS_ELAST, XrdOssCacheScan(), XrdOssErrorText, and XrdOssOK.
Referenced by Init().
int XrdOssSys::ConfigXeq | ( | char * | var, |
XrdOucStream & | Config, | ||
XrdSysError & | Eroute | ||
) | [protected] |
References Duplicate, XrdOucStream::Echo(), XrdSysError::Emsg(), XrdOucStream::GetRest(), isMSSC, LocalRoot, OptFlags, RemoteRoot, RSSCmd, XrdSysError::Say(), XrdOucStream::SetEnv(), StageMsg, strlcpy(), TS_Ade, TS_String, TS_Xeq, xalloc(), xcache(), xcachescan(), xcompdct(), xdefault(), xfdlimit(), xmaxsz(), xmemf(), xnml(), xpath(), XrdOss_USRPRTY, xspace(), xstg(), xtrace(), xusage(), and xxfr().
Referenced by ConfigProc().
int XrdOssSys::Create | ( | const char * | tident, |
const char * | path, | ||
mode_t | access_mode, | ||
XrdOucEnv & | env, | ||
int | opts = 0 |
||
) | [virtual] |
Implements XrdOss.
References XrdOssCache::Adjust(), Alloc_Cache(), Alloc_Local(), Check_RO, close, DEBUG, XrdSysError::Emsg(), EPNAME, XrdOssCache::fsfirst, GenLocalPath(), GenRemotePath(), lstat(), XrdOucUtils::makePath(), MSS_Create(), MSS_Stat(), open(), rindex, S_IROTH, S_IRWXG, S_IRWXU, S_IXOTH, XrdOssLock::Serialize(), Stage(), StageCreate, stat(), unlink(), XrdOssLock::UnSerialize(), XRDEXP_INPLACE, XRDEXP_MAKELF, XRDEXP_NOCHECK, XRDEXP_RCREATE, XRDOSS_mkpath, XRDOSS_new, XrdOssDIR, XrdOssEXC, XrdOssFILE, XrdOssNOWAIT, XrdOssOK, XrdOssRETIME, and XrdOssSHR.
void XrdOssSys::doScrub | ( | ) | [protected] |
int XrdOssSys::Find | ( | XrdOssStage_Req * | req, |
void * | carg | ||
) | [protected] |
int XrdOssSys::GenLocalPath | ( | const char * | oldp, |
char * | newp | ||
) |
References lcl_N2N, and XrdOucName2Name::lfn2pfn().
Referenced by ConfigSpace(), ConfigStats(), Create(), GetFile(), HasFile(), Reloc(), Remdir(), Rename(), and Unlink().
int XrdOssSys::GenRemotePath | ( | const char * | oldp, |
char * | newp | ||
) |
int XrdOssSys::getCname | ( | const char * | path, |
struct stat * | sbuff, | ||
char * | cgbuff | ||
) | [protected] |
int XrdOssSys::GetFile | ( | XrdOssStage_Req * | req | ) | [protected] |
References XrdSysError::Emsg(), GenLocalPath(), GenRemotePath(), XrdOssStage_Req::path, XrdOucProg::Run(), StageProg, and XRDOSS_E8009.
Referenced by Stage_In().
int XrdOssSys::getID | ( | const char * | Tid, |
XrdOucEnv & | Env, | ||
char * | buff, | ||
int | bsz | ||
) | [protected] |
Referenced by Stage_QT().
int XrdOssSys::getStats | ( | char * | buff, |
int | blen | ||
) | [protected] |
References DPList, XrdOssCache_Space::Free, XrdOssCache_FS::freeSpace(), XrdOssCache_Group::fsgroups, XrdOssCache_FS::getSpace(), XrdOssCache_Group::group, XrdOssCache_Space::Inleft, XrdOssCache_Space::Inodes, lenDP, XrdOssCache_Space::Maxfree, XrdOssSpace::maxSNlen, XrdOssCache_Group::next, OssDPath::Next, numCG, numDP, OssDPath::Path1, OssDPath::Path2, XrdOssCache_Space::Quota, snprintf, XrdOssCache_Space::Total, and XrdOssCache_Space::Usage.
Referenced by Stats().
time_t XrdOssSys::HasFile | ( | const char * | fn, |
const char * | sfx, | ||
time_t * | mTime = 0 |
||
) | [protected] |
References GenLocalPath(), and stat().
Referenced by Stage_QT(), and Stage_RT().
int XrdOssSys::Init | ( | XrdSysLogger * | lp, |
const char * | configfn | ||
) | [virtual] |
Implements XrdOss.
References Configure(), XrdSysError::logger(), OssEroute, and XrdOssOK.
Referenced by Configure(), XrdOssGetSS(), and XrdSfsGetFileSystem().
int XrdOssSys::IsRemote | ( | const char * | path | ) | [inline] |
References XrdOucPListAnchor::Find(), RPList, and XRDEXP_REMOTE.
Referenced by Stat().
int XrdOssSys::Lfn2Pfn | ( | const char * | Path, |
char * | buff, | ||
int | blen | ||
) | [virtual] |
Reimplemented from XrdOss.
References lcl_N2N, and XrdOucName2Name::lfn2pfn().
void XrdOssSys::List_Path | ( | const char * | pfx, |
const char * | pname, | ||
unsigned long long | flags, | ||
XrdSysError & | Eroute | ||
) | [protected] |
References XrdSysError::Say(), snprintf, XRDEXP_COMPCHK, XRDEXP_FORCERO, XRDEXP_GLBLRO, XRDEXP_INPLACE, XRDEXP_LOCAL, XRDEXP_MIG, XRDEXP_MKEEP, XRDEXP_MLOK, XRDEXP_MMAP, XRDEXP_NOCHECK, XRDEXP_NODREAD, XRDEXP_PURGE, XRDEXP_RCREATE, XRDEXP_READONLY, and XRDEXP_STAGE.
Referenced by Config_Display().
int XrdOssSys::Mkdir | ( | const char * | path, |
mode_t | mode, | ||
int | mkpath = 0 |
||
) | [virtual] |
int XrdOssSys::Mkpath | ( | const char * | path, |
mode_t | mode | ||
) |
int XrdOssSys::MSS_Closedir | ( | void * | dir_handle | ) |
References XrdSysError::Emsg(), XrdOssHandle::hflag, XRDOSS_HT_DIR, and XrdOssOK.
Referenced by XrdOssDir::Close().
References XrdSysError::Emsg(), and MSS_Xeq().
Referenced by Create().
void * XrdOssSys::MSS_Opendir | ( | const char * | dir_path, |
int & | rc | ||
) |
References XrdSysError::Emsg(), MSS_Xeq(), XrdOssHandle::sp, XRDOSS_HT_DIR, and XrdOssHandle::XrdOssHandle().
Referenced by XrdOssDir::Opendir().
int XrdOssSys::MSS_Readdir | ( | void * | fd, |
char * | buff, | ||
int | blen | ||
) |
References XrdSysError::Emsg(), XrdOucStream::GetLine(), XrdOssHandle::hflag, XrdOucStream::LastError(), NegVal, XrdOssHandle::sp, strlcpy(), XRDOSS_HT_DIR, XRDOSS_HT_EOF, and XrdOssOK.
Referenced by XrdOssDir::Readdir().
int XrdOssSys::MSS_Remdir | ( | const char * | , |
const char * | |||
) | [inline] |
int XrdOssSys::MSS_Rename | ( | const char * | oldname, |
const char * | newname | ||
) |
References XrdSysError::Emsg(), and MSS_Xeq().
Referenced by Rename().
int XrdOssSys::MSS_Stat | ( | const char * | path, |
struct stat * | buff = 0 |
||
) |
References XrdSysError::Emsg(), isMSSC, MSS_Xeq(), stat(), tranmode(), and XRDOSS_E8012.
Referenced by Create(), Stage_RT(), and Stat().
int XrdOssSys::MSS_Unlink | ( | const char * | path | ) |
References XrdSysError::Emsg(), and MSS_Xeq().
Referenced by Unlink().
int XrdOssSys::MSS_Xeq | ( | XrdOucStream ** | xfd, |
int | okerr, | ||
const char * | cmd, | ||
const char * | arg1 = 0 , |
||
const char * | arg2 = 0 |
||
) | [protected] |
References DEBUG, XrdSysError::Emsg(), EPNAME, ETIMEDOUT, XrdOucStream::GetLine(), NegVal, RSSCmd, RSSProg, RSSTout, XrdOucProg::Run(), XrdOssHandle::sp, XrdOucStream::Wait4Data(), XRDOSS_E8013, XRDOSS_E8023, and XRDOSS_E8024.
Referenced by MSS_Create(), MSS_Opendir(), MSS_Rename(), MSS_Stat(), and MSS_Unlink().
unsigned long long XrdOssSys::PathOpts | ( | const char * | path | ) | [inline] |
References XrdOucPListAnchor::Find(), and RPList.
Referenced by XrdOssFile::Open(), XrdOssDir::Opendir(), Stat(), StatFS(), and StatXP().
int XrdOssSys::Reloc | ( | const char * | tident, |
const char * | path, | ||
const char * | cgName, | ||
const char * | anchor = 0 |
||
) | [virtual] |
Reimplemented from XrdOss.
References XrdOssCache::Adjust(), XrdOssCache::Alloc(), XrdOssCache::allocInfo::aMode, XrdOssCache::allocInfo::cgFSp, XrdOssCache::allocInfo::cgName, XrdOssCache::allocInfo::cgPath, XrdOssCache::allocInfo::cgPlen, XrdOssCache::allocInfo::cgPsfx, XrdOssCache::allocInfo::cgSize, close, XrdOssCopy::Copy(), DEBUG, XrdSysError::Emsg(), EPNAME, XrdOssCache::Find(), GenLocalPath(), getCname(), XrdOssPath::isXA(), XrdOucUtils::makePath(), XrdOssSpace::minSNbsz, XrdOssCache::Parse(), rename(), rindex, S_IAMB, S_IROTH, S_IRWXG, S_IRWXU, S_IXOTH, stat(), unlink(), and XrdOssOK.
int XrdOssSys::Remdir | ( | const char * | path, |
int | Opts = 0 |
||
) | [virtual] |
Implements XrdOss.
References Check_RO, GenLocalPath(), lstat(), opts, stat(), Unlink(), and XRDOSS_isPFN.
int XrdOssSys::Rename | ( | const char * | oldname, |
const char * | newname | ||
) | [virtual] |
Implements XrdOss.
References Check_RO, DEBUG, XrdSysError::Emsg(), EPNAME, GenLocalPath(), GenRemotePath(), lstat(), XrdOucUtils::makePath(), MSS_Rename(), rename(), RenameLink(), rindex, RSSCmd, S_IRWXG, S_IRWXU, XrdOssLock::Serialize(), XrdOssPath::Sfx, XrdOssPath::sfxMigL, snprintf, stat(), XrdOssLock::UnSerialize(), XRDEXP_MAKELF, XRDEXP_MIG, XRDOSS_E8011, XrdOssDIR, XrdOssEXC, and XrdOssOK.
int XrdOssSys::RenameLink | ( | char * | old_path, |
char * | new_path | ||
) | [protected] |
References XrdOssCache::Adjust(), XrdOssPath::Convert(), XrdSysError::Emsg(), lstat(), rename(), RenameLink2(), Solitary, stat(), XrdOssPath::Trim2Base(), UDir, unlink(), and XrdOssPath::xChar.
Referenced by Rename().
int XrdOssSys::RenameLink2 | ( | int | Llen, |
char * | oLnk, | ||
char * | old_path, | ||
char * | nLnk, | ||
char * | new_path | ||
) | [protected] |
References XrdSysError::Emsg(), and unlink().
Referenced by RenameLink().
int XrdOssSys::Stage | ( | const char * | Tid, |
const char * | fn, | ||
XrdOucEnv & | env, | ||
int | Oflag, | ||
mode_t | Mode, | ||
unsigned long long | Popts | ||
) | [virtual] |
References Stage_QT(), Stage_RT(), and StageRealTime.
Referenced by Create(), and XrdOssFile::Open().
void * XrdOssSys::Stage_In | ( | void * | carg | ) |
References badreqs, XrdOssStage_Req::flags, GetFile(), XrdOucDLlist< T >::Item(), XrdSysMutex::Lock(), XrdOssStage_Req::pendList, pndbytes, XrdOucDLlist< T >::Prev(), XrdOucDLlist< T >::Remove(), XrdOssStage_Req::sigtod, XrdOssStage_Req::size, XrdOssStage_Req::StageQ, stgbytes, totbytes, totreqs, XrdSysMutex::UnLock(), XrdSysSemaphore::Wait(), xfrhold, xfrspeed, xfrtcount, xfrthreads, XRDOSS_REQ_ACTV, XRDOSS_REQ_ENOF, and XRDOSS_REQ_FAIL.
Referenced by XrdOssxfr().
int XrdOssSys::Stage_QT | ( | const char * | Tid, |
const char * | fn, | ||
XrdOucEnv & | env, | ||
int | Oflag, | ||
mode_t | Mode | ||
) | [protected] |
References XrdFrmProxy::Add(), XrdOucHash< T >::Add(), XrdOucHash< T >::Apply(), CalcTime(), XrdOucEnv::Env(), XrdOucProg::Feed(), getID(), HasFile(), Hash_data_is_key, XrdOucReqID::ID(), Info, lcl_N2N, XrdSysMutex::Lock(), XrdOucMsubs::maxElem, StageAction, StageActLen, StageEvents, StageEvSize, StageFormat, StageFrm, StageProg, StageSnd, XrdOucMsubs::Subs(), XrdSysMutex::UnLock(), xfrhold, xfrkeep, XRDOSS_E8009, XRDOSS_E8025, XRDOSS_FAIL_FILE, and XrdOssScrubScan().
Referenced by Stage().
int XrdOssSys::Stage_RT | ( | const char * | Tid, |
const char * | fn, | ||
XrdOucEnv & | env, | ||
unsigned long long | Popts | ||
) | [protected] |
References XrdOuca2x::a2i(), CalcTime(), XrdSysError::Emsg(), XrdOssStage_Req::flags, XrdOssStage_Req::fullList, XrdOucEnv::Get(), HasFile(), XrdOssStage_Req::hash, XrdOucDLlist< T >::Insert(), XrdOucName2Name::lfn2rfn(), XrdSysMutexHelper::Lock(), MSS_Stat(), OptFlags, OSS_MAX_PRTY, OSS_SYSPRTY, OSS_USE_PRTY, OSS_USRPRTY, XrdOssStage_Req::path, XrdOssStage_Req::pendList, pndbytes, XrdSysSemaphore::Post(), rmt_N2N, XrdOssStage_Req::sigtod, XrdOssStage_Req::size, StageCmd, XrdOssStage_Req::StageQ, stat(), XrdSysMutexHelper::UnLock(), XRDEXP_NOCHECK, XRDOSS_E8006, XRDOSS_E8009, XRDOSS_E8010, XRDOSS_FAIL_FILE, XRDOSS_REQ_ENOF, XRDOSS_REQ_FAIL, XrdOss_USRPRTY, XrdOssFind_Prty(), XrdOssFind_Req(), and XrdOucHashVal().
Referenced by Stage().
int XrdOssSys::Stat | ( | const char * | path, |
struct stat * | buff, | ||
int | opts = 0 |
||
) | [virtual] |
Implements XrdOss.
References IsRemote(), lcl_N2N, XrdOucName2Name::lfn2pfn(), XrdOucName2Name::lfn2rfn(), MSS_Stat(), PathOpts(), rmt_N2N, RSSCmd, S_IWGRP, S_IWOTH, S_IWUSR, stat(), XRDEXP_NOCHECK, XRDEXP_NOTRW, XRDOSS_resonly, XRDOSS_updtatm, and XrdOssOK.
int XrdOssSys::StatFS | ( | const char * | path, |
char * | buff, | ||
int & | blen | ||
) | [virtual] |
Reimplemented from XrdOss.
References snprintf, XRDEXP_NOTRW, XRDEXP_STAGE, and XrdOssOK.
Referenced by StatLS().
int XrdOssSys::StatFS | ( | const char * | path, |
unsigned long long & | Opt, | ||
long long & | fSize, | ||
long long & | fSpace | ||
) |
int XrdOssSys::StatLS | ( | XrdOucEnv & | env, |
const char * | path, | ||
char * | buff, | ||
int & | blen | ||
) | [virtual] |
Reimplemented from XrdOss.
References XrdOssCache_Group::fsgroups, XrdOucEnv::Get(), getCname(), XrdOssCache_FS::getSpace(), XrdOssSpace::minSNbsz, OSS_CGROUP, XrdOssCache_Group::PubQuota, snprintf, stat(), StatFS(), and XrdOssOK.
int XrdOssSys::Stats | ( | char * | bp, |
int | bl | ||
) | [virtual] |
Reimplemented from XrdOss.
References getStats().
int XrdOssSys::StatVS | ( | XrdOssVSInfo * | sP, |
const char * | sname = 0 , |
||
int | updt = 0 |
||
) | [virtual] |
Reimplemented from XrdOss.
References XrdOssVSInfo::Extents, XrdOssCache_Space::Free, XrdOssVSInfo::Free, XrdOssCache::fsCount, XrdOssCache::fsFree, XrdOssCache_Group::fsgroups, XrdOssCache::fsLarge, XrdOssCache::fsTotal, XrdOssCache::fsTotFr, XrdOssCache_FS::getSpace(), XrdOssVSInfo::Large, XrdOssCache_Space::Largest, XrdOssVSInfo::LFree, XrdSysMutex::Lock(), XrdOssCache_Space::Maxfree, XrdOssCache::Mutex, XrdOssCache_Space::Quota, XrdOssVSInfo::Quota, XrdOssCache::Scan(), XrdOssCache_Space::Total, XrdOssVSInfo::Total, XrdSysMutex::UnLock(), XrdOssCache_Space::Usage, XrdOssVSInfo::Usage, and XrdOssOK.
int XrdOssSys::StatXA | ( | const char * | path, |
char * | buff, | ||
int & | blen | ||
) | [virtual] |
Reimplemented from XrdOss.
References getCname(), XrdOssSpace::minSNbsz, S_ISDIR, S_ISREG, S_IWUSR, snprintf, stat(), and XrdOssOK.
int XrdOssSys::StatXP | ( | const char * | path, |
unsigned long long & | attr | ||
) | [virtual] |
Reimplemented from XrdOss.
References PathOpts(), and XrdOssOK.
int XrdOssSys::tranmode | ( | char * | mode | ) | [protected] |
References S_IROTH, S_IWOTH, and S_IXOTH.
Referenced by MSS_Stat().
int XrdOssSys::Truncate | ( | const char * | path, |
unsigned long long | Size | ||
) | [virtual] |
Implements XrdOss.
References XrdOssCache::Adjust(), lcl_N2N, XrdOucName2Name::lfn2pfn(), lstat(), stat(), truncate(), and XrdOssOK.
int XrdOssSys::Unlink | ( | const char * | path, |
int | Opts = 0 |
||
) | [virtual] |
Implements XrdOss.
References XrdOssCache::Adjust(), BreakLink(), Check_RO, DEBUG, EPNAME, GenLocalPath(), GenRemotePath(), lstat(), MSS_Unlink(), XrdOssLock::NoSerialize(), rmdir(), RSSCmd, XrdOssLock::Serialize(), XrdOssPath::Sfx, XrdOssPath::sfxMigL, stat(), unlink(), XrdOssLock::UnSerialize(), XRDEXP_MAKELF, XRDOSS_isMIG, XRDOSS_isPFN, XRDOSS_Online, XrdOssDIR, XrdOssEXC, and XrdOssOK.
Referenced by Remdir().
int XrdOssSys::xalloc | ( | XrdOucStream & | Config, |
XrdSysError & | Eroute | ||
) | [protected] |
References XrdOuca2x::a2i(), XrdOuca2x::a2sz(), XrdSysError::Emsg(), fuzalloc, XrdOucStream::GetWord(), minalloc, and ovhalloc.
Referenced by ConfigXeq().
int XrdOssSys::xcache | ( | XrdOucStream & | Config, |
XrdSysError & | Eroute | ||
) | [protected] |
References XrdSysError::Say(), and xspace().
Referenced by ConfigXeq().
int XrdOssSys::xcachescan | ( | XrdOucStream & | Config, |
XrdSysError & | Eroute | ||
) | [protected] |
References XrdOuca2x::a2tm(), cscanint, XrdSysError::Emsg(), and XrdOucStream::GetWord().
Referenced by ConfigXeq().
int XrdOssSys::xcompdct | ( | XrdOucStream & | Config, |
XrdSysError & | Eroute | ||
) | [protected] |
References CompSuffix, CompSuflen, XrdSysError::Emsg(), and XrdOucStream::GetWord().
Referenced by ConfigXeq().
int XrdOssSys::xdefault | ( | XrdOucStream & | Config, |
XrdSysError & | Eroute | ||
) | [protected] |
References DirFlags, and XrdOucExport::ParseDefs().
Referenced by ConfigXeq().
int XrdOssSys::xfdlimit | ( | XrdOucStream & | Config, |
XrdSysError & | Eroute | ||
) | [protected] |
References XrdOuca2x::a2i(), XrdSysError::Emsg(), FDFence, FDLimit, XrdOucStream::GetWord(), Hard_FD_Limit, XrdSysError::Say(), xrdmax, XrdOssFDLIMIT, and XrdOssFDMINLIM.
Referenced by ConfigXeq().
int XrdOssSys::xmaxsz | ( | XrdOucStream & | Config, |
XrdSysError & | Eroute | ||
) | [protected] |
References XrdOuca2x::a2sz(), XrdSysError::Emsg(), XrdOucStream::GetWord(), and MaxSize.
Referenced by ConfigXeq().
int XrdOssSys::xmemf | ( | XrdOucStream & | Config, |
XrdSysError & | Eroute | ||
) | [protected] |
References XrdOuca2x::a2i(), XrdOuca2x::a2sz(), XrdSysError::Emsg(), XrdOucStream::GetWord(), XrdSysError::Say(), and XrdOssMio::Set().
Referenced by ConfigXeq().
int XrdOssSys::xnml | ( | XrdOucStream & | Config, |
XrdSysError & | Eroute | ||
) | [protected] |
References XrdSysError::Emsg(), XrdOucStream::GetRest(), XrdOucStream::GetWord(), N2N_Lib, and N2N_Parms.
Referenced by ConfigXeq().
int XrdOssSys::xpath | ( | XrdOucStream & | Config, |
XrdSysError & | Eroute | ||
) | [protected] |
References DirFlags, XrdOucPList::Flag(), XrdOucPListAnchor::Insert(), XrdOucPListAnchor::Match(), XrdMpx::Opts, XrdOucExport::ParsePath(), XrdOucPList::Path(), RPList, XrdOucPList::Set(), and XRDEXP_MASKSHIFT.
Referenced by ConfigProc(), and ConfigXeq().
int XrdOssSys::xspace | ( | XrdOucStream & | Config, |
XrdSysError & | Eroute, | ||
int * | isCD = 0 |
||
) | [protected] |
References closedir(), XrdSysError::Emsg(), XrdOucStream::GetWord(), XrdOssSpace::maxSNlen, XrdOssSpace::minSNbsz, opendir(), readdir(), XrdSysError::Say(), stat(), and xspaceBuild().
Referenced by ConfigXeq(), and xcache().
int XrdOssSys::xspaceBuild | ( | char * | grp, |
char * | fn, | ||
int | isxa, | ||
XrdSysError & | Eroute | ||
) | [protected] |
References XrdSysError::Emsg(), XrdOssCache_FS::isXA, XrdOssCache_FS::None, OptFlags, and XrdOss_CacheFS.
Referenced by xspace().
int XrdOssSys::xstg | ( | XrdOucStream & | Config, |
XrdSysError & | Eroute | ||
) | [protected] |
References XrdSysError::Emsg(), XrdOucStream::GetWord(), StageAsync, StageCmd, and StageCreate.
Referenced by ConfigXeq().
int XrdOssSys::xtrace | ( | XrdOucStream & | Config, |
XrdSysError & | Eroute | ||
) | [protected] |
References XrdSysError::Emsg(), XrdOucStream::GetWord(), XrdSysError::Say(), TRACE_ALL, TRACE_Debug, TRACE_Open, TRACE_Opendir, and XrdOucTrace::What.
Referenced by ConfigXeq().
int XrdOssSys::xusage | ( | XrdOucStream & | Config, |
XrdSysError & | Eroute | ||
) | [protected] |
References XrdSysError::Emsg(), XrdOucStream::GetWord(), QFile, and UDir.
Referenced by ConfigXeq().
int XrdOssSys::xxfr | ( | XrdOucStream & | Config, |
XrdSysError & | Eroute | ||
) | [protected] |
References XrdOuca2x::a2i(), XrdOuca2x::a2sz(), XrdOuca2x::a2tm(), XrdSysError::Emsg(), XrdOucStream::GetWord(), OptFlags, xfrhold, xfrkeep, xfrovhd, xfrspeed, xfrthreads, and XrdOss_USRPRTY.
Referenced by ConfigXeq().
int XrdOssSys::AioAllOk = 0 [static] |
Referenced by AioInit(), XrdOssFile::Fsync(), XrdOssFile::Read(), XrdOssFile::Write(), and XrdOssAioWait().
int XrdOssSys::badreqs [protected] |
Referenced by Stage_In(), and XrdOssSys().
char XrdOssSys::chkMmap = 0 [static] |
Referenced by ConfigMio(), XrdOssFile::Open(), and XrdOssSys().
char* XrdOssSys::CompSuffix |
Referenced by Config_Display(), xcompdct(), and XrdOssSys().
Referenced by xcompdct(), and XrdOssSys().
char* XrdOssSys::ConfigFN |
Referenced by Config_Display(), ConfigN2N(), ConfigProc(), Configure(), and XrdOssSys().
int XrdOssSys::cscanint [protected] |
Referenced by Config_Display(), Configure(), xcachescan(), and XrdOssSys().
unsigned long long XrdOssSys::DirFlags |
Referenced by Config_Display(), ConfigMio(), ConfigSpath(), ConfigStage(), Configure(), XrdOssFile::Read(), xdefault(), xpath(), and XrdOssSys().
Referenced by ConfigStats(), getStats(), and XrdOssSys().
Referenced by Config_Display(), Configure(), XrdOssFile::Open_ufs(), xfdlimit(), and XrdOssSys().
Referenced by Config_Display(), Configure(), xfdlimit(), and XrdOssSys().
int XrdOssSys::fuzalloc [protected] |
Referenced by Config_Display(), Configure(), xalloc(), and XrdOssSys().
Referenced by Configure(), and xfdlimit().
Referenced by ConfigXeq(), MSS_Stat(), and XrdOssSys().
Referenced by Chmod(), ConfigN2N(), GenLocalPath(), getCname(), Lfn2Pfn(), Mkdir(), XrdOssFile::Open(), XrdOssDir::Opendir(), Stage_QT(), Stat(), StatFS(), Truncate(), and XrdOssSys().
int XrdOssSys::lenDP |
Referenced by ConfigStats(), getStats(), and XrdOssSys().
char* XrdOssSys::LocalRoot |
Referenced by Config_Display(), ConfigN2N(), ConfigProc(), ConfigXeq(), and XrdOssSys().
const int XrdOssSys::MaxArgs = 15 [static] |
long long XrdOssSys::MaxSize |
Referenced by Config_Display(), XrdOssFile::Write(), xmaxsz(), and XrdOssSys().
Referenced by XrdOssSys().
long long XrdOssSys::minalloc [protected] |
Referenced by Config_Display(), Configure(), xalloc(), and XrdOssSys().
char* XrdOssSys::N2N_Lib |
Referenced by Config_Display(), ConfigN2N(), ConfigProc(), xnml(), and XrdOssSys().
char* XrdOssSys::N2N_Parms |
Referenced by ConfigN2N(), xnml(), and XrdOssSys().
short XrdOssSys::numCG |
Referenced by ConfigStats(), getStats(), and XrdOssSys().
short XrdOssSys::numDP |
Referenced by ConfigStats(), getStats(), and XrdOssSys().
Referenced by ConfigSpace(), ConfigXeq(), Stage_RT(), XrdOssSys(), xspaceBuild(), and xxfr().
int XrdOssSys::ovhalloc [protected] |
Referenced by Config_Display(), Configure(), xalloc(), and XrdOssSys().
long long XrdOssSys::pndbytes [protected] |
Referenced by Stage_In(), Stage_RT(), and XrdOssSys().
char* XrdOssSys::QFile [protected] |
Referenced by Configure(), XrdOssSys(), and xusage().
char* XrdOssSys::RemoteRoot |
Referenced by Config_Display(), ConfigN2N(), ConfigProc(), ConfigXeq(), and XrdOssSys().
Referenced by ConfigN2N(), GenRemotePath(), XrdOssDir::Opendir(), Stage_RT(), Stat(), and XrdOssSys().
Referenced by Config_Display(), ConfigMio(), ConfigSpace(), ConfigStage(), ConfigStats(), Configure(), IsRemote(), PathOpts(), and xpath().
char* XrdOssSys::RSSCmd |
Referenced by Config_Display(), ConfigStage(), ConfigXeq(), MSS_Xeq(), Rename(), Stat(), Unlink(), and XrdOssSys().
XrdOucProg* XrdOssSys::RSSProg [protected] |
Referenced by ConfigStage(), and MSS_Xeq().
Referenced by MSS_Xeq(), and XrdOssSys().
Referenced by ConfigStage(), Configure(), RenameLink(), and XrdOssSys().
char* XrdOssSys::StageAction |
Referenced by ConfigStage(), Stage_QT(), and XrdOssSys().
Referenced by ConfigStage(), Stage_QT(), and XrdOssSys().
char* XrdOssSys::StageArg[MaxArgs] |
Referenced by CalcTime(), Config_Display(), ConfigStage(), XrdOssSys(), and xstg().
char* XrdOssSys::StageCmd |
Referenced by Config_Display(), ConfigStage(), ConfigStageC(), Stage_RT(), XrdOssSys(), and xstg().
Referenced by Config_Display(), ConfigStage(), Create(), XrdOssSys(), and xstg().
char* XrdOssSys::StageEvents |
Referenced by ConfigStage(), Stage_QT(), and XrdOssSys().
Referenced by ConfigStage(), Stage_QT(), and XrdOssSys().
Referenced by ConfigStageC(), and Stage_QT().
Referenced by ConfigStage(), Stage_QT(), and XrdOssSys().
char* XrdOssSys::StageMsg |
Referenced by Config_Display(), ConfigStageC(), ConfigXeq(), and XrdOssSys().
XrdOucProg* XrdOssSys::StageProg [protected] |
Referenced by ConfigStageC(), GetFile(), and Stage_QT().
Referenced by ConfigStage(), ConfigStageC(), Stage(), and XrdOssSys().
Referenced by ConfigStageC(), Stage_QT(), and XrdOssSys().
long long XrdOssSys::stgbytes [protected] |
Referenced by CalcTime(), Stage_In(), and XrdOssSys().
Referenced by ConfigN2N(), and XrdOssSys().
long long XrdOssSys::totbytes [protected] |
Referenced by Stage_In(), and XrdOssSys().
int XrdOssSys::totreqs [protected] |
Referenced by Stage_In(), and XrdOssSys().
int XrdOssSys::Trace |
char XrdOssSys::tryMmap = 0 [static] |
Referenced by ConfigMio(), XrdOssFile::Open(), and XrdOssSys().
char* XrdOssSys::UDir [protected] |
Referenced by Configure(), RenameLink(), XrdOssSys(), and xusage().
int XrdOssSys::xfrhold [protected] |
Referenced by Config_Display(), Stage_In(), Stage_QT(), XrdOssSys(), and xxfr().
int XrdOssSys::xfrkeep [protected] |
Referenced by Stage_QT(), XrdOssSys(), and xxfr().
int XrdOssSys::xfrovhd [protected] |
Referenced by CalcTime(), Config_Display(), XrdOssSys(), and xxfr().
int XrdOssSys::xfrspeed [protected] |
Referenced by CalcTime(), Config_Display(), Stage_In(), XrdOssSys(), and xxfr().
int XrdOssSys::xfrtcount [protected] |
Referenced by ConfigStageC(), Stage_In(), and XrdOssSys().
int XrdOssSys::xfrthreads [protected] |
Referenced by Config_Display(), ConfigStageC(), Stage_In(), XrdOssSys(), and xxfr().