XrdFrmPurge Class Reference

#include <XrdFrmPurge.hh>

Collaboration diagram for XrdFrmPurge:

List of all members.

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 ()
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.
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

)

[static, private]

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 XrdCms::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.

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

)

[static, private]

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 XrdCms::Config, Default, Find(), First, XrdOucProg::getStream(), XrdOssVSInfo::Large, XrdFrmConfig::VPInfo::Name, XrdOucTList::next, Next, XrdFrmConfig::VPInfo::Next, XrdCmsConfig::ossFS, PolProg, PolStream, XrdFrmConfig::PP_atime, XrdFrmConfig::PP_fsize, XrdFrmConfig::PP_mtime, XrdFrmConfig::PP_pfn, XrdFrmConfig::PP_sname, Say, XrdOucProg::Setup(), XrdOucProg::Start(), XrdOss::StatVS(), XrdOucTList::text, XrdOssVSInfo::Total, totlSpace, and XRDABS.

Referenced by mainConfig().

int XrdFrmPurge::LowOnSpace

(

)

[static, private]

>0 -> Purge is needed.

References XrdCms::Config, contSpace, Enabled, First, XrdOssVSInfo::Free, freeSpace, Left2Do, XrdOssVSInfo::LFree, minFSpace, Next, XrdCmsConfig::ossFS, SName, XrdOss::StatVS(), Stop, XrdOssVSInfo::Usage, and usedSpace.

Referenced by Purge().

static XrdFrmPurge* XrdFrmPurge::Policy

(

const char *

sname

)

[inline, static]

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(), and Scan().

int XrdFrmPurge::PurgeFile

(

)

[private]

References Advance(), XrdFrmFileset::baseFile(), XrdFrmFileset::basePath(), XrdCms::Config, DEBUG, Eligible(), EPNAME, Ext, freeSpace, FSTab, Hold, maxFSpace, nextReset, XrdFrmTSort::Oldest(), XrdCmsConfig::ossFS, prgFiles, purgBytes, XrdFrmFileset::Refresh(), XrdFrmCns::Rm(), SName, XrdOucNSWalk::NSEnt::Stat, Stop, Track(), XrdOss::Unlink(), XPolOK(), XRDOSS_isMIG, and XRDOSS_isPFN.

Referenced by Purge().

void XrdFrmPurge::Scan

(

)

[static, private]

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

void XrdFrmPurge::Stats

(

int

Final

)

[static, private]

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(), XrdCms::Config, XrdOucUtils::fmtBytes(), localtime_r, Say, SName, and XrdOucNSWalk::NSEnt::Stat.

Referenced by PurgeFile().

const char * XrdFrmPurge::XPolOK

(

XrdFrmFileset *

sP

)

[private]

References XrdFrmFileset::baseFile(), XrdFrmFileset::basePath(), XrdCms::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 [static, private]

Referenced by Add(), and Init().

XrdFrmFileset* XrdFrmPurge::DeferQ[DeferQsz] [private]

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

const int XrdFrmPurge::DeferQsz = 16 [static, private]

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 [static, private]

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 [static, private]

int XrdFrmPurge::Left2Do = 0 [static, private]

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 [static, private]

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 [static, private]

Referenced by Init(), and XPolOK().

XrdOucStream * XrdFrmPurge::PolStream = 0 [static, private]

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:

• XrdFrmPurge.hh
• XrdFrmPurge.cc