xrootd
Public Member Functions | Static Public Member Functions | Private Member Functions | Static Private Member Functions | Private Attributes | Static Private Attributes | List of all members
XrdFrmPurge Class Reference

#include <XrdFrmPurge.hh>

Collaboration diagram for XrdFrmPurge:
Collaboration graph
[legend]

Public Member Functions

 XrdFrmPurge (const char *snp, XrdFrmPurge *spp=0)
 
 ~XrdFrmPurge ()
 

Static Public Member Functions

static void Display ()
 
static int Init (XrdOucTList *sP=0, long long minV=-1, int hVal=-1)
 
static XrdFrmPurge * Policy (const char *sname)
 
static XrdFrmPurge * Policy (const char *sname, long long minV, long long maxV, int hVal, int xVal)
 
static void Purge ()
 

Private Member Functions

XrdFrmFileset * Advance ()
 
void Clear ()
 
void Defer (XrdFrmFileset *sP, time_t xTime)
 
const char * Eligible (XrdFrmFileset *sP, time_t &xTime, int hTime=0)
 
int PurgeFile ()
 
int PurgeFile (XrdFrmFileset *fP, const char *pFN)
 
void Track (XrdFrmFileset *sP)
 
const char * XPolOK (XrdFrmFileset *sP)
 

Static Private Member Functions

static void Add (XrdFrmFileset *fsp)
 
static XrdFrmPurge * Find (const char *snp)
 
static int LowOnSpace ()
 >0 -> Purge is needed. More...
 
static void Scan ()
 
static void Stats (int Final)
 

Private Attributes

long long freeSpace
 
long long fconMaxsp
 
long long usedSpace
 
long long pmaxSpace
 
long long totlSpace
 
long long contSpace
 
long long purgBytes
 
long long minFSpace
 
long long maxFSpace
 
char * spaceTotl
 
char * spaceTotP
 
int spaceTLen
 
int spaceTLep
 
int Hold
 
int Hold2x
 
int Ext
 
int numFiles
 
int prgFiles
 
int Enabled
 
int Stop
 
int SNlen
 
XrdFrmPurge * Next
 
XrdFrmTSort FSTab
 
char SName [XrdOssSpace::minSNbsz]
 
XrdFrmFileset * DeferQ [DeferQsz]
 
time_t DeferT [DeferQsz]
 

Static Private Attributes

static XrdOucProg * PolProg = 0
 
static XrdOucStream * PolStream = 0
 
static time_t lastReset = 0
 
static time_t nextReset = 0
 
static XrdFrmPurge * First = 0
 
static XrdFrmPurge * Default = 0
 
static int Left2Do = 0
 
static const int DeferQsz = 16
 

Constructor & Destructor Documentation

XrdFrmPurge::XrdFrmPurge ( const char *  snp,
XrdFrmPurge *  spp = 0 
)

References Clear(), contSpace, DeferQ, Enabled, freeSpace, maxFSpace, minFSpace, Next, pmaxSpace, SName, SNlen, Stop, totlSpace, and usedSpace.

Referenced by Policy().

XrdFrmPurge::~XrdFrmPurge ( )
inline

References Clear().

Member Function Documentation

void XrdFrmPurge::Add ( XrdFrmFileset *  fsp)
staticprivate

References XrdFrmTSort::Add(), XrdFrmFileset::baseFile(), XrdFrmFileset::basePath(), DEBUG, Default, Defer(), Eligible(), Enabled, EPNAME, Find(), FSTab, XrdOssPath::getCname(), Hold, XrdOucNSWalk::NSEnt::Link, XrdOucNSWalk::NSEnt::Lksz, XrdOssSpace::minSNbsz, and numFiles.

Referenced by Advance(), and Scan().

XrdFrmFileset * XrdFrmPurge::Advance ( )
private

References Add(), DeferQ, DeferQsz, DeferT, FSTab, Hold, XrdFrmFileset::Next, XrdFrmTSort::Oldest(), and XrdFrmFileset::Refresh().

Referenced by PurgeFile().

void XrdFrmPurge::Clear ( )
private

References DeferQ, DeferQsz, DeferT, FSTab, XrdFrmFileset::Next, numFiles, prgFiles, purgBytes, and XrdFrmTSort::Purge().

Referenced by XrdFrmPurge(), and ~XrdFrmPurge().

void XrdFrmPurge::Defer ( XrdFrmFileset *  sP,
time_t  xTime 
)
private

References XrdFrmFileset::baseFile(), DeferQ, DeferQsz, DeferT, XrdFrmFileset::Next, and XrdOucNSWalk::NSEnt::Stat.

Referenced by Add().

void XrdFrmPurge::Display ( )
static

References XrdCopy::Config, XrdFrmConfig::VPInfo::Dir, Enabled, Ext, First, XrdOucUtils::fmtBytes(), Hold, maxFSpace, minFSpace, XrdFrmConfig::VPInfo::Name, XrdOucTList::next, Next, XrdFrmConfig::VPInfo::Next, Say, SName, XrdOucTList::text, and XrdFrmConfig::VPInfo::Val.

Referenced by main().

const char * XrdFrmPurge::Eligible ( XrdFrmFileset *  sP,
time_t &  xTime,
int  hTime = 0 
)
private

References XrdOucXAttr< T >::Attr, XrdFrmFileset::baseFile(), XrdFrmFileset::cpyInfo, XrdFrcXAttrCpy::cpyTime, XrdFrmFileset::failFile(), XrdFrcXAttrPin::Flags, XrdFrcXAttrPin::pinIdle, XrdFrmFileset::pinInfo, XrdFrcXAttrPin::pinKeep, XrdFrcXAttrPin::pinPerm, XrdFrcXAttrPin::pinTime, and XrdOucNSWalk::NSEnt::Stat.

Referenced by Add(), and PurgeFile().

XrdFrmPurge * XrdFrmPurge::Find ( const char *  snp)
staticprivate

References First, Next, and SName.

Referenced by Add(), Init(), and Policy().

int XrdFrmPurge::Init ( XrdOucTList *  sP = 0,
long long  minV = -1,
int  hVal = -1 
)
static

References XrdCopy::Config, Default, Find(), First, XrdOucProg::getStream(), XrdOssVSInfo::Large, XrdFrmConfig::VPInfo::Name, XrdOucTList::next, Next, XrdFrmConfig::VPInfo::Next, PolProg, PolStream, XrdFrmConfig::PP_atime, XrdFrmConfig::PP_fsize, XrdFrmConfig::PP_mtime, XrdFrmConfig::PP_pfn, XrdFrmConfig::PP_sname, Say, XrdOucProg::Setup(), XrdOucProg::Start(), XrdOucTList::text, XrdOssVSInfo::Total, totlSpace, and XRDABS.

Referenced by mainConfig().

int XrdFrmPurge::LowOnSpace ( )
staticprivate

>0 -> Purge is needed.

References XrdCopy::Config, contSpace, Enabled, First, XrdOssVSInfo::Free, freeSpace, Left2Do, XrdOssVSInfo::LFree, minFSpace, Next, SName, Stop, XrdOssVSInfo::Usage, and usedSpace.

Referenced by Purge().

static XrdFrmPurge* XrdFrmPurge::Policy ( const char *  sname)
inlinestatic

References Find().

Referenced by mainConfig().

XrdFrmPurge * XrdFrmPurge::Policy ( const char *  sname,
long long  minV,
long long  maxV,
int  hVal,
int  xVal 
)
static

References Ext, Find(), First, Hold, Hold2x, maxFSpace, minFSpace, and XrdFrmPurge().

void XrdFrmPurge::Purge ( )
static

References First, Left2Do, LowOnSpace(), Next, PurgeFile(), Say, Stats(), and Stop.

Referenced by main().

int XrdFrmPurge::PurgeFile ( )
private

References Advance(), XrdFrmFileset::baseFile(), XrdFrmFileset::basePath(), XrdCopy::Config, DEBUG, Eligible(), EPNAME, Ext, freeSpace, FSTab, Hold, maxFSpace, nextReset, XrdFrmTSort::Oldest(), prgFiles, purgBytes, XrdFrmFileset::Refresh(), SName, XrdOucNSWalk::NSEnt::Stat, Stop, Track(), XrdCpConfig::Verbose, and XPolOK().

Referenced by Purge().

int XrdFrmPurge::PurgeFile ( XrdFrmFileset *  fP,
const char *  pFN 
)
private

References XrdFrmFileset::baseFile(), XrdCopy::Config, XrdFrmMonitor::Map(), XrdFrmMonitor::monPURGE, XrdFrmCns::Rm(), XrdOucNSWalk::NSEnt::Stat, XRDOSS_isMIG, XRDOSS_isPFN, and XROOTD_MON_MAPPURG.

void XrdFrmPurge::Scan ( )
staticprivate

References Add(), XrdFrmFiles::CompressD, XrdCopy::Config, XrdFrmConfig::VPInfo::Dir, XrdFrmFiles::Get(), XrdFrmPurgeDir::lowDirTime, XrdFrmConfig::VPInfo::Name, XrdFrmConfig::VPInfo::Next, XrdFrmFiles::NoAutoDel, XrdFrmPurgeDir::numEMD, XrdFrmPurgeDir::numRMD, XrdMpx::Opts, XrdFrmFileset::Purge(), XrdFrmFiles::Recursive, XrdFrmPurgeDir::Reset(), Say, XrdFrmFileset::Screen(), XrdFrmConfig::VPInfo::Val, and VMSG.

void XrdFrmPurge::Stats ( int  Final)
staticprivate

References XrdFrmTSort::Count(), Enabled, First, XrdOucUtils::fmtBytes(), freeSpace, FSTab, maxFSpace, minFSpace, Next, numFiles, prgFiles, purgBytes, Say, SName, totlSpace, and usedSpace.

Referenced by Purge().

void XrdFrmPurge::Track ( XrdFrmFileset *  sP)
private

References XrdFrmFileset::baseFile(), XrdFrmFileset::basePath(), XrdCopy::Config, XrdOucUtils::fmtBytes(), Say, SName, and XrdOucNSWalk::NSEnt::Stat.

Referenced by PurgeFile().

const char * XrdFrmPurge::XPolOK ( XrdFrmFileset *  sP)
private

References XrdFrmFileset::baseFile(), XrdFrmFileset::basePath(), XrdCopy::Config, XrdOucProg::Feed(), XrdOucNSWalk::NSEnt::File, freeSpace, XrdOucStream::GetLine(), PolProg, PolStream, XrdFrmConfig::PP_atime, XrdFrmConfig::PP_ctime, XrdFrmConfig::PP_fname, XrdFrmConfig::PP_fsize, XrdFrmConfig::PP_fspace, XrdFrmConfig::PP_mtime, XrdFrmConfig::PP_pfn, XrdFrmConfig::PP_sname, XrdFrmConfig::PP_tspace, XrdFrmConfig::PP_usage, purgBytes, SName, SNlen, spaceTLen, spaceTotl, XrdOucNSWalk::NSEnt::Stat, Stop, and usedSpace.

Referenced by PurgeFile().

Member Data Documentation

long long XrdFrmPurge::contSpace
private

Referenced by LowOnSpace(), and XrdFrmPurge().

XrdFrmPurge * XrdFrmPurge::Default = 0
staticprivate

Referenced by Add(), and Init().

XrdFrmFileset* XrdFrmPurge::DeferQ[DeferQsz]
private

Referenced by Advance(), Clear(), Defer(), and XrdFrmPurge().

const int XrdFrmPurge::DeferQsz = 16
staticprivate

Referenced by Advance(), Clear(), and Defer().

time_t XrdFrmPurge::DeferT[DeferQsz]
private

Referenced by Advance(), Clear(), and Defer().

int XrdFrmPurge::Enabled
private

Referenced by Add(), Display(), LowOnSpace(), Stats(), and XrdFrmPurge().

int XrdFrmPurge::Ext
private

Referenced by Display(), Policy(), and PurgeFile().

long long XrdFrmPurge::fconMaxsp
private
XrdFrmPurge * XrdFrmPurge::First = 0
staticprivate

Referenced by Display(), Find(), Init(), LowOnSpace(), Policy(), Purge(), and Stats().

long long XrdFrmPurge::freeSpace
private

Referenced by LowOnSpace(), PurgeFile(), Stats(), XPolOK(), and XrdFrmPurge().

XrdFrmTSort XrdFrmPurge::FSTab
private

Referenced by Add(), Advance(), Clear(), PurgeFile(), and Stats().

int XrdFrmPurge::Hold
private

Referenced by Add(), Advance(), Display(), Policy(), and PurgeFile().

int XrdFrmPurge::Hold2x
private

Referenced by Policy().

time_t XrdFrmPurge::lastReset = 0
staticprivate
int XrdFrmPurge::Left2Do = 0
staticprivate

Referenced by LowOnSpace(), and Purge().

long long XrdFrmPurge::maxFSpace
private

Referenced by Display(), Policy(), PurgeFile(), Stats(), and XrdFrmPurge().

long long XrdFrmPurge::minFSpace
private

Referenced by Display(), LowOnSpace(), Policy(), Stats(), and XrdFrmPurge().

XrdFrmPurge* XrdFrmPurge::Next
private

Referenced by Display(), Find(), Init(), LowOnSpace(), Purge(), Stats(), and XrdFrmPurge().

time_t XrdFrmPurge::nextReset = 0
staticprivate

Referenced by PurgeFile().

int XrdFrmPurge::numFiles
private

Referenced by Add(), Clear(), and Stats().

long long XrdFrmPurge::pmaxSpace
private

Referenced by XrdFrmPurge().

XrdOucProg * XrdFrmPurge::PolProg = 0
staticprivate

Referenced by Init(), and XPolOK().

XrdOucStream * XrdFrmPurge::PolStream = 0
staticprivate

Referenced by Init(), and XPolOK().

int XrdFrmPurge::prgFiles
private

Referenced by Clear(), PurgeFile(), and Stats().

long long XrdFrmPurge::purgBytes
private

Referenced by Clear(), PurgeFile(), Stats(), and XPolOK().

char XrdFrmPurge::SName[XrdOssSpace::minSNbsz]
private

Referenced by Display(), Find(), LowOnSpace(), PurgeFile(), Stats(), Track(), XPolOK(), and XrdFrmPurge().

int XrdFrmPurge::SNlen
private

Referenced by XPolOK(), and XrdFrmPurge().

int XrdFrmPurge::spaceTLen
private

Referenced by XPolOK().

int XrdFrmPurge::spaceTLep
private
char* XrdFrmPurge::spaceTotl
private

Referenced by XPolOK().

char* XrdFrmPurge::spaceTotP
private
int XrdFrmPurge::Stop
private

Referenced by LowOnSpace(), Purge(), PurgeFile(), XPolOK(), and XrdFrmPurge().

long long XrdFrmPurge::totlSpace
private

Referenced by Init(), Stats(), and XrdFrmPurge().

long long XrdFrmPurge::usedSpace
private

Referenced by LowOnSpace(), Stats(), XPolOK(), and XrdFrmPurge().

The documentation for this class was generated from the following files:
Generated by   doxygen 1.8.3.1