1#ifndef __XRDPFC_CACHE_HH__
2#define __XRDPFC_CACHE_HH__
26#include "XrdVersion.hh"
167 int dcnt = 0; {
char *p =
f_str;
while (*p) {
if (*(p++) ==
f_delim[0]) ++dcnt; } }
168 argv.reserve(dcnt + 1);
196 m_dirs.reserve(max_depth);
199 for (
int i = 0; i < max_depth; ++i)
231 for (std::vector<const char*>::iterator i =
m_dirs.begin(); i !=
m_dirs.end(); ++i)
246 printf(
"PathTokenizer::deboog size=%d\n",
m_n_dirs);
249 printf(
" %2d: %s\n", i,
m_dirs[i]);
286 virtual int Prepare(
const char *url,
int oflags, mode_t mode);
289 virtual int Stat(
const char *url,
struct stat &sbuff);
316 bool Config(
const char *config_filename,
const char *parameters);
333 static bool VCheck(XrdVersionInfo &urVersion) {
return true; }
348 int UnlinkFile(
const std::string& f_name,
bool fail_if_open);
380 File*
GetFile(
const std::string&,
IO*,
long long off = 0,
long long filesize = 0);
404 bool cfg2bytes(
const std::string &str,
long long &store,
long long totalSpace,
const char *name);
#define stat(a, b)
Definition XrdPosix.hh:96
Definition XrdOucCache.hh:105
Definition XrdOucCache.hh:495
virtual XrdOucCacheIO * Attach(XrdOucCacheIO *ioP, int opts=0)=0
LFP_Reason
Definition XrdOucCache.hh:570
@ ForAccess
Definition XrdOucCache.hh:570
Definition XrdOucEnv.hh:42
Definition XrdOucStream.hh:47
Definition XrdPfcFile.hh:117
Attaches/creates and detaches/deletes cache-io objects for disk based cache.
Definition XrdPfc.hh:264
bool ConfigXeq(char *, XrdOucStream &)
void RegisterPrefetchFile(File *)
Configuration m_configuration
configurable parameters
Definition XrdPfc.hh:419
long long m_RAM_used
Definition XrdPfc.hh:425
static XrdScheduler * schedP
Definition XrdPfc.hh:395
ActiveMap_t m_active
Map of currently active / open files.
Definition XrdPfc.hh:451
ScanAndPurgeThreadState_e
Definition XrdPfc.hh:469
@ SPTS_Idle
Definition XrdPfc.hh:469
@ SPTS_Done
Definition XrdPfc.hh:469
@ SPTS_Purge
Definition XrdPfc.hh:469
@ SPTS_Scan
Definition XrdPfc.hh:469
StatsMMap_t m_closed_files_stats
Definition XrdPfc.hh:452
bool ConfigParameters(std::string, XrdOucStream &, TmpConfiguration &tmpc)
std::map< std::string, File * > ActiveMap_t
Definition XrdPfc.hh:445
char * RequestRAM(long long size)
static const Cache & TheOne()
const Configuration & RefConfiguration() const
Reference XrdPfc configuration.
Definition XrdPfc.hh:306
void FileSyncDone(File *, bool high_debug)
void inc_ref_cnt(File *, bool lock, bool high_debug)
static const Configuration & Conf()
WriteQ m_writeQ
Definition XrdPfc.hh:442
std::vector< XrdPfc::Decision * > m_decisionpoints
decision plugins
Definition XrdPfc.hh:417
XrdSysTrace * GetTrace()
Definition XrdPfc.hh:389
int UnlinkFile(const std::string &f_name, bool fail_if_open)
Remove cinfo and data files from cache.
void DeRegisterPrefetchFile(File *)
void Purge()
Thread function invoked to scan and purge files from disk when needed.
int m_last_scan_duration
Definition XrdPfc.hh:475
int m_RAM_std_size
Definition XrdPfc.hh:428
int m_last_purge_duration
Definition XrdPfc.hh:476
bool m_isClient
True if running as client.
Definition XrdPfc.hh:430
void copy_out_active_stats_and_update_data_fs_state()
File * GetFile(const std::string &, IO *, long long off=0, long long filesize=0)
void RemoveWriteQEntriesFor(File *f)
Remove blocks from write queue which belong to given prefetch. This method is used at the time of Fil...
bool xcschk(XrdOucStream &)
StatsMMap_t::iterator StatsMMap_i
Definition XrdPfc.hh:448
XrdSysMutex m_RAM_mutex
lock for allcoation of RAM blocks
Definition XrdPfc.hh:424
DataFsState * m_fs_state
directory state for access / usage info and quotas
Definition XrdPfc.hh:473
XrdOss * m_oss
disk cache file system
Definition XrdPfc.hh:413
virtual int LocalFilePath(const char *url, char *buff=0, int blen=0, LFP_Reason why=ForAccess, bool forall=false)
ActiveMap_t::iterator ActiveMap_i
Definition XrdPfc.hh:446
void schedule_file_sync(File *, bool ref_cnt_already_set, bool high_debug)
PrefetchList m_prefetchList
Definition XrdPfc.hh:464
bool cfg2bytes(const std::string &str, long long &store, long long totalSpace, const char *name)
bool xdlib(XrdOucStream &)
void ProcessWriteTasks()
Separate task which writes blocks from ram to disk.
std::vector< File * > PrefetchList
Definition XrdPfc.hh:463
const char * m_traceID
Definition XrdPfc.hh:411
void ResourceMonitorHeartBeat()
Thread function checking resource usage periodically.
bool Config(const char *config_filename, const char *parameters)
Parse configuration file.
void ExecuteCommandUrl(const std::string &command_url)
virtual int Prepare(const char *url, int oflags, mode_t mode)
virtual int Stat(const char *url, struct stat &sbuff)
void ReleaseRAM(char *buf, long long size)
virtual int Unlink(const char *url)
XrdXrootdGStream * m_gstream
Definition XrdPfc.hh:415
std::multimap< std::string, XrdPfc::Stats > StatsMMap_t
Definition XrdPfc.hh:447
XrdOucEnv * m_env
environment passed in at creation
Definition XrdPfc.hh:408
ScanAndPurgeThreadState_e m_spt_state
Definition XrdPfc.hh:477
XrdSysCondVar m_prefetch_condVar
lock for vector of prefetching files
Definition XrdPfc.hh:421
long long m_RAM_write_queue
Definition XrdPfc.hh:426
XrdXrootdGStream * GetGStream()
Definition XrdPfc.hh:391
XrdSysTrace * m_trace
Definition XrdPfc.hh:410
std::list< char * > m_RAM_std_blocks
A list of blocks of standard size, to be reused.
Definition XrdPfc.hh:427
bool xtrace(XrdOucStream &)
void dec_ref_cnt(File *, bool high_debug)
static Cache & GetInstance()
Singleton access.
XrdSysError m_log
XrdPfc namespace logger.
Definition XrdPfc.hh:409
bool m_in_purge
Definition XrdPfc.hh:454
void ReleaseFile(File *, IO *)
bool m_prefetch_enabled
set to true when prefetching is enabled
Definition XrdPfc.hh:422
FNameSet_t m_purge_delay_set
Definition XrdPfc.hh:453
Cache(XrdSysLogger *logger, XrdOucEnv *env)
Constructor.
void AddWriteTask(Block *b, bool from_read)
Add downloaded block in write queue.
bool IsFileActiveOrPurgeProtected(const std::string &)
static Cache * m_instance
this object
Definition XrdPfc.hh:406
XrdOss * GetOss() const
Definition XrdPfc.hh:376
static bool VCheck(XrdVersionInfo &urVersion)
Version check.
Definition XrdPfc.hh:333
File * GetNextFileToPrefetch()
static Cache & CreateInstance(XrdSysLogger *logger, XrdOucEnv *env)
Singleton creation.
std::set< std::string > FNameSet_t
Definition XrdPfc.hh:449
virtual XrdOucCacheIO * Attach(XrdOucCacheIO *, int Options=0)
XrdSysCondVar m_stats_n_purge_cond
communication between heart-beat and scan-purge threads
Definition XrdPfc.hh:471
XrdSysError * GetLog()
Definition XrdPfc.hh:388
bool Decide(XrdOucCacheIO *)
Makes decision if the original XrdOucCacheIO should be cached.
void ScheduleFileSync(File *f)
Definition XrdPfc.hh:384
XrdSysCondVar m_active_cond
Cond-var protecting active file data structures.
Definition XrdPfc.hh:455
Definition XrdPfcFile.hh:213
Base cache-io class that implements some XrdOucCacheIO abstract methods.
Definition XrdPfcIO.hh:18
Definition XrdScheduler.hh:46
Definition XrdSysPthread.hh:79
Definition XrdSysError.hh:90
Definition XrdSysLogger.hh:53
Definition XrdSysPthread.hh:165
Definition XrdSysTrace.hh:49
Definition XrdXrootdGStream.hh:44
CkSumCheck_e
Definition XrdPfcTypes.hh:23
@ CSChk_Both
Definition XrdPfcTypes.hh:23
@ CSChk_Net
Definition XrdPfcTypes.hh:23
@ CSChk_Cache
Definition XrdPfcTypes.hh:23
long long writes_between_purges
upper bound on amount of bytes written between two purge passes
Definition XrdPfc.hh:438
XrdSysCondVar condVar
write list condVar
Definition XrdPfc.hh:436
int size
current size of write queue
Definition XrdPfc.hh:439
WriteQ()
Definition XrdPfc.hh:434
std::list< Block * > queue
container
Definition XrdPfc.hh:437
Contains parameters configurable from the xrootd config file.
Definition XrdPfc.hh:56
long long m_hdfsbsize
used with m_hdfsmode, default 128MB
Definition XrdPfc.hh:108
long long m_RamAbsAvailable
available from configuration
Definition XrdPfc.hh:102
long long m_flushCnt
nuber of unsynced blcoks on disk before flush is called
Definition XrdPfc.hh:109
int m_accHistorySize
max number of entries in access history part of cinfo file
Definition XrdPfc.hh:94
bool does_cschk_have_missing_bits(CkSumCheck_e cks_on_file) const
Definition XrdPfc.hh:74
int m_wqueue_threads
number of threads writing blocks to disk
Definition XrdPfc.hh:105
long long m_diskTotalSpace
total disk space on configured partition or oss space
Definition XrdPfc.hh:85
long long m_fileUsageMax
cache purge - files usage maximum
Definition XrdPfc.hh:90
long long m_fileUsageBaseline
cache purge - files usage baseline
Definition XrdPfc.hh:88
int m_dirStatsStoreDepth
depth to which statistics should be collected
Definition XrdPfc.hh:99
bool m_allow_xrdpfc_command
flag for enabling access to /xrdpfc-command/ functionality.
Definition XrdPfc.hh:79
bool is_purge_plugin_set_up() const
Definition XrdPfc.hh:63
long long m_diskUsageHWM
cache purge - disk usage high water mark
Definition XrdPfc.hh:87
bool is_cschk_cache() const
Definition XrdPfc.hh:69
std::set< std::string > m_dirStatsDirGlobs
directory globs for which stat reporting was requested
Definition XrdPfc.hh:97
CkSumCheck_e get_cs_Chk() const
Definition XrdPfc.hh:67
bool is_uvkeep_purge_in_effect() const
Definition XrdPfc.hh:61
int m_prefetch_max_blocks
maximum number of blocks to prefetch per file
Definition XrdPfc.hh:106
bool are_file_usage_limits_set() const
Definition XrdPfc.hh:59
bool is_cschk_any() const
Definition XrdPfc.hh:71
bool m_cs_ChkTLS
Allow TLS.
Definition XrdPfc.hh:113
void calculate_fractional_usages(long long du, long long fu, double &frac_du, double &frac_fu)
long long m_fileUsageNominal
cache purge - files usage nominal
Definition XrdPfc.hh:89
int m_cs_Chk
Checksum check.
Definition XrdPfc.hh:112
bool should_uvkeep_purge(time_t delta) const
Definition XrdPfc.hh:76
int m_purgeAgeBasedPeriod
peform cold file / uvkeep purge every this many purge cycles
Definition XrdPfc.hh:93
bool m_hdfsmode
flag for enabling block-level operation
Definition XrdPfc.hh:78
int m_purgeColdFilesAge
purge files older than this age
Definition XrdPfc.hh:92
std::string m_data_space
oss space for data files
Definition XrdPfc.hh:82
bool is_cschk_both() const
Definition XrdPfc.hh:72
std::set< std::string > m_dirStatsDirs
directories for which stat reporting was requested
Definition XrdPfc.hh:96
long long m_diskUsageLWM
cache purge - disk usage low water mark
Definition XrdPfc.hh:86
int m_RamKeepStdBlocks
number of standard-sized blocks kept after release
Definition XrdPfc.hh:103
long long m_bufferSize
prefetch buffer size, default 1MB
Definition XrdPfc.hh:101
std::string m_meta_space
oss space for metadata files (cinfo)
Definition XrdPfc.hh:83
int m_wqueue_blocks
maximum number of blocks written per write-queue loop
Definition XrdPfc.hh:104
bool is_age_based_purge_in_effect() const
Definition XrdPfc.hh:60
std::string m_username
username passed to oss plugin
Definition XrdPfc.hh:81
bool is_cschk_net() const
Definition XrdPfc.hh:70
time_t m_cs_UVKeep
unverified checksum cache keep
Definition XrdPfc.hh:111
int m_dirStatsMaxDepth
maximum depth for statistics write out
Definition XrdPfc.hh:98
int m_purgeInterval
sleep interval between cache purges
Definition XrdPfc.hh:91
bool is_dir_stat_reporting_on() const
Definition XrdPfc.hh:62
const char * get_dir(int pos)
Definition XrdPfc.hh:222
std::string make_path()
Definition XrdPfc.hh:228
const char * m_reminder
Definition XrdPfc.hh:185
PathTokenizer(const std::string &path, int max_depth, bool parse_as_lfn)
Definition XrdPfc.hh:188
void deboog()
Definition XrdPfc.hh:244
int get_n_dirs()
Definition XrdPfc.hh:217
std::vector< const char * > m_dirs
Definition XrdPfc.hh:184
int m_n_dirs
Definition XrdPfc.hh:186
SplitParser(const std::string &s, const char *d)
Definition XrdPfc.hh:142
char * f_str
Definition XrdPfc.hh:137
~SplitParser()
Definition XrdPfc.hh:145
char * get_reminder_with_delim()
Definition XrdPfc.hh:153
const char * f_delim
Definition XrdPfc.hh:138
char * f_state
Definition XrdPfc.hh:139
char * get_token()
Definition XrdPfc.hh:147
char * get_reminder()
Definition XrdPfc.hh:159
int fill_argv(std::vector< char * > &argv)
Definition XrdPfc.hh:164
bool f_first
Definition XrdPfc.hh:140
std::string m_diskUsageLWM
Definition XrdPfc.hh:120
std::string m_diskUsageHWM
Definition XrdPfc.hh:121
std::string m_fileUsageBaseline
Definition XrdPfc.hh:122
TmpConfiguration()
Definition XrdPfc.hh:127
std::string m_fileUsageNominal
Definition XrdPfc.hh:123
std::string m_flushRaw
Definition XrdPfc.hh:125
std::string m_fileUsageMax
Definition XrdPfc.hh:124