XrdProofdProofServMgr.cxx File Reference

#include "XrdProofdPlatform.h"
#include "XrdSys/XrdSysError.hh"
#include "XrdSys/XrdSysLogger.hh"
#include "Xrd/XrdBuffer.hh"
#include "Xrd/XrdPoll.hh"
#include "Xrd/XrdScheduler.hh"
#include "XrdNet/XrdNet.hh"
#include "XrdNet/XrdNetDNS.hh"
#include "XrdNet/XrdNetPeer.hh"
#include "XrdOuc/XrdOucRash.hh"
#include "XrdOuc/XrdOucStream.hh"
#include "XrdSys/XrdSysPriv.hh"
#include "XrdSut/XrdSutAux.hh"
#include "XrdProofdClient.h"
#include "XrdProofdClientMgr.h"
#include "XrdProofdManager.h"
#include "XrdProofdNetMgr.h"
#include "XrdProofdPriorityMgr.h"
#include "XrdProofdProofServMgr.h"
#include "XrdProofdProtocol.h"
#include "XrdProofGroup.h"
#include "XrdProofSched.h"
#include "XrdROOT.h"
#include <map>
#include "XrdProofdTrace.h"

Go to the source code of this file.

Classes
struct	XpdBroadcastPriority_t
struct	XpdWriteEnv_t
Functions
void *	XrdProofdProofServCron (void *p)
void *	XrdProofdProofServRecover (void *p)
static int	WriteSessEnvs (const char *, XpdEnv *env, void *s)
static int	WriteSessRCs (const char *, XpdEnv *erc, void *f)
static int	BroadcastPriority (const char *, XrdProofdProofServ *ps, void *s)
static int	FreeClientID (const char *, XrdProofdProofServ *ps, void *s)
static int	CountTopMasters (const char *, XrdProofdProofServ *ps, void *s)
Variables
static XpdManagerCron_t	fManagerCron

---

Function Documentation

static int BroadcastPriority	(	const char *	,
		XrdProofdProofServ *	ps,
		void *	s
	)			[static]

Definition at line 3997 of file XrdProofdProofServMgr.cxx.

References XrdProofdProofServ::BroadcastPriority(), XrdProofdProofServ::Client(), emsg(), XpdBroadcastPriority_t::fGroupMgr, XpdBroadcastPriority_t::fNBroadcast, g, XrdProofGroupMgr::GetGroup(), XrdProofdProofServ::Group(), int, XrdProofdProofServ::IsValid(), kXPD_Master, kXPD_running, XrdProofdProofServ::SrvType(), XrdProofdProofServ::Status(), TRACE, and XPDLOC.

Referenced by XrdProofdProofServMgr::BroadcastPriorities().

static int CountTopMasters	(	const char *	,
		XrdProofdProofServ *	ps,
		void *	s
	)			[static]

Definition at line 4136 of file XrdProofdProofServMgr.cxx.

References emsg(), kXPD_TopMaster, XrdProofdProofServ::SrvType(), TRACE, and XPDLOC.

Referenced by XrdProofdProofServMgr::CurrentSessions().

static int FreeClientID	(	const char *	,
		XrdProofdProofServ *	ps,
		void *	s
	)			[static]

Definition at line 4106 of file XrdProofdProofServMgr.cxx.

References XrdProofdProofServ::FreeClientID(), TRACE, and XPDLOC.

Referenced by XrdProofdProofServMgr::DisconnectFromProofServ().

static int WriteSessEnvs	(	const char *	,
		XpdEnv *	env,
		void *	s
	)			[static]

Definition at line 2440 of file XrdProofdProofServMgr.cxx.

References emsg(), env, XpdWriteEnv_t::fClient, XpdWriteEnv_t::fEnv, XpdWriteEnv_t::fMgr, fprintf(), putenv, XrdProofdManager::ResolveKeywords(), TRACE, and XPDLOC.

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

static int WriteSessRCs	(	const char *	,
		XpdEnv *	erc,
		void *	f
	)			[static]

Definition at line 2837 of file XrdProofdProofServMgr.cxx.

References XrdOucString::c_str(), emsg(), XpdEnv::fEnv, XrdOucString::find(), fprintf(), XrdOucString::length(), STR_NPOS, TRACE, and XPDLOC.

Referenced by XrdProofdProofServMgr::SetProofServEnv().

void* XrdProofdProofServCron

(

void *

p

)

Definition at line 79 of file XrdProofdProofServMgr.cxx.

References XrdProofdProofServMgr::BroadcastClusterInfo(), XpdMsg::Buf(), XrdOucString::c_str(), XrdProofdProofServMgr::CheckActiveSessions(), XrdProofdProofServMgr::CheckCounter(), XrdProofdProofServMgr::CheckFrequency(), XrdProofdProofServMgr::CheckTerminatedSessions(), XrdProofdProofServMgr::CleanupLostProofServ(), xmlio::cnt, XrdProofdProofServMgr::CurrentSessions(), XrdProofdProofServMgr::DeleteFromSessions(), XrdProofdProofServMgr::DisconnectFromProofServ(), XpdManagerCron_t::fProofSched, XpdManagerCron_t::fSessionMgr, XpdMsg::Get(), int, XrdProofdProofServMgr::kChgSessionSt, XrdProofdProofServMgr::kCleanSessions, XrdProofdProofServMgr::kCleanSessionsCnt, XrdProofdProofServMgr::kClientDisconnect, XrdProofdProofServMgr::kProcessCnt, XrdProofdProofServMgr::kProcessReq, XrdProofSched::kReschedule, XrdProofdProofServMgr::kSessionRemoval, XrdProofdProofServMgr::Mutex(), XrdProofdProofServMgr::MvSession(), XrdProofdProofServMgr::NextSessionsCheck(), XrdProofSched::Pipe(), XrdProofdProofServMgr::Pipe(), XrdProofdPipe::Poll(), XrdProofdPipe::Post(), XrdSysSemWait::Post(), XrdProofdProofServMgr::ProcessSem(), XrdProofdPipe::Recv(), XrdProofdProofServMgr::SetNextSessionsCheck(), TRACE, XpdMsg::Type(), XrdProofdProofServMgr::UpdateCounter(), and XPDLOC.

Referenced by XrdProofdProofServMgr::Config().

void* XrdProofdProofServRecover

(

void *

p

)

Definition at line 250 of file XrdProofdProofServMgr.cxx.

References XpdManagerCron_t::fSessionMgr, XrdProofdProofServMgr::RecoverActiveSessions(), TRACE, and XPDLOC.

Referenced by XrdProofdProofServMgr::PrepareSessionRecovering().

---

Variable Documentation

XpdManagerCron_t fManagerCron [static]

Definition at line 69 of file XrdProofdProofServMgr.cxx.

---