XrdFrmProxy Class Reference

#include <XrdFrmProxy.hh>

Collaboration diagram for XrdFrmProxy:

List of all members.

Classes
struct	o2qMap
class	Queues
Public Member Functions
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	List (Queues &State, char *Buff, int Bsz)
int	List (int qType, int qPrty, XrdFrmRequest::Item *Items, int Num)
int	Init (int opX, const char *aPath, int aMode, const char *qPath=0)
	XrdFrmProxy (XrdSysLogger *lP, const char *iName, int Debug=0)
	~XrdFrmProxy ()
Static Public Attributes
static const int	opGet = 1
static const int	opPut = 2
static const int	opMig = 4
static const int	opStg = 8
static const int	opAll = 15
Private Member Functions
int	Init2 (const char *cfgFN)
int	qChk (XrdOucStream &cFile)
Private Attributes
XrdFrmReqAgent *	Agent [XrdFrmRequest::numQ]
const char *	insName
char *	intName
char *	QPath
Static Private Attributes
static o2qMap	oqMap []
static int	oqNum = sizeof(oqMap)/sizeof(oqMap[0])

---

Constructor & Destructor Documentation

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

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

XrdFrmProxy::~XrdFrmProxy

(

)

[inline]

---

Member Function Documentation

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

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

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

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

References XrdFrmRequest::ID, XrdFrmUtils::MapR2Q(), and strlcpy().

Referenced by XrdCmsPrepare::Del().

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

References XrdFrmUtils::makePath().

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

int XrdFrmProxy::Init2

(

const char *

cfgFN

)

[private]

References XrdOucStream::Attach(), XrdOucStream::Close(), XrdOucStream::Echo(), XrdSysError::Emsg(), XrdOucStream::GetMyFirstWord(), XrdOucStream::LastError(), open(), and XrdFrm::Say.

int XrdFrmProxy::List	(	int	qType,
		int	qPrty,
		XrdFrmRequest::Item *	Items,
		int	Num
	)

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

References XrdFrmProxy::Queues::Active, XrdFrmRequest::maxPrty, XrdFrmProxy::Queues::Offset, XrdFrmProxy::Queues::Prty, XrdFrmProxy::Queues::QList, and XrdFrmProxy::Queues::QNow.

Referenced by XrdCmsPrepare::Reset().

int XrdFrmProxy::qChk

(

XrdOucStream &

cFile

)

[private]

References XrdSysError::Emsg(), XrdOucStream::GetWord(), and XrdFrm::Say.

---

Member Data Documentation

XrdFrmReqAgent* XrdFrmProxy::Agent[XrdFrmRequest::numQ] [private]

const char* XrdFrmProxy::insName [private]

char* XrdFrmProxy::intName [private]

const int XrdFrmProxy::opAll = 15 [static]

Referenced by XrdFrmAdmin::QueryXfrQ().

const int XrdFrmProxy::opGet = 1 [static]

Referenced by XrdFrmAdmin::ConfigProxy(), and XrdFrmAdmin::QueryXfrQ().

const int XrdFrmProxy::opMig = 4 [static]

Referenced by XrdFrmAdmin::ConfigProxy(), and XrdFrmAdmin::QueryXfrQ().

const int XrdFrmProxy::opPut = 2 [static]

Referenced by XrdFrmAdmin::ConfigProxy(), and XrdFrmAdmin::QueryXfrQ().

const int XrdFrmProxy::opStg = 8 [static]

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

XrdFrmProxy::o2qMap XrdFrmProxy::oqMap [static, private]

Initial value:

                               {{"getf", XrdFrmRequest::getQ, opGet},
                                {"migr", XrdFrmRequest::migQ, opMig},
                                {"pstg", XrdFrmRequest::stgQ, opStg},
                                {"putf", XrdFrmRequest::putQ, opPut}}

int XrdFrmProxy::oqNum = sizeof(oqMap)/sizeof(oqMap[0]) [static, private]

char* XrdFrmProxy::QPath [private]

---

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

• XrdFrmProxy.hh
• XrdFrmProxy.cc