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