xrootd
Public Member Functions | Static Public Member Functions | Public Attributes | Static Public Attributes | Private Member Functions | Private Attributes | Static Private Attributes | Friends | List of all members
XrdCmsNode Class Reference

#include <XrdCmsNode.hh>

Collaboration diagram for XrdCmsNode:
Collaboration graph
[legend]

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)
int setTZone (int tZone)
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
char TimeZone
char TZValid
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, XrdSysMutex::Lock(), XrdCmsConfig::LogPerf, 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 DEBUGR, XrdCmsRRData::dskFree, XrdCmsRRData::dskUtil, and EPNAME.

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

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

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

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

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

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

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

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

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

References XrdCmsConfig::asManager(), XrdCmsMeter::calcLoad(), XrdCms::Cluster, XrdCms::Config, XrdCms::CmsLoadRequest::cpuLoad, DEBUGR, XrdCmsConfig::DiskMin, XrdCmsRRData::dskFree, XrdCms::CmsLoadRequest::dskLoad, XrdSysError::Emsg(), EPNAME, XrdCmsConfig::LogPerf, XrdCms::CmsLoadRequest::memLoad, XrdCms::Meter, XrdCms::CmsLoadRequest::netLoad, XrdCmsRRData::Opaque, XrdCms::CmsLoadRequest::pagLoad, XrdCmsMeter::Record(), XrdCmsCluster::Refs(), XrdCms::Say, XrdCmsMeter::setVirtUpdt(), and XrdCms::CmsLoadRequest::xeqLoad.

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

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

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

References XrdCmsSelected::Disable, XrdCmsSelected::IPV6, XrdCmsSelected::IPV6Len, XrdCmsSelected::isMangr, XrdCmsSelected::Mask, XrdCmsSelected::next, XrdCmsSelected::Offline, and XrdCmsSelected::Status.

Referenced by XrdCmsRRQ::sendLocResp().

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

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

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

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

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

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

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 DEBUGR, EPNAME, XrdCms::CmsPrepAddRequest::kYR_write, XrdCmsRRData::Mode, XrdCmsRRData::Notify, XrdCmsRRData::Opaque, XrdCmsRRData::Opts, XrdCmsRRData::Path, XrdCmsXmi::Prep(), XrdCmsRRData::Prty, XrdCmsRRData::Reqid, XrdCms::Xmi_Prep, and XMI_RW.

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

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

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

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

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

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

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

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

int XrdCmsNode::do_SelPrep ( XrdCmsPrepArgs &  Arg)
static

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

Referenced by XrdCmsPrepArgs::DoIt().

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

References XrdCmsManList::Add(), XrdCms::Config, DEBUGR, XrdCmsManList::Del(), EPNAME, XrdOucTokenizer::GetLine(), XrdOucTokenizer::GetToken(), XrdCms::myMans, XrdCmsRRData::Path, 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 XrdCms::Config, XrdCmsConfig::lcl_N2N, XrdOucName2Name::lfn2pfn(), XrdOucProg::Run(), and XrdCmsMAX_PATH_LEN.

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

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

int XrdCmsNode::getMode ( const char *  theMode,
mode_t &  Mode 
)
private
int XrdCmsNode::getSize ( const char *  theSize,
long long &  Size 
)
private
short XrdCmsNode::getSlot ( )
inline

References RSlot.

Referenced by XrdCmsReq::XrdCmsReq().

int XrdCmsNode::ID ( int &  INum)
inline

References Instance, and NodeID.

Referenced by XrdCmsManager::Remove(), and XrdCmsCluster::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 XrdLink::Host(), and Link.

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 isLocked, XrdSysMutex::Lock(), and myMutex.

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

SMask_t XrdCmsNode::Mask ( )
inline

References NodeMask.

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

char* XrdCmsNode::Name ( )
inline

References myName.

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

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

References myName, myNlen, and Port.

void XrdCmsNode::Report_Usage ( XrdLink *  lp)
static

References XrdCms::CmsLoadRequest::cpuLoad, XrdCms::CmsRRHdr::datalen, DEBUG, XrdCms::CmsLoadRequest::dskLoad, EPNAME, XrdCms::CmsLoadRequest::Hdr, XrdCmsManager::Inform(), XrdCms::kYR_load, XrdCms::Manager, XrdCms::CmsLoadRequest::memLoad, XrdCms::Meter, XrdCms::CmsLoadRequest::netLoad, XrdCms::CmsLoadRequest::numLoad, XrdOucPup::Pack(), XrdCms::CmsLoadRequest::pagLoad, XrdCmsMeter::Report(), XrdLink::Send(), and XrdCms::CmsLoadRequest::xeqLoad.

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(), XrdCmsManager::Inform(), XrdCmsReq::Reply(), XrdCmsManager::Reset(), XrdCmsCluster::SelNode(), 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::ID, XrdSysDNS::IP2String(), XrdSysDNS::IPAddr(), XrdLink::Name(), and XrdMonCtrCollector::port.

Referenced by XrdCmsCluster::Add().

void XrdCmsNode::setShare ( int  shrval)
inline

References Share, Shrem, and Shrip.

void XrdCmsNode::setSlot ( short  rslot)
inline

References RSlot.

int XrdCmsNode::setTZone ( int  tZone)
inline

References TimeZone, and TZValid.

void XrdCmsNode::SyncSpace ( )

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

void XrdCmsNode::UnLock ( )
inline

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

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

Friends And Related Function Documentation

friend class XrdCmsCluster
friend

Member Data Documentation

const char XrdCmsNode::allowsRW = 0x01
static

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

const char XrdCmsNode::allowsSS = 0x02
static

Referenced by XrdCmsProtocol::AddPath(), XrdCmsCluster::SelbyLoad(), XrdCmsCluster::SelbyRef(), and XrdCmsCluster::SelNode().

unsigned int XrdCmsNode::ConfigID
int XrdCmsNode::DiskFree

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

int XrdCmsNode::DiskMinF

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

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::Drop(), and XrdCmsCluster::Remove().

time_t XrdCmsNode::DropTime
private

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

const int XrdCmsNode::fsL2PFail1 = 999991
staticprivate
const int XrdCmsNode::fsL2PFail2 = 999992
staticprivate
char* XrdCmsNode::Ident

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

int XrdCmsNode::Instance
private

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

unsigned int XrdCmsNode::IPAddr
private

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

char XrdCmsNode::IPV6[28]
private

Referenced by XrdCmsCluster::List().

int XrdCmsNode::IPV6Len
private

Referenced by XrdCmsCluster::List().

char XrdCmsNode::isBound

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

char XrdCmsNode::isConn

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

char XrdCmsNode::isDisable

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

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 XrdCmsManager::Add(), XrdCmsCluster::Add(), XrdCmsCluster::Drop(), and XrdCmsCluster::List().

char XrdCmsNode::isNoStage

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

char XrdCmsNode::isOffline

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

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 XrdCmsProtocol::AddPath(), XrdCmsCluster::List(), and XrdCmsCluster::Space().

char XrdCmsNode::isSuspend

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

int XrdCmsNode::LastFree = 0
staticprivate
XrdLink* XrdCmsNode::Link
private

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

int XrdCmsNode::logload
private
XrdSysMutex XrdCmsNode::mlMutex
staticprivate
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::SelbyLoad(), and XrdCmsCluster::Select().

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 ID(), and XrdCmsCluster::List().

SMask_t XrdCmsNode::NodeMask
private

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

int XrdCmsNode::Port
private

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

int XrdCmsNode::RefR
private

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

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::SelbyCost(), XrdCmsCluster::SelbyLoad(), XrdCmsCluster::SelbyRef(), and XrdCmsCluster::Select().

char XrdCmsNode::RoleID

Referenced by XrdCmsCluster::List().

short XrdCmsNode::RSlot
private

Referenced by getSlot(), and setSlot().

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().

char XrdCmsNode::TimeZone

Referenced by setTZone().

char XrdCmsNode::TZValid

Referenced by setTZone().

The documentation for this class was generated from the following files:
Generated by   doxygen 1.8.1.2