1 #ifndef XRD_READCACHE_H
2 #define XRD_READCACHE_H
63 long long end_offs,
long long ticksnow,
64 bool placeholder=
false);
72 return ( (end_offs >= begin_offs) &&
79 return ( (end_offs > begin_offs) &&
98 inline bool GetInterval(
const void *buffer,
long long begin_offs,
103 end_offs - begin_offs + 1);
110 long long end_offs) {
112 long long b = -1, e, l;
114 if (begin_offs > end_offs)
return 0;
193 long long begin_offs);
207 long long end_offs,
bool PerfCalc,
215 long long &bytessubmitted,
222 long long &misscount,
228 long long &readreqcnt,
231 float &bytesusefulness
244 cout <<
"Low level caching info:" << endl;
245 cout <<
" StallsRate=" <<
fMissRate << endl;
246 cout <<
" StallsCount=" <<
fMissCount << endl;
260 long long end_offs,
bool pinned=
false);
263 void RemoveItems(
long long begin_offs,
long long end_offs,
bool remove_overlapped =
false);
276 void *
FindBlk(
long long begin_offs,
long long end_offs);
#define xrdmin(a, b)
Definition: XrdClientConst.hh:189
#define TRUE
Definition: XrdClientConst.hh:186
#define FALSE
Definition: XrdClientConst.hh:187
XrdClientVector< XrdClientReadCacheItem * > ItemVect
Definition: XrdClientReadCache.hh:151
XrdClientVector< XrdClientCacheInterval > XrdClientIntvList
Definition: XrdClientReadCache.hh:159
Definition: XrdClientMessage.hh:49
Definition: XrdClientReadCache.hh:51
long GetPartialInterval(const void *buffer, long long begin_offs, long long end_offs)
Definition: XrdClientReadCache.hh:109
bool ContainsOffset(long long offs)
Definition: XrdClientReadCache.hh:91
bool fIsPlaceholder
Definition: XrdClientReadCache.hh:54
void * GetData()
Definition: XrdClientReadCache.hh:95
long long EndOffset()
Definition: XrdClientReadCache.hh:68
bool IsPlaceholder()
Definition: XrdClientReadCache.hh:136
bool ContainsInterval(long long begin_offs, long long end_offs)
Definition: XrdClientReadCache.hh:78
~XrdClientReadCacheItem()
bool IntersectInterval(long long begin_offs, long long end_offs)
Definition: XrdClientReadCache.hh:84
long long BeginOffset()
Definition: XrdClientReadCache.hh:67
XrdClientReadCacheItem(const void *buffer, long long begin_offs, long long end_offs, long long ticksnow, bool placeholder=false)
long long GetTimestampTicks()
Definition: XrdClientReadCache.hh:134
void * fData
Definition: XrdClientReadCache.hh:57
long long fEndOffset
Definition: XrdClientReadCache.hh:58
bool GetInterval(const void *buffer, long long begin_offs, long long end_offs)
Definition: XrdClientReadCache.hh:98
long Size()
Definition: XrdClientReadCache.hh:138
void Touch(long long ticksnow)
Definition: XrdClientReadCache.hh:140
bool Pinned
Definition: XrdClientReadCache.hh:142
long long fBeginOffset
Definition: XrdClientReadCache.hh:56
bool ContainedInInterval(long long begin_offs, long long end_offs)
Definition: XrdClientReadCache.hh:71
long fTimestampTicks
Definition: XrdClientReadCache.hh:59
Definition: XrdClientReadCache.hh:161
int FindInsertionApprox_rec(int startidx, int endidx, long long begin_offs)
int fBlkRemPolicy
Definition: XrdClientReadCache.hh:173
long long fTotalByteCount
Definition: XrdClientReadCache.hh:175
@ kRmBlk_LeastOffs
Definition: XrdClientReadCache.hh:199
@ kRmBlk_LRU
Definition: XrdClientReadCache.hh:198
@ kRmBlk_FIFO
Definition: XrdClientReadCache.hh:200
void RemovePlaceholders()
int FindInsertionApprox(long long begin_offs)
ItemVect fItems
Definition: XrdClientReadCache.hh:167
long long fBytesSubmitted
Definition: XrdClientReadCache.hh:165
void * FindBlk(long long begin_offs, long long end_offs)
bool WillFit(long long bc)
Definition: XrdClientReadCache.hh:279
long long GetTotalByteCount()
Definition: XrdClientReadCache.hh:234
bool MakeFreeSpace(long long bytes)
long long GetTimestampTick()
long long fReadsCounter
Definition: XrdClientReadCache.hh:172
void UnPinCacheBlk(long long begin_offs, long long end_offs)
long long fBytesHit
Definition: XrdClientReadCache.hh:164
void PrintPerfCounters()
Definition: XrdClientReadCache.hh:241
long long fTimestampTickCounter
Definition: XrdClientReadCache.hh:174
void RemoveItems(long long begin_offs, long long end_offs, bool remove_overlapped=false)
void SetBlkRemovalPolicy(int p)
Definition: XrdClientReadCache.hh:271
void GetInfo(int &size, long long &bytessubmitted, long long &byteshit, long long &misscount, float &missrate, long long &readreqcnt, float &bytesusefulness)
void SetSize(int sz)
Definition: XrdClientReadCache.hh:267
bool SubmitRawData(const void *buffer, long long begin_offs, long long end_offs, bool pinned=false)
float fBytesUsefulness
Definition: XrdClientReadCache.hh:166
void RemoveItems(bool leavepinned=true)
long long fMissCount
Definition: XrdClientReadCache.hh:169
XrdSysRecMutex fMutex
Definition: XrdClientReadCache.hh:171
long GetDataIfPresent(const void *buffer, long long begin_offs, long long end_offs, bool PerfCalc, XrdClientIntvList &missingblks, long &outstandingblks)
long long fMaxCacheSize
Definition: XrdClientReadCache.hh:168
void SubmitXMessage(XrdClientMessage *xmsg, long long begin_offs, long long end_offs)
void UpdatePerfCounters()
Definition: XrdClientReadCache.hh:184
void PutPlaceholder(long long begin_offs, long long end_offs)
float fMissRate
Definition: XrdClientReadCache.hh:170
Definition: XrdSysPthread.hh:261
Definition: XrdSysPthread.hh:240
Definition: XrdClientReadCache.hh:154
long long endoffs
Definition: XrdClientReadCache.hh:156
long long beginoffs
Definition: XrdClientReadCache.hh:155