XrdCmsBaseFS Class Reference

#include <XrdCmsBaseFS.hh>

Collaboration diagram for XrdCmsBaseFS:

[legend]

List of all members.

Classes
struct	dMoP
struct	RequestQ
Public Member Functions
int	Exists (XrdCmsRRData &Arg, XrdCmsPInfo &Who, int noLim=0)
int	Exists (char *Path, int fnPos, int UpAT=0)
void	Init (int Opts, int DMlife, int DPLife)
int	isDFS ()
int	Limit ()
void	Limit (int rLim, int qMax)
int	Local ()
void	Pacer ()
void	Runner ()
void	Start ()
int	Trim ()
int	Traverse ()
	XrdCmsBaseFS (void(*theCB)(XrdCmsBaseFR *, int))
	~XrdCmsBaseFS ()
Static Public Attributes
static const int	Cntrl = 0x0001
static const int	DFSys = 0x0002
static const int	Immed = 0x0004
static const int	Servr = 0x0100
Private Member Functions
int	Bypass ()
int	FStat (char *Path, int fnPos, int upat=0)
int	hasDir (char *Path, int fnPos)
void	Queue (XrdCmsRRData &Arg, XrdCmsPInfo &Who, int dln, int Frc=0)
void	Xeq (XrdCmsBaseFR *rP)
Private Attributes
XrdSysMutex	fsMutex
XrdOucHash< dMoP >	fsDirMP
void(*	cBack )(XrdCmsBaseFR *, int)
struct XrdCmsBaseFS::RequestQ	theQ
int	dmLife
int	dpLife
char	lclStat
char	preSel
char	dfsSys
char	Server
char	Fixed
char	Punt

---

Constructor & Destructor Documentation

XrdCmsBaseFS::XrdCmsBaseFS

(

void(*)(XrdCmsBaseFR *, int)

theCB

)

[inline]

XrdCmsBaseFS::~XrdCmsBaseFS

(

)

[inline]

---

Member Function Documentation

int XrdCmsBaseFS::Bypass

(

)

[private]

References Fixed, XrdSysMutex::Lock(), XrdCmsBaseFS::RequestQ::Mutex, XrdCmsBaseFS::RequestQ::pqFirst, XrdCmsBaseFS::RequestQ::rAgain, XrdSysTimer::Report(), XrdSysTimer::Reset(), XrdCmsBaseFS::RequestQ::rLeft, XrdCmsBaseFS::RequestQ::rLimit, theQ, and XrdSysMutex::UnLock().

Referenced by Exists().

int XrdCmsBaseFS::Exists	(	char *	Path,
		int	fnPos,
		int	UpAT = 0
	)

References XrdCms::Config, DEBUG, XrdCmsConfig::DiskSS, dmLife, dpLife, EPNAME, XrdCmsPrepare::Exists(), fsDirMP, fsMutex, hasDir(), Hash_keepdata, XrdSysMutex::Lock(), XrdMpx::Opts, XrdCmsConfig::ossFS, XrdCms::PrepQ, XrdCmsBaseFS::dMoP::Present, XrdOucHash< T >::Rep(), XrdOss::Stat(), stat, XrdSysMutex::UnLock(), XRDOSS_resonly, and XRDOSS_updtatm.

int XrdCmsBaseFS::Exists	(	XrdCmsRRData &	Arg,
		XrdCmsPInfo &	Who,
		int	noLim = 0
	)

References Bypass(), dmLife, Fixed, hasDir(), lclStat, XrdCmsRRData::Path, XrdCmsRRData::PathLen, Queue(), XrdCmsBaseFS::RequestQ::rLimit, XrdCmsPInfo::rovec, and theQ.

Referenced by XrdCmsNode::do_State(), XrdCmsNode::do_StateFWD(), XrdCmsCluster::SelDFS(), and Xeq().

int XrdCmsBaseFS::FStat	(	char *	Path,
		int	fnPos,
		int	upat = 0
	)			[private]

int XrdCmsBaseFS::hasDir	(	char *	Path,
		int	fnPos
	)			[private]

References XrdOucHash< T >::Find(), fsDirMP, fsMutex, XrdSysMutex::Lock(), XrdCmsBaseFS::dMoP::Present, and XrdSysMutex::UnLock().

Referenced by Exists(), Pacer(), and Xeq().

void XrdCmsBaseFS::Init	(	int	Opts,
		int	DMlife,
		int	DPLife
	)

References Cntrl, dfsSys, DFSys, dmLife, dpLife, Immed, lclStat, preSel, Server, and Servr.

Referenced by XrdCmsConfig::Configure1(), and XrdCmsConfig::xdfs().

int XrdCmsBaseFS::isDFS

(

)

[inline]

References dfsSys.

Referenced by XrdCmsConfig::Configure2(), XrdCmsNode::do_Gone(), XrdCmsNode::do_Have(), XrdCmsNode::do_StateFWD(), and XrdCmsCluster::Select().

void XrdCmsBaseFS::Limit	(	int	rLim,
		int	qMax
	)

References Fixed, XrdCmsBaseFS::RequestQ::qMax, XrdCmsBaseFS::RequestQ::rAgain, XrdCmsBaseFS::RequestQ::rLeft, XrdCmsBaseFS::RequestQ::rLimit, and theQ.

int XrdCmsBaseFS::Limit

(

)

[inline]

References XrdCmsBaseFS::RequestQ::rLimit, and theQ.

Referenced by XrdCmsNode::do_State(), and XrdCmsConfig::xdfs().

int XrdCmsBaseFS::Local

(

)

[inline]

References lclStat.

Referenced by XrdCmsCluster::SelDFS().

void XrdCmsBaseFS::Pacer

(

)

References hasDir(), XrdSysMutex::Lock(), XrdCmsBaseFS::RequestQ::Mutex, XrdCmsBaseFR::Next, XrdCmsBaseFR::Path, XrdCmsBaseFR::PDirLen, XrdSysSemaphore::Post(), XrdCmsBaseFS::RequestQ::pqAvail, XrdCmsBaseFS::RequestQ::pqFirst, XrdCmsBaseFS::RequestQ::pqLast, XrdCmsBaseFS::RequestQ::rLimit, XrdCmsBaseFS::RequestQ::rqAvail, XrdCmsBaseFS::RequestQ::rqFirst, XrdCmsBaseFS::RequestQ::rqLast, theQ, XrdSysMutex::UnLock(), XrdSysTimer::Wait(), and XrdSysSemaphore::Wait().

void XrdCmsBaseFS::Queue	(	XrdCmsRRData &	Arg,
		XrdCmsPInfo &	Who,
		int	dln,
		int	Frc = 0
	)			[private]

References DEBUG, EPNAME, XrdSysMutex::Lock(), XrdCmsBaseFS::RequestQ::Mutex, XrdCmsBaseFR::Next, XrdCmsRRData::Path, XrdSysSemaphore::Post(), XrdCmsBaseFS::RequestQ::pqAvail, XrdCmsBaseFS::RequestQ::pqFirst, XrdCmsBaseFS::RequestQ::pqLast, XrdCmsBaseFS::RequestQ::qHWM, XrdCmsBaseFS::RequestQ::qMax, XrdCmsBaseFS::RequestQ::qNum, Say, theQ, XrdSysMutex::UnLock(), and Xeq().

Referenced by Exists().

void XrdCmsBaseFS::Runner

(

)

References XrdSysMutex::Lock(), XrdCmsBaseFS::RequestQ::Mutex, XrdCmsBaseFR::Next, XrdCmsBaseFS::RequestQ::qNum, XrdCmsBaseFS::RequestQ::rqAvail, XrdCmsBaseFS::RequestQ::rqFirst, XrdCmsBaseFS::RequestQ::rqLast, theQ, XrdSysMutex::UnLock(), XrdSysSemaphore::Wait(), and Xeq().

void XrdCmsBaseFS::Start

(

)

References DEBUG, dfsSys, dmLife, dpLife, EPNAME, Fixed, lclStat, preSel, Punt, XrdCmsBaseFS::RequestQ::qMax, XrdCmsBaseFS::RequestQ::rAgain, XrdCmsBaseFS::RequestQ::rLimit, XrdSysThread::Run(), Say, Server, theQ, XrdCmsBasePacer(), and XrdCmsBaseRunner().

Referenced by XrdCmsConfig::Configure2().

int XrdCmsBaseFS::Traverse

(

)

[inline]

References Punt.

Referenced by XrdCmsNode::do_StateFWD().

int XrdCmsBaseFS::Trim

(

)

[inline]

References preSel.

Referenced by XrdCmsCluster::Select().

void XrdCmsBaseFS::Xeq

(

XrdCmsBaseFR *

rP

)

[private]

References cBack, dmLife, Exists(), hasDir(), lclStat, XrdCmsBaseFR::Path, XrdCmsBaseFR::PDirLen, XrdCmsBaseFS::RequestQ::qMax, XrdCmsBaseFS::RequestQ::qNum, Say, and theQ.

Referenced by Queue(), and Runner().

---

Member Data Documentation

void(* XrdCmsBaseFS::cBack)(XrdCmsBaseFR *, int) [private]

Referenced by Xeq().

const int XrdCmsBaseFS::Cntrl = 0x0001 [static]

Referenced by Init(), and XrdCmsConfig::xdfs().

char XrdCmsBaseFS::dfsSys [private]

Referenced by Init(), isDFS(), and Start().

const int XrdCmsBaseFS::DFSys = 0x0002 [static]

Referenced by XrdCmsConfig::Configure1(), Init(), and XrdCmsConfig::xdfs().

int XrdCmsBaseFS::dmLife [private]

Referenced by Exists(), Init(), Start(), and Xeq().

int XrdCmsBaseFS::dpLife [private]

Referenced by Exists(), Init(), and Start().

char XrdCmsBaseFS::Fixed [private]

Referenced by Bypass(), Exists(), Limit(), and Start().

XrdOucHash<dMoP> XrdCmsBaseFS::fsDirMP [private]

Referenced by Exists(), and hasDir().

XrdSysMutex XrdCmsBaseFS::fsMutex [private]

Referenced by Exists(), and hasDir().

const int XrdCmsBaseFS::Immed = 0x0004 [static]

Referenced by XrdCmsConfig::Configure1(), Init(), and XrdCmsConfig::xdfs().

char XrdCmsBaseFS::lclStat [private]

Referenced by Exists(), Init(), Local(), Start(), and Xeq().

char XrdCmsBaseFS::preSel [private]

Referenced by Init(), Start(), and Trim().

char XrdCmsBaseFS::Punt [private]

Referenced by Start(), and Traverse().

char XrdCmsBaseFS::Server [private]

Referenced by Init(), and Start().

const int XrdCmsBaseFS::Servr = 0x0100 [static]

Referenced by Init(), and XrdCmsConfig::xdfs().

struct XrdCmsBaseFS::RequestQ XrdCmsBaseFS::theQ [private]

Referenced by Bypass(), Exists(), Limit(), Pacer(), Queue(), Runner(), Start(), and Xeq().

---

The documentation for this class was generated from the following files:

• XrdCmsBaseFS.hh
• XrdCmsBaseFS.cc