xrootd
Public Member Functions | Public Attributes | Private Member Functions | Private Attributes | List of all members
XrdClientPhyConnection Class Reference

#include <XrdClientPhyConnection.hh>

Inheritance diagram for XrdClientPhyConnection:
Inheritance graph
[legend]
Collaboration diagram for XrdClientPhyConnection:
Collaboration graph
[legend]

Public Member Functions

 XrdClientPhyConnection (XrdClientAbsUnsolMsgHandler *h, XrdClientSid *sid)
 
 ~XrdClientPhyConnection ()
 
XrdClientMessageBuildMessage (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 ()
 
XrdSecProtocolGetSecProtocol () 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)
 
XrdClientMessageReadMessage (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 Member Functions inherited from XrdClientUnsolMsgSender
virtual ~XrdClientUnsolMsgSender ()
 
UnsolRespProcResult SendUnsolicitedMsg (XrdClientUnsolMsgSender *sender, XrdClientMessage *unsolmsg)
 
 XrdClientUnsolMsgSender ()
 

Public Attributes

long fServerProto
 
ERemoteServerType fServerType
 
long fTTLsec
 
- Public Attributes inherited from XrdClientUnsolMsgSender
XrdClientAbsUnsolMsgHandlerUnsolicitedMsgHandler
 

Private Member Functions

UnsolRespProcResult HandleUnsolicited (XrdClientMessage *m)
 

Private Attributes

time_t fLastUseTimestamp
 
enum ELoginState fLogged
 
XrdSecProtocolfSecProtocol
 
XrdClientInputBuffer fMsgQ
 
int fRequestTimeout
 
bool fMStreamsGoing
 
XrdSysRecMutex fRwMutex
 
XrdSysRecMutex fMutex
 
XrdSysRecMutex fMultireadMutex
 
XrdClientThreadfReaderthreadhandler [64]
 
int fReaderthreadrunning
 
XrdClientUrlInfo fServer
 
XrdClientSockfSocket
 
XrdSysSemWait fReaderCV
 
short fLogConnCnt
 
XrdClientSidfSidManager
 

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

◆ BuildMessage()

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

◆ CheckAutoTerm()

bool XrdClientPhyConnection::CheckAutoTerm ( )

◆ Connect() [1/2]

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

◆ Connect() [2/2]

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

Connect to a remote location

Parameters
RemoteHostaddress descriptor
isUnixtrue if the address points to a Unix socket
fda descriptor pointing to a connected socket if the subroutine is supposed to reuse an existing connection, -1 otherwise

◆ 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

◆ ExpiredTTL()

bool XrdClientPhyConnection::ExpiredTTL ( )

◆ GetLogConnCnt()

short XrdClientPhyConnection::GetLogConnCnt ( ) const
inline

References fLogConnCnt.

◆ GetReaderThreadsCnt()

int XrdClientPhyConnection::GetReaderThreadsCnt ( )
inline

References fMutex, and fReaderthreadrunning.

◆ GetSecProtocol()

XrdSecProtocol* XrdClientPhyConnection::GetSecProtocol ( ) const
inline

References fSecProtocol.

◆ GetSocket()

int XrdClientPhyConnection::GetSocket ( )
inline

References XrdClientSock::fSocket, and fSocket.

◆ GetSockIdCount()

int XrdClientPhyConnection::GetSockIdCount ( )
inline

◆ GetSockIdHint()

int XrdClientPhyConnection::GetSockIdHint ( int  reqsperstream)
inline

◆ GetTTL()

long XrdClientPhyConnection::GetTTL ( )
inline

References fTTLsec.

◆ HandleUnsolicited()

UnsolRespProcResult XrdClientPhyConnection::HandleUnsolicited ( XrdClientMessage m)
private

◆ IsAddress()

bool XrdClientPhyConnection::IsAddress ( const XrdOucString addr)
inline

◆ IsLogged()

ELoginState XrdClientPhyConnection::IsLogged ( )

◆ IsPort()

bool XrdClientPhyConnection::IsPort ( int  port)
inline

References fServer, and XrdClientUrlInfo::Port.

◆ IsUser()

bool XrdClientPhyConnection::IsUser ( const XrdOucString usr)
inline

References fServer, and XrdClientUrlInfo::User.

◆ IsValid()

bool XrdClientPhyConnection::IsValid ( )

◆ LockChannel()

void XrdClientPhyConnection::LockChannel ( )

◆ PauseSelectOnSubstream()

void XrdClientPhyConnection::PauseSelectOnSubstream ( int  substreamid)
inline

◆ ReadLock()

void XrdClientPhyConnection::ReadLock ( )
inline

◆ 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

◆ ReConnect()

bool XrdClientPhyConnection::ReConnect ( XrdClientUrlInfo  RemoteHost)

◆ ReinitFDTable()

void XrdClientPhyConnection::ReinitFDTable ( )
inline

◆ RemoveParallelStream()

void XrdClientPhyConnection::RemoveParallelStream ( int  substreamid)
inline

◆ RestartSelectOnSubstream()

void XrdClientPhyConnection::RestartSelectOnSubstream ( int  substreamid)
inline

◆ SaveSocket()

int XrdClientPhyConnection::SaveSocket ( )
inline

◆ SetInterrupt()

void XrdClientPhyConnection::SetInterrupt ( )
inline

◆ SetLogged()

void XrdClientPhyConnection::SetLogged ( ELoginState  status)
inline

References fLogged.

◆ SetSecProtocol()

void XrdClientPhyConnection::SetSecProtocol ( XrdSecProtocol sp)
inline

References fSecProtocol.

◆ SetTTL()

void XrdClientPhyConnection::SetTTL ( long  ttl)
inline

References fTTLsec.

◆ 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

◆ UnBanSockDescr()

virtual void XrdClientPhyConnection::UnBanSockDescr ( int  sockdescr)
inlinevirtual

◆ UnlockChannel()

void XrdClientPhyConnection::UnlockChannel ( )

◆ WipeStreamid()

int XrdClientPhyConnection::WipeStreamid ( int  streamid)
inline

◆ WriteRaw()

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

Member Data Documentation

◆ fLastUseTimestamp

time_t XrdClientPhyConnection::fLastUseTimestamp
private

◆ fLogConnCnt

short XrdClientPhyConnection::fLogConnCnt
private

Referenced by GetLogConnCnt().

◆ fLogged

enum ELoginState XrdClientPhyConnection::fLogged
private

Referenced by SetLogged().

◆ fMsgQ

XrdClientInputBuffer XrdClientPhyConnection::fMsgQ
private

Referenced by WipeStreamid().

◆ fMStreamsGoing

bool XrdClientPhyConnection::fMStreamsGoing
private

◆ fMultireadMutex

XrdSysRecMutex XrdClientPhyConnection::fMultireadMutex
private

Referenced by ReadLock(), and ReadUnLock().

◆ fMutex

XrdSysRecMutex XrdClientPhyConnection::fMutex
private

Referenced by GetReaderThreadsCnt().

◆ fReaderCV

XrdSysSemWait XrdClientPhyConnection::fReaderCV
private

◆ fReaderthreadhandler

XrdClientThread* XrdClientPhyConnection::fReaderthreadhandler[64]
private

◆ fReaderthreadrunning

int XrdClientPhyConnection::fReaderthreadrunning
private

Referenced by GetReaderThreadsCnt().

◆ fRequestTimeout

int XrdClientPhyConnection::fRequestTimeout
private

◆ fRwMutex

XrdSysRecMutex XrdClientPhyConnection::fRwMutex
private

◆ fSecProtocol

XrdSecProtocol* XrdClientPhyConnection::fSecProtocol
private

Referenced by GetSecProtocol(), and SetSecProtocol().

◆ fServer

XrdClientUrlInfo XrdClientPhyConnection::fServer
private

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

◆ fServerProto

long XrdClientPhyConnection::fServerProto

◆ fServerType

ERemoteServerType XrdClientPhyConnection::fServerType

◆ fSidManager

XrdClientSid* XrdClientPhyConnection::fSidManager
private

◆ fSocket

XrdClientSock* XrdClientPhyConnection::fSocket
private

◆ fTTLsec

long XrdClientPhyConnection::fTTLsec

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


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