XrdOfsFile Class Reference

#include <XrdOfs.hh>

Inheritance diagram for XrdOfsFile:

Collaboration diagram for XrdOfsFile:

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, int MonID)
virtual	~XrdOfsFile ()
Public Member Functions inherited from XrdSfsFile
	XrdSfsFile (const char *user=0, int MonID=0)
virtual	~XrdSfsFile ()

Protected Attributes
const char *	tident

Private Member Functions
void	GenFWEvent ()

Private Attributes
XrdOfsHandle *	oh
XrdOfsTPC *	myTPC
int	dorawio
char	viaDel

Additional Inherited Members
Public Attributes inherited from XrdSfsFile
XrdOucErrInfo	error

Constructor & Destructor Documentation

XrdOfsFile::XrdOfsFile	(	const char *	user,
		int	MonID
	)

References dorawio, XrdOfs::dummyHandle, myTPC, oh, tident, and viaDel.

virtual XrdOfsFile::~XrdOfsFile ( )

inlinevirtual

References close(), oh, and viaDel.

Member Function Documentation

int XrdOfsFile::close ( )

virtual

Implements XrdSfsFile.

References XrdCmsClient::Added(), XrdOfs::Balancer, XrdOfsEvs::Closer, XrdOfsEvs::Closew, XrdOfsStats::Data, XrdOfsPoscq::Del(), XrdOfsTPC::Del(), XrdOfs::dummyHandle, XrdOfs::Emsg(), XrdOfsEvs::Enabled(), EPNAME, XrdSfsFile::error, XrdOfs::evsObject, XrdOssDF::Fchmod(), FTRACE, XrdOfsHandle::Inactive(), XrdOfsHandle::isRW, XrdSysMutex::Lock(), XrdOfsHandle::Lock(), myTPC, 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 ( )

inlinevirtual

Implements XrdSfsFile.

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.

References XrdOssDF::isCompressed(), oh, XrdOfsHandle::Select(), and SFS_OK.

int XrdOfsFile::getMmap ( void **  Addr, off_t &  Size  )

virtual

Implements XrdSfsFile.

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, XrdOfsTPC::Authorize(), XrdOfs::Balancer, XrdOfsPoscq::Commit(), XrdOfsEvs::Create, XrdOss::Create(), XrdOfsStats::Data, XrdOfsPoscq::Del(), dorawio, XrdOfs::Emsg(), XrdOfsEvs::Enabled(), EPNAME, XrdSfsFile::error, XrdOfs::evrObject, XrdOfs::evsObject, XrdOfs::Finder, XrdOfs::fsError(), FTRACE, XrdOfsHandle::isCompressed, XrdOss::Lfn2Pfn(), XrdCmsClient::Locate(), XrdSysMutex::Lock(), myTPC, 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, SFS_STARTED, XrdOfs::Stall(), tident, XrdOucTPC::tpcKey, XrdCopy::tpcKey, XrdSysMutex::UnLock(), XrdOfsHandle::Usage(), XrdOfsTPC::Validate(), XrdOfsEvr::Wait4Event(), XRDOSS_mkpath, XRDOSS_new, and ZTRACE.

int XrdOfsFile::read ( XrdSfsFileOffset  fileOffset, XrdSfsXferSize  amount  )

virtual

Implements XrdSfsFile.

References XrdOfs::Emsg(), EPNAME, XrdSfsFile::error, FTRACE, XrdOfsHandle::Name(), oh, XrdOssDF::Read(), and XrdOfsHandle::Select().

Referenced by read().

XrdSfsXferSize XrdOfsFile::read ( XrdSfsFileOffset  fileOffset, char *  buffer, XrdSfsXferSize  buffer_size  )

virtual

Implements XrdSfsFile.

References dorawio, XrdOfs::Emsg(), EPNAME, XrdSfsFile::error, FTRACE, XrdOfsHandle::Name(), oh, XrdOssDF::Read(), read(), XrdOssDF::ReadRaw(), and XrdOfsHandle::Select().

int XrdOfsFile::read ( XrdSfsAio *  aioparm )

virtual

Implements XrdSfsFile.

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.

References XrdOfs::Emsg(), EPNAME, XrdSfsFile::error, XrdOssDF::Fstat(), FTRACE, XrdOfsHandle::Name(), oh, XrdOfsHandle::Select(), and SFS_OK.

int XrdOfsFile::sync ( )

virtual

Implements XrdSfsFile.

References XrdOfs::Emsg(), EPNAME, XrdSfsFile::error, XrdOssDF::Fsync(), FTRACE, XrdOfsHandle::isPending, XrdOfsHandle::Lock(), myTPC, oh, XrdOfsHandle::Select(), SFS_OK, XrdOfsTPC::Sync(), and XrdOfsHandle::UnLock().

Referenced by sync().

int XrdOfsFile::sync ( XrdSfsAio *  aiop )

virtual

Implements XrdSfsFile.

References XrdSfsAio::doneWrite(), XrdSfsAio::Result, and sync().

int XrdOfsFile::truncate ( XrdSfsFileOffset  fileOffset )

virtual

Implements XrdSfsFile.

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.

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.

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().

Member Data Documentation

int XrdOfsFile::dorawio

private

Referenced by open(), read(), and XrdOfsFile().

XrdOfsTPC* XrdOfsFile::myTPC

private

Referenced by close(), open(), sync(), 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(), and XrdOfsFile().

char XrdOfsFile::viaDel

private

Referenced by close(), XrdOfsFile(), and ~XrdOfsFile().

---

The documentation for this class was generated from the following files:

• XrdOfs.hh
• XrdOfs.cc