xrootd
|
#include <XrdCmsFinder.hh>
Public Member Functions | |
void | Added (const char *path, int Pend=0) |
int | Configure (char *cfn) |
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 Active, CMSp, CMSPath, XrdCms::IsProxy, isProxy, XrdCms::IsRedir, isRedir, Login, myPort, XrdMonCtrCollector::port, Say, and SS.
void XrdCmsFinderTRG::Added | ( | const char * | path, |
int | Pend = 0 |
||
) | [virtual] |
Implements XrdCmsClient.
References Active, XrdOucStream::Close(), CMSp, XrdSysMutex::Lock(), myData, XrdOucStream::Put(), and XrdSysMutex::UnLock().
int XrdCmsFinderTRG::Configure | ( | char * | cfn | ) | [virtual] |
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 Active, XrdOucStream::Attach(), CMSp, CMSPath, XrdSysMutex::Lock(), myData, opts, Say, stat(), XrdSysMutex::UnLock(), XrdSysTimer::Wait(), and XRDNET_NOEMSG.
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 XrdCmsRRData::Blen, XrdCmsRRData::Buff, XrdCms::CmsRRHdr::datalen, DEBUG, XrdCmsRRData::Dlen, EPNAME, XrdCmsRRData::getBuff(), XrdCms::kYR_mv, XrdCms::kYR_rm, XrdCms::kYR_rmdir, XrdCmsParser::Parse(), XrdCms::Parser, XrdCmsRRData::Path, XrdCmsRRData::Path2, XrdOss::Remdir(), XrdOss::Rename(), XrdCmsRRData::Request, XrdCmsRRData::Routing, XrdCms::CmsRRHdr::rrCode, Say, SS, and XrdOss::Unlink().
Referenced by Start().
void XrdCmsFinderTRG::Removed | ( | const char * | path | ) | [virtual] |
Implements XrdCmsClient.
References Active, XrdOucStream::Close(), CMSp, XrdSysMutex::Lock(), myData, XrdOucStream::Put(), and XrdSysMutex::UnLock().
int XrdCmsFinderTRG::RunAdmin | ( | char * | Path | ) |
References CMSPath, XrdSysThread::Run(), Say, and XrdCmsStartRsp().
Referenced by Configure(), and XrdCmsFinderRMT::Configure().
int XrdCmsFinderTRG::Space | ( | XrdOucErrInfo & | Resp, |
const char * | path | ||
) | [inline, virtual] |
Implements XrdCmsClient.
void * XrdCmsFinderTRG::Start | ( | ) |
References Active, XrdOucStream::Close(), CMSp, CMSPath, XrdOucStream::FDNum(), Hookup(), XrdSysMutex::Lock(), Login, myData, Process(), XrdOucStream::Put(), XrdCmsRRData::Request, XrdCmsRRData::Routing, Say, XrdSysMutex::UnLock(), and XrdSysTimer::Wait().
Referenced by XrdCmsStartRsp().
int XrdCmsFinderTRG::Active [private] |
Referenced by Added(), Hookup(), Removed(), Start(), and XrdCmsFinderTRG().
XrdOucStream* XrdCmsFinderTRG::CMSp [private] |
Referenced by Added(), Hookup(), Removed(), Start(), XrdCmsFinderTRG(), and ~XrdCmsFinderTRG().
char* XrdCmsFinderTRG::CMSPath [private] |
Referenced by Hookup(), RunAdmin(), Start(), and XrdCmsFinderTRG().
int XrdCmsFinderTRG::isProxy [private] |
Referenced by XrdCmsFinderTRG().
int XrdCmsFinderTRG::isRedir [private] |
Referenced by Configure(), and XrdCmsFinderTRG().
char* XrdCmsFinderTRG::Login [private] |
Referenced by Start(), XrdCmsFinderTRG(), and ~XrdCmsFinderTRG().
XrdSysMutex XrdCmsFinderTRG::myData [private] |
int XrdCmsFinderTRG::myPort [private] |
Referenced by XrdCmsFinderTRG().
XrdOss* XrdCmsFinderTRG::SS [private] |
Referenced by Process(), and XrdCmsFinderTRG().