XrdFrcProxy Class Reference

#include <XrdFrcProxy.hh>

Collaboration diagram for XrdFrcProxy:

Classes
class	Queues

Public Member Functions
	XrdFrcProxy (XrdSysLogger *lP, const char *iName, int Debug=0)
	~XrdFrcProxy ()
int	Add (char Opc, const char *Lfn, const char *Opq, const char *Usr, const char *Rid, const char *Nop, const char *Pop, int Prty=1)
int	Del (char Opc, const char *Rid)
int	Init (int opX, const char *aPath, int aMode, const char *qPath=0)
int	List (int qType, int qPrty, XrdFrcRequest::Item *Items, int Num)
int	List (Queues &State, char *Buff, int Bsz)

Static Public Attributes
static const int	opAll = 15
static const int	opGet = 1
static const int	opMig = 4
static const int	opPut = 2
static const int	opStg = 8

Detailed Description

Definition at line 39 of file XrdFrcProxy.hh.

Constructor & Destructor Documentation

XrdFrcProxy()

XrdFrcProxy::XrdFrcProxy	(	XrdSysLogger *	lP,
		const char *	iName,
		int	Debug = 0
	)

Definition at line 67 of file XrdFrcProxy.cc.

{
   char buff[256];
 
// Clear agent vector
//
   memset(Agent, 0, sizeof(Agent));
 
// Link the logger to our message facility
//
   Say.logger(lP);
 
// Set the debug flag
//
   if (Debug) Trace.What |= TRACE_ALL;
 
// Develop our internal name
//
   QPath = 0;
   insName = XrdOucUtils::InstName(iName,0);
   sprintf(buff,"%s.%d",XrdOucUtils::InstName(iName),static_cast<int>(getpid()));
   intName = strdup(buff);
}

References Debug, XrdOucUtils::InstName(), XrdSysError::logger(), XrdFrc::Say, XrdFrc::Trace, TRACE_ALL, and XrdOucTrace::What.

Here is the call graph for this function:

~XrdFrcProxy()

XrdFrcProxy::~XrdFrcProxy ( )

inline

Definition at line 74 of file XrdFrcProxy.hh.

{}

Member Function Documentation

Add()

int XrdFrcProxy::Add	(	char	Opc,
		const char *	Lfn,
		const char *	Opq,
		const char *	Usr,
		const char *	Rid,
		const char *	Nop,
		const char *	Pop,
		int	Prty = 1
	)

Definition at line 95 of file XrdFrcProxy.cc.

{
   XrdFrcRequest myReq;
   int n, Options = 0;
   int qType = XrdFrcUtils::MapR2Q(Opc, &Options);
 
// Verify that we can support this operation
//
   if (!Agent[qType]) return -ENOTSUP;
 
// Initialize the request element
//
   memset(&myReq, 0, sizeof(myReq));
   myReq.OPc = Opc;
 
// Insert the Lfn and Opaque information
//
   n = strlen(Lfn);
   if (Opq && *Opq)
      {if (n + strlen(Opq) + 2 > sizeof(myReq.LFN)) return -ENAMETOOLONG;
       strcpy(myReq.LFN, Lfn); strcpy(myReq.LFN+n+1, Opq), myReq.Opaque = n+1;
      } else if (n < int(sizeof(myReq.LFN))) strcpy(myReq.LFN, Lfn);
                else return -ENAMETOOLONG;
 
// Get the LFN offset in case this is a url
//
   if (myReq.LFN[0] != '/' && !(myReq.LFO = XrdFrcUtils::chkURL(myReq.LFN)))
      return -EILSEQ;
 
// Set the user, request id, notification path, and priority
//
   if (Usr && *Usr) strlcpy(myReq.User, Usr, sizeof(myReq.User));
      else strcpy(myReq.User, intName);
   if (Rid) strlcpy(myReq.ID, Rid, sizeof(myReq.ID));
      else *(myReq.ID) = '?';
   if (Nop && *Nop) strlcpy(myReq.Notify, Nop, sizeof(myReq.Notify));
      else *(myReq.Notify) = '-';
   myReq.Prty = Prty;
 
// Establish processing options
//
   myReq.Options = Options | XrdFrcUtils::MapM2O(myReq.Notify, Pop);
 
// Add this request to the queue of requests via the agent
//
   Agent[qType]->Add(myReq);
   return 0;
}

References XrdFrcUtils::chkURL(), XrdFrcRequest::ID, XrdFrcRequest::LFN, XrdFrcRequest::LFO, XrdFrcUtils::MapM2O(), XrdFrcUtils::MapR2Q(), XrdFrcRequest::Notify, XrdFrcRequest::Opaque, XrdFrcRequest::OPc, XrdFrcRequest::Options, XrdFrcRequest::Prty, strlcpy(), and XrdFrcRequest::User.

Referenced by XrdCmsPrepare::Add(), and XrdOssSys::Stage_QT().

Here is the call graph for this function:

Here is the caller graph for this function:

Del()

int XrdFrcProxy::Del	(	char	Opc,
		const char *	Rid
	)

Definition at line 150 of file XrdFrcProxy.cc.

{
   XrdFrcRequest myReq;
   int qType = XrdFrcUtils::MapR2Q(Opc);
 
// Verify that we can support this operation
//
   if (!Agent[qType]) return -ENOTSUP;
 
// Initialize the request element
//
   memset(&myReq, 0, sizeof(myReq));
   strlcpy(myReq.ID, Rid, sizeof(myReq.ID));
 
// Delete the request from the queue
//
   Agent[qType]->Del(myReq);
   return 0;
}

References XrdFrcRequest::ID, XrdFrcUtils::MapR2Q(), and strlcpy().

Referenced by XrdCmsPrepare::Del().

Here is the call graph for this function:

Here is the caller graph for this function:

Init()

int XrdFrcProxy::Init	(	int	opX,
		const char *	aPath,
		int	aMode,
		const char *	qPath = 0
	)

Definition at line 229 of file XrdFrcProxy.cc.

{
   const char *configFN = getenv("XRDCONFIGFN"), *iName = 0;
   int i;
 
// If a qPath was specified, and the "Queues" component will be added later.
// Otherwise, we check the config file to see if there is a qpath there.
// If not we use the aPath which must be unqualified with a component name
// which we will add here). All paths must have the instance name if so needed.
//
        if (qPath) QPath = strdup(qPath);
   else if (!configFN) iName = insName;
   else if (Init2(configFN)) return 0;
 
// Create the queue path directory if it does not exists
//
   if (!QPath && !(QPath = XrdFrcUtils::makePath(iName, aPath, aMode)))
      return 0;
 
// Now create and start an agent for each wanted service
//
   for (i = 0; i < oqNum; i++)
       if (opX & oqMap[i].oType)
          {Agent[oqMap[i].qType]
                = new XrdFrcReqAgent(oqMap[i].qName, oqMap[i].qType);
           if (!Agent[oqMap[i].qType]->Start(QPath, aMode)) return 0;
          }
 
// All done
//
   return 1;
}

References XrdFrcUtils::makePath().

Referenced by XrdOssSys::ConfigStage(), and XrdCmsPrepare::Reset().

Here is the call graph for this function:

Here is the caller graph for this function:

List() [1/2]

int XrdFrcProxy::List	(	int	qType,
		int	qPrty,
		XrdFrcRequest::Item *	Items,
		int	Num
	)

Definition at line 205 of file XrdFrcProxy.cc.

{
   int i, n, Cnt = 0;
 
// List each queue
//
   while(qType & opAll)
        {for (i = 0; i < oqNum; i++) if (oqMap[i].oType & qType) break;
         if (i >= oqNum) return Cnt;
         qType &= ~oqMap[i].oType; n = oqMap[i].qType;
         if (!Agent[n]) continue;
         if (qPrty < 0) Cnt += Agent[n]->List(Items, Num);
            else Cnt += Agent[n]->List(Items, Num, qPrty);
        }
 
// All done
//
   return Cnt;
}

List() [2/2]

int XrdFrcProxy::List	(	XrdFrcProxy::Queues &	State,
		char *	Buff,
		int	Bsz
	)

Definition at line 174 of file XrdFrcProxy.cc.

{
   int i;
 
// Get a queue type
//
do{if (!State.Active)
      while(State.QList & opAll)
           {for (i = 0; i < oqNum; i++) if (oqMap[i].oType & State.QList) break;
            if (i >= oqNum) return 0;
            State.QNow   =  oqMap[i].qType;
            State.QList &= ~oqMap[i].oType;
            if (!Agent[int(State.QNow)]) continue;
            State.Active = 1;
            break;
           }
 
   for (i = State.Prty; i <= XrdFrcRequest::maxPrty; i++)
       if (Agent[int(State.QNow)]->NextLFN(Buff,Bsz,i,State.Offset)) return 1;
          else State.Prty = i+1;
 
   State.Active = 0; State.Offset = 0; State.Prty = 0;
  } while(State.QList & opAll);
 
// We've completed returning all info
//
   return 0;
}

References XrdFrcRequest::maxPrty.

Member Data Documentation

opAll

const int XrdFrcProxy::opAll = 15

static

Definition at line 53 of file XrdFrcProxy.hh.

opGet

const int XrdFrcProxy::opGet = 1

static

Definition at line 49 of file XrdFrcProxy.hh.

opMig

const int XrdFrcProxy::opMig = 4

static

Definition at line 51 of file XrdFrcProxy.hh.

opPut

const int XrdFrcProxy::opPut = 2

static

Definition at line 50 of file XrdFrcProxy.hh.

opStg

const int XrdFrcProxy::opStg = 8

static

Definition at line 52 of file XrdFrcProxy.hh.

Referenced by XrdOssSys::ConfigStage(), and XrdCmsPrepare::Reset().

---

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

• XrdFrcProxy.hh
• XrdFrcProxy.cc