XrdOlbServer Class Reference

#include <XrdOlbServer.hh>

Collaboration diagram for XrdOlbServer:

List of all members.

Public Member Functions
int	do_Locate (char *, const char *, SMask_t hfVec, SMask_t rwVec)
int	Inst ()
int	isServer (SMask_t smask)
int	isServer (const char *hn)
int	isServer (unsigned int ipa)
int	isServer (unsigned int ipa, int port)
int	isServer (unsigned int ipa, int port, char *sid)
char *	Name ()
const char *	Nick ()
void	Lock ()
void	UnLock ()
int	Login (int Port, int Status, int Lvl)
void	Process_Director (void)
int	Process_Requests (void)
int	Process_Responses (void)
int	Send (const char *buff, int blen=0)
int	Send (const struct iovec *iov, int iovcnt)
void	setName (XrdNetLink *lnkp, int port)
	XrdOlbServer (XrdNetLink *lnkp, int port=0, char *sid=0)
	~XrdOlbServer ()
Static Public Member Functions
static int	Resume (XrdOlbPrepArgs *pargs)
static void	setRelay (XrdNetLink *rlyp)
static void	setSpace (int Dfree, int Dutil)
Public Attributes
char	isDisable
char	isOffline
char	isNoStage
char	isSpecial
char	isMan
char	isPeer
char	isProxy
char	isSuspend
char	isActive
char	isBound
char	isRW
char	isKnown
char	isBusy
char	isGone
Private Member Functions
int	do_AvKb (char *rid)
int	do_Chmod (char *rid, int do4real)
int	do_Delay (char *rid)
int	do_Disc (char *rid, int sendDisc)
int	do_Gone (char *rid)
int	do_Have (char *rid)
int	do_Load (char *rid)
int	do_Mkdir (char *rid, int do4real)
int	do_Mkpath (char *rid, int do4real)
int	do_Mv (char *rid, int do4real)
int	do_Ping (char *rid)
int	do_Pong (char *rid)
int	do_Port (char *rid)
int	do_PrepAdd (char *rid, int server=0)
int	do_PrepDel (char *rid, int server=0)
int	do_Rm (char *rid, int do4real)
int	do_Rmdir (char *rid, int do4real)
int	do_RST (char *rid)
int	do_Select (char *rid, int refresh=0)
int	do_Space (char *rid)
int	do_State (char *rid, int reset)
int	do_StateFWD (char *tp, int reset)
int	do_Stats (char *rid, int wantdata)
int	do_StNst (char *rid, int Resume)
int	do_SuRes (char *rid, int Resume)
int	do_Try (char *rid)
int	do_Usage (char *rid)
int	getMode (const char *, const char *, const char *, mode_t &)
int	Mkpath (char *local_path, mode_t mode)
char *	prepScan (char **Line, XrdOlbPrepArgs *pargs, const char *Etxt)
char *	Receive (char *idbuff, int blen)
int	Reissue (char *rid, const char *op, char *arg1, char *path, char *arg3=0)
Static Private Member Functions
static int	do_PrepAdd4Real (XrdOlbPrepArgs *pargs)
static int	do_PrepSel (XrdOlbPrepArgs *pargs, int stage)
static int	Inform (const char *cmd, XrdOlbPrepArgs *pargs)
static int	isOnline (char *path, int upt=1, XrdNetLink *lnk=0)
Private Attributes
XrdSysMutex	myMutex
XrdNetLink *	Link
unsigned int	IPAddr
XrdOlbServer *	Next
time_t	DropTime
XrdOlbDrop *	DropJob
XrdOlbRRQInfo	Info
XrdOlbReq	Req
SMask_t	ServMask
int	ServID
int	Instance
int	Port
int	myLevel
char *	mySID
char *	myName
char *	myNick
char *	Stype
struct iovec	redr_iov [redr_iov_cnt]
int	pingpong
int	newload
int	logload
int	DiskFree
int	DiskNums
int	DiskTotu
int	myCost
int	myLoad
int	RefA
int	RefTotA
int	RefR
int	RefTotR
Static Private Attributes
static XrdNetLink *	Relay = 0
static const int	redr_iov_cnt = 3
static XrdSysMutex	mlMutex
static int	xeq_load = 0
static int	cpu_load = 0
static int	mem_load = 0
static int	pag_load = 0
static int	net_load = 0
static int	dsk_free = 0
static int	dsk_totu = 0
Friends
class	XrdOlbManager

---

Constructor & Destructor Documentation

XrdOlbServer::XrdOlbServer	(	XrdNetLink *	lnkp,
		int	port = 0,
		char *	sid = 0
	)

References XrdNetLink::Addr(), XrdCms::Config, DiskFree, DiskNums, DiskTotu, DropJob, DropTime, Info, Instance, iovec::iov_base, iovec::iov_len, IPAddr, isActive, isBound, isBusy, isDisable, isGone, isKnown, isMan, isNoStage, isOffline, isPeer, isProxy, isSpecial, isSuspend, Link, XrdSysMutex::Lock(), logload, XrdCmsConfig::LogPerf, myCost, myLevel, myLoad, myName, myNick, mySID, newload, Next, pingpong, Port, redr_iov, RefA, RefR, RefTotA, RefTotR, XrdOlbRRQInfo::Rinst, ServID, ServMask, setName(), Stype, and XrdSysMutex::UnLock().

XrdOlbServer::~XrdOlbServer

(

)

References XrdCms::Cache, isOffline, Link, Lock(), myName, myNick, mySID, XrdCmsCache::Paths, XrdNetLink::Recycle(), XrdCmsPList_Anchor::Remove(), ServID, ServMask, Stype, and UnLock().

---

Member Function Documentation

int XrdOlbServer::do_AvKb

(

char *

rid

)

[private]

References XrdOuca2x::a2i(), DiskFree, DiskTotu, XrdNetLink::GetToken(), Link, and Say.

Referenced by Process_Responses().

int XrdOlbServer::do_Chmod	(	char *	rid,
		int	do4real
	)			[private]

References XrdCmsXmi::Chmod(), XrdCms::Config, DEBUG, EPNAME, getMode(), XrdNetLink::GetToken(), XrdCmsConfig::lcl_N2N, XrdOucName2Name::lfn2pfn(), Link, XrdCms::Manager, XrdCmsConfig::ProgCH, Reissue(), Req, XrdOucProg::Run(), Say, strlcpy(), XrdCms::Xmi_Chmod, and XrdOlbMAX_PATH_LEN.

Referenced by Process_Director(), and Process_Requests().

int XrdOlbServer::do_Delay

(

char *

rid

)

[private]

References XrdCms::Config, Link, XrdNetLink::Send(), snprintf, and XrdCmsConfig::SUPDelay.

Referenced by Process_Director().

int XrdOlbServer::do_Disc	(	char *	rid,
		int	sendDisc
	)			[private]

References XrdNetLink::Close(), isOffline, Link, XrdNetLink::Name(), Say, and XrdNetLink::Send().

Referenced by Process_Requests(), and Process_Responses().

int XrdOlbServer::do_Gone

(

char *

rid

)

[private]

References XrdCms::Cache, XrdCms::Config, XrdCmsCache::DelFile(), XrdCmsConfig::DiskSS, XrdNetLink::GetToken(), XrdCmsPrepare::Gone(), XrdCmsManager::Inform(), Instance, Link, XrdCms::Manager, Name(), XrdCms::PrepQ, Say, and ServMask.

Referenced by Process_Responses().

int XrdOlbServer::do_Have

(

char *

rid

)

[private]

References XrdCmsCache::AddFile(), XrdCms::Cache, XrdNetLink::GetToken(), XrdCmsManager::Inform(), Instance, Link, XrdCms::Manager, Name(), Say, and ServMask.

Referenced by Process_Responses().

int XrdOlbServer::do_Load

(

char *

rid

)

[private]

References XrdOuca2x::a2i(), XrdCmsConfig::asManager(), XrdCmsMeter::calcLoad(), XrdCms::Config, cpu_load, DiskFree, DiskTotu, dsk_free, dsk_totu, XrdNetLink::GetToken(), XrdCmsManager::Inform(), isRW, Link, XrdSysMutex::Lock(), logload, XrdCmsConfig::LogPerf, XrdCms::Manager, mem_load, XrdCms::Meter, mlMutex, myLoad, Name(), net_load, newload, pag_load, Say, snprintf, XrdSysMutex::UnLock(), and xeq_load.

Referenced by Process_Responses().

int XrdOlbServer::do_Locate	(	char *	rid,
		const char *	path,
		SMask_t	hfVec,
		SMask_t	rwVec
	)

References DEBUG, EPNAME, XrdNetDNS::IP2String(), XrdOlbSInfo::IPAddr, Link, XrdCms::Manager, XrdOlbSInfo::Mask, XrdOlbSInfo::next, OLB_LS_IPO, OLB_SERVER_DISABLE, OLB_SERVER_ISMANGR, XrdOlbSInfo::Port, XrdNetLink::Send(), snprintf, and XrdOlbSInfo::Status.

Referenced by do_Select(), and XrdOlbRRQ::sendLocInfo().

int XrdOlbServer::do_Mkdir	(	char *	rid,
		int	do4real
	)			[private]

References XrdCms::Config, DEBUG, EPNAME, getMode(), XrdNetLink::GetToken(), XrdCmsConfig::lcl_N2N, XrdOucName2Name::lfn2pfn(), Link, XrdCms::Manager, mkdir(), XrdCmsXmi::Mkdir(), XrdCmsConfig::ProgMD, Reissue(), Req, XrdOucProg::Run(), Say, strlcpy(), XrdCms::Xmi_Mkdir, and XrdOlbMAX_PATH_LEN.

Referenced by Process_Director(), and Process_Requests().

int XrdOlbServer::do_Mkpath	(	char *	rid,
		int	do4real
	)			[private]

References XrdCms::Config, DEBUG, EPNAME, getMode(), XrdNetLink::GetToken(), XrdCmsConfig::lcl_N2N, XrdOucName2Name::lfn2pfn(), Link, XrdCms::Manager, Mkpath(), XrdCmsXmi::Mkpath(), XrdCmsConfig::ProgMD, XrdCmsConfig::ProgMP, Reissue(), Req, XrdOucProg::Run(), Say, strlcpy(), XrdCms::Xmi_Mkpath, and XrdOlbMAX_PATH_LEN.

Referenced by Process_Director(), and Process_Requests().

int XrdOlbServer::do_Mv	(	char *	rid,
		int	do4real
	)			[private]

References XrdCms::Config, DEBUG, EPNAME, XrdNetLink::GetToken(), XrdOlbRRQInfo::ID, Info, XrdCmsConfig::lcl_N2N, XrdOucName2Name::lfn2pfn(), Link, XrdCms::Manager, XrdCmsConfig::ProgMV, Reissue(), rename(), XrdCmsXmi::Rename(), Req, XrdOucProg::Run(), Say, strlcpy(), XrdCms::Xmi_Rename, and XrdOlbMAX_PATH_LEN.

Referenced by Process_Director(), and Process_Requests().

int XrdOlbServer::do_Ping

(

char *

rid

)

[private]

References Link, XrdNetLink::Send(), and snprintf.

Referenced by Process_Requests().

int XrdOlbServer::do_Pong

(

char *

rid

)

[private]

References pingpong.

Referenced by Process_Responses().

int XrdOlbServer::do_Port

(

char *

rid

)

[private]

int XrdOlbServer::do_PrepAdd	(	char *	rid,
		int	server = 0
	)			[private]

References XrdOlbPrepArgs::data, XrdNetLink::GetToken(), Link, XrdOlbPrepArgs::mode, Name(), XrdOlbPrepArgs::path, prepScan(), XrdOlbPrepArgs::prty, XrdOlbPrepArgs::Queue(), XrdOlbPrepArgs::reqid, XrdNetLink::RetToken(), Say, XrdOlbPrepArgs::Stage, and XrdOlbPrepArgs::user.

Referenced by Process_Director(), and Process_Requests().

int XrdOlbServer::do_PrepAdd4Real

(

XrdOlbPrepArgs *

pargs

)

[static, private]

References XrdCmsPrepare::Add(), XrdCms::Config, DEBUG, XrdCmsConfig::DiskSS, EPNAME, index(), Inform(), isOnline(), XrdOlbPrepArgs::mode, XrdOlbPrepArgs::path, XrdCmsXmi::Prep(), XrdCms::PrepQ, XrdOlbPrepArgs::prty, XrdOlbPrepArgs::reqid, Say, XrdOlbPrepArgs::user, XrdCms::Xmi_Prep, and XMI_RW.

Referenced by Resume().

int XrdOlbServer::do_PrepDel	(	char *	rid,
		int	server = 0
	)			[private]

References BUFF, XrdCms::Config, DEBUG, XrdCmsPrepare::Del(), XrdCmsConfig::DiskSS, EPNAME, XrdNetLink::GetToken(), Link, XrdCms::Manager, Name(), XrdCmsXmi::Prep(), XrdCms::PrepQ, Reissue(), Say, XMI_CANCEL, and XrdCms::Xmi_Prep.

Referenced by Process_Director(), and Process_Requests().

int XrdOlbServer::do_PrepSel	(	XrdOlbPrepArgs *	pargs,
		int	stage
	)			[static, private]

References XrdCmsCache::AddFile(), BUFF, XrdCms::Cache, XrdCms::Config, XrdOlbCInfo::deadline, DEBUG, XrdCmsCache::DelFile(), EPNAME, XrdCmsPList_Anchor::Find(), XrdCmsCache::GetFile(), XrdOlbCInfo::hfvec, index(), Inform(), XrdCmsConfig::LUPDelay, XrdCms::Manager, XrdOlbPrepArgs::mode, XrdOlbPrepArgs::Msg, OLB_needrw, opts, XrdOlbPrepArgs::path, XrdCmsCache::Paths, XrdCmsXmi::Prep(), XrdOlbPrepArgs::prepMsg(), XrdOlbPrepArgs::reqid, XrdOlbPInfo::rovec, XrdOlbPInfo::rwvec, XrdOlbCInfo::sbvec, XrdCms::Sched, XrdScheduler::Schedule(), snprintf, XrdOlbPInfo::ssvec, XrdCms::Xmi_Prep, and XMI_RW.

Referenced by Resume().

int XrdOlbServer::do_Rm	(	char *	rid,
		int	do4real
	)			[private]

References XrdCms::Config, DEBUG, EPNAME, XrdNetLink::GetToken(), XrdOlbRRQInfo::ID, Info, XrdCmsConfig::lcl_N2N, XrdOucName2Name::lfn2pfn(), Link, XrdCms::Manager, XrdCmsConfig::ProgRM, Reissue(), XrdCmsXmi::Remove(), Req, XrdOucProg::Run(), Say, unlink(), XrdCms::Xmi_Remove, and XrdOlbMAX_PATH_LEN.

Referenced by Process_Director(), and Process_Requests().

int XrdOlbServer::do_Rmdir	(	char *	rid,
		int	do4real
	)			[private]

References XrdCms::Config, DEBUG, EPNAME, XrdNetLink::GetToken(), XrdOlbRRQInfo::ID, Info, XrdCmsConfig::lcl_N2N, XrdOucName2Name::lfn2pfn(), Link, XrdCms::Manager, XrdCmsConfig::ProgRD, Reissue(), XrdCmsXmi::Remdir(), Req, rmdir(), XrdOucProg::Run(), Say, XrdCms::Xmi_Remdir, and XrdOlbMAX_PATH_LEN.

Referenced by Process_Director(), and Process_Requests().

int XrdOlbServer::do_RST

(

char *

rid

)

[private]

References XrdCmsCache::Bounce(), XrdCms::Cache, XrdCms::Manager, XrdCmsManager::Reset(), and ServMask.

Referenced by Process_Responses().

int XrdOlbServer::do_Select	(	char *	rid,
		int	refresh = 0
	)			[private]

References XrdCmsCache::AddFile(), XrdOlbRRQInfo::Arg, BUFF, XrdCms::Cache, XrdCms::Config, XrdOlbCInfo::deadline, DEBUG, XrdCmsCache::DelFile(), do_Locate(), EPNAME, XrdCmsPList_Anchor::Find(), XrdCmsCache::GetFile(), XrdNetLink::GetToken(), XrdOlbCInfo::hfvec, XrdNetDNS::Host2IP(), XrdOlbRRQInfo::ID, Info, iovec::iov_base, iovec::iov_len, XrdOlbRRQInfo::isLU, XrdOlbRRQInfo::Key, Link, XrdCmsConfig::LUPDelay, XrdCms::Manager, Name(), OLB_needrw, OLB_newfile, OLB_peersok, opts, XrdCmsCache::Paths, redr_iov, redr_iov_cnt, Req, XrdOlbPInfo::rovec, XrdOlbPInfo::rwvec, XrdOlbCInfo::sbvec, XrdCmsXmi::Select(), XrdNetLink::Send(), snprintf, XrdOlbPInfo::ssvec, XrdCmsXmi::Stat(), XMI_RW, XrdCms::Xmi_Select, and XrdCms::Xmi_Stat.

Referenced by Process_Director().

int XrdOlbServer::do_Space

(

char *

rid

)

[private]

References XrdCmsConfig::asManager(), XrdCms::Config, dsk_free, dsk_totu, XrdCmsMeter::FreeSpace(), Link, XrdCms::Meter, XrdNetLink::Send(), and snprintf.

Referenced by Process_Requests().

int XrdOlbServer::do_State	(	char *	rid,
		int	reset
	)			[private]

References XrdCms::Config, do_StateFWD(), XrdNetLink::GetToken(), isKnown, isMan, isOnline(), Link, XrdCms::Manager, XrdCmsConfig::PathList, XrdNetLink::Send(), snprintf, and XrdCmsPList_Anchor::Type().

Referenced by Process_Requests().

int XrdOlbServer::do_StateFWD	(	char *	tp,
		int	reset
	)			[private]

References XrdCmsCache::AddFile(), BUFF, XrdCms::Cache, XrdCms::Config, XrdOlbCInfo::deadline, DEBUG, XrdCmsCache::DelFile(), EPNAME, XrdCmsPList_Anchor::Find(), XrdCmsCache::GetFile(), XrdOlbCInfo::hfvec, XrdCmsConfig::LUPDelay, XrdCms::Manager, XrdCmsCache::Paths, XrdOlbPInfo::rovec, XrdOlbCInfo::sbvec, and snprintf.

Referenced by do_State().

int XrdOlbServer::do_Stats	(	char *	rid,
		int	wantdata
	)			[private]

References Link, XrdSysMutex::Lock(), XrdCms::Manager, XrdNetLink::Send(), snprintf, and XrdSysMutex::UnLock().

Referenced by Process_Director().

int XrdOlbServer::do_StNst	(	char *	rid,
		int	Resume
	)			[private]

References XrdOlbState::Calc(), isDisable, isMan, isNoStage, isOffline, Name(), XrdOlb::OlbState, and Say.

Referenced by Process_Responses().

int XrdOlbServer::do_SuRes	(	char *	rid,
		int	Resume
	)			[private]

References XrdOlbState::Calc(), isDisable, isMan, isOffline, isSuspend, Name(), XrdOlb::OlbState, and Say.

Referenced by Process_Responses().

int XrdOlbServer::do_Try

(

char *

rid

)

[private]

References XrdCmsManList::Add(), XrdNetLink::Addr(), XrdNetLink::Close(), XrdCms::Config, XrdCmsManList::Del(), XrdNetLink::GetToken(), isOffline, Link, myLevel, XrdCms::myMans, and XrdCmsConfig::PortTCP.

Referenced by Process_Requests().

int XrdOlbServer::do_Usage

(

char *

rid

)

[private]

References XrdCmsConfig::asManager(), XrdCms::Config, cpu_load, dsk_free, dsk_totu, XrdCmsMeter::FreeSpace(), XrdCmsMeter::isOn(), Link, mem_load, XrdCms::Meter, net_load, pag_load, XrdCmsMeter::Report(), XrdNetLink::Send(), snprintf, and xeq_load.

Referenced by Process_Requests().

int XrdOlbServer::getMode	(	const char *	rid,
		const char *	path,
		const char *	modearg,
		mode_t &	mode
	)			[private]

References XrdOlbRRQInfo::ID, Info, XrdOlbReq::Reply_Error(), Req, and Say.

Referenced by do_Chmod(), do_Mkdir(), and do_Mkpath().

int XrdOlbServer::Inform	(	const char *	cmd,
		XrdOlbPrepArgs *	pargs
	)			[static, private]

References DEBUG, EPNAME, index(), XrdOlbPrepArgs::mode, XrdOlbPrepArgs::Msg, XrdOlbPrepArgs::prepMsg(), Relay, XrdOlbPrepArgs::reqid, XrdNetLink::Send(), and XrdOlbPrepArgs::user.

Referenced by do_PrepAdd4Real(), and do_PrepSel().

int XrdOlbServer::Inst

(

)

[inline]

References Instance.

int XrdOlbServer::isOnline	(	char *	path,
		int	upt = 1,
		XrdNetLink *	lnk = 0
	)			[static, private]

References XrdCms::Config, XrdCmsConfig::DiskSS, XrdCmsPrepare::Exists(), XrdCmsConfig::lcl_N2N, XrdOucName2Name::lfn2pfn(), XrdCms::PrepQ, stat(), and XrdOlbMAX_PATH_LEN.

Referenced by do_PrepAdd4Real(), and do_State().

int XrdOlbServer::isServer

(

const char *

hn

)

[inline]

References Link, and XrdNetLink::Name().

int XrdOlbServer::isServer

(

unsigned int

ipa

)

[inline]

References IPAddr.

int XrdOlbServer::isServer

(

SMask_t

smask

)

[inline]

References ServMask.

Referenced by XrdOlbManager::Broadcast(), XrdOlbManager::getMask(), and XrdOlbManager::MonRefs().

int XrdOlbServer::isServer	(	unsigned int	ipa,
		int	port,
		char *	sid
	)			[inline]

References IPAddr, mySID, and Port.

int XrdOlbServer::isServer	(	unsigned int	ipa,
		int	port
	)			[inline]

References IPAddr, and Port.

void XrdOlbServer::Lock

(

)

[inline]

References XrdSysMutex::Lock(), and myMutex.

Referenced by XrdOlbManager::AddServer(), XrdOlbManager::Broadcast(), XrdOlbManager::Login(), XrdOlbManager::MonPerf(), XrdOlbManager::MonPing(), XrdOlbManager::MonRefs(), XrdOlbManager::Reset(), XrdOlbManager::SelbyCost(), XrdOlbManager::SelbyLoad(), XrdOlbManager::SelbyRef(), XrdOlbManager::SelServer(), and ~XrdOlbServer().

int XrdOlbServer::Login	(	int	Port,
		int	Status,
		int	Lvl
	)

References XrdCmsManList::Add(), XrdNetLink::Addr(), XrdCmsConfig::asManager(), XrdCms::Config, XrdCmsManList::Del(), XrdCmsPList_Anchor::First(), XrdCmsMeter::FreeSpace(), XrdNetLink::GetToken(), Link, XrdCms::Meter, myLevel, XrdCms::myMans, XrdCmsConfig::mySID, XrdNetLink::Name(), XrdOlbPList::Next(), XrdCmsMeter::numFS(), XrdNetLink::OK2Recv(), OLB_isMan, OLB_isPeer, OLB_isProxy, OLB_Lost, OLB_noStage, OLB_Suspend, XrdOlbPList::Path(), XrdCmsConfig::PathList, XrdCmsConfig::PortTCP, XrdOlbPList::PType(), Receive(), Say, XrdNetLink::Send(), and snprintf.

Referenced by XrdOlbManager::Pander().

int XrdOlbServer::Mkpath	(	char *	local_path,
		mode_t	mode
	)			[private]

References index(), mkdir(), and stat().

Referenced by do_Mkpath().

char* XrdOlbServer::Name

(

)

[inline]

References myName.

Referenced by do_Gone(), do_Have(), do_Load(), do_PrepAdd(), do_PrepDel(), do_Select(), do_StNst(), do_SuRes(), XrdOlbManager::ListServers(), prepScan(), and XrdOlbManager::SelServer().

const char* XrdOlbServer::Nick

(

)

[inline]

References myNick.

Referenced by XrdOlbManager::Add_Manager(), XrdOlbManager::AddServer(), XrdOlbManager::Drop_Server(), XrdOlbManager::Login(), XrdOlbManager::Remove_Manager(), XrdOlbManager::Remove_Server(), and XrdOlbManager::Reset().

char * XrdOlbServer::prepScan	(	char **	Line,
		XrdOlbPrepArgs *	pargs,
		const char *	Etxt
	)			[private]

References Name(), and Say.

Referenced by do_PrepAdd().

void XrdOlbServer::Process_Director

(

void

)

References XrdCms::Config, do_Chmod(), do_Delay(), do_Mkdir(), do_Mkpath(), do_Mv(), do_PrepAdd(), do_PrepDel(), do_Rm(), do_Rmdir(), do_Select(), do_Stats(), isOffline, XrdNetLink::LastError(), Link, XrdNetLink::Name(), Receive(), and Say.

Referenced by XrdOlbManager::Login().

int XrdOlbServer::Process_Requests

(

void

)

References XrdCmsConfig::asManager(), XrdCms::Config, do_Chmod(), do_Disc(), do_Mkdir(), do_Mkpath(), do_Mv(), do_Ping(), do_PrepAdd(), do_PrepDel(), do_Rm(), do_Rmdir(), do_Space(), do_State(), do_Try(), do_Usage(), isOffline, XrdNetLink::LastError(), Link, XrdCms::Manager, XrdNetLink::Name(), XrdOlb::OlbState, Receive(), Say, ServMask, and XrdOlbState::Sync().

Referenced by XrdOlbManager::Pander().

int XrdOlbServer::Process_Responses

(

void

)

References XrdCmsConfig::asManager(), XrdCms::Config, DiskFree, DiskTotu, do_AvKb(), do_Disc(), do_Gone(), do_Have(), do_Load(), do_Pong(), do_RST(), do_StNst(), do_SuRes(), dsk_free, dsk_totu, XrdCmsManager::Inform(), isOffline, isRW, XrdNetLink::LastError(), Link, XrdSysMutex::Lock(), XrdCms::Manager, mlMutex, myNick, XrdNetLink::Name(), Receive(), Say, snprintf, and XrdSysMutex::UnLock().

Referenced by XrdOlbManager::Login().

char * XrdOlbServer::Receive	(	char *	idbuff,
		int	blen
	)			[private]

References DEBUG, EPNAME, XrdNetLink::GetLine(), XrdNetLink::GetToken(), isActive, Link, myNick, XrdCms::Trace, TRACE_Debug, TRACEX, and XrdOucTrace::What.

Referenced by Login(), Process_Director(), Process_Requests(), and Process_Responses().

int XrdOlbServer::Reissue	(	char *	rid,
		const char *	op,
		char *	arg1,
		char *	path,
		char *	arg3 = 0
	)			[private]

References XrdCms::Cache, XrdCms::Config, XrdCmsPList_Anchor::Find(), iovec::iov_base, iovec::iov_len, XrdCms::Manager, XrdCmsCache::Paths, XrdOlbPInfo::rovec, XrdOlbPInfo::rwvec, and Say.

Referenced by do_Chmod(), do_Mkdir(), do_Mkpath(), do_Mv(), do_PrepDel(), do_Rm(), and do_Rmdir().

int XrdOlbServer::Resume

(

XrdOlbPrepArgs *

pargs

)

[static]

References do_PrepAdd4Real(), do_PrepSel(), XrdOlbPrepArgs::endP, XrdOlbPrepArgs::Request(), and XrdOlbPrepArgs::Stage.

Referenced by XrdOlbPrepArgs::DoIt(), and XrdOlbStartPreparing().

int XrdOlbServer::Send	(	const struct iovec *	iov,
		int	iovcnt
	)

int XrdOlbServer::Send	(	const char *	buff,
		int	blen = 0
	)

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

Referenced by XrdOlbManager::Broadcast(), XrdOlbManTree::Connect(), XrdOlbManager::MonPerf(), XrdOlbReq::Reply(), XrdOlbManager::Reset(), and XrdOlbRRQ::sendResponse().

void XrdOlbServer::setName	(	XrdNetLink *	lnkp,
		int	port
	)

References myName, myNick, XrdNetLink::Name(), XrdNetLink::Nick(), and Port.

Referenced by XrdOlbServer().

static void XrdOlbServer::setRelay

(

XrdNetLink *

rlyp

)

[inline, static]

References Relay.

Referenced by XrdOlbConfig::setupServer().

static void XrdOlbServer::setSpace	(	int	Dfree,
		int	Dutil
	)			[inline, static]

References dsk_free, and dsk_totu.

Referenced by XrdOlbConfig::Configure2().

void XrdOlbServer::UnLock

(

)

[inline]

References myMutex, and XrdSysMutex::UnLock().

Referenced by XrdOlbManager::AddServer(), XrdOlbManager::Broadcast(), XrdOlbManager::ListServers(), XrdOlbManager::Login(), XrdOlbManager::MonPerf(), XrdOlbManager::MonPing(), XrdOlbManager::MonRefs(), XrdOlbManager::Reset(), XrdOlbManager::SelServer(), and ~XrdOlbServer().

---

Friends And Related Function Documentation

friend class XrdOlbManager [friend]

---

Member Data Documentation

int XrdOlbServer::cpu_load = 0 [static, private]

Referenced by do_Load(), and do_Usage().

int XrdOlbServer::DiskFree [private]

Referenced by do_AvKb(), do_Load(), XrdOlbManager::Login(), Process_Responses(), XrdOlbManager::SelbyLoad(), XrdOlbManager::SelbyRef(), XrdOlbManager::SelServer(), and XrdOlbServer().

int XrdOlbServer::DiskNums [private]

Referenced by XrdOlbManager::Login(), and XrdOlbServer().

int XrdOlbServer::DiskTotu [private]

Referenced by do_AvKb(), do_Load(), XrdOlbManager::ListServers(), XrdOlbManager::Login(), Process_Responses(), and XrdOlbServer().

XrdOlbDrop* XrdOlbServer::DropJob [private]

Referenced by XrdOlbManager::Drop_Server(), XrdOlbManager::Remove_Server(), and XrdOlbServer().

time_t XrdOlbServer::DropTime [private]

Referenced by XrdOlbManager::Drop_Server(), XrdOlbManager::Remove_Server(), and XrdOlbServer().

int XrdOlbServer::dsk_free = 0 [static, private]

Referenced by do_Load(), do_Space(), do_Usage(), Process_Responses(), and setSpace().

int XrdOlbServer::dsk_totu = 0 [static, private]

Referenced by do_Load(), do_Space(), do_Usage(), Process_Responses(), and setSpace().

XrdOlbRRQInfo XrdOlbServer::Info [private]

Referenced by do_Mv(), do_Rm(), do_Rmdir(), do_Select(), getMode(), XrdOlbManager::Login(), and XrdOlbServer().

int XrdOlbServer::Instance [private]

Referenced by do_Gone(), do_Have(), XrdOlbManager::Drop_Server(), Inst(), XrdOlbManager::Login(), XrdOlbManager::Login_Failed(), XrdOlbManager::MonPerf(), XrdOlbManager::Remove_Manager(), XrdOlbManager::Remove_Server(), and XrdOlbServer().

unsigned int XrdOlbServer::IPAddr [private]

Referenced by isServer(), XrdOlbManager::ListServers(), and XrdOlbServer().

char XrdOlbServer::isActive

Referenced by XrdOlbManager::Add_Manager(), XrdOlbManager::MonPing(), Receive(), and XrdOlbServer().

char XrdOlbServer::isBound

Referenced by XrdOlbManager::Drop_Server(), XrdOlbManager::Login(), XrdOlbManager::MonPerf(), XrdOlbManager::Remove_Server(), and XrdOlbServer().

char XrdOlbServer::isBusy

Referenced by XrdOlbServer().

char XrdOlbServer::isDisable

Referenced by do_StNst(), do_SuRes(), XrdOlbManager::ListServers(), XrdOlbManager::Login(), XrdOlbManager::SelbyCost(), XrdOlbManager::SelbyLoad(), XrdOlbManager::SelbyRef(), XrdOlbManager::SelServer(), and XrdOlbServer().

char XrdOlbServer::isGone

Referenced by XrdOlbManager::AddServer(), XrdOlbManager::Login(), and XrdOlbServer().

char XrdOlbServer::isKnown

Referenced by do_State(), XrdOlbManager::Reset(), and XrdOlbServer().

char XrdOlbServer::isMan

Referenced by XrdOlbManager::Add_Manager(), do_State(), do_StNst(), do_SuRes(), XrdOlbManager::Drop_Server(), XrdOlbManager::ListServers(), and XrdOlbServer().

char XrdOlbServer::isNoStage

Referenced by XrdOlbManager::Add_Manager(), do_StNst(), XrdOlbManager::ListServers(), XrdOlbManager::Remove_Server(), XrdOlbManager::SelbyCost(), XrdOlbManager::SelbyLoad(), XrdOlbManager::SelbyRef(), XrdOlbManager::SelServer(), and XrdOlbServer().

char XrdOlbServer::isOffline

Referenced by XrdOlbManager::Add_Manager(), XrdOlbManager::AddServer(), XrdOlbManager::Broadcast(), do_Disc(), do_StNst(), do_SuRes(), do_Try(), XrdOlbManager::Drop_Server(), XrdOlbManager::ListServers(), XrdOlbManager::Login(), XrdOlbManager::MonPing(), Process_Director(), Process_Requests(), Process_Responses(), XrdOlbManager::Remove_Manager(), XrdOlbManager::Remove_Server(), XrdOlbManager::Reset(), XrdOlbManager::SelbyCost(), XrdOlbManager::SelbyLoad(), XrdOlbManager::SelbyRef(), XrdOlbManager::SelServer(), Send(), XrdOlbServer(), and ~XrdOlbServer().

char XrdOlbServer::isPeer

Referenced by XrdOlbManager::Drop_Server(), XrdOlbManager::ListServers(), XrdOlbManager::Login(), and XrdOlbServer().

char XrdOlbServer::isProxy

Referenced by XrdOlbManager::ListServers(), and XrdOlbServer().

char XrdOlbServer::isRW

Referenced by XrdOlbManager::AddPath(), do_Load(), XrdOlbManager::ListServers(), and Process_Responses().

char XrdOlbServer::isSpecial

Referenced by XrdOlbServer().

char XrdOlbServer::isSuspend

Referenced by XrdOlbManager::Add_Manager(), do_SuRes(), XrdOlbManager::ListServers(), XrdOlbManager::Login(), XrdOlbManager::Remove_Server(), XrdOlbManager::SelbyCost(), XrdOlbManager::SelbyLoad(), XrdOlbManager::SelbyRef(), XrdOlbManager::SelServer(), and XrdOlbServer().

XrdNetLink* XrdOlbServer::Link [private]

Referenced by XrdOlbManager::Add_Manager(), XrdOlbManager::AddPath(), XrdOlbManager::AddServer(), do_AvKb(), do_Chmod(), do_Delay(), do_Disc(), do_Gone(), do_Have(), do_Load(), do_Locate(), do_Mkdir(), do_Mkpath(), do_Mv(), do_Ping(), do_PrepAdd(), do_PrepDel(), do_Rm(), do_Rmdir(), do_Select(), do_Space(), do_State(), do_Stats(), do_Try(), do_Usage(), isServer(), Login(), XrdOlbManager::MonPing(), Process_Director(), Process_Requests(), Process_Responses(), Receive(), XrdOlbManager::Remove_Manager(), XrdOlbManager::Remove_Server(), XrdOlbManager::SelServer(), Send(), XrdOlbServer(), and ~XrdOlbServer().

int XrdOlbServer::logload [private]

Referenced by do_Load(), and XrdOlbServer().

int XrdOlbServer::mem_load = 0 [static, private]

Referenced by do_Load(), and do_Usage().

XrdSysMutex XrdOlbServer::mlMutex [static, private]

Referenced by do_Load(), and Process_Responses().

int XrdOlbServer::myCost [private]

Referenced by XrdOlbManager::SelbyCost(), and XrdOlbServer().

int XrdOlbServer::myLevel [private]

Referenced by do_Try(), Login(), and XrdOlbServer().

int XrdOlbServer::myLoad [private]

Referenced by do_Load(), XrdOlbManager::ListServers(), XrdOlbManager::SelbyLoad(), XrdOlbManager::SelServer(), and XrdOlbServer().

XrdSysMutex XrdOlbServer::myMutex [private]

Referenced by Lock(), and UnLock().

char* XrdOlbServer::myName [private]

Referenced by Name(), setName(), XrdOlbServer(), and ~XrdOlbServer().

char* XrdOlbServer::myNick [private]

Referenced by Nick(), Process_Responses(), Receive(), setName(), XrdOlbServer(), and ~XrdOlbServer().

char* XrdOlbServer::mySID [private]

Referenced by isServer(), XrdOlbServer(), and ~XrdOlbServer().

int XrdOlbServer::net_load = 0 [static, private]

Referenced by do_Load(), and do_Usage().

int XrdOlbServer::newload [private]

Referenced by do_Load(), XrdOlbManager::MonPerf(), and XrdOlbServer().

XrdOlbServer* XrdOlbServer::Next [private]

Referenced by XrdOlbServer().

int XrdOlbServer::pag_load = 0 [static, private]

Referenced by do_Load(), and do_Usage().

int XrdOlbServer::pingpong [private]

Referenced by do_Pong(), XrdOlbManager::MonPerf(), and XrdOlbServer().

int XrdOlbServer::Port [private]

Referenced by isServer(), XrdOlbManager::ListServers(), setName(), and XrdOlbServer().

struct iovec XrdOlbServer::redr_iov[redr_iov_cnt] [private]

Referenced by do_Select(), and XrdOlbServer().

const int XrdOlbServer::redr_iov_cnt = 3 [static, private]

Referenced by do_Select().

int XrdOlbServer::RefA [private]

Referenced by XrdOlbManager::ListServers(), XrdOlbManager::MonRefs(), XrdOlbManager::SelbyCost(), XrdOlbManager::SelbyLoad(), XrdOlbManager::SelbyRef(), and XrdOlbServer().

int XrdOlbServer::RefR [private]

Referenced by XrdOlbManager::ListServers(), XrdOlbManager::MonRefs(), XrdOlbManager::SelbyCost(), XrdOlbManager::SelbyLoad(), XrdOlbManager::SelbyRef(), XrdOlbManager::SelServer(), and XrdOlbServer().

int XrdOlbServer::RefTotA [private]

Referenced by XrdOlbManager::ListServers(), XrdOlbManager::MonRefs(), and XrdOlbServer().

int XrdOlbServer::RefTotR [private]

Referenced by XrdOlbManager::ListServers(), XrdOlbManager::MonRefs(), and XrdOlbServer().

XrdNetLink * XrdOlbServer::Relay = 0 [static, private]

Referenced by Inform(), and setRelay().

XrdOlbReq XrdOlbServer::Req [private]

Referenced by do_Chmod(), do_Mkdir(), do_Mkpath(), do_Mv(), do_Rm(), do_Rmdir(), do_Select(), and getMode().

int XrdOlbServer::ServID [private]

Referenced by XrdOlbManager::Add_Manager(), XrdOlbManager::ListServers(), XrdOlbManager::Login(), XrdOlbManager::Login_Failed(), XrdOlbManager::Remove_Manager(), XrdOlbServer(), and ~XrdOlbServer().

SMask_t XrdOlbServer::ServMask [private]

Referenced by XrdOlbManager::Add_Manager(), XrdOlbManager::AddPath(), do_Gone(), do_Have(), do_RST(), XrdOlbManager::Drop_Server(), XrdOlbManager::getMask(), isServer(), XrdOlbManager::ListServers(), XrdOlbManager::Login(), Process_Requests(), XrdOlbManager::SelbyCost(), XrdOlbManager::SelbyLoad(), XrdOlbManager::SelbyRef(), XrdOlbManager::SelServer(), XrdOlbServer(), and ~XrdOlbServer().

char* XrdOlbServer::Stype [private]

Referenced by XrdOlbManager::Login(), XrdOlbServer(), and ~XrdOlbServer().

int XrdOlbServer::xeq_load = 0 [static, private]

Referenced by do_Load(), and do_Usage().

---

The documentation for this class was generated from the following files:

• XrdOlbServer.hh
• XrdOlbServer.cc