XrdClientConnectionMgr Class Reference

#include <XrdClientConnMgr.hh>

Inheritance diagram for XrdClientConnectionMgr:

Collaboration diagram for XrdClientConnectionMgr:

List of all members.

Classes
class	CndVarInfo
Public Member Functions
	XrdClientConnectionMgr ()
virtual	~XrdClientConnectionMgr ()
bool	BootUp ()
bool	ShutDown ()
int	Connect (XrdClientUrlInfo RemoteAddress)
void	Disconnect (int LogConnectionID, bool ForcePhysicalDisc)
void	GarbageCollect ()
XrdClientLogConnection *	GetConnection (int LogConnectionID)
XrdClientPhyConnection *	GetPhyConnection (XrdClientUrlInfo server)
XrdClientMessage *	ReadMsg (int LogConnectionID)
int	ReadRaw (int LogConnectionID, void *buffer, int BufferLength)
int	WriteRaw (int LogConnectionID, const void *buffer, int BufferLength, int substreamid)
XrdClientSid *	SidManager ()
Private Member Functions
UnsolRespProcResult	ProcessUnsolicitedMsg (XrdClientUnsolMsgSender *sender, XrdClientMessage *unsolmsg)
Private Attributes
XrdClientSid *	fSidManager
XrdClientVector < XrdClientLogConnection * >	fLogVec
XrdOucHash < XrdClientPhyConnection >	fPhyHash
int	fLastLogIdUsed
XrdClientVector < XrdClientPhyConnection * >	fPhyTrash
XrdOucHash< CndVarInfo >	fConnectingCondVars
XrdSysRecMutex	fMutex
XrdClientThread *	fGarbageColl
Friends
void *	GarbageCollectorThread (void *, XrdClientThread *thr)
int	DisconnectElapsedPhyConn (const char *, XrdClientPhyConnection *, void *)
int	DestroyPhyConn (const char *, XrdClientPhyConnection *, void *)

---

Constructor & Destructor Documentation

XrdClientConnectionMgr::XrdClientConnectionMgr

(

)

References BootUp().

XrdClientConnectionMgr::~XrdClientConnectionMgr

(

)

[virtual]

References ShutDown().

---

Member Function Documentation

bool XrdClientConnectionMgr::BootUp

(

)

References fLastLogIdUsed, fGarbageColl, GarbageCollectorThread, Error, XrdClientThread::Run(), and fSidManager.

Referenced by XrdClientConnectionMgr().

int XrdClientConnectionMgr::Connect

(

XrdClientUrlInfo

RemoteAddress

)

References FALSE, Info, XrdClientDebug::kHIDEBUG, fSidManager, Error, XrdClientUrlInfo::User, XrdOucString::length(), XrdOucUtils::UserName(), XrdOucString::c_str(), XrdClientUrlInfo::Host, XrdClientUrlInfo::Port, XrdClientUrlInfo::HostAddr, fMutex, XrdSysMutex::Lock(), fConnectingCondVars, XrdOucHash::Find(), fPhyHash, XrdOucHash::Num(), GarbageCollect(), XrdClientPhyConnection::IsValid(), XrdClientPhyConnection::CountLogConn(), XrdClientPhyConnection::Touch(), XrdClientLogConnection::SetPhyConnection(), TRUE, XrdOucHash::Rep(), Hash_keepdata, XrdSysMutex::UnLock(), XrdClientConnectionMgr::CndVarInfo::cv, XrdSysCondVar::Lock(), XrdClientConnectionMgr::CndVarInfo::cnt, XrdSysCondVar::Wait(), XrdSysCondVar::UnLock(), DebugLevel, XrdOucHash::Apply(), DumpPhyConn(), XrdClientPhyConnection::Connect(), XrdSysCondVar::Broadcast(), XrdOucHash::Del(), fPhyTrash, XrdClientVector::Push_back(), XrdClientPhyConnection::WipeStreamid(), XrdClientLogConnection::Streamid(), fLogVec, XrdClientVector::GetSize(), XRC_MAXVECTSIZE, and fLastLogIdUsed.

void XrdClientConnectionMgr::Disconnect	(	int	LogConnectionID,
		bool	ForcePhysicalDisc
	)

References fMutex, fLogVec, XrdClientVector::GetSize(), Error, GarbageCollect(), Info, and XrdClientDebug::kHIDEBUG.

Referenced by ShutDown().

void XrdClientConnectionMgr::GarbageCollect

(

)

References fMutex, fPhyHash, XrdOucHash::Num(), DebugLevel, XrdOucHash::Apply(), DumpPhyConn(), DisconnectElapsedPhyConn, fPhyTrash, XrdClientVector::GetSize(), and XrdClientVector::Erase().

Referenced by GarbageCollectorThread(), ShutDown(), Connect(), and Disconnect().

XrdClientLogConnection * XrdClientConnectionMgr::GetConnection

(

int

LogConnectionID

)

References fMutex, and fLogVec.

Referenced by ReadRaw(), ReadMsg(), and WriteRaw().

XrdClientPhyConnection * XrdClientConnectionMgr::GetPhyConnection

(

XrdClientUrlInfo

server

)

References XrdClientUrlInfo::User, XrdOucString::length(), XrdOucUtils::UserName(), XrdOucString::c_str(), XrdClientUrlInfo::Host, XrdClientUrlInfo::Port, XrdClientUrlInfo::HostAddr, fPhyHash, XrdOucHash::Num(), XrdOucHash::Find(), and XrdClientPhyConnection::IsValid().

Referenced by ProcessUnsolicitedMsg().

UnsolRespProcResult XrdClientConnectionMgr::ProcessUnsolicitedMsg	(	XrdClientUnsolMsgSender *	sender,
		XrdClientMessage *	unsolmsg
	)		[private, virtual]

Implements XrdClientAbsUnsolMsgHandler.

References kUNSOL_CONTINUE, fMutex, fLogVec, XrdClientVector::GetSize(), GetPhyConnection(), XrdSysMutex::UnLock(), and XrdSysMutex::Lock().

XrdClientMessage * XrdClientConnectionMgr::ReadMsg

(

int

LogConnectionID

)

References GetConnection(), XrdClientLogConnection::GetPhyConnection(), XrdClientPhyConnection::ReadMessage(), and XrdClientLogConnection::Streamid().

int XrdClientConnectionMgr::ReadRaw	(	int	LogConnectionID,
		void *	buffer,
		int	BufferLength
	)

References GetConnection(), XrdClientLogConnection::ReadRaw(), Error, and TXSOCK_ERR.

bool XrdClientConnectionMgr::ShutDown

(

)

References fPhyHash, XrdOucHash::Apply(), DumpPhyConn(), fMutex, fLogVec, XrdClientVector::GetSize(), Disconnect(), TRUE, fGarbageColl, XrdClientThread::Cancel(), XrdClientThread::Join(), GarbageCollect(), DestroyPhyConn, fPhyTrash, XrdClientVector::Clear(), XrdOucHash::Purge(), and fSidManager.

Referenced by ~XrdClientConnectionMgr().

XrdClientSid* XrdClientConnectionMgr::SidManager

(

)

[inline]

References fSidManager.

int XrdClientConnectionMgr::WriteRaw	(	int	LogConnectionID,
		const void *	buffer,
		int	BufferLength,
		int	substreamid
	)

References GetConnection(), XrdClientLogConnection::WriteRaw(), Error, and TXSOCK_ERR.

---

Friends And Related Function Documentation

int DestroyPhyConn	(	const char *	key,
		XrdClientPhyConnection *	p,
		void *	voidcmgr
	)		[friend]

Referenced by ShutDown().

int DisconnectElapsedPhyConn	(	const char *	key,
		XrdClientPhyConnection *	p,
		void *	voidcmgr
	)		[friend]

Referenced by GarbageCollect().

void* GarbageCollectorThread	(	void *	arg,
		XrdClientThread *	thr
	)		[friend]

Referenced by BootUp().

---

Member Data Documentation

XrdOucHash<CndVarInfo> XrdClientConnectionMgr::fConnectingCondVars [private]

Referenced by Connect().

XrdClientThread* XrdClientConnectionMgr::fGarbageColl [private]

Referenced by BootUp(), and ShutDown().

int XrdClientConnectionMgr::fLastLogIdUsed [private]

Referenced by BootUp(), and Connect().

XrdClientVector<XrdClientLogConnection*> XrdClientConnectionMgr::fLogVec [private]

Referenced by ShutDown(), Connect(), Disconnect(), GetConnection(), and ProcessUnsolicitedMsg().

XrdSysRecMutex XrdClientConnectionMgr::fMutex [private]

Referenced by ShutDown(), GarbageCollect(), Connect(), Disconnect(), GetConnection(), and ProcessUnsolicitedMsg().

XrdOucHash<XrdClientPhyConnection> XrdClientConnectionMgr::fPhyHash [private]

Referenced by ShutDown(), GarbageCollect(), Connect(), and GetPhyConnection().

XrdClientVector<XrdClientPhyConnection *> XrdClientConnectionMgr::fPhyTrash [private]

Referenced by DisconnectElapsedPhyConn(), ShutDown(), GarbageCollect(), and Connect().

XrdClientSid* XrdClientConnectionMgr::fSidManager [private]

Referenced by BootUp(), ShutDown(), Connect(), and SidManager().

---

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

• XrdClientConnMgr.hh
• XrdClientConnMgr.cc