XrdClientPhyConnection Class Reference

#include <XrdClientPhyConnection.hh>

Inheritance diagram for XrdClientPhyConnection:

[legend]Collaboration diagram for XrdClientPhyConnection:

[legend]List of all members.

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)
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
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

---

Constructor & Destructor Documentation

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

XrdClientPhyConnection::~XrdClientPhyConnection (   )

---

Member Function Documentation

virtual void XrdClientPhyConnection::BanSockDescr (  int  sockdescr, int  sockid )  [inline, virtual]

XrdClientMessage * XrdClientPhyConnection::BuildMessage (  bool  IgnoreTimeouts, bool  Enqueue )

bool XrdClientPhyConnection::CheckAutoTerm (   )

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

Connect to a remote location Parameters: RemoteHost  address descriptor isUnix  true if the address points to a Unix socket fd  a descriptor pointing to a connected socket if the subroutine is supposed to reuse an existing connection, -1 otherwise

bool XrdClientPhyConnection::Connect (  XrdClientUrlInfo  RemoteHost, bool  isUnix = 0 )

void XrdClientPhyConnection::CountLogConn (  int  d = 1  )

void XrdClientPhyConnection::Disconnect (   )

ERemoteServerType XrdClientPhyConnection::DoHandShake (  ServerInitHandShake &  xbody, int  substreamid = 0 )

int XrdClientPhyConnection::EstablishPendingParallelStream (  int  tmpid, int  newid )  [inline]

bool XrdClientPhyConnection::ExpiredTTL (   )

short XrdClientPhyConnection::GetLogConnCnt (   )  const [inline]

int XrdClientPhyConnection::GetReaderThreadsCnt (   )  [inline]

XrdSecProtocol* XrdClientPhyConnection::GetSecProtocol (   )  const [inline]

int XrdClientPhyConnection::GetSocket (   )  [inline]

int XrdClientPhyConnection::GetSockIdCount (   )  [inline]

int XrdClientPhyConnection::GetSockIdHint (  int  reqsperstream  )  [inline]

long XrdClientPhyConnection::GetTTL (   )  [inline]

UnsolRespProcResult XrdClientPhyConnection::HandleUnsolicited (  XrdClientMessage *  m  )  [private]

bool XrdClientPhyConnection::IsAddress (  const XrdOucString &  addr  )  [inline]

ELoginState XrdClientPhyConnection::IsLogged (   )

bool XrdClientPhyConnection::IsPort (  int  port  )  [inline]

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

bool XrdClientPhyConnection::IsValid (   )

void XrdClientPhyConnection::LockChannel (   )

void XrdClientPhyConnection::PauseSelectOnSubstream (  int  substreamid  )  [inline]

void XrdClientPhyConnection::ReadLock (   )  [inline]

XrdClientMessage * XrdClientPhyConnection::ReadMessage (  int  streamid  )

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

void XrdClientPhyConnection::ReadUnLock (   )  [inline]

bool XrdClientPhyConnection::ReConnect (  XrdClientUrlInfo  RemoteHost  )

void XrdClientPhyConnection::ReinitFDTable (   )  [inline]

void XrdClientPhyConnection::RemoveParallelStream (  int  substreamid  )  [inline]

void XrdClientPhyConnection::RestartSelectOnSubstream (  int  substreamid  )  [inline]

int XrdClientPhyConnection::SaveSocket (   )  [inline]

void XrdClientPhyConnection::SetInterrupt (   )  [inline]

void XrdClientPhyConnection::SetLogged (  ELoginState  status  )  [inline]

void XrdClientPhyConnection::SetSecProtocol (  XrdSecProtocol *  sp  )  [inline]

void XrdClientPhyConnection::SetTTL (  long  ttl  )  [inline]

void XrdClientPhyConnection::StartedReader (   )

void XrdClientPhyConnection::StartReader (   )

bool XrdClientPhyConnection::TestAndSetMStreamsGoing (   )

void XrdClientPhyConnection::Touch (   )

int XrdClientPhyConnection::TryConnectParallelStream (  int  port, int  windowsz, int  sockid )  [inline]

virtual void XrdClientPhyConnection::UnBanSockDescr (  int  sockdescr  )  [inline, virtual]

void XrdClientPhyConnection::UnlockChannel (   )

int XrdClientPhyConnection::WipeStreamid (  int  streamid  )  [inline]

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

---

Member Data Documentation

time_t XrdClientPhyConnection::fLastUseTimestamp [private]

short XrdClientPhyConnection::fLogConnCnt [private]

XrdClientInputBuffer XrdClientPhyConnection::fMsgQ [private]

bool XrdClientPhyConnection::fMStreamsGoing [private]

XrdSysRecMutex XrdClientPhyConnection::fMultireadMutex [private]

XrdSysRecMutex XrdClientPhyConnection::fMutex [private]

XrdSysSemWait XrdClientPhyConnection::fReaderCV [private]

XrdClientThread* XrdClientPhyConnection::fReaderthreadhandler[64] [private]

int XrdClientPhyConnection::fReaderthreadrunning [private]

int XrdClientPhyConnection::fRequestTimeout [private]

XrdSysRecMutex XrdClientPhyConnection::fRwMutex [private]

XrdSecProtocol* XrdClientPhyConnection::fSecProtocol [private]

XrdClientUrlInfo XrdClientPhyConnection::fServer [private]

long XrdClientPhyConnection::fServerProto

ERemoteServerType XrdClientPhyConnection::fServerType

XrdClientSid* XrdClientPhyConnection::fSidManager [private]

XrdClientSock* XrdClientPhyConnection::fSocket [private]

long XrdClientPhyConnection::fTTLsec

---

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

• XrdClientPhyConnection.hh
• XrdClientPhyConnection.cc

---