![]() |
XRootD
|
#include <XrdCmsClientMan.hh>
Public Member Functions | |
XrdCmsClientMan (char *host, int port, int cw, int nr, int rw, int rd) | |
~XrdCmsClientMan () | |
int | delayResp (XrdOucErrInfo &Resp) |
int | isActive () |
int | manPort () |
char * | Name () |
XrdCmsClientMan * | nextManager () |
char * | NPfx () |
int | Send (unsigned int &iMan, char *msg, int mlen=0) |
int | Send (unsigned int &iMan, const struct iovec *iov, int iovcnt, int iotot=0) |
void | setNext (XrdCmsClientMan *np) |
void * | Start () |
int | Suspended () |
int | waitTime () |
int | whatsUp (const char *user, const char *path, unsigned int iMan) |
Static Public Member Functions | |
static void | setConfig (const char *cfn) |
static void | setNetwork (XrdInet *nP) |
Static Public Attributes | |
static char | doDebug = 0 |
Definition at line 47 of file XrdCmsClientMan.hh.
XrdCmsClientMan::XrdCmsClientMan | ( | char * | host, |
int | port, | ||
int | cw, | ||
int | nr, | ||
int | rw, | ||
int | rd | ||
) |
Definition at line 66 of file XrdCmsClientMan.cc.
References XrdOucBuffPool::Alloc(), XrdSysMutex::Lock(), XrdOucEI::Max_Error_Len, and XrdSysMutex::UnLock().
XrdCmsClientMan::~XrdCmsClientMan | ( | ) |
Definition at line 112 of file XrdCmsClientMan.cc.
References XrdLink::Close(), and XrdOucBuffer::Recycle().
int XrdCmsClientMan::delayResp | ( | XrdOucErrInfo & | Resp | ) |
Definition at line 124 of file XrdCmsClientMan.cc.
References XrdCmsRespQ::Add(), XrdCmsResp::Alloc(), XrdSysError::Emsg(), XrdOucErrInfo::getErrInfo(), XrdOucErrInfo::getErrUser(), XrdSysSemaphore::Post(), XrdCmsRespQ::Purge(), XrdCms::Say, XrdOucErrInfo::setErrInfo(), SFS_ERROR, SFS_STALL, and SFS_STARTED.
|
inline |
|
inline |
Definition at line 62 of file XrdCmsClientMan.hh.
|
inline |
Definition at line 59 of file XrdCmsClientMan.hh.
Referenced by XrdCmsFinderRMT::Prepare().
|
inline |
Definition at line 57 of file XrdCmsClientMan.hh.
Referenced by XrdCmsFinderRMT::~XrdCmsFinderRMT().
|
inline |
Definition at line 60 of file XrdCmsClientMan.hh.
int XrdCmsClientMan::Send | ( | unsigned int & | iMan, |
char * | msg, | ||
int | mlen = 0 |
||
) |
Definition at line 167 of file XrdCmsClientMan.cc.
References XrdLink::Close(), XrdSysMutex::Lock(), XrdLink::Send(), and XrdSysMutex::UnLock().
Referenced by XrdCmsFinderRMT::Forward(), and XrdCmsFinderRMT::Prepare().
int XrdCmsClientMan::Send | ( | unsigned int & | iMan, |
const struct iovec * | iov, | ||
int | iovcnt, | ||
int | iotot = 0 |
||
) |
Definition at line 197 of file XrdCmsClientMan.cc.
References XrdLink::Close(), XrdSysMutex::Lock(), XrdLink::Send(), and XrdSysMutex::UnLock().
|
inlinestatic |
Definition at line 81 of file XrdCmsClientMan.hh.
Referenced by XrdCmsFinderRMT::Configure().
|
inlinestatic |
Definition at line 79 of file XrdCmsClientMan.hh.
Referenced by XrdCmsFinderRMT::Configure().
|
inline |
Definition at line 77 of file XrdCmsClientMan.hh.
void * XrdCmsClientMan::Start | ( | ) |
Definition at line 225 of file XrdCmsClientMan.cc.
References XrdLink::Close(), XrdSysError::Emsg(), XrdCms::kYR_status, XrdCms::kYR_waitresp, XrdSysMutex::Lock(), XrdCms::CmsRRHdr::modifier, XrdCmsClientMsg::Reply(), XrdCms::CmsRRHdr::rrCode, XrdCms::Say, XrdSysTimer::Snooze(), XrdSysMutex::UnLock(), and XrdSysSemaphore::Wait().
Referenced by XrdCmsStartManager().
|
inline |
Definition at line 70 of file XrdCmsClientMan.hh.
|
inline |
int XrdCmsClientMan::whatsUp | ( | const char * | user, |
const char * | path, | ||
unsigned int | iMan | ||
) |
Definition at line 267 of file XrdCmsClientMan.cc.
References XrdLink::Close(), EPNAME, XrdCmsClientMsg::inQ(), XrdSysMutex::Lock(), TRACE, and XrdSysMutex::UnLock().
|
static |
Definition at line 51 of file XrdCmsClientMan.hh.
Referenced by XrdCmsFinderRMT::Forward(), XrdCmsFinderRMT::Locate(), XrdCmsFinderRMT::Prepare(), and XrdCmsFinderRMT::Space().