#include <XrdFileCacheFile.hh>
|
bool | overlap (int blk, long long blk_size, long long req_off, int req_size, long long &off, long long &blk_off, long long &size) |
|
Block * | PrepareBlockRequest (int i, IO *io, bool prefetch) |
|
void | ProcessBlockRequest (Block *b, bool prefetch) |
|
void | ProcessBlockRequests (BlockList_t &blks, bool prefetch) |
|
int | RequestBlocksDirect (IO *io, DirectResponseHandler *handler, IntList_t &blocks, char *buff, long long req_off, long long req_size) |
|
int | ReadBlocksFromDisk (IntList_t &blocks, char *req_buf, long long req_off, long long req_size) |
|
bool | VReadValidate (const XrdOucIOVec *readV, int n) |
|
bool | VReadPreProcess (IO *io, const XrdOucIOVec *readV, int n, ReadVBlockListRAM &blks_to_process, ReadVBlockListDisk &blks_on_disk, std::vector< XrdOucIOVec > &chunkVec) |
|
int | VReadFromDisk (const XrdOucIOVec *readV, int n, ReadVBlockListDisk &blks_on_disk) |
|
int | VReadProcessBlocks (IO *io, const XrdOucIOVec *readV, int n, std::vector< ReadVChunkListRAM > &blks_to_process, std::vector< ReadVChunkListRAM > &blks_rocessed) |
|
long long | BufferSize () |
|
void | inc_ref_count (Block *) |
|
void | dec_ref_count (Block *) |
|
void | free_block (Block *) |
|
bool | select_current_io_or_disable_prefetching (bool skip_current) |
|
int | offsetIdx (int idx) |
|
Enumerator |
---|
kOff |
|
kOn |
|
kHold |
|
kStopped |
|
kComplete |
|
XrdFileCache::File::File |
( |
const std::string & |
path, |
|
|
long long |
offset, |
|
|
long long |
fileSize |
|
) |
| |
XrdFileCache::File::~File |
( |
| ) |
|
void XrdFileCache::File::AddIO |
( |
IO * |
io | ) |
|
void XrdFileCache::File::BlockRemovedFromWriteQ |
( |
Block * |
| ) |
|
long long XrdFileCache::File::BufferSize |
( |
| ) |
|
|
private |
int XrdFileCache::File::dec_ref_cnt |
( |
| ) |
|
|
inline |
void XrdFileCache::File::dec_ref_count |
( |
Block * |
| ) |
|
|
private |
bool XrdFileCache::File::FinalizeSyncBeforeExit |
( |
| ) |
|
void XrdFileCache::File::free_block |
( |
Block * |
| ) |
|
|
private |
int XrdFileCache::File::get_ref_cnt |
( |
| ) |
|
|
inline |
long long XrdFileCache::File::GetFileSize |
( |
| ) |
|
|
inline |
std::string& XrdFileCache::File::GetLocalPath |
( |
| ) |
|
|
inline |
int XrdFileCache::File::GetPrefetchCountOnIO |
( |
IO * |
io | ) |
|
float XrdFileCache::File::GetPrefetchScore |
( |
| ) |
const |
Stats& XrdFileCache::File::GetStats |
( |
| ) |
|
|
inline |
Reference to prefetch statistics.
References m_stats.
int XrdFileCache::File::inc_ref_cnt |
( |
| ) |
|
|
inline |
void XrdFileCache::File::inc_ref_count |
( |
Block * |
| ) |
|
|
private |
bool XrdFileCache::File::ioActive |
( |
IO * |
io | ) |
|
bool XrdFileCache::File::isOpen |
( |
| ) |
const |
|
inline |
Data and cinfo files are open.
References m_is_open.
const char* XrdFileCache::File::lPath |
( |
| ) |
const |
int XrdFileCache::File::offsetIdx |
( |
int |
idx | ) |
|
|
private |
bool XrdFileCache::File::Open |
( |
| ) |
|
Open file handle for data file and info file on local disk.
bool XrdFileCache::File::overlap |
( |
int |
blk, |
|
|
long long |
blk_size, |
|
|
long long |
req_off, |
|
|
int |
req_size, |
|
|
long long & |
off, |
|
|
long long & |
blk_off, |
|
|
long long & |
size |
|
) |
| |
|
private |
void XrdFileCache::File::Prefetch |
( |
| ) |
|
Block* XrdFileCache::File::PrepareBlockRequest |
( |
int |
i, |
|
|
IO * |
io, |
|
|
bool |
prefetch |
|
) |
| |
|
private |
void XrdFileCache::File::ProcessBlockRequest |
( |
Block * |
b, |
|
|
bool |
prefetch |
|
) |
| |
|
private |
void XrdFileCache::File::ProcessBlockRequests |
( |
BlockList_t & |
blks, |
|
|
bool |
prefetch |
|
) |
| |
|
private |
int XrdFileCache::File::Read |
( |
IO * |
io, |
|
|
char * |
buff, |
|
|
long long |
offset, |
|
|
int |
size |
|
) |
| |
int XrdFileCache::File::ReadBlocksFromDisk |
( |
IntList_t & |
blocks, |
|
|
char * |
req_buf, |
|
|
long long |
req_off, |
|
|
long long |
req_size |
|
) |
| |
|
private |
int XrdFileCache::File::ReadV |
( |
IO * |
io, |
|
|
const XrdOucIOVec * |
readV, |
|
|
int |
n |
|
) |
| |
Vector read from disk if block is already downloaded, else ReadV from client.
void XrdFileCache::File::RemoveIO |
( |
IO * |
io | ) |
|
int XrdFileCache::File::RequestBlocksDirect |
( |
IO * |
io, |
|
|
DirectResponseHandler * |
handler, |
|
|
IntList_t & |
blocks, |
|
|
char * |
buff, |
|
|
long long |
req_off, |
|
|
long long |
req_size |
|
) |
| |
|
private |
void XrdFileCache::File::RequestSyncOfDetachStats |
( |
| ) |
|
Flags that detach stats should be written out in final sync. Called from CacheIO upon Detach.
bool XrdFileCache::File::select_current_io_or_disable_prefetching |
( |
bool |
skip_current | ) |
|
|
private |
void XrdFileCache::File::StopPrefetchingOnIO |
( |
IO * |
io | ) |
|
void XrdFileCache::File::Sync |
( |
| ) |
|
Sync file cache inf o and output data with disk.
int XrdFileCache::File::VReadFromDisk |
( |
const XrdOucIOVec * |
readV, |
|
|
int |
n, |
|
|
ReadVBlockListDisk & |
blks_on_disk |
|
) |
| |
|
private |
bool XrdFileCache::File::VReadPreProcess |
( |
IO * |
io, |
|
|
const XrdOucIOVec * |
readV, |
|
|
int |
n, |
|
|
ReadVBlockListRAM & |
blks_to_process, |
|
|
ReadVBlockListDisk & |
blks_on_disk, |
|
|
std::vector< XrdOucIOVec > & |
chunkVec |
|
) |
| |
|
private |
int XrdFileCache::File::VReadProcessBlocks |
( |
IO * |
io, |
|
|
const XrdOucIOVec * |
readV, |
|
|
int |
n, |
|
|
std::vector< ReadVChunkListRAM > & |
blks_to_process, |
|
|
std::vector< ReadVChunkListRAM > & |
blks_rocessed |
|
) |
| |
|
private |
bool XrdFileCache::File::VReadValidate |
( |
const XrdOucIOVec * |
readV, |
|
|
int |
n |
|
) |
| |
|
private |
void XrdFileCache::File::WriteBlockToDisk |
( |
Block * |
b | ) |
|
Info XrdFileCache::File::m_cfi |
|
private |
download status of file blocks and access statistics
IoMap_i XrdFileCache::File::m_current_io |
|
private |
IO object to be used for prefetching.
bool XrdFileCache::File::m_detachTimeIsLogged |
|
private |
std::string XrdFileCache::File::m_filename |
|
private |
long long XrdFileCache::File::m_fileSize |
|
private |
size of cached disk file for block-based operation
Referenced by GetFileSize().
bool XrdFileCache::File::m_in_sync |
|
private |
XrdOssDF* XrdFileCache::File::m_infoFile |
|
private |
file handle for data-info file on disk
IoMap_t XrdFileCache::File::m_io_map |
|
private |
int XrdFileCache::File::m_ios_in_detach |
|
private |
Number of IO objects to which we replied false to ioActive() and will be removed soon.
bool XrdFileCache::File::m_is_open |
|
private |
int XrdFileCache::File::m_non_flushed_cnt |
|
private |
long long XrdFileCache::File::m_offset |
|
private |
offset of cached file for block-based / hdfs operation
file handle for data file on disk
int XrdFileCache::File::m_prefetchHitCnt |
|
private |
int XrdFileCache::File::m_prefetchReadCnt |
|
private |
float XrdFileCache::File::m_prefetchScore |
|
private |
int XrdFileCache::File::m_ref_cnt |
|
private |
Stats XrdFileCache::File::m_stats |
|
private |
cache statistics, used in IO detach
Referenced by GetStats().
const char* XrdFileCache::File::m_traceID |
|
staticprivate |
std::vector<int> XrdFileCache::File::m_writes_during_sync |
|
private |
The documentation for this class was generated from the following file: