|
xrootd
|
#include <XrdCmsFinder.hh>


Public Member Functions | |
| void | Added (const char *path, int Pend=0) |
| int | Configure (char *cfn, XrdOucEnv *EnvInfo) |
| int | Forward (XrdOucErrInfo &Resp, const char *cmd, const char *arg1=0, const char *arg2=0, const char *arg3=0, const char *arg4=0) |
| int | Locate (XrdOucErrInfo &Resp, const char *path, int flags, XrdOucEnv *Info=0) |
| int | Prepare (XrdOucErrInfo &Resp, XrdSfsPrep &pargs) |
| void | Removed (const char *path) |
| int | RunAdmin (char *Path) |
| int | Space (XrdOucErrInfo &Resp, const char *path) |
| void * | Start () |
| XrdCmsFinderTRG (XrdSysLogger *, int, int, XrdOss *theSS=0) | |
| ~XrdCmsFinderTRG () | |
Private Member Functions | |
| void | Hookup () |
| int | Process (XrdCmsRRData &Data) |
Private Attributes | |
| XrdOss * | SS |
| XrdOucStream * | CMSp |
| XrdSysMutex | myData |
| int | myPort |
| char * | CMSPath |
| char * | Login |
| int | isRedir |
| int | isProxy |
| int | Active |
| XrdCmsFinderTRG::XrdCmsFinderTRG | ( | XrdSysLogger * | lp, |
| int | whoami, | ||
| int | port, | ||
| XrdOss * | theSS = 0 |
||
| ) |
References isRedir, XrdCms::IsRedir, isProxy, XrdCms::IsProxy, SS, CMSPath, CMSp, Say, Active, myPort, XrdMonCtrCollector::port, and Login.
| void XrdCmsFinderTRG::Added | ( | const char * | path, |
| int | Pend = 0 |
||
| ) | [virtual] |
Implements XrdCmsClient.
References myData, XrdSysMutex::Lock(), Active, CMSp, XrdOucStream::Put(), XrdOucStream::Close(), and XrdSysMutex::UnLock().
| int XrdCmsFinderTRG::Configure | ( | char * | cfn, |
| XrdOucEnv * | EnvInfo | ||
| ) | [virtual] |
Implements XrdCmsClient.
References isRedir, XrdCmsClientConfig::Configure(), XrdCmsClientConfig::configNorm, RunAdmin(), and XrdCmsClientConfig::CMSPath.
| int XrdCmsFinderTRG::Forward | ( | XrdOucErrInfo & | Resp, |
| const char * | cmd, | ||
| const char * | arg1 = 0, |
||
| const char * | arg2 = 0, |
||
| const char * | arg3 = 0, |
||
| const char * | arg4 = 0 |
||
| ) | [inline, virtual] |
Implements XrdCmsClient.
| void XrdCmsFinderTRG::Hookup | ( | ) | [private] |
References stat(), Say, opts, CMSPath, XrdSysTimer::Wait(), XRDNET_NOEMSG, myData, XrdSysMutex::Lock(), Active, CMSp, XrdOucStream::Attach(), and XrdSysMutex::UnLock().
Referenced by Start().
| int XrdCmsFinderTRG::Locate | ( | XrdOucErrInfo & | Resp, |
| const char * | path, | ||
| int | flags, | ||
| XrdOucEnv * | Info = 0 |
||
| ) | [inline, virtual] |
Implements XrdCmsClient.
| int XrdCmsFinderTRG::Prepare | ( | XrdOucErrInfo & | Resp, |
| XrdSfsPrep & | pargs | ||
| ) | [inline, virtual] |
Implements XrdCmsClient.
| int XrdCmsFinderTRG::Process | ( | XrdCmsRRData & | Data | ) | [private] |
References EPNAME, XrdCmsRRData::Dlen, XrdCmsRRData::Request, XrdCms::CmsRRHdr::datalen, Say, XrdCmsRRData::Buff, XrdCmsRRData::Blen, XrdCmsRRData::getBuff(), XrdCmsRRData::Routing, XrdCms::CmsRRHdr::rrCode, XrdCms::kYR_mv, XrdCms::kYR_rm, XrdCmsRRData::Path2, XrdCms::kYR_rmdir, XrdCms::Parser, XrdCmsParser::Parse(), DEBUG, XrdCmsRRData::Path, SS, XrdOss::Rename(), XrdOss::Unlink(), and XrdOss::Remdir().
Referenced by Start().
| void XrdCmsFinderTRG::Removed | ( | const char * | path | ) | [virtual] |
Implements XrdCmsClient.
References myData, XrdSysMutex::Lock(), Active, CMSp, XrdOucStream::Put(), XrdOucStream::Close(), and XrdSysMutex::UnLock().
| int XrdCmsFinderTRG::RunAdmin | ( | char * | Path | ) |
References CMSPath, Say, XrdSysThread::Run(), and XrdCmsStartRsp().
Referenced by XrdCmsFinderRMT::Configure(), and Configure().
| int XrdCmsFinderTRG::Space | ( | XrdOucErrInfo & | Resp, |
| const char * | path | ||
| ) | [inline, virtual] |
Implements XrdCmsClient.
| void * XrdCmsFinderTRG::Start | ( | ) |
References Hookup(), myData, XrdSysMutex::Lock(), CMSp, XrdOucStream::Put(), Login, XrdSysMutex::UnLock(), XrdCmsRRData::Routing, XrdOucStream::FDNum(), XrdCmsRRData::Request, Process(), XrdOucStream::Close(), Active, Say, CMSPath, and XrdSysTimer::Wait().
Referenced by XrdCmsStartRsp().
int XrdCmsFinderTRG::Active [private] |
Referenced by XrdCmsFinderTRG(), Added(), Removed(), Start(), and Hookup().
XrdOucStream* XrdCmsFinderTRG::CMSp [private] |
Referenced by XrdCmsFinderTRG(), ~XrdCmsFinderTRG(), Added(), Removed(), Start(), and Hookup().
char* XrdCmsFinderTRG::CMSPath [private] |
Referenced by XrdCmsFinderTRG(), RunAdmin(), Start(), and Hookup().
int XrdCmsFinderTRG::isProxy [private] |
Referenced by XrdCmsFinderTRG().
int XrdCmsFinderTRG::isRedir [private] |
Referenced by XrdCmsFinderTRG(), and Configure().
char* XrdCmsFinderTRG::Login [private] |
Referenced by XrdCmsFinderTRG(), ~XrdCmsFinderTRG(), and Start().
XrdSysMutex XrdCmsFinderTRG::myData [private] |
int XrdCmsFinderTRG::myPort [private] |
Referenced by XrdCmsFinderTRG().
XrdOss* XrdCmsFinderTRG::SS [private] |
Referenced by XrdCmsFinderTRG(), and Process().
1.7.5