XRootD
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...
 
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 () const
 
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 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 XrdPosixDirDir (int fildes, bool glk=false)
 
static XrdPosixFileFile (int fildes, bool glk=false)
 
static int Init (int numfd)
 
static void Release (XrdPosixObject *oP, bool needlk=true)
 
static XrdPosixDirReleaseDir (int fildes)
 
static XrdPosixFileReleaseFile (int fildes)
 
static void Shutdown ()
 
static bool Valid (int fd)
 
- Static Public Member Functions inherited from XrdCl::ResponseHandler
static ResponseHandlerWrap (std::function< void(XRootDStatus &, AnyObject &)> func)
 
static ResponseHandlerWrap (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
 
XrdPosixPrepIOPrepIO
 
XrdOucCacheIOXCio
 
- Public Attributes inherited from XrdPosixObject
XrdOucECMsg ecMsg
 
std::mutex ecMutex
 

Static Public Attributes

static XrdPosixFileddList = InitDDL()
 
static XrdPosixFileddLost = 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.

123  : XCio((XrdOucCacheIO *)this), PrepIO(0),
124  mySize(0), myAtime(0), myCtime(0), myMtime(0), myRdev(0),
125  myInode(0), myMode(0), theCB(cbP), fLoc(0), cOpt(0),
126  isStream(Opts & isStrm ? 1 : 0)
127 {
128 // Handle path generation. This is trickt as we may have two namespaces. One
129 // for the origin and one for the cache.
130 //
131  fOpen = strdup(path); aOK = true;
132  if (!XrdPosixGlobals::theN2N || !XrdPosixGlobals::theCache) fPath = fOpen;
133  else if (!XrdPosixXrootPath::P2L("file",path,fPath)) aOK = false;
134  else if (!fPath) fPath = fOpen;
135 
136 // Check for structured file check
137 //
138  if (sfSFX)
139  {int n = strlen(path);
140  if (n > sfSLN && !strcmp(sfSFX, path + n - sfSLN))
141  cOpt = XrdOucCache::optFIS;
142  }
143 
144 // Set cache update option
145 //
146  if (Opts & isUpdt) cOpt |= XrdOucCache::optRW;
147 }
static const int optRW
File is read/write (o/w read/only)
Definition: XrdOucCache.hh:517
static const int optFIS
File is structured (e.g. root file)
Definition: XrdOucCache.hh:516
static char * sfSFX
static const int isUpdt
static const int isStrm
XrdPosixPrepIO * PrepIO
Definition: XrdPosixFile.hh:66
static short sfSLN
XrdOucCacheIO * XCio
Definition: XrdPosixFile.hh:65
static const char * P2L(const char *who, const char *inP, char *&relP, bool ponly=false)
int Opts
Definition: XrdMpxStats.cc:58
XrdOucCache * theCache
XrdOucName2Name * theN2N
Definition: XrdPosixFile.cc:62

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.

154 {
155 // Close the remote connection
156 //
157  if (clFile.IsOpen())
159  XrdCl::XRootDStatus status = clFile.Close();
160  if (!status.IsOK())
162  }
163 
164 // Get rid of deferred open object
165 //
166  if (PrepIO) delete PrepIO;
167 
168 // Free the path and location information
169 //
170  if (fPath) free(fPath);
171  if (fOpen != fPath) free(fOpen);
172  if (fLoc) free(fLoc);
173 }
XRootDStatus Close(ResponseHandler *handler, uint16_t timeout=0) XRD_WARN_UNUSED_RESULT
Definition: XrdClFile.cc:151
bool IsOpen() const
Check if the file is open.
Definition: XrdClFile.cc:846
XrdCl::File clFile
Definition: XrdPosixFile.hh:67
void Count(long long &Dest)
XrdPosixStats Stats
Definition: XrdPosixFile.cc:64
bool IsOK() const
We're fine.
Definition: XrdClStatus.hh:124

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.

70  {updMutex.Lock();
71  currOffset += offs;
72  if (updtSz && currOffset > (long long)mySize)
73  mySize = currOffset;
74  long long retOffset = currOffset;
75  updMutex.UnLock();
76  return retOffset;
77  }
XrdSysRecMutex updMutex

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.

311 {
312 // If this is a deferred open, disable any future calls as we are ready to
313 // shutdown this beast!
314 //
315  if (PrepIO) PrepIO->Disable();
316 
317 // If we don't need to close the file, then return success. Otherwise, do the
318 // actual close and return the status. We should have already been removed
319 // from the file table at this point and should be unlocked.
320 //
321  if (clFile.IsOpen())
323  Status = clFile.Close();
324  if (Status.IsOK()) return true;
326  return false;
327  }
328  return true;
329 }

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.

180 {
181 // Static function.
182 // Called within a dedicated thread if there is a reference outstanding to the
183 // file or the file cannot be closed in a clean fashion for some reason.
184 //
185  EPNAME("DDestroy");
186 
188  XrdCl::XRootDStatus Status;
189  std::string statusMsg;
190  const char *eTxt;
191  XrdPosixFile *fCurr, *fNext;
192  char buff[512], buff2[256];
193  static int ddNumLost = 0;
194  int ddCount, refNum;
195  bool doWait = false;
196 
197 // Wait for active I/O to complete
198 //
199 do{if (doWait)
201  doWait = false;
202  } else {
203  ddSem.Wait();
204  doWait = true;
205  continue;
206  }
207 
208 // Grab the delayed delete list
209 //
210  ddMutex.Lock();
211  fNext=ddList; ddList=0; ddPosted=false; ddCount = ddNum; ddNum = 0;
212  ddMutex.UnLock();
213 
214 // Do some debugging
215 //
216  DEBUG("DLY destroy of "<<ddCount<<" objects; "<<ddNumLost <<" already lost.");
217 
218 // Try to delete all the files on the list. If we exceeded the try limit,
219 // remove the file from the list and let it sit forever.
220 //
221  int nowLost = ddNumLost;
222  while((fCurr = fNext))
223  {fNext = fCurr->nextFile;
224  if (!(refNum = fCurr->Refs()))
225  {if (fCurr->Close(Status) || !fCurr->clFile.IsOpen())
226  {delete fCurr; ddCount--; continue;}
227  else {statusMsg = Status.ToString();
228  eTxt = statusMsg.c_str();
229  }
230  } else eTxt = 0;
231 
232  if (fCurr->numTries > XrdPosixGlobals::ddMaxTries)
233  {ddNumLost++; ddCount--;
234  if (!eTxt)
235  {snprintf(buff2, sizeof(buff2), "in use %d", refNum);
236  eTxt = buff2;
237  }
238  if (Say)
239  {snprintf(buff, sizeof(buff), "%s timeout closing", eTxt);
240  Say->Emsg("DDestroy", buff, obfuscateAuth(fCurr->Origin()).c_str());
241  } else {
242  DMSG("DDestroy", eTxt <<" timeout closing " << obfuscateAuth(fCurr->Origin())
243  <<' ' <<ddNumLost <<" objects lost");
244  }
245  fCurr->nextFile = ddLost;
246  ddLost = fCurr;
247  } else {
248  fCurr->numTries++;
249  doWait = true;
250  ddMutex.Lock();
251  fCurr->nextFile = ddList; ddList = fCurr;
252  ddNum++; ddPosted = true;
253  ddMutex.UnLock();
254  }
255  }
256  if (Say && ddNumLost - nowLost >= 3)
257  {snprintf(buff, sizeof(buff), "%d objects deferred and %d lost.",
258  ddCount, ddNumLost);
259  Say->Emsg("DDestroy", buff);
260  } else {
261  DEBUG("DLY destroy end; "<<ddCount<<" objects deferred and "
262  <<ddNumLost <<" lost.");
263  }
264  if (XrdPosixGlobals::theCache && ddNumLost != nowLost)
266  (XrdPosixGlobals::theCache->Statistics.X.ClosedLost), ddNumLost);
267  } while(true);
268 
269  return 0;
270 }
#define DEBUG(x)
Definition: XrdBwmTrace.hh:54
#define EPNAME(x)
Definition: XrdBwmTrace.hh:56
std::string obfuscateAuth(const std::string &input)
#define DMSG(x, y)
void Set(XrdOucCacheStats &S)
XrdOucCacheStats Statistics
Definition: XrdOucCache.hh:686
static XrdSysSemaphore ddSem
static XrdSysMutex ddMutex
static XrdPosixFile * ddLost
static bool ddPosted
static int ddNum
const char * Origin()
bool Close(XrdCl::XRootDStatus &Status)
static XrdPosixFile * ddList
int Emsg(const char *esfx, int ecode, const char *text1, const char *text2=0)
Definition: XrdSysError.cc:95
static void Snooze(int seconds)
Definition: XrdSysTimer.cc:168
XrdSysError Say
XrdSysError * eDest
Definition: XrdPosixFile.cc:63
std::string ToString() const
Create a string representation.
Definition: XrdClStatus.cc:97

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.

275 {
276  EPNAME("DDestroyFP");
277  int ddCount;
278  bool doPost;
279 
280 // Count number of times this has happened (we should have a cache)
281 //
284  (XrdPosixGlobals::theCache->Statistics.X.ClosDefers));
285 
286 // Place this file on the delayed delete list
287 //
288  ddMutex.Lock();
289  fp->nextFile = ddList;
290  ddList = fp;
291  ddNum++; ddCount = ddNum;
292  if (ddPosted) doPost = false;
293  else {doPost = true;
294  ddPosted = true;
295  }
296  fp->numTries = 0;
297  ddMutex.UnLock();
298 
299  if(DEBUGON) {
300  DEBUG("DLY destroy " << (doPost ? "post " : "has ") << ddCount
301  << " objects; added " << obfuscateAuth(fp->Origin()));
302  }
303  if (doPost) ddSem.Post();
304 }
#define DEBUGON
void Count(long long &Dest)

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
iocdreference 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.

88  {(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.

90 {unRef();}

References XrdPosixObject::unRef().

+ Here is the call graph for this function:

◆ Finalize()

bool XrdPosixFile::Finalize ( XrdCl::XRootDStatus Status)

Definition at line 335 of file XrdPosixFile.cc.

336 {
337  XrdOucCacheIO *ioP;
338 
339 // Indicate that we are at the start of the file
340 //
341  currOffset = 0;
342 
343 // Complete initialization. If the stat() fails, the caller will unwind the
344 // whole open process (ick). In the process get correct I/O vector.
345 
346  if (!Status) ioP = (XrdOucCacheIO *)PrepIO;
347  else if (Stat(*Status)) ioP = (XrdOucCacheIO *)this;
348  else return false;
349 
350 // Setup the cache if it is to be used
351 //
353  {XCio = XrdPosixGlobals::theCache->Attach(ioP, cOpt);
354  if (ioP == (XrdOucCacheIO *)PrepIO)
355  XrdPosixGlobals::theCache->Statistics.Add(
357  }
358 
359  return true;
360 }
struct XrdOucCacheStats::CacheStats X
virtual XrdOucCacheIO * Attach(XrdOucCacheIO *ioP, int opts=0)=0
bool Stat(XrdCl::XRootDStatus &Status, bool force=false)

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 94 of file XrdPosixFile.hh.

96  long long retSize = AtomicGet(mySize);
98  return retSize;
99  }
#define AtomicBeg(Mtx)
#define AtomicGet(x)
#define AtomicEnd(Mtx)

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
sbuffreference 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 366 of file XrdPosixFile.cc.

367 {
368  long long theSize;
369 
370 // The size is treated differently here as it may come from a cache and may
371 // actually trigger a file open if the open was deferred.
372 //
373  theSize = XCio->FSize();
374  if (theSize < 0) return static_cast<int>(theSize);
375 
376 // Return what little we can
377 //
379  buf.st_size = theSize;
380  buf.st_atime = myAtime;
381  buf.st_ctime = myCtime;
382  buf.st_mtime = myMtime;
383  buf.st_blocks = buf.st_size/512 + buf.st_size%512;
384  buf.st_ino = myInode;
385  buf.st_rdev = myRdev;
386  buf.st_mode = myMode;
387  return 0;
388 }
virtual long long FSize()=0
static void initStat(struct stat *buf)

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
statusstatus of the request
responsean object associated with the response (request dependent)

Reimplemented from XrdCl::ResponseHandler.

Definition at line 396 of file XrdPosixFile.cc.

398 {
399  XrdCl::XRootDStatus Status;
400  XrdPosixCallBack *xeqCB = theCB;
401  int rc = fdNum;
402 
403 // If no errors occurred, complete the open
404 //
405  if (!(status->IsOK()))
406  {std::unique_lock lock(ecMutex);
407  rc = XrdPosixMap::Result(*status,ecMsg,false);
408  } else if (!Finalize(&Status))
409  {std::unique_lock lock(ecMutex);
410  rc = XrdPosixMap::Result( Status,ecMsg,false);
411  }
412 
413 // Issue XrdPosixCallBack callback with the correct result. Errors are indicated
414 // by result set < 0 (typically -1) and errno set to the error number. In our
415 // case, rc is -errno if an error occurred and that is what the callback gets.
416 //
417  xeqCB->Complete(rc);
418 
419 // Finish up
420 //
421  delete status;
422  delete response;
423  if (rc < 0) delete this;
424 }
An abstract class to define a callback for Open() call.
virtual void Complete(int Result)=0
bool Finalize(XrdCl::XRootDStatus *Status)
static int Result(const XrdCl::XRootDStatus &Status, XrdOucECMsg &ecMsg, bool retneg1=false)
Definition: XrdPosixMap.cc:188
std::mutex ecMutex
XrdOucECMsg ecMsg

References XrdPosixCallBack::Complete(), XrdPosixObject::ecMsg, XrdPosixObject::ecMutex, 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 430 of file XrdPosixFile.cc.

431 {
432 
433 // If the file is not open, then we have no location
434 //
435  if (!clFile.IsOpen()) return "";
436 
437 // If we have no location info, get it
438 //
439  if (!fLoc || refresh)
440  {std::string currNode;
441  if (clFile.GetProperty(dsProperty, currNode))
442  {if (!fLoc || strcmp(fLoc, currNode.c_str()))
443  {if (fLoc) free(fLoc);
444  fLoc = strdup(currNode.c_str());
445  }
446  } else return "";
447  }
448 
449 // Return location information
450 //
451  return fLoc;
452 }
bool GetProperty(const std::string &name, std::string &value) const
Definition: XrdClFile.cc:878

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 112 of file XrdPosixFile.hh.

112 {AtomicRet(updMutex, currOffset);}
#define AtomicRet(mtx, x)

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 114 of file XrdPosixFile.hh.

114 {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 116 of file XrdPosixFile.hh.

116 {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 458 of file XrdPosixFile.cc.

464 {
465 // Do a sync call using the async interface
466 //
467  pgioCB pgrCB("Posix pgRead CB");
468  pgRead(pgrCB, buff, offs, rlen, csvec, opts, csfix);
469  return pgrCB.Wait4PGIO();
470 }
struct myOpts opts
int pgRead(char *buff, long long offs, int rdlen, std::vector< uint32_t > &csvec, uint64_t opts=0, int *csfix=0) override

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
iocbreference 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.
buffpointer to buffer where the bytes are to be placed.
offsThe offset where the read is to start.
rdlenThe number of bytes to read.
csvecA vector which will be filled with the corresponding CRC32C checksum for each page or page segment.
optsProcessing options: forceCS - always return checksums even when not available.
csfixWhen not nil, returns the number of corrected checksum errs.

Reimplemented from XrdOucCacheIO.

Definition at line 474 of file XrdPosixFile.cc.

481 {
482  XrdCl::XRootDStatus Status;
483  XrdPosixFileRH *rhP;
484 
485 // Allocate callback object. Note the response handler may do additional post
486 // processing.
487 //
488  rhP = XrdPosixFileRH::Alloc(&iocb, this, offs, rlen, XrdPosixFileRH::isReadP);
489 
490 // Set the destination checksum vector
491 //
492  if (csfix) *csfix = 0;
493  rhP->setCSVec(&csvec, csfix, (opts & XrdOucCacheIO::forceCS) != 0);
494 
495 // Issue read
496 //
497  Ref();
498  Status = clFile.PgRead((uint64_t)offs,(uint32_t)rlen,buff,rhP);
499 
500 // Check status, upon error we pass -errno as the result.
501 //
502  if (!Status.IsOK())
503  {int rc;
504  {
505  std::unique_lock lock(ecMutex);
506  rc = XrdPosixMap::Result(Status, ecMsg, false);
507  }
508  rhP->Sched(rc);
509  unRef();
510  }
511 }
XRootDStatus PgRead(uint64_t offset, uint32_t size, void *buffer, ResponseHandler *handler, uint16_t timeout=0) XRD_WARN_UNUSED_RESULT
Definition: XrdClFile.cc:245
static const uint64_t forceCS
Definition: XrdOucCache.hh:188
void setCSVec(std::vector< uint32_t > *csv, int *csf, bool fcs=false)
void Sched(int result)
static XrdPosixFileRH * Alloc(XrdOucCacheIOCB *cbp, XrdPosixFile *fp, long long offs, int xResult, ioType typeIO)

References XrdPosixFileRH::Alloc(), clFile, XrdPosixObject::ecMsg, XrdPosixObject::ecMutex, 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
buffpointer to buffer holding the bytes to be written.
offsThe offset where the write is to start.
wrlenThe number of bytes to write. offs+wrlen (i.e. it establishes an end of file).
csvecA vector of that holds the corresponding verified CRC32C checksum for each page or page segment.
optsProcessing options.
csfixWhen 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 517 of file XrdPosixFile.cc.

523 {
524  XrdCl::XRootDStatus Status;
525 
526 // Preset checksum error count
527 //
528  if (csfix) *csfix = 0;
529 
530 // Issue write and return appropriately. An error returns -1.
531 //
532  Ref();
533  Status = clFile.PgWrite((uint64_t)offs, (uint32_t)wlen, buff, csvec);
534  unRef();
535 
536  if (Status.IsOK()) return wlen;
537  else
538  {std::unique_lock lock(ecMutex);
539  return XrdPosixMap::Result(Status,ecMsg,true);
540  }
541 }
XRootDStatus PgWrite(uint64_t offset, uint32_t size, const void *buffer, std::vector< uint32_t > &cksums, ResponseHandler *handler, uint16_t timeout=0) XRD_WARN_UNUSED_RESULT
Definition: XrdClFile.cc:380

References clFile, XrdPosixObject::ecMsg, XrdPosixObject::ecMutex, 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
iocbreference 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.
buffpointer to buffer holding the bytes to be written.
offsThe offset where the write is to start.
wrlenThe number of bytes to write.
csvecA vector of that holds the corresponding verified CRC32C checksum for each page or page segment.
optsProcessing options.
csfixWhen not nil, returns the number of corrected checksum errs.

Reimplemented from XrdOucCacheIO.

Definition at line 545 of file XrdPosixFile.cc.

552 {
553  XrdCl::XRootDStatus Status;
554  XrdPosixFileRH *rhP;
555 
556 // Allocate callback object. Note that a pgWrite is essentially a normal write
557 // as far as the response handler is concerned.
558 //
559  rhP = XrdPosixFileRH::Alloc(&iocb,this,offs,wlen,XrdPosixFileRH::isWrite);
560 
561 // Set checksum info
562 //
563  if (csfix)
564  {*csfix = 0;
565  rhP->setCSVec(0, csfix);
566  }
567 
568 // Issue write
569 //
570  Ref();
571  Status = clFile.PgWrite((uint64_t)offs, (uint32_t)wlen, buff, csvec, rhP);
572 
573 // Check status, if error pass along -errno as the result.
574 //
575  if (!Status.IsOK())
576  {int rc;
577  {
578  std::unique_lock lock(ecMutex);
579  rc = XrdPosixMap::Result(Status,ecMsg,false);
580  }
581  rhP->Sched(rc);
582  unRef();
583  }
584 }

References XrdPosixFileRH::Alloc(), clFile, XrdPosixObject::ecMsg, XrdPosixObject::ecMutex, 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
buffpointer to the buffer to receive the results. The buffer must remain valid until the callback is invoked.
offsthe offset into the file.
rlenthe 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 590 of file XrdPosixFile.cc.

591 {
592  XrdCl::XRootDStatus Status;
593  uint32_t bytes;
594 
595 // Handle automatic pgread
596 //
598  {pgioCB pgrCB("Posix pgRead CB");
599  Read(pgrCB, Buff, Offs, Len);
600  return pgrCB.Wait4PGIO();
601  }
602 
603 // Issue read and return appropriately.
604 //
605  Ref();
606  Status = clFile.Read((uint64_t)Offs, (uint32_t)Len, Buff, bytes);
607  unRef();
608 
609  if (Status.IsOK()) return (int)bytes;
610  else
611  {std::unique_lock lock(ecMutex);
612  return XrdPosixMap::Result(Status,ecMsg,false);
613  }
614 }
XRootDStatus Read(uint64_t offset, uint32_t size, void *buffer, ResponseHandler *handler, uint16_t timeout=0) XRD_WARN_UNUSED_RESULT
Definition: XrdClFile.cc:206
int Read(char *Buff, long long Offs, int Len) override

References XrdPosixGlobals::autoPGRD, clFile, XrdPosixObject::ecMsg, XrdPosixObject::ecMutex, 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
iocbreference 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.
buffpointer to the buffer to receive the results. The buffer must remain valid until the callback is invoked.
offsthe offset into the file.
rlenthe number of bytes to read.

Reimplemented from XrdOucCacheIO.

Definition at line 618 of file XrdPosixFile.cc.

620 {
621  XrdCl::XRootDStatus Status;
622  XrdPosixFileRH *rhP;
624  bool doPgRd = XrdPosixGlobals::autoPGRD;
625 
626 // Allocate correct callback object
627 //
629  rhP = XrdPosixFileRH::Alloc(&iocb, this, offs, rlen, rhT);
630 
631 // Issue read
632 //
633  Ref();
634  if (doPgRd) Status = clFile.PgRead((uint64_t)offs,(uint32_t)rlen,buff,rhP);
635  else Status = clFile.Read ((uint64_t)offs,(uint32_t)rlen,buff,rhP);
636 
637 // Check status. Upon error pass along -errno as the result.
638 //
639  if (!Status.IsOK())
640  {int rc;
641  {
642  std::unique_lock lock(ecMutex);
643  rc = XrdPosixMap::Result(Status, ecMsg, false);
644  }
645  rhP->Sched(rc);
646  unRef();
647  }
648 }

References XrdPosixFileRH::Alloc(), XrdPosixGlobals::autoPGRD, clFile, XrdPosixObject::ecMsg, XrdPosixObject::ecMutex, 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
readVpointer to a vector of read requests.
rnumthe 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 654 of file XrdPosixFile.cc.

655 {
656  XrdCl::XRootDStatus Status;
657  XrdCl::ChunkList chunkVec;
658  XrdCl::VectorReadInfo *vrInfo = 0;
659  int nbytes = 0;
660 
661 // Copy in the vector (would be nice if we didn't need to do this)
662 //
663  chunkVec.reserve(n);
664  for (int i = 0; i < n; i++)
665  {nbytes += readV[i].size;
666  chunkVec.push_back(XrdCl::ChunkInfo((uint64_t)readV[i].offset,
667  (uint32_t)readV[i].size,
668  (void *)readV[i].data
669  ));
670  }
671 
672 // Issue the readv. We immediately delete the vrInfo as w don't need it as a
673 // readv will succeed only if actually read the number of bytes requested.
674 //
675  Ref();
676  Status = clFile.VectorRead(chunkVec, (void *)0, vrInfo);
677  unRef();
678  delete vrInfo;
679 
680 // Return appropriate result (here we return -errno as the result)
681 //
682  if (Status.IsOK()) return nbytes;
683  else
684  {std::unique_lock lock(ecMutex);
685  return XrdPosixMap::Result(Status, ecMsg, false);
686  }
687 }
XRootDStatus VectorRead(const ChunkList &chunks, void *buffer, ResponseHandler *handler, uint16_t timeout=0) XRD_WARN_UNUSED_RESULT
Definition: XrdClFile.cc:468
std::vector< ChunkInfo > ChunkList
List of chunks.
Describe a data chunk for vector read.

References clFile, XrdPosixObject::ecMsg, XrdPosixObject::ecMutex, 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
iocbreference 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.
readVpointer to a vector of read requests.
rnumthe number of elements in the vector.

Reimplemented from XrdOucCacheIO.

Definition at line 691 of file XrdPosixFile.cc.

692 {
693  XrdCl::XRootDStatus Status;
694  XrdCl::ChunkList chunkVec;
695  int nbytes = 0;
696 
697 // Copy in the vector (would be nice if we didn't need to do this)
698 //
699  chunkVec.reserve(n);
700  for (int i = 0; i < n; i++)
701  {nbytes += readV[i].size;
702  chunkVec.push_back(XrdCl::ChunkInfo((uint64_t)readV[i].offset,
703  (uint32_t)readV[i].size,
704  (void *)readV[i].data
705  ));
706  }
707 
708 // Issue the readv.
709 //
710  XrdPosixFileRH *rhp = XrdPosixFileRH::Alloc(&iocb, this, 0, nbytes,
712  Ref();
713  Status = clFile.VectorRead(chunkVec, (void *)0, rhp);
714 
715 // Return appropriate result
716 //
717  if (!Status.IsOK())
718  {int rc;
719  {
720  std::unique_lock lock(ecMutex);
721  rc = XrdPosixMap::Result(Status, ecMsg, false);
722  }
723  rhp->Sched(rc);
724  unRef();
725  }
726 }

References XrdPosixFileRH::Alloc(), clFile, XrdPosixObject::ecMsg, XrdPosixObject::ecMutex, 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 146 of file XrdPosixFile.hh.

147  {updMutex.Lock();
148  currOffset = offs;
149  updMutex.UnLock();
150  return offs;
151  }

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 732 of file XrdPosixFile.cc.

733 {
734  XrdCl::StatInfo *sInfo = 0;
735 
736 // Get the stat information from the open file
737 //
738  Ref();
739  Status = clFile.Stat(force, sInfo);
740  if (!Status.IsOK())
741  {unRef();
742  delete sInfo;
743  return false;
744  }
745 
746 // Copy over the relevant fields, the stat structure must have been
747 // properly pre-initialized.
748 //
750  myMtime = static_cast<time_t>(sInfo->GetModTime());
751  mySize = static_cast<size_t>(sInfo->GetSize());
752  myInode = static_cast<ino_t>(strtoll(sInfo->GetId().c_str(), 0, 10));
753 
754 // If this is an extended stat then we can get some more info
755 //
756  if (sInfo->ExtendedFormat())
757  {myCtime = static_cast<time_t>(sInfo->GetChangeTime());
758  myAtime = static_cast<time_t>(sInfo->GetAccessTime());
759  } else {
760  myCtime = myMtime;
761  myAtime = time(0);
762  }
763 
764 // Delete our status information and return final result
765 //
766  unRef();
767  delete sInfo;
768  return true;
769 }
XRootDStatus Stat(bool force, ResponseHandler *handler, uint16_t timeout=0) XRD_WARN_UNUSED_RESULT
Definition: XrdClFile.cc:177
Object stat info.
uint64_t GetChangeTime() const
Get change time (in seconds since epoch)
uint64_t GetSize() const
Get size (in bytes)
uint32_t GetFlags() const
Get flags.
bool ExtendedFormat() const
Has extended stat information.
const std::string & GetId() const
Get id.
uint64_t GetModTime() const
Get modification time (in seconds since epoch)
uint64_t GetAccessTime() const
Get change time (in seconds since epoch)
static mode_t Flags2Mode(dev_t *rdv, uint32_t flags)
Definition: XrdPosixMap.cc:62

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 775 of file XrdPosixFile.cc.

776 {
777  XrdCl::XRootDStatus Status;
778 
779 // Issue the Sync
780 //
781  Ref();
782  Status = clFile.Sync();
783  unRef();
784 
785 // Return result
786 //
787  std::unique_lock lock(ecMutex);
788  return XrdPosixMap::Result(Status, ecMsg, false);
789 }
XRootDStatus Sync(ResponseHandler *handler, uint16_t timeout=0) XRD_WARN_UNUSED_RESULT
Definition: XrdClFile.cc:414

References clFile, XrdPosixObject::ecMsg, XrdPosixObject::ecMutex, 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
iocbreference 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 793 of file XrdPosixFile.cc.

794 {
795  XrdCl::XRootDStatus Status;
796  XrdPosixFileRH *rhp = XrdPosixFileRH::Alloc(&iocb, this, 0, 0,
798 
799 // Issue read
800 //
801  Status = clFile.Sync(rhp);
802 
803 // Check status
804 //
805  if (!Status.IsOK())
806  {int rc;
807  {
808  std::unique_lock lock(ecMutex);
809  rc = XrdPosixMap::Result(Status, ecMsg, false);
810  }
811  rhp->Sched(rc);
812  }
813 }

References XrdPosixFileRH::Alloc(), clFile, XrdPosixObject::ecMsg, XrdPosixObject::ecMutex, 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
offsthe size the file is have.
Returns
<0 - Trunc failed, value is -errno. =0 - Trunc succeeded.

Implements XrdOucCacheIO.

Definition at line 819 of file XrdPosixFile.cc.

820 {
821  XrdCl::XRootDStatus Status;
822 
823 // Issue truncate request
824 //
825  Ref();
826  Status = clFile.Truncate((uint64_t)Offset);
827  unRef();
828 
829 // Return results
830 //
831  std::unique_lock lock(ecMutex);
832  return XrdPosixMap::Result(Status,ecMsg,false);
833 }
XRootDStatus Truncate(uint64_t size, ResponseHandler *handler, uint16_t timeout=0) XRD_WARN_UNUSED_RESULT
Definition: XrdClFile.cc:440
long long Offset()

References clFile, XrdPosixObject::ecMsg, XrdPosixObject::ecMutex, 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 108 of file XrdPosixFile.hh.

108 {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 161 of file XrdPosixFile.hh.

162  {updMutex.Lock();
163  if (newsz > mySize) mySize = newsz;
164  updMutex.UnLock();
165  }

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 110 of file XrdPosixFile.hh.

110 {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 91 of file XrdPosixObject.hh.

91 {return false;}

◆ Who() [2/3]

virtual bool XrdPosixObject::Who
inline

Definition at line 93 of file XrdPosixObject.hh.

93 {return false;}

◆ Who() [3/3]

bool XrdPosixFile::Who ( XrdPosixFile **  fileP)
inlineoverridevirtual

Reimplemented from XrdPosixObject.

Definition at line 169 of file XrdPosixFile.hh.

170  {*fileP = this; return true;}

◆ Write() [1/2]

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

Perform an synchronous write.

Parameters
buffpointer to the buffer holding the contents. The buffer must remain valid until the callback is invoked.
offsthe offset into the file.
wlenthe 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 839 of file XrdPosixFile.cc.

840 {
841  XrdCl::XRootDStatus Status;
842 
843 // Issue write and return appropriately
844 //
845  Ref();
846  Status = clFile.Write((uint64_t)Offs, (uint32_t)Len, Buff);
847  unRef();
848 
849  if (Status.IsOK()) return Len;
850  else
851  {std::unique_lock lock(ecMutex);
852  return XrdPosixMap::Result(Status,ecMsg,false);
853  }
854 }
XRootDStatus Write(uint64_t offset, uint32_t size, const void *buffer, ResponseHandler *handler, uint16_t timeout=0) XRD_WARN_UNUSED_RESULT
Definition: XrdClFile.cc:286

References clFile, XrdPosixObject::ecMsg, XrdPosixObject::ecMutex, 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
iocbreference 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.
buffpointer to the buffer holding the contents. The buffer must remain valid until the callback is invoked.
offsthe offset into the file.
wlenthe number of bytes to write

Reimplemented from XrdOucCacheIO.

Definition at line 858 of file XrdPosixFile.cc.

860 {
861  XrdCl::XRootDStatus Status;
862  XrdPosixFileRH *rhp = XrdPosixFileRH::Alloc(&iocb, this, offs, wlen,
864 
865 // Issue write
866 //
867  Ref();
868  Status = clFile.Write((uint64_t)offs, (uint32_t)wlen, buff, rhp);
869 
870 // Check status
871 //
872  if (!Status.IsOK())
873  {int rc;
874  {
875  std::unique_lock lock(ecMutex);
876  rc = XrdPosixMap::Result(Status,ecMsg,false);
877  }
878  rhp->Sched(rc);
879  unRef();
880  }
881 }

References XrdPosixFileRH::Alloc(), clFile, XrdPosixObject::ecMsg, XrdPosixObject::ecMutex, 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

◆ ddList

XrdPosixFile * XrdPosixFile::ddList = InitDDL()
static

Definition at line 188 of file XrdPosixFile.hh.

Referenced by DelayedDestroy().

◆ ddLost

XrdPosixFile * XrdPosixFile::ddLost = 0
static

Definition at line 189 of file XrdPosixFile.hh.

Referenced by DelayedDestroy().

◆ ddMutex

XrdSysMutex XrdPosixFile::ddMutex
static

Definition at line 187 of file XrdPosixFile.hh.

Referenced by DelayedDestroy().

◆ ddNum

int XrdPosixFile::ddNum = 0
static

Definition at line 193 of file XrdPosixFile.hh.

Referenced by DelayedDestroy().

◆ ddPosted

bool XrdPosixFile::ddPosted = false
static

Definition at line 192 of file XrdPosixFile.hh.

Referenced by DelayedDestroy().

◆ ddSem

XrdSysSemaphore XrdPosixFile::ddSem
static

Definition at line 186 of file XrdPosixFile.hh.

Referenced by DelayedDestroy().

◆ isStrm

const int XrdPosixFile::isStrm = 2
static

Definition at line 196 of file XrdPosixFile.hh.

◆ isUpdt

const int XrdPosixFile::isUpdt = 4
static

Definition at line 197 of file XrdPosixFile.hh.

Referenced by XrdPosixFile().

◆ myAtime

time_t XrdPosixFile::myAtime

Definition at line 178 of file XrdPosixFile.hh.

Referenced by Fstat(), and Stat().

◆ myCtime

time_t XrdPosixFile::myCtime

Definition at line 179 of file XrdPosixFile.hh.

Referenced by Fstat(), and Stat().

◆ myInode

ino_t XrdPosixFile::myInode

Definition at line 182 of file XrdPosixFile.hh.

Referenced by Fstat(), and Stat().

◆ myMode

mode_t XrdPosixFile::myMode

Definition at line 183 of file XrdPosixFile.hh.

Referenced by Fstat(), and Stat().

◆ myMtime

time_t XrdPosixFile::myMtime

Definition at line 180 of file XrdPosixFile.hh.

Referenced by Fstat(), and Stat().

◆ myRdev

dev_t XrdPosixFile::myRdev

Definition at line 181 of file XrdPosixFile.hh.

Referenced by Fstat(), and Stat().

◆ mySize

size_t XrdPosixFile::mySize

Definition at line 177 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 195 of file XrdPosixFile.hh.

◆ sfSFX

char * XrdPosixFile::sfSFX = 0
static

Definition at line 190 of file XrdPosixFile.hh.

Referenced by XrdPosixFile().

◆ sfSLN

short XrdPosixFile::sfSLN = 0
static

Definition at line 191 of file XrdPosixFile.hh.

Referenced by XrdPosixFile().

◆ XCio


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