xrootd
|
#include <XrdClientConnMgr.hh>
XrdClientConnectionMgr::XrdClientConnectionMgr | ( | ) |
References BootUp().
XrdClientConnectionMgr::~XrdClientConnectionMgr | ( | ) | [virtual] |
References ShutDown().
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, XrdOucHash< T >::Del(), 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, 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 | ) |
UnsolRespProcResult XrdClientConnectionMgr::ProcessUnsolicitedMsg | ( | XrdClientUnsolMsgSender * | sender, |
XrdClientMessage * | unsolmsg | ||
) | [private, virtual] |
Implements XrdClientAbsUnsolMsgHandler.
References fLogVec, fMutex, GetPhyConnection(), XrdClientVector< T >::GetSize(), kUNSOL_CONTINUE, XrdSysMutex::Lock(), and XrdSysMutex::UnLock().
XrdClientMessage * XrdClientConnectionMgr::ReadMsg | ( | int | LogConnectionID | ) |
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().
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().
Referenced by Connect().
Referenced by BootUp(), and ShutDown().
int XrdClientConnectionMgr::fLastLogIdUsed [private] |
Referenced by Connect(), Disconnect(), GetConnection(), ProcessUnsolicitedMsg(), and ShutDown().
XrdSysRecMutex XrdClientConnectionMgr::fMutex [private] |
Referenced by Connect(), Disconnect(), GarbageCollect(), GetConnection(), ProcessUnsolicitedMsg(), and ShutDown().
Referenced by Connect(), GarbageCollect(), GetPhyConnection(), and ShutDown().
Referenced by Connect(), DisconnectElapsedPhyConn(), GarbageCollect(), and ShutDown().
XrdClientSid* XrdClientConnectionMgr::fSidManager [private] |
Referenced by BootUp(), Connect(), ShutDown(), and SidManager().