#include <XrdOfs.hh>

Inheritance diagram for XrdOfsFile:

[legend]

Collaboration diagram for XrdOfsFile:

[legend]

Public Member Functions
int	open (const char fileName, XrdSfsFileOpenMode openMode, mode_t createMode, const XrdSecEntity client, const char *opaque=0)

int	checkpoint (XrdSfsFile::cpAct act, struct iov *range=0, int n=0)

int	close ()

int	fctl (const int cmd, const char *args, XrdOucErrInfo &out_error)

int	fctl (const int cmd, int alen, const char args, const XrdSecEntity client=0)

const char *	FName ()

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

XrdSfsXferSize	pgRead (XrdSfsFileOffset offset, char buffer, XrdSfsXferSize rdlen, uint32_t csvec, uint64_t opts=0)

int	pgRead (XrdSfsAio *aioparm, uint64_t opts=0)

XrdSfsXferSize	pgWrite (XrdSfsFileOffset offset, char buffer, XrdSfsXferSize wrlen, uint32_t csvec, uint64_t opts=0)

int	pgWrite (XrdSfsAio *aioparm, uint64_t opts=0)

int	read (XrdSfsFileOffset fileOffset, XrdSfsXferSize amount)

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

XrdSfsXferSize	readv (XrdOucIOVec *readV, int readCount)

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 (XrdOucErrInfo &eInfo, const char *user)

	~XrdOfsFile ()

virtual int	fctl (const int cmd, const char *args, XrdOucErrInfo &eInfo)=0

virtual int	fctl (const int cmd, int alen, const char args, const XrdSecEntity client=0)

Public Member Functions inherited from XrdSfsFile
virtual int	SendData (XrdSfsDio *sfDio, XrdSfsFileOffset offset, XrdSfsXferSize size)

virtual XrdSfsXferSize	writev (XrdOucIOVec *writeV, int wdvCnt)

virtual void	setXio (XrdSfsXio *xioP)

	XrdSfsFile (const char *user=0, int MonID=0)

	XrdSfsFile (XrdSfsFile &wrapF)

	XrdSfsFile (XrdOucErrInfo &eInfo)

virtual	~XrdSfsFile ()
	Destructor.

Protected Attributes
const char *	tident

XrdOfsHandle *	oh

XrdOfsTPC *	myTPC

XrdOucChkPnt *	myCKP

int	dorawio

char	viaDel

bool	ckpBad

Private Member Functions
void	GenFWEvent ()

int	CreateCKP ()

Additional Inherited Members
Public Types inherited from XrdSfsFile
enum	cpAct { cpCreate =0 , cpDelete , cpRestore , cpQuery , cpTrunc , cpWrite }

Public Attributes inherited from XrdSfsFile
XrdOucErrInfo &	error

Static Public Attributes inherited from XrdSfsFile
static const uint64_t	Verify = 0x8000000000000000ULL
	Options for pgRead() and pgWrite() as noted below.

Constructor & Destructor Documentation

◆ XrdOfsFile()

XrdOfsFile::XrdOfsFile	(	XrdOucErrInfo &	eInfo,
		const char *	user
	)

◆ ~XrdOfsFile()

XrdOfsFile::~XrdOfsFile ( )

inline

References close(), oh, and viaDel.

Member Function Documentation

◆ checkpoint()

int XrdOfsFile::checkpoint	(	XrdSfsFile::cpAct	act,
		struct iov *	range = `0`,
		int	n = `0`
	)

virtual

Reimplemented from XrdSfsFile.

◆ close()

int XrdOfsFile::close ( )

virtual

Close the file.

Returns: One of SFS_OK or SFS_ERROR.

Implements XrdSfsFile.

Referenced by ~XrdOfsFile().

◆ CreateCKP()

int XrdOfsFile::CreateCKP ( )

private

◆ fctl() [1/4]

virtual int XrdSfsFile::fctl	(	const int	cmd,
		const char *	args,
		XrdOucErrInfo &	eInfo
	)

virtual

Execute a special operation on the file (version 1)

Parameters

cmd	- The operation to be performed (see below). SFS_FCTL_GETFD Return file descriptor if possible SFS_FCTL_STATV Reserved for future use.
args	- specific arguments to cmd SFS_FCTL_GETFD Set to zero.
eInfo	- The object where error info or results are to be returned. This is legacy and the error onject may be used as well.

Returns: If an error occurs or the operation is not support, SFS_ERROR should be returned with error.code set to errno. Otherwise, SFS_FCTL_GETFD error.code holds the real file descriptor number If the value is negative, sendfile() is not used. If the value is SFS_SFIO_FDVAL then the SendData() method is used for future read requests.

Implements XrdSfsFile.

◆ fctl() [2/4]

int XrdOfsFile::fctl	(	const int	cmd,
		const char *	args,
		XrdOucErrInfo &	eInfo
	)

virtual

Execute a special operation on the file (version 1)

Parameters

cmd	- The operation to be performed (see below). SFS_FCTL_GETFD Return file descriptor if possible SFS_FCTL_STATV Reserved for future use.
args	- specific arguments to cmd SFS_FCTL_GETFD Set to zero.
eInfo	- The object where error info or results are to be returned. This is legacy and the error onject may be used as well.

Returns: If an error occurs or the operation is not support, SFS_ERROR should be returned with error.code set to errno. Otherwise, SFS_FCTL_GETFD error.code holds the real file descriptor number If the value is negative, sendfile() is not used. If the value is SFS_SFIO_FDVAL then the SendData() method is used for future read requests.

Implements XrdSfsFile.

◆ fctl() [3/4]

virtual int XrdSfsFile::fctl	(	const int	cmd,
		int	alen,
		const char *	args,
		const XrdSecEntity *	client = `0`
	)

virtual

Execute a special operation on the file (version 2)

Parameters

cmd	- The operation to be performed: SFS_FCTL_SPEC1 Perform implementation defined action
alen	- Length of data pointed to by args.
args	- Data sent with request, zero if alen is zero.
client	- Client's identify (see common description).

Returns: SFS_OK a null response is sent.; SFS_DATA error.code length of the data to be sent. error.message contains the data to be sent. o/w one of SFS_ERROR, SFS_REDIRECT, or SFS_STALL.

Reimplemented from XrdSfsFile.

◆ fctl() [4/4]

int XrdOfsFile::fctl	(	const int	cmd,
		int	alen,
		const char *	args,
		const XrdSecEntity *	client = `0`
	)

virtual

Execute a special operation on the file (version 2)

Parameters

cmd	- The operation to be performed: SFS_FCTL_SPEC1 Perform implementation defined action
alen	- Length of data pointed to by args.
args	- Data sent with request, zero if alen is zero.
client	- Client's identify (see common description).

Returns: SFS_OK a null response is sent.; SFS_DATA error.code length of the data to be sent. error.message contains the data to be sent. o/w one of SFS_ERROR, SFS_REDIRECT, or SFS_STALL.

Reimplemented from XrdSfsFile.

◆ FName()

const char * XrdOfsFile::FName ( )

inlinevirtual

Get the file path.

Returns: Null terminated string of the path used in open().

Implements XrdSfsFile.

References XrdOfsHandle::Name(), and oh.

◆ GenFWEvent()

void XrdOfsFile::GenFWEvent ( )

private

◆ getCXinfo()

int XrdOfsFile::getCXinfo	(	char	cxtype[4],
		int &	cxrsz
	)

virtual

Get compression information for the file.

Parameters

cxtype	- Place where the compression algorithm name is to be placed
cxrsz	- Place where the compression page size is to be returned

Returns: One of the valid SFS return codes described above. If the file is not compressed or an error is returned, cxrsz must be set to 0.

Implements XrdSfsFile.

◆ getMmap()

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

virtual

Get file's memory mapping if one exists (memory mapped files only).

Parameters

Addr	- Place where the starting memory address is returned.
Size	- Place where the file's size is returned.

Returns: SFS_OK when the file is memory mapped or any other code otherwise.

Implements XrdSfsFile.

◆ open()

int XrdOfsFile::open	(	const char *	fileName,
		XrdSfsFileOpenMode	openMode,
		mode_t	createMode,
		const XrdSecEntity *	client,
		const char *	opaque = `0`
	)

virtual

Open a file.

Parameters

fileName	- Pointer to the path of the file to be opened.
openMode	- Flags indicating how the open is to be handled. SFS_O_CREAT create the file SFS_O_MKPTH Make directory path if missing SFS_O_NOWAIT do not impose operational delays SFS_O_NOTPC do not allow TPC operation SFS_O_POSC persist only on successful close SFS_O_RAWIO allow client-side decompression SFS_O_RDONLY open read/only SFS_O_RDWR open read/write SFS_O_REPLICA Open for replication SFS_O_RESET Reset any cached information SFS_O_TRUNC truncate existing file to zero length SFS_O_WRONLY open write/only
createMode	- The file's mode if it will be created.
client	- Client's identify (see common description).
opaque	- path's CGI information (see common description).

Returns: One of SFS_OK, SFS_ERROR, SFS_REDIRECT, SFS_STALL, or SFS_STARTED

Implements XrdSfsFile.

◆ pgRead() [1/2]

int XrdOfsFile::pgRead	(	XrdSfsAio *	aioparm,
		uint64_t	opts = `0`
	)

virtual

Read file pages and checksums using asynchronous I/O.

Parameters

aioparm	- Pointer to async I/O object controlling the I/O.
opts	- Processing options (see above).

Returns: SFS_OK Request accepted and will be scheduled.; SFS_ERROR File could not be read, error holds the reason.

Reimplemented from XrdSfsFile.

◆ pgRead() [2/2]

XrdSfsXferSize XrdOfsFile::pgRead	(	XrdSfsFileOffset	offset,
		char *	buffer,
		XrdSfsXferSize	rdlen,
		uint32_t *	csvec,
		uint64_t	opts = `0`
	)

virtual

Read file pages into a buffer and return corresponding checksums.

Parameters

offset	- The offset where the read is to start. It may be unaligned with certain caveats relative to csvec.
buffer	- pointer to buffer where the bytes are to be placed.
rdlen	- The number of bytes to read. The amount must be an integral number of XrdSfsPage::Size bytes.
csvec	- A vector of entries to be filled with the cooresponding CRC32C checksum for each page. However, if the offset is unaligned, then csvec[0] contains the crc for the page fragment that brings it to alignment for csvec[1]. It must be sized to hold all aligned XrdSys::Pagesize crc's plus additional ones for leading and ending page fragments, if any.
opts	- Processing options (see above).

Returns: >= 0 The number of bytes that placed in buffer.; SFS_ERROR File could not be read, error holds the reason.

Reimplemented from XrdSfsFile.

◆ pgWrite() [1/2]

int XrdOfsFile::pgWrite	(	XrdSfsAio *	aioparm,
		uint64_t	opts = `0`
	)

virtual

Write file pages and checksums using asynchronous I/O.

Parameters

aioparm	- Pointer to async I/O object controlling the I/O.
opts	- Processing options (see above).

Returns: SFS_OK Request accepted and will be scheduled.; SFS_ERROR File could not be read, error holds the reason.

Reimplemented from XrdSfsFile.

◆ pgWrite() [2/2]

XrdSfsXferSize XrdOfsFile::pgWrite	(	XrdSfsFileOffset	offset,
		char *	buffer,
		XrdSfsXferSize	wrlen,
		uint32_t *	csvec,
		uint64_t	opts = `0`
	)

virtual

Write file pages into a file with corresponding checksums.

Parameters

offset	- The offset where the write is to start. It may be unaligned with certain caveats relative to csvec.
buffer	- pointer to buffer containing the bytes to write.
wrlen	- The number of bytes to write. If amount is not an integral number of XrdSys::PageSize bytes, then this must be the last write to the file at or above the offset.
csvec	- A vector which contains the corresponding CRC32 checksum for each page or page fragment. If offset is unaligned then csvec[0] is the crc of the leading fragment to align the subsequent full page who's crc is in csvec[1]. It must be sized to hold all aligned XrdSys::Pagesize crc's plus additional ones for leading and ending page fragments, if any.
opts	- Processing options (see above).

Returns: >= 0 The number of bytes written.; SFS_ERROR File could not be read, error holds the reason.

Reimplemented from XrdSfsFile.

◆ read() [1/3]

int XrdOfsFile::read ( XrdSfsAio * aioparm )

virtual

Read file bytes using asynchronous I/O.

Parameters

aioparm - Pointer to async I/O object controlling the I/O.

Returns: SFS_OK Request accepted and will be scheduled.; SFS_ERROR File could not be read, error holds the reason.

Implements XrdSfsFile.

◆ read() [2/3]

XrdSfsXferSize XrdOfsFile::read	(	XrdSfsFileOffset	offset,
		char *	buffer,
		XrdSfsXferSize	size
	)

virtual

Read file bytes into a buffer.

Parameters

offset	- The offset where the read is to start.
buffer	- pointer to buffer where the bytes are to be placed.
size	- The number of bytes to read.

Returns: >= 0 The number of bytes that placed in buffer.; SFS_ERROR File could not be read, error holds the reason.

Implements XrdSfsFile.

◆ read() [3/3]

int XrdOfsFile::read	(	XrdSfsFileOffset	offset,
		XrdSfsXferSize	size
	)

virtual

Preread file blocks into the file system cache.

Parameters

offset	- The offset where the read is to start.
size	- The number of bytes to pre-read.

Returns: >= 0 The number of bytes that will be pre-read.; SFS_ERROR File could not be preread, error holds the reason.

Implements XrdSfsFile.

◆ readv()

XrdSfsXferSize XrdOfsFile::readv	(	XrdOucIOVec *	readV,
		int	rdvCnt
	)

virtual

Given an array of read requests (size rdvCnt), read them from the file and place the contents consecutively in the provided buffer. A dumb default implementation is supplied but should be replaced to increase performance.

Parameters

readV	pointer to the array of read requests.
rdvCnt	the number of elements in readV.

Returns: >=0 The numbe of bytes placed into the buffer.; SFS_ERROR File could not be read, error holds the reason.

Reimplemented from XrdSfsFile.

◆ stat()

int XrdOfsFile::stat ( struct stat * buf )

virtual

Return state information on the file.

Parameters

buf	- Pointer to the structure where info it to be returned.

Returns: One of SFS_OK, SFS_ERROR, SFS_REDIRECT, or SFS_STALL. When SFS_OK is returned, buf must hold stat information.

Implements XrdSfsFile.

◆ sync() [1/2]

int XrdOfsFile::sync ( )

virtual

Make sure all outstanding data is actually written to the file (sync).

Returns: One of SFS_OK, SFS_ERROR, SFS_REDIRECT, SFS_STALL, or SFS_STARTED

Implements XrdSfsFile.

◆ sync() [2/2]

int XrdOfsFile::sync ( XrdSfsAio * aiop )

virtual

Make sure all outstanding data is actually written to the file (async).

Returns: SFS_OK Request accepted and will be scheduled.; SFS_ERROR Request could not be accepted, return error has reason.

Implements XrdSfsFile.

◆ truncate()

int XrdOfsFile::truncate ( XrdSfsFileOffset fsize )

virtual

Truncate the file.

Parameters

fsize - The size that the file is to have.

Returns: One of SFS_OK, SFS_ERROR, SFS_REDIRECT, or SFS_STALL

Implements XrdSfsFile.

◆ write() [1/2]

int XrdOfsFile::write ( XrdSfsAio * aioparm )

virtual

Write file bytes using asynchronous I/O.

Parameters

aioparm - Pointer to async I/O object controlling the I/O.

Returns: 0 Request accepted and will be scheduled.; !0 Request not accepted, returned value is errno.

Implements XrdSfsFile.

◆ write() [2/2]

XrdSfsXferSize XrdOfsFile::write	(	XrdSfsFileOffset	offset,
		const char *	buffer,
		XrdSfsXferSize	size
	)

virtual

Write file bytes from a buffer.

Parameters

offset	- The offset where the write is to start.
buffer	- pointer to buffer where the bytes reside.
size	- The number of bytes to write.

Returns: >= 0 The number of bytes that were written.; SFS_ERROR File could not be written, error holds the reason.

Implements XrdSfsFile.

Member Data Documentation

◆ ckpBad

bool XrdOfsFile::ckpBad

protected

◆ dorawio

int XrdOfsFile::dorawio

protected

◆ myCKP

XrdOucChkPnt* XrdOfsFile::myCKP

protected

◆ myTPC

XrdOfsTPC* XrdOfsFile::myTPC

protected

◆ oh

XrdOfsHandle* XrdOfsFile::oh

protected

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

◆ tident

const char* XrdOfsFile::tident

protected

◆ viaDel

char XrdOfsFile::viaDel

protected

Referenced by ~XrdOfsFile().

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

XrdOfs.hh

Public Member Functions

Protected Attributes

Private Member Functions

Additional Inherited Members

Constructor & Destructor Documentation

◆ XrdOfsFile()

◆ ~XrdOfsFile()

Member Function Documentation

◆ checkpoint()

◆ close()

◆ CreateCKP()

◆ fctl() [1/4]

◆ fctl() [2/4]

◆ fctl() [3/4]

◆ fctl() [4/4]

◆ FName()

◆ GenFWEvent()

◆ getCXinfo()

◆ getMmap()

◆ open()

◆ pgRead() [1/2]

◆ pgRead() [2/2]

◆ pgWrite() [1/2]

◆ pgWrite() [2/2]

◆ read() [1/3]

◆ read() [2/3]

◆ read() [3/3]

◆ readv()

◆ stat()

◆ sync() [1/2]

◆ sync() [2/2]

◆ truncate()

◆ write() [1/2]

◆ write() [2/2]

Member Data Documentation

◆ ckpBad

◆ dorawio

◆ myCKP

◆ myTPC

◆ oh

◆ tident

◆ viaDel