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