#include <XrdFrmProxy.hh>
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 |
Classes | |
struct | o2qMap |
class | Queues |
Definition at line 21 of file XrdFrmProxy.hh.
XrdFrmProxy::XrdFrmProxy | ( | XrdSysLogger * | lP, | |
const char * | iName, | |||
int | Debug = 0 | |||
) |
Definition at line 51 of file XrdFrmProxy.cc.
References Agent, insName, XrdOucUtils::InstName(), intName, XrdSysError::logger(), QPath, XrdFrm::Say(), sprintf(), Trace, and TRACE_ALL.
XrdFrmProxy::~XrdFrmProxy | ( | ) | [inline] |
Definition at line 56 of file XrdFrmProxy.hh.
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 | |||
) |
Definition at line 79 of file XrdFrmProxy.cc.
References XrdFrmReqAgent::Add(), Agent, XrdFrmUtils::chkURL(), ENOTSUP, intName, XrdFrmUtils::MapM2O(), XrdFrmUtils::MapR2Q(), n, strcpy(), and strlcpy().
Referenced by XrdCmsPrepare::Add(), and XrdOssSys::Stage_QT().
int XrdFrmProxy::Del | ( | char | Opc, | |
const char * | Rid | |||
) |
Definition at line 134 of file XrdFrmProxy.cc.
References Agent, XrdFrmReqAgent::Del(), ENOTSUP, XrdFrmUtils::MapR2Q(), and strlcpy().
Referenced by XrdCmsPrepare::Del().
int XrdFrmProxy::List | ( | Queues & | State, | |
char * | Buff, | |||
int | Bsz | |||
) |
Definition at line 158 of file XrdFrmProxy.cc.
References Agent, i, if(), XrdFrmRequest::maxPrty, XrdFrmReqAgent::NextLFN(), opAll, and oqNum.
Referenced by List(), XrdFrmAdmin::QueryXfrQ(), and XrdCmsPrepare::Reset().
int XrdFrmProxy::List | ( | int | qType, | |
int | qPrty, | |||
XrdFrmRequest::Item * | Items, | |||
int | Num | |||
) |
Definition at line 189 of file XrdFrmProxy.cc.
References Agent, i, XrdFrmReqAgent::List(), List(), n, opAll, and oqNum.
int XrdFrmProxy::Init | ( | int | opX, | |
const char * | aPath, | |||
int | aMode, | |||
const char * | qPath = 0 | |||
) |
Definition at line 213 of file XrdFrmProxy.cc.
References Agent, getenv(), i, Init2(), insName, XrdFrmUtils::makePath(), oqNum, and QPath.
Referenced by XrdFrmAdmin::ConfigProxy(), XrdOssSys::ConfigStage(), and XrdCmsPrepare::Reset().
int XrdFrmProxy::Init2 | ( | const char * | cfgFN | ) | [private] |
Definition at line 250 of file XrdFrmProxy.cc.
References XrdOucStream::Attach(), XrdOucStream::Close(), XrdOucStream::Echo(), XrdSysError::Emsg(), getenv(), XrdOucStream::GetMyFirstWord(), XrdOucStream::LastError(), open, qChk(), and XrdFrm::Say().
Referenced by Init().
int XrdFrmProxy::qChk | ( | XrdOucStream & | cFile | ) | [private] |
Definition at line 287 of file XrdFrmProxy.cc.
References XrdSysError::Emsg(), free(), XrdOucStream::GetWord(), QPath, XrdFrm::Say(), and val.
Referenced by Init2().
const int XrdFrmProxy::opGet = 1 [static] |
Definition at line 31 of file XrdFrmProxy.hh.
Referenced by XrdFrmAdmin::ConfigProxy(), and XrdFrmAdmin::QueryXfrQ().
const int XrdFrmProxy::opPut = 2 [static] |
Definition at line 32 of file XrdFrmProxy.hh.
Referenced by XrdFrmAdmin::ConfigProxy(), and XrdFrmAdmin::QueryXfrQ().
const int XrdFrmProxy::opMig = 4 [static] |
Definition at line 33 of file XrdFrmProxy.hh.
Referenced by XrdFrmAdmin::ConfigProxy(), and XrdFrmAdmin::QueryXfrQ().
const int XrdFrmProxy::opStg = 8 [static] |
Definition at line 34 of file XrdFrmProxy.hh.
Referenced by XrdFrmAdmin::ConfigProxy(), XrdOssSys::ConfigStage(), XrdFrmAdmin::QueryXfrQ(), and XrdCmsPrepare::Reset().
const int XrdFrmProxy::opAll = 15 [static] |
XrdFrmProxy::o2qMap XrdFrmProxy::oqMap [static, private] |
Definition at line 65 of file XrdFrmProxy.hh.
int XrdFrmProxy::oqNum [static, private] |
XrdFrmReqAgent* XrdFrmProxy::Agent[XrdFrmRequest::numQ] [private] |
Definition at line 68 of file XrdFrmProxy.hh.
Referenced by Add(), Del(), Init(), List(), and XrdFrmProxy().
const char* XrdFrmProxy::insName [private] |
char* XrdFrmProxy::intName [private] |
char* XrdFrmProxy::QPath [private] |