xrootd
Public Member Functions | Static Public Member Functions | Static Public Attributes | Private Member Functions | Private Attributes | Static Private Attributes
XrdCmsClientMan Class Reference

#include <XrdCmsClientMan.hh>

Collaboration diagram for XrdCmsClientMan:
Collaboration graph
[legend]

List of all members.

Public Member Functions

int delayResp (XrdOucErrInfo &Resp)
int isActive ()
XrdCmsClientMan * nextManager ()
char * Name ()
char * NPfx ()
int Send (char *msg, int mlen=0)
int Send (const struct iovec *iov, int iovcnt, int iotot=0)
void * Start ()
int Suspended ()
void setNext (XrdCmsClientMan *np)
int whatsUp (const char *user, const char *path)
int waitTime ()
 XrdCmsClientMan (char *host, int port, int cw, int nr, int rw, int rd)
 ~XrdCmsClientMan ()

Static Public Member Functions

static void setNetwork (XrdInet *nP)
static void setConfig (char *cfn)

Static Public Attributes

static char doDebug = 0

Private Member Functions

int Hookup ()
int Receive ()
void relayResp ()
void chkStatus ()
void setStatus ()

Private Attributes

XrdSysSemaphore syncResp
XrdCmsRespQ RespQ
XrdCmsClientMan * Next
XrdSysMutex myData
XrdLink * Link
char * Host
char * HPfx
int Port
int manMask
int dally
int Active
int Silent
int Suspend
int RecvCnt
int SendCnt
int nrMax
int maxMsgID
int repWait
int repWMax
int minDelay
int maxDelay
int qTime
int chkCount
time_t lastUpdt
time_t lastTOut
XrdCms::CmsRRHdr Response
XrdNetBuffer * NetBuff

Static Private Attributes

static XrdSysMutex manMutex
static XrdNetBufferQ BuffQ
static XrdInet * Network = 0
static char * ConfigFN = 0
static const int chkVal = 256

Constructor & Destructor Documentation

XrdCmsClientMan::XrdCmsClientMan ( char *  host,
int  port,
int  cw,
int  nr,
int  rw,
int  rd 
)

References Host, index(), HPfx, Port, XrdMonCtrCollector::port, Link, Active, Silent, Suspend, RecvCnt, nrMax, NetBuff, BuffQ, XrdNetBufferQ::Alloc(), repWMax, repWait, minDelay, maxDelay, chkCount, chkVal, lastUpdt, lastTOut, dally, XrdSysMutex::Lock(), manMask, and XrdSysMutex::UnLock().

XrdCmsClientMan::~XrdCmsClientMan ( )

References Link, XrdLink::Close(), Host, HPfx, NetBuff, and XrdNetBuffer::Recycle().

Member Function Documentation

void XrdCmsClientMan::chkStatus ( ) [private]

References XrdCms::kYR_update, myData, XrdSysMutex::Lock(), chkCount, chkVal, lastUpdt, Active, Link, XrdLink::Send(), and XrdSysMutex::UnLock().

Referenced by Suspended().

int XrdCmsClientMan::delayResp ( XrdOucErrInfo &  Resp)

References XrdOucErrInfo::getErrInfo(), Say, Host, XrdOucErrInfo::setErrInfo(), syncResp, XrdSysSemaphore::Post(), XrdCmsResp::Alloc(), XrdOucErrInfo::getErrUser(), maxMsgID, RespQ, XrdCmsRespQ::Purge(), XrdCmsRespQ::Add(), and EINPROGRESS.

Referenced by XrdCmsFinderRMT::send2Man().

int XrdCmsClientMan::Hookup ( ) [private]

References EPNAME, opts, manMutex, XrdSysMutex::Lock(), doDebug, manMask, XrdSysMutex::UnLock(), Network, XrdInet::Connect(), Host, Port, XrdSysTimer::Snooze(), dally, XRDNET_NOEMSG, XrdLink::Bind(), XrdSysThread::ID(), XrdCms::CmsLoginData::Mode, XrdCms::CmsLoginData::HoldTime, XrdCmsLogin::Login(), XrdLink::Close(), myData, Link, Active, Silent, RecvCnt, SendCnt, Suspend, repWait, repWMax, qTime, lastTOut, XrdCms::CmsLoginData::Version, Say, and DEBUG.

Referenced by Start().

int XrdCmsClientMan::isActive ( ) [inline]

References Active.

Referenced by XrdCmsFinderRMT::Inform(), and XrdCmsFinderRMT::SelectManager().

char* XrdCmsClientMan::Name ( ) [inline]

References Host.

Referenced by XrdCmsFinderRMT::Prepare().

XrdCmsClientMan* XrdCmsClientMan::nextManager ( ) [inline]

References Next.

Referenced by XrdCmsFinderRMT::~XrdCmsFinderRMT(), XrdCmsFinderRMT::Inform(), and XrdCmsFinderRMT::SelectManager().

char* XrdCmsClientMan::NPfx ( ) [inline]

References HPfx.

int XrdCmsClientMan::Receive ( ) [private]

References EPNAME, Link, XrdLink::RecvAll(), Response, RecvCnt, NetBuff, XrdNetBuffer::dlen, DEBUG, XrdLink::Name(), XrdNetBuffer::BuffSize(), Say, Host, and XrdNetBuffer::data.

Referenced by Start().

void XrdCmsClientMan::relayResp ( ) [private]

References EPNAME, RespQ, XrdCmsRespQ::Rem(), Response, XrdCms::CmsRRHdr::streamid, DEBUG, Host, XrdCmsResp::Reply(), HPfx, NetBuff, BuffQ, and XrdNetBufferQ::Alloc().

Referenced by Start().

int XrdCmsClientMan::Send ( char *  msg,
int  mlen = 0 
)

References Active, myData, XrdSysMutex::Lock(), Link, XrdLink::Send(), XrdLink::Close(), SendCnt, and XrdSysMutex::UnLock().

Referenced by XrdCmsFinderRMT::Forward(), XrdCmsFinderRMT::Inform(), XrdCmsFinderRMT::Prepare(), and XrdCmsFinderRMT::send2Man().

int XrdCmsClientMan::Send ( const struct iovec *  iov,
int  iovcnt,
int  iotot = 0 
)

References Active, myData, XrdSysMutex::Lock(), Link, XrdLink::Send(), XrdLink::Close(), SendCnt, and XrdSysMutex::UnLock().

static void XrdCmsClientMan::setConfig ( char *  cfn) [inline, static]

References ConfigFN.

Referenced by XrdCmsFinderRMT::Configure().

static void XrdCmsClientMan::setNetwork ( XrdInet *  nP) [inline, static]

References Network.

Referenced by XrdCmsFinderRMT::Configure().

void XrdCmsClientMan::setNext ( XrdCmsClientMan *  np) [inline]

References Next.

Referenced by XrdCmsFinderRMT::StartManagers().

void XrdCmsClientMan::setStatus ( ) [private]

References EPNAME, myData, XrdSysMutex::Lock(), Response, XrdCms::CmsRRHdr::modifier, Suspend, XrdSysMutex::UnLock(), DEBUG, Host, and Say.

Referenced by Start().

void * XrdCmsClientMan::Start ( )

References Hookup(), Receive(), Response, XrdCms::CmsRRHdr::modifier, relayResp(), XrdCms::CmsRRHdr::rrCode, XrdCms::kYR_status, setStatus(), XrdCmsClientMsg::Reply(), HPfx, NetBuff, XrdCms::kYR_waitresp, syncResp, XrdSysSemaphore::Wait(), myData, XrdSysMutex::Lock(), Link, XrdLink::Close(), Active, Suspend, XrdSysMutex::UnLock(), Say, Host, XrdSysTimer::Snooze(), and dally.

Referenced by XrdCmsStartManager().

int XrdCmsClientMan::Suspended ( ) [inline]

References Suspend, and chkStatus().

Referenced by XrdCmsFinderRMT::SelectManager(), and XrdCmsFinderRMT::send2Man().

int XrdCmsClientMan::waitTime ( ) [inline]

References repWait.

Referenced by XrdCmsFinderRMT::send2Man().

int XrdCmsClientMan::whatsUp ( const char *  user,
const char *  path 
)

References EPNAME, myData, XrdSysMutex::Lock(), Active, RecvCnt, lastTOut, repWait, Silent, nrMax, Suspend, Link, XrdLink::Close(), repWMax, XrdCmsClientMsg::inQ(), qTime, XrdSysMutex::UnLock(), minDelay, maxDelay, TRACE, and HPfx.

Referenced by XrdCmsFinderRMT::send2Man().

Member Data Documentation

int XrdCmsClientMan::Active [private]

Referenced by XrdCmsClientMan(), Send(), Start(), whatsUp(), Hookup(), chkStatus(), and isActive().

XrdNetBufferQ XrdCmsClientMan::BuffQ [static, private]

Referenced by XrdCmsClientMan(), and relayResp().

int XrdCmsClientMan::chkCount [private]

Referenced by XrdCmsClientMan(), and chkStatus().

const int XrdCmsClientMan::chkVal = 256 [static, private]

Referenced by XrdCmsClientMan(), and chkStatus().

char * XrdCmsClientMan::ConfigFN = 0 [static, private]

Referenced by setConfig().

int XrdCmsClientMan::dally [private]

Referenced by XrdCmsClientMan(), Start(), and Hookup().

char XrdCmsClientMan::doDebug = 0 [static]

Referenced by Hookup(), XrdCmsFinderRMT::Forward(), XrdCmsFinderRMT::Locate(), XrdCmsFinderRMT::Prepare(), and XrdCmsFinderRMT::Space().

char* XrdCmsClientMan::Host [private]

Referenced by XrdCmsClientMan(), ~XrdCmsClientMan(), delayResp(), Start(), Hookup(), Receive(), relayResp(), setStatus(), and Name().

char* XrdCmsClientMan::HPfx [private]

Referenced by XrdCmsClientMan(), ~XrdCmsClientMan(), Start(), whatsUp(), relayResp(), and NPfx().

time_t XrdCmsClientMan::lastTOut [private]

Referenced by XrdCmsClientMan(), whatsUp(), and Hookup().

time_t XrdCmsClientMan::lastUpdt [private]

Referenced by XrdCmsClientMan(), and chkStatus().

XrdLink* XrdCmsClientMan::Link [private]

Referenced by XrdCmsClientMan(), ~XrdCmsClientMan(), Send(), Start(), whatsUp(), Hookup(), Receive(), and chkStatus().

int XrdCmsClientMan::manMask [private]

Referenced by XrdCmsClientMan(), and Hookup().

XrdSysMutex XrdCmsClientMan::manMutex [static, private]

Referenced by Hookup().

int XrdCmsClientMan::maxDelay [private]

Referenced by XrdCmsClientMan(), and whatsUp().

int XrdCmsClientMan::maxMsgID [private]

Referenced by delayResp().

int XrdCmsClientMan::minDelay [private]

Referenced by XrdCmsClientMan(), and whatsUp().

XrdSysMutex XrdCmsClientMan::myData [private]

Referenced by Send(), Start(), whatsUp(), Hookup(), chkStatus(), and setStatus().

XrdNetBuffer* XrdCmsClientMan::NetBuff [private]

Referenced by XrdCmsClientMan(), ~XrdCmsClientMan(), Start(), Receive(), and relayResp().

XrdInet * XrdCmsClientMan::Network = 0 [static, private]

Referenced by Hookup(), and setNetwork().

XrdCmsClientMan* XrdCmsClientMan::Next [private]

Referenced by nextManager(), and setNext().

int XrdCmsClientMan::nrMax [private]

Referenced by XrdCmsClientMan(), and whatsUp().

int XrdCmsClientMan::Port [private]

Referenced by XrdCmsClientMan(), and Hookup().

int XrdCmsClientMan::qTime [private]

Referenced by whatsUp(), and Hookup().

int XrdCmsClientMan::RecvCnt [private]

Referenced by XrdCmsClientMan(), whatsUp(), Hookup(), and Receive().

int XrdCmsClientMan::repWait [private]

Referenced by XrdCmsClientMan(), whatsUp(), Hookup(), and waitTime().

int XrdCmsClientMan::repWMax [private]

Referenced by XrdCmsClientMan(), whatsUp(), and Hookup().

XrdCms::CmsRRHdr XrdCmsClientMan::Response [private]

Referenced by Start(), Receive(), relayResp(), and setStatus().

XrdCmsRespQ XrdCmsClientMan::RespQ [private]

Referenced by delayResp(), and relayResp().

int XrdCmsClientMan::SendCnt [private]

Referenced by Send(), and Hookup().

int XrdCmsClientMan::Silent [private]

Referenced by XrdCmsClientMan(), whatsUp(), and Hookup().

int XrdCmsClientMan::Suspend [private]

Referenced by XrdCmsClientMan(), Start(), whatsUp(), Hookup(), setStatus(), and Suspended().

XrdSysSemaphore XrdCmsClientMan::syncResp [private]

Referenced by delayResp(), and Start().

The documentation for this class was generated from the following files:
Generated on Sat Mar 17 2012 17:26:51 for xrootd by   doxygen 1.7.5