XrdFrcProxy Class Reference

#include <XrdFrcProxy.hh>

Collaboration diagram for XrdFrcProxy:

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, XrdFrcRequest::Item *Items, int Num)
int	Init (int opX, const char *aPath, int aMode, const char *qPath=0)
	XrdFrcProxy (XrdSysLogger *lP, const char *iName, int Debug=0)
	~XrdFrcProxy ()

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
XrdFrcReqAgent *	Agent [XrdFrcRequest::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

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

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

XrdFrcProxy::~XrdFrcProxy ( )

inline

Member Function Documentation

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
	)

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

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

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

Referenced by XrdCmsPrepare::Del().

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

References XrdFrcUtils::makePath().

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

int XrdFrcProxy::Init2 ( const char *  cfgFN )

private

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

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

References XrdFrcProxy::Queues::Active, XrdFrcRequest::maxPrty, XrdFrcProxy::Queues::Offset, XrdFrcProxy::Queues::Prty, XrdFrcProxy::Queues::QList, and XrdFrcProxy::Queues::QNow.

Referenced by XrdCmsPrepare::Reset().

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

int XrdFrcProxy::qChk ( XrdOucStream &  cFile )

private

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

Member Data Documentation

XrdFrcReqAgent* XrdFrcProxy::Agent[XrdFrcRequest::numQ]

private

const char* XrdFrcProxy::insName

private

char* XrdFrcProxy::intName

private

const int XrdFrcProxy::opAll = 15

static

Referenced by XrdFrmAdmin::QueryXfrQ().

const int XrdFrcProxy::opGet = 1

static

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

const int XrdFrcProxy::opMig = 4

static

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

const int XrdFrcProxy::opPut = 2

static

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

const int XrdFrcProxy::opStg = 8

static

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

XrdFrcProxy::o2qMap XrdFrcProxy::oqMap

staticprivate

Initial value:

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

int XrdFrcProxy::oqNum = sizeof(oqMap)/sizeof(oqMap[0])

staticprivate

char* XrdFrcProxy::QPath

private

---

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

• XrdFrcProxy.hh
• XrdFrcProxy.cc