XrdCmsPrepare Class Reference

#include <XrdCmsPrepare.hh>

Inheritance diagram for XrdCmsPrepare:

Collaboration diagram for XrdCmsPrepare:

List of all members.

Public Member Functions
int	Add (XrdCmsPrepArgs &pargs)
int	Del (char *reqid)
int	Exists (char *path)
void	Gone (char *path)
void	DoIt ()
void	Inform (const char *cmd, XrdCmsPrepArgs *pargs)
int	isOK ()
int	Pending ()
void	Prepare (XrdCmsPrepArgs *pargs)
void	Reset (const char *iName, const char *aPath, int aMode)
int	setParms (int rcnt, int stime, int deco=0)
int	setParms (const char *ifpgm, char *ifmsg=0)
int	setParms (XrdOucName2Name *n2n)
	XrdCmsPrepare ()
	~XrdCmsPrepare ()
Private Member Functions
int	isOnline (char *path)
void	Reset ()
void	Scrub ()
int	startIF ()
Private Attributes
XrdSysMutex	PTMutex
XrdOucHash< char >	PTable
XrdOucStream	prepSched
XrdOucName2Name *	N2N
XrdOucMsubs *	prepMsg
XrdNetMsg *	Relay
XrdFrcProxy *	PrepFrm
char *	prepif
time_t	lastemsg
pid_t	preppid
int	prepOK
int	NumFiles
int	doEcho
int	resetcnt
int	scrub2rst
int	scrubtime

---

Constructor & Destructor Documentation

XrdCmsPrepare::XrdCmsPrepare

(

)

References prepif, preppid, resetcnt, scrub2rst, scrubtime, NumFiles, lastemsg, Relay, Say, PrepFrm, and prepOK.

XrdCmsPrepare::~XrdCmsPrepare

(

)

[inline]

---

Member Function Documentation

int XrdCmsPrepare::Add

(

XrdCmsPrepArgs &

pargs

)

References PrepFrm, XrdFrcProxy::Add(), XrdCmsPrepArgs::path, XrdCmsPrepArgs::opaque, XrdCmsPrepArgs::Ident, XrdCmsPrepArgs::reqid, XrdCmsPrepArgs::notify, XrdCmsPrepArgs::mode, XrdCmsPrepArgs::prty, Say, PTMutex, XrdSysMutex::Lock(), PTable, XrdOucHash::Add(), Hash_data_is_key, NumFiles, XrdSysMutex::UnLock(), prepif, prepSched, XrdOucStream::isAlive(), prepMsg, XrdOucStream::Put(), index(), Info, N2N, and XrdOucMsubs::Subs().

Referenced by Prepare().

int XrdCmsPrepare::Del

(

char *

reqid

)

References PrepFrm, XrdFrcProxy::Del(), Say, PTMutex, XrdSysMutex::Lock(), prepif, prepSched, XrdOucStream::isAlive(), XrdSysMutex::UnLock(), and XrdOucStream::Put().

Referenced by XrdCmsNode::do_PrepDel().

void XrdCmsPrepare::DoIt

(

)

[virtual]

Implements XrdJob.

References Scrub(), XrdCms::Sched, XrdScheduler::Schedule(), and scrubtime.

int XrdCmsPrepare::Exists

(

char *

path

)

References PTMutex, XrdSysMutex::Lock(), NumFiles, PTable, XrdOucHash::Find(), and XrdSysMutex::UnLock().

Referenced by XrdCmsBaseFS::Exists(), and isOnline().

void XrdCmsPrepare::Gone

(

char *

path

)

References PTMutex, XrdSysMutex::Lock(), NumFiles, PTable, XrdOucHash::Del(), and XrdSysMutex::UnLock().

Referenced by XrdCmsAdmin::do_RmDid(), and XrdCmsNode::do_Gone().

void XrdCmsPrepare::Inform	(	const char *	cmd,
		XrdCmsPrepArgs *	pargs
	)

References EPNAME, index(), XrdCmsPrepArgs::mode, XrdCmsPrepArgs::notify, Relay, DEBUG, XrdCmsPrepArgs::Ident, XrdCmsPrepArgs::reqid, iovec::iov_base, iovec::iov_len, XrdCmsPrepArgs::path, XrdCmsPrepArgs::pathlen, and XrdNetMsg::Send().

Referenced by XrdCmsNode::do_SelPrep(), and Prepare().

int XrdCmsPrepare::isOK

(

)

[inline]

References prepOK.

Referenced by XrdCmsAdmin::do_RmDid().

int XrdCmsPrepare::isOnline

(

char *

path

)

[private]

References XRDOSS_resonly, XRDOSS_updtatm, stat(), XrdCms::Config, XrdCmsConfig::ossFS, XrdOss::Stat(), XrdCmsConfig::DiskSS, and Exists().

Referenced by Prepare().

int XrdCmsPrepare::Pending

(

)

[inline]

References NumFiles.

void XrdCmsPrepare::Prepare

(

XrdCmsPrepArgs *

pargs

)

References EPNAME, isOnline(), XrdCmsPrepArgs::path, DEBUG, XrdCmsPrepArgs::reqid, XrdCmsPrepArgs::notify, XrdCmsPrepArgs::prty, XrdCmsPrepArgs::mode, XrdCms::Config, XrdCmsConfig::DiskSS, Say, XrdCmsPrepArgs::Ident, Add(), and Inform().

Referenced by XrdCmsPrepArgs::Process().

void XrdCmsPrepare::Reset	(	const char *	iName,
		const char *	aPath,
		int	aMode
	)

References EPNAME, prepif, PrepFrm, Say, DEBUG, rindex, prepOK, XrdFrcProxy::Init(), XrdFrcProxy::opStg, Reset(), scrubtime, XrdCms::Sched, and XrdScheduler::Schedule().

Referenced by XrdCmsConfig::setupServer().

void XrdCmsPrepare::Reset

(

)

[private]

References PrepFrm, XrdFrcProxy::opStg, prepOK, PTable, XrdOucHash::Purge(), NumFiles, XrdFrcProxy::List(), XrdOucHash::Add(), Hash_data_is_key, doEcho, Say, prepif, prepSched, XrdOucStream::isAlive(), startIF(), XrdOucStream::Put(), XrdOucStream::LastError(), XrdOucStream::Drain(), and XrdOucStream::GetLine().

Referenced by Reset(), and Scrub().

void XrdCmsPrepare::Scrub

(

)

[private]

References PTMutex, XrdSysMutex::Lock(), scrub2rst, Reset(), resetcnt, PTable, XrdOucHash::Apply(), XrdCmsScrubScan(), PrepFrm, prepSched, XrdOucStream::isAlive(), startIF(), and XrdSysMutex::UnLock().

Referenced by DoIt().

int XrdCmsPrepare::setParms	(	int	rcnt,
		int	stime,
		int	deco = 0
	)

References resetcnt, scrub2rst, scrubtime, and doEcho.

Referenced by XrdCmsConfig::ConfigN2N(), XrdCmsConfig::xprep(), and XrdCmsConfig::xprepm().

int XrdCmsPrepare::setParms	(	const char *	ifpgm,
		char *	ifmsg = 0
	)

References rindex, prepif, prepMsg, Say, and XrdOucMsubs::Parse().

int XrdCmsPrepare::setParms

(

XrdOucName2Name *

n2n

)

[inline]

References N2N.

int XrdCmsPrepare::startIF

(

)

[private]

References EPNAME, PrepFrm, prepOK, prepif, Say, DEBUG, prepSched, XrdOucStream::Exec(), lastemsg, and XrdOucStream::LastError().

Referenced by Reset(), and Scrub().

---

Member Data Documentation

int XrdCmsPrepare::doEcho [private]

Referenced by setParms(), and Reset().

time_t XrdCmsPrepare::lastemsg [private]

Referenced by XrdCmsPrepare(), and startIF().

XrdOucName2Name* XrdCmsPrepare::N2N [private]

Referenced by Add(), and setParms().

int XrdCmsPrepare::NumFiles [private]

Referenced by XrdCmsPrepare(), Add(), Exists(), Gone(), Reset(), and Pending().

XrdFrcProxy* XrdCmsPrepare::PrepFrm [private]

Referenced by XrdCmsPrepare(), Add(), Del(), Reset(), Scrub(), and startIF().

char* XrdCmsPrepare::prepif [private]

Referenced by XrdCmsPrepare(), Add(), Del(), Reset(), setParms(), and startIF().

XrdOucMsubs* XrdCmsPrepare::prepMsg [private]

Referenced by Add(), and setParms().

int XrdCmsPrepare::prepOK [private]

Referenced by XrdCmsPrepare(), Reset(), startIF(), and isOK().

pid_t XrdCmsPrepare::preppid [private]

Referenced by XrdCmsPrepare().

XrdOucStream XrdCmsPrepare::prepSched [private]

Referenced by Add(), Del(), Reset(), Scrub(), and startIF().

XrdOucHash<char> XrdCmsPrepare::PTable [private]

Referenced by Add(), Exists(), Gone(), Reset(), and Scrub().

XrdSysMutex XrdCmsPrepare::PTMutex [private]

Referenced by Add(), Del(), Exists(), Gone(), and Scrub().

XrdNetMsg* XrdCmsPrepare::Relay [private]

Referenced by XrdCmsPrepare(), and Inform().

int XrdCmsPrepare::resetcnt [private]

Referenced by XrdCmsPrepare(), setParms(), and Scrub().

int XrdCmsPrepare::scrub2rst [private]

Referenced by XrdCmsPrepare(), setParms(), and Scrub().

int XrdCmsPrepare::scrubtime [private]

Referenced by XrdCmsPrepare(), DoIt(), Reset(), and setParms().

---

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

• XrdCmsPrepare.hh
• XrdCmsPrepare.cc