xrootd
|
#include <XrdOfs.hh>
Public Member Functions | |
int | open (const char *fileName, XrdSfsFileOpenMode openMode, mode_t createMode, const XrdSecEntity *client, const char *opaque=0) |
int | close () |
virtual int | fctl (const int cmd, const char *args, XrdOucErrInfo &out_error) |
const char * | FName () |
int | getMmap (void **Addr, off_t &Size) |
int | read (XrdSfsFileOffset fileOffset, XrdSfsXferSize amount) |
XrdSfsXferSize | read (XrdSfsFileOffset fileOffset, char *buffer, XrdSfsXferSize buffer_size) |
int | read (XrdSfsAio *aioparm) |
XrdSfsXferSize | write (XrdSfsFileOffset fileOffset, const char *buffer, XrdSfsXferSize buffer_size) |
int | write (XrdSfsAio *aioparm) |
int | sync () |
int | sync (XrdSfsAio *aiop) |
int | stat (struct stat *buf) |
int | truncate (XrdSfsFileOffset fileOffset) |
int | getCXinfo (char cxtype[4], int &cxrsz) |
XrdOfsFile (const char *user) | |
virtual | ~XrdOfsFile () |
Protected Attributes | |
const char * | tident |
Private Member Functions | |
void | GenFWEvent () |
Private Attributes | |
XrdOfsHandle * | oh |
int | dorawio |
char | viaDel |
int XrdOfsFile::close | ( | ) | [virtual] |
Implements XrdSfsFile.
Reimplemented in XrdTokenAuthzOfsFile.
References XrdCmsClient::Added(), XrdOfs::Balancer, XrdOfsEvs::Closer, XrdOfsEvs::Closew, XrdOfsStats::Data, XrdOfsPoscq::Del(), XrdOfs::Emsg(), XrdOfsEvs::Enabled(), EPNAME, XrdSfsFile::error, XrdOfs::evsObject, XrdOssDF::Fchmod(), FTRACE, XrdOfsHandle::Inactive(), XrdOfsHandle::isRW, XrdOfsHandle::Lock(), XrdSysMutex::Lock(), XrdOfsHandle::Name(), XrdOfsEvs::Notify(), XrdOfsStats::StatsData::numOpenP, XrdOfsStats::StatsData::numOpenR, XrdOfsStats::StatsData::numOpenW, XrdOfs::ocMutex, oh, XrdOfsHandle::opPC, XrdOfsHandle::PoscGet(), XrdOfs::poscHold, XrdOfs::poscQ, XrdOfsHandle::Retire(), XrdOfsStats::sdMutex, XrdOfsHandle::Select(), SFS_OK, tident, XrdSysMutex::UnLock(), XrdOfs::Unpersist(), XrdOfsHandle::Usage(), and viaDel.
Referenced by ~XrdOfsFile().
int XrdOfsFile::fctl | ( | const int | cmd, |
const char * | args, | ||
XrdOucErrInfo & | out_error | ||
) | [virtual] |
Implements XrdSfsFile.
References XrdOssDF::getFD(), oh, XrdOfsHandle::Select(), XrdOucErrInfo::setErrCode(), XrdOucErrInfo::setErrInfo(), SFS_ERROR, SFS_FCTL_GETFD, and SFS_OK.
const char* XrdOfsFile::FName | ( | ) | [inline, virtual] |
Implements XrdSfsFile.
Reimplemented in XrdTokenAuthzOfsFile.
References XrdOfsHandle::Name(), and oh.
void XrdOfsFile::GenFWEvent | ( | ) | [private] |
References XrdOfs::evsObject, XrdOfsEvs::Fwrite, XrdOfsHandle::isChanged, XrdOfsHandle::Lock(), XrdOfsHandle::Name(), XrdOfsEvs::Notify(), oh, tident, and XrdOfsHandle::UnLock().
Referenced by truncate(), and write().
int XrdOfsFile::getCXinfo | ( | char | cxtype[4], |
int & | cxrsz | ||
) | [virtual] |
Implements XrdSfsFile.
Reimplemented in XrdTokenAuthzOfsFile.
References XrdOssDF::isCompressed(), oh, XrdOfsHandle::Select(), and SFS_OK.
int XrdOfsFile::getMmap | ( | void ** | Addr, |
off_t & | Size | ||
) | [virtual] |
Implements XrdSfsFile.
Reimplemented in XrdTokenAuthzOfsFile.
References XrdOssDF::getMmap(), oh, XrdOfsHandle::Select(), and SFS_OK.
int XrdOfsFile::open | ( | const char * | fileName, |
XrdSfsFileOpenMode | openMode, | ||
mode_t | createMode, | ||
const XrdSecEntity * | client, | ||
const char * | opaque = 0 |
||
) | [virtual] |
Implements XrdSfsFile.
References XrdOfsPoscq::Add(), XrdCmsClient::Added(), XrdOfsHandle::Alloc(), AOP_Create, AOP_Read, AOP_Update, AUTHORIZE, XrdOfs::Balancer, XrdOfsPoscq::Commit(), XrdOfsEvs::Create, XrdOss::Create(), XrdOfsStats::Data, XrdOfsPoscq::Del(), dorawio, EINPROGRESS, XrdOfs::Emsg(), XrdOfsEvs::Enabled(), EPNAME, XrdSfsFile::error, ETXTBSY, XrdOfs::evrObject, XrdOfs::evsObject, XrdOfs::Finder, XrdOfs::fsError(), FTRACE, XrdOfsHandle::isCompressed, XrdCmsClient::Locate(), XrdSysMutex::Lock(), XrdOss::newFile(), XrdOfsEvs::Notify(), XrdOfsStats::StatsData::numOpenP, XrdOfsStats::StatsData::numOpenR, XrdOfsStats::StatsData::numOpenW, XrdOfs::ocMutex, oh, OOIDENTENV, XrdOfsEvs::Openr, XrdOfsEvs::Openw, XrdOfsHandle::opPC, XrdOfsHandle::opRW, Path, XrdOfs::poscAuto, XrdOfs::poscQ, XrdCmsClient::Removed(), S_IAMB, XrdOfsStats::sdMutex, SFS_O_CREAT, SFS_O_MKPTH, SFS_O_NOWAIT, SFS_O_POSC, SFS_O_RAWIO, SFS_O_RDONLY, SFS_O_RDWR, SFS_O_REPLICA, SFS_O_RESET, SFS_O_TRUNC, SFS_O_WRONLY, SFS_OK, XrdOfs::Stall(), tident, XrdSysMutex::UnLock(), XrdOfsHandle::Usage(), XrdOfsEvr::Wait4Event(), XRDOSS_mkpath, XRDOSS_new, and ZTRACE.
XrdSfsXferSize XrdOfsFile::read | ( | XrdSfsFileOffset | fileOffset, |
char * | buffer, | ||
XrdSfsXferSize | buffer_size | ||
) | [virtual] |
Implements XrdSfsFile.
Reimplemented in XrdTokenAuthzOfsFile.
References dorawio, XrdOfs::Emsg(), EPNAME, XrdSfsFile::error, FTRACE, XrdOfsHandle::Name(), oh, XrdOssDF::Read(), read(), XrdOssDF::ReadRaw(), and XrdOfsHandle::Select().
int XrdOfsFile::read | ( | XrdSfsFileOffset | fileOffset, |
XrdSfsXferSize | amount | ||
) | [virtual] |
Implements XrdSfsFile.
Reimplemented in XrdTokenAuthzOfsFile.
References XrdOfs::Emsg(), EPNAME, XrdSfsFile::error, FTRACE, XrdOfsHandle::Name(), oh, XrdOssDF::Read(), and XrdOfsHandle::Select().
Referenced by read().
int XrdOfsFile::read | ( | XrdSfsAio * | aioparm | ) | [virtual] |
Implements XrdSfsFile.
Reimplemented in XrdTokenAuthzOfsFile.
References aiocb::aio_buf, aiocb::aio_nbytes, aiocb::aio_offset, XrdSfsAio::doneRead(), XrdOfs::Emsg(), EPNAME, XrdSfsFile::error, FTRACE, XrdOfsHandle::isCompressed, XrdOfsHandle::Name(), oh, XrdOssDF::Read(), read(), XrdSfsAio::Result, XrdOfsHandle::Select(), SFS_OK, and XrdSfsAio::sfsAio.
int XrdOfsFile::stat | ( | struct stat * | buf | ) | [virtual] |
Implements XrdSfsFile.
Reimplemented in XrdTokenAuthzOfsFile.
References XrdOfs::Emsg(), EPNAME, XrdSfsFile::error, XrdOssDF::Fstat(), FTRACE, XrdOfsHandle::Name(), oh, XrdOfsHandle::Select(), and SFS_OK.
int XrdOfsFile::sync | ( | XrdSfsAio * | aiop | ) | [virtual] |
Implements XrdSfsFile.
Reimplemented in XrdTokenAuthzOfsFile.
References XrdSfsAio::doneWrite(), XrdSfsAio::Result, and sync().
int XrdOfsFile::sync | ( | ) | [virtual] |
Implements XrdSfsFile.
Reimplemented in XrdTokenAuthzOfsFile.
References XrdOfs::Emsg(), EPNAME, XrdSfsFile::error, XrdOssDF::Fsync(), FTRACE, XrdOfsHandle::isPending, XrdOfsHandle::Lock(), oh, XrdOfsHandle::Select(), SFS_OK, and XrdOfsHandle::UnLock().
Referenced by sync().
int XrdOfsFile::truncate | ( | XrdSfsFileOffset | fileOffset | ) | [virtual] |
Implements XrdSfsFile.
Reimplemented in XrdTokenAuthzOfsFile.
References XrdOfs::Emsg(), XrdOfsEvs::Enabled(), EPNAME, XrdSfsFile::error, XrdOfs::evsObject, FTRACE, XrdOssDF::Ftruncate(), XrdOfsEvs::Fwrite, GenFWEvent(), XrdOfsHandle::isChanged, XrdOfsHandle::isPending, oh, XrdOfsHandle::Select(), and SFS_OK.
XrdSfsXferSize XrdOfsFile::write | ( | XrdSfsFileOffset | fileOffset, |
const char * | buffer, | ||
XrdSfsXferSize | buffer_size | ||
) | [virtual] |
Implements XrdSfsFile.
Reimplemented in XrdTokenAuthzOfsFile.
References XrdOfs::Emsg(), XrdOfsEvs::Enabled(), EPNAME, XrdSfsFile::error, XrdOfs::evsObject, FTRACE, XrdOfsEvs::Fwrite, GenFWEvent(), XrdOfsHandle::isChanged, XrdOfsHandle::isPending, oh, XrdOfsHandle::Select(), and XrdOssDF::Write().
Referenced by write().
int XrdOfsFile::write | ( | XrdSfsAio * | aioparm | ) | [virtual] |
Implements XrdSfsFile.
Reimplemented in XrdTokenAuthzOfsFile.
References aiocb::aio_buf, aiocb::aio_nbytes, aiocb::aio_offset, XrdSfsAio::doneWrite(), XrdOfs::Emsg(), XrdOfsEvs::Enabled(), EPNAME, XrdSfsFile::error, XrdOfs::evsObject, FTRACE, XrdOfsEvs::Fwrite, GenFWEvent(), XrdOfsHandle::isChanged, XrdOfsHandle::isPending, XrdOfsHandle::isRW, XrdOfsHandle::Name(), oh, XrdOfsHandle::opPC, XrdSfsAio::Result, XrdOfsHandle::Select(), SFS_OK, XrdSfsAio::sfsAio, XrdOssDF::Write(), and write().
int XrdOfsFile::dorawio [private] |
Referenced by open(), read(), and XrdOfsFile().
XrdOfsHandle* XrdOfsFile::oh [private] |
Referenced by close(), fctl(), FName(), GenFWEvent(), getCXinfo(), getMmap(), open(), read(), stat(), sync(), truncate(), write(), XrdOfsFile(), and ~XrdOfsFile().
const char* XrdOfsFile::tident [protected] |
Referenced by close(), GenFWEvent(), open(), XrdTokenAuthzOfs::stat(), and XrdOfsFile().
char XrdOfsFile::viaDel [private] |
Referenced by close(), XrdOfsFile(), and ~XrdOfsFile().