![]() |
XRootD
|
#include <XrdPfcFile.hh>
Public Member Functions | |
void | AddIO (IO *io) |
void | BlockRemovedFromWriteQ (Block *) |
Handle removal of a block from Cache's write queue. | |
void | BlocksRemovedFromWriteQ (std::list< Block * > &) |
Handle removal of a set of blocks from Cache's write queue. | |
int | dec_ref_cnt () |
bool | FinalizeSyncBeforeExit () |
Returns true if any of blocks need sync. Called from Cache::dec_ref_cnt on zero ref cnt. | |
int | Fstat (struct stat &sbuff) |
int | get_ref_cnt () |
size_t | GetAccessCnt () const |
int | GetBlockSize () const |
long long | GetFileSize () const |
const Info::AStat * | GetLastAccessStats () const |
const std::string & | GetLocalPath () const |
XrdSysError * | GetLog () |
int | GetNBlocks () const |
int | GetNDownloadedBlocks () const |
int | GetPrefetchCountOnIO (IO *io) |
long long | GetPrefetchedBytes () const |
float | GetPrefetchScore () const |
std::string | GetRemoteLocations () const |
XrdSysTrace * | GetTrace () |
int | inc_ref_cnt () |
long long | initiate_emergency_shutdown () |
bool | ioActive (IO *io) |
Initiate close. Return true if still IO active. Used in XrdPosixXrootd::Close() | |
void | ioUpdated (IO *io) |
Notification from IO that it has been updated (remote open). | |
bool | is_in_emergency_shutdown () |
const char * | lPath () const |
Log path. | |
void | Prefetch () |
int | Read (IO *io, char *buff, long long offset, int size, ReadReqRH *rh) |
Normal read. | |
int | ReadV (IO *io, const XrdOucIOVec *readV, int readVnum, ReadReqRH *rh) |
Vector read. | |
const Stats & | RefStats () const |
void | RemoveIO (IO *io) |
void | RequestSyncOfDetachStats () |
Flags that detach stats should be written out in final sync. Called from CacheIO upon Detach. | |
void | StopPrefetchingOnIO (IO *io) |
void | Sync () |
Sync file cache inf o and output data with disk. | |
void | WriteBlockToDisk (Block *b) |
Static Public Member Functions | |
static File * | FileOpen (const std::string &path, long long offset, long long fileSize) |
Static constructor that also does Open. Returns null ptr if Open fails. | |
Friends | |
class | BlockResponseHandler |
class | Cache |
class | DirectResponseHandler |
Definition at line 202 of file XrdPfcFile.hh.
void File::AddIO | ( | IO * | io | ) |
Definition at line 346 of file XrdPfcFile.cc.
References Debug, Error, XrdPfc::IO::GetLocation(), and TRACEF.
Referenced by XrdPfc::Cache::GetFile().
void File::BlockRemovedFromWriteQ | ( | Block * | b | ) |
Handle removal of a block from Cache's write queue.
Definition at line 208 of file XrdPfcFile.cc.
References XrdPfc::Block::m_offset, and TRACEF.
void File::BlocksRemovedFromWriteQ | ( | std::list< Block * > & | blocks | ) |
Handle removal of a set of blocks from Cache's write queue.
Definition at line 216 of file XrdPfcFile.cc.
References TRACEF.
Referenced by XrdPfc::Cache::RemoveWriteQEntriesFor().
|
inline |
Definition at line 288 of file XrdPfcFile.hh.
|
static |
Static constructor that also does Open. Returns null ptr if Open fails.
Definition at line 138 of file XrdPfcFile.cc.
References File.
Referenced by XrdPfc::Cache::GetFile().
bool File::FinalizeSyncBeforeExit | ( | ) |
Returns true if any of blocks need sync. Called from Cache::dec_ref_cnt on zero ref cnt.
Definition at line 322 of file XrdPfcFile.cc.
int File::Fstat | ( | struct stat & | sbuff | ) |
Definition at line 563 of file XrdPfcFile.cc.
References stat.
Referenced by XrdPfc::Cache::ConsiderCached(), and XrdPfc::Cache::Stat().
|
inline |
Definition at line 286 of file XrdPfcFile.hh.
|
inline |
Definition at line 276 of file XrdPfcFile.hh.
|
inline |
Definition at line 277 of file XrdPfcFile.hh.
|
inline |
Definition at line 267 of file XrdPfcFile.hh.
|
inline |
Definition at line 275 of file XrdPfcFile.hh.
|
inline |
Definition at line 262 of file XrdPfcFile.hh.
Referenced by XrdPfc::Cache::AddWriteTask(), and XrdPfc::Cache::ReleaseFile().
XrdSysError * File::GetLog | ( | ) |
Definition at line 1633 of file XrdPfcFile.cc.
References XrdPfc::Cache::GetInstance(), and XrdPfc::Cache::GetLog().
|
inline |
Definition at line 278 of file XrdPfcFile.hh.
|
inline |
Definition at line 279 of file XrdPfcFile.hh.
int XrdPfc::File::GetPrefetchCountOnIO | ( | IO * | io | ) |
|
inline |
Definition at line 280 of file XrdPfcFile.hh.
float File::GetPrefetchScore | ( | ) | const |
Definition at line 1628 of file XrdPfcFile.cc.
std::string File::GetRemoteLocations | ( | ) | const |
Definition at line 1652 of file XrdPfcFile.cc.
XrdSysTrace * File::GetTrace | ( | ) |
Definition at line 1638 of file XrdPfcFile.cc.
References XrdPfc::Cache::GetInstance(), and XrdPfc::Cache::GetTrace().
|
inline |
Definition at line 287 of file XrdPfcFile.hh.
long long File::initiate_emergency_shutdown | ( | ) |
Definition at line 151 of file XrdPfcFile.cc.
Referenced by XrdPfc::Cache::UnlinkFile().
bool File::ioActive | ( | IO * | io | ) |
Initiate close. Return true if still IO active. Used in XrdPosixXrootd::Close()
Definition at line 239 of file XrdPfcFile.cc.
References Debug, Error, XrdPfc::IO::GetLocation(), XrdPfc::IO::m_active_read_reqs, TRACE, and TRACEF.
void File::ioUpdated | ( | IO * | io | ) |
Notification from IO that it has been updated (remote open).
Definition at line 230 of file XrdPfcFile.cc.
References XrdPfc::IO::GetLocation().
|
inline |
Definition at line 291 of file XrdPfcFile.hh.
const char * File::lPath | ( | ) | const |
Log path.
Definition at line 1540 of file XrdPfcFile.cc.
Referenced by XrdPfc::Cache::ProcessWriteTasks(), and XrdPfc::Cache::RemoveWriteQEntriesFor().
void File::Prefetch | ( | ) |
Definition at line 1555 of file XrdPfcFile.cc.
References Debug, Error, and TRACEF.
Referenced by XrdPfc::Cache::Prefetch().
Normal read.
Definition at line 748 of file XrdPfcFile.cc.
References Xrd::hex1, XrdPfc::ReadReqRH::m_seq_id, and TRACEF.
Referenced by XrdPfc::IOFileBlock::Read().
int File::ReadV | ( | IO * | io, |
const XrdOucIOVec * | readV, | ||
int | readVnum, | ||
ReadReqRH * | rh ) |
Vector read.
Definition at line 785 of file XrdPfcFile.cc.
References TRACEF.
|
inline |
Definition at line 281 of file XrdPfcFile.hh.
void File::RemoveIO | ( | IO * | io | ) |
Definition at line 383 of file XrdPfcFile.cc.
References Debug, Error, and TRACEF.
Referenced by XrdPfc::Cache::ReleaseFile().
void File::RequestSyncOfDetachStats | ( | ) |
Flags that detach stats should be written out in final sync. Called from CacheIO upon Detach.
Definition at line 316 of file XrdPfcFile.cc.
void XrdPfc::File::StopPrefetchingOnIO | ( | IO * | io | ) |
void File::Sync | ( | ) |
Sync file cache inf o and output data with disk.
Definition at line 1154 of file XrdPfcFile.cc.
References Error, XrdPfc::Cache::GetInstance(), Sync(), TRACEF, XrdPfc::Cache::UnlinkFile(), and XrdOssOK.
Referenced by Sync().
void File::WriteBlockToDisk | ( | Block * | b | ) |
Definition at line 1068 of file XrdPfcFile.cc.
References Error, XrdPfc::Block::get_buff(), XrdPfc::Block::get_size(), XrdPfc::Cache::GetInstance(), XrdPfc::Block::has_cksums(), XrdPfc::Block::m_offset, XrdPfc::Block::m_prefetch, XrdPfc::Block::ref_cksum_vec(), XrdPfc::Block::req_cksum_net(), and TRACEF.
Referenced by XrdPfc::Cache::ProcessWriteTasks().
|
friend |
Definition at line 205 of file XrdPfcFile.hh.
References BlockResponseHandler.
Referenced by BlockResponseHandler.
|
friend |
|
friend |
Definition at line 206 of file XrdPfcFile.hh.
References DirectResponseHandler.
Referenced by DirectResponseHandler.