xrootd
Public Member Functions | Static Public Member Functions | Public Attributes | Static Public Attributes | Private Member Functions | Private Attributes | Static Private Attributes | Friends
XrdCmsNode Class Reference

#include <XrdCmsNode.hh>

Collaboration diagram for XrdCmsNode:
Collaboration graph
[legend]

List of all members.

Public Member Functions

const char * do_Avail (XrdCmsRRData &Arg)
const char * do_Chmod (XrdCmsRRData &Arg)
const char * do_Disc (XrdCmsRRData &Arg)
const char * do_Gone (XrdCmsRRData &Arg)
const char * do_Have (XrdCmsRRData &Arg)
const char * do_Load (XrdCmsRRData &Arg)
const char * do_Locate (XrdCmsRRData &Arg)
const char * do_Mkdir (XrdCmsRRData &Arg)
const char * do_Mkpath (XrdCmsRRData &Arg)
const char * do_Mv (XrdCmsRRData &Arg)
const char * do_Ping (XrdCmsRRData &Arg)
const char * do_Pong (XrdCmsRRData &Arg)
const char * do_PrepAdd (XrdCmsRRData &Arg)
const char * do_PrepDel (XrdCmsRRData &Arg)
const char * do_Rm (XrdCmsRRData &Arg)
const char * do_Rmdir (XrdCmsRRData &Arg)
const char * do_Select (XrdCmsRRData &Arg)
const char * do_Space (XrdCmsRRData &Arg)
const char * do_State (XrdCmsRRData &Arg)
int do_StateFWD (XrdCmsRRData &Arg)
const char * do_StatFS (XrdCmsRRData &Arg)
const char * do_Stats (XrdCmsRRData &Arg)
const char * do_Status (XrdCmsRRData &Arg)
const char * do_Trunc (XrdCmsRRData &Arg)
const char * do_Try (XrdCmsRRData &Arg)
const char * do_Update (XrdCmsRRData &Arg)
const char * do_Usage (XrdCmsRRData &Arg)
void Disc (const char *reason=0, int needLock=1)
int ID (int &INum)
int Inst ()
int isNode (SMask_t smask)
int isNode (const char *hn)
int isNode (unsigned int ipa)
int isNode (unsigned int ipa, const char *nid)
char * Name ()
char * Name (int &len, int &port)
SMask_t Mask ()
void Lock ()
void UnLock ()
int Send (const char *buff, int blen=0)
int Send (const struct iovec *iov, int iovcnt, int iotot=0)
void setName (XrdLink *lnkp, int port)
void setShare (int shrval)
void setSlot (short rslot)
short getSlot ()
void SyncSpace ()
 XrdCmsNode (XrdLink *lnkp, int port=0, const char *sid=0, int lvl=0, int id=-1)
 ~XrdCmsNode ()

Static Public Member Functions

static int do_LocFmt (char *buff, XrdCmsSelected *sP, SMask_t pf, SMask_t wf)
static int do_SelPrep (XrdCmsPrepArgs &Arg)
static void do_StateDFS (XrdCmsBaseFR *rP, int rc)
static void Report_Usage (XrdLink *lp)

Public Attributes

char * Ident
char isDisable
char isOffline
char isNoStage
char isMan
char isPeer
char isProxy
char isSuspend
char isBound
char isRW
char isKnown
char isConn
char isGone
char isPerm
char isReserved [2]
char RoleID
unsigned int DiskTotal
int DiskNums
int DiskMinF
int DiskFree
int DiskUtil
unsigned int ConfigID

Static Public Attributes

static const char allowsRW = 0x01
static const char allowsSS = 0x02

Private Member Functions

int fsExec (XrdOucProg *Prog, char *Arg1, char *Arg2=0)
const char * fsFail (const char *Who, const char *What, const char *Path, int rc)
int getMode (const char *theMode, mode_t &Mode)
int getSize (const char *theSize, long long &Size)

Private Attributes

XrdSysMutex myMutex
XrdLink * Link
unsigned int IPAddr
XrdCmsNode * Next
time_t DropTime
XrdCmsDrop * DropJob
int IPV6Len
char IPV6 [28]
SMask_t NodeMask
int NodeID
int Instance
int Port
int myLevel
int myCNUM
char * myCID
char * myNID
char * myName
int myNlen
int logload
int myCost
int myLoad
int myMass
int RefW
int RefTotW
int RefR
int RefTotR
short RSlot
char isLocked
char Share
char Shrem
char Shrip
char Rsvd [2]
int Shrin

Static Private Attributes

static const int fsL2PFail1 = 999991
static const int fsL2PFail2 = 999992
static XrdSysMutex mlMutex
static int LastFree = 0

Friends

class XrdCmsCluster

Constructor & Destructor Documentation

XrdCmsNode::XrdCmsNode ( XrdLink *  lnkp,
int  port = 0,
const char *  sid = 0,
int  lvl = 0,
int  id = -1 
)

References XrdCms::Config, XrdCmsConfig::LogPerf, index(), XrdSysMutex::Lock(), and XrdSysMutex::UnLock().

XrdCmsNode::~XrdCmsNode ( )

Member Function Documentation

void XrdCmsNode::Disc ( const char *  reason = 0,
int  needLock = 1 
)

Referenced by XrdCmsCluster::Remove().

const char * XrdCmsNode::do_Avail ( XrdCmsRRData &  Arg)

References EPNAME, XrdCmsRRData::dskFree, XrdCmsRRData::dskUtil, and DEBUGR.

const char * XrdCmsNode::do_Chmod ( XrdCmsRRData &  Arg)

References EPNAME, DEBUGR, XrdCmsRRData::Mode, XrdCmsRRData::Path, XrdCms::Xmi_Chmod, XrdCmsRRData::Request, XrdCms::CmsRRHdr::streamid, XrdCmsXmi::Chmod(), XrdCmsRRData::Opaque, XrdCms::Config, XrdCmsConfig::DiskOK, XrdCmsConfig::ProgCH, XrdCmsConfig::ossFS, XrdOss::Chmod(), and XrdCmsRRData::Ident.

const char * XrdCmsNode::do_Disc ( XrdCmsRRData &  Arg)

References XrdCms::Say, XrdSysError::Emsg(), XrdCms::Config, XrdCmsConfig::asManager(), and XrdCmsRRData::Request.

const char * XrdCmsNode::do_Gone ( XrdCmsRRData &  Arg)

References EPNAME, TRACER, XrdCmsRRData::Path, XrdCms::Config, XrdCmsConfig::asManager(), XrdCmsSelect::Advisory, XrdCmsRRData::PathLen, XrdCms::Cache, XrdCmsCache::DelFile(), XrdCms::baseFS, XrdCmsBaseFS::isDFS(), XrdCmsConfig::DiskSS, XrdCms::PrepQ, XrdCmsPrepare::Gone(), XrdCms::Manager, XrdCmsManager::Present(), XrdCmsManager::Inform(), XrdCmsRRData::Request, XrdCmsRRData::Buff, and XrdCmsRRData::Dlen.

const char * XrdCmsNode::do_Have ( XrdCmsRRData &  Arg)

References EPNAME, XrdMpx::Opts, TRACER, XrdCmsRRData::Request, XrdCms::CmsRRHdr::modifier, XrdCms::CmsHaveRequest::Pending, XrdCmsRRData::Path, XrdCms::Cache, XrdCmsCache::Paths, XrdCmsPList_Anchor::Find(), XrdCmsPInfo::rwvec, XrdCmsSelect::Write, XrdCms::Config, XrdCmsConfig::asManager(), XrdCmsSelect::Advisory, XrdCmsRRData::PathLen, XrdCmsSelect::Path, XrdCmsKey::Hash, XrdCms::CmsRRHdr::streamid, XrdCms::baseFS, XrdCmsBaseFS::isDFS(), XrdCmsSelect::Vec, XrdCmsSelect::hf, XrdCmsPInfo::rovec, XrdCmsSelect::wf, XrdCmsCache::AddFile(), XrdCms::Manager, XrdCmsManager::Present(), XrdCmsManager::Inform(), XrdCmsRRData::Buff, and XrdCmsRRData::Dlen.

const char * XrdCmsNode::do_Load ( XrdCmsRRData &  Arg)

References EPNAME, XrdCmsRRData::Opaque, XrdCms::Meter, XrdCmsMeter::calcLoad(), XrdCmsRRData::dskFree, DEBUGR, XrdCms::Config, XrdCmsConfig::asManager(), XrdCmsMeter::Record(), XrdCmsMeter::setVirtUpdt(), XrdCmsConfig::DiskMin, XrdCmsConfig::LogPerf, XrdCms::Cluster, XrdCmsCluster::Refs(), snprintf, XrdCms::Say, and XrdSysError::Emsg().

const char * XrdCmsNode::do_Locate ( XrdCmsRRData &  Arg)

References EPNAME, XrdCmsRRData::Request, XrdCms::CmsRRHdr::streamid, XrdCms::Config, XrdCmsConfig::QryMinum, XrdCmsRRData::Path, XrdCmsRRData::PathLen, STMax, XrdCms::Xmi_Select, XrdCmsXmi::Select(), XMI_LOCATE, XrdCmsRRData::Opaque, XrdCmsRRData::Opts, XrdCms::CmsLocateRequest::kYR_refresh, XrdCmsSelect::Opts, XrdCms::CmsLocateRequest::kYR_asap, XrdCmsSelect::InfoP, DEBUGR, XrdCms::Cluster, XrdCmsCluster::Locate(), XrdCms::CmsRRHdr::rrCode, XrdCms::kYR_wait, XrdCms::kYR_error, XrdCms::kYR_ENOENT, strlcpy(), XrdCmsSelect::Vec, XrdCmsSelect::hf, XrdCmsCluster::List(), XrdCmsCluster::LS_IPO, XrdCmsSelect::pf, XrdCmsSelect::wf, XrdCms::kYR_data, XrdCms::CmsRRHdr::datalen, and iovec::iov_len.

int XrdCmsNode::do_LocFmt ( char *  buff,
XrdCmsSelected *  sP,
SMask_t  pf,
SMask_t  wf 
) [static]

References XrdCmsSelected::Status, XrdCmsSelected::Mask, XrdCmsSelected::IPV6, XrdCmsSelected::IPV6Len, and XrdCmsSelected::next.

Referenced by XrdCmsRRQ::sendLocResp().

const char * XrdCmsNode::do_Mkdir ( XrdCmsRRData &  Arg)

References EPNAME, DEBUGR, XrdCmsRRData::Mode, XrdCmsRRData::Path, XrdCms::Xmi_Mkdir, XrdCmsRRData::Request, XrdCms::CmsRRHdr::streamid, XrdCmsXmi::Mkdir(), XrdCmsRRData::Opaque, XrdCms::Config, XrdCmsConfig::DiskOK, XrdCmsConfig::ProgMD, XrdCmsConfig::ossFS, XrdOss::Mkdir(), and XrdCmsRRData::Ident.

const char * XrdCmsNode::do_Mkpath ( XrdCmsRRData &  Arg)

References EPNAME, DEBUGR, XrdCmsRRData::Mode, XrdCmsRRData::Path, XrdCms::Xmi_Mkpath, XrdCmsRRData::Request, XrdCms::CmsRRHdr::streamid, XrdCmsXmi::Mkpath(), XrdCmsRRData::Opaque, XrdCms::Config, XrdCmsConfig::DiskOK, XrdCmsConfig::ProgMP, XrdCmsConfig::ossFS, XrdOss::Mkdir(), and XrdCmsRRData::Ident.

const char * XrdCmsNode::do_Mv ( XrdCmsRRData &  Arg)

References EPNAME, DEBUGR, XrdCmsRRData::Path, XrdCmsRRData::Path2, XrdCms::Xmi_Rename, XrdCmsRRData::Request, XrdCms::CmsRRHdr::streamid, XrdCms::CmsRRHdr::modifier, XrdCms::kYR_dnf, XrdCmsXmi::Rename(), XrdCmsRRData::Opaque, XrdCmsRRData::Opaque2, XrdCms::Config, XrdCmsConfig::DiskOK, XrdCmsSelect::Defer, XrdCmsSelect::iovP, XrdCmsSelect::iovN, XrdCmsSelect::InfoP, XrdCmsSelect::nmask, XrdCms::Cluster, XrdCmsCluster::Select(), XrdCmsRRData::waitVal, XrdCmsSelect::Vec, XrdCmsSelect::hf, XrdCms::Say, XrdSysError::Emsg(), XrdCms::Cache, XrdCmsCache::DelFile(), XrdCmsConfig::ProgMV, XrdCmsConfig::ossFS, XrdOss::Rename(), and XrdCmsRRData::Ident.

const char * XrdCmsNode::do_Ping ( XrdCmsRRData &  Arg)

References XrdCms::kYR_pong.

const char * XrdCmsNode::do_Pong ( XrdCmsRRData &  Arg)
const char * XrdCmsNode::do_PrepAdd ( XrdCmsRRData &  Arg)

References EPNAME, DEBUGR, XrdCmsRRData::Reqid, XrdCmsRRData::Notify, XrdCmsRRData::Prty, XrdCmsRRData::Mode, XrdCmsRRData::Path, XrdCms::Xmi_Prep, XrdCmsXmi::Prep(), XrdCmsRRData::Opts, XrdCms::CmsPrepAddRequest::kYR_write, XMI_RW, and XrdCmsRRData::Opaque.

const char * XrdCmsNode::do_PrepDel ( XrdCmsRRData &  Arg)

References EPNAME, DEBUGR, XrdCmsRRData::Reqid, XrdCms::Xmi_Prep, XrdCmsXmi::Prep(), XMI_CANCEL, XrdCms::Config, XrdCmsConfig::DiskOK, XrdCmsConfig::DiskSS, XrdCms::PrepQ, and XrdCmsPrepare::Del().

const char * XrdCmsNode::do_Rm ( XrdCmsRRData &  Arg)

References EPNAME, DEBUGR, XrdCmsRRData::Path, XrdCms::Xmi_Remove, XrdCmsRRData::Request, XrdCms::CmsRRHdr::streamid, XrdCms::CmsRRHdr::modifier, XrdCms::kYR_dnf, XrdCmsXmi::Remove(), XrdCmsRRData::Opaque, XrdCms::Config, XrdCmsConfig::DiskOK, XrdCms::Cache, XrdCmsCache::DelFile(), XrdCmsConfig::ProgRM, XrdCmsConfig::ossFS, XrdOss::Unlink(), and XrdCmsRRData::Ident.

const char * XrdCmsNode::do_Rmdir ( XrdCmsRRData &  Arg)

References EPNAME, DEBUGR, XrdCmsRRData::Path, XrdCms::Xmi_Remdir, XrdCmsRRData::Request, XrdCms::CmsRRHdr::streamid, XrdCms::CmsRRHdr::modifier, XrdCms::kYR_dnf, XrdCmsXmi::Remdir(), XrdCmsRRData::Opaque, XrdCms::Config, XrdCmsConfig::DiskOK, XrdCms::Cache, XrdCmsCache::DelFile(), XrdCmsConfig::ProgRD, XrdCmsConfig::ossFS, XrdOss::Remdir(), and XrdCmsRRData::Ident.

const char * XrdCmsNode::do_Select ( XrdCmsRRData &  Arg)

References EPNAME, XrdCmsRRData::Request, XrdCms::CmsRRHdr::streamid, XrdCms::Config, XrdCmsConfig::QryMinum, XrdCmsSelect::Peers, XrdCmsRRData::Path, XrdCmsRRData::PathLen, XrdCmsRRData::Opts, XrdCms::CmsSelectRequest::kYR_stat, XrdCms::Xmi_Stat, XrdCmsXmi::Stat(), XrdCmsRRData::Opaque, XrdCms::Xmi_Select, opts, XMI_RW, XrdCms::CmsSelectRequest::kYR_create, XMI_NEW, XrdCms::CmsSelectRequest::kYR_trunc, XMI_TRUNC, XrdCmsXmi::Select(), XrdCmsSelect::iovP, XrdCmsSelect::iovN, XrdCmsSelect::InfoP, XrdCms::CmsSelectRequest::kYR_refresh, XrdCmsSelect::Opts, XrdCms::CmsSelectRequest::kYR_online, XrdCms::CmsSelectRequest::kYR_write, XrdCms::CmsSelectRequest::kYR_metaop, XrdCms::CmsSelectRequest::kYR_replica, XrdCmsSelect::nmask, XrdCmsRRData::Avoid, DEBUGR, index(), XrdCms::Cluster, XrdCmsCluster::getMask(), XrdSysDNS::Host2IP(), XrdCmsCluster::Select(), XrdCms::CmsRRHdr::rrCode, XrdCms::kYR_wait, XrdCmsSelect::Resp, XrdCmsSelect::Port, XrdCmsSelect::DLen, XrdCms::kYR_error, XrdCms::kYR_ENOENT, XrdCmsSelect::Data, XrdCms::kYR_redirect, XrdCms::CmsRRHdr::datalen, iovec::iov_base, and iovec::iov_len.

int XrdCmsNode::do_SelPrep ( XrdCmsPrepArgs &  Arg) [static]

References EPNAME, XrdCmsSelect::Peers, XrdCmsPrepArgs::path, XrdCmsPrepArgs::pathlen, XrdCms::Xmi_Prep, opts, XrdCmsPrepArgs::options, XMI_RW, XrdCmsXmi::Prep(), XrdCmsPrepArgs::reqid, XrdCmsPrepArgs::opaque, XrdCms::CmsPrepAddRequest::kYR_fresh, XrdCmsSelect::Opts, XrdCms::CmsPrepAddRequest::kYR_write, XrdCms::CmsPrepAddRequest::kYR_stage, XrdCmsSelect::iovP, XrdCmsPrepArgs::ioV, XrdCmsSelect::iovN, XrdCmsPrepArgs::iovNum, XrdCmsSelect::InfoP, XrdCmsSelect::nmask, XrdCmsPrepArgs::clPath, DEBUGR, XrdCms::Cluster, XrdCmsCluster::Select(), XrdCms::Sched, XrdScheduler::Schedule(), XrdCms::Say, XrdSysError::Emsg(), XrdCmsSelect::Resp, XrdCmsSelect::Data, XrdCmsSelect::smask, XrdCms::PrepQ, and XrdCmsPrepare::Inform().

Referenced by XrdCmsPrepArgs::DoIt().

const char * XrdCmsNode::do_Space ( XrdCmsRRData &  Arg)

References EPNAME, XrdCms::kYR_avail, XrdCms::Meter, XrdCmsMeter::FreeSpace(), DEBUGR, XrdOucPup::Pack(), XrdCmsRRData::Request, XrdCms::CmsRRHdr::rrCode, XrdCms::kYR_space, XrdCms::Manager, XrdCmsManager::Inform(), iovec::iov_base, and iovec::iov_len.

const char * XrdCmsNode::do_State ( XrdCmsRRData &  Arg)

References EPNAME, XrdCmsRRData::Request, XrdCms::CmsRRHdr::modifier, TRACER, XrdCmsRRData::Path, XrdCms::Config, XrdCmsConfig::DiskOK, XrdCmsConfig::asProxy(), XrdCms::baseFS, XrdCmsBaseFS::Limit(), XrdCmsPInfo::rovec, XrdCmsBaseFS::Exists(), XrdCmsRRData::PathLen, iovec::iov_base, iovec::iov_len, XrdCmsRRData::Buff, XrdCmsRRData::Dlen, XrdCms::CmsRRHdr::rrCode, XrdCms::kYR_have, and XrdCms::kYR_raw.

void XrdCmsNode::do_StateDFS ( XrdCmsBaseFR *  rP,
int  rc 
) [static]
int XrdCmsNode::do_StateFWD ( XrdCmsRRData &  Arg)

References EPNAME, XrdCmsRRData::Path, XrdCmsRRData::PathLen, XrdCms::Cache, XrdCmsCache::Paths, XrdCmsPList_Anchor::Find(), XrdCmsPInfo::rovec, DEBUGR, XrdCmsSelect::Vec, XrdCmsSelect::hf, XrdCmsSelect::pf, XrdCmsSelect::bf, XrdCmsRRData::Request, XrdCms::CmsRRHdr::modifier, XrdCms::CmsStateRequest::kYR_refresh, XrdCmsCache::GetFile(), XrdCms::Config, XrdCmsConfig::asServer(), XrdCms::CmsStateRequest::kYR_metaman, XrdCms::baseFS, XrdCmsBaseFS::isDFS(), XrdCmsBaseFS::Traverse(), XrdCmsCache::AddFile(), XrdCms::Cluster, XrdCmsCluster::Broadsend(), XrdCmsRRData::Buff, XrdCmsRRData::Dlen, XrdCmsBaseFS::Exists(), XrdCmsSelect::Opts, XrdCmsSelect::wf, XrdCmsPInfo::rwvec, and XrdCmsCluster::Broadcast().

const char * XrdCmsNode::do_StatFS ( XrdCmsRRData &  Arg)

References XrdCmsRRData::Request, XrdCms::Cache, XrdCmsCache::Paths, XrdCmsPList_Anchor::Find(), XrdCmsRRData::Path, XrdCmsPInfo::rovec, XrdCms::Cluster, XrdCmsCluster::Space(), XrdCms::SpaceData::wNum, XrdCms::SpaceData::wFree, XrdCms::SpaceData::wUtil, XrdCms::SpaceData::sNum, XrdCms::SpaceData::sFree, XrdCms::SpaceData::sUtil, strlcpy(), iovec::iov_len, XrdCms::CmsRRHdr::rrCode, XrdCms::kYR_data, and XrdCms::CmsRRHdr::datalen.

const char * XrdCmsNode::do_Stats ( XrdCmsRRData &  Arg)

References XrdCmsRRData::Request, XrdSysMutex::Lock(), XrdCms::Cluster, XrdCmsCluster::Stats(), XrdCms::CmsRRHdr::modifier, XrdCms::CmsStatsRequest::kYR_size, iovec::iov_len, XrdCms::CmsRRHdr::datalen, XrdCms::CmsRRHdr::rrCode, XrdCms::kYR_data, XrdSysMutex::UnLock(), and iovec::iov_base.

const char * XrdCmsNode::do_Status ( XrdCmsRRData &  Arg)

References EPNAME, XrdCmsRRData::Request, XrdCms::CmsRRHdr::modifier, DEBUGR, XrdCms::Manager, XrdCmsManager::Reset(), XrdCms::Cache, XrdCmsCache::Bounce(), XrdCms::CmsRRHdr::streamid, XrdCms::CmsState, XrdCmsState::Update(), XrdCmsState::Counts, XrdCms::Say, and XrdSysError::Emsg().

const char * XrdCmsNode::do_Trunc ( XrdCmsRRData &  Arg)

References EPNAME, DEBUGR, XrdCmsRRData::Mode, XrdCmsRRData::Path, XrdCms::Config, XrdCmsConfig::DiskOK, XrdCmsConfig::ProgTR, XrdCmsConfig::ossFS, XrdOss::Truncate(), and XrdCmsRRData::Ident.

const char * XrdCmsNode::do_Try ( XrdCmsRRData &  Arg)

References EPNAME, XrdCmsRRData::Path, DEBUGR, XrdCms::myMans, XrdCmsManList::Del(), XrdOucTokenizer::GetLine(), XrdOucTokenizer::GetToken(), XrdCmsManList::Add(), XrdCms::Config, and XrdCmsConfig::PortTCP.

const char * XrdCmsNode::do_Update ( XrdCmsRRData &  Arg)

References XrdCms::CmsState, and XrdCmsState::sendState().

const char * XrdCmsNode::do_Usage ( XrdCmsRRData &  Arg)
int XrdCmsNode::fsExec ( XrdOucProg *  Prog,
char *  Arg1,
char *  Arg2 = 0 
) [private]

References XrdCmsMAX_PATH_LEN, XrdCms::Config, XrdCmsConfig::lcl_N2N, XrdOucName2Name::lfn2pfn(), and XrdOucProg::Run().

const char * XrdCmsNode::fsFail ( const char *  Who,
const char *  What,
const char *  Path,
int  rc 
) [private]

References EPNAME, XrdCms::Say, XrdSysError::Emsg(), and DEBUGR.

int XrdCmsNode::getMode ( const char *  theMode,
mode_t &  Mode 
) [private]
int XrdCmsNode::getSize ( const char *  theSize,
long long &  Size 
) [private]

References strtoll.

short XrdCmsNode::getSlot ( ) [inline]

References RSlot.

Referenced by XrdCmsReq::XrdCmsReq().

int XrdCmsNode::ID ( int &  INum) [inline]

References Instance, and NodeID.

Referenced by XrdCmsCluster::Remove(), and XrdCmsManager::Remove().

int XrdCmsNode::Inst ( ) [inline]

References Instance.

Referenced by XrdCmsCluster::Drop(), and XrdCmsReq::XrdCmsReq().

int XrdCmsNode::isNode ( SMask_t  smask) [inline]

References NodeMask.

Referenced by XrdCmsCluster::Broadcast(), XrdCmsCluster::Broadsend(), XrdCmsCluster::getMask(), XrdCmsCluster::MonRefs(), and XrdCmsCluster::Space().

int XrdCmsNode::isNode ( const char *  hn) [inline]

References Link, and XrdLink::Host().

int XrdCmsNode::isNode ( unsigned int  ipa) [inline]

References IPAddr.

int XrdCmsNode::isNode ( unsigned int  ipa,
const char *  nid 
) [inline]

References IPAddr, and myNID.

void XrdCmsNode::Lock ( ) [inline]

References myMutex, XrdSysMutex::Lock(), and isLocked.

Referenced by XrdCmsCluster::Broadcast(), XrdCmsCluster::Broadsend(), XrdCmsCluster::MonRefs(), XrdCmsCluster::Select(), XrdCmsCluster::Space(), XrdCmsCluster::SelNode(), XrdCmsCluster::SelbyCost(), XrdCmsCluster::SelbyLoad(), XrdCmsCluster::SelbyRef(), XrdCmsManager::Add(), XrdCmsManager::Inform(), and XrdCmsManager::Reset().

SMask_t XrdCmsNode::Mask ( ) [inline]

References NodeMask.

Referenced by XrdCmsCluster::Broadcast(), and XrdCmsProtocol::AddPath().

char* XrdCmsNode::Name ( ) [inline]

References myName.

Referenced by XrdCmsCluster::List(), XrdCmsCluster::Select(), XrdCmsCluster::SelNode(), XrdCmsManager::Add(), XrdCmsManager::Inform(), XrdCmsManager::Remove(), and XrdCmsManager::Reset().

char* XrdCmsNode::Name ( int &  len,
int &  port 
) [inline]

References myNlen, Port, and myName.

void XrdCmsNode::Report_Usage ( XrdLink *  lp) [static]

References EPNAME, XrdCms::kYR_load, XrdCms::Meter, XrdCmsMeter::Report(), XrdOucPup::Pack(), XrdCms::CmsLoadRequest::Hdr, XrdCms::CmsRRHdr::datalen, iovec::iov_base, iovec::iov_len, XrdLink::Send(), XrdCms::Manager, XrdCmsManager::Inform(), and DEBUG.

Referenced by XrdCmsMeter::Run().

int XrdCmsNode::Send ( const char *  buff,
int  blen = 0 
) [inline]

References isOffline, Link, and XrdLink::Send().

Referenced by XrdCmsCluster::Broadcast(), XrdCmsCluster::Broadsend(), XrdCmsCluster::SelNode(), XrdCmsManager::Inform(), XrdCmsManager::Reset(), XrdCmsReq::Reply(), XrdCmsRRQ::sendLocResp(), and XrdCmsRRQ::sendResponse().

int XrdCmsNode::Send ( const struct iovec *  iov,
int  iovcnt,
int  iotot = 0 
) [inline]

References isOffline, Link, and XrdLink::Send().

void XrdCmsNode::setName ( XrdLink *  lnkp,
int  port 
)

References XrdLink::Host(), XrdLink::Name(), XrdSysDNS::IPAddr(), XrdMonCtrCollector::port, XrdLink::ID, and XrdSysDNS::IP2String().

Referenced by XrdCmsCluster::Add().

void XrdCmsNode::setShare ( int  shrval) [inline]

References Shrem, Shrip, and Share.

void XrdCmsNode::setSlot ( short  rslot) [inline]

References RSlot.

void XrdCmsNode::SyncSpace ( )

References XrdCmsRRData::Request, XrdCms::CmsRRHdr::rrCode, XrdCms::kYR_login, XrdCmsRRData::Ident, XrdCmsRRData::dskFree, and XrdCmsRRData::dskUtil.

void XrdCmsNode::UnLock ( ) [inline]

References isLocked, myMutex, and XrdSysMutex::UnLock().

Referenced by XrdCmsCluster::Broadcast(), XrdCmsCluster::Broadsend(), XrdCmsCluster::List(), XrdCmsCluster::MonRefs(), XrdCmsCluster::Select(), XrdCmsCluster::SelNode(), XrdCmsManager::Inform(), XrdCmsManager::Reset(), and XrdCmsRTable::Add().

Friends And Related Function Documentation

friend class XrdCmsCluster [friend]

Member Data Documentation

const char XrdCmsNode::allowsRW = 0x01 [static]

Referenced by XrdCmsCluster::Space().

const char XrdCmsNode::allowsSS = 0x02 [static]

Referenced by XrdCmsProtocol::AddPath().

unsigned int XrdCmsNode::ConfigID
int XrdCmsNode::DiskFree

Referenced by XrdCmsCluster::Select(), XrdCmsCluster::Space(), XrdCmsCluster::SelbyLoad(), and XrdCmsCluster::SelbyRef().

int XrdCmsNode::DiskMinF

Referenced by XrdCmsCluster::Select(), XrdCmsCluster::Space(), XrdCmsCluster::SelbyLoad(), and XrdCmsCluster::SelbyRef().

int XrdCmsNode::DiskNums
unsigned int XrdCmsNode::DiskTotal

Referenced by XrdCmsCluster::Space().

int XrdCmsNode::DiskUtil

Referenced by XrdCmsCluster::Space().

XrdCmsDrop* XrdCmsNode::DropJob [private]

Referenced by XrdCmsCluster::Remove(), and XrdCmsCluster::Drop().

time_t XrdCmsNode::DropTime [private]

Referenced by XrdCmsCluster::Remove(), and XrdCmsCluster::Drop().

const int XrdCmsNode::fsL2PFail1 = 999991 [static, private]
const int XrdCmsNode::fsL2PFail2 = 999992 [static, private]
char* XrdCmsNode::Ident

Referenced by XrdCmsCluster::Add(), XrdCmsCluster::Broadcast(), XrdCmsCluster::Broadsend(), XrdCmsCluster::Remove(), XrdCmsCluster::Drop(), and XrdCmsManager::Remove().

int XrdCmsNode::Instance [private]

Referenced by XrdCmsCluster::Add(), ID(), and Inst().

unsigned int XrdCmsNode::IPAddr [private]

Referenced by XrdCmsCluster::List(), and isNode().

char XrdCmsNode::IPV6[28] [private]

Referenced by XrdCmsCluster::List().

int XrdCmsNode::IPV6Len [private]

Referenced by XrdCmsCluster::List().

char XrdCmsNode::isBound

Referenced by XrdCmsCluster::Add(), XrdCmsCluster::Remove(), XrdCmsCluster::Drop(), and XrdCmsManager::Add().

char XrdCmsNode::isConn

Referenced by XrdCmsCluster::Add(), XrdCmsCluster::Remove(), and XrdCmsManager::Add().

char XrdCmsNode::isDisable

Referenced by XrdCmsCluster::Add(), XrdCmsCluster::List(), XrdCmsCluster::Select(), XrdCmsCluster::SelbyCost(), XrdCmsCluster::SelbyLoad(), and XrdCmsCluster::SelbyRef().

char XrdCmsNode::isGone

Referenced by XrdCmsCluster::Remove().

char XrdCmsNode::isKnown

Referenced by XrdCmsManager::Reset().

char XrdCmsNode::isLocked [private]

Referenced by Lock(), and UnLock().

char XrdCmsNode::isMan

Referenced by XrdCmsCluster::Add(), XrdCmsCluster::List(), XrdCmsCluster::Drop(), and XrdCmsManager::Add().

char XrdCmsNode::isNoStage

Referenced by XrdCmsCluster::Add(), XrdCmsCluster::List(), XrdCmsCluster::Remove(), XrdCmsCluster::Select(), XrdCmsCluster::SelbyCost(), XrdCmsCluster::SelbyLoad(), XrdCmsCluster::SelbyRef(), and XrdCmsManager::Add().

char XrdCmsNode::isOffline

Referenced by XrdCmsCluster::Add(), XrdCmsCluster::List(), XrdCmsCluster::Remove(), XrdCmsCluster::Select(), XrdCmsCluster::Space(), XrdCmsCluster::Drop(), XrdCmsCluster::SelbyCost(), XrdCmsCluster::SelbyLoad(), XrdCmsCluster::SelbyRef(), XrdCmsManager::Add(), XrdCmsManager::Inform(), XrdCmsManager::Remove(), XrdCmsManager::Reset(), and Send().

char XrdCmsNode::isPeer

Referenced by XrdCmsCluster::Add(), and XrdCmsCluster::Drop().

char XrdCmsNode::isPerm

Referenced by XrdCmsCluster::Add().

char XrdCmsNode::isProxy
char XrdCmsNode::isReserved[2]
char XrdCmsNode::isRW

Referenced by XrdCmsCluster::List(), XrdCmsCluster::Space(), and XrdCmsProtocol::AddPath().

char XrdCmsNode::isSuspend

Referenced by XrdCmsCluster::Add(), XrdCmsCluster::List(), XrdCmsCluster::Remove(), XrdCmsCluster::Select(), XrdCmsCluster::SelbyCost(), XrdCmsCluster::SelbyLoad(), XrdCmsCluster::SelbyRef(), and XrdCmsManager::Add().

int XrdCmsNode::LastFree = 0 [static, private]
XrdLink* XrdCmsNode::Link [private]

Referenced by XrdCmsCluster::Add(), isNode(), and Send().

int XrdCmsNode::logload [private]
XrdSysMutex XrdCmsNode::mlMutex [static, private]
char* XrdCmsNode::myCID [private]

Referenced by XrdCmsCluster::Add().

int XrdCmsNode::myCNUM [private]

Referenced by XrdCmsCluster::Add(), and XrdCmsCluster::getMask().

int XrdCmsNode::myCost [private]

Referenced by XrdCmsCluster::SelbyCost().

int XrdCmsNode::myLevel [private]
int XrdCmsNode::myLoad [private]

Referenced by XrdCmsCluster::Select(), and XrdCmsCluster::SelbyLoad().

int XrdCmsNode::myMass [private]

Referenced by XrdCmsCluster::SelbyLoad().

XrdSysMutex XrdCmsNode::myMutex [private]

Referenced by Lock(), and UnLock().

char* XrdCmsNode::myName [private]

Referenced by Name().

char* XrdCmsNode::myNID [private]

Referenced by XrdCmsCluster::Add(), and isNode().

int XrdCmsNode::myNlen [private]

Referenced by Name().

XrdCmsNode* XrdCmsNode::Next [private]
int XrdCmsNode::NodeID [private]

Referenced by XrdCmsCluster::List(), and ID().

SMask_t XrdCmsNode::NodeMask [private]

Referenced by XrdCmsCluster::Add(), XrdCmsCluster::getMask(), XrdCmsCluster::List(), XrdCmsCluster::Drop(), XrdCmsCluster::SelNode(), XrdCmsCluster::SelbyCost(), XrdCmsCluster::SelbyLoad(), XrdCmsCluster::SelbyRef(), isNode(), and Mask().

int XrdCmsNode::Port [private]

Referenced by XrdCmsCluster::List(), and Name().

int XrdCmsNode::RefR [private]

Referenced by XrdCmsCluster::MonRefs(), XrdCmsCluster::Select(), XrdCmsCluster::SelbyCost(), XrdCmsCluster::SelbyLoad(), and XrdCmsCluster::SelbyRef().

int XrdCmsNode::RefTotR [private]

Referenced by XrdCmsCluster::List(), and XrdCmsCluster::Select().

int XrdCmsNode::RefTotW [private]

Referenced by XrdCmsCluster::List(), and XrdCmsCluster::Select().

int XrdCmsNode::RefW [private]

Referenced by XrdCmsCluster::MonRefs(), XrdCmsCluster::Select(), XrdCmsCluster::SelbyCost(), XrdCmsCluster::SelbyLoad(), and XrdCmsCluster::SelbyRef().

char XrdCmsNode::RoleID

Referenced by XrdCmsCluster::List().

short XrdCmsNode::RSlot [private]

Referenced by setSlot(), and getSlot().

char XrdCmsNode::Rsvd[2] [private]
char XrdCmsNode::Share [private]

Referenced by XrdCmsCluster::List(), XrdCmsCluster::MonRefs(), and setShare().

char XrdCmsNode::Shrem [private]

Referenced by XrdCmsCluster::MonRefs(), and setShare().

int XrdCmsNode::Shrin [private]

Referenced by XrdCmsCluster::List().

char XrdCmsNode::Shrip [private]

Referenced by setShare().

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