#include <XrdCmsPrepArgs.hh>

Inheritance diagram for XrdCmsPrepArgs:

Collaboration diagram for XrdCmsPrepArgs:

Public Member Functions
	XrdCmsPrepArgs (XrdCmsRRData &Arg)
	~XrdCmsPrepArgs ()
void	DoIt ()
void	Queue ()
Public Member Functions inherited from XrdJob
	XrdJob (const char *desc="")
virtual	~XrdJob ()

Static Public Member Functions
static XrdCmsPrepArgs *	getRequest ()
static void	Process ()

Public Attributes
char *	clPath
char *	Ident
struct iovec	ioV [iovNum]
char *	mode
char *	notify
char *	opaque
int	options
char *	path
int	pathlen
char *	prty
char *	reqid
XrdCms::CmsRRHdr	Request
Public Attributes inherited from XrdJob
const char *	Comment
XrdJob *	NextJob

Static Public Attributes
static const int	iovNum = 2

Detailed Description

Definition at line 40 of file XrdCmsPrepArgs.hh.

Constructor & Destructor Documentation

◆ XrdCmsPrepArgs()

XrdCmsPrepArgs::XrdCmsPrepArgs ( XrdCmsRRData & Arg )

Definition at line 56 of file XrdCmsPrepArgs.cc.

                                                : XrdJob("prepare")
{
 
// Copy variable pointers and steal the data buffer behind them
//
   Request = Arg.Request; Request.streamid = 0;
   Ident   = Arg.Ident;
   reqid   = Arg.Reqid;
   notify  = Arg.Notify;
   prty    = Arg.Prty;
   mode    = Arg.Mode;
   path    = Arg.Path;
   pathlen = Arg.PathLen;
   opaque  = Arg.Opaque;
   options = Arg.Request.modifier;
   Data    = Arg.Buff; Arg.Buff = 0; Arg.Blen = 0;
 
// Fill out co-location information
//
   if (options & CmsPrepAddRequest::kYR_stage
   &&  options & CmsPrepAddRequest::kYR_coloc && prty)
      {clPath = prty;
       while(*clPath && *clPath != '/') clPath++;
       if (*clPath != '/') clPath = 0;
      } else clPath = 0;
 
// Fill out the iovec
//
   ioV[0].iov_base = (char *)&Request;
   ioV[0].iov_len  = sizeof(Request);
   ioV[1].iov_base = Data;
   ioV[1].iov_len  = Arg.Dlen;
}

References XrdJob::XrdJob(), XrdCmsRRData::Blen, XrdCmsRRData::Buff, clPath, XrdCmsRRData::Dlen, Ident, XrdCmsRRData::Ident, ioV, XrdCms::CmsPrepAddRequest::kYR_coloc, XrdCms::CmsPrepAddRequest::kYR_stage, XrdCmsRRData::Mode, mode, XrdCms::CmsRRHdr::modifier, XrdCmsRRData::Notify, notify, XrdCmsRRData::Opaque, opaque, options, XrdCmsRRData::Path, path, XrdCmsRRData::PathLen, pathlen, XrdCmsRRData::Prty, prty, XrdCmsRRData::Reqid, reqid, Request, and XrdCmsRRData::Request.

Referenced by getRequest(), and Process().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ ~XrdCmsPrepArgs()

XrdCmsPrepArgs::~XrdCmsPrepArgs ( )

inline

Definition at line 69 of file XrdCmsPrepArgs.hh.

69{if (Data) free(Data);}

Member Function Documentation

◆ DoIt()

void XrdCmsPrepArgs::DoIt ( )

inlinevirtual

Implements XrdJob.

Definition at line 59 of file XrdCmsPrepArgs.hh.

59{if (!XrdCmsNode::do_SelPrep(*this)) delete this;}

XrdCmsNode::do_SelPrep

static int do_SelPrep(XrdCmsPrepArgs &Arg)

Definition XrdCmsNode.cc:1189

References XrdCmsNode::do_SelPrep().

Referenced by Process().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ getRequest()

XrdCmsPrepArgs * XrdCmsPrepArgs::getRequest ( )

static

Definition at line 94 of file XrdCmsPrepArgs.cc.

{
   XrdCmsPrepArgs *parg;
 
// Wait for a request
//
   do {PAQueue.Lock();
       if ((parg = First))
          if (parg == Last) First = Last = 0;
             else           First = parg->Next;
          else {isIdle = 1; PAQueue.UnLock(); PAReady.Wait();}
      } while(parg == 0);
   isIdle = 0;
   PAQueue.UnLock();
   return parg;
}

References XrdCmsPrepArgs().

Referenced by Process().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Process()

void XrdCmsPrepArgs::Process ( )

static

Definition at line 117 of file XrdCmsPrepArgs.cc.

{
   XrdCmsPrepArgs *aP;
 
// Process all queued prepare arguments. If we have data then we do this
// for real. Otherwise, simply do a server selection and, if need be, tell 
// the server to stage the file.
//
   if (Config.DiskOK)
      do {aP = getRequest();
          PrepQ.Prepare(aP);
          delete aP;
         } while(1);
      else
      do {getRequest()->DoIt();
         } while(1);
}

References XrdCmsPrepArgs(), XrdCms::Config, DoIt(), getRequest(), and XrdCms::PrepQ.

Referenced by XrdCmsStartPreparing().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Queue()

void XrdCmsPrepArgs::Queue ( )

Definition at line 139 of file XrdCmsPrepArgs.cc.

{
 
// Lock the queue and add the element and post the waiter
//
   PAQueue.Lock();
   if (First) Last->Next = this;
      else    First      = this;
   Last = this;
   if (isIdle) PAReady.Post();
   PAQueue.UnLock();
}