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 ()
 
XrdOucECMsggetECMsg ()
 
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
 

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())) rc = XrdPosixMap::Result(*status,ecMsg,false);
406  else if (!Finalize(&Status)) rc = XrdPosixMap::Result( Status,ecMsg,false);
407 
408 // Issue XrdPosixCallBack callback with the correct result. Errors are indicated
409 // by result set < 0 (typically -1) and errno set to the error number. In our
410 // case, rc is -errno if an error occured and that is what the callback gets.
411 //
412  xeqCB->Complete(rc);
413 
414 // Finish up
415 //
416  delete status;
417  delete response;
418  if (rc < 0) delete this;
419 }
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:150
XrdOucECMsg ecMsg

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

426 {
427 
428 // If the file is not open, then we have no location
429 //
430  if (!clFile.IsOpen()) return "";
431 
432 // If we have no location info, get it
433 //
434  if (!fLoc || refresh)
435  {std::string currNode;
436  if (clFile.GetProperty(dsProperty, currNode))
437  {if (!fLoc || strcmp(fLoc, currNode.c_str()))
438  {if (fLoc) free(fLoc);
439  fLoc = strdup(currNode.c_str());
440  }
441  } else return "";
442  }
443 
444 // Return location information
445 //
446  return fLoc;
447 }
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 453 of file XrdPosixFile.cc.

459 {
460 // Do a sync call using the async interface
461 //
462  pgioCB pgrCB("Posix pgRead CB");
463  pgRead(pgrCB, buff, offs, rlen, csvec, opts, csfix);
464  return pgrCB.Wait4PGIO();
465 }
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 469 of file XrdPosixFile.cc.

476 {
477  XrdCl::XRootDStatus Status;
478  XrdPosixFileRH *rhP;
479 
480 // Allocate callback object. Note the response handler may do additional post
481 // processing.
482 //
483  rhP = XrdPosixFileRH::Alloc(&iocb, this, offs, rlen, XrdPosixFileRH::isReadP);
484 
485 // Set the destination checksum vector
486 //
487  if (csfix) *csfix = 0;
488  rhP->setCSVec(&csvec, csfix, (opts & XrdOucCacheIO::forceCS) != 0);
489 
490 // Issue read
491 //
492  Ref();
493  Status = clFile.PgRead((uint64_t)offs,(uint32_t)rlen,buff,rhP);
494 
495 // Check status, upon error we pass -errno as the result.
496 //
497  if (!Status.IsOK())
498  {rhP->Sched(XrdPosixMap::Result(Status, ecMsg, false));
499  unRef();
500  }
501 }
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, 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 507 of file XrdPosixFile.cc.

513 {
514  XrdCl::XRootDStatus Status;
515 
516 // Preset checksum error count
517 //
518  if (csfix) *csfix = 0;
519 
520 // Issue write and return appropriately. An error returns -1.
521 //
522  Ref();
523  Status = clFile.PgWrite((uint64_t)offs, (uint32_t)wlen, buff, csvec);
524  unRef();
525 
526  return (Status.IsOK() ? wlen : XrdPosixMap::Result(Status,ecMsg,true));
527 }
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, 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 531 of file XrdPosixFile.cc.

538 {
539  XrdCl::XRootDStatus Status;
540  XrdPosixFileRH *rhP;
541 
542 // Allocate callback object. Note that a pgWrite is essentially a normal write
543 // as far as the response handler is concerned.
544 //
545  rhP = XrdPosixFileRH::Alloc(&iocb,this,offs,wlen,XrdPosixFileRH::isWrite);
546 
547 // Set checksum info
548 //
549  if (csfix)
550  {*csfix = 0;
551  rhP->setCSVec(0, csfix);
552  }
553 
554 // Issue write
555 //
556  Ref();
557  Status = clFile.PgWrite((uint64_t)offs, (uint32_t)wlen, buff, csvec, rhP);
558 
559 // Check status, if error pass along -errno as the result.
560 //
561  if (!Status.IsOK())
562  {rhP->Sched(XrdPosixMap::Result(Status,ecMsg,false));
563  unRef();
564  }
565 }

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

572 {
573  XrdCl::XRootDStatus Status;
574  uint32_t bytes;
575 
576 // Handle automatic pgread
577 //
579  {pgioCB pgrCB("Posix pgRead CB");
580  Read(pgrCB, Buff, Offs, Len);
581  return pgrCB.Wait4PGIO();
582  }
583 
584 // Issue read and return appropriately.
585 //
586  Ref();
587  Status = clFile.Read((uint64_t)Offs, (uint32_t)Len, Buff, bytes);
588  unRef();
589 
590  return (Status.IsOK() ? (int)bytes : XrdPosixMap::Result(Status,ecMsg,false));
591 }
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, 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 595 of file XrdPosixFile.cc.

597 {
598  XrdCl::XRootDStatus Status;
599  XrdPosixFileRH *rhP;
601  bool doPgRd = XrdPosixGlobals::autoPGRD;
602 
603 // Allocate correct callback object
604 //
606  rhP = XrdPosixFileRH::Alloc(&iocb, this, offs, rlen, rhT);
607 
608 // Issue read
609 //
610  Ref();
611  if (doPgRd) Status = clFile.PgRead((uint64_t)offs,(uint32_t)rlen,buff,rhP);
612  else Status = clFile.Read ((uint64_t)offs,(uint32_t)rlen,buff,rhP);
613 
614 // Check status. Upon error pass along -errno as the result.
615 //
616  if (!Status.IsOK())
617  {rhP->Sched(XrdPosixMap::Result(Status, ecMsg, false));
618  unRef();
619  }
620 }

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

627 {
628  XrdCl::XRootDStatus Status;
629  XrdCl::ChunkList chunkVec;
630  XrdCl::VectorReadInfo *vrInfo = 0;
631  int nbytes = 0;
632 
633 // Copy in the vector (would be nice if we didn't need to do this)
634 //
635  chunkVec.reserve(n);
636  for (int i = 0; i < n; i++)
637  {nbytes += readV[i].size;
638  chunkVec.push_back(XrdCl::ChunkInfo((uint64_t)readV[i].offset,
639  (uint32_t)readV[i].size,
640  (void *)readV[i].data
641  ));
642  }
643 
644 // Issue the readv. We immediately delete the vrInfo as w don't need it as a
645 // readv will succeed only if actually read the number of bytes requested.
646 //
647  Ref();
648  Status = clFile.VectorRead(chunkVec, (void *)0, vrInfo);
649  unRef();
650  delete vrInfo;
651 
652 // Return appropriate result (here we return -errno as the result)
653 //
654  return (Status.IsOK() ? nbytes : XrdPosixMap::Result(Status, ecMsg, false));
655 }
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, 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 659 of file XrdPosixFile.cc.

660 {
661  XrdCl::XRootDStatus Status;
662  XrdCl::ChunkList chunkVec;
663  int nbytes = 0;
664 
665 // Copy in the vector (would be nice if we didn't need to do this)
666 //
667  chunkVec.reserve(n);
668  for (int i = 0; i < n; i++)
669  {nbytes += readV[i].size;
670  chunkVec.push_back(XrdCl::ChunkInfo((uint64_t)readV[i].offset,
671  (uint32_t)readV[i].size,
672  (void *)readV[i].data
673  ));
674  }
675 
676 // Issue the readv.
677 //
678  XrdPosixFileRH *rhp = XrdPosixFileRH::Alloc(&iocb, this, 0, nbytes,
680  Ref();
681  Status = clFile.VectorRead(chunkVec, (void *)0, rhp);
682 
683 // Return appropriate result
684 //
685  if (!Status.IsOK())
686  {rhp->Sched(XrdPosixMap::Result(Status, ecMsg, false));
687  unRef();
688  }
689 }

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

696 {
697  XrdCl::StatInfo *sInfo = 0;
698 
699 // Get the stat information from the open file
700 //
701  Ref();
702  Status = clFile.Stat(force, sInfo);
703  if (!Status.IsOK())
704  {unRef();
705  delete sInfo;
706  return false;
707  }
708 
709 // Copy over the relevant fields, the stat structure must have been
710 // properly pre-initialized.
711 //
713  myMtime = static_cast<time_t>(sInfo->GetModTime());
714  mySize = static_cast<size_t>(sInfo->GetSize());
715  myInode = static_cast<ino_t>(strtoll(sInfo->GetId().c_str(), 0, 10));
716 
717 // If this is an extended stat then we can get some more info
718 //
719  if (sInfo->ExtendedFormat())
720  {myCtime = static_cast<time_t>(sInfo->GetChangeTime());
721  myAtime = static_cast<time_t>(sInfo->GetAccessTime());
722  } else {
723  myCtime = myMtime;
724  myAtime = time(0);
725  }
726 
727 // Delete our status information and return final result
728 //
729  unRef();
730  delete sInfo;
731  return true;
732 }
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 738 of file XrdPosixFile.cc.

739 {
740  XrdCl::XRootDStatus Status;
741 
742 // Issue the Sync
743 //
744  Ref();
745  Status = clFile.Sync();
746  unRef();
747 
748 // Return result
749 //
750  return XrdPosixMap::Result(Status, ecMsg, false);
751 }
XRootDStatus Sync(ResponseHandler *handler, uint16_t timeout=0) XRD_WARN_UNUSED_RESULT
Definition: XrdClFile.cc:414

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

756 {
757  XrdCl::XRootDStatus Status;
758  XrdPosixFileRH *rhp = XrdPosixFileRH::Alloc(&iocb, this, 0, 0,
760 
761 // Issue read
762 //
763  Status = clFile.Sync(rhp);
764 
765 // Check status
766 //
767  if (!Status.IsOK()) rhp->Sched(XrdPosixMap::Result(Status, ecMsg, false));
768 }

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
offsthe size the file is have.
Returns
<0 - Trunc failed, value is -errno. =0 - Trunc succeeded.

Implements XrdOucCacheIO.

Definition at line 774 of file XrdPosixFile.cc.

775 {
776  XrdCl::XRootDStatus Status;
777 
778 // Issue truncate request
779 //
780  Ref();
781  Status = clFile.Truncate((uint64_t)Offset);
782  unRef();
783 
784 // Return results
785 //
786  return XrdPosixMap::Result(Status,ecMsg,false);
787 }
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, 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 89 of file XrdPosixObject.hh.

89 {return false;}

◆ Who() [2/3]

virtual bool XrdPosixObject::Who
inline

Definition at line 91 of file XrdPosixObject.hh.

91 {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 793 of file XrdPosixFile.cc.

794 {
795  XrdCl::XRootDStatus Status;
796 
797 // Issue write and return appropriately
798 //
799  Ref();
800  Status = clFile.Write((uint64_t)Offs, (uint32_t)Len, Buff);
801  unRef();
802 
803  return (Status.IsOK() ? Len : XrdPosixMap::Result(Status,ecMsg,false));
804 }
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, 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 808 of file XrdPosixFile.cc.

810 {
811  XrdCl::XRootDStatus Status;
812  XrdPosixFileRH *rhp = XrdPosixFileRH::Alloc(&iocb, this, offs, wlen,
814 
815 // Issue write
816 //
817  Ref();
818  Status = clFile.Write((uint64_t)offs, (uint32_t)wlen, buff, rhp);
819 
820 // Check status
821 //
822  if (!Status.IsOK())
823  {rhp->Sched(XrdPosixMap::Result(Status,ecMsg,false));
824  unRef();
825  }
826 }

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

◆ 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: