#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 {

int	fdNum

int	fHandle

};

union {

unsigned long long	cbArg

char *	mmAddr

};

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 aioFob, AsyncMode, XrdSfsFile::error, XrdSfsFile::fctl(), fhProc, FileKey, FileMode, XrdSfsFile::getMmap(), ID, if(), isMMapped, pgwFob, SFS_FCTL_GETFD, SFS_OK, stat, XrdSfsFile::stat(), Stats, and XrdSfsp.

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, fhProc, FileKey, FileMode, pgwFob, Serialize(), TRACEI, 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, and TRACEI.

◆ 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();
}