xrootd
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
Public Member Functions | Private Member Functions | Private Attributes | List of all members
XrdPfc::IOFileBlock Class Reference

Downloads original file into multiple files, chunked into blocks. Only blocks that are asked for are downloaded. Handles read requests as they come along. More...

#include <XrdPfcIOFileBlock.hh>

Inheritance diagram for XrdPfc::IOFileBlock:
Inheritance graph
[legend]
Collaboration diagram for XrdPfc::IOFileBlock:
Collaboration graph
[legend]

Public Member Functions

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

Private Member Functions

void GetBlockSizeFromPath ()
 
int initLocalStat ()
 
FilenewBlockFile (long long off, int blocksize)
 
void CloseInfoFile ()
 

Private Attributes

long long m_blocksize
 size of file-block More...
 
std::map< int, File * > m_blocks
 map of created blocks More...
 
XrdSysMutex m_mutex
 map mutex More...
 
struct statm_localStat
 
Info m_info
 
XrdOssDFm_info_file
 

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. More...
 
- Protected Member Functions inherited from XrdPfc::IO
const char * GetPath ()
 
std::string GetFilename ()
 
const char * RefreshLocation ()
 
- Protected Member Functions inherited from XrdOucCacheIO
virtual ~XrdOucCacheIO ()
 
- Protected Attributes inherited from XrdPfc::IO
Cachem_cache
 reference to Cache needed in detach More...
 
const char * m_traceID
 

Detailed Description

Downloads original file into multiple files, chunked into blocks. Only blocks that are asked for are downloaded. Handles read requests as they come along.

Constructor & Destructor Documentation

XrdPfc::IOFileBlock::IOFileBlock ( XrdOucCacheIO io,
Cache cache 
)
XrdPfc::IOFileBlock::~IOFileBlock ( )

Member Function Documentation

void XrdPfc::IOFileBlock::CloseInfoFile ( )
private
void XrdPfc::IOFileBlock::DetachFinalize ( )
virtual

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

Implements XrdPfc::IO.

virtual long long XrdPfc::IOFileBlock::FSize ( )
virtual

Obtain size of the file.

Returns
Size of the file in bytes.

Implements XrdOucCacheIO.

virtual int XrdPfc::IOFileBlock::Fstat ( struct stat sbuff)
virtual

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.

void XrdPfc::IOFileBlock::GetBlockSizeFromPath ( )
private
int XrdPfc::IOFileBlock::initLocalStat ( )
private
bool XrdPfc::IOFileBlock::ioActive ( )
virtual

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

Implements XrdPfc::IO.

File* XrdPfc::IOFileBlock::newBlockFile ( long long  off,
int  blocksize 
)
private
virtual int XrdPfc::IOFileBlock::Read ( char *  buff,
long long  offs,
int  rlen 
)
virtual

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.

virtual void XrdPfc::IOFileBlock::Update ( XrdOucCacheIO iocp)
virtual

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.

Member Data Documentation

std::map<int, File*> XrdPfc::IOFileBlock::m_blocks
private

map of created blocks

long long XrdPfc::IOFileBlock::m_blocksize
private

size of file-block

Info XrdPfc::IOFileBlock::m_info
private
XrdOssDF* XrdPfc::IOFileBlock::m_info_file
private
struct stat* XrdPfc::IOFileBlock::m_localStat
private
XrdSysMutex XrdPfc::IOFileBlock::m_mutex
private

map mutex


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