ROOT  6.07/01
Reference Guide
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Groups Pages
List of all members | Public Member Functions | Public Attributes | Private Member Functions | Private Attributes | List of all members
XrdClientPhyConnection Class Reference

Definition at line 69 of file XrdClientPhyConnection.hh.

Public Member Functions

 XrdClientPhyConnection (XrdClientAbsUnsolMsgHandler *h, XrdClientSid *sid)
 
 ~XrdClientPhyConnection ()
 
XrdClientMessage * BuildMessage (bool IgnoreTimeouts, bool Enqueue)
 
bool CheckAutoTerm ()
 
bool Connect (XrdClientUrlInfo RemoteHost, bool isUnix=0)
 
bool Connect (XrdClientUrlInfo RemoteHost, bool isUnix, int fd)
 Connect to a remote location. More...
 
void CountLogConn (int d=1)
 
void Disconnect ()
 
ERemoteServerType DoHandShake (ServerInitHandShake &xbody, int substreamid=0)
 
bool ExpiredTTL ()
 
short GetLogConnCnt () const
 
int GetReaderThreadsCnt ()
 
long GetTTL ()
 
XrdSecProtocol * GetSecProtocol () const
 
int GetSocket ()
 
void ReinitFDTable ()
 
int SaveSocket ()
 
void SetInterrupt ()
 
void SetSecProtocol (XrdSecProtocol *sp)
 
void StartedReader ()
 
bool IsAddress (const XrdOucString &addr)
 
ELoginState IsLogged ()
 
bool IsPort (int port)
 
bool IsUser (const XrdOucString &usr)
 
bool IsValid ()
 
void LockChannel ()
 
int ReadRaw (void *buffer, int BufferLength, int substreamid=-1, int *usedsubstreamid=0)
 
XrdClientMessage * ReadMessage (int streamid)
 
bool ReConnect (XrdClientUrlInfo RemoteHost)
 
void SetLogged (ELoginState status)
 
void SetTTL (long ttl)
 
void StartReader ()
 
void Touch ()
 
void UnlockChannel ()
 
int WriteRaw (const void *buffer, int BufferLength, int substreamid=0)
 
int TryConnectParallelStream (int port, int windowsz, int sockid)
 
int EstablishPendingParallelStream (int tmpid, int newid)
 
void RemoveParallelStream (int substreamid)
 
bool TestAndSetMStreamsGoing ()
 
int GetSockIdHint (int reqsperstream)
 
int GetSockIdCount ()
 
void PauseSelectOnSubstream (int substreamid)
 
void RestartSelectOnSubstream (int substreamid)
 
virtual void BanSockDescr (int sockdescr, int sockid)
 
virtual void UnBanSockDescr (int sockdescr)
 
void ReadLock ()
 
void ReadUnLock ()
 
int WipeStreamid (int streamid)
 

Public Attributes

long fServerProto
 
ERemoteServerType fServerType
 
long fTTLsec
 

Private Member Functions

UnsolRespProcResult HandleUnsolicited (XrdClientMessage *m)
 

Private Attributes

time_t fLastUseTimestamp
 
enum ELoginState fLogged
 
XrdSecProtocol * fSecProtocol
 
XrdClientInputBuffer fMsgQ
 
int fRequestTimeout
 
bool fMStreamsGoing
 
XrdSysRecMutex fRwMutex
 
XrdSysRecMutex fMutex
 
XrdSysRecMutex fMultireadMutex
 
XrdClientThread * fReaderthreadhandler [64]
 
int fReaderthreadrunning
 
XrdClientUrlInfo fServer
 
XrdClientSock * fSocket
 
XrdSysSemWait fReaderCV
 
short fLogConnCnt
 
XrdClientSid * fSidManager
 

#include </mnt/vdb/lsf/workspace/root-makedoc/rootspi/rdoc/src/master/proof/xrdinc/XrdClient/XrdClientPhyConnection.hh>

Inheritance diagram for XrdClientPhyConnection:
[legend]

Constructor & Destructor Documentation

XrdClientPhyConnection::XrdClientPhyConnection ( XrdClientAbsUnsolMsgHandler *  h,
XrdClientSid *  sid 
)
XrdClientPhyConnection::~XrdClientPhyConnection ( )

Member Function Documentation

virtual void XrdClientPhyConnection::BanSockDescr ( int  sockdescr,
int  sockid 
)
inlinevirtual

Definition at line 194 of file XrdClientPhyConnection.hh.

XrdClientMessage* XrdClientPhyConnection::BuildMessage ( bool  IgnoreTimeouts,
bool  Enqueue 
)
bool XrdClientPhyConnection::CheckAutoTerm ( )
bool XrdClientPhyConnection::Connect ( XrdClientUrlInfo  RemoteHost,
bool  isUnix = 0 
)

Referenced by XrdProofPhyConn::TryConnect().

bool XrdClientPhyConnection::Connect ( XrdClientUrlInfo  RemoteHost,
bool  isUnix,
int  fd 
)

Connect to a remote location.

Parameters
RemoteHostaddress descriptor
isUnixtrue if the address points to a Unix socket
fda descriptor pointing to a connected socket if the subroutine is supposed to reuse an existing connection, -1 otherwise
void XrdClientPhyConnection::CountLogConn ( int  d = 1)
void XrdClientPhyConnection::Disconnect ( )

Referenced by XrdProofPhyConn::Close().

ERemoteServerType XrdClientPhyConnection::DoHandShake ( ServerInitHandShake &  xbody,
int  substreamid = 0 
)
int XrdClientPhyConnection::EstablishPendingParallelStream ( int  tmpid,
int  newid 
)
inline

Definition at line 182 of file XrdClientPhyConnection.hh.

bool XrdClientPhyConnection::ExpiredTTL ( )
short XrdClientPhyConnection::GetLogConnCnt ( ) const
inline

Definition at line 137 of file XrdClientPhyConnection.hh.

int XrdClientPhyConnection::GetReaderThreadsCnt ( )
inline

Definition at line 138 of file XrdClientPhyConnection.hh.

XrdSecProtocol* XrdClientPhyConnection::GetSecProtocol ( ) const
inline

Definition at line 142 of file XrdClientPhyConnection.hh.

int XrdClientPhyConnection::GetSocket ( )
inline

Definition at line 143 of file XrdClientPhyConnection.hh.

Referenced by XrdProofConn::GetLowSocket().

int XrdClientPhyConnection::GetSockIdCount ( )
inline

Definition at line 189 of file XrdClientPhyConnection.hh.

int XrdClientPhyConnection::GetSockIdHint ( int  reqsperstream)
inline

Definition at line 188 of file XrdClientPhyConnection.hh.

long XrdClientPhyConnection::GetTTL ( )
inline

Definition at line 140 of file XrdClientPhyConnection.hh.

UnsolRespProcResult XrdClientPhyConnection::HandleUnsolicited ( XrdClientMessage *  m)
private
bool XrdClientPhyConnection::IsAddress ( const XrdOucString &  addr)
inline

Definition at line 154 of file XrdClientPhyConnection.hh.

ELoginState XrdClientPhyConnection::IsLogged ( )

Referenced by XrdProofConn::Connect(), XrdProofPhyConn::GetAccessToSrv(), and XrdProofConn::GetAccessToSrv().

bool XrdClientPhyConnection::IsPort ( int  port)
inline

Definition at line 161 of file XrdClientPhyConnection.hh.

bool XrdClientPhyConnection::IsUser ( const XrdOucString &  usr)
inline

Definition at line 162 of file XrdClientPhyConnection.hh.

bool XrdClientPhyConnection::IsValid ( )

Referenced by XrdProofConn::IsValid(), XrdProofConn::ReadRaw(), and XrdProofConn::WriteRaw().

void XrdClientPhyConnection::LockChannel ( )

Referenced by XrdClientPhyConnLocker::XrdClientPhyConnLocker().

void XrdClientPhyConnection::PauseSelectOnSubstream ( int  substreamid)
inline

Definition at line 190 of file XrdClientPhyConnection.hh.

void XrdClientPhyConnection::ReadLock ( )
inline

Definition at line 197 of file XrdClientPhyConnection.hh.

XrdClientMessage* XrdClientPhyConnection::ReadMessage ( int  streamid)

Referenced by XrdProofPhyConn::ReadMsg().

int XrdClientPhyConnection::ReadRaw ( void *  buffer,
int  BufferLength,
int  substreamid = -1,
int *  usedsubstreamid = 0 
)

Referenced by XrdProofPhyConn::ReadRaw(), and XrdProofConn::ReadRaw().

void XrdClientPhyConnection::ReadUnLock ( )
inline

Definition at line 198 of file XrdClientPhyConnection.hh.

bool XrdClientPhyConnection::ReConnect ( XrdClientUrlInfo  RemoteHost)
void XrdClientPhyConnection::ReinitFDTable ( )
inline

Definition at line 146 of file XrdClientPhyConnection.hh.

void XrdClientPhyConnection::RemoveParallelStream ( int  substreamid)
inline

Definition at line 183 of file XrdClientPhyConnection.hh.

void XrdClientPhyConnection::RestartSelectOnSubstream ( int  substreamid)
inline

Definition at line 191 of file XrdClientPhyConnection.hh.

int XrdClientPhyConnection::SaveSocket ( )
inline

Definition at line 148 of file XrdClientPhyConnection.hh.

void XrdClientPhyConnection::SetInterrupt ( )
inline

Definition at line 149 of file XrdClientPhyConnection.hh.

Referenced by XrdProofConn::SetInterrupt().

void XrdClientPhyConnection::SetLogged ( ELoginState  status)
inline

Definition at line 174 of file XrdClientPhyConnection.hh.

Referenced by XrdProofConn::Login().

void XrdClientPhyConnection::SetSecProtocol ( XrdSecProtocol *  sp)
inline

Definition at line 150 of file XrdClientPhyConnection.hh.

Referenced by XrdProofConn::Login().

void XrdClientPhyConnection::SetTTL ( long  ttl)
inline

Definition at line 175 of file XrdClientPhyConnection.hh.

void XrdClientPhyConnection::StartedReader ( )
void XrdClientPhyConnection::StartReader ( )

Referenced by XrdProofPhyConn::GetAccessToSrv(), and XrdProofConn::GetAccessToSrv().

bool XrdClientPhyConnection::TestAndSetMStreamsGoing ( )
void XrdClientPhyConnection::Touch ( )
int XrdClientPhyConnection::TryConnectParallelStream ( int  port,
int  windowsz,
int  sockid 
)
inline

Definition at line 181 of file XrdClientPhyConnection.hh.

virtual void XrdClientPhyConnection::UnBanSockDescr ( int  sockdescr)
inlinevirtual

Definition at line 195 of file XrdClientPhyConnection.hh.

void XrdClientPhyConnection::UnlockChannel ( )

Referenced by XrdClientPhyConnLocker::~XrdClientPhyConnLocker().

int XrdClientPhyConnection::WipeStreamid ( int  streamid)
inline

Definition at line 200 of file XrdClientPhyConnection.hh.

int XrdClientPhyConnection::WriteRaw ( const void *  buffer,
int  BufferLength,
int  substreamid = 0 
)

Referenced by XrdProofPhyConn::WriteRaw(), and XrdProofConn::WriteRaw().

Member Data Documentation

time_t XrdClientPhyConnection::fLastUseTimestamp
private

Definition at line 72 of file XrdClientPhyConnection.hh.

short XrdClientPhyConnection::fLogConnCnt
private

Definition at line 101 of file XrdClientPhyConnection.hh.

Referenced by GetLogConnCnt().

enum ELoginState XrdClientPhyConnection::fLogged
private

Definition at line 73 of file XrdClientPhyConnection.hh.

Referenced by SetLogged().

XrdClientInputBuffer XrdClientPhyConnection::fMsgQ
private

Definition at line 77 of file XrdClientPhyConnection.hh.

Referenced by WipeStreamid().

bool XrdClientPhyConnection::fMStreamsGoing
private

Definition at line 80 of file XrdClientPhyConnection.hh.

XrdSysRecMutex XrdClientPhyConnection::fMultireadMutex
private

Definition at line 85 of file XrdClientPhyConnection.hh.

Referenced by ReadLock(), and ReadUnLock().

XrdSysRecMutex XrdClientPhyConnection::fMutex
private

Definition at line 84 of file XrdClientPhyConnection.hh.

Referenced by GetReaderThreadsCnt().

XrdSysSemWait XrdClientPhyConnection::fReaderCV
private

Definition at line 99 of file XrdClientPhyConnection.hh.

XrdClientThread* XrdClientPhyConnection::fReaderthreadhandler[64]
private

Definition at line 88 of file XrdClientPhyConnection.hh.

int XrdClientPhyConnection::fReaderthreadrunning
private

Definition at line 91 of file XrdClientPhyConnection.hh.

Referenced by GetReaderThreadsCnt().

int XrdClientPhyConnection::fRequestTimeout
private

Definition at line 79 of file XrdClientPhyConnection.hh.

XrdSysRecMutex XrdClientPhyConnection::fRwMutex
private

Definition at line 81 of file XrdClientPhyConnection.hh.

XrdSecProtocol* XrdClientPhyConnection::fSecProtocol
private

Definition at line 74 of file XrdClientPhyConnection.hh.

Referenced by GetSecProtocol(), and SetSecProtocol().

XrdClientUrlInfo XrdClientPhyConnection::fServer
private

Definition at line 93 of file XrdClientPhyConnection.hh.

Referenced by IsAddress(), IsPort(), and IsUser().

long XrdClientPhyConnection::fServerProto

Definition at line 106 of file XrdClientPhyConnection.hh.

Referenced by XrdProofConn::DoHandShake(), and XrdProofConn::TryConnect().

ERemoteServerType XrdClientPhyConnection::fServerType

Definition at line 107 of file XrdClientPhyConnection.hh.

Referenced by XrdProofConn::DoHandShake(), XrdProofPhyConn::GetAccessToSrv(), and XrdProofConn::GetAccessToSrv().

XrdClientSid* XrdClientPhyConnection::fSidManager
private

Definition at line 103 of file XrdClientPhyConnection.hh.

XrdClientSock* XrdClientPhyConnection::fSocket
private

Definition at line 95 of file XrdClientPhyConnection.hh.

Referenced by BanSockDescr(), EstablishPendingParallelStream(), GetSocket(), GetSockIdCount(), GetSockIdHint(), PauseSelectOnSubstream(), ReinitFDTable(), RemoveParallelStream(), RestartSelectOnSubstream(), SaveSocket(), SetInterrupt(), TryConnectParallelStream(), and UnBanSockDescr().

long XrdClientPhyConnection::fTTLsec

Definition at line 108 of file XrdClientPhyConnection.hh.

Referenced by GetTTL(), SaveSocket(), and SetTTL().

Collaboration diagram for XrdClientPhyConnection:
[legend]
The documentation for this class was generated from the following file: