Main Page | Namespace List | Class Hierarchy | Class List | Directories | File List | Namespace Members | Class Members | File Members

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

int XrdClientPhyConnection::GetReaderThreadsCnt  )  [inline]
 

XrdSecProtocol* XrdClientPhyConnection::GetSecProtocol  )  const [inline]
 

int XrdClientPhyConnection::GetSocket  )  [inline]
 

int XrdClientPhyConnection::GetSockIdCount  )  [inline]
 

int XrdClientPhyConnection::GetSockIdHint int  reqsperstream  )  [inline]
 

long XrdClientPhyConnection::GetTTL  )  [inline]
 

UnsolRespProcResult XrdClientPhyConnection::HandleUnsolicited XrdClientMessage m  )  [private]
 

bool XrdClientPhyConnection::IsAddress const XrdOucString addr  )  [inline]
 

ELoginState XrdClientPhyConnection::IsLogged  ) 
 

bool XrdClientPhyConnection::IsPort int  port  )  [inline]
 

bool XrdClientPhyConnection::IsUser const XrdOucString usr  )  [inline]
 

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]
 

void XrdClientPhyConnection::SetSecProtocol XrdSecProtocol sp  )  [inline]
 

void XrdClientPhyConnection::SetTTL long  ttl  )  [inline]
 

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

time_t XrdClientPhyConnection::fLastUseTimestamp [private]
 

short XrdClientPhyConnection::fLogConnCnt [private]
 

XrdClientInputBuffer XrdClientPhyConnection::fMsgQ [private]
 

bool XrdClientPhyConnection::fMStreamsGoing [private]
 

XrdSysRecMutex XrdClientPhyConnection::fMultireadMutex [private]
 

XrdSysRecMutex XrdClientPhyConnection::fMutex [private]
 

XrdSysSemWait XrdClientPhyConnection::fReaderCV [private]
 

XrdClientThread* XrdClientPhyConnection::fReaderthreadhandler[64] [private]
 

int XrdClientPhyConnection::fReaderthreadrunning [private]
 

int XrdClientPhyConnection::fRequestTimeout [private]
 

XrdSysRecMutex XrdClientPhyConnection::fRwMutex [private]
 

XrdSecProtocol* XrdClientPhyConnection::fSecProtocol [private]
 

XrdClientUrlInfo XrdClientPhyConnection::fServer [private]
 

long XrdClientPhyConnection::fServerProto
 

ERemoteServerType XrdClientPhyConnection::fServerType
 

XrdClientSid* XrdClientPhyConnection::fSidManager [private]
 

XrdClientSock* XrdClientPhyConnection::fSocket [private]
 

long XrdClientPhyConnection::fTTLsec
 


The documentation for this class was generated from the following files:
Generated on Sun Nov 6 13:36:55 2011 for xrootd by  doxygen 1.3.9.1