![]() |
XRootD
|
#include <XrdCmsFinder.hh>
Public Member Functions | |
XrdCmsFinderRMT (XrdSysLogger *lp, int whoami=0, int Port=0) | |
~XrdCmsFinderRMT () | |
void | Added (const char *path, int Pend=0) |
int | Configure (const char *cfn, char *Args, XrdOucEnv *EnvInfo) |
int | Forward (XrdOucErrInfo &Resp, const char *cmd, const char *arg1=0, const char *arg2=0, XrdOucEnv *Env1=0, XrdOucEnv *Env2=0) |
int | Locate (XrdOucErrInfo &Resp, const char *path, int flags, XrdOucEnv *Info=0) |
XrdOucTList * | Managers () |
int | Prepare (XrdOucErrInfo &Resp, XrdSfsPrep &pargs, XrdOucEnv *Info=0) |
void | Removed (const char *path) |
void | setSS (XrdOss *thess) |
int | Space (XrdOucErrInfo &Resp, const char *path, XrdOucEnv *Info=0) |
![]() | |
XrdCmsClient (Persona acting) | |
virtual | ~XrdCmsClient () |
Destructor. More... | |
virtual int | isRemote () |
virtual int | Release (int n=1) |
virtual int | Reserve (int n=1) |
virtual int | Resource (int n) |
virtual void | Resume (int Perm=1) |
virtual void | Suspend (int Perm=1) |
virtual void | Utilization (unsigned int util, bool alert=false) |
Static Public Member Functions | |
static bool | VCheck (XrdVersionInfo &urVersion) |
Static Public Attributes | |
static const int | MaxMan = 15 |
Additional Inherited Members | |
![]() | |
enum | Persona { amLocal , amRemote , amTarget } |
![]() | |
Persona | myPersona |
Definition at line 53 of file XrdCmsFinder.hh.
XrdCmsFinderRMT::XrdCmsFinderRMT | ( | XrdSysLogger * | lp, |
int | whoami = 0 , |
||
int | Port = 0 |
||
) |
Definition at line 103 of file XrdCmsFinder.cc.
References XrdCms::IsMeta, XrdCms::IsProxy, XrdCms::IsTarget, XrdSysError::logger(), XrdCms::Say(), XrdSysTrace::SetLogger(), and XrdCms::Trace.
XrdCmsFinderRMT::~XrdCmsFinderRMT | ( | ) |
Definition at line 124 of file XrdCmsFinder.cc.
References XrdOucTList::next, and XrdCmsClientMan::nextManager().
|
inlinevirtual |
Notify the cms of a newly added file or a file whose state has changed on a data server node.
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.
Definition at line 56 of file XrdCmsFinder.hh.
|
virtual |
Configure the client object.
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. |
Implements XrdCmsClient.
Definition at line 138 of file XrdCmsFinder.cc.
References XrdCmsClientConfig::CMSPath, XrdCmsClientConfig::configMan, XrdCmsClientConfig::configMeta, XrdCmsClientConfig::configNorm, XrdCmsClientConfig::configProxy, XrdCmsClientConfig::configSuper, XrdCmsClientConfig::Configure(), XrdCmsClientConfig::ConWait, XrdSysError::Emsg(), XrdProxy::envP, XrdCmsClientConfig::FwdWait, XrdOucEnv::GetPtr(), XrdCmsClientConfig::haveMeta, XrdCms::IsProxy, XrdCms::IsRedir, XrdSysError::logger(), XrdCmsClientConfig::ManList, XrdCmsClientConfig::myVNID, XrdCmsClientConfig::PanList, XrdCmsClientConfig::PrepWait, QTRACE, XrdCmsClientConfig::RepDelay, XrdCmsClientConfig::RepNone, XrdCmsClientConfig::RepWait, XrdCmsFinderTRG::RunAdmin(), XrdCms::Say(), XrdCmsClientMan::setConfig(), XrdCmsClientMan::setNetwork(), XrdCmsSecurity::setSecFunc(), XrdCmsClientConfig::SMode, and XrdCmsClientConfig::SModeP.
|
virtual |
Relay a meta-operation to all nodes in the cluster.
This method is only used on manager nodes and is enabled by the ofs.forward directive.
Resp | Object where messages are to be returned. |
cmd | The operation being performed (see table below). If it starts with a '+' then a response (2way) is needed. Otherwise, a best-effort is all that is all that is required and success can always be returned. |
arg1 | 1st argument to cmd. |
arg2 | 2nd argument to cmd, which may be null if none exists. |
Env1 | Associated environmental information for arg1 (e.g., cgi info which can be retrieved by Env1->Env(<len>)). |
Env2 | Associated environmental information for arg2 (e.g., cgi info which can be retrieved by Env1->Env(<len>)). |
cmd arg1 arg2 cmd arg1 arg2 -------- ------ ------ -------- ------ ------ [+]chmod <path> <mode %o> [+]rmdir <path> 0 [+]mkdir <path> <mode %o> [+]mv <oldp> <newp> [+]mkpath <path> <mode %o> [+]trunc <path> <size %lld> [+]rm <path> 0
Reimplemented from XrdCmsClient.
Definition at line 210 of file XrdCmsFinder.cc.
References XrdCmsClientMan::doDebug, XrdSysError::Emsg(), XrdOucEnv::EnvTidy(), XrdOucErrInfo::getErrUser(), XrdCmsRRData::Ident, XrdCms::kYR_chmod, XrdCms::kYR_dnf, XrdCms::kYR_mkdir, XrdCms::kYR_mkpath, XrdCms::kYR_mv, XrdCms::kYR_rm, XrdCms::kYR_rmdir, XrdCms::kYR_trunc, XrdSysMutex::Lock(), XrdCmsRRData::Mode, XrdCms::CmsRRHdr::modifier, XrdCmsRRData::Opaque, XrdCmsRRData::Opaque2, XrdCmsParser::Pack(), XrdCms::Parser, XrdCmsRRData::Path, XrdCmsRRData::Path2, XrdCmsRRData::Request, XrdCms::CmsRRHdr::rrCode, XrdCms::Say(), XrdCmsClientMan::Send(), XrdOucErrInfo::setErrInfo(), SFS_ERROR, XrdCms::CmsRRHdr::streamid, XrdSysMutex::UnLock(), and XrdSysTimer::Wait().
|
virtual |
Retrieve file location information.
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>)). |
Implements XrdCmsClient.
Definition at line 334 of file XrdCmsFinder.cc.
References XrdCmsRRData::Avoid, XrdCmsClientMan::doDebug, XrdOucEnv::EnvTidy(), XrdOucEnv::Get(), XrdOucErrInfo::getErrUser(), XrdOucErrInfo::getUCap(), XrdCmsRRData::Ident, if(), XrdCms::kYR_locate, XrdCms::kYR_select, XrdCms::kYR_trunc, XrdCms::CmsRRHdr::modifier, XrdCmsRRData::Opaque, XrdCmsRRData::Opts, XrdCmsParser::Pack(), XrdCms::Parser, XrdCmsRRData::Path, XrdCmsRRData::Request, XrdCms::CmsRRHdr::rrCode, XrdOucErrInfo::setErrInfo(), SFS_ERROR, SFS_O_CREAT, SFS_O_FORCE, SFS_O_HNAME, SFS_O_LOCAL, SFS_O_LOCATE, SFS_O_META, SFS_O_MULTIW, SFS_O_NOWAIT, SFS_O_RAWIO, SFS_O_RDWR, SFS_O_REPLICA, SFS_O_RESET, SFS_O_STAT, SFS_O_TRUNC, SFS_O_WRONLY, XrdCms::CmsRRHdr::streamid, XrdOucEI::uIPv4, XrdOucEI::uIPv64, and XrdOucEI::uPrip.
|
inlinevirtual |
Obtain the list of cmsd's being used by a manager node along with their associated index numbers, origin 1.
Reimplemented from XrdCmsClient.
Definition at line 67 of file XrdCmsFinder.hh.
|
virtual |
Start the preparation of a file for future processing.
Resp | Object where message or response is to be returned. |
pargs | Information on which and how to prepare the file. |
Info | Associated environmental information. |
Reimplemented from XrdCmsClient.
Definition at line 528 of file XrdCmsFinder.cc.
References DEBUG, XrdCmsClientMan::doDebug, XrdSysError::Emsg(), EPNAME, XrdOucErrInfo::getErrUser(), XrdCmsRRData::Ident, XrdCms::kYR_prepadd, XrdCms::kYR_prepdel, XrdSysMutex::Lock(), XrdCmsRRData::Mode, XrdCms::CmsRRHdr::modifier, XrdCmsClientMan::Name(), XrdOucTList::next, XrdCmsRRData::Notify, XrdSfsPrep::notify, XrdSfsPrep::oinfo, XrdCmsRRData::Opaque, XrdSfsPrep::opts, XrdCmsParser::Pack(), XrdCms::Parser, XrdCmsRRData::Path, XrdSfsPrep::paths, Prep_COLOC, Prep_FRESH, Prep_PMASK, Prep_SENDACK, Prep_SENDERR, Prep_STAGE, Prep_WMODE, XrdCmsRRData::Prty, XrdCmsRRData::Reqid, XrdSfsPrep::reqid, XrdCmsRRData::Request, XrdCms::CmsRRHdr::rrCode, XrdCms::Say(), XrdCmsClientMan::Send(), XrdOucErrInfo::setErrInfo(), SFS_ERROR, XrdCms::CmsRRHdr::streamid, strlcpy(), XrdOucTList::text, XrdSysMutex::UnLock(), and XrdSysTimer::Wait().
|
inlinevirtual |
Notify the cmsd that a file or directory has been deleted. It is only called called on a data server node.
path | The logical file name that was removed. |
Reimplemented from XrdCmsClient.
Definition at line 72 of file XrdCmsFinder.hh.
|
inline |
Definition at line 74 of file XrdCmsFinder.hh.
|
virtual |
Obtain the overall space usage of a cluster. Called only on manager nodes.
Resp | Object to hold response or error message. |
path | Associated logical path for the space request. |
Info | Associated cgi information for path. |
Implements XrdCmsClient.
Definition at line 837 of file XrdCmsFinder.cc.
References XrdCmsClientMan::doDebug, XrdOucEnv::Get(), XrdOucErrInfo::getErrUser(), XrdCmsRRData::Ident, XrdCms::kYR_statfs, XrdCms::CmsRRHdr::modifier, XrdCmsParser::Pack(), XrdCms::Parser, XrdCmsRRData::Path, XrdCmsRRData::Request, XrdCms::CmsRRHdr::rrCode, XrdOucErrInfo::setErrInfo(), SFS_ERROR, and XrdCms::CmsRRHdr::streamid.
|
static |
Definition at line 877 of file XrdCmsFinder.cc.
References XrdCms::myVersion, and XrdSysPlugin::VerCmp().
|
static |
Definition at line 83 of file XrdCmsFinder.hh.