1 #ifndef _XrdClientPhyConnection
2 #define _XrdClientPhyConnection
42 #include "XrdClient/XrdClientUnsolMsg.hh"
44 #include "XrdClient/XrdClientUrlInfo.hh"
45 #include "XrdSys/XrdSysPthread.hh"
46 #include "XrdSys/XrdSysSemWait.hh"
66 class XrdClientThread;
116 bool Connect(XrdClientUrlInfo RemoteHost,
bool isUnix = 0);
127 bool Connect( XrdClientUrlInfo RemoteHost,
bool isUnix ,
int fd );
134 int substreamid = 0);
155 return ( (
fServer.Host == addr) ||
169 int ReadRaw(
void *
buffer,
int BufferLength,
int substreamid = -1,
170 int *usedsubstreamid = 0);
173 bool ReConnect(XrdClientUrlInfo RemoteHost);
179 int WriteRaw(
const void *
buffer,
int BufferLength,
int substreamid = 0);
virtual void RestartSelectOnSubstream(Sockid)
void RestartSelectOnSubstream(int substreamid)
virtual void PauseSelectOnSubstream(Sockid)
virtual void BanSockDescr(int sockdescr, int sockid)
bool IsAddress(const XrdOucString &addr)
void SetLogged(ELoginState status)
virtual void UnBanSockDescr(Sockdescr)
virtual Sockid GetSockIdHint(int)
int WipeStreamid(int streamid)
~XrdClientPhyConnection()
virtual int RemoveParallelSock(Sockid)
int TryConnectParallelStream(int port, int windowsz, int sockid)
XrdClientPhyConnection(XrdClientAbsUnsolMsgHandler *h, XrdClientSid *sid)
XrdClientInputBuffer fMsgQ
XrdSecProtocol * fSecProtocol
int EstablishPendingParallelStream(int tmpid, int newid)
XrdClientPhyConnLocker(XrdClientPhyConnection *phyc)
int ReadRaw(void *buffer, int BufferLength, int substreamid=-1, int *usedsubstreamid=0)
virtual int GetSockIdCount()
void CountLogConn(int d=1)
XrdSysRecMutex fMultireadMutex
bool Connect(XrdClientUrlInfo RemoteHost, bool isUnix=0)
ERemoteServerType fServerType
#define XrdSysMutexHelper
UnsolRespProcResult HandleUnsolicited(XrdClientMessage *m)
XrdSecProtocol * GetSecProtocol() const
ERemoteServerType DoHandShake(ServerInitHandShake &xbody, int substreamid=0)
bool ReConnect(XrdClientUrlInfo RemoteHost)
bool IsUser(const XrdOucString &usr)
~XrdClientPhyConnLocker()
virtual int EstablishParallelSock(Sockid, Sockid)
XrdClientSid * fSidManager
void SetInterrupt(int which=0)
XrdClientPhyConnection * phyconn
void SetSecProtocol(XrdSecProtocol *sp)
XrdClientMessage * BuildMessage(bool IgnoreTimeouts, bool Enqueue)
void RemoveParallelStream(int substreamid)
bool TestAndSetMStreamsGoing()
virtual void UnBanSockDescr(int sockdescr)
int GetSockIdHint(int reqsperstream)
int WriteRaw(const void *buffer, int BufferLength, int substreamid=0)
XrdClientThread * fReaderthreadhandler[64]
int GetReaderThreadsCnt()
virtual Sockdescr TryConnectParallelSock(int, int, Sockid &)
short GetLogConnCnt() const
virtual void BanSockDescr(Sockdescr, Sockid)
void PauseSelectOnSubstream(int substreamid)
XrdClientMessage * ReadMessage(int streamid)