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