Logo ROOT  
Reference Guide
 
All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Modules Pages
Loading...
Searching...
No Matches
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)
 
XrdClientMessageBuildMessage (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 ()
 
XrdSecProtocolGetSecProtocol () 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 ()
 
XrdClientMessageReadMessage (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
XrdClientAbsUnsolMsgHandlerUnsolicitedMsgHandler
 

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
 
XrdClientThreadfReaderthreadhandler [64]
 
int fReaderthreadrunning
 
int fRequestTimeout
 
XrdSysRecMutex fRwMutex
 
XrdSecProtocolfSecProtocol
 
XrdClientUrlInfo fServer
 
XrdClientSidfSidManager
 
XrdClientSockfSocket
 

#include </github/home/ROOT-CI/src/proof/xrdinc/XrdClient/XrdClientPhyConnection.hh>

Inheritance diagram for XrdClientPhyConnection:
[legend]

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

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

  • proof/xrdinc/XrdClient/XrdClientPhyConnection.hh