#include <XrdClientPSock.hh>
Public Member Functions | |
XrdClientPSock (XrdClientUrlInfo host, int windowsize=0) | |
virtual | ~XrdClientPSock () |
void | BanSockDescr (Sockdescr s, Sockid newid) |
void | UnBanSockDescr (Sockdescr s) |
virtual int | RecvRaw (void *buffer, int length, Sockid substreamid=-1, Sockid *usedsubstreamid=0) |
virtual int | SendRaw (const void *buffer, int length, Sockid substreamid=0) |
virtual void | TryConnect (bool isUnix=0) |
virtual Sockdescr | TryConnectParallelSock (int port, int windowsz, Sockid &tmpid) |
virtual int | EstablishParallelSock (Sockid tmpsockid, Sockid newsockid) |
virtual void | Disconnect () |
virtual int | RemoveParallelSock (Sockid sockid) |
virtual Sockid | GetSockIdHint (int reqsperstream) |
virtual int | GetSockIdCount () |
virtual void | PauseSelectOnSubstream (Sockid substreamid) |
virtual void | RestartSelectOnSubstream (Sockid substreamid) |
Protected Member Functions | |
virtual int | SaveSocket () |
Private Member Functions | |
Sockdescr | GetSock (Sockid id) |
Sockdescr | GetMainSock () |
Sockid | GetSockId (Sockdescr sock) |
Private Attributes | |
XrdSysRecMutex | fMutex |
fdinfo | globalfdinfo |
Sockid | lastsidhint |
XrdClientVector< Sockid > | fSocketIdRepo |
XrdOucRash< Sockid, Sockdescr > | fSocketPool |
XrdOucRash< Sockdescr, Sockid > | fSocketNYHandshakedIdPool |
XrdOucRash< Sockdescr, Sockid > | fSocketIdPool |
Friends | |
class | XrdClientPhyConnection |
XrdClientPSock::XrdClientPSock | ( | XrdClientUrlInfo | host, | |
int | windowsize = 0 | |||
) |
virtual XrdClientPSock::~XrdClientPSock | ( | ) | [virtual] |
Reimplemented from XrdClientSock.
References fMutex, fSocketNYHandshakedIdPool, and XrdOucRash< K, V >::Rep().
virtual void XrdClientPSock::Disconnect | ( | ) | [virtual] |
Reimplemented from XrdClientSock.
Reimplemented from XrdClientSock.
References XrdOucRash< K, V >::Find(), fMutex, and fSocketPool.
Referenced by GetMainSock().
References XrdOucRash< K, V >::Find(), fMutex, and fSocketIdPool.
virtual int XrdClientPSock::GetSockIdCount | ( | ) | [inline, virtual] |
Reimplemented from XrdClientSock.
References fMutex, fSocketPool, and XrdOucRash< K, V >::Num().
virtual Sockid XrdClientPSock::GetSockIdHint | ( | int | reqsperstream | ) | [virtual] |
Reimplemented from XrdClientSock.
virtual void XrdClientPSock::PauseSelectOnSubstream | ( | Sockid | substreamid | ) | [virtual] |
Reimplemented from XrdClientSock.
virtual int XrdClientPSock::RecvRaw | ( | void * | buffer, | |
int | length, | |||
Sockid | substreamid = -1 , |
|||
Sockid * | usedsubstreamid = 0 | |||
) | [virtual] |
Reimplemented from XrdClientSock.
virtual int XrdClientPSock::RemoveParallelSock | ( | Sockid | sockid | ) | [virtual] |
Reimplemented from XrdClientSock.
virtual void XrdClientPSock::RestartSelectOnSubstream | ( | Sockid | substreamid | ) | [virtual] |
Reimplemented from XrdClientSock.
virtual int XrdClientPSock::SaveSocket | ( | ) | [inline, protected, virtual] |
Reimplemented from XrdClientSock.
References XrdOucRash< K, V >::Del(), XrdClientSock::fConnected, XrdOucRash< K, V >::Find(), fMutex, XrdClientSock::fRDInterrupt, fSocketIdPool, fSocketPool, and XrdClientSock::fWRInterrupt.
virtual int XrdClientPSock::SendRaw | ( | const void * | buffer, | |
int | length, | |||
Sockid | substreamid = 0 | |||
) | [virtual] |
Reimplemented from XrdClientSock.
virtual void XrdClientPSock::TryConnect | ( | bool | isUnix = 0 |
) | [virtual] |
Reimplemented from XrdClientSock.
virtual Sockdescr XrdClientPSock::TryConnectParallelSock | ( | int | port, | |
int | windowsz, | |||
Sockid & | tmpid | |||
) | [virtual] |
Reimplemented from XrdClientSock.
void XrdClientPSock::UnBanSockDescr | ( | Sockdescr | s | ) | [inline, virtual] |
Reimplemented from XrdClientSock.
References XrdOucRash< K, V >::Del(), fMutex, and fSocketNYHandshakedIdPool.
friend class XrdClientPhyConnection [friend] |
Reimplemented from XrdClientSock.
XrdSysRecMutex XrdClientPSock::fMutex [private] |
Referenced by BanSockDescr(), GetSock(), GetSockId(), GetSockIdCount(), SaveSocket(), and UnBanSockDescr().
XrdOucRash<Sockdescr, Sockid> XrdClientPSock::fSocketIdPool [private] |
Referenced by GetSockId(), and SaveSocket().
XrdClientVector<Sockid> XrdClientPSock::fSocketIdRepo [private] |
Referenced by BanSockDescr(), and UnBanSockDescr().
XrdOucRash<Sockid, Sockdescr> XrdClientPSock::fSocketPool [private] |
Referenced by GetSock(), GetSockIdCount(), and SaveSocket().
fdinfo XrdClientPSock::globalfdinfo [private] |
Sockid XrdClientPSock::lastsidhint [private] |