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(), XrdCmsRRQ::sendLwtResp(), and XrdCmsRRQ::sendRedResp().

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.3.1