XrdClientPhyConnection Class Reference

Definition at line 69 of file XrdClientPhyConnection.hh.

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

Public Attributes
long	fServerProto
ERemoteServerType	fServerType
long	fTTLsec
Public Attributes inherited from XrdClientUnsolMsgSender
XrdClientAbsUnsolMsgHandler *	UnsolicitedMsgHandler

Private Member Functions
UnsolRespProcResult	HandleUnsolicited (XrdClientMessage *m)

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

#include </home/sftnight/build/workspace/root-makedoc-v624/rootspi/rdoc/src/v6-24-00-patches/proof/xrdinc/XrdClient/XrdClientPhyConnection.hh>

Inheritance diagram for XrdClientPhyConnection:

Constructor & Destructor Documentation

XrdClientPhyConnection()

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

~XrdClientPhyConnection()

XrdClientPhyConnection::~XrdClientPhyConnection

(

)

Member Function Documentation

BanSockDescr()

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

inlinevirtual

Definition at line 194 of file XrdClientPhyConnection.hh.

BuildMessage()

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

CheckAutoTerm()

bool XrdClientPhyConnection::CheckAutoTerm

(

)

Connect() [1/2]

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

Connect() [2/2]

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

CountLogConn()

void XrdClientPhyConnection::CountLogConn

(

int

d = 1

)

Disconnect()

void XrdClientPhyConnection::Disconnect

(

)

DoHandShake()

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

EstablishPendingParallelStream()

int XrdClientPhyConnection::EstablishPendingParallelStream ( int  tmpid, int  newid  )

inline

Definition at line 182 of file XrdClientPhyConnection.hh.

ExpiredTTL()

bool XrdClientPhyConnection::ExpiredTTL

(

)

GetLogConnCnt()

short XrdClientPhyConnection::GetLogConnCnt ( ) const

inline

Definition at line 137 of file XrdClientPhyConnection.hh.

GetReaderThreadsCnt()

int XrdClientPhyConnection::GetReaderThreadsCnt ( )

inline

Definition at line 138 of file XrdClientPhyConnection.hh.

GetSecProtocol()

XrdSecProtocol * XrdClientPhyConnection::GetSecProtocol ( ) const

inline

Definition at line 142 of file XrdClientPhyConnection.hh.

GetSocket()

int XrdClientPhyConnection::GetSocket ( )

inline

Definition at line 143 of file XrdClientPhyConnection.hh.

GetSockIdCount()

int XrdClientPhyConnection::GetSockIdCount ( )

inline

Definition at line 189 of file XrdClientPhyConnection.hh.

GetSockIdHint()

int XrdClientPhyConnection::GetSockIdHint ( int  reqsperstream )

inline

Definition at line 188 of file XrdClientPhyConnection.hh.

GetTTL()

long XrdClientPhyConnection::GetTTL ( )

inline

Definition at line 140 of file XrdClientPhyConnection.hh.

HandleUnsolicited()

UnsolRespProcResult XrdClientPhyConnection::HandleUnsolicited ( XrdClientMessage *  m )

private

IsAddress()

bool XrdClientPhyConnection::IsAddress ( const XrdOucString &  addr )

inline

Definition at line 154 of file XrdClientPhyConnection.hh.

IsLogged()

ELoginState XrdClientPhyConnection::IsLogged

(

)

IsPort()

bool XrdClientPhyConnection::IsPort ( int  port )

inline

Definition at line 161 of file XrdClientPhyConnection.hh.

IsUser()

bool XrdClientPhyConnection::IsUser ( const XrdOucString &  usr )

inline

Definition at line 162 of file XrdClientPhyConnection.hh.

IsValid()

bool XrdClientPhyConnection::IsValid

(

)

LockChannel()

void XrdClientPhyConnection::LockChannel

(

)

PauseSelectOnSubstream()

void XrdClientPhyConnection::PauseSelectOnSubstream ( int  substreamid )

inline

Definition at line 190 of file XrdClientPhyConnection.hh.

ReadLock()

void XrdClientPhyConnection::ReadLock ( )

inline

Definition at line 197 of file XrdClientPhyConnection.hh.

ReadMessage()

XrdClientMessage * XrdClientPhyConnection::ReadMessage

(

int

streamid

)

ReadRaw()

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

ReadUnLock()

void XrdClientPhyConnection::ReadUnLock ( )

inline

Definition at line 198 of file XrdClientPhyConnection.hh.

ReConnect()

bool XrdClientPhyConnection::ReConnect

(

XrdClientUrlInfo

RemoteHost

)

ReinitFDTable()

void XrdClientPhyConnection::ReinitFDTable ( )

inline

Definition at line 146 of file XrdClientPhyConnection.hh.

RemoveParallelStream()

void XrdClientPhyConnection::RemoveParallelStream ( int  substreamid )

inline

Definition at line 183 of file XrdClientPhyConnection.hh.

RestartSelectOnSubstream()

void XrdClientPhyConnection::RestartSelectOnSubstream ( int  substreamid )

inline

Definition at line 191 of file XrdClientPhyConnection.hh.

SaveSocket()

int XrdClientPhyConnection::SaveSocket ( )

inline

Definition at line 148 of file XrdClientPhyConnection.hh.

SetInterrupt()

void XrdClientPhyConnection::SetInterrupt ( )

inline

Definition at line 149 of file XrdClientPhyConnection.hh.

SetLogged()

void XrdClientPhyConnection::SetLogged ( ELoginState  status )

inline

Definition at line 174 of file XrdClientPhyConnection.hh.

SetSecProtocol()

void XrdClientPhyConnection::SetSecProtocol ( XrdSecProtocol *  sp )

inline

Definition at line 150 of file XrdClientPhyConnection.hh.

SetTTL()

void XrdClientPhyConnection::SetTTL ( long  ttl )

inline

Definition at line 175 of file XrdClientPhyConnection.hh.

StartedReader()

void XrdClientPhyConnection::StartedReader

(

)

StartReader()

void XrdClientPhyConnection::StartReader

(

)

TestAndSetMStreamsGoing()

bool XrdClientPhyConnection::TestAndSetMStreamsGoing

(

)

Touch()

void XrdClientPhyConnection::Touch

(

)

TryConnectParallelStream()

int XrdClientPhyConnection::TryConnectParallelStream ( int  port, int  windowsz, int  sockid  )

inline

Definition at line 181 of file XrdClientPhyConnection.hh.

UnBanSockDescr()

virtual void XrdClientPhyConnection::UnBanSockDescr ( int  sockdescr )

inlinevirtual

Definition at line 195 of file XrdClientPhyConnection.hh.

UnlockChannel()

void XrdClientPhyConnection::UnlockChannel

(

)

WipeStreamid()

int XrdClientPhyConnection::WipeStreamid ( int  streamid )

inline

Definition at line 200 of file XrdClientPhyConnection.hh.

WriteRaw()

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

Member Data Documentation

fLastUseTimestamp

time_t XrdClientPhyConnection::fLastUseTimestamp

private

Definition at line 72 of file XrdClientPhyConnection.hh.

fLogConnCnt

short XrdClientPhyConnection::fLogConnCnt

private

Definition at line 101 of file XrdClientPhyConnection.hh.

fLogged

enum ELoginState XrdClientPhyConnection::fLogged

private

Definition at line 73 of file XrdClientPhyConnection.hh.

fMsgQ

XrdClientInputBuffer XrdClientPhyConnection::fMsgQ

private

Definition at line 77 of file XrdClientPhyConnection.hh.

fMStreamsGoing

bool XrdClientPhyConnection::fMStreamsGoing

private

Definition at line 80 of file XrdClientPhyConnection.hh.

fMultireadMutex

XrdSysRecMutex XrdClientPhyConnection::fMultireadMutex

private

Definition at line 85 of file XrdClientPhyConnection.hh.

fMutex

XrdSysRecMutex XrdClientPhyConnection::fMutex

private

Definition at line 84 of file XrdClientPhyConnection.hh.

fReaderCV

XrdSysSemWait XrdClientPhyConnection::fReaderCV

private

Definition at line 99 of file XrdClientPhyConnection.hh.

fReaderthreadhandler

XrdClientThread* XrdClientPhyConnection::fReaderthreadhandler[64]

private

Definition at line 88 of file XrdClientPhyConnection.hh.

fReaderthreadrunning

int XrdClientPhyConnection::fReaderthreadrunning

private

Definition at line 91 of file XrdClientPhyConnection.hh.

fRequestTimeout

int XrdClientPhyConnection::fRequestTimeout

private

Definition at line 79 of file XrdClientPhyConnection.hh.

fRwMutex

XrdSysRecMutex XrdClientPhyConnection::fRwMutex

private

Definition at line 81 of file XrdClientPhyConnection.hh.

fSecProtocol

XrdSecProtocol* XrdClientPhyConnection::fSecProtocol

private

Definition at line 74 of file XrdClientPhyConnection.hh.

fServer

XrdClientUrlInfo XrdClientPhyConnection::fServer

private

Definition at line 93 of file XrdClientPhyConnection.hh.

fServerProto

long XrdClientPhyConnection::fServerProto

Definition at line 106 of file XrdClientPhyConnection.hh.

fServerType

ERemoteServerType XrdClientPhyConnection::fServerType

Definition at line 107 of file XrdClientPhyConnection.hh.

fSidManager

XrdClientSid* XrdClientPhyConnection::fSidManager

private

Definition at line 103 of file XrdClientPhyConnection.hh.

fSocket

XrdClientSock* XrdClientPhyConnection::fSocket

private

Definition at line 95 of file XrdClientPhyConnection.hh.

fTTLsec

long XrdClientPhyConnection::fTTLsec

Definition at line 108 of file XrdClientPhyConnection.hh.