XrdProofdNetMgr Class Reference

#include <XrdProofdNetMgr.h>

Inheritance diagram for XrdProofdNetMgr:


Public Member Functions
	XrdProofdNetMgr (XrdProofdManager mgr, XrdProtocol_Config pi, XrdSysError *e)
virtual	~XrdProofdNetMgr ()
int	Config (bool rcf=0)
int	DoDirective (XrdProofdDirective d, char val, XrdOucStream *cfg, bool rcf)
void	RegisterDirectives ()
void	Dump ()
const char *	PROOFcfg () const
bool	WorkerUsrCfg () const
int	Broadcast (int type, const char msg, const char usr=0, XrdProofdResponse *r=0, bool notify=0, int subtype=-1)
int	BroadcastCtrlC (const char *usr)
XrdProofConn *	GetProofConn (const char *url)
bool	IsLocal (const char *host, bool checkport=0)
XrdClientMessage *	Send (const char url, int type, const char msg, int srvtype, XrdProofdResponse *r, bool notify=0, int subtype=-1)
int	ReadBuffer (XrdProofdProtocol *p)
char *	ReadBufferLocal (const char *file, kXR_int64 ofs, int &len)
char *	ReadBufferLocal (const char file, const char pat, int &len, int opt)
char *	ReadBufferRemote (const char url, const char file, kXR_int64 ofs, int &len, int grep)
char *	ReadLogPaths (const char url, const char stag, int isess)
std::list< XrdProofWorker * > *	GetActiveWorkers ()
std::list< XrdProofWorker * > *	GetNodes ()
void	BalanceNodesOrder ()
Private Member Functions
void	CreateDefaultPROOFcfg ()
int	ReadPROOFcfg (bool reset=1)
int	FindUniqueNodes ()
int	LocateLocalFile (XrdOucString &file)
int	DoDirectiveBonjour (char val, XrdOucStream cfg, bool)
int	DoDirectiveAdminReqTO (char , XrdOucStream , bool)
int	DoDirectiveResource (char , XrdOucStream , bool)
int	DoDirectiveWorker (char , XrdOucStream , bool)
Private Attributes
XrdSysRecMutex	fMutex
XrdProofdManager *	fMgr
XrdOucHash< XrdProofConn >	fProofConnHash
int	fNumLocalWrks
int	fResourceType
XrdProofdFile	fPROOFcfg
bool	fReloadPROOFcfg
bool	fDfltFallback
bool	fWorkerUsrCfg
int	fRequestTO
std::list< XrdProofWorker * >	fDfltWorkers
std::list< XrdProofWorker * >	fRegWorkers
std::list< XrdProofWorker * >	fWorkers
std::list< XrdProofWorker * >	fNodes
bool	fBonjourEnabled

Detailed Description

Definition at line 46 of file XrdProofdNetMgr.h.

Constructor & Destructor Documentation

XrdProofdNetMgr::XrdProofdNetMgr	(	XrdProofdManager *	mgr,
		XrdProtocol_Config *	pi,
		XrdSysError *	e
	)

Definition at line 60 of file XrdProofdNetMgr.cxx.

References fBonjourEnabled, fDfltFallback, fDfltWorkers, fMgr, XrdProofdFile::fMtime, XrdProofdFile::fName, fNodes, fNumLocalWrks, fPROOFcfg, fRegWorkers, fReloadPROOFcfg, fRequestTO, fResourceType, fWorkers, fWorkerUsrCfg, XrdNetDNS::getHostName(), XrdProofdAux::GetNumCPUs(), kBonjourSrvDisabled, kRTNone, RegisterDirectives(), and SafeFree.

XrdProofdNetMgr::~XrdProofdNetMgr ( ) [virtual]

Definition at line 104 of file XrdProofdNetMgr.cxx.

References fDfltWorkers, fRegWorkers, fWorkers, and w.

Member Function Documentation

void XrdProofdNetMgr::CreateDefaultPROOFcfg ( ) [private]

Definition at line 1578 of file XrdProofdNetMgr.cxx.

References fDfltWorkers, FindUniqueNodes(), fMgr, fMutex, fNumLocalWrks, fWorkers, XrdProofdManager::Host(), XrdProofdManager::Port(), TRACE, and XPDLOC.

Referenced by Config(), GetActiveWorkers(), and GetNodes().

int XrdProofdNetMgr::ReadPROOFcfg ( bool reset = 1 ) [private]

Definition at line 1704 of file XrdProofdNetMgr.cxx.

References XrdOucString::beginswith(), XrdOucString::c_str(), fclose(), fDfltFallback, XrdProofWorker::fHost, FindUniqueNodes(), fMgr, XrdProofdFile::fMtime, fMutex, XrdProofdFile::fName, fopen, XrdProofWorker::fPort, fPROOFcfg, fRegWorkers, fWorkers, XrdProofdManager::Host(), XrdOucString::length(), XrdProofWorker::Matches(), p, XrdProofWorker::Reset(), SafeDelete, stat, TRACE, and XPDLOC.

Referenced by Config(), GetActiveWorkers(), and GetNodes().

int XrdProofdNetMgr::FindUniqueNodes ( ) [private]

Definition at line 1862 of file XrdProofdNetMgr.cxx.

References fNodes, fWorkers, n, TRACE, and XPDLOC.

Referenced by Config(), CreateDefaultPROOFcfg(), DoDirectiveWorker(), and ReadPROOFcfg().

int XrdProofdNetMgr::LocateLocalFile ( XrdOucString & file ) [private]

Definition at line 1182 of file XrdProofdNetMgr.cxx.

References XrdOucString::assign(), XrdOucString::c_str(), closedir, emsg(), XrdOucString::find(), XrdOucString::length(), XrdOucString::matches(), opendir, readdir, XrdOucString::rfind(), STR_NPOS, TRACE, XPDFORM, and XPDLOC.

Referenced by ReadBufferLocal().

int XrdProofdNetMgr::DoDirectiveBonjour	(	char *	val,
		XrdOucStream *	cfg,
		bool
	)			`[private]`

Definition at line 233 of file XrdProofdNetMgr.cxx.

References fMgr, XrdOucStream::GetWord(), kBonjourSrvBoth, kBonjourSrvBrowse, kBonjourSrvRegister, NULL, XrdOucStream::RetToken(), s, XrdProofdManager::SrvType(), strtol(), TRACE, and XPDLOC.

Referenced by DoDirective().

int XrdProofdNetMgr::DoDirectiveAdminReqTO	(	char *	,
		XrdOucStream *	,
		bool
	)			`[private]`

Definition at line 655 of file XrdProofdNetMgr.cxx.

References XrdProofdAux::CheckIf(), fMgr, fRequestTO, XrdProofdManager::Host(), and strtol().

Referenced by DoDirective().

int XrdProofdNetMgr::DoDirectiveResource	(	char *	,
		XrdOucStream *	,
		bool
	)			`[private]`

Definition at line 676 of file XrdProofdNetMgr.cxx.

References access, XrdOucString::beginswith(), XrdOucString::c_str(), XrdProofdAux::Expand(), fDfltFallback, XrdProofdFile::fMtime, XrdProofdFile::fName, fPROOFcfg, fReloadPROOFcfg, fResourceType, fWorkerUsrCfg, XrdOucStream::GetWord(), kRTStatic, R_OK, XrdOucString::replace(), s, TRACE, and XPDLOC.

Referenced by DoDirective().

int XrdProofdNetMgr::DoDirectiveWorker	(	char *	,
		XrdOucStream *	,
		bool
	)			`[private]`

Definition at line 723 of file XrdProofdNetMgr.cxx.

References XrdOucString::beginswith(), XrdProofWorker::fHost, FindUniqueNodes(), fMgr, fMutex, fWorkers, XrdOucStream::GetRest(), XrdOucStream::GetWord(), XrdProofdManager::Host(), i, line, XrdProofWorker::Matches(), XrdProofWorker::Reset(), XrdOucStream::RetToken(), SafeDelete, STR_NPOS, TRACE, XPD_LONGOK, XPDFORM, and XPDLOC.

Referenced by DoDirective().

int XrdProofdNetMgr::Config ( bool rcf = 0 ) [virtual]

Reimplemented from XrdProofdConfig.

Definition at line 124 of file XrdProofdNetMgr.cxx.

References XrdOucString::c_str(), XrdProofdConfig::Config(), CreateDefaultPROOFcfg(), EnvPutInt, fBonjourEnabled, fDfltFallback, FindUniqueNodes(), fMgr, XrdProofdFile::fMtime, fMutex, XrdProofdFile::fName, fPROOFcfg, fReloadPROOFcfg, fRequestTO, fResourceType, fWorkers, XrdProofdManager::Host(), kRTNone, kRTStatic, kXPD_AnyServer, kXPD_Worker, XrdOucString::length(), NAME_REQUESTTIMEOUT, XrdProofdManager::Port(), ReadPROOFcfg(), XrdProofConn::SetRetryParam(), XrdProofdManager::SrvType(), TRACE, w, XPDERR, XPDFORM, and XPDLOC.

Referenced by XrdProofdManager::Config().

int XrdProofdNetMgr::DoDirective	(	XrdProofdDirective *	d,
		char *	val,
		XrdOucStream *	cfg,
		bool	rcf
	)			`[virtual]`

Reimplemented from XrdProofdConfig.

Definition at line 207 of file XrdProofdNetMgr.cxx.

References d, DoDirectiveAdminReqTO(), DoDirectiveBonjour(), DoDirectiveResource(), DoDirectiveWorker(), TRACE, and XPDLOC.

void XrdProofdNetMgr::RegisterDirectives ( ) [virtual]

Reimplemented from XrdProofdConfig.

Definition at line 92 of file XrdProofdNetMgr.cxx.

References DoDirectiveClass(), DoDirectiveInt(), fNumLocalWrks, and XrdProofdConfig::Register().

Referenced by XrdProofdNetMgr().

void XrdProofdNetMgr::Dump ( )

Definition at line 1655 of file XrdProofdNetMgr.cxx.

References fMutex, fWorkers, and XPDPRT.

Referenced by GetActiveWorkers(), XrdProofdManager::GetWorkers(), and XrdProofdAdmin::ReleaseWorker().

const char* XrdProofdNetMgr::PROOFcfg ( ) const [inline]

Definition at line 101 of file XrdProofdNetMgr.h.

References XrdOucString::c_str(), XrdProofdFile::fName, and fPROOFcfg.

bool XrdProofdNetMgr::WorkerUsrCfg ( ) const [inline]

Definition at line 102 of file XrdProofdNetMgr.h.

References fWorkerUsrCfg.

Referenced by XrdProofdManager::Config(), XrdProofdProofServMgr::SetProofServEnv(), and XrdProofdProofServMgr::SetProofServEnvOld().

int XrdProofdNetMgr::Broadcast	(	int	type,
		const char *	msg,
		const char *	usr = `0`,
		XrdProofdResponse *	r = `0`,
		bool	notify = `0`,
		int	subtype = `-1`
	)

Definition at line 854 of file XrdProofdNetMgr.cxx.

References XrdProofdManager::EffectiveUser(), fMgr, fNodes, XrdProofdManager::Host(), kXPD_Master, kXPD_Worker, XrdProofdManager::Port(), SafeDelete, Send(), STR_NPOS, TRACE, u, w, and XPDLOC.

Referenced by XrdProofdAdmin::CleanupSessions(), XrdProofdAdmin::Exec(), and XrdProofdAdmin::SetROOTVersion().

int XrdProofdNetMgr::BroadcastCtrlC ( const char * usr )

Definition at line 793 of file XrdProofdNetMgr.cxx.

References XPD::clientMarshall(), XrdProofdManager::EffectiveUser(), fMgr, fNodes, GetProofConn(), XrdProofdManager::Host(), XrdProofConn::IsValid(), kOK, kXP_ctrlc, XrdProofConn::LowWrite(), XrdProofdManager::Port(), SafeDelete, XrdProofConn::SetSID(), STR_NPOS, TRACE, u, w, and XPDLOC.

Referenced by XrdProofdProtocol::CtrlC().

XrdProofConn * XrdProofdNetMgr::GetProofConn ( const char * url )

Definition at line 908 of file XrdProofdNetMgr.cxx.

References buf, fMgr, fMutex, XrdProofdManager::Host(), m, p, and SafeDelete.

Referenced by BroadcastCtrlC(), ReadBufferRemote(), ReadLogPaths(), and Send().

bool XrdProofdNetMgr::IsLocal	(	const char *	host,
		bool	checkport = `0`
	)

Definition at line 1034 of file XrdProofdNetMgr.cxx.

References XrdOucString::c_str(), fMgr, XrdNetDNS::getHostName(), XrdClientUrlInfo::Host, XrdProofdManager::Host(), XrdProofdManager::Port(), XrdClientUrlInfo::Port, and SafeFree.

Referenced by XrdProofdAdmin::Exec(), and ReadBuffer().

XrdClientMessage * XrdProofdNetMgr::Send	(	const char *	url,
		int	type,
		const char *	msg,
		int	srvtype,
		XrdProofdResponse *	r,
		bool	notify = `0`,
		int	subtype = `-1`
	)