XrdCmsFinderTRG Class Reference

#include <XrdCmsFinder.hh>

Inheritance diagram for XrdCmsFinderTRG:

Collaboration diagram for XrdCmsFinderTRG:

Public Member Functions
void	Added (const char *path, int Pend=0)
int	Configure (const char *cfn, char *Args, XrdOucEnv *EnvInfo)
int	Locate (XrdOucErrInfo &Resp, const char *path, int flags, XrdOucEnv *Info=0)
int	Prepare (XrdOucErrInfo &Resp, XrdSfsPrep &pargs, XrdOucEnv *Info=0)
void	Removed (const char *path)
int	RunAdmin (char *Path)
int	Space (XrdOucErrInfo &Resp, const char *path, XrdOucEnv *envP=0)
void *	Start ()
	XrdCmsFinderTRG (XrdSysLogger *, int, int, XrdOss *theSS=0)
	~XrdCmsFinderTRG ()
Public Member Functions inherited from XrdCmsClient
virtual int	Forward (XrdOucErrInfo &Resp, const char *cmd, const char *arg1=0, const char *arg2=0, XrdOucEnv *Env1=0, XrdOucEnv *Env2=0)
virtual int	isRemote ()
virtual XrdOucTList *	Managers ()
virtual void	Resume (int Perm=1)
virtual void	Suspend (int Perm=1)
virtual int	Resource (int n)
virtual int	Reserve (int n=1)
virtual int	Release (int n=1)
	XrdCmsClient (Persona acting)
virtual	~XrdCmsClient ()
	Destructor. More...

Static Public Member Functions
static bool	VCheck (XrdVersionInfo &urVersion)

Private Member Functions
void	Hookup ()
int	Process (XrdCmsRRData &Data)

Private Attributes
XrdOss *	SS
XrdOucStream *	CMSp
XrdSysMutex	myData
int	myPort
char *	CMSPath
char *	Login
int	isRedir
int	isProxy
int	Active

Additional Inherited Members
Public Types inherited from XrdCmsClient
enum	Persona { amLocal, amRemote, amTarget }
Protected Attributes inherited from XrdCmsClient
Persona	myPersona

Constructor & Destructor Documentation

XrdCmsFinderTRG::XrdCmsFinderTRG	(	XrdSysLogger *	lp,
		int	whoami,
		int	port,
		XrdOss *	theSS = 0
	)

References Active, CMSp, CMSPath, isProxy, XrdCms::IsProxy, isRedir, XrdCms::IsRedir, Login, myPort, XrdMonCtrCollector::port, Say, and SS.

XrdCmsFinderTRG::~XrdCmsFinderTRG

(

)

References CMSp, and Login.

Member Function Documentation

void XrdCmsFinderTRG::Added ( const char *  path, int  Pend = 0  )

virtual

Notify the cms of a newly added file or a file whose state has changed on a data server node.

Parameters

path	The logical file name.
Pend	When true, the file is scheduled to be present in the future (e.g. copied in).

Reimplemented from XrdCmsClient.

References Active, XrdOucStream::Close(), CMSp, XrdSysMutex::Lock(), myData, XrdOucStream::Put(), and XrdSysMutex::UnLock().

int XrdCmsFinderTRG::Configure ( const char *  cfn, char *  Parms, XrdOucEnv *  EnvInfo  )

virtual

Configure the client object.

Parameters

cfn	The configuration file name.
Parms	Any parameters specified in the cmslib directive. If none, the pointer may be null.
EnvInfo	Environmental information of the caller.

Returns

Success !0 Failure =0

Implements XrdCmsClient.

References XrdCmsClientConfig::CMSPath, XrdCmsClientConfig::configNorm, XrdCmsClientConfig::configServer, XrdCmsClientConfig::configSuper, XrdCmsClientConfig::Configure(), isRedir, and RunAdmin().

void XrdCmsFinderTRG::Hookup ( )

private

References Active, XrdOucStream::Attach(), CMSp, CMSPath, XrdSysMutex::Lock(), myData, opts, Say, stat(), XrdSysMutex::UnLock(), XrdSysTimer::Wait(), and XRDNET_NOEMSG.

Referenced by Start().

int XrdCmsFinderTRG::Locate ( XrdOucErrInfo &  Resp, const char *  path, int  flags, XrdOucEnv *  Info = 0  )

inlinevirtual

Retrieve file location information.

Parameters

Resp	Object where message or response is to be returned.
path	The logical path whise location is wanted.
flags	One or more of the following: SFS_O_LOCATE - return the list of servers that have the file. Otherwise, redirect to the best server for the file. SFS_O_NOWAIT - w/ SFS_O_LOCATE return readily available info. Otherwise, select online files only. SFS_O_CREAT - file will be created. SFS_O_NOWAIT - select server if file is online. SFS_O_REPLICA - a replica of the file will be made. SFS_O_STAT - only stat() information wanted. SFS_O_TRUNC - file will be truncated. For any the the above, additional flags are passed: SFS_O_META - data will not change (inode operation only) SFS_O_RESET - reset cached info and recaculate the location(s). SFS_O_WRONLY - file will be only written (o/w RDWR or RDONLY). SFS_O_RDWR - file may be read and written (o/w WRONLY or RDONLY).
Info	Associated environmental information for arg2 (e.g., cgi info which can be retrieved by Env1->Env(<len>)).

Returns

As explained under "return conventions".

Implements XrdCmsClient.

int XrdCmsFinderTRG::Prepare ( XrdOucErrInfo &  Resp, XrdSfsPrep &  pargs, XrdOucEnv *  Info = 0  )

inlinevirtual

Start the preparation of a file for future processing.

Parameters

Resp	Object where message or response is to be returned.
pargs	Information on which and how to prepare the file.
Info	Associated environmental information.

Returns

As explained under "return conventions".

Reimplemented from XrdCmsClient.

int XrdCmsFinderTRG::Process ( XrdCmsRRData &  Data )

private

References XrdCmsRRData::Blen, XrdCmsRRData::Buff, XrdCms::CmsRRHdr::datalen, DEBUG, XrdCmsRRData::Dlen, EPNAME, XrdCmsRRData::getBuff(), XrdCms::kYR_mv, XrdCms::kYR_rm, XrdCms::kYR_rmdir, XrdCmsParser::Parse(), XrdCms::Parser, XrdCmsRRData::Path, XrdCmsRRData::Path2, XrdOss::Remdir(), XrdOss::Rename(), XrdCmsRRData::Request, XrdCmsRRData::Routing, XrdCms::CmsRRHdr::rrCode, Say, SS, and XrdOss::Unlink().

Referenced by Start().

void XrdCmsFinderTRG::Removed ( const char *  path )

virtual

Notify the cmsd that a file or directory has been deleted. It is only called called on a data server node.

Parameters

path	The logical file name that was removed.

Reimplemented from XrdCmsClient.

References Active, XrdOucStream::Close(), CMSp, XrdSysMutex::Lock(), myData, XrdOucStream::Put(), and XrdSysMutex::UnLock().

int XrdCmsFinderTRG::RunAdmin

(

char *

Path

)

References CMSPath, XrdSysThread::Run(), Say, and XrdCmsStartRsp().

Referenced by XrdCmsFinderRMT::Configure(), and Configure().

int XrdCmsFinderTRG::Space ( XrdOucErrInfo &  Resp, const char *  path, XrdOucEnv *  Info = 0  )

inlinevirtual

Obtain the overall space usage of a cluster. Called only on manager nodes.

Parameters

Resp	Object to hold response or error message.
path	Associated logical path for the space request.
Info	Associated cgi information for path.

Returns

Space information as defined by the response to kYR_statfs. For a typical implementation see XrdCmsNode::do_StatFS().

Implements XrdCmsClient.

void * XrdCmsFinderTRG::Start

(

)

References Active, XrdOucStream::Close(), CMSp, CMSPath, XrdOucStream::FDNum(), Hookup(), XrdSysMutex::Lock(), Login, myData, Process(), XrdOucStream::Put(), XrdCmsRRData::Request, XrdCmsRRData::Routing, Say, XrdSysMutex::UnLock(), and XrdSysTimer::Wait().

Referenced by XrdCmsStartRsp().

bool XrdCmsFinderTRG::VCheck ( XrdVersionInfo &  urVersion )

static

References XrdSysPlugin::VerCmp().

Referenced by XrdOfs::ConfigRedir().

Member Data Documentation

int XrdCmsFinderTRG::Active

private

Referenced by Added(), Hookup(), Removed(), Start(), and XrdCmsFinderTRG().

XrdOucStream* XrdCmsFinderTRG::CMSp

private

Referenced by Added(), Hookup(), Removed(), Start(), XrdCmsFinderTRG(), and ~XrdCmsFinderTRG().

char* XrdCmsFinderTRG::CMSPath

private

Referenced by Hookup(), RunAdmin(), Start(), and XrdCmsFinderTRG().

int XrdCmsFinderTRG::isProxy

private

Referenced by XrdCmsFinderTRG().

int XrdCmsFinderTRG::isRedir

private

Referenced by Configure(), and XrdCmsFinderTRG().

char* XrdCmsFinderTRG::Login

private

Referenced by Start(), XrdCmsFinderTRG(), and ~XrdCmsFinderTRG().

XrdSysMutex XrdCmsFinderTRG::myData

private

Referenced by Added(), Hookup(), Removed(), and Start().

int XrdCmsFinderTRG::myPort

private

Referenced by XrdCmsFinderTRG().

XrdOss* XrdCmsFinderTRG::SS

private

Referenced by Process(), and XrdCmsFinderTRG().

---

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

• XrdCmsFinder.hh
• XrdCmsFinder.cc