xrootd
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros
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 ( XrdClientAbsUnsolMsgHandler h,
XrdClientSid sid 
)
XrdClientPhyConnection::~XrdClientPhyConnection ( )

Member Function Documentation

virtual void XrdClientPhyConnection::BanSockDescr ( int  sockdescr,
int  sockid 
)
inlinevirtual
XrdClientMessage* XrdClientPhyConnection::BuildMessage ( bool  IgnoreTimeouts,
bool  Enqueue 
)
bool XrdClientPhyConnection::CheckAutoTerm ( )
bool XrdClientPhyConnection::Connect ( XrdClientUrlInfo  RemoteHost,
bool  isUnix = 0 
)
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
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)
inlinevirtual
void XrdClientPhyConnection::UnlockChannel ( )
int XrdClientPhyConnection::WipeStreamid ( int  streamid)
inline
int XrdClientPhyConnection::WriteRaw ( const void *  buffer,
int  BufferLength,
int  substreamid = 0 
)

Member Data Documentation

time_t XrdClientPhyConnection::fLastUseTimestamp
private
short XrdClientPhyConnection::fLogConnCnt
private

Referenced by GetLogConnCnt().

enum ELoginState XrdClientPhyConnection::fLogged
private

Referenced by SetLogged().

XrdClientInputBuffer XrdClientPhyConnection::fMsgQ
private

Referenced by WipeStreamid().

bool XrdClientPhyConnection::fMStreamsGoing
private
XrdSysRecMutex XrdClientPhyConnection::fMultireadMutex
private

Referenced by ReadLock(), and ReadUnLock().

XrdSysRecMutex XrdClientPhyConnection::fMutex
private

Referenced by GetReaderThreadsCnt().

XrdSysSemWait XrdClientPhyConnection::fReaderCV
private
XrdClientThread* XrdClientPhyConnection::fReaderthreadhandler[64]
private
int XrdClientPhyConnection::fReaderthreadrunning
private

Referenced by GetReaderThreadsCnt().

int XrdClientPhyConnection::fRequestTimeout
private
XrdSysRecMutex XrdClientPhyConnection::fRwMutex
private
XrdSecProtocol* XrdClientPhyConnection::fSecProtocol
private

Referenced by GetSecProtocol(), and SetSecProtocol().

XrdClientUrlInfo XrdClientPhyConnection::fServer
private

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

long XrdClientPhyConnection::fServerProto
ERemoteServerType XrdClientPhyConnection::fServerType
XrdClientSid* XrdClientPhyConnection::fSidManager
private
XrdClientSock* XrdClientPhyConnection::fSocket
private
long XrdClientPhyConnection::fTTLsec

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


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