XrdCmsFinderRMT Class Reference

#include <XrdCmsFinder.hh>

Inheritance diagram for XrdCmsFinderRMT:

Collaboration diagram for XrdCmsFinderRMT:

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)
Public Member Functions inherited from XrdCmsClient
	XrdCmsClient (Persona acting)
virtual	~XrdCmsClient ()
	Destructor.
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
Public Types inherited from XrdCmsClient
enum	Persona {   amLocal ,   amRemote ,   amTarget }
Protected Attributes inherited from XrdCmsClient
Persona	myPersona

Detailed Description

Definition at line 53 of file XrdCmsFinder.hh.

Constructor & Destructor Documentation

XrdCmsFinderRMT()

XrdCmsFinderRMT::XrdCmsFinderRMT	(	XrdSysLogger *	lp,
		int	whoami = 0,
		int	Port = 0
	)

Definition at line 103 of file XrdCmsFinder.cc.

               : XrdCmsClient(XrdCmsClient::amRemote)
{
     myManagers  = 0;
     myManCount  = 0;
     myManList   = 0;
     myPort      = Port;
     SMode       = 0;
     sendID      = 0;
     isMeta      = whoami & IsMeta;
     isProxy     = whoami & IsProxy;
     isTarget    = whoami & IsTarget;
     savePath    = 0;
     Say.logger(lp);
     Trace.SetLogger(lp);
}

References XrdCms::IsMeta, XrdCms::IsProxy, XrdCms::IsTarget, XrdSysError::logger(), XrdCms::Say, XrdSysTrace::SetLogger(), and XrdCms::Trace.

Here is the call graph for this function:

~XrdCmsFinderRMT()

XrdCmsFinderRMT::~XrdCmsFinderRMT

(

)

Definition at line 124 of file XrdCmsFinder.cc.

{
    XrdCmsClientMan *mp, *nmp = myManagers;
    XrdOucTList *tp, *tpp = myManList;
 
    while((mp = nmp)) {nmp = mp->nextManager(); delete mp;}
 
    while((tp = tpp)) {tpp = tp->next; delete tp;}
}

References XrdOucTList::next, and XrdCmsClientMan::nextManager().

Here is the call graph for this function:

Member Function Documentation

Added()

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

inlinevirtual

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.

Definition at line 56 of file XrdCmsFinder.hh.

{}

Configure()

int XrdCmsFinderRMT::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.

Definition at line 138 of file XrdCmsFinder.cc.

{
   XrdCmsClientConfig             config;
   XrdCmsClientConfig::configHow  How;
   XrdCmsClientConfig::configWhat What;
   XrdInet *netP;
   int Topts = IsRedir;
 
// Establish what we will be configuring
//
   if (isProxy)
      {How = XrdCmsClientConfig::configProxy; Topts |= IsProxy;}
      else if (isMeta) How = XrdCmsClientConfig::configMeta;
              else     How = XrdCmsClientConfig::configNorm;
   What = (isTarget ? XrdCmsClientConfig::configSuper
                    : XrdCmsClientConfig::configMan);
 
// Establish the network interface that the caller must provide
//
   if (!envP || !(netP = (XrdInet *)envP->GetPtr("XrdInet*")))
      {Say.Emsg("Finder", "Network not defined; unable to connect to cmsd.");
       return 0;
      }
   XrdCmsClientMan::setNetwork(netP);
   XrdCmsClientMan::setConfig(cfn);
   XrdCmsSecurity::setSecFunc(envP->GetPtr("XrdSecGetProtocol*"));
 
// Now call the configration object
//
   if (config.Configure(cfn, What, How)) return 0;
 
// Set configured values and start the managers
//
   CMSPath    = config.CMSPath;
   RepDelay   = config.RepDelay;
   RepNone    = config.RepNone;
   RepWait    = config.RepWait;
   ConWait    = config.ConWait;
   FwdWait    = config.FwdWait;
   PrepWait   = config.PrepWait;
   if (isProxy)
           {SMode = config.SModeP;
            StartManagers(config.PanList);
            config.PanList = 0;
           }
      else {SMode = config.SMode;
            StartManagers(config.ManList);
            config.ManList = 0;
           }
 
// If we are tracing or if redirect monitoring is enabled, we will need
// to save path information.
//
   if (QTRACE(Redirect) || getenv("XRDMONRDR")) savePath = 1;
 
// If we are a plain manager but have a meta manager then we must start
// a responder (that we will hide) to pass through the port number.
//
   if (!isMeta && !isTarget && config.haveMeta)
      {XrdCmsFinderTRG *Rsp = new XrdCmsFinderTRG(Say.logger(),Topts,myPort);
       return Rsp->RunAdmin(CMSPath, config.myVNID);
      }
 
// All done
//
   return 1;
}

References XrdCmsClientConfig::CMSPath, XrdCmsClientConfig::configMan, XrdCmsClientConfig::configMeta, XrdCmsClientConfig::configNorm, XrdCmsClientConfig::configProxy, XrdCmsClientConfig::configSuper, XrdCmsClientConfig::Configure(), XrdCmsClientConfig::ConWait, XrdSysError::Emsg(), 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.

Here is the call graph for this function:

Forward()

int XrdCmsFinderRMT::Forward ( XrdOucErrInfo &  Resp, const char *  cmd, const char *  arg1 = 0, const char *  arg2 = 0, XrdOucEnv *  Env1 = 0, XrdOucEnv *  Env2 = 0  )

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.

Parameters

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

Returns

As explained under "return conventions".

Reimplemented from XrdCmsClient.

Definition at line 210 of file XrdCmsFinder.cc.

{
   static XrdSysMutex fwdMutex;
   static struct timeval fwdClk = {time(0),0};
   static const int xNum   = 12;
 
   XrdCmsClientMan *Manp;
   XrdCmsRRData     Data;
   unsigned int     iMan;
   int              iovcnt, is2way, doAll = 0, opQ1Len = 0, opQ2Len = 0;
   char             Work[xNum*12];
   struct iovec     xmsg[xNum];
 
// Encode the request as a redirector command
//
   if ((is2way = (*cmd == '+'))) cmd++;
 
        if (!strcmp("chmod", cmd)) Data.Request.rrCode = kYR_chmod;
   else if (!strcmp("mkdir", cmd)) Data.Request.rrCode = kYR_mkdir;
   else if (!strcmp("mkpath",cmd)) Data.Request.rrCode = kYR_mkpath;
   else if (!strcmp("mv",    cmd)){Data.Request.rrCode = kYR_mv;    doAll=1;}
   else if (!strcmp("rm",    cmd)){Data.Request.rrCode = kYR_rm;    doAll=1;}
   else if (!strcmp("rmdir", cmd)){Data.Request.rrCode = kYR_rmdir; doAll=1;}
   else if (!strcmp("trunc", cmd)) Data.Request.rrCode = kYR_trunc;
   else {Say.Emsg("Finder", "Unable to forward '", cmd, "'.");
         Resp.setErrInfo(EINVAL, "Internal error processing file.");
         return SFS_ERROR;
        }
 
// Fill out the RR data structure
//
   Data.Ident   = (char *)(XrdCmsClientMan::doDebug ? Resp.getErrUser() : "");
   Data.Path    = (char *)arg1;
   Data.Mode    = (char *)arg2;
   Data.Path2   = (char *)arg2;
   Data.Opaque  = (Env1 ? Env1->EnvTidy(opQ1Len) : 0);
   Data.Opaque2 = (Env2 ? Env2->EnvTidy(opQ2Len) : 0);
 
// Pack the arguments
//
   if (!(iovcnt = Parser.Pack(int(Data.Request.rrCode), &xmsg[1], &xmsg[xNum],
                              (char *)&Data, Work)))
      {Resp.setErrInfo(EINVAL, "Internal error processing file.");
       return SFS_ERROR;
      }
 
// Insert the header into the stream
//
   Data.Request.streamid = 0;
   Data.Request.modifier = 0;
   xmsg[0].iov_base      = (char *)&Data.Request;
   xmsg[0].iov_len       = sizeof(Data.Request);
 
// This may be a 2way message. If so, use the longer path.
//
   if (is2way) return send2Man(Resp, (arg1 ? arg1 : "/"), xmsg, iovcnt+1);
 
// Check if we have exceeded the maximum rate for requests. If we have, we
// will wait to repace the stream so as to not burden the cmsd.
//
   if (doAll && FwdWait)
      {struct timeval nowClk;
       time_t Window;
       fwdMutex.Lock();
       gettimeofday(&nowClk, 0);
       fwdClk.tv_sec  = nowClk.tv_sec  - fwdClk.tv_sec;
       fwdClk.tv_usec = nowClk.tv_usec - fwdClk.tv_usec;
       if (fwdClk.tv_usec < 0) {fwdClk.tv_sec--; fwdClk.tv_usec += 1000000;}
       Window = fwdClk.tv_sec*1000 + fwdClk.tv_usec/1000;
       if (Window < FwdWait) XrdSysTimer::Wait(FwdWait - Window);
       fwdClk = nowClk;
       fwdMutex.UnLock();
      }
 
// Select the right manager for this request
//
   if (!(Manp = SelectManager(Resp, (arg1 ? arg1 : "/")))) return ConWait;
 
// Send message and simply wait for the reply
//
   if (Manp->Send(iMan, xmsg, iovcnt+1))
      {if (doAll)
          {Data.Request.modifier |= kYR_dnf;
           Inform(Manp, xmsg, iovcnt+1);
          }
       return 0;
      }
 
// Indicate client should retry later
//
   Resp.setErrInfo(RepDelay, "");
   return RepDelay;
}

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

Here is the call graph for this function:

Locate()

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

virtual

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.

Definition at line 334 of file XrdCmsFinder.cc.

{
   static const int xNum   = 12;
 
   XrdCmsRRData   Data;
   int            n, iovcnt;
   char           Work[xNum*12];
   struct iovec   xmsg[xNum];
   char          *triedRC, *affmode;
 
// Fill out the RR data structure
//
   Data.Ident   = (char *)(XrdCmsClientMan::doDebug ? Resp.getErrUser() : "");
   Data.Path    = (char *)path;
   Data.Opaque  = (Env ? Env->EnvTidy(n)   : 0);
   Data.Avoid   = (Env ? Env->Get("tried") : 0);
 
// Set options and command
//
   if (flags & SFS_O_LOCATE)
      {bool doAll = (flags & SFS_O_FORCE) != 0;
       if (flags & SFS_O_LOCAL) return LocLocal(Resp, Env);
       Data.Request.rrCode = kYR_locate;
       Data.Opts = (flags & SFS_O_NOWAIT ? CmsLocateRequest::kYR_asap    : 0)
                 | (flags & SFS_O_RESET  ? CmsLocateRequest::kYR_refresh : 0);
       if (Resp.getUCap() & XrdOucEI::uPrip)
          Data.Opts |= CmsLocateRequest::kYR_prvtnet;
       if (Resp.getUCap() & XrdOucEI::uIPv4)
         {Data.Opts |= (Resp.getUCap() & XrdOucEI::uIPv64 || doAll
                     ?  CmsLocateRequest::kYR_retipv46 : 0);
         } else {
          Data.Opts |= (Resp.getUCap() & XrdOucEI::uIPv64 || doAll
                     ?  CmsLocateRequest::kYR_retipv64 :
                        CmsLocateRequest::kYR_retipv6);
         }
       if (flags & SFS_O_HNAME) Data.Opts |= CmsLocateRequest::kYR_retname;
       if (flags & SFS_O_RAWIO) Data.Opts |= CmsLocateRequest::kYR_retuniq;
       if (doAll)               Data.Opts |= CmsLocateRequest::kYR_listall;
      } else
  {     Data.Request.rrCode = kYR_select;
        if (flags & SFS_O_TRUNC) Data.Opts = CmsSelectRequest::kYR_trunc;
   else if (flags & SFS_O_CREAT)
           {   Data.Opts = CmsSelectRequest::kYR_create;
            if (flags & SFS_O_REPLICA)
               Data.Opts|= CmsSelectRequest::kYR_replica;
           }
   else if (flags & SFS_O_STAT)  Data.Opts = CmsSelectRequest::kYR_stat;
   else                          Data.Opts = 0;
 
   Data.Opts |= (flags & (SFS_O_WRONLY | SFS_O_RDWR)
              ? CmsSelectRequest::kYR_write : CmsSelectRequest::kYR_read);
 
   if (flags & SFS_O_META)      Data.Opts  |= CmsSelectRequest::kYR_metaop;
 
   if (flags & SFS_O_NOWAIT)    Data.Opts  |= CmsSelectRequest::kYR_online;
 
   if (flags & SFS_O_RESET)     Data.Opts  |= CmsSelectRequest::kYR_refresh;
 
   if (flags & SFS_O_MULTIW)    Data.Opts  |= CmsSelectRequest::kYR_mwfiles;
 
   if (Env && (affmode = Env->Get("cms.aff")))
      {     if (*affmode == 'n') Data.Opts |= CmsSelectRequest::kYR_aNone;
       else if (*affmode == 'S') Data.Opts |= CmsSelectRequest::kYR_aStrict;
       else if (*affmode == 's') Data.Opts |= CmsSelectRequest::kYR_aStrong;
       else if (*affmode == 'w') Data.Opts |= CmsSelectRequest::kYR_aWeak;
      }
 
   if (Resp.getUCap() & XrdOucEI::uPrip)
      Data.Opts |= CmsSelectRequest::kYR_prvtnet;
       if (Resp.getUCap() & XrdOucEI::uIPv4)
         {Data.Opts |= (Resp.getUCap() & XrdOucEI::uIPv64
                     ?  CmsSelectRequest::kYR_retipv46 : 0);
         } else {
          Data.Opts |= (Resp.getUCap() & XrdOucEI::uIPv64
                     ?  CmsSelectRequest::kYR_retipv64 :
                        CmsSelectRequest::kYR_retipv6);
         }
 
   if (Data.Avoid && Env && (triedRC = Env->Get("triedrc")))
      {char *comma = rindex(triedRC, ',');
       if (comma) triedRC = comma+1;
            if (!strcmp(triedRC, "enoent"))
               Data.Opts |= CmsSelectRequest::kYR_tryMISS;
       else if (!strcmp(triedRC, "ioerr"))
               Data.Opts |= CmsSelectRequest::kYR_tryIOER;
       else if (!strcmp(triedRC, "fserr"))
               Data.Opts |= CmsSelectRequest::kYR_tryFSER;
       else if (!strcmp(triedRC, "srverr"))
               Data.Opts |= CmsSelectRequest::kYR_trySVER;
       else if (!strcmp(triedRC, "resel"))
               Data.Opts |= CmsSelectRequest::kYR_tryRSEL;
       else if (!strcmp(triedRC, "reseg"))
               Data.Opts |= CmsSelectRequest::kYR_tryRSEG;
      }
  }
 
// Pack the arguments
//
   if (!(iovcnt = Parser.Pack(int(Data.Request.rrCode), &xmsg[1], &xmsg[xNum],
                              (char *)&Data, Work)))
      {Resp.setErrInfo(EINVAL, "Internal error processing file.");
       return SFS_ERROR;
      }
 
// Insert the header into the stream
//
   Data.Request.streamid = 0;
   Data.Request.modifier = 0;
   xmsg[0].iov_base      = (char *)&Data.Request;
   xmsg[0].iov_len       = sizeof(Data.Request);
 
// Send the 2way message
//
   return send2Man(Resp, path, xmsg, iovcnt+1);
}

References XrdCmsRRData::Avoid, XrdCmsClientMan::doDebug, XrdOucEnv::EnvTidy(), XrdOucEnv::Get(), XrdOucErrInfo::getErrUser(), XrdOucErrInfo::getUCap(), XrdCmsRRData::Ident, XrdCms::CmsSelectRequest::kYR_aNone, XrdCms::CmsLocateRequest::kYR_asap, XrdCms::CmsSelectRequest::kYR_aStrict, XrdCms::CmsSelectRequest::kYR_aStrong, XrdCms::CmsSelectRequest::kYR_aWeak, XrdCms::CmsSelectRequest::kYR_create, XrdCms::CmsLocateRequest::kYR_listall, XrdCms::kYR_locate, XrdCms::CmsSelectRequest::kYR_metaop, XrdCms::CmsSelectRequest::kYR_mwfiles, XrdCms::CmsSelectRequest::kYR_online, XrdCms::CmsLocateRequest::kYR_prvtnet, XrdCms::CmsSelectRequest::kYR_prvtnet, XrdCms::CmsSelectRequest::kYR_read, XrdCms::CmsLocateRequest::kYR_refresh, XrdCms::CmsSelectRequest::kYR_refresh, XrdCms::CmsSelectRequest::kYR_replica, XrdCms::CmsLocateRequest::kYR_retipv46, XrdCms::CmsSelectRequest::kYR_retipv46, XrdCms::CmsLocateRequest::kYR_retipv6, XrdCms::CmsSelectRequest::kYR_retipv6, XrdCms::CmsLocateRequest::kYR_retipv64, XrdCms::CmsSelectRequest::kYR_retipv64, XrdCms::CmsLocateRequest::kYR_retname, XrdCms::CmsLocateRequest::kYR_retuniq, XrdCms::kYR_select, XrdCms::CmsSelectRequest::kYR_stat, XrdCms::CmsSelectRequest::kYR_trunc, XrdCms::CmsSelectRequest::kYR_tryFSER, XrdCms::CmsSelectRequest::kYR_tryIOER, XrdCms::CmsSelectRequest::kYR_tryMISS, XrdCms::CmsSelectRequest::kYR_tryRSEG, XrdCms::CmsSelectRequest::kYR_tryRSEL, XrdCms::CmsSelectRequest::kYR_trySVER, XrdCms::CmsSelectRequest::kYR_write, XrdCms::CmsRRHdr::modifier, XrdCmsRRData::Opaque, XrdCmsRRData::Opts, XrdCmsParser::Pack(), 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.

Here is the call graph for this function:

Managers()

XrdOucTList * XrdCmsFinderRMT::Managers ( )

inlinevirtual

Obtain the list of cmsd's being used by a manager node along with their associated index numbers, origin 1.

Returns

The list of cmsd's being used. The list is considered permanent and is not deleted.

Reimplemented from XrdCmsClient.

Definition at line 67 of file XrdCmsFinder.hh.

{return myManList;}

Prepare()

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

virtual

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.

Definition at line 528 of file XrdCmsFinder.cc.

{
   EPNAME("Prepare")
   static const int   xNum   = 16;
   static XrdSysMutex prepMutex;
 
   XrdCmsRRData       Data;
   XrdOucTList       *tp, *op;
   XrdCmsClientMan   *Manp = 0;
 
   unsigned int       iMan;
   int                iovcnt = 0, NoteLen, n;
   char               Prty[1032], *NoteNum = 0, *colocp = 0;
   char               Work[xNum*12];
   struct iovec       xmsg[xNum];
 
// Prefill the RR data structure and iovec
//
   Data.Ident = (char *)(XrdCmsClientMan::doDebug ? Resp.getErrUser() : "");
   Data.Reqid = pargs.reqid;
   Data.Request.streamid = 0;
   Data.Request.modifier = 0;
   xmsg[0].iov_base = (char *)&Data.Request;
   xmsg[0].iov_len  = sizeof(Data.Request);
 
// Check for a cancel request
//
   if (!(tp = pargs.paths))
      {Data.Request.rrCode = kYR_prepdel;
       if (!(iovcnt = Parser.Pack(kYR_prepdel, &xmsg[1], &xmsg[xNum],
                                 (char *)&Data, Work)))
          {Resp.setErrInfo(EINVAL, "Internal error processing file.");
           return SFS_ERROR;
          }
       if (!(Manp = SelectManager(Resp, 0))) return ConWait;
       if (Manp->Send(iMan, (const struct iovec *)&xmsg, iovcnt+1)) return 0;
       DEBUG("Finder: Failed to send prepare cancel to " 
             <<Manp->Name() <<" reqid=" <<pargs.reqid);
       Resp.setErrInfo(RepDelay, "");
       return RepDelay;
      }
 
// Set prepadd options
//
   Data.Request.modifier =
               (pargs.opts & Prep_STAGE ? CmsPrepAddRequest::kYR_stage : 0)
             | (pargs.opts & Prep_WMODE ? CmsPrepAddRequest::kYR_write : 0)
             | (pargs.opts & Prep_FRESH ? CmsPrepAddRequest::kYR_fresh : 0);
 
// Set coloc information if staging wanted and there are atleast two paths
//
 
// Set the prepadd mode
//
   if (!pargs.notify || !(pargs.opts & Prep_SENDACK))
      {Data.Mode   = (char *)(pargs.opts & Prep_WMODE ? "wq" : "rq");
       Data.Notify = (char *)"*";
       NoteNum     = 0;
      } else {
       NoteLen      = strlen(pargs.notify);
       Data.Notify  = (char *)malloc(NoteLen+16);
       strcpy(Data.Notify, pargs.notify);
       NoteNum = Data.Notify+NoteLen; *NoteNum++ = '-';
       if (pargs.opts & Prep_SENDERR) 
               Data.Mode = (char *)(pargs.opts & Prep_WMODE ? "wn"  : "rn");
          else Data.Mode = (char *)(pargs.opts & Prep_WMODE ? "wnq" : "rnq");
      }
 
// Set the priority (if co-locate, add in the co-locate path)
//
   n = sprintf(Prty, "%d", (pargs.opts & Prep_PMASK));
   if (pargs.opts & Prep_STAGE && pargs.opts & Prep_COLOC
   &&  pargs.paths && pargs.paths->next) 
      {colocp = Prty + n;
       strlcpy(colocp+1, pargs.paths->text, sizeof(Prty)-n-1);
      }
   Data.Prty = Prty;
 
// Distribute out paths to the various managers
//
   Data.Request.rrCode = kYR_prepadd;
   op = pargs.oinfo;
   while(tp)
        {if (NoteNum) sprintf(NoteNum, "%d", tp->val);
         Data.Path = tp->text;
         if (op) {Data.Opaque = op->text; op = op->next;}
            else  Data.Opaque = 0;
         if (!(iovcnt = Parser.Pack(kYR_prepadd, &xmsg[1], &xmsg[xNum],
                                   (char *)&Data, Work))) break;
         if (!(Manp = SelectManager(Resp, tp->text))) break;
         DEBUG("Finder: Sending " <<Manp->Name() <<' ' <<Data.Reqid
                      <<' ' <<Data.Path);
         if (!Manp->Send(iMan, (const struct iovec *)&xmsg, iovcnt+1)) break;
         if ((tp = tp->next))
            {prepMutex.Lock(); XrdSysTimer::Wait(PrepWait); prepMutex.UnLock();}
         if (colocp) {Data.Request.modifier |= CmsPrepAddRequest::kYR_coloc;
                      *colocp = ' '; colocp = 0;
                     }
        }
 
// Check if all went well
//
   if (NoteNum) free(Data.Notify);
   if (!tp) return 0;
 
// Decode the error condition
//
   if (!Manp) return ConWait;
 
   if (!iovcnt)
      {Say.Emsg("Finder", "Unable to send prepadd; too much data.");
       Resp.setErrInfo(EINVAL, "Internal error processing file.");
       return SFS_ERROR;
      }
 
   Resp.setErrInfo(RepDelay, "");
   DEBUG("Finder: Failed to send prepare to " <<(Manp ? Manp->Name() : "?")
                  <<" reqid=" <<pargs.reqid);
   return RepDelay;
}

References DEBUG, XrdCmsClientMan::doDebug, XrdSysError::Emsg(), EPNAME, XrdOucErrInfo::getErrUser(), XrdCmsRRData::Ident, XrdCms::CmsPrepAddRequest::kYR_coloc, XrdCms::CmsPrepAddRequest::kYR_fresh, XrdCms::kYR_prepadd, XrdCms::kYR_prepdel, XrdCms::CmsPrepAddRequest::kYR_stage, XrdCms::CmsPrepAddRequest::kYR_write, XrdSysMutex::Lock(), XrdCmsRRData::Mode, XrdCms::CmsRRHdr::modifier, XrdCmsClientMan::Name(), XrdOucTList::next, XrdCmsRRData::Notify, XrdSfsPrep::notify, XrdSfsPrep::oinfo, XrdCmsRRData::Opaque, XrdSfsPrep::opts, XrdCmsParser::Pack(), 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().

Here is the call graph for this function:

Removed()

void XrdCmsFinderRMT::Removed ( const char *  path )

inlinevirtual

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.

Definition at line 72 of file XrdCmsFinder.hh.

{}

setSS()

void XrdCmsFinderRMT::setSS ( XrdOss *  thess )

inline

Definition at line 74 of file XrdCmsFinder.hh.

{}

Space()

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

virtual

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.

Definition at line 837 of file XrdCmsFinder.cc.

{
   static const int xNum   = 4;
 
   XrdCmsRRData   Data;
   int            iovcnt;
   char           Work[xNum*12];
   struct iovec   xmsg[xNum];
 
// Fill out the RR data structure
//
   Data.Ident   = (char *)(XrdCmsClientMan::doDebug ? Resp.getErrUser() : "");
   Data.Path    = (char *)path;
 
// Pack the arguments
//
   if (!(iovcnt = Parser.Pack(kYR_statfs, &xmsg[1], &xmsg[xNum],
                                  (char *)&Data, Work)))
      {Resp.setErrInfo(EINVAL, "Internal error processing file.");
       return SFS_ERROR;
      }
 
// Insert the header into the stream
//
   Data.Request.rrCode   = kYR_statfs;
   Data.Request.streamid = 0;
   Data.Request.modifier = (eP && eP->Get("cms.qvfs")
                         ?  CmsStatfsRequest::kYR_qvfs : 0);
   xmsg[0].iov_base      = (char *)&Data.Request;
   xmsg[0].iov_len       = sizeof(Data.Request);
 
// Send the 2way message
//
   return send2Man(Resp, path, xmsg, iovcnt+1);
}

References XrdCmsClientMan::doDebug, XrdOucEnv::Get(), XrdOucErrInfo::getErrUser(), XrdCmsRRData::Ident, XrdCms::CmsStatfsRequest::kYR_qvfs, XrdCms::kYR_statfs, XrdCms::CmsRRHdr::modifier, XrdCmsParser::Pack(), XrdCmsRRData::Path, XrdCmsRRData::Request, XrdCms::CmsRRHdr::rrCode, XrdOucErrInfo::setErrInfo(), SFS_ERROR, and XrdCms::CmsRRHdr::streamid.

Here is the call graph for this function:

VCheck()

bool XrdCmsFinderRMT::VCheck ( XrdVersionInfo &  urVersion )

static

Definition at line 877 of file XrdCmsFinder.cc.

{
   return XrdSysPlugin::VerCmp(urVersion, myVersion);
}

References XrdCms::myVersion, and XrdSysPlugin::VerCmp().

Here is the call graph for this function:

Member Data Documentation

MaxMan

const int XrdCmsFinderRMT::MaxMan = 15

static

Definition at line 83 of file XrdCmsFinder.hh.

---

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

• XrdCmsFinder.hh
• XrdCmsFinder.cc