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-v606/rootspi/rdoc/src/v6-06-00-patches/proof/xrdinc/XrdClient/XrdClientPhyConnection.hh>

Inheritance diagram for XrdClientPhyConnection:

Collaboration diagram for XrdClientPhyConnection:

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

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

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.

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.

XrdSysRecMutex XrdClientPhyConnection::fMutex

private

Definition at line 84 of file XrdClientPhyConnection.hh.

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

XrdClientUrlInfo XrdClientPhyConnection::fServer

private

Definition at line 93 of file XrdClientPhyConnection.hh.

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.

long XrdClientPhyConnection::fTTLsec

Definition at line 108 of file XrdClientPhyConnection.hh.

Referenced by GetTTL().

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

proof/xrdinc/XrdClient/XrdClientPhyConnection.hh

Public Member Functions

Public Attributes

Private Member Functions

Private Attributes

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation