|
xrootd
|
#include <XrdPosixXrootd.hh>

Public Member Functions | |
| XrdPosixXrootd (int maxfd=255, int maxdir=255, int maxthr=255) | |
| ~XrdPosixXrootd () | |
Static Public Member Functions | |
| static int | Close (int fildes, int Stream=0) |
| static int | Closedir (DIR *dirp) |
| static int | Fstat (int fildes, struct stat *buf) |
| static int | Fsync (int fildes) |
| static int | Ftruncate (int fildes, off_t offset) |
| static long long | Getxattr (const char *path, const char *name, void *value, unsigned long long size) |
| static off_t | Lseek (int fildes, off_t offset, int whence) |
| static int | Mkdir (const char *path, mode_t mode) |
| static int | Open (const char *path, int oflag, mode_t mode=0, XrdPosixCallBack *cbP=0) |
| static DIR * | Opendir (const char *path) |
| static ssize_t | Pread (int fildes, void *buf, size_t nbyte, off_t offset) |
| static ssize_t | Read (int fildes, void *buf, size_t nbyte) |
| static ssize_t | Readv (int fildes, const struct iovec *iov, int iovcnt) |
| static struct dirent * | Readdir (DIR *dirp) |
| static struct dirent64 * | Readdir64 (DIR *dirp) |
| static int | Readdir_r (DIR *dirp, struct dirent *entry, struct dirent **result) |
| static int | Readdir64_r (DIR *dirp, struct dirent64 *entry, struct dirent64 **result) |
| static int | Rename (const char *oldpath, const char *newpath) |
| static void | Rewinddir (DIR *dirp) |
| static int | Rmdir (const char *path) |
| static void | Seekdir (DIR *dirp, long loc) |
| static int | Stat (const char *path, struct stat *buf) |
| static int | Statfs (const char *path, struct statfs *buf) |
| static int | Statvfs (const char *path, struct statvfs *buf) |
| static ssize_t | Pwrite (int fildes, const void *buf, size_t nbyte, off_t offset) |
| static long | Telldir (DIR *dirp) |
| static int | Truncate (const char *path, off_t offset) |
| static int | Unlink (const char *path) |
| static ssize_t | Write (int fildes, const void *buf, size_t nbyte) |
| static ssize_t | Write (int fildes, void *buf, size_t nbyte, off_t offset) |
| static ssize_t | Writev (int fildes, const struct iovec *iov, int iovcnt) |
| static int | Access (const char *path, int amode) |
| static int | endPoint (int FD, char *Buff, int Blen) |
| static bool | isXrootdDir (DIR *dirp) |
| static int | mapError (int rc) |
| static bool | myFD (int fd) |
| static void | OpenCB (XrdPosixFile *fp, void *cbArg, int res) |
| static int | QueryChksum (const char *, time_t &, char *, int) |
| static long long | QueryOpaque (const char *, char *, int) |
| static void | setDebug (int val) |
| static void | setEnv (const char *var, const char *val) |
| static void | setEnv (const char *var, long val) |
| static void | setCache (XrdOucCache *cP) |
Static Public Attributes | |
| static const int | isStream = 0x40000000 |
| static int | Debug = -2 |
Static Private Member Functions | |
| static void | initEnv () |
| static void | initEnv (char *eData) |
| static void | initEnv (XrdOucEnv &, const char *, long long &) |
| static int | Fault (XrdPosixFile *fp, int complete=1) |
| static XrdPosixFile * | findFP (int fildes, int glk=0) |
| static XrdPosixDir * | findDIR (DIR *dirp, int glk=0) |
| static void | initStat (struct stat *buf) |
| static void | initXdev (dev_t &st_dev, dev_t &st_rdev) |
| static int | mapFlags (int flags) |
| static int | mapMode (mode_t Mode) |
Static Private Attributes | |
| static XrdSysMutex | myMutex |
| static XrdPosixFile ** | myFiles = 0 |
| static XrdPosixDir ** | myDirs = 0 |
| static XrdOucCache * | myCache = 0 |
| static int | lastFD = -1 |
| static int | highFD = -1 |
| static int | baseFD = 0 |
| static int | freeFD = 0 |
| static int | lastDir = -1 |
| static int | highDir = -1 |
| static int | devNull = -1 |
| static int | pllOpen = 0 |
| static int | maxThreads = 0 |
| static int | initDone = 0 |
| XrdPosixXrootd::XrdPosixXrootd | ( | int | maxfd = 255, |
| int | maxdir = 255, |
||
| int | maxthr = 255 |
||
| ) |
References baseFD, devNull, initDone, initEnv(), lastDir, lastFD, XrdSysMutex::Lock(), maxThreads, myDirs, myFiles, myMutex, open(), and XrdSysMutex::UnLock().
| XrdPosixXrootd::~XrdPosixXrootd | ( | ) |
References highDir, highFD, initDone, XrdSysMutex::Lock(), myDirs, myFiles, myMutex, and XrdSysMutex::UnLock().
|
static |
|
static |
References baseFD, XrdPosixFile::FD, findFP(), freeFD, myFD(), myFiles, myMutex, XrdSysMutex::UnLock(), and XrdPosixFile::UnLock().
Referenced by XrdPssFile::Close(), main(), XrdFfsPosix_close(), XrdPosix_Close(), XrdPosix_Fclose(), and XrdPosix_Fopen().
|
static |
References XrdPosixDir::dirNo(), findDIR(), myDirs, myMutex, XrdPosixDir::UnLock(), and XrdSysMutex::UnLock().
Referenced by XrdFfsPosix_closedir(), and XrdPosix_Closedir().
|
static |
|
staticprivate |
References Debug, ServerResponseBody_Error::errmsg, ServerResponseBody_Error::errnum, kXR_noErrorYet, XrdClientAbs::LastServerError(), mapError(), XrdPosixFile::UnLock(), and XrdPosixFile::XClient.
Referenced by Fsync(), Ftruncate(), Open(), OpenCB(), Pread(), Pwrite(), Read(), and Write().
|
staticprivate |
References XrdPosixDir::dirNo(), XrdPosixDir::Lock(), XrdSysMutex::Lock(), myDirs, myMutex, and XrdSysMutex::UnLock().
Referenced by Closedir(), Readdir64(), Readdir64_r(), Rewinddir(), Seekdir(), and Telldir().
|
staticprivate |
References XrdPosixFile::Active(), baseFD, lastFD, XrdSysMutex::Lock(), XrdPosixFile::Lock(), myFiles, myMutex, and XrdSysMutex::UnLock().
Referenced by Close(), endPoint(), Fstat(), Fsync(), Ftruncate(), Lseek(), Pread(), Pwrite(), Read(), and Write().
|
static |
References findFP(), XrdClientStatInfo::flags, XrdClientStatInfo::id, initStat(), mapFlags(), XrdClientStatInfo::modtime, XrdClientStatInfo::size, XrdPosixFile::stat, and XrdPosixFile::UnLock().
Referenced by XrdPssFile::Fstat(), and XrdPosix_Fstat().
|
static |
References Fault(), findFP(), XrdOucCacheIO::Sync(), XrdPosixFile::UnLock(), and XrdPosixFile::XCio.
Referenced by XrdPssFile::Fsync(), XrdFfsPosix_fsync(), XrdPosix_Fdatasync(), XrdPosix_Fflush(), and XrdPosix_Fsync().
|
static |
References Fault(), findFP(), XrdOucCacheIO::Trunc(), XrdPosixFile::UnLock(), and XrdPosixFile::XCio.
Referenced by XrdPssFile::Ftruncate(), XrdFfsPosix_ftruncate(), and XrdPosix_Ftruncate().
|
static |
|
staticprivate |
References Debug, myCache, NAME_CONNECTTIMEOUT, NAME_DATASERVERCONN_TTL, NAME_DEBUG, NAME_DFLTTCPWINDOWSIZE, NAME_FIRSTCONNECTMAXCNT, NAME_LBSERVERCONN_TTL, NAME_MULTISTREAMCNT, NAME_READAHEADSIZE, NAME_READCACHEBLKREMPOLICY, NAME_READCACHESIZE, NAME_RECONNECTWAIT, NAME_REMUSEDCACHEBLKS, NAME_REQUESTTIMEOUT, NAME_TRANSACTIONTIMEOUT, pllOpen, and setEnv().
Referenced by initEnv(), and XrdPosixXrootd().
|
staticprivate |
References XrdPosixFile::CacheR, XrdOucCache::Parms::CacheSize, XrdOucCache::canPreRead, XrdOucCache::Create(), XrdOucEnv::Get(), initEnv(), XrdOucCache::isServer, XrdOucCache::isStructured, XrdOucCache::logStats, XrdOucCache::Parms::Max2Cache, XrdOucCache::Parms::MaxFiles, XrdOucCacheIO::aprParms::minPages, XrdOucCacheIO::aprParms::minPerf, myCache, NAME_READAHEADSIZE, NAME_READCACHESIZE, XrdOucCache::Parms::Options, XrdOucCache::Parms::PageSize, XrdOucCacheIO::aprParms::prRecalc, XrdOucCache::Serialized, setEnv(), XrdPosixFile::sfSFX, XrdPosixFile::sfSLN, and XrdOucCacheIO::aprParms::Trigger.
|
staticprivate |
References XrdOucEnv::Get().
|
staticprivate |
References initXdev(), and stat().
|
staticprivate |
References stat().
Referenced by initStat().
|
static |
References highDir, and myDirs.
Referenced by XrdPosix_Closedir(), XrdPosix_Readdir(), XrdPosix_Readdir64(), XrdPosix_Readdir64_r(), XrdPosix_Readdir_r(), XrdPosix_Rewinddir(), XrdPosix_Seekdir(), and XrdPosix_Telldir().
|
static |
References XrdPosixFile::addOffset(), findFP(), Scuttle, XrdPosixFile::setOffset(), XrdClientStatInfo::size, XrdPosixFile::stat, and XrdPosixFile::UnLock().
Referenced by XrdFfsPosix_lseek(), XrdPosix_Fseek(), XrdPosix_Fseeko(), XrdPosix_Ftell(), XrdPosix_Ftello(), and XrdPosix_Lseek().
|
static |
References kXR_ArgTooLong, kXR_FSError, kXR_IOError, kXR_isDirectory, kXR_NoMemory, kXR_noserver, kXR_NoSpace, kXR_NotAuthorized, kXR_NotFile, and kXR_NotFound.
Referenced by XrdPosixAdminNew::Fault(), Fault(), XrdPosixAdminNew::lastError(), XrdPosixDir::nextEntry(), XrdPosixAdminNew::XrdPosixAdminNew(), and XrdPosixDir::XrdPosixDir().
|
staticprivate |
References kXR_isDir, kXR_offline, kXR_other, kXR_poscpend, kXR_readable, kXR_writable, and kXR_xset.
|
staticprivate |
|
static |
|
inlinestatic |
References baseFD, highFD, and myFiles.
Referenced by Close(), fcntl(), fstat(), XrdPosix_Close(), XrdPosix_Fclose(), XrdPosix_Fcntl(), XrdPosix_Fdatasync(), XrdPosix_Fflush(), XrdPosix_Fread(), XrdPosix_Fseek(), XrdPosix_Fseeko(), XrdPosix_Fstat(), XrdPosix_Fsync(), XrdPosix_Ftell(), XrdPosix_Ftello(), XrdPosix_Ftruncate(), XrdPosix_Fwrite(), XrdPosix_Lseek(), XrdPosix_Pread(), XrdPosix_Pwrite(), XrdPosix_Read(), XrdPosix_Readv(), XrdPosix_Write(), and XrdPosix_Writev().
|
static |
References baseFD, close(), devNull, Fault(), freeFD, highFD, XrdPosixFile::isOpen(), isStream, XrdPosixFile::isSync, kXR_delete, kXR_mkpath, kXR_new, kXR_ok, kXR_open_read, kXR_open_updt, lastFD, XrdClientAbs::LastServerResp(), XrdSysMutex::Lock(), mapMode(), maxThreads, myFiles, myMutex, XrdClient::Open(), XrdMpx::Opts, pllOpen, XrdPosixFile::realFD, XrdPosixFile::stat, XrdClient::Stat(), ServerResponseHeader::status, XrdSysMutex::UnLock(), and XrdPosixFile::XClient.
Referenced by main(), XrdPssFile::Open(), XrdFfsPosix_open(), XrdPosix_Fopen(), and XrdPosix_Open().
|
static |
References baseFD, XrdPosixFile::cbResult, XrdPosixCallBack::Complete(), Fault(), XrdPosixFile::FD, XrdPosixFile::isOpen(), kXR_ok, XrdClientAbs::LastServerResp(), XrdSysMutex::Lock(), maxThreads, myFiles, myMutex, XrdPosixFile::Next, XrdSysSemaphore::Post(), XrdSysThread::Run(), XrdPosixFile::stat, XrdClient::Stat(), ServerResponseHeader::status, XrdPosixFile::theCB, XrdSysMutex::UnLock(), XrdSysSemaphore::Wait(), XrdPosixFile::XClient, and XrdPosixXrootdCB().
Referenced by XrdPosixFile::OpenComplete(), and XrdPosixXrootdCB().
|
static |
References close(), devNull, highDir, lastDir, XrdSysMutex::Lock(), myDirs, myMutex, XrdPosixDir::Status(), and XrdSysMutex::UnLock().
Referenced by XrdFfsPosix_opendir(), and XrdPosix_Opendir().
|
static |
References Fault(), findFP(), XrdOucCacheIO::Read(), Scuttle, XrdPosixFile::UnLock(), and XrdPosixFile::XCio.
Referenced by XrdPssFile::Read(), XrdFfsPosix_pread(), and XrdPosix_Pread().
|
static |
References Fault(), findFP(), Scuttle, XrdClientStatInfo::size, XrdPosixFile::stat, XrdPosixFile::UnLock(), XrdOucCacheIO::Write(), and XrdPosixFile::XCio.
Referenced by XrdPssFile::Write(), XrdFfsPosix_pwrite(), and XrdPosix_Pwrite().
|
static |
|
static |
|
static |
References XrdPosixFile::addOffset(), Fault(), findFP(), XrdPosixFile::Offset(), XrdOucCacheIO::Read(), Scuttle, XrdPosixFile::UnLock(), and XrdPosixFile::XCio.
Referenced by main(), Readv(), XrdFfsPosix_read(), XrdPosix_Fread(), and XrdPosix_Read().
|
staticread |
References Readdir64().
Referenced by XrdFfsPosix_readdir(), and XrdPosix_Readdir().
|
staticread |
References findDIR(), XrdPosixDir::nextEntry(), XrdPosixDir::Status(), and XrdPosixDir::UnLock().
Referenced by Readdir(), and XrdPosix_Readdir64().
|
static |
References findDIR(), XrdPosixDir::nextEntry(), XrdPosixDir::Status(), and XrdPosixDir::UnLock().
Referenced by Readdir_r(), and XrdPosix_Readdir64_r().
|
static |
References Readdir64_r().
Referenced by XrdPosix_Readdir_r().
|
static |
References Read().
Referenced by XrdPosix_Readv().
|
static |
|
static |
References findDIR(), XrdPosixDir::rewind(), and XrdPosixDir::UnLock().
Referenced by XrdPosix_Rewinddir().
|
static |
|
static |
References findDIR(), XrdPosixDir::getEntries(), XrdPosixDir::getOffset(), XrdPosixDir::nextEntry(), XrdPosixDir::setOffset(), and XrdPosixDir::UnLock().
Referenced by XrdPosix_Seekdir().
|
static |
References myCache.
Referenced by XrdPssSys::getCache().
|
static |
References Debug, and setEnv().
Referenced by XrdPssSys::Configure(), and XrdPssSys::xtrac().
|
static |
References EnvPutString.
Referenced by XrdPssSys::Configure(), initEnv(), setDebug(), and XrdPssSys::xsopt().
|
static |
References EnvPutInt.
|
static |
References XrdPosixAdminNew::Admin, XrdOucString::c_str(), XrdPosixAdminNew::Fault(), XrdClientUrlInfo::File, initStat(), XrdPosixAdminNew::isOK(), mapFlags(), XrdPosixAdminNew::Result(), and XrdClientAdmin::Stat().
Referenced by main(), XrdPssSys::Stat(), XrdFfsPosix_stat(), XrdPosix_Lstat(), and XrdPosix_Stat().
|
static |
References statfs(), Statvfs(), and statvfs().
Referenced by XrdPosix_Statfs().
|
static |
References XrdPosixAdminNew::Admin, XrdOucString::c_str(), XrdPosixAdminNew::Fault(), XrdClientUrlInfo::File, XrdPosixAdminNew::isOK(), XrdPosixAdminNew::Result(), XrdClientAdmin::Stat_vfs(), and statfs().
Referenced by Statfs(), and XrdPosix_Statvfs().
|
static |
References findDIR(), XrdPosixDir::getOffset(), and XrdPosixDir::UnLock().
Referenced by XrdPosix_Telldir().
|
static |
|
static |
|
static |
References XrdPosixFile::addOffset(), Fault(), findFP(), XrdPosixFile::Offset(), Scuttle, XrdPosixFile::UnLock(), XrdOucCacheIO::Write(), and XrdPosixFile::XCio.
Referenced by Writev(), XrdFfsPosix_write(), XrdPosix_Fwrite(), and XrdPosix_Write().
|
static |
|
static |
References Write().
Referenced by XrdPosix_Writev().
|
staticprivate |
|
static |
Referenced by XrdPosixAdminNew::Fault(), Fault(), initEnv(), and setDebug().
|
staticprivate |
Referenced by Open(), Opendir(), and XrdPosixXrootd().
|
staticprivate |
Referenced by isXrootdDir(), Opendir(), and ~XrdPosixXrootd().
|
staticprivate |
Referenced by myFD(), Open(), and ~XrdPosixXrootd().
|
staticprivate |
Referenced by XrdPosixXrootd(), and ~XrdPosixXrootd().
|
static |
Referenced by Open(), and XrdPosix_Fopen().
|
staticprivate |
Referenced by Opendir(), and XrdPosixXrootd().
|
staticprivate |
Referenced by findFP(), Open(), and XrdPosixXrootd().
|
staticprivate |
Referenced by Open(), OpenCB(), and XrdPosixXrootd().
|
staticprivate |
Referenced by initEnv(), and setCache().
|
staticprivate |
Referenced by Closedir(), findDIR(), isXrootdDir(), Opendir(), XrdPosixXrootd(), and ~XrdPosixXrootd().
|
staticprivate |
Referenced by Close(), findFP(), myFD(), Open(), OpenCB(), XrdPosixXrootd(), and ~XrdPosixXrootd().
|
staticprivate |
Referenced by Close(), Closedir(), findDIR(), findFP(), Open(), OpenCB(), Opendir(), XrdPosixXrootd(), and ~XrdPosixXrootd().
1.8.3.1