XrdPosixFile Class Reference

#include <XrdPosixFile.hh>

Inheritance diagram for XrdPosixFile:

Collaboration diagram for XrdPosixFile:

Public Member Functions
	XrdPosixFile (bool &aOK, const char *path, XrdPosixCallBack *cbP=0, int Opts=0)
	~XrdPosixFile ()
long long	addOffset (long long offs, int updtSz=0)
bool	Close (XrdCl::XRootDStatus &Status)
bool	Detach (XrdOucCacheIOCD &cdP) override
void	DetachDone () override
	Indicate that the CacheIO object has been detached. More...
int	Fcntl (XrdOucCacheOp::Code opc, const std::string &args, std::string &resp) override
bool	Finalize (XrdCl::XRootDStatus *Status)
long long	FSize () override
int	Fstat (struct stat &buf) override
void	HandleResponse (XrdCl::XRootDStatus *status, XrdCl::AnyObject *response) override
const char *	Location (bool refresh=false) override
long long	Offset ()
const char *	Origin ()
const char *	Path () override
int	pgRead (char *buff, long long offs, int rdlen, std::vector< uint32_t > &csvec, uint64_t opts=0, int *csfix=0) override
void	pgRead (XrdOucCacheIOCB &iocb, char *buff, long long offs, int rdlen, std::vector< uint32_t > &csvec, uint64_t opts=0, int *csfix=0) override
int	pgWrite (char *buff, long long offs, int wrlen, std::vector< uint32_t > &csvec, uint64_t opts=0, int *csfix=0) override
void	pgWrite (XrdOucCacheIOCB &iocb, char *buff, long long offs, int wrlen, std::vector< uint32_t > &csvec, uint64_t opts=0, int *csfix=0) override
int	Read (char *Buff, long long Offs, int Len) override
void	Read (XrdOucCacheIOCB &iocb, char *buff, long long offs, int rlen) override
int	ReadV (const XrdOucIOVec *readV, int n) override
void	ReadV (XrdOucCacheIOCB &iocb, const XrdOucIOVec *readV, int n) override
long long	setOffset (long long offs)
bool	Stat (XrdCl::XRootDStatus &Status, bool force=false)
int	Sync () override
void	Sync (XrdOucCacheIOCB &iocb) override
int	Trunc (long long Offset) override
void	updLock ()
void	UpdtSize (size_t newsz)
void	updUnLock ()
virtual bool	Who (XrdPosixDir **dirP)
virtual bool	Who (XrdPosixFile **fileP)
bool	Who (XrdPosixFile **fileP) override
int	Write (char *Buff, long long Offs, int Len) override
void	Write (XrdOucCacheIOCB &iocb, char *buff, long long offs, int wlen) override
Public Member Functions inherited from XrdPosixObject
	XrdPosixObject ()
virtual	~XrdPosixObject ()
bool	AssignFD (bool isStream=false)
int	FDNum ()
XrdOucECMsg *	getECMsg ()
void	Lock (bool wr=true)
void	Ref ()
int	Refs ()
void	UnLock ()
void	unRef ()
virtual bool	Who (XrdPosixDir **dirP)
Public Member Functions inherited from XrdOucCacheIO
	XrdOucCacheIO ()
	Construct and Destructor. More...
virtual void	Preread (aprParms &Parms)
virtual void	Preread (long long offs, int rlen, int opts=0)
virtual void	Preread (XrdOucRangeList &rlist)
virtual void	Trunc (XrdOucCacheIOCB &iocb, long long offs)
virtual void	Update (XrdOucCacheIO &iocp)
virtual int	WriteV (const XrdOucIOVec *writV, int wnum)
virtual void	WriteV (XrdOucCacheIOCB &iocb, const XrdOucIOVec *writV, int wnum)
Public Member Functions inherited from XrdOucCacheIOCD
	XrdOucCacheIOCD ()
virtual	~XrdOucCacheIOCD ()
Public Member Functions inherited from XrdCl::ResponseHandler
virtual	~ResponseHandler ()
virtual void	HandleResponseWithHosts (XRootDStatus *status, AnyObject *response, HostList *hostList)

Static Public Member Functions
static void *	DelayedDestroy (void *)
static void	DelayedDestroy (XrdPosixFile *fp)
Static Public Member Functions inherited from XrdPosixObject
static bool	CanStream ()
static XrdPosixDir *	Dir (int fildes, bool glk=false)
static XrdPosixFile *	File (int fildes, bool glk=false)
static int	Init (int numfd)
static void	Release (XrdPosixObject *oP, bool needlk=true)
static XrdPosixDir *	ReleaseDir (int fildes)
static XrdPosixFile *	ReleaseFile (int fildes)
static void	Shutdown ()
static bool	Valid (int fd)
Static Public Member Functions inherited from XrdCl::ResponseHandler
static ResponseHandler *	Wrap (std::function< void(XRootDStatus &, AnyObject &)> func)
static ResponseHandler *	Wrap (std::function< void(XRootDStatus *, AnyObject *)> func)

Public Attributes
XrdCl::File	clFile
time_t	myAtime
time_t	myCtime
ino_t	myInode
mode_t	myMode
time_t	myMtime
dev_t	myRdev
size_t	mySize
XrdPosixPrepIO *	PrepIO
XrdOucCacheIO *	XCio
Public Attributes inherited from XrdPosixObject
XrdOucECMsg	ecMsg

Static Public Attributes
static XrdPosixFile *	ddList = InitDDL()
static XrdPosixFile *	ddLost = 0
static XrdSysMutex	ddMutex
static int	ddNum = 0
static bool	ddPosted = false
static XrdSysSemaphore	ddSem
static const int	isStrm = 2
static const int	isUpdt = 4
static const int	realFD = 1
static char *	sfSFX = 0
static short	sfSLN = 0
Static Public Attributes inherited from XrdOucCacheIO
static const uint64_t	forceCS = 0x0000000000000001ULL
static const int	SingleUse = 0x0001
	Mark pages for single use. More...

Additional Inherited Members
Protected Member Functions inherited from XrdOucCacheIO
virtual	~XrdOucCacheIO ()
Protected Attributes inherited from XrdPosixObject
int	fdNum
XrdSysRWLock	objMutex
int	refCnt
XrdSysRecMutex	updMutex

Detailed Description

Definition at line 58 of file XrdPosixFile.hh.

Constructor & Destructor Documentation

XrdPosixFile()

XrdPosixFile::XrdPosixFile	(	bool &	aOK,
		const char *	path,
		XrdPosixCallBack *	cbP = 0,
		int	Opts = 0
	)

Definition at line 121 of file XrdPosixFile.cc.

             : XCio((XrdOucCacheIO *)this), PrepIO(0),
               mySize(0), myAtime(0), myCtime(0), myMtime(0), myRdev(0),
               myInode(0), myMode(0), theCB(cbP), fLoc(0), cOpt(0),
               isStream(Opts & isStrm ? 1 : 0)
{
// Handle path generation. This is trickt as we may have two namespaces. One
// for the origin and one for the cache.
//
   fOpen = strdup(path); aOK = true;
   if (!XrdPosixGlobals::theN2N || !XrdPosixGlobals::theCache) fPath = fOpen;
      else if (!XrdPosixXrootPath::P2L("file",path,fPath)) aOK = false;
              else if (!fPath) fPath = fOpen;
 
// Check for structured file check
//
   if (sfSFX)
      {int n = strlen(path);
       if (n > sfSLN && !strcmp(sfSFX, path + n - sfSLN))
          cOpt = XrdOucCache::optFIS;
      }
 
// Set cache update option
//
   if (Opts & isUpdt) cOpt |= XrdOucCache::optRW;
}

References isUpdt, XrdOucCache::optFIS, XrdOucCache::optRW, XrdMpx::Opts, XrdPosixXrootPath::P2L(), sfSFX, sfSLN, XrdPosixGlobals::theCache, and XrdPosixGlobals::theN2N.

Here is the call graph for this function:

~XrdPosixFile()

XrdPosixFile::~XrdPosixFile

(

)

Definition at line 153 of file XrdPosixFile.cc.

{
// Close the remote connection
//
   if (clFile.IsOpen())
      {XrdPosixGlobals::Stats.Count(XrdPosixGlobals::Stats.X.Closes);
       XrdCl::XRootDStatus status = clFile.Close();
       if (!status.IsOK())
          XrdPosixGlobals::Stats.Count(XrdPosixGlobals::Stats.X.CloseErrs);
      }
 
// Get rid of deferred open object
//
   if (PrepIO) delete PrepIO;
 
// Free the path and location information
//
   if (fPath) free(fPath);
   if (fOpen != fPath) free(fOpen);
   if (fLoc)  free(fLoc);
}

References clFile, XrdCl::File::Close(), XrdPosixStats::Count(), XrdCl::Status::IsOK(), XrdCl::File::IsOpen(), PrepIO, and XrdPosixGlobals::Stats.

Here is the call graph for this function:

Member Function Documentation

addOffset()

long long XrdPosixFile::addOffset ( long long  offs, int  updtSz = 0  )

inline

Definition at line 69 of file XrdPosixFile.hh.

                              {updMutex.Lock();
                               currOffset += offs;
                               if (updtSz && currOffset > (long long)mySize)
                                  mySize = currOffset;
                               long long retOffset = currOffset;
                               updMutex.UnLock();
                               return retOffset;
                              }

References XrdSysMutex::Lock(), mySize, XrdSysMutex::UnLock(), and XrdPosixObject::updMutex.

Referenced by XrdPosixXrootd::Lseek(), XrdPosixXrootd::Read(), and XrdPosixXrootd::Write().

Here is the call graph for this function:

Here is the caller graph for this function:

Close()

bool XrdPosixFile::Close

(

XrdCl::XRootDStatus &

Status

)

Definition at line 310 of file XrdPosixFile.cc.

{
// If this is a deferred open, disable any future calls as we are ready to
// shutdown this beast!
//
   if (PrepIO) PrepIO->Disable();
 
// If we don't need to close the file, then return success. Otherwise, do the
// actual close and return the status. We should have already been removed
// from the file table at this point and should be unlocked.
//
   if (clFile.IsOpen())
      {XrdPosixGlobals::Stats.Count(XrdPosixGlobals::Stats.X.Closes);
       Status = clFile.Close();
       if (Status.IsOK()) return true;
       XrdPosixGlobals::Stats.Count(XrdPosixGlobals::Stats.X.CloseErrs);
       return false;
      }
   return true;
}

References clFile, XrdCl::File::Close(), XrdPosixStats::Count(), XrdPosixPrepIO::Disable(), XrdCl::Status::IsOK(), XrdCl::File::IsOpen(), PrepIO, and XrdPosixGlobals::Stats.

Referenced by XrdPosixXrootd::Close(), and DelayedDestroy().

Here is the call graph for this function:

Here is the caller graph for this function:

DelayedDestroy() [1/2]

void * XrdPosixFile::DelayedDestroy ( void *  vpf )

static

Definition at line 179 of file XrdPosixFile.cc.

{
// Static function.
// Called within a dedicated thread if there is a reference outstanding to the
// file or the file cannot be closed in a clean fashion for some reason.
//
   EPNAME("DDestroy");
 
   XrdSysError *Say = XrdPosixGlobals::eDest;
   XrdCl::XRootDStatus Status;
   std::string statusMsg;
   const char *eTxt;
   XrdPosixFile *fCurr, *fNext;
   char buff[512], buff2[256];
   static int ddNumLost = 0;
   int ddCount, refNum;
   bool doWait = false;
 
// Wait for active I/O to complete
//
do{if (doWait)
      {XrdSysTimer::Snooze(XrdPosixGlobals::ddInterval);
       doWait = false;
      } else {
       ddSem.Wait();
       doWait = true;
       continue;
      }
 
// Grab the delayed delete list
//
   ddMutex.Lock();
   fNext=ddList; ddList=0; ddPosted=false; ddCount = ddNum; ddNum = 0;
   ddMutex.UnLock();
 
// Do some debugging
//
   DEBUG("DLY destroy of "<<ddCount<<" objects; "<<ddNumLost <<" already lost.");
 
// Try to delete all the files on the list. If we exceeded the try limit,
// remove the file from the list and let it sit forever.
//
   int nowLost = ddNumLost;
   while((fCurr = fNext))
        {fNext = fCurr->nextFile;
         if (!(refNum = fCurr->Refs()))
            {if (fCurr->Close(Status) || !fCurr->clFile.IsOpen())
                {delete fCurr; ddCount--; continue;}
                else {statusMsg = Status.ToString();
                      eTxt = statusMsg.c_str();
                     }
            } else eTxt = 0;
 
         if (fCurr->numTries > XrdPosixGlobals::ddMaxTries)
            {ddNumLost++; ddCount--;
             if (!eTxt)
                {snprintf(buff2, sizeof(buff2), "in use %d", refNum);
                 eTxt = buff2;
                }
             if (Say)
                {snprintf(buff, sizeof(buff), "%s timeout closing", eTxt);
                 Say->Emsg("DDestroy", buff, obfuscateAuth(fCurr->Origin()).c_str());
                } else {
                 DMSG("DDestroy", eTxt <<" timeout closing " << obfuscateAuth(fCurr->Origin())
                        <<' ' <<ddNumLost <<" objects lost");
                }
             fCurr->nextFile = ddLost;
             ddLost = fCurr;
            } else {
             fCurr->numTries++;
             doWait = true;
             ddMutex.Lock();
             fCurr->nextFile = ddList; ddList = fCurr;
             ddNum++; ddPosted = true;
             ddMutex.UnLock();
            }
        }
        if (Say && ddNumLost - nowLost >= 3)
           {snprintf(buff, sizeof(buff), "%d objects deferred and %d lost.",
                                         ddCount,  ddNumLost);
            Say->Emsg("DDestroy", buff);
           } else {
            DEBUG("DLY destroy end; "<<ddCount<<" objects deferred and "
                             <<ddNumLost <<" lost.");
           }
        if (XrdPosixGlobals::theCache && ddNumLost != nowLost)
           XrdPosixGlobals::theCache->Statistics.Set(
          (XrdPosixGlobals::theCache->Statistics.X.ClosedLost), ddNumLost);
   } while(true);
 
   return 0;
}

References clFile, Close(), XrdPosixGlobals::ddInterval, ddList, ddLost, XrdPosixGlobals::ddMaxTries, ddMutex, ddNum, ddPosted, ddSem, DEBUG, DMSG, XrdPosixGlobals::eDest, XrdSysError::Emsg(), EPNAME, XrdCl::File::IsOpen(), XrdSysMutex::Lock(), obfuscateAuth(), Origin(), XrdPosixObject::Refs(), XrdCms::Say, XrdOucCacheStats::Set(), XrdSysTimer::Snooze(), XrdOucCache::Statistics, XrdPosixGlobals::theCache, XrdCl::Status::ToString(), XrdSysMutex::UnLock(), and XrdSysSemaphore::Wait().

Referenced by XrdPosixXrootd::Close().

Here is the call graph for this function:

Here is the caller graph for this function:

DelayedDestroy() [2/2]

void XrdPosixFile::DelayedDestroy ( XrdPosixFile *  fp )

static

Definition at line 274 of file XrdPosixFile.cc.

{
   EPNAME("DDestroyFP");
   int  ddCount;
   bool doPost;
 
// Count number of times this has happened (we should have a cache)
//
   if (XrdPosixGlobals::theCache)
       XrdPosixGlobals::theCache->Statistics.Count(
         (XrdPosixGlobals::theCache->Statistics.X.ClosDefers));
 
// Place this file on the delayed delete list
//
   ddMutex.Lock();
   fp->nextFile = ddList;
   ddList       = fp;
   ddNum++; ddCount = ddNum;
   if (ddPosted) doPost = false;
      else {doPost   = true;
            ddPosted = true;
           }
   fp->numTries = 0;
   ddMutex.UnLock();
 
   if(DEBUGON) {
     DEBUG("DLY destroy " << (doPost ? "post " : "has ") << ddCount
                          << " objects; added " << obfuscateAuth(fp->Origin()));
   }
   if (doPost) ddSem.Post();
}

References XrdOucCacheStats::Count(), ddList, ddMutex, ddNum, ddPosted, ddSem, DEBUG, DEBUGON, EPNAME, XrdSysMutex::Lock(), obfuscateAuth(), Origin(), XrdSysSemaphore::Post(), XrdOucCache::Statistics, XrdPosixGlobals::theCache, and XrdSysMutex::UnLock().

Here is the call graph for this function:

Detach()

bool XrdPosixFile::Detach ( XrdOucCacheIOCD &  iocd )

inlineoverridevirtual

Detach this CacheIO object from the cache.

Note

This method must be called instead of using the delete operator since CacheIO objects may have multiple outstanding references and actual deletion may need to be deferred.

Parameters

iocd	reference to the detach complete callback object.

Returns

true Deletion can occur immediately. There is no outstanding I/O.

false Deletion must be deferred until it is safe to so from the cache perspective. At which point, the cache will call the DetachDone() method in the passed callback object. No locks may be held with respect to the CacheIO object when this is done to avoid deadlocks.

Implements XrdOucCacheIO.

Definition at line 87 of file XrdPosixFile.hh.

                           {(void)cdP; return true;}

DetachDone()

void XrdPosixFile::DetachDone ( )

inlineoverridevirtual

Indicate that the CacheIO object has been detached.

Implements XrdOucCacheIOCD.

Definition at line 90 of file XrdPosixFile.hh.

{unRef();}

References XrdPosixObject::unRef().

Here is the call graph for this function:

Fcntl()

int XrdPosixFile::Fcntl ( XrdOucCacheOp::Code  opc, const std::string &  args, std::string &  resp  )

overridevirtual

Issue a special file control operation (synchronous).

Parameters

opc	The operation code (one of the enums).
args	The argument as required by opc.
resp	Where the response is to be placed.

Returns

0 upon success or -errno upon failure.

Reimplemented from XrdOucCacheIO.

Definition at line 335 of file XrdPosixFile.cc.

{
   XrdCl::QueryCode::Code qCode; 
 
// Make sure we support the operation code
//
   switch(opc)
         {case XrdOucCacheOp::Code::QFinfo:
                       qCode = XrdCl::QueryCode::Code::FInfo;
                       break;
          default:     resp = "Unsupported operation code.";
                       return -ENOTSUP;
         }
 
// Convert argument to a client buffer
//
   uint32_t sz = args.size();
   if (sz && args[0]) sz++;
   XrdCl::Buffer theArgs(sz);
   if (sz) theArgs.Append(args.c_str(), sz);
 
// We only support the sync version of this, we may need to change that later
//
   XrdCl::Buffer* theResp = 0;
   XrdCl::XRootDStatus Status;
   Ref();
   Status = clFile.Fcntl(qCode, theArgs, theResp);
   unRef();
 
// Check status, upon error we set errno and return -1
//
   if (!Status.IsOK())
      {if (theResp) delete theResp;
       return XrdPosixMap::Result(Status,ecMsg,true);
      }
 
// Construct the response.
//
   if (!theResp || !(sz = theResp->GetSize())) resp = "";
      else resp.assign(theResp->GetBuffer(), sz);
 
// All done
//
   if (theResp) delete theResp;
   return 0;
}

References XrdCl::Buffer::Append(), clFile, XrdPosixObject::ecMsg, XrdCl::File::Fcntl(), XrdCl::Buffer::GetBuffer(), XrdCl::Buffer::GetSize(), XrdCl::Status::IsOK(), XrdPosixObject::Ref(), XrdPosixMap::Result(), and XrdPosixObject::unRef().

Referenced by XrdPosixPrepIO::Fcntl().

Here is the call graph for this function:

Here is the caller graph for this function:

Finalize()

bool XrdPosixFile::Finalize

(

XrdCl::XRootDStatus *

Status

)

Definition at line 387 of file XrdPosixFile.cc.

{
   XrdOucCacheIO *ioP;
 
// Indicate that we are at the start of the file
//
   currOffset = 0;
 
// Complete initialization. If the stat() fails, the caller will unwind the
// whole open process (ick). In the process get correct I/O vector.
 
        if (!Status)       ioP = (XrdOucCacheIO *)PrepIO;
   else if (Stat(*Status)) ioP = (XrdOucCacheIO *)this;
   else return false;
 
// Setup the cache if it is to be used
//
   if (XrdPosixGlobals::theCache)
      {XCio = XrdPosixGlobals::theCache->Attach(ioP, cOpt);
       if (ioP == (XrdOucCacheIO *)PrepIO)
       XrdPosixGlobals::theCache->Statistics.Add(
         (XrdPosixGlobals::theCache->Statistics.X.OpenDefers), 1LL);
      }
 
   return true;
}

References XrdOucCache::Attach(), XrdOucCacheStats::CacheStats::OpenDefers, PrepIO, Stat(), XrdOucCache::Statistics, XrdPosixGlobals::theCache, XrdOucCacheStats::X, and XCio.

Referenced by HandleResponse().

Here is the call graph for this function:

Here is the caller graph for this function:

FSize()

long long XrdPosixFile::FSize ( )

inlineoverridevirtual

Obtain size of the file.

Returns

Size of the file in bytes.

Implements XrdOucCacheIO.

Definition at line 97 of file XrdPosixFile.hh.

                          {AtomicBeg(updMutex);
                           long long retSize = AtomicGet(mySize);
                           AtomicEnd(updMutex);
                           return retSize;
                          }

References AtomicBeg, AtomicEnd, AtomicGet, mySize, and XrdPosixObject::updMutex.

Referenced by XrdPosixPrepIO::FSize().

Here is the caller graph for this function:

Fstat()

int XrdPosixFile::Fstat ( struct stat &  sbuff )

overridevirtual

Perform an fstat() operation (defaults to passthrough).

Parameters

sbuff

reference to the stat buffer to be filled in. Only fields st_size, st_blocks, st_mtime (st_atime and st_ctime may be set to st_mtime), st_ino, and st_mode need to be set. All other fields are preset and should not be changed.

Returns

<0 - fstat failed, value is -errno. =0 - fstat succeeded, sbuff holds stat information. >0 - fstat could not be done, forward operation to next level.

Reimplemented from XrdOucCacheIO.

Definition at line 418 of file XrdPosixFile.cc.

{
   long long theSize;
 
// The size is treated differently here as it may come from a cache and may
// actually trigger a file open if the open was deferred.
//
   theSize = XCio->FSize();
   if (theSize < 0) return static_cast<int>(theSize);
 
// Return what little we can
//
   XrdPosixConfig::initStat(&buf);
   buf.st_size   = theSize;
   buf.st_atime  = myAtime;
   buf.st_ctime  = myCtime;
   buf.st_mtime  = myMtime;
   buf.st_blocks = buf.st_size/512 + buf.st_size%512;
   buf.st_ino    = myInode;
   buf.st_rdev   = myRdev;
   buf.st_mode   = myMode;
   return 0;
}

References XrdOucCacheIO::FSize(), XrdPosixConfig::initStat(), myAtime, myCtime, myInode, myMode, myMtime, myRdev, and XCio.

Referenced by XrdPosixXrootd::Fstat(), and XrdPosixPrepIO::Fstat().

Here is the call graph for this function:

Here is the caller graph for this function:

HandleResponse()

void XrdPosixFile::HandleResponse ( XrdCl::XRootDStatus *  status, XrdCl::AnyObject *  response  )

overridevirtual

Called when a response to associated request arrives or an error occurs

Parameters

status	status of the request
response	an object associated with the response (request dependent)

Reimplemented from XrdCl::ResponseHandler.

Definition at line 448 of file XrdPosixFile.cc.

{
   XrdCl::XRootDStatus Status;
   XrdPosixCallBack *xeqCB = theCB;
   int rc = fdNum;
 
// If no errors occurred, complete the open
//
   if (!(status->IsOK()))          rc = XrdPosixMap::Result(*status,ecMsg,false);
      else if (!Finalize(&Status)) rc = XrdPosixMap::Result( Status,ecMsg,false);
 
// Issue XrdPosixCallBack callback with the correct result. Errors are indicated
// by result set < 0 (typically -1) and errno set to the error number. In our
// case, rc is -errno if an error occurred and that is what the callback gets.
//
   xeqCB->Complete(rc);
 
// Finish up
//
   delete status;
   delete response;
   if (rc < 0) delete this;
}

References XrdPosixCallBack::Complete(), XrdPosixObject::ecMsg, XrdPosixObject::fdNum, Finalize(), XrdCl::Status::IsOK(), and XrdPosixMap::Result().

Here is the call graph for this function:

Location()

const char * XrdPosixFile::Location ( bool  refresh = false )

overridevirtual

Get the file's location (i.e. endpoint hostname and port)

Parameters

refresh

- when true, recomputes the location in case it changed st the location is cached from the previous successful call.

Returns

A pointer to the file's location. It remains valid until the file is closed or Location() is called with refresh set to true. A null string means the file is not open or location is unknown.

Reimplemented from XrdOucCacheIO.

Definition at line 477 of file XrdPosixFile.cc.

{
 
// If the file is not open, then we have no location
//
   if (!clFile.IsOpen()) return "";
 
// If we have no location info, get it
//
   if (!fLoc || refresh)
      {std::string currNode;
       if (clFile.GetProperty(dsProperty, currNode))
          {if (!fLoc || strcmp(fLoc, currNode.c_str()))
              {if (fLoc) free(fLoc);
               fLoc = strdup(currNode.c_str());
              }
          } else return "";
      }
 
// Return location information
//
   return fLoc;
}

References clFile, XrdCl::File::GetProperty(), and XrdCl::File::IsOpen().

Here is the call graph for this function:

Offset()

long long XrdPosixFile::Offset ( )

inline

Definition at line 115 of file XrdPosixFile.hh.

{AtomicRet(updMutex, currOffset);}

References AtomicRet, and XrdPosixObject::updMutex.

Referenced by XrdPosixXrootd::Read(), Trunc(), and XrdPosixXrootd::Write().

Here is the caller graph for this function:

Origin()

const char* XrdPosixFile::Origin ( )

inline

Definition at line 117 of file XrdPosixFile.hh.

{return fOpen;}

Referenced by XrdPosixXrootd::Close(), DelayedDestroy(), and XrdPosixPrepIO::Disable().

Here is the caller graph for this function:

Path()

const char* XrdPosixFile::Path ( )

inlineoverridevirtual

Get the path associated with this object.

Returns

Pointer to the path.

Implements XrdOucCacheIO.

Definition at line 119 of file XrdPosixFile.hh.

{return fPath;}

Referenced by XrdPosixPrepIO::Path().

Here is the caller graph for this function:

pgRead() [1/2]

int XrdPosixFile::pgRead ( char *  buff, long long  offs, int  rdlen, std::vector< uint32_t > &  csvec, uint64_t  opts = 0, int *  csfix = 0  )

overridevirtual

Reimplemented from XrdOucCacheIO.

Definition at line 505 of file XrdPosixFile.cc.

{
// Do a sync call using the async interface
//
   pgioCB pgrCB("Posix pgRead CB");
   pgRead(pgrCB, buff, offs, rlen, csvec, opts, csfix);
   return pgrCB.Wait4PGIO();
}

References opts.

pgRead() [2/2]

void XrdPosixFile::pgRead ( XrdOucCacheIOCB &  iocb, char *  buff, long long  offs, int  rdlen, std::vector< uint32_t > &  csvec, uint64_t  opts = 0, int *  csfix = 0  )

overridevirtual

Read file pages and checksums using asynchronous I/O (default sync).

Parameters

iocb	reference to the callback object that receives the result. All results are returned via this object's Done() method. If the caller holds any locks they must be recursive locks as the callback may occur on the calling thread.
buff	pointer to buffer where the bytes are to be placed.
offs	The offset where the read is to start.
rdlen	The number of bytes to read.
csvec	A vector which will be filled with the corresponding CRC32C checksum for each page or page segment.
opts	Processing options: forceCS - always return checksums even when not available.
csfix	When not nil, returns the number of corrected checksum errs.

Reimplemented from XrdOucCacheIO.

Definition at line 521 of file XrdPosixFile.cc.

{
   XrdCl::XRootDStatus Status;
   XrdPosixFileRH *rhP;
 
// Allocate callback object. Note the response handler may do additional post
// processing.
//
   rhP = XrdPosixFileRH::Alloc(&iocb, this, offs, rlen, XrdPosixFileRH::isReadP);
 
// Set the destination checksum vector
//
   if (csfix) *csfix = 0;
   rhP->setCSVec(&csvec, csfix, (opts & XrdOucCacheIO::forceCS) != 0);
 
// Issue read
//
   Ref();
   Status = clFile.PgRead((uint64_t)offs,(uint32_t)rlen,buff,rhP);
 
// Check status, upon error we pass -errno as the result.
//
   if (!Status.IsOK())
      {rhP->Sched(XrdPosixMap::Result(Status, ecMsg, false));
       unRef();
      }
}

References XrdPosixFileRH::Alloc(), clFile, XrdPosixObject::ecMsg, XrdOucCacheIO::forceCS, XrdCl::Status::IsOK(), XrdPosixFileRH::isReadP, opts, XrdCl::File::PgRead(), XrdPosixObject::Ref(), XrdPosixMap::Result(), XrdPosixFileRH::Sched(), XrdPosixFileRH::setCSVec(), and XrdPosixObject::unRef().

Here is the call graph for this function:

pgWrite() [1/2]

int XrdPosixFile::pgWrite ( char *  buff, long long  offs, int  wrlen, std::vector< uint32_t > &  csvec, uint64_t  opts = 0, int *  csfix = 0  )

overridevirtual

Write file pages from a buffer and corresponding verified checksums.

Parameters

buff	pointer to buffer holding the bytes to be written.
offs	The offset where the write is to start.
wrlen	The number of bytes to write. offs+wrlen (i.e. it establishes an end of file).
csvec	A vector of that holds the corresponding verified CRC32C checksum for each page or page segment.
opts	Processing options.
csfix	When not nil, returns the number of corrected checksum errs.

Returns

>= 0 The number of bytes written.

-errno File could not be written, returned value is the reason.

Reimplemented from XrdOucCacheIO.

Definition at line 559 of file XrdPosixFile.cc.

{
   XrdCl::XRootDStatus Status;
 
// Preset checksum error count
//
   if (csfix) *csfix = 0;
 
// Issue write and return appropriately. An error returns -1.
//
   Ref();
   Status = clFile.PgWrite((uint64_t)offs, (uint32_t)wlen, buff, csvec);
   unRef();
 
   return (Status.IsOK() ? wlen : XrdPosixMap::Result(Status,ecMsg,true));
}

References clFile, XrdPosixObject::ecMsg, XrdCl::Status::IsOK(), XrdCl::File::PgWrite(), XrdPosixObject::Ref(), XrdPosixMap::Result(), and XrdPosixObject::unRef().

Here is the call graph for this function:

pgWrite() [2/2]

void XrdPosixFile::pgWrite ( XrdOucCacheIOCB &  iocb, char *  buff, long long  offs, int  wrlen, std::vector< uint32_t > &  csvec, uint64_t  opts = 0, int *  csfix = 0  )

overridevirtual

Write file pages and checksums using asynchronous I/O (default sync).

Parameters

iocb	reference to the callback object that receives the result. All results are returned via this object's Done() method. If the caller holds any locks they must be recursive locks as the callback may occur on the calling thread.
buff	pointer to buffer holding the bytes to be written.
offs	The offset where the write is to start.
wrlen	The number of bytes to write.
csvec	A vector of that holds the corresponding verified CRC32C checksum for each page or page segment.
opts	Processing options.
csfix	When not nil, returns the number of corrected checksum errs.

Reimplemented from XrdOucCacheIO.

Definition at line 583 of file XrdPosixFile.cc.

{
   XrdCl::XRootDStatus Status;
   XrdPosixFileRH *rhP;
 
// Allocate callback object. Note that a pgWrite is essentially a normal write
// as far as the response handler is concerned.
//
   rhP = XrdPosixFileRH::Alloc(&iocb,this,offs,wlen,XrdPosixFileRH::isWrite);
 
// Set checksum info
//
   if (csfix)
      {*csfix = 0;
       rhP->setCSVec(0, csfix);
      }
 
// Issue write
//
   Ref();
   Status = clFile.PgWrite((uint64_t)offs, (uint32_t)wlen, buff, csvec, rhP);
 
// Check status, if error pass along -errno as the result.
//
   if (!Status.IsOK())
      {rhP->Sched(XrdPosixMap::Result(Status,ecMsg,false));
       unRef();
      }
}

References XrdPosixFileRH::Alloc(), clFile, XrdPosixObject::ecMsg, XrdCl::Status::IsOK(), XrdPosixFileRH::isWrite, XrdCl::File::PgWrite(), XrdPosixObject::Ref(), XrdPosixMap::Result(), XrdPosixFileRH::Sched(), XrdPosixFileRH::setCSVec(), and XrdPosixObject::unRef().

Here is the call graph for this function:

Read() [1/2]

int XrdPosixFile::Read ( char *  buff, long long  offs, int  rlen  )

overridevirtual

Perform an synchronous read.

Parameters

buff	pointer to the buffer to receive the results. The buffer must remain valid until the callback is invoked.
offs	the offset into the file.
rlen	the number of bytes to read.

Returns

< 0 - Read failed, value is -errno. >=0 - Read succeeded, value is number of bytes read.

Implements XrdOucCacheIO.

Definition at line 623 of file XrdPosixFile.cc.

{
   XrdCl::XRootDStatus Status;
   uint32_t bytes;
 
// Handle automatic pgread
//
   if (XrdPosixGlobals::autoPGRD)
      {pgioCB pgrCB("Posix pgRead CB");
       Read(pgrCB, Buff, Offs, Len);
       return pgrCB.Wait4PGIO();
      }
 
// Issue read and return appropriately.
//
   Ref();
   Status = clFile.Read((uint64_t)Offs, (uint32_t)Len, Buff, bytes);
   unRef();
 
   return (Status.IsOK() ? (int)bytes : XrdPosixMap::Result(Status,ecMsg,false));
}

References XrdPosixGlobals::autoPGRD, clFile, XrdPosixObject::ecMsg, XrdCl::Status::IsOK(), XrdCl::File::Read(), XrdPosixObject::Ref(), XrdPosixMap::Result(), and XrdPosixObject::unRef().

Referenced by XrdPosixPrepIO::Read().

Here is the call graph for this function:

Here is the caller graph for this function:

Read() [2/2]

void XrdPosixFile::Read ( XrdOucCacheIOCB &  iocb, char *  buff, long long  offs, int  rlen  )

overridevirtual

Perform an asynchronous read (defaults to synchronous).

Parameters

iocb	reference to the callback object that receives the result. All results are returned via this object's Done() method. If the caller holds any locks they must be recursive locks as the callback may occur on the calling thread.
buff	pointer to the buffer to receive the results. The buffer must remain valid until the callback is invoked.
offs	the offset into the file.
rlen	the number of bytes to read.

Reimplemented from XrdOucCacheIO.

Definition at line 647 of file XrdPosixFile.cc.

{
   XrdCl::XRootDStatus Status;
   XrdPosixFileRH *rhP;
   XrdPosixFileRH::ioType rhT;
   bool doPgRd = XrdPosixGlobals::autoPGRD;
 
// Allocate correct callback object
//
   rhT = (doPgRd ? XrdPosixFileRH::isReadP : XrdPosixFileRH::isRead);
   rhP = XrdPosixFileRH::Alloc(&iocb, this, offs, rlen, rhT);
 
// Issue read
//
   Ref();
   if (doPgRd) Status = clFile.PgRead((uint64_t)offs,(uint32_t)rlen,buff,rhP);
      else     Status = clFile.Read  ((uint64_t)offs,(uint32_t)rlen,buff,rhP);
 
// Check status. Upon error pass along -errno as the result.
//
   if (!Status.IsOK())
      {rhP->Sched(XrdPosixMap::Result(Status, ecMsg, false));
       unRef();
      }
}

References XrdPosixFileRH::Alloc(), XrdPosixGlobals::autoPGRD, clFile, XrdPosixObject::ecMsg, XrdCl::Status::IsOK(), XrdPosixFileRH::isRead, XrdPosixFileRH::isReadP, XrdCl::File::PgRead(), XrdCl::File::Read(), XrdPosixObject::Ref(), XrdPosixMap::Result(), XrdPosixFileRH::Sched(), and XrdPosixObject::unRef().

Here is the call graph for this function:

ReadV() [1/2]

int XrdPosixFile::ReadV ( const XrdOucIOVec *  readV, int  rnum  )

overridevirtual

Perform an synchronous vector read.

Parameters

readV	pointer to a vector of read requests.
rnum	the number of elements in the vector.

Returns

< 0 - ReadV failed, value is -errno. >=0 - ReadV succeeded, value is number of bytes read.

Reimplemented from XrdOucCacheIO.

Definition at line 678 of file XrdPosixFile.cc.

{
   XrdCl::XRootDStatus    Status;
   XrdCl::ChunkList       chunkVec;
   XrdCl::VectorReadInfo *vrInfo = 0;
   int nbytes = 0;
 
// Copy in the vector (would be nice if we didn't need to do this)
//
   chunkVec.reserve(n);
   for (int i = 0; i < n; i++)
       {nbytes += readV[i].size;
        chunkVec.push_back(XrdCl::ChunkInfo((uint64_t)readV[i].offset,
                                            (uint32_t)readV[i].size,
                                            (void   *)readV[i].data
                                           ));
       }
 
// Issue the readv. We immediately delete the vrInfo as w don't need it as a
// readv will succeed only if actually read the number of bytes requested.
//
   Ref();
   Status = clFile.VectorRead(chunkVec, (void *)0, vrInfo);
   unRef();
   delete vrInfo;
 
// Return appropriate result (here we return -errno as the result)
//
   return (Status.IsOK() ? nbytes : XrdPosixMap::Result(Status, ecMsg, false));
}

References clFile, XrdPosixObject::ecMsg, XrdCl::Status::IsOK(), XrdPosixObject::Ref(), XrdPosixMap::Result(), XrdOucIOVec::size, XrdPosixObject::unRef(), and XrdCl::File::VectorRead().

Referenced by XrdPosixPrepIO::ReadV().

Here is the call graph for this function:

Here is the caller graph for this function:

ReadV() [2/2]

void XrdPosixFile::ReadV ( XrdOucCacheIOCB &  iocb, const XrdOucIOVec *  readV, int  rnum  )

overridevirtual

Perform an asynchronous vector read (defaults to synchronous).

Parameters

iocb	reference to the callback object that receives the result. All results are returned via this object's Done() method. If the caller holds any locks they must be recursive locks as the callback may occur on the calling thread.
readV	pointer to a vector of read requests.
rnum	the number of elements in the vector.

Reimplemented from XrdOucCacheIO.

Definition at line 711 of file XrdPosixFile.cc.

{
   XrdCl::XRootDStatus    Status;
   XrdCl::ChunkList       chunkVec;
   int nbytes = 0;
 
// Copy in the vector (would be nice if we didn't need to do this)
//
   chunkVec.reserve(n);
   for (int i = 0; i < n; i++)
       {nbytes += readV[i].size;
        chunkVec.push_back(XrdCl::ChunkInfo((uint64_t)readV[i].offset,
                                            (uint32_t)readV[i].size,
                                            (void   *)readV[i].data
                                           ));
       }
 
// Issue the readv.
//
   XrdPosixFileRH *rhp =  XrdPosixFileRH::Alloc(&iocb, this, 0, nbytes,
                                                XrdPosixFileRH::isReadV);
   Ref();
   Status = clFile.VectorRead(chunkVec, (void *)0, rhp);
 
// Return appropriate result
//
   if (!Status.IsOK())
      {rhp->Sched(XrdPosixMap::Result(Status, ecMsg, false));
       unRef();
      }
}

References XrdPosixFileRH::Alloc(), clFile, XrdPosixObject::ecMsg, XrdCl::Status::IsOK(), XrdPosixFileRH::isReadV, XrdPosixObject::Ref(), XrdPosixMap::Result(), XrdPosixFileRH::Sched(), XrdOucIOVec::size, XrdPosixObject::unRef(), and XrdCl::File::VectorRead().

Here is the call graph for this function:

setOffset()

long long XrdPosixFile::setOffset ( long long  offs )

inline

Definition at line 149 of file XrdPosixFile.hh.

                              {updMutex.Lock();
                               currOffset = offs;
                               updMutex.UnLock();
                               return offs;
                              }

References XrdSysMutex::Lock(), XrdSysMutex::UnLock(), and XrdPosixObject::updMutex.

Referenced by XrdPosixXrootd::Lseek().

Here is the call graph for this function:

Here is the caller graph for this function:

Stat()

bool XrdPosixFile::Stat	(	XrdCl::XRootDStatus &	Status,
		bool	force = false
	)

Definition at line 747 of file XrdPosixFile.cc.

{
   XrdCl::StatInfo *sInfo = 0;
 
// Get the stat information from the open file
//
   Ref();
   Status = clFile.Stat(force, sInfo);
   if (!Status.IsOK())
      {unRef();
       delete sInfo;
       return false;
      }
 
// Copy over the relevant fields, the stat structure must have been
// properly pre-initialized.
//
   myMode  = XrdPosixMap::Flags2Mode(&myRdev, sInfo->GetFlags());
   myMtime = static_cast<time_t>(sInfo->GetModTime());
   mySize  = static_cast<size_t>(sInfo->GetSize());
   myInode = static_cast<ino_t>(strtoll(sInfo->GetId().c_str(), 0, 10));
 
// If this is an extended stat then we can get some more info
//
   if (sInfo->ExtendedFormat())
      {myCtime = static_cast<time_t>(sInfo->GetChangeTime());
       myAtime = static_cast<time_t>(sInfo->GetAccessTime());
      } else {
       myCtime = myMtime;
       myAtime = time(0);
      }
 
// Delete our status information and return final result
//
   unRef();
   delete sInfo;
   return true;
}

References clFile, XrdCl::StatInfo::ExtendedFormat(), XrdPosixMap::Flags2Mode(), XrdCl::StatInfo::GetAccessTime(), XrdCl::StatInfo::GetChangeTime(), XrdCl::StatInfo::GetFlags(), XrdCl::StatInfo::GetId(), XrdCl::StatInfo::GetModTime(), XrdCl::StatInfo::GetSize(), XrdCl::Status::IsOK(), myAtime, myCtime, myInode, myMode, myMtime, myRdev, mySize, XrdPosixObject::Ref(), XrdCl::File::Stat(), and XrdPosixObject::unRef().

Referenced by Finalize().

Here is the call graph for this function:

Here is the caller graph for this function:

Sync() [1/2]

int XrdPosixFile::Sync ( )

overridevirtual

Perform an synchronous sync() operation.

Returns

<0 - Sync failed, value is -errno. =0 - Sync succeeded.

Implements XrdOucCacheIO.

Definition at line 790 of file XrdPosixFile.cc.

{
   XrdCl::XRootDStatus Status;
 
// Issue the Sync
//
   Ref();
   Status = clFile.Sync();
   unRef();
 
// Return result
//
   return XrdPosixMap::Result(Status, ecMsg, false);
}

References clFile, XrdPosixObject::ecMsg, XrdPosixObject::Ref(), XrdPosixMap::Result(), XrdCl::File::Sync(), and XrdPosixObject::unRef().

Referenced by XrdPosixPrepIO::Sync().

Here is the call graph for this function:

Here is the caller graph for this function:

Sync() [2/2]

void XrdPosixFile::Sync ( XrdOucCacheIOCB &  iocb )

overridevirtual

Perform an asynchronous sync() operation (defaults to synchronous).

Parameters

iocb	reference to the callback object that receives the result. All results are returned via this object's Done() method. If the caller holds any locks they must be recursive locks as the callback may occur on the calling thread.

Reimplemented from XrdOucCacheIO.

Definition at line 807 of file XrdPosixFile.cc.

{
   XrdCl::XRootDStatus Status;
   XrdPosixFileRH *rhp =  XrdPosixFileRH::Alloc(&iocb, this, 0, 0,
                                                XrdPosixFileRH::nonIO);
 
// Issue read
//
   Status = clFile.Sync(rhp);
 
// Check status
//
   if (!Status.IsOK()) rhp->Sched(XrdPosixMap::Result(Status, ecMsg, false));
}

References XrdPosixFileRH::Alloc(), clFile, XrdPosixObject::ecMsg, XrdCl::Status::IsOK(), XrdPosixFileRH::nonIO, XrdPosixMap::Result(), XrdPosixFileRH::Sched(), and XrdCl::File::Sync().

Here is the call graph for this function:

Trunc()

int XrdPosixFile::Trunc ( long long  offs )

overridevirtual

Perform an synchronous trunc() operation.

Parameters

offs	the size the file is have.

Returns

<0 - Trunc failed, value is -errno. =0 - Trunc succeeded.

Implements XrdOucCacheIO.

Definition at line 826 of file XrdPosixFile.cc.

{
   XrdCl::XRootDStatus Status;
 
// Issue truncate request
//
   Ref();
   Status = clFile.Truncate((uint64_t)Offset);
   unRef();
 
// Return results
//
   return XrdPosixMap::Result(Status,ecMsg,false);
}

References clFile, XrdPosixObject::ecMsg, Offset(), XrdPosixObject::Ref(), XrdPosixMap::Result(), XrdCl::File::Truncate(), and XrdPosixObject::unRef().

Referenced by XrdPosixPrepIO::Trunc().

Here is the call graph for this function:

Here is the caller graph for this function:

updLock()

void XrdPosixFile::updLock ( )

inline

Definition at line 111 of file XrdPosixFile.hh.

{updMutex.Lock();}

References XrdSysMutex::Lock(), and XrdPosixObject::updMutex.

Referenced by XrdPosixObjGuard::Init().

Here is the call graph for this function:

Here is the caller graph for this function:

UpdtSize()

void XrdPosixFile::UpdtSize ( size_t  newsz )

inline

Definition at line 164 of file XrdPosixFile.hh.

                              {updMutex.Lock();
                               if (newsz > mySize) mySize = newsz;
                               updMutex.UnLock();
                              }

References XrdSysMutex::Lock(), mySize, XrdSysMutex::UnLock(), and XrdPosixObject::updMutex.

Referenced by XrdPosixFileRH::HandleResponse(), XrdPosixExtra::pgWrite(), and XrdPosixXrootd::Pwrite().

Here is the call graph for this function:

Here is the caller graph for this function:

updUnLock()

void XrdPosixFile::updUnLock ( )

inline

Definition at line 113 of file XrdPosixFile.hh.

{updMutex.UnLock();}

References XrdSysMutex::UnLock(), and XrdPosixObject::updMutex.

Referenced by XrdPosixObjGuard::Init(), and XrdPosixObjGuard::Release().

Here is the call graph for this function:

Here is the caller graph for this function:

Who() [1/3]

virtual bool XrdPosixObject::Who

inline

Definition at line 89 of file XrdPosixObject.hh.

{return false;}

Who() [2/3]

virtual bool XrdPosixObject::Who

inline

Definition at line 91 of file XrdPosixObject.hh.

{return false;}

Who() [3/3]

bool XrdPosixFile::Who ( XrdPosixFile **  fileP )

inlineoverridevirtual

Reimplemented from XrdPosixObject.

Definition at line 172 of file XrdPosixFile.hh.

                          {*fileP = this; return true;}

Write() [1/2]

int XrdPosixFile::Write ( char *  buff, long long  offs, int  wlen  )

overridevirtual

Perform an synchronous write.

Parameters

buff	pointer to the buffer holding the contents. The buffer must remain valid until the callback is invoked.
offs	the offset into the file.
wlen	the number of bytes to write

Returns

< 0 - Write failed, value is -errno. >=0 - Write succeeded, value is number of bytes written.

Implements XrdOucCacheIO.

Definition at line 845 of file XrdPosixFile.cc.

{
   XrdCl::XRootDStatus Status;
 
// Issue write and return appropriately
//
   Ref();
   Status = clFile.Write((uint64_t)Offs, (uint32_t)Len, Buff);
   unRef();
 
   return (Status.IsOK() ? Len : XrdPosixMap::Result(Status,ecMsg,false));
}

References clFile, XrdPosixObject::ecMsg, XrdCl::Status::IsOK(), XrdPosixObject::Ref(), XrdPosixMap::Result(), XrdPosixObject::unRef(), and XrdCl::File::Write().

Referenced by XrdPosixPrepIO::Write().

Here is the call graph for this function:

Here is the caller graph for this function:

Write() [2/2]

void XrdPosixFile::Write ( XrdOucCacheIOCB &  iocb, char *  buff, long long  offs, int  wlen  )

overridevirtual

Perform an asynchronous write (defaults to synchronous).

Parameters

iocb	reference to the callback object that receives the result. All results are returned via this object's Done() method. If the caller holds any locks they must be recursive locks as the callback may occur on the calling thread.
buff	pointer to the buffer holding the contents. The buffer must remain valid until the callback is invoked.
offs	the offset into the file.
wlen	the number of bytes to write

Reimplemented from XrdOucCacheIO.

Definition at line 860 of file XrdPosixFile.cc.

{
   XrdCl::XRootDStatus Status;
   XrdPosixFileRH *rhp =  XrdPosixFileRH::Alloc(&iocb, this, offs, wlen,
                                                XrdPosixFileRH::isWrite);
 
// Issue write
//
   Ref();
   Status = clFile.Write((uint64_t)offs, (uint32_t)wlen, buff, rhp);
 
// Check status
//
   if (!Status.IsOK())
      {rhp->Sched(XrdPosixMap::Result(Status,ecMsg,false));
       unRef();
      }
}

References XrdPosixFileRH::Alloc(), clFile, XrdPosixObject::ecMsg, XrdCl::Status::IsOK(), XrdPosixFileRH::isWrite, XrdPosixObject::Ref(), XrdPosixMap::Result(), XrdPosixFileRH::Sched(), XrdPosixObject::unRef(), and XrdCl::File::Write().

Here is the call graph for this function:

Member Data Documentation

clFile

XrdCl::File XrdPosixFile::clFile

Definition at line 67 of file XrdPosixFile.hh.

Referenced by ~XrdPosixFile(), Close(), DelayedDestroy(), XrdPosixXrootd::endPoint(), Fcntl(), Location(), pgRead(), pgWrite(), Read(), ReadV(), Stat(), Sync(), Trunc(), and Write().

ddList

XrdPosixFile * XrdPosixFile::ddList = InitDDL()

static

Definition at line 191 of file XrdPosixFile.hh.

Referenced by DelayedDestroy().

ddLost

XrdPosixFile * XrdPosixFile::ddLost = 0

static

Definition at line 192 of file XrdPosixFile.hh.

Referenced by DelayedDestroy().

ddMutex

XrdSysMutex XrdPosixFile::ddMutex

static

Definition at line 190 of file XrdPosixFile.hh.

Referenced by DelayedDestroy().

ddNum

int XrdPosixFile::ddNum = 0

static

Definition at line 196 of file XrdPosixFile.hh.

Referenced by DelayedDestroy().

ddPosted

bool XrdPosixFile::ddPosted = false

static

Definition at line 195 of file XrdPosixFile.hh.

Referenced by DelayedDestroy().

ddSem

XrdSysSemaphore XrdPosixFile::ddSem

static

Definition at line 189 of file XrdPosixFile.hh.

Referenced by DelayedDestroy().

isStrm

const int XrdPosixFile::isStrm = 2

static

Definition at line 199 of file XrdPosixFile.hh.

isUpdt

const int XrdPosixFile::isUpdt = 4

static

Definition at line 200 of file XrdPosixFile.hh.

Referenced by XrdPosixFile().

myAtime

time_t XrdPosixFile::myAtime

Definition at line 181 of file XrdPosixFile.hh.

Referenced by Fstat(), and Stat().

myCtime

time_t XrdPosixFile::myCtime

Definition at line 182 of file XrdPosixFile.hh.

Referenced by Fstat(), and Stat().

myInode

ino_t XrdPosixFile::myInode

Definition at line 185 of file XrdPosixFile.hh.

Referenced by Fstat(), and Stat().

myMode

mode_t XrdPosixFile::myMode

Definition at line 186 of file XrdPosixFile.hh.

Referenced by Fstat(), and Stat().

myMtime

time_t XrdPosixFile::myMtime

Definition at line 183 of file XrdPosixFile.hh.

Referenced by Fstat(), and Stat().

myRdev

dev_t XrdPosixFile::myRdev

Definition at line 184 of file XrdPosixFile.hh.

Referenced by Fstat(), and Stat().

mySize

size_t XrdPosixFile::mySize

Definition at line 180 of file XrdPosixFile.hh.

Referenced by addOffset(), FSize(), Stat(), and UpdtSize().

PrepIO

XrdPosixPrepIO* XrdPosixFile::PrepIO

Definition at line 66 of file XrdPosixFile.hh.

Referenced by ~XrdPosixFile(), Close(), and Finalize().

realFD

const int XrdPosixFile::realFD = 1

static

Definition at line 198 of file XrdPosixFile.hh.

sfSFX

char * XrdPosixFile::sfSFX = 0

static

Definition at line 193 of file XrdPosixFile.hh.

Referenced by XrdPosixFile().

sfSLN

short XrdPosixFile::sfSLN = 0

static

Definition at line 194 of file XrdPosixFile.hh.

Referenced by XrdPosixFile().

XCio

XrdOucCacheIO* XrdPosixFile::XCio

Definition at line 65 of file XrdPosixFile.hh.

Referenced by XrdPosixXrootd::Close(), XrdPosixExtra::Fctl(), Finalize(), XrdPosixXrootd::Fstat(), Fstat(), XrdPosixXrootd::Fsync(), XrdPosixXrootd::Ftruncate(), XrdPosixXrootd::Lseek(), XrdPosixExtra::pgRead(), XrdPosixExtra::pgWrite(), XrdPosixXrootd::Pread(), XrdPosixXrootd::Pwrite(), XrdPosixXrootd::Read(), XrdPosixXrootd::VRead(), and XrdPosixXrootd::Write().

---

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

• XrdPosixFile.hh
• XrdPosixFile.cc