#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 XrdCmsRRData::Blen, XrdCmsRRData::Buff, clPath, XrdCmsRRData::Dlen, Ident, XrdCmsRRData::Ident, ioV, XrdCms::CmsPrepAddRequest::kYR_coloc, XrdCms::CmsPrepAddRequest::kYR_stage, mode, XrdCmsRRData::Mode, XrdCms::CmsRRHdr::modifier, notify, XrdCmsRRData::Notify, opaque, XrdCmsRRData::Opaque, options, path, XrdCmsRRData::Path, pathlen, XrdCmsRRData::PathLen, prty, XrdCmsRRData::Prty, reqid, XrdCmsRRData::Reqid, Request, XrdCmsRRData::Request, and XrdCms::CmsRRHdr::streamid.

◆ ~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 XrdSysMutex::Lock(), XrdSysMutex::UnLock(), and XrdSysSemaphore::Wait().

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 XrdCms::Config, XrdCmsConfig::DiskOK, DoIt(), getRequest(), and XrdCmsPrepare::Prepare().

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();
}