XrdClientPhyConnection Class Reference

#include <XrdClientPhyConnection.hh>

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

List of all members.

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 Attributes

long fServerProto
ERemoteServerType fServerType
long fTTLsec

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 ( XrdClientAbsUnsolMsgHandler h,
XrdClientSid sid 
)
XrdClientPhyConnection::~XrdClientPhyConnection (  ) 

Member Function Documentation

virtual void XrdClientPhyConnection::BanSockDescr ( int  sockdescr,
int  sockid 
) [inline, virtual]
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]
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]
int XrdClientPhyConnection::GetSockIdHint ( int  reqsperstream  )  [inline]
long XrdClientPhyConnection::GetTTL (  )  [inline]

References fTTLsec.

UnsolRespProcResult XrdClientPhyConnection::HandleUnsolicited ( XrdClientMessage m  )  [private]
bool XrdClientPhyConnection::IsAddress ( const XrdOucString addr  )  [inline]
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 (  ) 
void XrdClientPhyConnection::PauseSelectOnSubstream ( int  substreamid  )  [inline]
void XrdClientPhyConnection::ReadLock (  )  [inline]
XrdClientMessage* XrdClientPhyConnection::ReadMessage ( int  streamid  ) 
int XrdClientPhyConnection::ReadRaw ( void *  buffer,
int  BufferLength,
int  substreamid = -1,
int *  usedsubstreamid = 0 
)
void XrdClientPhyConnection::ReadUnLock (  )  [inline]
bool XrdClientPhyConnection::ReConnect ( XrdClientUrlInfo  RemoteHost  ) 
void XrdClientPhyConnection::ReinitFDTable (  )  [inline]
void XrdClientPhyConnection::RemoveParallelStream ( int  substreamid  )  [inline]
void XrdClientPhyConnection::RestartSelectOnSubstream ( int  substreamid  )  [inline]
int XrdClientPhyConnection::SaveSocket (  )  [inline]
void XrdClientPhyConnection::SetInterrupt (  )  [inline]
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]
virtual void XrdClientPhyConnection::UnBanSockDescr ( int  sockdescr  )  [inline, virtual]
void XrdClientPhyConnection::UnlockChannel (  ) 
int XrdClientPhyConnection::WipeStreamid ( int  streamid  )  [inline]
int XrdClientPhyConnection::WriteRaw ( const void *  buffer,
int  BufferLength,
int  substreamid = 0 
)

Member Data Documentation

Referenced by GetLogConnCnt().

Referenced by SetLogged().

Referenced by WipeStreamid().

Referenced by ReadLock(), and ReadUnLock().

Referenced by GetReaderThreadsCnt().

Referenced by GetReaderThreadsCnt().

Referenced by GetSecProtocol(), and SetSecProtocol().

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

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


The documentation for this class was generated from the following file:
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Defines

Generated on 16 Oct 2020 for xrootd by  doxygen 1.6.1