XrdClientPhyConnection Class Reference
#include <XrdClientPhyConnection.hh>
List of all members.
Public Member Functions |
| XrdClientPhyConnection (XrdClientAbsUnsolMsgHandler *h, XrdClientSid *sid) |
| ~XrdClientPhyConnection () |
XrdClientMessage * | BuildMessage (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 () |
XrdSecProtocol * | GetSecProtocol () 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) |
XrdClientMessage * | ReadMessage (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 |
XrdSecProtocol * | fSecProtocol |
XrdClientInputBuffer | fMsgQ |
int | fRequestTimeout |
bool | fMStreamsGoing |
XrdSysRecMutex | fRwMutex |
XrdSysRecMutex | fMutex |
XrdSysRecMutex | fMultireadMutex |
XrdClientThread * | fReaderthreadhandler [64] |
int | fReaderthreadrunning |
XrdClientUrlInfo | fServer |
XrdClientSock * | fSocket |
XrdSysSemWait | fReaderCV |
short | fLogConnCnt |
XrdClientSid * | fSidManager |
Constructor & Destructor Documentation
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 |
( |
|
) |
|
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] |
bool XrdClientPhyConnection::IsAddress |
( |
const XrdOucString & |
addr |
) |
[inline] |
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] |
int XrdClientPhyConnection::ReadRaw |
( |
void * |
buffer, |
|
|
int |
BufferLength, |
|
|
int |
substreamid = -1 , |
|
|
int * |
usedsubstreamid = 0 | |
|
) |
| | |
void XrdClientPhyConnection::ReadUnLock |
( |
|
) |
[inline] |
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
Referenced by BanSockDescr(), EstablishPendingParallelStream(), GetSocket(), GetSockIdCount(), GetSockIdHint(), PauseSelectOnSubstream(), ReinitFDTable(), RemoveParallelStream(), RestartSelectOnSubstream(), SaveSocket(), SetInterrupt(), TryConnectParallelStream(), and UnBanSockDescr().
The documentation for this class was generated from the following file: