#include <XrdClientPSock.hh>

Inheritance diagram for XrdClientPSock:

Collaboration diagram for XrdClientPSock:

[legend]

Public Member Functions
	XrdClientPSock (XrdClientUrlInfo host, int windowsize=0)

virtual	~XrdClientPSock ()

void	BanSockDescr (Sockdescr s, Sockid newid)

void	UnBanSockDescr (Sockdescr s)

virtual int	RecvRaw (void buffer, int length, Sockid substreamid=-1, Sockid usedsubstreamid=0)

virtual int	SendRaw (const void *buffer, int length, Sockid substreamid=0)

virtual void	TryConnect (bool isUnix=0)

virtual Sockdescr	TryConnectParallelSock (int port, int windowsz, Sockid &tmpid)

virtual int	EstablishParallelSock (Sockid tmpsockid, Sockid newsockid)

virtual void	Disconnect ()

virtual int	RemoveParallelSock (Sockid sockid)

virtual Sockid	GetSockIdHint (int reqsperstream)

virtual int	GetSockIdCount ()

virtual void	PauseSelectOnSubstream (Sockid substreamid)

virtual void	RestartSelectOnSubstream (Sockid substreamid)

Public Member Functions inherited from XrdClientSock
	XrdClientSock (XrdClientUrlInfo host, int windowsize=0, int fd=-1)

virtual	~XrdClientSock ()

virtual void	BanSockDescr (Sockdescr, Sockid)

virtual void	UnBanSockDescr (Sockdescr)

void	ReinitFDTable ()

virtual int	RecvRaw (void buffer, int length, Sockid substreamid=-1, Sockid usedsubstreamid=0)

virtual int	SendRaw (const void *buffer, int length, Sockid substreamid=0)

void	SetRequestTimeout (int timeout=-1)

virtual int	Socks4Handshake (Sockid sockid)

virtual void	TryConnect (bool isUnix=0)

virtual Sockdescr	TryConnectParallelSock (int, int, Sockid &)

virtual int	EstablishParallelSock (Sockid, Sockid)

virtual int	RemoveParallelSock (Sockid)

virtual Sockid	GetSockIdHint (int)

virtual void	Disconnect ()

bool	IsConnected ()

virtual int	GetSockIdCount ()

virtual void	PauseSelectOnSubstream (Sockid)

virtual void	RestartSelectOnSubstream (Sockid)

Protected Member Functions
virtual int	SaveSocket ()

Protected Member Functions inherited from XrdClientSock
virtual int	SaveSocket ()

void	SetInterrupt (int which=0)

int	TryConnect_low (bool isUnix=0, int altport=0, int windowsz=0)

virtual int	SendRaw_sock (const void *buffer, int length, Sockdescr sock)

Private Member Functions
Sockdescr	GetSock (Sockid id)

Sockdescr	GetMainSock ()

Sockid	GetSockId (Sockdescr sock)

Private Attributes
XrdSysRecMutex	fMutex

fdinfo	globalfdinfo

Sockid	lastsidhint

XrdClientVector< Sockid >	fSocketIdRepo

XrdOucRash< Sockid, Sockdescr >	fSocketPool

XrdOucRash< Sockdescr, Sockid >	fSocketNYHandshakedIdPool

XrdOucRash< Sockdescr, Sockid >	fSocketIdPool

Friends
class	XrdClientPhyConnection

Additional Inherited Members
Public Types inherited from XrdClientSock
typedef int	Sockid

typedef int	Sockdescr

Protected Attributes inherited from XrdClientSock
int	fRequestTimeout

XrdClientSockConnectParms	fHost

bool	fConnected

bool	fRDInterrupt

bool	fWRInterrupt

bool	fReinit_fd

Constructor & Destructor Documentation

◆ XrdClientPSock()

XrdClientPSock::XrdClientPSock	(	XrdClientUrlInfo	host,
		int	windowsize = `0`
	)

◆ ~XrdClientPSock()

virtual XrdClientPSock::~XrdClientPSock ( )

virtual

Member Function Documentation

◆ BanSockDescr()

void XrdClientPSock::BanSockDescr	(	Sockdescr	s,
		Sockid	newid
	)

inlinevirtual

Reimplemented from XrdClientSock.

References fMutex, fSocketNYHandshakedIdPool, and XrdOucRash< K, V >::Rep().

◆ Disconnect()

virtual void XrdClientPSock::Disconnect ( )

virtual

Reimplemented from XrdClientSock.

◆ EstablishParallelSock()

virtual int XrdClientPSock::EstablishParallelSock	(	Sockid	tmpsockid,
		Sockid	newsockid
	)

virtual

Reimplemented from XrdClientSock.

◆ GetMainSock()

Sockdescr XrdClientPSock::GetMainSock ( )

inlineprivate

References GetSock().

◆ GetSock()

Sockdescr XrdClientPSock::GetSock ( Sockid id )

inlineprivate

References XrdOucRash< K, V >::Find(), fMutex, and fSocketPool.

Referenced by GetMainSock().

◆ GetSockId()

Sockid XrdClientPSock::GetSockId ( Sockdescr sock )

inlineprivate

References XrdOucRash< K, V >::Find(), fMutex, and fSocketIdPool.

◆ GetSockIdCount()

virtual int XrdClientPSock::GetSockIdCount ( )

inlinevirtual

Reimplemented from XrdClientSock.

References fMutex, fSocketPool, and XrdOucRash< K, V >::Num().

◆ GetSockIdHint()

virtual Sockid XrdClientPSock::GetSockIdHint ( int reqsperstream )

virtual

Reimplemented from XrdClientSock.

◆ PauseSelectOnSubstream()

virtual void XrdClientPSock::PauseSelectOnSubstream ( Sockid substreamid )

virtual

Reimplemented from XrdClientSock.

◆ RecvRaw()

virtual int XrdClientPSock::RecvRaw	(	void *	buffer,
		int	length,
		Sockid	substreamid = `-1`,
		Sockid *	usedsubstreamid = `0`
	)

virtual

Reimplemented from XrdClientSock.

◆ RemoveParallelSock()

virtual int XrdClientPSock::RemoveParallelSock ( Sockid sockid )

virtual

Reimplemented from XrdClientSock.

◆ RestartSelectOnSubstream()

virtual void XrdClientPSock::RestartSelectOnSubstream ( Sockid substreamid )

virtual

Reimplemented from XrdClientSock.

◆ SaveSocket()

virtual int XrdClientPSock::SaveSocket ( )

inlineprotectedvirtual

Reimplemented from XrdClientSock.

References XrdOucRash< K, V >::Del(), XrdClientSock::fConnected, XrdOucRash< K, V >::Find(), fMutex, XrdClientSock::fRDInterrupt, fSocketIdPool, fSocketPool, and XrdClientSock::fWRInterrupt.

◆ SendRaw()

virtual int XrdClientPSock::SendRaw	(	const void *	buffer,
		int	length,
		Sockid	substreamid = `0`
	)

virtual

Reimplemented from XrdClientSock.

◆ TryConnect()

virtual void XrdClientPSock::TryConnect ( bool isUnix = 0 )

virtual

Reimplemented from XrdClientSock.

◆ TryConnectParallelSock()

virtual Sockdescr XrdClientPSock::TryConnectParallelSock	(	int	port,
		int	windowsz,
		Sockid &	tmpid
	)

virtual

Reimplemented from XrdClientSock.

◆ UnBanSockDescr()

void XrdClientPSock::UnBanSockDescr ( Sockdescr s )

inlinevirtual

Reimplemented from XrdClientSock.

References XrdOucRash< K, V >::Del(), fMutex, and fSocketNYHandshakedIdPool.

Friends And Related Function Documentation

◆ XrdClientPhyConnection

friend class XrdClientPhyConnection

friend

Member Data Documentation

◆ fMutex

XrdSysRecMutex XrdClientPSock::fMutex

private

Referenced by BanSockDescr(), GetSock(), GetSockId(), GetSockIdCount(), SaveSocket(), and UnBanSockDescr().

◆ fSocketIdPool

XrdOucRash<Sockdescr, Sockid> XrdClientPSock::fSocketIdPool

private

Referenced by GetSockId(), and SaveSocket().

◆ fSocketIdRepo

XrdClientVector<Sockid> XrdClientPSock::fSocketIdRepo

private

◆ fSocketNYHandshakedIdPool

XrdOucRash<Sockdescr, Sockid> XrdClientPSock::fSocketNYHandshakedIdPool

private

Referenced by BanSockDescr(), and UnBanSockDescr().

◆ fSocketPool

XrdOucRash<Sockid, Sockdescr> XrdClientPSock::fSocketPool

private

Referenced by GetSock(), GetSockIdCount(), and SaveSocket().

◆ globalfdinfo

fdinfo XrdClientPSock::globalfdinfo

private

◆ lastsidhint

Sockid XrdClientPSock::lastsidhint

private

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

XrdClientPSock.hh

Public Member Functions

Protected Member Functions

Private Member Functions

Private Attributes

Friends

Additional Inherited Members

Constructor & Destructor Documentation

◆ XrdClientPSock()

◆ ~XrdClientPSock()

Member Function Documentation

◆ BanSockDescr()

◆ Disconnect()

◆ EstablishParallelSock()

◆ GetMainSock()

◆ GetSock()

◆ GetSockId()

◆ GetSockIdCount()

◆ GetSockIdHint()

◆ PauseSelectOnSubstream()

◆ RecvRaw()

◆ RemoveParallelSock()

◆ RestartSelectOnSubstream()

◆ SaveSocket()

◆ SendRaw()

◆ TryConnect()

◆ TryConnectParallelSock()

◆ UnBanSockDescr()

Friends And Related Function Documentation

◆ XrdClientPhyConnection

Member Data Documentation

◆ fMutex

◆ fSocketIdPool

◆ fSocketIdRepo

◆ fSocketNYHandshakedIdPool

◆ fSocketPool

◆ globalfdinfo

◆ lastsidhint