1 #ifndef _XrdClientPhyConnection
2 #define _XrdClientPhyConnection
134 int substreamid = 0);
169 int ReadRaw(
void *buffer,
int BufferLength,
int substreamid = -1,
170 int *usedsubstreamid = 0);
179 int WriteRaw(
const void *buffer,
int BufferLength,
int substreamid = 0);
Definition: XrdClientPhyConnection.hh:52
void ReadUnLock()
Definition: XrdClientPhyConnection.hh:198
virtual void RestartSelectOnSubstream(Sockid)
Definition: XrdClientSock.hh:149
int fRequestTimeout
Definition: XrdClientPhyConnection.hh:79
void RestartSelectOnSubstream(int substreamid)
Definition: XrdClientPhyConnection.hh:191
void SetInterrupt()
Definition: XrdClientPhyConnection.hh:149
virtual void PauseSelectOnSubstream(Sockid)
Definition: XrdClientSock.hh:148
Definition: XrdSysPthread.hh:239
virtual void BanSockDescr(int sockdescr, int sockid)
Definition: XrdClientPhyConnection.hh:194
void ReinitFDTable()
Definition: XrdClientPhyConnection.hh:146
int Port
Definition: XrdClientUrlInfo.hh:56
bool IsAddress(const XrdOucString &addr)
Definition: XrdClientPhyConnection.hh:154
void SetLogged(ELoginState status)
Definition: XrdClientPhyConnection.hh:174
short fLogConnCnt
Definition: XrdClientPhyConnection.hh:101
Definition: XrdClientPhyConnection.hh:61
virtual void UnBanSockDescr(Sockdescr)
Definition: XrdClientSock.hh:100
virtual Sockid GetSockIdHint(int)
Definition: XrdClientSock.hh:142
time_t fLastUseTimestamp
Definition: XrdClientPhyConnection.hh:72
int WipeStreamid(int streamid)
Definition: XrdClientPhyConnection.hh:200
~XrdClientPhyConnection()
Definition: XrdClientThread.hh:40
long fTTLsec
Definition: XrdClientPhyConnection.hh:108
Definition: XrdClientPhyConnection.hh:69
Definition: XrdSecInterface.hh:130
virtual int RemoveParallelSock(Sockid)
Definition: XrdClientSock.hh:139
int TryConnectParallelStream(int port, int windowsz, int sockid)
Definition: XrdClientPhyConnection.hh:181
XrdClientPhyConnection(XrdClientAbsUnsolMsgHandler *h, XrdClientSid *sid)
Definition: XrdClientUrlInfo.hh:50
long GetTTL()
Definition: XrdClientPhyConnection.hh:140
bool fMStreamsGoing
Definition: XrdClientPhyConnection.hh:80
int fReaderthreadrunning
Definition: XrdClientPhyConnection.hh:91
int fSocket
Definition: XrdClientSock.hh:59
XrdSysRecMutex fRwMutex
Definition: XrdClientPhyConnection.hh:81
XrdClientInputBuffer fMsgQ
Definition: XrdClientPhyConnection.hh:77
Definition: XrdClientUnsolMsg.hh:63
XrdSecProtocol * fSecProtocol
Definition: XrdClientPhyConnection.hh:74
int EstablishPendingParallelStream(int tmpid, int newid)
Definition: XrdClientPhyConnection.hh:182
ERemoteServerType
Definition: XrdClientPhyConnection.hh:56
int GetSocket()
Definition: XrdClientPhyConnection.hh:143
Definition: XrdClientSid.hh:57
XrdClientSock * fSocket
Definition: XrdClientPhyConnection.hh:95
Definition: XrdClientPhyConnection.hh:60
XrdClientPhyConnLocker(XrdClientPhyConnection *phyc)
Definition: XrdClientPhyConnection.hh:214
int ReadRaw(void *buffer, int BufferLength, int substreamid=-1, int *usedsubstreamid=0)
Definition: XrdClientUnsolMsg.hh:51
virtual int GetSockIdCount()
Definition: XrdClientSock.hh:147
Definition: XrdClientMessage.hh:49
void CountLogConn(int d=1)
XrdSysRecMutex fMultireadMutex
Definition: XrdClientPhyConnection.hh:85
enum ELoginState fLogged
Definition: XrdClientPhyConnection.hh:73
Definition: XrdClientPhyConnection.hh:59
bool Connect(XrdClientUrlInfo RemoteHost, bool isUnix=0)
ERemoteServerType fServerType
Definition: XrdClientPhyConnection.hh:107
virtual int SaveSocket()
Definition: XrdClientSock.hh:75
XrdClientUrlInfo fServer
Definition: XrdClientPhyConnection.hh:93
UnsolRespProcResult
Definition: XrdClientUnsolMsg.hh:43
XrdSysRecMutex fMutex
Definition: XrdClientPhyConnection.hh:84
void ReinitFDTable()
Definition: XrdClientSock.hh:103
int SaveSocket()
Definition: XrdClientPhyConnection.hh:148
Definition: XrdClientSock.hh:50
UnsolRespProcResult HandleUnsolicited(XrdClientMessage *m)
XrdSecProtocol * GetSecProtocol() const
Definition: XrdClientPhyConnection.hh:142
bool IsPort(int port)
Definition: XrdClientPhyConnection.hh:161
ERemoteServerType DoHandShake(ServerInitHandShake &xbody, int substreamid=0)
XrdOucString User
Definition: XrdClientUrlInfo.hh:54
bool ReConnect(XrdClientUrlInfo RemoteHost)
bool IsUser(const XrdOucString &usr)
Definition: XrdClientPhyConnection.hh:162
Definition: XrdClientPhyConnection.hh:58
void ReadLock()
Definition: XrdClientPhyConnection.hh:197
Definition: XrdSysSemWait.hh:34
~XrdClientPhyConnLocker()
Definition: XrdClientPhyConnection.hh:220
void Lock()
Definition: XrdSysPthread.hh:220
Definition: XrdClientPhyConnection.hh:53
virtual int EstablishParallelSock(Sockid, Sockid)
Definition: XrdClientSock.hh:137
ELoginState
Definition: XrdClientPhyConnection.hh:50
long fServerProto
Definition: XrdClientPhyConnection.hh:106
XrdClientSid * fSidManager
Definition: XrdClientPhyConnection.hh:103
void SetInterrupt(int which=0)
Definition: XrdClientSock.hh:78
XrdClientPhyConnection * phyconn
Definition: XrdClientPhyConnection.hh:211
void SetSecProtocol(XrdSecProtocol *sp)
Definition: XrdClientPhyConnection.hh:150
int GetSockIdCount()
Definition: XrdClientPhyConnection.hh:189
XrdClientMessage * BuildMessage(bool IgnoreTimeouts, bool Enqueue)
Definition: XrdClientPhyConnection.hh:62
void RemoveParallelStream(int substreamid)
Definition: XrdClientPhyConnection.hh:183
bool TestAndSetMStreamsGoing()
virtual void UnBanSockDescr(int sockdescr)
Definition: XrdClientPhyConnection.hh:195
XrdSysSemWait fReaderCV
Definition: XrdClientPhyConnection.hh:99
int GetSockIdHint(int reqsperstream)
Definition: XrdClientPhyConnection.hh:188
void SetTTL(long ttl)
Definition: XrdClientPhyConnection.hh:175
Definition: XProtocol.hh:858
int WriteRaw(const void *buffer, int BufferLength, int substreamid=0)
Definition: XrdClientPhyConnection.hh:209
void UnLock()
Definition: XrdSysPthread.hh:222
XrdClientThread * fReaderthreadhandler[64]
Definition: XrdClientPhyConnection.hh:88
Definition: XrdClientPhyConnection.hh:57
Definition: XrdClientPhyConnection.hh:51
int GetReaderThreadsCnt()
Definition: XrdClientPhyConnection.hh:138
Definition: XrdOucString.hh:254
virtual Sockdescr TryConnectParallelSock(int, int, Sockid &)
Definition: XrdClientSock.hh:132
Definition: XrdSysPthread.hh:260
short GetLogConnCnt() const
Definition: XrdClientPhyConnection.hh:137
virtual void BanSockDescr(Sockdescr, Sockid)
Definition: XrdClientSock.hh:99
XrdOucString Host
Definition: XrdClientUrlInfo.hh:55
void PauseSelectOnSubstream(int substreamid)
Definition: XrdClientPhyConnection.hh:190
XrdClientMessage * ReadMessage(int streamid)
XrdOucString HostAddr
Definition: XrdClientUrlInfo.hh:57