xrootd
|
#include <XrdCmsNode.hh>
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 | 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 | 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 [3] |
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) |
Static Private Member Functions | |
static int | isOnline (char *path, int upt=1) |
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 | RefA |
int | RefTotA |
int | RefR |
int | RefTotR |
short | RSlot |
char | isLocked |
char | RSVD |
Static Private Attributes | |
static const int | fsL2PFail1 = 999991 |
static const int | fsL2PFail2 = 999992 |
static XrdSysMutex | mlMutex |
static int | LastFree = 0 |
Friends | |
class | XrdCmsCluster |
XrdCmsNode::XrdCmsNode | ( | XrdLink * | lnkp, |
int | port = 0 , |
||
const char * | sid = 0 , |
||
int | lvl = 0 , |
||
int | id = -1 |
||
) |
References XrdCms::Config, index(), XrdSysMutex::Lock(), XrdCmsConfig::LogPerf, and XrdSysMutex::UnLock().
XrdCmsNode::~XrdCmsNode | ( | ) |
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(), XrdCmsRRData::Buff, XrdCms::Cache, XrdCms::Config, XrdCmsCache::DelFile(), XrdCmsConfig::DiskSS, XrdCmsRRData::Dlen, EPNAME, XrdCmsPrepare::Gone(), XrdCmsManager::Inform(), 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(), XrdCmsRRData::Buff, XrdCms::Cache, XrdCms::Config, XrdCmsRRData::Dlen, EPNAME, XrdCmsPList_Anchor::Find(), XrdCmsKey::Hash, XrdCmsManager::Inform(), 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::rwvec, XrdCms::CmsRRHdr::streamid, TRACER, and XrdCmsSelect::Write.
const char * XrdCmsNode::do_Load | ( | XrdCmsRRData & | Arg | ) |
References XrdCmsConfig::asManager(), XrdCmsMeter::calcLoad(), 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(), XrdCms::Say, XrdCmsMeter::setVirtUpdt(), snprintf, and XrdCms::CmsLoadRequest::xeqLoad.
const char * XrdCmsNode::do_Locate | ( | XrdCmsRRData & | Arg | ) |
References XrdCmsSelect::Asap, XrdCms::Cluster, XrdCms::CmsRRHdr::datalen, DEBUGR, EPNAME, XrdCmsSelect::hf, XrdCmsSelect::InfoP, iovec::iov_len, 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_IPV6, XrdCmsRRData::Opaque, XrdCmsSelect::Opts, XrdCmsRRData::Opts, XrdCmsRRData::Path, XrdCmsRRData::PathLen, XrdCmsSelect::pf, 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] |
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 | ) |
const char * XrdCmsNode::do_PrepDel | ( | XrdCmsRRData & | Arg | ) |
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, XrdCmsSelect::Data, XrdCms::CmsRRHdr::datalen, DEBUGR, XrdCmsSelect::DLen, EPNAME, XrdCmsCluster::getMask(), XrdNetDNS::Host2IP(), index(), XrdCmsSelect::InfoP, iovec::iov_base, iovec::iov_len, 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, opts, XrdCmsRRData::Opts, XrdCmsRRData::Path, XrdCmsRRData::PathLen, XrdCmsSelect::Peers, XrdCmsSelect::Port, 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 | ) |
const char * XrdCmsNode::do_State | ( | XrdCmsRRData & | Arg | ) |
References XrdCmsRRData::Buff, XrdCms::Config, XrdCmsConfig::DiskOK, XrdCmsRRData::Dlen, EPNAME, iovec::iov_base, iovec::iov_len, XrdCms::kYR_have, XrdCms::CmsStateRequest::kYR_noresp, XrdCms::kYR_raw, XrdCms::CmsRRHdr::modifier, XrdCmsRRData::Path, XrdCmsRRData::Request, XrdCms::CmsRRHdr::rrCode, and TRACER.
int XrdCmsNode::do_StateFWD | ( | XrdCmsRRData & | Arg | ) |
References XrdCmsCache::AddFile(), XrdCmsSelect::bf, XrdCmsCluster::Broadcast(), XrdCmsRRData::Buff, XrdCms::Cache, XrdCms::Cluster, DEBUGR, XrdCmsRRData::Dlen, EPNAME, XrdCmsPList_Anchor::Find(), XrdCmsCache::GetFile(), XrdCmsSelect::hf, XrdCms::CmsStateRequest::kYR_refresh, XrdCms::CmsRRHdr::modifier, XrdCms::CmsHaveRequest::Online, XrdCmsRRData::Path, XrdCmsRRData::PathLen, XrdCmsCache::Paths, XrdCms::CmsHaveRequest::Pending, XrdCmsSelect::pf, XrdCmsRRData::Request, XrdCmsPInfo::rovec, and XrdCmsSelect::Vec.
const char * XrdCmsNode::do_StatFS | ( | XrdCmsRRData & | Arg | ) |
References XrdCms::Cache, XrdCms::Cluster, XrdCms::CmsRRHdr::datalen, XrdCmsPList_Anchor::Find(), iovec::iov_len, 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 | ) |
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 | ) |
const char * XrdCmsNode::do_Try | ( | XrdCmsRRData & | Arg | ) |
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] |
References strtoll.
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 | ( | const char * | hn | ) | [inline] |
References XrdLink::Host(), and Link.
int XrdCmsNode::isNode | ( | unsigned int | ipa, |
const char * | nid | ||
) | [inline] |
int XrdCmsNode::isNode | ( | unsigned int | ipa | ) | [inline] |
References IPAddr.
int XrdCmsNode::isNode | ( | SMask_t | smask | ) | [inline] |
References NodeMask.
Referenced by XrdCmsCluster::Broadcast(), XrdCmsCluster::getMask(), XrdCmsCluster::MonRefs(), and XrdCmsCluster::Space().
int XrdCmsNode::isOnline | ( | char * | path, |
int | upt = 1 |
||
) | [static, private] |
void XrdCmsNode::Lock | ( | ) | [inline] |
References isLocked, XrdSysMutex::Lock(), and myMutex.
Referenced by XrdCmsManager::Add(), XrdCmsCluster::Broadcast(), 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().
void XrdCmsNode::Report_Usage | ( | XrdLink * | lp | ) | [static] |
References XrdCms::CmsLoadRequest::cpuLoad, XrdCms::CmsRRHdr::datalen, DEBUG, XrdCms::CmsLoadRequest::dskLoad, EPNAME, XrdCms::CmsLoadRequest::Hdr, XrdCmsManager::Inform(), iovec::iov_base, iovec::iov_len, 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 struct iovec * | iov, |
int | iovcnt, | ||
int | iotot = 0 |
||
) | [inline] |
References isOffline, Link, and XrdLink::Send().
int XrdCmsNode::Send | ( | const char * | buff, |
int | blen = 0 |
||
) | [inline] |
References isOffline, Link, and XrdLink::Send().
Referenced by XrdCmsCluster::Broadcast(), XrdCmsManager::Inform(), XrdCmsReq::Reply(), XrdCmsManager::Reset(), XrdCmsCluster::SelNode(), XrdCmsRRQ::sendLocResp(), and XrdCmsRRQ::sendResponse().
void XrdCmsNode::setName | ( | XrdLink * | lnkp, |
int | port | ||
) |
References XrdLink::Host(), XrdLink::ID, XrdNetDNS::IP2String(), XrdNetDNS::IPAddr(), XrdLink::Name(), and XrdMonCtrCollector::port.
Referenced by XrdCmsCluster::Add().
void XrdCmsNode::setSlot | ( | short | rslot | ) | [inline] |
References RSlot.
void XrdCmsNode::SyncSpace | ( | ) |
void XrdCmsNode::UnLock | ( | ) | [inline] |
friend class XrdCmsCluster [friend] |
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 |
Referenced by XrdCmsCluster::SelbyLoad(), XrdCmsCluster::SelbyRef(), XrdCmsCluster::Select(), and XrdCmsCluster::Space().
Referenced by XrdCmsCluster::SelbyLoad(), XrdCmsCluster::SelbyRef(), XrdCmsCluster::Select(), and XrdCmsCluster::Space().
unsigned int XrdCmsNode::DiskTotal |
Referenced by XrdCmsCluster::Space().
Referenced by XrdCmsCluster::List(), and 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 [static, private] |
const int XrdCmsNode::fsL2PFail2 = 999992 [static, private] |
char* XrdCmsNode::Ident |
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::isGone |
Referenced by XrdCmsCluster::Remove().
char XrdCmsNode::isKnown |
Referenced by XrdCmsManager::Reset().
char XrdCmsNode::isLocked [private] |
char XrdCmsNode::isMan |
Referenced by XrdCmsManager::Add(), XrdCmsCluster::Add(), XrdCmsCluster::Drop(), and XrdCmsCluster::List().
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(), XrdCmsCluster::Drop(), and XrdCmsCluster::List().
char XrdCmsNode::isPerm |
Referenced by XrdCmsCluster::Add().
char XrdCmsNode::isProxy |
Referenced by XrdCmsCluster::List().
char XrdCmsNode::isReserved[3] |
char XrdCmsNode::isRW |
Referenced by XrdCmsProtocol::AddPath(), XrdCmsCluster::List(), and XrdCmsCluster::Space().
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::List(), XrdCmsCluster::SelbyLoad(), and XrdCmsCluster::Select().
int XrdCmsNode::myMass [private] |
Referenced by XrdCmsCluster::SelbyLoad().
XrdSysMutex XrdCmsNode::myMutex [private] |
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] |
int XrdCmsNode::Port [private] |
Referenced by XrdCmsCluster::List(), and Name().
int XrdCmsNode::RefA [private] |
int XrdCmsNode::RefR [private] |
int XrdCmsNode::RefTotA [private] |
Referenced by XrdCmsCluster::List(), and XrdCmsCluster::MonRefs().
int XrdCmsNode::RefTotR [private] |
Referenced by XrdCmsCluster::List(), and XrdCmsCluster::MonRefs().
short XrdCmsNode::RSlot [private] |
char XrdCmsNode::RSVD [private] |