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

---

Constructor & Destructor Documentation

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

XrdClientPhyConnection::~XrdClientPhyConnection

(

)

---

Member Function Documentation

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

References XrdClientSock::BanSockDescr(), and fSocket.

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]

References XrdClientSock::EstablishParallelSock(), and fSocket.

bool XrdClientPhyConnection::ExpiredTTL

(

)

short XrdClientPhyConnection::GetLogConnCnt

(

)

const [inline]

References fLogConnCnt.

int XrdClientPhyConnection::GetReaderThreadsCnt

(

)

[inline]

References fMutex, and fReaderthreadrunning.

XrdSecProtocol* XrdClientPhyConnection::GetSecProtocol

(

)

const [inline]

References fSecProtocol.

int XrdClientPhyConnection::GetSocket

(

)

[inline]

References XrdClientSock::fSocket, and fSocket.

int XrdClientPhyConnection::GetSockIdCount

(

)

[inline]

References fSocket, and XrdClientSock::GetSockIdCount().

int XrdClientPhyConnection::GetSockIdHint

(

int

reqsperstream

)

[inline]

References fSocket, and XrdClientSock::GetSockIdHint().

long XrdClientPhyConnection::GetTTL

(

)

[inline]

References fTTLsec.

UnsolRespProcResult XrdClientPhyConnection::HandleUnsolicited

(

XrdClientMessage *

m

)

[private]

bool XrdClientPhyConnection::IsAddress

(

const XrdOucString &

addr

)

[inline]

References fServer, XrdClientUrlInfo::Host, and XrdClientUrlInfo::HostAddr.

ELoginState XrdClientPhyConnection::IsLogged

(

)

bool XrdClientPhyConnection::IsPort

(

int

port

)

[inline]

References fServer, and XrdClientUrlInfo::Port.

bool XrdClientPhyConnection::IsUser

(

const XrdOucString &

usr

)

[inline]

References fServer, and XrdClientUrlInfo::User.

bool XrdClientPhyConnection::IsValid

(

)

void XrdClientPhyConnection::LockChannel

(

)

Referenced by XrdClientPhyConnLocker::XrdClientPhyConnLocker().

void XrdClientPhyConnection::PauseSelectOnSubstream

(

int

substreamid

)

[inline]

References fSocket, and XrdClientSock::PauseSelectOnSubstream().

void XrdClientPhyConnection::ReadLock

(

)

[inline]

References fMultireadMutex, and XrdSysMutex::Lock().

XrdClientMessage* XrdClientPhyConnection::ReadMessage

(

int

streamid

)

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

void XrdClientPhyConnection::ReadUnLock

(

)

[inline]

References fMultireadMutex, and XrdSysMutex::UnLock().

bool XrdClientPhyConnection::ReConnect

(

XrdClientUrlInfo

RemoteHost

)

void XrdClientPhyConnection::ReinitFDTable

(

)

[inline]

References fSocket, and XrdClientSock::ReinitFDTable().

void XrdClientPhyConnection::RemoveParallelStream

(

int

substreamid

)

[inline]

References fSocket, and XrdClientSock::RemoveParallelSock().

void XrdClientPhyConnection::RestartSelectOnSubstream

(

int

substreamid

)

[inline]

References fSocket, and XrdClientSock::RestartSelectOnSubstream().

int XrdClientPhyConnection::SaveSocket

(

)

[inline]

References fSocket, fTTLsec, and XrdClientSock::SaveSocket().

void XrdClientPhyConnection::SetInterrupt

(

)

[inline]

References fSocket, and XrdClientSock::SetInterrupt().

void XrdClientPhyConnection::SetLogged

(

ELoginState

status

)

[inline]

References fLogged.

void XrdClientPhyConnection::SetSecProtocol

(

XrdSecProtocol *

sp

)

[inline]

References fSecProtocol.

void XrdClientPhyConnection::SetTTL

(

long

ttl

)

[inline]

References fTTLsec.

void XrdClientPhyConnection::StartedReader

(

)

void XrdClientPhyConnection::StartReader

(

)

bool XrdClientPhyConnection::TestAndSetMStreamsGoing

(

)

void XrdClientPhyConnection::Touch

(

)

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

References fSocket, and XrdClientSock::TryConnectParallelSock().

virtual void XrdClientPhyConnection::UnBanSockDescr

(

int

sockdescr

)

[inline, virtual]

References fSocket, and XrdClientSock::UnBanSockDescr().

void XrdClientPhyConnection::UnlockChannel

(

)

Referenced by XrdClientPhyConnLocker::~XrdClientPhyConnLocker().

int XrdClientPhyConnection::WipeStreamid

(

int

streamid

)

[inline]

References fMsgQ, and XrdClientInputBuffer::WipeStreamid().

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

---

Member Data Documentation

time_t XrdClientPhyConnection::fLastUseTimestamp [private]

short XrdClientPhyConnection::fLogConnCnt [private]

Referenced by GetLogConnCnt().

enum ELoginState XrdClientPhyConnection::fLogged [private]

Referenced by SetLogged().

XrdClientInputBuffer XrdClientPhyConnection::fMsgQ [private]

Referenced by WipeStreamid().

bool XrdClientPhyConnection::fMStreamsGoing [private]

XrdSysRecMutex XrdClientPhyConnection::fMultireadMutex [private]

Referenced by ReadLock(), and ReadUnLock().

XrdSysRecMutex XrdClientPhyConnection::fMutex [private]

Referenced by GetReaderThreadsCnt().

XrdSysSemWait XrdClientPhyConnection::fReaderCV [private]

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

int XrdClientPhyConnection::fReaderthreadrunning [private]

Referenced by GetReaderThreadsCnt().

int XrdClientPhyConnection::fRequestTimeout [private]

XrdSysRecMutex XrdClientPhyConnection::fRwMutex [private]

XrdSecProtocol* XrdClientPhyConnection::fSecProtocol [private]

Referenced by GetSecProtocol(), and SetSecProtocol().

XrdClientUrlInfo XrdClientPhyConnection::fServer [private]

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

long XrdClientPhyConnection::fServerProto

ERemoteServerType XrdClientPhyConnection::fServerType

XrdClientSid* XrdClientPhyConnection::fSidManager [private]

XrdClientSock* XrdClientPhyConnection::fSocket [private]

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

long XrdClientPhyConnection::fTTLsec

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

---

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

• XrdClientPhyConnection.hh