XrdClientConn Class Reference

#include <XrdClientConn.hh>

Collaboration diagram for XrdClientConn:

List of all members.

Classes
struct	SessionIDInfo

Public Types
enum	ESrvErrorHandlerRetval {   kSEHRReturnMsgToCaller = 0, kSEHRBreakLoop = 1, kSEHRContinue = 2, kSEHRReturnNoMsgToCaller = 3,   kSEHRRedirLimitReached = 4 }
enum	EThreeStateReadHandler { kTSRHReturnMex = 0, kTSRHReturnNullMex = 1, kTSRHContinue = 2 }

Public Member Functions
	XrdClientConn ()
virtual	~XrdClientConn ()
bool	CacheWillFit (long long bytes)
bool	CheckHostDomain (XrdOucString hostToCheck)
short	Connect (XrdClientUrlInfo Host2Conn, XrdClientAbsUnsolMsgHandler *unsolhandler)
void	Disconnect (bool ForcePhysicalDisc)
virtual bool	GetAccessToSrv ()
XReqErrorType	GoBackToRedirector ()
XrdOucString	GetClientHostDomain ()
long	GetDataFromCache (const void *buffer, long long begin_offs, long long end_offs, bool PerfCalc, XrdClientIntvList &missingblks, long &outstandingblks)
bool	SubmitDataToCache (XrdClientMessage *xmsg, long long begin_offs, long long end_offs)
bool	SubmitRawDataToCache (const void *buffer, long long begin_offs, long long end_offs)
void	SubmitPlaceholderToCache (long long begin_offs, long long end_offs)
void	RemoveAllDataFromCache (bool keepwriteblocks=true)
void	RemoveDataFromCache (long long begin_offs, long long end_offs, bool remove_overlapped=false)
void	RemovePlaceholdersFromCache ()
void	PrintCache ()
bool	GetCacheInfo (int &size, long long &bytessubmitted, long long &byteshit, long long &misscount, float &missrate, long long &readreqcnt, float &bytesusefulness)
void	SetCacheSize (int CacheSize)
void	SetCacheRmPolicy (int RmPolicy)
void	UnPinCacheBlk (long long begin_offs, long long end_offs)
int	GetLogConnID () const
ERemoteServerType	GetServerType () const
kXR_unt16	GetStreamID () const
XrdClientUrlInfo *	GetLBSUrl ()
XrdClientUrlInfo *	GetMetaUrl ()
XrdClientUrlInfo	GetCurrentUrl ()
XrdClientUrlInfo	GetRedirUrl ()
XErrorCode	GetOpenError () const
virtual XReqErrorType	GoToAnotherServer (XrdClientUrlInfo &newdest)
virtual XReqErrorType	GoToMetaManager ()
bool	IsConnected () const
bool	IsPhyConnConnected ()
void	ClearLastServerError ()
UnsolRespProcResult	ProcessAsynResp (XrdClientMessage *unsolmsg)
virtual bool	SendGenCommand (ClientRequest *req, const void *reqMoreData, void **answMoreDataAllocated, void *answMoreData, bool HasToAlloc, char *CmdName, int substreamid=0)
int	GetOpenSockFD () const
void	SetClientHostDomain (const char *src)
void	SetConnected (bool conn)
void	SetOpenError (XErrorCode err)
int	GetParallelStreamToUse (int reqsperstream)
int	GetParallelStreamCount ()
void	SetRedirHandler (XrdClientAbs *rh)
void	SetRequestedDestHost (char *newh, kXR_int32 port)
void	SetREQPauseState (kXR_int32 wsec)
void	SetREQDelayedConnectState (kXR_int32 wsec)
void	SetSID (kXR_char *sid)
void	SetUrl (XrdClientUrlInfo thisUrl)
XReqErrorType	WriteToServer_Async (ClientRequest *req, const void *reqMoreData, int substreamid=0)
void	GetSessionID (SessionIDInfo &sess)
long	GetServerProtocol ()
short	GetMaxRedirCnt () const
void	SetMaxRedirCnt (short mx)
short	GetRedirCnt () const
bool	DoWriteSoftCheckPoint ()
bool	DoWriteHardCheckPoint ()
void	UnPinCacheBlk ()
void	SetOpTimeLimit (int delta_secs)
bool	IsOpTimeLimitElapsed (time_t timenow)

Static Public Member Functions
static XrdClientPhyConnection *	GetPhyConn (int LogConnID)
static XrdClientConnectionMgr *	GetConnectionMgr ()
static void	DelSessionIDRepo ()

Public Attributes
int	fLastDataBytesRecv
int	fLastDataBytesSent
XErrorCode	fOpenError
XrdOucString	fRedirOpaque
struct ServerResponseHeader	LastServerResp
struct ServerResponseBody_Error	LastServerError
XrdOucString	fRedirCGI

Protected Member Functions
void	SetLogConnID (int cid)
void	SetStreamID (kXR_unt16 sid)

Protected Attributes
XrdClientAbsUnsolMsgHandler *	fUnsolMsgHandler
XrdClientUrlInfo	fUrl
XrdClientUrlInfo *	fLBSUrl
XrdClientUrlInfo	fREQUrl
short	fGlobalRedirCnt

Private Member Functions
bool	CheckErrorStatus (XrdClientMessage *, short &, char *)
void	CheckPort (int &port)
void	CheckREQPauseState ()
void	CheckREQConnectWaitState ()
bool	CheckResp (struct ServerResponseHeader *resp, const char *method)
XrdClientMessage *	ClientServerCmd (ClientRequest *req, const void *reqMoreData, void **answMoreDataAllocated, void *answMoreData, bool HasToAlloc, int substreamid=0)
XrdSecProtocol *	DoAuthentication (char *plist, int plsiz)
ERemoteServerType	DoHandShake (short log)
bool	DoLogin ()
bool	DomainMatcher (XrdOucString dom, XrdOucString domlist)
XrdOucString	GetDomainToMatch (XrdOucString hostname)
ESrvErrorHandlerRetval	HandleServerError (XReqErrorType &, XrdClientMessage *, ClientRequest *)
bool	MatchStreamid (struct ServerResponseHeader *ServerResponse)
bool	PanicClose ()
XrdOucString	ParseDomainFromHostname (XrdOucString hostname)
XrdClientMessage *	ReadPartialAnswer (XReqErrorType &, size_t &, ClientRequest *, bool, void **, EThreeStateReadHandler &)
XReqErrorType	WriteToServer (ClientRequest *req, const void *reqMoreData, short LogConnID, int substreamid=0)
bool	WaitResp (int secsmax)

Private Attributes
bool	fConnected
bool	fGettingAccessToSrv
time_t	fGlobalRedirLastUpdateTimestamp
int	fLogConnID
kXR_unt16	fPrimaryStreamid
short	fMaxGlobalRedirCnt
XrdClientReadCache *	fMainReadCache
time_t	fOpTimeLimit
XrdClientAbs *	fRedirHandler
XrdOucString	fRedirInternalToken
XrdSysCondVar *	fREQWaitResp
ServerResponseBody_Attn_asynresp *	fREQWaitRespData
time_t	fREQWaitTimeLimit
XrdSysCondVar *	fREQWait
time_t	fREQConnectWaitTimeLimit
XrdSysCondVar *	fREQConnectWait
long	fServerProto
ERemoteServerType	fServerType
SessionIDInfo	mySessionID
int	fOpenSockFD
XrdSysCondVar *	fWriteWaitAck
XrdClientVector< ClientRequest >	fWriteReqsToRetry
XrdClientUrlInfo *	fMetaUrl
bool	fLBSIsMeta

Static Private Attributes
static XrdOucString	fgClientHostDomain
static XrdSysMutex	fSessionIDRMutex
static XrdOucHash< SessionIDInfo >	fSessionIDRepo
static XrdClientConnectionMgr *	fgConnectionMgr = 0

---

Member Enumeration Documentation

enum XrdClientConn::ESrvErrorHandlerRetval

Enumerator:

kSEHRReturnMsgToCaller
kSEHRBreakLoop
kSEHRContinue
kSEHRReturnNoMsgToCaller
kSEHRRedirLimitReached

enum XrdClientConn::EThreeStateReadHandler

Enumerator:

kTSRHReturnMex
kTSRHReturnNullMex
kTSRHContinue

---

Constructor & Destructor Documentation

XrdClientConn::XrdClientConn

(

)

References XrdOucString::c_str(), XrdClientUrlInfo::Clear(), ClearLastServerError(), EnvGetLong, EnvGetString, EnvPutString, Error, fgClientHostDomain, fgConnectionMgr, fGlobalRedirCnt, fGlobalRedirLastUpdateTimestamp, fMaxGlobalRedirCnt, fOpenSockFD, fRedirHandler, fREQConnectWait, fREQUrl, fREQWait, fREQWaitResp, fServerType, fUnsolMsgHandler, fWriteWaitAck, GetDomainToMatch(), kSTNone, kXR_noResponsesYet, LastServerResp, NAME_CONNECTDOMAINALLOW_RE, NAME_CONNECTDOMAINDENY_RE, NAME_MAXREDIRECTCOUNT, NAME_REDIRDOMAINALLOW_RE, NAME_REDIRDOMAINDENY_RE, and ServerResponseHeader::status.

XrdClientConn::~XrdClientConn ( )

virtual

References DebugLevel, Disconnect(), FALSE, fLBSUrl, fMainReadCache, fREQConnectWait, fREQWait, fREQWaitResp, fWriteWaitAck, XrdClientDebug::kUSERDEBUG, and XrdClientReadCache::PrintPerfCounters().

---

Member Function Documentation

bool XrdClientConn::CacheWillFit ( long long  bytes )

inline

References FALSE, fMainReadCache, and XrdClientReadCache::WillFit().

Referenced by XrdClient::Read(), and XrdClient::ReadV().

bool XrdClientConn::CheckErrorStatus ( XrdClientMessage *  mex, short &  Retry, char *  CmdName  )

private

References XrdClientMessage::DataLen(), ServerResponseBody_Error::errmsg, ServerResponseBody_Error::errnum, Error, FALSE, fOpenError, fUrl, GetCurrentUrl(), XrdClientMessage::GetData(), XrdClientMessage::HeaderStatus(), XrdClientUrlInfo::Host, Info, ServerResponseBody_Wait::infomsg, XrdClientDebug::kNODEBUG, XrdClientDebug::kUSERDEBUG, kXR_error, kXR_maxReqRetry, kXR_redirect, kXR_wait, LastServerError, XrdClientUrlInfo::Port, ServerResponseBody_Wait::seconds, and TRUE.

Referenced by SendGenCommand().

bool XrdClientConn::CheckHostDomain

(

XrdOucString

hostToCheck

)

References XrdOucHash< T >::Add(), XrdOucString::c_str(), DomainMatcher(), EnvGetString, Error, FALSE, XrdOucHash< T >::Find(), GetDomainToMatch(), Info, XrdClientDebug::kHIDEBUG, XrdOucString::length(), NAME_REDIRDOMAINALLOW_RE, NAME_REDIRDOMAINDENY_RE, and TRUE.

Referenced by XrdClientAdmin::Connect(), HandleServerError(), and XrdClient::Open().

void XrdClientConn::CheckPort ( int &  port )

private

References Info, XrdClientDebug::kHIDEBUG, and XrdClientDebug::kNODEBUG.

Referenced by HandleServerError().

void XrdClientConn::CheckREQConnectWaitState ( )

private

References fREQConnectWait, fREQConnectWaitTimeLimit, fREQWaitTimeLimit, IsOpTimeLimitElapsed(), XrdSysCondVar::Lock(), XrdSysCondVar::UnLock(), XrdSysCondVar::Wait(), and xrdmin.

Referenced by Connect().

void XrdClientConn::CheckREQPauseState ( )

private

References fREQWait, fREQWaitTimeLimit, IsOpTimeLimitElapsed(), XrdSysCondVar::Lock(), XrdSysCondVar::UnLock(), XrdSysCondVar::Wait(), and xrdmin.

Referenced by SendGenCommand().

bool XrdClientConn::CheckResp ( struct ServerResponseHeader *  resp, const char *  method  )

private

References Error, FALSE, kXR_authmore, kXR_ok, kXR_redirect, MatchStreamid(), ServerResponseHeader::status, and TRUE.

Referenced by SendGenCommand().

void XrdClientConn::ClearLastServerError ( )

inline

References ServerResponseBody_Error::errnum, kXR_noErrorYet, and LastServerError.

Referenced by XrdClientAdmin::DirList(), and XrdClientConn().

XrdClientMessage * XrdClientConn::ClientServerCmd ( ClientRequest *  req, const void *  reqMoreData, void **  answMoreDataAllocated, void *  answMoreData, bool  HasToAlloc, int  substreamid = 0  )

private

References XrdOucString::c_str(), XrdClientMessage::DataLen(), ClientOpenRequest::dlen, ClientRequestHdr::dlen, ServerResponseHeader::dlen, XrdOucString::erase(), fGlobalRedirCnt, XrdClientMessage::fHdr, fLogConnID, fMainReadCache, fMaxGlobalRedirCnt, fRedirOpaque, ClientRequest::header, XrdClientMessage::HeaderStatus(), IsOpTimeLimitElapsed(), kOK, kTSRHReturnMex, kTSRHReturnNullMex, kXR_chmod, kXR_dirlist, kXR_locate, kXR_mkdir, kXR_mv, kXR_ok, kXR_oksofar, kXR_open, kXR_read, kXR_redirect, kXR_rm, kXR_rmdir, kXR_stat, kXR_truncate, XrdOucString::length(), ClientReadRequest::offset, ClientRequest::open, ClientRequest::read, ReadPartialAnswer(), ClientRequestHdr::requestid, SetSID(), ClientRequestHdr::streamid, XrdClientReadCache::SubmitXMessage(), and WriteToServer().

Referenced by SendGenCommand().

short XrdClientConn::Connect	(	XrdClientUrlInfo	Host2Conn,
		XrdClientAbsUnsolMsgHandler *	unsolhandler
	)

References CheckREQConnectWaitState(), ConnectionManager, Error, FALSE, fConnected, fLogConnID, fPrimaryStreamid, fUnsolMsgHandler, XrdClientUrlInfo::Host, XrdClientUrlInfo::HostAddr, Info, XrdClientDebug::kHIDEBUG, XrdClientUrlInfo::Port, and TRUE.

Referenced by XrdClientAdmin::Connect(), GoToAnotherServer(), and XrdClient::Open().

static void XrdClientConn::DelSessionIDRepo ( )

inlinestatic

References fSessionIDRepo, fSessionIDRMutex, XrdSysMutex::Lock(), XrdOucHash< T >::Purge(), and XrdSysMutex::UnLock().

Referenced by prepare().

void XrdClientConn::Disconnect

(

bool

ForcePhysicalDisc

)

References ConnectionManager, DebugLevel, FALSE, fConnected, fLogConnID, fMainReadCache, fPrimaryStreamid, fWriteReqsToRetry, XrdClientDebug::kDUMPDEBUG, and XrdClientReadCache::PrintCache().

Referenced by XrdClient::Close(), XrdClientAdmin::Connect(), XrdClientAdmin::DirList(), DoLogin(), GetAccessToSrv(), XrdClientAdmin::GetSpaceInfo(), GoBackToRedirector(), HandleServerError(), XrdClientAdmin::Locate(), XrdClient::Open(), ProcessAsynResp(), XrdClient::TryOpen(), and ~XrdClientConn().

XrdSecProtocol * XrdClientConn::DoAuthentication ( char *  plist, int  plsiz  )

private

References ClientRequest::auth, XrdSecBuffer::buffer, XrdOucString::c_str(), ClientAuthRequest::credtype, XrdSecProtocol::Delete(), ClientRequestHdr::dlen, ServerResponseHeader::dlen, XrdSecProtocol::Entity, ServerResponseBody_Error::errmsg, ServerResponseBody_Error::errnum, Error, fOpenError, fOpenSockFD, fUrl, XrdSecProtocol::getCredentials(), XrdOucErrInfo::getErrText(), XrdSysDNS::getHostAddr(), ClientRequest::header, XrdClientUrlInfo::Host, XrdClientUrlInfo::HostAddr, Info, XrdSysDNS::IPFormat(), XrdClientDebug::kHIDEBUG, XrdClientDebug::kUSERDEBUG, kXR_auth, kXR_authmore, kXR_error, kXR_NotAuthorized, LastServerError, LastServerResp, XrdOucString::length(), LT_MODULE_EXT, XrdClientUrlInfo::Port, XrdSecEntity::prot, XrdOucEnv::Put(), ClientRequestHdr::requestid, ClientAuthRequest::reserved, SafeDelete, SendGenCommand(), SetSID(), XrdSecBuffer::size, ServerResponseHeader::status, ClientRequestHdr::streamid, and TRUE.

Referenced by DoLogin().

ERemoteServerType XrdClientConn::DoHandShake ( short  log )

private

References ConnectionManager, XrdClientPhyConnection::DoHandShake(), fLBSIsMeta, fLBSUrl, fMetaUrl, XrdClientPhyConnection::fServerProto, fServerProto, XrdClientPhyConnection::fServerType, fUrl, XrdClientLogConnection::GetPhyConnection(), XrdClientUrlInfo::GetUrl(), Info, XrdClientPhyConnection::IsValid(), XrdClientDebug::kHIDEBUG, kSTBaseXrootd, kSTError, kSTMetaXrootd, and kSTNone.

Referenced by GetAccessToSrv().

bool XrdClientConn::DoLogin ( )

private

References XrdOucString::c_str(), ClientLoginRequest::capver, ConnectionManager, DebugLevel, Disconnect(), ClientRequestHdr::dlen, ServerResponseHeader::dlen, DoAuthentication(), emsg(), ClientRequest::endsess, EnvGetLong, ServerResponseBody_Error::errmsg, ServerResponseBody_Error::errnum, Error, FALSE, XrdOucHash< T >::Find(), fLogConnID, fOpenError, fOpenSockFD, fRedirInternalToken, fServerProto, fSessionIDRepo, fSessionIDRMutex, fUrl, XrdClientLogConnection::GetPhyConnection(), XrdClientPhyConnection::GetSocket(), ClientRequest::header, XrdClientUrlInfo::Host, XrdClientUrlInfo::HostAddr, XrdClientConn::SessionIDInfo::id, Info, XrdClientDebug::kHIDEBUG, kNo, kXR_endsess, kXR_login, kXR_NotAuthorized, kYes, LastServerError, LastServerResp, XrdOucString::length(), XrdSysMutex::Lock(), ClientRequest::login, mySessionID, NAME_DEBUG, ClientLoginRequest::pid, XrdClientUrlInfo::Port, XrdOucHash< T >::Rep(), ClientRequestHdr::requestid, SendGenCommand(), ClientEndsessRequest::sessid, XrdClientPhyConnection::SetLogged(), XrdClientPhyConnection::SetSecProtocol(), SetSID(), ClientRequestHdr::streamid, TRUE, XrdSysMutex::UnLock(), XrdClientUrlInfo::User, XrdOucUtils::UserName(), ClientLoginRequest::username, and XRD_CLIENT_CAPVER.

Referenced by GetAccessToSrv().

bool XrdClientConn::DomainMatcher ( XrdOucString  dom, XrdOucString  domlist  )

private

References XrdOucString::c_str(), FALSE, Info, XrdClientDebug::kDUMPDEBUG, XrdClientDebug::kHIDEBUG, XrdOucString::length(), XrdOucString::matches(), STR_NPOS, XrdOucString::tokenize(), and TRUE.

Referenced by CheckHostDomain().

bool XrdClientConn::DoWriteHardCheckPoint

(

)

References ConnectionManager, DoWriteSoftCheckPoint(), fPrimaryStreamid, fWriteWaitAck, and XrdSysCondVar::Wait().

Referenced by XrdClient::Close(), XrdClient::Sync(), and XrdClient::Write().

bool XrdClientConn::DoWriteSoftCheckPoint

(

)

References XrdClientVector< T >::Clear(), ConnectionManager, ClientWriteRequest::dlen, Error, XrdClientReadCache::FindBlk(), fMainReadCache, fPrimaryStreamid, fWriteReqsToRetry, XrdClientVector< T >::GetSize(), ClientWriteRequest::offset, ClientWriteRequest::pathid, SendGenCommand(), UnPinCacheBlk(), and ClientRequest::write.

Referenced by DoWriteHardCheckPoint(), and XrdClient::Write().

bool XrdClientConn::GetAccessToSrv ( )

virtual

References ConnectionManager, Disconnect(), DoHandShake(), DoLogin(), EnvGetLong, Error, FALSE, fGettingAccessToSrv, fLogConnID, fOpenSockFD, fServerType, fUrl, XrdClientLogConnection::GetPhyConnection(), XrdClientUrlInfo::Host, Info, XrdClientPhyConnection::IsLogged(), XrdClientPhyConnection::IsValid(), XrdClientDebug::kHIDEBUG, kNo, XrdClientDebug::kNODEBUG, kSTBaseXrootd, kSTDataXrootd, kSTError, kSTMetaXrootd, kSTNone, kSTRootd, NAME_DATASERVERCONN_TTL, NAME_KEEPSOCKOPENIFNOTXRD, NAME_LBSERVERCONN_TTL, XrdClientUrlInfo::Port, XrdClientPhyConnection::SaveSocket(), XrdClientPhyConnection::SetTTL(), XrdClientPhyConnection::StartReader(), and TRUE.

Referenced by XrdClientAdmin::Connect(), GoToAnotherServer(), and XrdClient::Open().

bool XrdClientConn::GetCacheInfo ( int &  size, long long &  bytessubmitted, long long &  byteshit, long long &  misscount, float &  missrate, long long &  readreqcnt, float &  bytesusefulness  )

inline

References fMainReadCache, and XrdClientReadCache::GetInfo().

Referenced by XrdClient::GetCacheInfo(), XrdClient::Read(), and XrdClient::UseCache().

XrdOucString XrdClientConn::GetClientHostDomain ( )

inline

References fgClientHostDomain.

static XrdClientConnectionMgr* XrdClientConn::GetConnectionMgr ( )

inlinestatic

References fgConnectionMgr.

XrdClientUrlInfo XrdClientConn::GetCurrentUrl ( )

inline

References fUrl.

Referenced by CheckErrorStatus(), XrdClientAbs::GetCurrentUrl(), XrdClientAdmin::Locate(), XrdClientAdmin::ProcessUnsolicitedMsg(), and XrdClient::TryOpen().

long XrdClientConn::GetDataFromCache	(	const void *	buffer,
		long long	begin_offs,
		long long	end_offs,
		bool	PerfCalc,
		XrdClientIntvList &	missingblks,
		long &	outstandingblks
	)

References FALSE, fMainReadCache, and XrdClientReadCache::GetDataIfPresent().

Referenced by XrdClient::Read().

XrdOucString XrdClientConn::GetDomainToMatch ( XrdOucString  hostname )

private

References XrdOucString::c_str(), XrdSysDNS::getHostName(), Info, XrdClientDebug::kHIDEBUG, XrdOucString::length(), and ParseDomainFromHostname().

Referenced by CheckHostDomain(), and XrdClientConn().

XrdClientUrlInfo* XrdClientConn::GetLBSUrl ( )

inline

References fLBSUrl.

Referenced by XrdClient::TryOpen().

int XrdClientConn::GetLogConnID ( ) const

inline

References fLogConnID.

Referenced by XrdClientMStream::AddParallelStream(), XrdClientMStream::BindPendingStream(), XrdClientAdmin::Connect(), XrdClientMStream::EstablishParallelStreams(), XrdClient::Open(), and XrdClientMStream::RemoveParallelStream().

short XrdClientConn::GetMaxRedirCnt ( ) const

inline

References fMaxGlobalRedirCnt.

Referenced by XrdClient::Open(), and XrdClient::TryOpen().

XrdClientUrlInfo* XrdClientConn::GetMetaUrl ( )

inline

References fMetaUrl.

Referenced by XrdClient::TryOpen().

XErrorCode XrdClientConn::GetOpenError ( ) const

inline

References fOpenError.

int XrdClientConn::GetOpenSockFD ( ) const

inline

References fOpenSockFD.

int XrdClientConn::GetParallelStreamCount

(

)

References ConnectionManager, Error, fLogConnID, XrdClientLogConnection::GetPhyConnection(), and XrdClientPhyConnection::GetSockIdCount().

Referenced by XrdClientMStream::GetGoodSplitParameters().

int XrdClientConn::GetParallelStreamToUse

(

int

reqsperstream

)

References ConnectionManager, Error, fLogConnID, XrdClientLogConnection::GetPhyConnection(), XrdClientPhyConnection::GetSockIdHint(), and kWRITE.

Referenced by XrdClient::ReadV(), and XrdClientMStream::SplitReadRequest().

XrdClientPhyConnection * XrdClientConn::GetPhyConn ( int  LogConnID )

static

References ConnectionManager, and XrdClientLogConnection::GetPhyConnection().

Referenced by XrdClientMStream::AddParallelStream(), and XrdClientMStream::EstablishParallelStreams().

short XrdClientConn::GetRedirCnt ( ) const

inline

References fGlobalRedirCnt.

Referenced by XrdClient::Open(), and XrdClient::TryOpen().

XrdClientUrlInfo XrdClientConn::GetRedirUrl ( )

inline

References fREQUrl.

long XrdClientConn::GetServerProtocol ( )

inline

References fServerProto.

Referenced by XrdClientAdmin::DirList(), XrdClientAdmin::GetSpaceInfo(), XrdClientAdmin::Locate(), XrdClient::Read(), XrdClient::ReadV(), and SendGenCommand().

ERemoteServerType XrdClientConn::GetServerType ( ) const

inline

References fServerType.

Referenced by XrdClientAdmin::Connect(), XrdClientMStream::EstablishParallelStreams(), and XrdClient::Open().

void XrdClientConn::GetSessionID ( SessionIDInfo &  sess )

inline

References mySessionID.

Referenced by XrdClientMStream::BindPendingStream().

kXR_unt16 XrdClientConn::GetStreamID ( ) const

inline

References fPrimaryStreamid.

Referenced by XrdClient::ProcessUnsolicitedMsg().

XReqErrorType XrdClientConn::GoBackToRedirector

(

)

References Disconnect(), fGlobalRedirCnt, fLBSUrl, GoToAnotherServer(), and kOK.

Referenced by XrdClientAdmin::GoBackToRedirector().

XReqErrorType XrdClientConn::GoToAnotherServer ( XrdClientUrlInfo &  newdest )

virtual

References XrdOucString::c_str(), Connect(), ConnectionManager, EnvGetLong, Error, fGettingAccessToSrv, fLogConnID, fPrimaryStreamid, fUnsolMsgHandler, fUrl, GetAccessToSrv(), XrdClientUrlInfo::Host, XrdClientUrlInfo::HostAddr, Info, IsConnected(), XrdClientDebug::kNODEBUG, kOK, kREDIRCONNECT, NAME_PRINT_REDIRECTS, and XrdClientUrlInfo::Port.

Referenced by XrdClientAdmin::DirList(), XrdClientAdmin::GetSpaceInfo(), GoBackToRedirector(), XrdClientAdmin::GoBackToRedirector(), GoToMetaManager(), HandleServerError(), XrdClientAdmin::Locate(), and XrdClient::TryOpen().

XReqErrorType XrdClientConn::GoToMetaManager ( )

virtual

References fLBSIsMeta, fLBSUrl, fMetaUrl, XrdClientUrlInfo::GetUrl(), GoToAnotherServer(), and kGENERICERR.

Referenced by XrdClient::TryOpen().

XrdClientConn::ESrvErrorHandlerRetval XrdClientConn::HandleServerError ( XReqErrorType &  errorType, XrdClientMessage *  xmsg, ClientRequest *  req  )

private

References XrdClientAbs::CanRedirOnError(), CheckHostDomain(), CheckPort(), XrdClientUrlInfo::Clear(), DebugLevel, Disconnect(), EnvGetLong, ServerResponseBody_Error::errnum, Error, FALSE, fGlobalRedirCnt, XrdClientMessage::fHdr, fLBSUrl, fMainReadCache, fMaxGlobalRedirCnt, fRedirCGI, fRedirHandler, fRedirInternalToken, fRedirOpaque, fREQUrl, fUrl, XrdClientUrlInfo::GetUrl(), GoToAnotherServer(), ClientRequest::header, XrdClientUrlInfo::Host, XrdClientUrlInfo::HostAddr, Info, IsConnected(), XrdClientMessage::IsError(), IsOpTimeLimitElapsed(), isRedir(), XrdClientDebug::kHIDEBUG, kOK, kREAD, kREDIRCONNECT, kSEHRContinue, kSEHRReturnMsgToCaller, kSEHRReturnNoMsgToCaller, XrdClientDebug::kUSERDEBUG, kWRITE, kXR_login, kXR_NotAuthorized, kXR_open, LastServerError, XrdOucString::length(), NAME_RECONNECTWAIT, XrdClientAbs::OpenFileWhenRedirected(), ParseRedir(), ParseRedirHost(), XrdClientUrlInfo::Port, PutFilehandleInRequest(), XrdClientReadCache::RemovePlaceholders(), ClientRequestHdr::requestid, and TRUE.

Referenced by ReadPartialAnswer().

bool XrdClientConn::IsConnected ( ) const

inline

References fConnected.

Referenced by XrdClientAdmin::Connect(), XrdClientAdmin::GoBackToRedirector(), GoToAnotherServer(), HandleServerError(), XrdClientAdmin::Locate(), XrdClient::Open(), XrdClientAbs::Query(), and XrdClient::TryOpen().

bool XrdClientConn::IsOpTimeLimitElapsed

(

time_t

timenow

)

References fOpTimeLimit.

Referenced by CheckREQConnectWaitState(), CheckREQPauseState(), ClientServerCmd(), XrdClientAdmin::Connect(), HandleServerError(), XrdClient::Open(), SendGenCommand(), and WaitResp().

bool XrdClientConn::IsPhyConnConnected

(

)

References ConnectionManager, fLogConnID, XrdClientLogConnection::GetPhyConnection(), and XrdClientPhyConnection::IsValid().

Referenced by XrdClient::Read().

bool XrdClientConn::MatchStreamid ( struct ServerResponseHeader *  ServerResponse )

private

References fPrimaryStreamid, and ServerResponseHeader::streamid.

Referenced by CheckResp(), and ProcessAsynResp().

bool XrdClientConn::PanicClose ( )

private

References ClientRequest::close, ClientCloseRequest::dlen, fLogConnID, ClientRequest::header, kXR_close, ClientCloseRequest::requestid, SetSID(), ClientRequestHdr::streamid, TRUE, and WriteToServer().

XrdOucString XrdClientConn::ParseDomainFromHostname ( XrdOucString  hostname )

private

References XrdOucString::assign(), XrdOucString::find(), and STR_NPOS.

Referenced by GetDomainToMatch().

void XrdClientConn::PrintCache ( )

inline

References fMainReadCache, and XrdClientReadCache::PrintCache().

Referenced by XrdClient::Read().

UnsolRespProcResult XrdClientConn::ProcessAsynResp

(

XrdClientMessage *

unsolmsg

)

References clientUnmarshall(), DebugLevel, Disconnect(), ServerResponseHeader::dlen, XrdClientMessage::DonateData(), ServerResponseBody_Error::errmsg, ServerResponseBody_Error::errnum, FALSE, fREQWaitResp, fREQWaitRespData, XrdClientMessage::GetData(), XrdClientMessage::GetStatusCode(), ServerResponseBody_Redirect::host, Info, XrdClientDebug::kDUMPDEBUG, XrdClientDebug::kHIDEBUG, XrdClientDebug::kNODEBUG, kUNSOL_CONTINUE, kUNSOL_DISPOSE, XrdClientDebug::kUSERDEBUG, kXR_error, kXR_redirect, kXR_wait, XrdClientMessage::kXrdMSC_ok, LastServerError, LastServerResp, XrdSysCondVar::Lock(), MatchStreamid(), ServerResponseBody_Redirect::port, ServerResponseBody_Attn_asynresp::respdata, ServerResponseBody_Attn_asynresp::resphdr, SetRequestedDestHost(), XrdSysCondVar::Signal(), smartPrintServerHeader(), ServerResponseHeader::status, XrdSysCondVar::UnLock(), and xrdmin.

Referenced by XrdClientAdmin::ProcessUnsolicitedMsg(), and XrdClient::ProcessUnsolicitedMsg().

XrdClientMessage * XrdClientConn::ReadPartialAnswer ( XReqErrorType &  errorType, size_t &  TotalBlkSize, ClientRequest *  req, bool  HasToAlloc, void **  tmpMoreData, EThreeStateReadHandler &  what_to_do  )

private

References ConnectionManager, convertRespStatusToChar(), XrdClientMessage::DataLen(), DebugLevel, Error, XrdClientMessage::fHdr, fLastDataBytesRecv, fLogConnID, fUrl, XrdClientMessage::GetData(), HandleServerError(), XrdClientMessage::HeaderStatus(), XrdClientUrlInfo::Host, Info, XrdClientMessage::IsError(), isRedir(), XrdClientDebug::kDUMPDEBUG, XrdClientDebug::kHIDEBUG, XrdClientDebug::kNODEBUG, kOK, kREAD, kSEHRReturnMsgToCaller, kSEHRReturnNoMsgToCaller, kTSRHContinue, kTSRHReturnMex, kTSRHReturnNullMex, kWRITE, kXR_authmore, kXR_ok, kXR_oksofar, XrdClientUrlInfo::Port, smartPrintServerHeader(), ServerResponseHeader::status, and XrdClientMessage::Unmarshall().

Referenced by ClientServerCmd().

void XrdClientConn::RemoveAllDataFromCache ( bool  keepwriteblocks = true )

inline

References fMainReadCache, and XrdClientReadCache::RemoveItems().

Referenced by XrdClient::RemoveAllDataFromCache().

void XrdClientConn::RemoveDataFromCache ( long long  begin_offs, long long  end_offs, bool  remove_overlapped = false  )

inline

References fMainReadCache, and XrdClientReadCache::RemoveItems().

Referenced by XrdClient::ProcessUnsolicitedMsg(), XrdClient::Read(), XrdClient::RemoveDataFromCache(), and XrdClient::Write().

void XrdClientConn::RemovePlaceholdersFromCache ( )

inline

References fMainReadCache, and XrdClientReadCache::RemovePlaceholders().

bool XrdClientConn::SendGenCommand ( ClientRequest *  req, const void *  reqMoreData, void **  answMoreDataAllocated, void *  answMoreData, bool  HasToAlloc, char *  CmdName, int  substreamid = 0  )

virtual

References CheckErrorStatus(), CheckREQPauseState(), CheckResp(), ClientServerCmd(), convertRequestIdToChar(), ServerResponseHeader::dlen, Error, FALSE, fGlobalRedirCnt, XrdClientMessage::fHdr, fMaxGlobalRedirCnt, fOpenError, fREQWaitRespData, fUrl, XrdClientMessage::GetData(), GetServerProtocol(), ClientRequest::header, XrdClientUrlInfo::Host, Info, XrdClientMessage::IsError(), IsOpTimeLimitElapsed(), XrdClientDebug::kHIDEBUG, kXR_bind, kXR_close, kXR_error, kXR_maxReqRetry, kXR_ok, kXR_open, kXR_read, kXR_refresh, kXR_retstat, kXR_sync, kXR_wait, kXR_waitresp, kXR_write, LastServerResp, ClientRequest::open, ClientOpenRequest::options, XrdClientUrlInfo::Port, ClientRequestHdr::requestid, ServerResponseBody_Attn_asynresp::respdata, ServerResponseBody_Attn_asynresp::resphdr, ServerResponseHeader::status, TRUE, and WaitResp().

Referenced by XrdClientAdmin::Chmod(), XrdClient::Close(), XrdClientAdmin::DirList_low(), DoAuthentication(), DoLogin(), DoWriteSoftCheckPoint(), XrdClientMStream::EstablishParallelStreams(), XrdClientAdmin::GetChecksum(), XrdClientAdmin::GetSpaceInfo(), XrdClientAdmin::LocalLocate(), XrdClient::LowOpen(), XrdClientAdmin::Mkdir(), XrdClientAdmin::Mv(), XrdClientAdmin::Prepare(), XrdClientAdmin::Protocol(), XrdClientAbs::Query(), XrdClient::Read(), XrdClientReadV::ReqReadV(), XrdClientAdmin::Rm(), XrdClientAdmin::Rmdir(), XrdClientAdmin::Stat(), XrdClient::Stat(), XrdClientAdmin::Stat_vfs(), XrdClient::Sync(), XrdClientAdmin::SysStatX(), XrdClientAdmin::Truncate(), XrdClient::Truncate(), and XrdClient::Write().

void XrdClientConn::SetCacheRmPolicy ( int  RmPolicy )

inline

References fMainReadCache, and XrdClientReadCache::SetBlkRemovalPolicy().

Referenced by XrdClient::SetCacheParameters().

void XrdClientConn::SetCacheSize ( int  CacheSize )

inline

References fMainReadCache, and XrdClientReadCache::SetSize().

Referenced by XrdClient::SetCacheParameters().

void XrdClientConn::SetClientHostDomain ( const char *  src )

inline

References fgClientHostDomain.

void XrdClientConn::SetConnected ( bool  conn )

inline

References fConnected.

void XrdClientConn::SetLogConnID ( int  cid )

inlineprotected

References fLogConnID.

void XrdClientConn::SetMaxRedirCnt ( short  mx )

inline

References fMaxGlobalRedirCnt.

void XrdClientConn::SetOpenError ( XErrorCode  err )

inline

References fOpenError.

void XrdClientConn::SetOpTimeLimit

(

int

delta_secs

)

References fOpTimeLimit.

Referenced by XrdClientAdmin::Chmod(), XrdClient::Close(), XrdClientAdmin::Connect(), XrdClientAdmin::DirList_low(), XrdClientAdmin::GetChecksum(), XrdClientAdmin::GetSpaceInfo(), XrdClientAdmin::Locate(), XrdClientAdmin::Mkdir(), XrdClientAdmin::Mv(), XrdClient::Open(), XrdClientAdmin::Prepare(), XrdClientAdmin::Protocol(), XrdClientAbs::Query(), XrdClient::Read(), XrdClient::ReadV(), XrdClientAdmin::Rm(), XrdClientAdmin::Rmdir(), XrdClientAdmin::Stat(), XrdClientAdmin::Stat_vfs(), XrdClient::Sync(), XrdClientAdmin::SysStatX(), XrdClientAdmin::Truncate(), and XrdClient::Write().

void XrdClientConn::SetRedirHandler ( XrdClientAbs *  rh )

inline

References fRedirHandler.

Referenced by XrdClient::XrdClient(), and XrdClientAdmin::XrdClientAdmin().

void XrdClientConn::SetREQDelayedConnectState ( kXR_int32  wsec )

inline

References XrdSysCondVar::Broadcast(), fREQConnectWait, fREQConnectWaitTimeLimit, XrdSysCondVar::Lock(), and XrdSysCondVar::UnLock().

Referenced by XrdClientAdmin::ProcessUnsolicitedMsg(), and XrdClient::ProcessUnsolicitedMsg().

void XrdClientConn::SetREQPauseState ( kXR_int32  wsec )

inline

References XrdSysCondVar::Broadcast(), fREQWait, fREQWaitTimeLimit, XrdSysCondVar::Lock(), and XrdSysCondVar::UnLock().

Referenced by XrdClientAdmin::ProcessUnsolicitedMsg(), and XrdClient::ProcessUnsolicitedMsg().

void XrdClientConn::SetRequestedDestHost ( char *  newh, kXR_int32  port  )

inline

References fREQUrl, fUrl, XrdClientUrlInfo::Host, XrdMonCtrCollector::port, XrdClientUrlInfo::Port, and XrdClientUrlInfo::SetAddrFromHost().

Referenced by ProcessAsynResp(), XrdClientAdmin::ProcessUnsolicitedMsg(), and XrdClient::ProcessUnsolicitedMsg().

void XrdClientConn::SetSID

(

kXR_char *

sid

)

References fPrimaryStreamid.

Referenced by XrdClientMStream::BindPendingStream(), XrdClientAdmin::Chmod(), ClientServerCmd(), XrdClient::Close(), XrdClientAdmin::DirList_low(), DoAuthentication(), DoLogin(), XrdClientMStream::EstablishParallelStreams(), XrdClientAdmin::GetChecksum(), XrdClientAdmin::GetSpaceInfo(), XrdClientAdmin::LocalLocate(), XrdClient::LowOpen(), XrdClientAdmin::Mkdir(), XrdClientAdmin::Mv(), PanicClose(), XrdClientAdmin::Prepare(), XrdClientAdmin::Protocol(), XrdClientAbs::Query(), XrdClient::Read(), XrdClientReadV::ReqReadV(), XrdClientAdmin::Rm(), XrdClientAdmin::Rmdir(), XrdClientAdmin::Stat(), XrdClient::Stat(), XrdClientAdmin::Stat_vfs(), XrdClient::Sync(), XrdClientAdmin::SysStatX(), XrdClientAdmin::Truncate(), XrdClient::Truncate(), and XrdClient::Write().

void XrdClientConn::SetStreamID ( kXR_unt16  sid )

inlineprotected

References fPrimaryStreamid.

void XrdClientConn::SetUrl ( XrdClientUrlInfo  thisUrl )

inline

References fUrl.

Referenced by XrdClientAdmin::Connect(), and XrdClient::Open().

bool XrdClientConn::SubmitDataToCache	(	XrdClientMessage *	xmsg,
		long long	begin_offs,
		long long	end_offs
	)

References fMainReadCache, XrdClientMessage::HeaderStatus(), kXR_ok, kXR_oksofar, and XrdClientReadCache::SubmitXMessage().

Referenced by XrdClient::ProcessUnsolicitedMsg().

void XrdClientConn::SubmitPlaceholderToCache ( long long  begin_offs, long long  end_offs  )

inline

References fMainReadCache, and XrdClientReadCache::PutPlaceholder().

Referenced by XrdClient::Read_Async(), and XrdClientReadV::ReqReadV().

bool XrdClientConn::SubmitRawDataToCache	(	const void *	buffer,
		long long	begin_offs,
		long long	end_offs
	)

References fMainReadCache, and XrdClientReadCache::SubmitRawData().

Referenced by XrdClientReadV::SubmitToCacheReadVResp().

void XrdClientConn::UnPinCacheBlk ( long long  begin_offs, long long  end_offs  )

inline

References XrdSysCondVar::Broadcast(), fMainReadCache, fWriteWaitAck, and XrdClientReadCache::UnPinCacheBlk().

Referenced by XrdClient::ProcessUnsolicitedMsg().

void XrdClientConn::UnPinCacheBlk

(

)

Referenced by DoWriteSoftCheckPoint().

bool XrdClientConn::WaitResp ( int  secsmax )

private

References fREQWaitResp, fREQWaitRespData, Info, IsOpTimeLimitElapsed(), XrdClientDebug::kHIDEBUG, XrdSysCondVar::Lock(), XrdSysCondVar::UnLock(), XrdSysCondVar::Wait(), and xrdmin.

Referenced by SendGenCommand().

XReqErrorType XrdClientConn::WriteToServer ( ClientRequest *  req, const void *  reqMoreData, short  LogConnID, int  substreamid = 0  )

private

References clientMarshall(), ConnectionManager, DebugLevel, ClientRequestHdr::dlen, Error, fLastDataBytesSent, fUrl, XrdClientLogConnection::GetPhyConnection(), ClientRequest::header, XrdClientUrlInfo::Host, XrdClientDebug::kDUMPDEBUG, kOK, kWRITE, kXR_bind, XrdClientUrlInfo::Port, ClientRequestHdr::requestid, and smartPrintClientHeader().

Referenced by ClientServerCmd(), PanicClose(), and WriteToServer_Async().

XReqErrorType XrdClientConn::WriteToServer_Async	(	ClientRequest *	req,
		const void *	reqMoreData,
		int	substreamid = 0
	)

References ConnectionManager, ClientRequestHdr::dlen, Error, fLogConnID, fMainReadCache, fPrimaryStreamid, ClientRequest::header, kGENERICERR, kNOMORESTREAMS, kXR_write, ClientWriteRequest::offset, ClientRequestHdr::requestid, XrdClientReadCache::SubmitRawData(), ClientRequest::write, and WriteToServer().

Referenced by XrdClient::Read_Async(), XrdClientReadV::ReqReadV(), and XrdClient::Write().

---

Member Data Documentation

bool XrdClientConn::fConnected

private

Referenced by Connect(), Disconnect(), IsConnected(), and SetConnected().

XrdOucString XrdClientConn::fgClientHostDomain

staticprivate

Referenced by GetClientHostDomain(), SetClientHostDomain(), and XrdClientConn().

XrdClientConnectionMgr * XrdClientConn::fgConnectionMgr = 0

staticprivate

Referenced by GetConnectionMgr(), and XrdClientConn().

bool XrdClientConn::fGettingAccessToSrv

private

Referenced by GetAccessToSrv(), and GoToAnotherServer().

short XrdClientConn::fGlobalRedirCnt

protected

Referenced by ClientServerCmd(), GetRedirCnt(), GoBackToRedirector(), HandleServerError(), SendGenCommand(), and XrdClientConn().

time_t XrdClientConn::fGlobalRedirLastUpdateTimestamp

private

Referenced by XrdClientConn().

int XrdClientConn::fLastDataBytesRecv

Referenced by ReadPartialAnswer().

int XrdClientConn::fLastDataBytesSent

Referenced by WriteToServer().

bool XrdClientConn::fLBSIsMeta

private

Referenced by DoHandShake(), and GoToMetaManager().

XrdClientUrlInfo* XrdClientConn::fLBSUrl

protected

Referenced by DoHandShake(), GetLBSUrl(), GoBackToRedirector(), GoToMetaManager(), HandleServerError(), and ~XrdClientConn().

int XrdClientConn::fLogConnID

private

Referenced by ClientServerCmd(), Connect(), Disconnect(), DoLogin(), GetAccessToSrv(), GetLogConnID(), GetParallelStreamCount(), GetParallelStreamToUse(), GoToAnotherServer(), IsPhyConnConnected(), PanicClose(), ReadPartialAnswer(), SetLogConnID(), and WriteToServer_Async().

XrdClientReadCache* XrdClientConn::fMainReadCache

private

Referenced by CacheWillFit(), ClientServerCmd(), Disconnect(), DoWriteSoftCheckPoint(), GetCacheInfo(), GetDataFromCache(), HandleServerError(), PrintCache(), RemoveAllDataFromCache(), RemoveDataFromCache(), RemovePlaceholdersFromCache(), SetCacheRmPolicy(), SetCacheSize(), SubmitDataToCache(), SubmitPlaceholderToCache(), SubmitRawDataToCache(), UnPinCacheBlk(), WriteToServer_Async(), and ~XrdClientConn().

short XrdClientConn::fMaxGlobalRedirCnt

private

Referenced by ClientServerCmd(), GetMaxRedirCnt(), HandleServerError(), SendGenCommand(), SetMaxRedirCnt(), and XrdClientConn().

XrdClientUrlInfo* XrdClientConn::fMetaUrl

private

Referenced by DoHandShake(), GetMetaUrl(), and GoToMetaManager().

XErrorCode XrdClientConn::fOpenError

Referenced by CheckErrorStatus(), DoAuthentication(), DoLogin(), GetOpenError(), SendGenCommand(), and SetOpenError().

int XrdClientConn::fOpenSockFD

private

Referenced by DoAuthentication(), DoLogin(), GetAccessToSrv(), GetOpenSockFD(), and XrdClientConn().

time_t XrdClientConn::fOpTimeLimit

private

Referenced by IsOpTimeLimitElapsed(), and SetOpTimeLimit().

kXR_unt16 XrdClientConn::fPrimaryStreamid

private

Referenced by Connect(), Disconnect(), DoWriteHardCheckPoint(), DoWriteSoftCheckPoint(), GetStreamID(), GoToAnotherServer(), MatchStreamid(), SetSID(), SetStreamID(), and WriteToServer_Async().

XrdOucString XrdClientConn::fRedirCGI

Referenced by doCp_xrd3xrd(), and HandleServerError().

XrdClientAbs* XrdClientConn::fRedirHandler

private

Referenced by HandleServerError(), SetRedirHandler(), and XrdClientConn().

XrdOucString XrdClientConn::fRedirInternalToken

private

Referenced by DoLogin(), and HandleServerError().

XrdOucString XrdClientConn::fRedirOpaque

Referenced by ClientServerCmd(), HandleServerError(), and XrdClient::LowOpen().

XrdSysCondVar* XrdClientConn::fREQConnectWait

private

Referenced by CheckREQConnectWaitState(), SetREQDelayedConnectState(), XrdClientConn(), and ~XrdClientConn().

time_t XrdClientConn::fREQConnectWaitTimeLimit

private

Referenced by CheckREQConnectWaitState(), and SetREQDelayedConnectState().

XrdClientUrlInfo XrdClientConn::fREQUrl

protected

Referenced by GetRedirUrl(), HandleServerError(), SetRequestedDestHost(), and XrdClientConn().

XrdSysCondVar* XrdClientConn::fREQWait

private

Referenced by CheckREQPauseState(), SetREQPauseState(), XrdClientConn(), and ~XrdClientConn().

XrdSysCondVar* XrdClientConn::fREQWaitResp

private

Referenced by ProcessAsynResp(), WaitResp(), XrdClientConn(), and ~XrdClientConn().

ServerResponseBody_Attn_asynresp* XrdClientConn::fREQWaitRespData

private

Referenced by ProcessAsynResp(), SendGenCommand(), and WaitResp().

time_t XrdClientConn::fREQWaitTimeLimit

private

Referenced by CheckREQConnectWaitState(), CheckREQPauseState(), and SetREQPauseState().

long XrdClientConn::fServerProto

private

Referenced by DoHandShake(), DoLogin(), and GetServerProtocol().

ERemoteServerType XrdClientConn::fServerType

private

Referenced by GetAccessToSrv(), GetServerType(), and XrdClientConn().

XrdOucHash< XrdClientConn::SessionIDInfo > XrdClientConn::fSessionIDRepo

staticprivate

Referenced by DelSessionIDRepo(), and DoLogin().

XrdSysMutex XrdClientConn::fSessionIDRMutex

staticprivate

Referenced by DelSessionIDRepo(), and DoLogin().

XrdClientAbsUnsolMsgHandler* XrdClientConn::fUnsolMsgHandler

protected

Referenced by Connect(), GoToAnotherServer(), and XrdClientConn().

XrdClientUrlInfo XrdClientConn::fUrl

protected

Referenced by CheckErrorStatus(), DoAuthentication(), DoHandShake(), DoLogin(), GetAccessToSrv(), GetCurrentUrl(), GoToAnotherServer(), HandleServerError(), ReadPartialAnswer(), SendGenCommand(), SetRequestedDestHost(), SetUrl(), and WriteToServer().

XrdClientVector<ClientRequest> XrdClientConn::fWriteReqsToRetry

private

Referenced by Disconnect(), and DoWriteSoftCheckPoint().

XrdSysCondVar* XrdClientConn::fWriteWaitAck

private

Referenced by DoWriteHardCheckPoint(), UnPinCacheBlk(), XrdClientConn(), and ~XrdClientConn().

struct ServerResponseBody_Error XrdClientConn::LastServerError

Referenced by CheckErrorStatus(), ClearLastServerError(), XrdClientAdmin::Connect(), XrdClientAdmin::DirList(), DoAuthentication(), DoLogin(), HandleServerError(), XrdClientAbs::LastServerError(), XrdClient::Open(), ProcessAsynResp(), XrdClient::ProcessUnsolicitedMsg(), XrdClient::Read(), and XrdClient::TryOpen().

struct ServerResponseHeader XrdClientConn::LastServerResp

Referenced by DoAuthentication(), DoLogin(), XrdClientMStream::EstablishParallelStreams(), XrdClientAdmin::GetChecksum(), XrdClientAbs::LastServerResp(), XrdClientAdmin::Locate(), XrdClient::LowOpen(), ProcessAsynResp(), XrdClient::Read(), XrdClientReadV::ReqReadV(), SendGenCommand(), XrdClientAdmin::Stat(), XrdClient::Stat(), XrdClientAdmin::Stat_vfs(), XrdClient::TryOpen(), and XrdClientConn().

SessionIDInfo XrdClientConn::mySessionID

private

Referenced by DoLogin(), and GetSessionID().

---

The documentation for this class was generated from the following files:

• XrdClientConn.hh
• XrdClientConn.cc