XrdClientConnectionMgr Class Reference

#include <XrdClientConnMgr.hh>

Inheritance diagram for XrdClientConnectionMgr:

Collaboration diagram for XrdClientConnectionMgr:

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 ()
Public Member Functions inherited from XrdClientAbsUnsolMsgHandler
virtual	~XrdClientAbsUnsolMsgHandler ()

Private Member Functions
UnsolRespProcResult	ProcessUnsolicitedMsg (XrdClientUnsolMsgSender *sender, XrdClientMessage *unsolmsg)
Private Member Functions inherited from XrdClientUnsolMsgSender
virtual	~XrdClientUnsolMsgSender ()
UnsolRespProcResult	SendUnsolicitedMsg (XrdClientUnsolMsgSender *sender, XrdClientMessage *unsolmsg)
	XrdClientUnsolMsgSender ()

Private Attributes
XrdClientSid *	fSidManager
XrdClientVector < XrdClientLogConnection * >	fLogVec
XrdOucHash < XrdClientPhyConnection >	fPhyHash
int	fLastLogIdUsed
XrdClientVector < XrdClientPhyConnection * >	fPhyTrash
XrdOucHash< CndVarInfo >	fConnectingCondVars
XrdSysRecMutex	fMutex
XrdClientThread *	fGarbageColl
Private Attributes inherited from XrdClientUnsolMsgSender
XrdClientAbsUnsolMsgHandler *	UnsolicitedMsgHandler

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 Error, fGarbageColl, fLastLogIdUsed, fSidManager, GarbageCollectorThread, and XrdClientThread::Run().

Referenced by XrdClientConnectionMgr().

int XrdClientConnectionMgr::Connect

(

XrdClientUrlInfo

RemoteAddress

)

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

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

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

Referenced by ShutDown().

void XrdClientConnectionMgr::GarbageCollect

(

)

References XrdOucHash< T >::Apply(), DebugLevel, DisconnectElapsedPhyConn, DumpPhyConn(), XrdClientVector< T >::Erase(), fMutex, fPhyHash, fPhyTrash, XrdClientVector< T >::GetSize(), XrdClientDebug::kUSERDEBUG, and XrdOucHash< T >::Num().

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

XrdClientLogConnection * XrdClientConnectionMgr::GetConnection

(

int

LogConnectionID

)

References fLogVec, and fMutex.

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

XrdClientPhyConnection * XrdClientConnectionMgr::GetPhyConnection

(

XrdClientUrlInfo

server

)

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

Referenced by ProcessUnsolicitedMsg().

UnsolRespProcResult XrdClientConnectionMgr::ProcessUnsolicitedMsg ( XrdClientUnsolMsgSender *  sender, XrdClientMessage *  unsolmsg  )

privatevirtual

Implements XrdClientAbsUnsolMsgHandler.

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

XrdClientMessage * XrdClientConnectionMgr::ReadMsg

(

int

LogConnectionID

)

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

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

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

bool XrdClientConnectionMgr::ShutDown

(

)

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

Referenced by ~XrdClientConnectionMgr().

XrdClientSid* XrdClientConnectionMgr::SidManager ( )

inline

References fSidManager.

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

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

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 Connect(), Disconnect(), GetConnection(), ProcessUnsolicitedMsg(), and ShutDown().

XrdSysRecMutex XrdClientConnectionMgr::fMutex

private

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

XrdOucHash<XrdClientPhyConnection> XrdClientConnectionMgr::fPhyHash

private

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

XrdClientVector<XrdClientPhyConnection *> XrdClientConnectionMgr::fPhyTrash

private

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

XrdClientSid* XrdClientConnectionMgr::fSidManager

private

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

---

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

• XrdClientConnMgr.hh
• XrdClientConnMgr.cc