#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] | 
 1.5.1
 1.5.1