xrootd: XrdCmsBaseFS Class Reference

xrootd

#include <XrdCmsBaseFS.hh>

Collaboration diagram for XrdCmsBaseFS:

Collaboration graph

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 XrdSysTimer::Report(), and XrdSysTimer::Reset().

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

References Exists, XrdCmsRRData::Path, XrdCmsRRData::PathLen, and XrdCmsPInfo::rovec.

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

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

References XrdCms::Config, DEBUG, XrdCmsConfig::DiskSS, EPNAME, XrdCmsPrepare::Exists(), Hash_keepdata, XrdCms::CmsHaveRequest::Online, XrdMpx::Opts, XrdCmsConfig::ossFS, XrdCms::CmsHaveRequest::Pending, XrdCms::PrepQ, XrdCmsBaseFS::dMoP::Present, XrdOss::Stat(), stat(), XRDOSS_resonly, and XRDOSS_updtatm.

int XrdCmsBaseFS::FStat	(	char *	Path,
		int	fnPos,
		int	upat = `0`
	)

private

int XrdCmsBaseFS::hasDir	(	char *	Path,
		int	fnPos
	)

private

References XrdCmsBaseFS::dMoP::Present.

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

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

int XrdCmsBaseFS::Limit ( )

inline

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

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

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

int XrdCmsBaseFS::Local ( )

inline

References lclStat.

Referenced by XrdCmsConfig::Configure1(), and XrdCmsCluster::SelDFS().

void XrdCmsBaseFS::Pacer ( )

References XrdCmsBaseFR::Next, XrdCmsBaseFR::Path, XrdCmsBaseFR::PDirLen, and XrdSysTimer::Wait().

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

private

References DEBUG, XrdSysError::Emsg(), EPNAME, XrdCmsRRData::Path, and XrdCms::Say.

void XrdCmsBaseFS::Runner ( )

References XrdCmsBaseFR::Next.

void XrdCmsBaseFS::Start ( )

References DEBUG, XrdSysError::Emsg(), EPNAME, XrdSysThread::Run(), XrdCms::Say, 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 XrdSysError::Emsg(), Exists, XrdCmsBaseFR::Path, XrdCmsBaseFR::PDirLen, and XrdCms::Say.

Member Data Documentation

void(* XrdCmsBaseFS::cBack)(XrdCmsBaseFR *, int)

private

const int XrdCmsBaseFS::Cntrl = 0x0001

static

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

char XrdCmsBaseFS::dfsSys

private

Referenced by isDFS().

const int XrdCmsBaseFS::DFSys = 0x0002

static

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

int XrdCmsBaseFS::dmLife

private

int XrdCmsBaseFS::dpLife

private

char XrdCmsBaseFS::Fixed

private

XrdOucHash<dMoP> XrdCmsBaseFS::fsDirMP

private

XrdSysMutex XrdCmsBaseFS::fsMutex

private

const int XrdCmsBaseFS::Immed = 0x0004

static

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

char XrdCmsBaseFS::lclStat

private

Referenced by Local().

char XrdCmsBaseFS::preSel

private

Referenced by Trim().

char XrdCmsBaseFS::Punt

private

Referenced by Traverse().

char XrdCmsBaseFS::Server

private

const int XrdCmsBaseFS::Servr = 0x0100

static

Referenced by XrdCmsConfig::xdfs().

struct XrdCmsBaseFS::RequestQ XrdCmsBaseFS::theQ

private

Referenced by Limit().

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