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