#include <XrdXrootdFile.hh>

Collaboration diagram for XrdXrootdFile:

Public Member Functions
	XrdXrootdFile (const char id, const char path, XrdSfsFile fp, char mode='r', bool async=false, struct stat sP=0)

	~XrdXrootdFile ()

void	Ref (int num)

void	Serialize ()

Static Public Member Functions
static void	Init (XrdXrootdFileLock lp, XrdSysError erP, bool sfok)

Public Attributes
union {
unsigned long long	cbArg

char *	mmAddr

};

union {
int	fdNum

int	fHandle

};

XrdXrootdAioFob *	aioFob

bool	AsyncMode

XrdXrootdFileHP *	fhProc

char *	FileKey

char	FileMode

const char *	ID

bool	isMMapped

XrdXrootdPgwFob *	pgwFob

bool	sfEnabled

XrdXrootdFileStats	Stats

XrdSfsFile *	XrdSfsp

Detailed Description

Definition at line 100 of file XrdXrootdFile.hh.

Constructor & Destructor Documentation

◆ XrdXrootdFile()

XrdXrootdFile::XrdXrootdFile	(	const char *	id,
		const char *	path,
		XrdSfsFile *	fp,
		char	mode = `'r'`,
		bool	async = `false`,
		struct stat *	sP = `0`
	)

Definition at line 83 of file XrdXrootdFile.cc.

                             : XrdSfsp(fp), mmAddr(0), FileKey(strdup(path)),
                               FileMode(mode), AsyncMode(async),
                               aioFob(0), pgwFob(0), fhProc(0),
                               ID(id), refCount(0), syncWait(0)
 {
     static XrdSysMutex seqMutex;
     struct stat buf;
     off_t mmSize;
  
 // Initialize statistical counters
 //
     Stats.Init();
  
 // Get the file descriptor number for sendfile() processing
 //
    if (!sfOK || fp->fctl(SFS_FCTL_GETFD, 0, fp->error) != SFS_OK)
       {fdNum = -1;
        sfEnabled = false;
       } else {
        fdNum = fp->error.getErrInfo();
        sfEnabled = (fdNum >= 0 || fdNum == (int)SFS_SFIO_FDVAL);
       }
  
 // Determine if file is memory mapped
 //
    if (fp->getMmap((void **)&mmAddr, mmSize) != SFS_OK) isMMapped = false;
       else {isMMapped = (mmSize ? true : false);
             Stats.fSize = static_cast<long long>(mmSize);
            }
  
 // Get file status information (we need it) and optionally return it to caller
 //
    if (sP || !isMMapped)
       {if (!sP) sP = &buf;
        fp->stat(sP);
        if (!isMMapped) Stats.fSize = static_cast<long long>(sP->st_size);
       }
 }

References XrdSfsFile::error, XrdSfsFile::fctl(), XrdXrootdFileStats::fSize, XrdOucErrInfo::getErrInfo(), XrdSfsFile::getMmap(), XrdXrootdFileStats::Init(), isMMapped, XrdXrootdMonInfo::seqMutex, sfEnabled, SFS_FCTL_GETFD, SFS_OK, SFS_SFIO_FDVAL, stat, XrdSfsFile::stat(), and Stats.

Here is the call graph for this function:

◆ ~XrdXrootdFile()

XrdXrootdFile::~XrdXrootdFile ( )

Definition at line 139 of file XrdXrootdFile.cc.

 {
    if (aioFob) aioFob->Reset();
  
    Serialize(); // Make sure there are no outstanding references
  
    if (XrdSfsp)
       {TRACEI(FS, "closing " <<FileMode <<' ' <<FileKey);
        delete XrdSfsp;
        XrdSfsp = 0;
        Locker->Unlock(FileKey, FileMode);
       }
  
    if (fhProc) fhProc->Avail(fHandle);
  
    if (aioFob) delete aioFob;
  
    if (pgwFob) delete pgwFob;
  
    if (FileKey) free(FileKey); // Must be the last thing deleted!
 }

References aioFob, XrdXrootdFileHP::Avail(), fhProc, FileKey, FileMode, pgwFob, XrdXrootdAioFob::Reset(), Serialize(), TRACEI, XrdXrootdFileLock::Unlock(), and XrdSfsp.

Here is the call graph for this function:

Member Function Documentation

◆ Init()

void XrdXrootdFile::Init	(	XrdXrootdFileLock *	lp,
		XrdSysError *	erP,
		bool	sfok
	)

static

Definition at line 128 of file XrdXrootdFile.cc.

 {
    Locker = lp;
    eDest  = erP;
    sfOK   = sfok;
 }

References eDest.

Referenced by XrdXrootdProtocol::Configure().

Here is the caller graph for this function:

◆ Ref()

void XrdXrootdFile::Ref ( int num )

Definition at line 165 of file XrdXrootdFile.cc.

 {
  
 // Change the reference counter and check if anyone is waiting
 //
    fileMutex.Lock();
    refCount += num;
    TRACEI(FSAIO,"File::Ref="<<refCount<<" after +"<<num<<' '<<FileKey);
    if (num < 0 && syncWait && refCount <= 0)
       {syncWait->Post();
        syncWait = nullptr;
       }
    fileMutex.UnLock();
 }

References FileKey, XrdSysMutex::Lock(), XrdSysSemaphore::Post(), TRACEI, and XrdSysMutex::UnLock().

Here is the call graph for this function:

◆ Serialize()

void XrdXrootdFile::Serialize ( )

Definition at line 184 of file XrdXrootdFile.cc.

 {
  
 // Wait until the reference count reaches zero
 //
    fileMutex.Lock();
    TRACEI(FSAIO, "serializing access "<<FileMode<<" Ref="<<refCount<<' '<<FileKey);
    if (refCount > 0)
       {XrdSysSemaphore mySem(0);
        syncWait = &mySem;
        fileMutex.UnLock();
        mySem.Wait();
       } else fileMutex.UnLock();
 }