XRootD
Loading...
Searching...
No Matches
XrdPfc::IOFile Class Reference

Downloads original file into a single file on local disk. Handles read requests as they come along. More...

#include <XrdPfcIOFile.hh>

+ Inheritance diagram for XrdPfc::IOFile:
+ Collaboration diagram for XrdPfc::IOFile:

Public Member Functions

 IOFile (XrdOucCacheIO *io, Cache &cache)
 
 ~IOFile ()
 
void DetachFinalize () override
 Abstract virtual method of XrdPfc::IO Called to destruct the IO object after it is no longer used.
 
long long FSize () override
 
int Fstat (struct stat &sbuff) override
 
bool HasFile () const
 Check if File was opened successfully.
 
bool ioActive () override
 Abstract virtual method of XrdPfc::IO Called to check if destruction needs to be done in a separate task.
 
virtual int pgRead (char *buff, long long offs, int rdlen, std::vector< uint32_t > &csvec, uint64_t opts=0, int *csfix=0)
 
void pgRead (XrdOucCacheIOCB &iocb, char *buff, long long off, int size, std::vector< uint32_t > &csvec, uint64_t opts=0, int *csfix=0) override
 
virtual void pgRead (XrdOucCacheIOCB &iocb, char *buff, long long offs, int rdlen, std::vector< uint32_t > &csvec, uint64_t opts=0, int *csfix=0)
 
int Read (char *buff, long long off, int size) override
 Pass Read request to the corresponding File object.
 
void Read (XrdOucCacheIOCB &iocb, char *buff, long long off, int size) override
 
int ReadV (const XrdOucIOVec *readV, int n) override
 Pass ReadV request to the corresponding File object.
 
void ReadV (XrdOucCacheIOCB &iocb, const XrdOucIOVec *readV, int n) override
 
void Update (XrdOucCacheIO &iocp) override
 
- Public Member Functions inherited from XrdPfc::IO
 IO (XrdOucCacheIO *io, Cache &cache)
 
virtual XrdOucCacheIOBase ()
 Original data source.
 
bool Detach (XrdOucCacheIOCD &iocdP) final
 
XrdOucCacheIOGetInput ()
 
const char * GetLocation ()
 
XrdSysTraceGetTrace ()
 
const char * Path () override
 Original data source URL.
 
int Sync () override
 
virtual int Sync ()=0
 
virtual void Sync (XrdOucCacheIOCB &iocb)
 
virtual int Trunc (long long offs)=0
 
int Trunc (long long Offset) override
 
virtual void Trunc (XrdOucCacheIOCB &iocb, long long offs)
 
virtual int Write (char *buff, long long offs, int wlen)=0
 
int Write (char *Buffer, long long Offset, int Length) override
 
virtual void Write (XrdOucCacheIOCB &iocb, char *buff, long long offs, int wlen)
 
- Public Member Functions inherited from XrdOucCacheIO
 XrdOucCacheIO ()
 Construct and Destructor.
 
virtual const char * Location (bool refresh=false)
 
virtual int pgWrite (char *buff, long long offs, int wrlen, std::vector< uint32_t > &csvec, uint64_t opts=0, int *csfix=0)
 
virtual void pgWrite (XrdOucCacheIOCB &iocb, char *buff, long long offs, int wrlen, std::vector< uint32_t > &csvec, uint64_t opts=0, int *csfix=0)
 
virtual void Preread (aprParms &Parms)
 
virtual void Preread (long long offs, int rlen, int opts=0)
 
virtual int WriteV (const XrdOucIOVec *writV, int wnum)
 
virtual void WriteV (XrdOucCacheIOCB &iocb, const XrdOucIOVec *writV, int wnum)
 

Additional Inherited Members

- Static Public Attributes inherited from XrdOucCacheIO
static const uint64_t forceCS = 0x0000000000000001ULL
 
static const int SingleUse = 0x0001
 Mark pages for single use.
 
- Protected Member Functions inherited from XrdPfc::IO
std::string GetFilename ()
 
const char * GetPath ()
 
unsigned short ObtainReadSid ()
 
const char * RefreshLocation ()
 
- Protected Member Functions inherited from XrdOucCacheIO
virtual ~XrdOucCacheIO ()
 
- Protected Attributes inherited from XrdPfc::IO
RAtomic_int m_active_read_reqs
 number of active read requests
 
Cachem_cache
 reference to Cache object
 
const char * m_traceID
 

Detailed Description

Downloads original file into a single file on local disk. Handles read requests as they come along.

Definition at line 39 of file XrdPfcIOFile.hh.

Constructor & Destructor Documentation

◆ IOFile()

IOFile::IOFile ( XrdOucCacheIO * io,
Cache & cache )

Definition at line 36 of file XrdPfcIOFile.cc.

36 :
37 IO(io, cache),
38 m_file(0),
39 m_localStat(0)
40{
41 m_file = Cache::GetInstance().GetFile(GetFilename(), this);
42}
File * GetFile(const std::string &, IO *, long long off=0, long long filesize=0)
Definition XrdPfc.cc:412
static Cache & GetInstance()
Singleton access.
Definition XrdPfc.cc:160
std::string GetFilename()
Definition XrdPfcIO.hh:56
IO(XrdOucCacheIO *io, Cache &cache)
Definition XrdPfcIO.cc:6

References XrdPfc::Cache::GetFile(), XrdPfc::IO::GetFilename(), and XrdPfc::Cache::GetInstance().

+ Here is the call graph for this function:

◆ ~IOFile()

IOFile::~IOFile ( )

Definition at line 45 of file XrdPfcIOFile.cc.

46{
47 // called from Detach() if no sync is needed or
48 // from Cache's sync thread
49 TRACEIO(Debug, "~IOFile() " << this);
50
51 delete m_localStat;
52}
#define TRACEIO(act, x)
bool Debug

References Debug, and TRACEIO.

Member Function Documentation

◆ DetachFinalize()

void IOFile::DetachFinalize ( )
overridevirtual

Abstract virtual method of XrdPfc::IO Called to destruct the IO object after it is no longer used.

Implements XrdPfc::IO.

Definition at line 152 of file XrdPfcIOFile.cc.

153{
154 // Effectively a destructor.
155
156 TRACE(Info, "DetachFinalize() " << this);
157
158 m_file->RequestSyncOfDetachStats();
159 Cache::GetInstance().ReleaseFile(m_file, this);
160
161 delete this;
162}
#define TRACE(act, x)
Definition XrdTrace.hh:63
void ReleaseFile(File *, IO *)
Definition XrdPfc.cc:493
void RequestSyncOfDetachStats()
Flags that detach stats should be written out in final sync. Called from CacheIO upon Detach.
Status of cached file. Can be read from and written into a binary file.
Definition XrdPfcInfo.hh:45

References XrdPfc::Cache::GetInstance(), XrdPfc::Cache::ReleaseFile(), XrdPfc::File::RequestSyncOfDetachStats(), and TRACE.

+ Here is the call graph for this function:

◆ FSize()

long long IOFile::FSize ( )
overridevirtual

Obtain size of the file.

Returns
Size of the file in bytes.

Implements XrdOucCacheIO.

Definition at line 69 of file XrdPfcIOFile.cc.

70{
71 return m_file->GetFileSize();
72}
long long GetFileSize()

References XrdPfc::File::GetFileSize().

+ Here is the call graph for this function:

◆ Fstat()

int IOFile::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 55 of file XrdPfcIOFile.cc.

56{
57 int res = 0;
58 if( ! m_localStat)
59 {
60 res = initCachedStat();
61 if (res) return res;
62 }
63
64 memcpy(&sbuff, m_localStat, sizeof(struct stat));
65 return 0;
66}
#define stat(a, b)
Definition XrdPosix.hh:96

References stat.

◆ HasFile()

bool XrdPfc::IOFile::HasFile ( ) const
inline

Check if File was opened successfully.

Definition at line 49 of file XrdPfcIOFile.hh.

49{ return m_file != 0; }

Referenced by XrdPfc::Cache::Attach().

+ Here is the caller graph for this function:

◆ ioActive()

bool IOFile::ioActive ( )
overridevirtual

Abstract virtual method of XrdPfc::IO Called to check if destruction needs to be done in a separate task.

Implements XrdPfc::IO.

Definition at line 145 of file XrdPfcIOFile.cc.

146{
148 return m_file->ioActive(this);
149}
bool ioActive(IO *io)
Initiate close. Return true if still IO active. Used in XrdPosixXrootd::Close()
const char * RefreshLocation()
Definition XrdPfcIO.hh:57

References XrdPfc::File::ioActive(), and XrdPfc::IO::RefreshLocation().

+ Here is the call graph for this function:

◆ pgRead() [1/3]

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

Reimplemented from XrdOucCacheIO.

Definition at line 190 of file XrdOucCache.cc.

45{
46 (void)csfix;
47 int bytes;
48
49// Read the data into the buffer
50//
51 bytes = Read(buff, offs, rdlen);
52
53// Calculate checksums if so wanted
54//
55 if (bytes > 0 && (opts & forceCS))
56 XrdOucPgrwUtils::csCalc((const char *)buff, (ssize_t)offs,
57 (size_t)bytes, csvec);
58
59// All done
60//
61 return bytes;
62}
struct myOpts opts
static const uint64_t forceCS
static void csCalc(const char *data, off_t offs, size_t count, uint32_t *csval)
int Read(char *buff, long long off, int size) override
Pass Read request to the corresponding File object.

◆ pgRead() [2/3]

void IOFile::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 217 of file XrdPfcIOFile.cc.

219{
220 struct ZHandler : ReadReqRH
221 { using ReadReqRH::ReadReqRH;
222 IOFile *m_io = nullptr;
223 std::function<void (int)> m_lambda {0};
224
225 void Done(int result) override {
226 if (m_lambda) m_lambda(result);
227 m_io->ReadEnd(result, this);
228 }
229 };
230
232
233 auto *rh = new ZHandler(ObtainReadSid(), &iocb);
234 rh->m_io = this;
235
236 TRACEIO(Dump, "pgRead() async " << this << " sid: " << Xrd::hex1 << rh->m_seq_id << " off: " << off << " size: " << size);
237
239 rh->m_lambda = [=, &csvec](int result) {
240 if (result > 0)
241 XrdOucPgrwUtils::csCalc((const char *)buff, (ssize_t)off, (size_t)result, csvec);
242 };
243
244 int retval = ReadBegin(buff, off, size, rh);
245 if (retval != -EWOULDBLOCK)
246 {
247 rh->Done(retval);
248 }
249}
Downloads original file into a single file on local disk. Handles read requests as they come along.
RAtomic_int m_active_read_reqs
number of active read requests
Definition XrdPfcIO.hh:72
unsigned short ObtainReadSid()
Definition XrdPfcIO.hh:59
ReadReqRH(unsigned short sid, XrdOucCacheIOCB *iocb)
Definition XrdPfcFile.hh:67

References XrdPfc::ReadReqRH::ReadReqRH(), XrdOucPgrwUtils::csCalc(), XrdOucCacheIO::forceCS, Xrd::hex1, XrdPfc::IO::m_active_read_reqs, XrdPfc::IO::ObtainReadSid(), opts, and TRACEIO.

+ Here is the call graph for this function:

◆ pgRead() [3/3]

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

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 214 of file XrdOucCache.hh.

221 {iocb.Done(pgRead(buff, offs, rdlen, csvec, opts, csfix));}
virtual void Done(int result)=0
void pgRead(XrdOucCacheIOCB &iocb, char *buff, long long off, int size, std::vector< uint32_t > &csvec, uint64_t opts=0, int *csfix=0) override

◆ Read() [1/2]

int IOFile::Read ( char * buff,
long long off,
int size )
overridevirtual

Pass Read request to the corresponding File object.

Implements XrdOucCacheIO.

Definition at line 170 of file XrdPfcIOFile.cc.

171{
173
174 auto *rh = new ReadReqRHCond(ObtainReadSid(), nullptr);
175
176 TRACEIO(Dump, "Read() sync " << this << " sid: " << Xrd::hex1 << rh->m_seq_id << " off: " << off << " size: " << size);
177
178 rh->m_cond.Lock();
179 int retval = ReadBegin(buff, off, size, rh);
180 if (retval == -EWOULDBLOCK)
181 {
182 rh->m_cond.Wait();
183 retval = rh->m_retval;
184 }
185 rh->m_cond.UnLock();
186
187 return ReadEnd(retval, rh);
188}

References Xrd::hex1, XrdPfc::IO::m_active_read_reqs, XrdPfc::IO::ObtainReadSid(), and TRACEIO.

+ Here is the call graph for this function:

◆ Read() [2/2]

void IOFile::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 191 of file XrdPfcIOFile.cc.

192{
193 struct ZHandler : ReadReqRH
194 { using ReadReqRH::ReadReqRH;
195 IOFile *m_io = nullptr;
196
197 void Done(int result) override {
198 m_io->ReadEnd(result, this);
199 }
200 };
201
203
204 auto *rh = new ZHandler(ObtainReadSid(), &iocb);
205 rh->m_io = this;
206
207 TRACEIO(Dump, "Read() async " << this << " sid: " << Xrd::hex1 << rh->m_seq_id << " off: " << off << " size: " << size);
208
209 int retval = ReadBegin(buff, off, size, rh);
210 if (retval != -EWOULDBLOCK)
211 {
212 rh->Done(retval);
213 }
214}

References XrdPfc::ReadReqRH::ReadReqRH(), Xrd::hex1, XrdPfc::IO::m_active_read_reqs, XrdPfc::IO::ObtainReadSid(), and TRACEIO.

+ Here is the call graph for this function:

◆ ReadV() [1/2]

int IOFile::ReadV ( const XrdOucIOVec * readV,
int n )
overridevirtual

Pass ReadV request to the corresponding File object.

Reimplemented from XrdOucCacheIO.

Definition at line 296 of file XrdPfcIOFile.cc.

297{
299
300 auto *rh = new ReadReqRHCond(ObtainReadSid(), nullptr);
301
302 TRACEIO(Dump, "ReadV() sync " << this << " sid: " << Xrd::hex1 << rh->m_seq_id << " n_chunks: " << n);
303
304 rh->m_cond.Lock();
305 int retval = ReadVBegin(readV, n, rh);
306 if (retval == -EWOULDBLOCK)
307 {
308 rh->m_cond.Wait();
309 retval = rh->m_retval;
310 }
311 rh->m_cond.UnLock();
312 return ReadVEnd(retval, rh);
313}

References Xrd::hex1, XrdPfc::IO::m_active_read_reqs, XrdPfc::ReadReqRH::m_seq_id, XrdPfc::IO::ObtainReadSid(), and TRACEIO.

+ Here is the call graph for this function:

◆ ReadV() [2/2]

void IOFile::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 316 of file XrdPfcIOFile.cc.

317{
318 struct ZHandler : ReadReqRH
319 { using ReadReqRH::ReadReqRH;
320 IOFile *m_io = nullptr;
321
322 void Done(int result) override { m_io-> ReadVEnd(result, this); }
323 };
324
326
327 auto *rh = new ZHandler(ObtainReadSid(), &iocb);
328 rh->m_io = this;
329
330 TRACEIO(Dump, "ReadV() async " << this << " sid: " << Xrd::hex1 << rh->m_seq_id << " n_chunks: " << n);
331
332 int retval = ReadVBegin(readV, n, rh);
333 if (retval != -EWOULDBLOCK)
334 {
335 rh->Done(retval);
336 }
337}

References XrdPfc::ReadReqRH::ReadReqRH(), XrdOucCacheIOCB::Done(), Xrd::hex1, XrdPfc::IO::m_active_read_reqs, XrdPfc::ReadReqRH::m_seq_id, XrdPfc::IO::ObtainReadSid(), and TRACEIO.

+ Here is the call graph for this function:

◆ Update()

void IOFile::Update ( XrdOucCacheIO & iocp)
overridevirtual

Update the originally passed XrdOucCacheIO object with the object passed. All future uses underlying XrdOucCacheIO object must now use this object. Update() is called when Prepare() indicated that the file should not be physically opened and a file method was invoked in the XrdOucCacheIO passed to Attach(). When this occurs, the file is actually opened and Update() called to replace the original XrdOucCacheIO object with one that uses the newly opened file.

Parameters
iocpreference to the new XrdOucCacheIO object.

Reimplemented from XrdPfc::IO.

Definition at line 138 of file XrdPfcIOFile.cc.

139{
140 IO::Update(iocp);
141 m_file->ioUpdated(this);
142}
void ioUpdated(IO *io)
Notification from IO that it has been updated (remote open).
void Update(XrdOucCacheIO &iocp) override
Definition XrdPfcIO.cc:16

References XrdPfc::File::ioUpdated(), and XrdPfc::IO::Update().

+ Here is the call graph for this function:

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