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

XrdClientConn::~XrdClientConn

(

)

[virtual]

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

---

Member Function Documentation

bool XrdClientConn::CacheWillFit

(

long long

bytes

)

[inline]

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

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

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

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

Referenced by SendGenCommand().

bool XrdClientConn::CheckHostDomain

(

XrdOucString

hostToCheck

)

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

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

void XrdClientConn::CheckPort

(

int &

port

)

[private]

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

Referenced by HandleServerError().

void XrdClientConn::CheckREQConnectWaitState

(

)

[private]

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

Referenced by Connect().

void XrdClientConn::CheckREQPauseState

(

)

[private]

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

Referenced by SendGenCommand().

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

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

Referenced by SendGenCommand().

void XrdClientConn::ClearLastServerError

(

)

[inline]

References LastServerError, ServerResponseBody_Error::errnum, and kXR_noErrorYet.

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 kOK, SetSID(), ClientRequest::header, ClientRequestHdr::streamid, WriteToServer(), fLogConnID, ReadPartialAnswer(), fMainReadCache, ClientRequestHdr::requestid, kXR_read, XrdClientMessage::HeaderStatus(), kXR_oksofar, kXR_ok, XrdClientReadCache::SubmitXMessage(), ClientRequest::read, ClientReadRequest::offset, XrdClientMessage::fHdr, ServerResponseHeader::dlen, kTSRHReturnNullMex, kTSRHReturnMex, XrdClientMessage::DataLen(), fGlobalRedirCnt, fMaxGlobalRedirCnt, IsOpTimeLimitElapsed(), and kXR_redirect.

Referenced by SendGenCommand().

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

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

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

static void XrdClientConn::DelSessionIDRepo

(

)

[inline, static]

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

Referenced by prepare().

void XrdClientConn::Disconnect

(

bool

ForcePhysicalDisc

)

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

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

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

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

Referenced by DoLogin().

ERemoteServerType XrdClientConn::DoHandShake

(

short

log

)

[private]

Referenced by GetAccessToSrv().

bool XrdClientConn::DoLogin

(

)

[private]

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

Referenced by GetAccessToSrv().

bool XrdClientConn::DomainMatcher	(	XrdOucString	dom,
		XrdOucString	domlist
	)		[private]

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

Referenced by CheckHostDomain().

bool XrdClientConn::DoWriteHardCheckPoint

(

)

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

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

bool XrdClientConn::DoWriteSoftCheckPoint

(

)

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

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

bool XrdClientConn::GetAccessToSrv

(

)

[virtual]

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

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

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::Read(), XrdClient::UseCache(), and XrdClient::GetCacheInfo().

XrdOucString XrdClientConn::GetClientHostDomain

(

)

[inline]

References fgClientHostDomain.

static XrdClientConnectionMgr* XrdClientConn::GetConnectionMgr

(

)

[inline, static]

References fgConnectionMgr.

XrdClientUrlInfo XrdClientConn::GetCurrentUrl

(

)

[inline]

References fUrl.

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

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

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

Referenced by XrdClient::Read().

XrdOucString XrdClientConn::GetDomainToMatch

(

XrdOucString

hostname

)

[private]

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

Referenced by XrdClientConn(), and CheckHostDomain().

XrdClientUrlInfo* XrdClientConn::GetLBSUrl

(

)

[inline]

References fLBSUrl.

Referenced by XrdClient::TryOpen().

int XrdClientConn::GetLogConnID

(

)

const [inline]

References fLogConnID.

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

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, fLogConnID, Error, XrdClientLogConnection::GetPhyConnection(), and XrdClientPhyConnection::GetSockIdCount().

Referenced by XrdClientMStream::GetGoodSplitParameters().

int XrdClientConn::GetParallelStreamToUse

(

int

reqsperstream

)

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

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

XrdClientPhyConnection * XrdClientConn::GetPhyConn

(

int

LogConnID

)

[static]

References ConnectionManager, and XrdClientLogConnection::GetPhyConnection().

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

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 XrdClient::Read(), XrdClient::ReadV(), XrdClientAdmin::DirList(), XrdClientAdmin::Locate(), XrdClientAdmin::GetSpaceInfo(), and SendGenCommand().

ERemoteServerType XrdClientConn::GetServerType

(

)

const [inline]

References fServerType.

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

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 EnvGetLong, NAME_PRINT_REDIRECTS, Info, XrdClientDebug::kNODEBUG, XrdClientUrlInfo::Host, XrdClientUrlInfo::Port, fGettingAccessToSrv, XrdClientUrlInfo::HostAddr, fLogConnID, Connect(), fUnsolMsgHandler, Error, kREDIRCONNECT, fUrl, IsConnected(), GetAccessToSrv(), XrdOucString::c_str(), fPrimaryStreamid, ConnectionManager, and kOK.

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

XReqErrorType XrdClientConn::GoToMetaManager

(

)

[virtual]

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

Referenced by XrdClient::TryOpen().

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

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

Referenced by ReadPartialAnswer().

bool XrdClientConn::IsConnected

(

)

const [inline]

References fConnected.

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

bool XrdClientConn::IsOpTimeLimitElapsed

(

time_t

timenow

)

References fOpTimeLimit.

Referenced by XrdClient::Open(), XrdClientAdmin::Connect(), ClientServerCmd(), SendGenCommand(), HandleServerError(), CheckREQPauseState(), CheckREQConnectWaitState(), 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 ServerResponseHeader::streamid, and fPrimaryStreamid.

Referenced by CheckResp(), and ProcessAsynResp().

bool XrdClientConn::PanicClose

(

)

[private]

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

XrdOucString XrdClientConn::ParseDomainFromHostname

(

XrdOucString

hostname

)

[private]

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

Referenced by GetDomainToMatch().

void XrdClientConn::PrintCache

(

)

[inline]

References fMainReadCache, and XrdClientReadCache::PrintCache().

Referenced by XrdClient::Read().

UnsolRespProcResult XrdClientConn::ProcessAsynResp

(

XrdClientMessage *

unsolmsg

)

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

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

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

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

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::Read(), XrdClient::Write(), XrdClient::ProcessUnsolicitedMsg(), and XrdClient::RemoveDataFromCache().

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

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

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

)

[inline, protected]

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 XrdClient::Open(), XrdClient::Read(), XrdClient::ReadV(), XrdClient::Write(), XrdClient::Sync(), XrdClient::Close(), XrdClientAbs::Query(), XrdClientAdmin::Connect(), XrdClientAdmin::Stat(), XrdClientAdmin::Stat_vfs(), XrdClientAdmin::SysStatX(), XrdClientAdmin::Rmdir(), XrdClientAdmin::Rm(), XrdClientAdmin::Chmod(), XrdClientAdmin::Mkdir(), XrdClientAdmin::Mv(), XrdClientAdmin::Protocol(), XrdClientAdmin::Prepare(), XrdClientAdmin::DirList_low(), XrdClientAdmin::GetChecksum(), XrdClientAdmin::Locate(), XrdClientAdmin::Truncate(), and XrdClientAdmin::GetSpaceInfo().

void XrdClientConn::SetRedirHandler

(

XrdClientAbs *

rh

)

[inline]

References fRedirHandler.

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

void XrdClientConn::SetREQDelayedConnectState

(

kXR_int32

wsec

)

[inline]

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

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

void XrdClientConn::SetREQPauseState

(

kXR_int32

wsec

)

[inline]

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

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

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

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

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

void XrdClientConn::SetSID

(

kXR_char *

sid

)

References fPrimaryStreamid.

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

void XrdClientConn::SetStreamID

(

kXR_unt16

sid

)

[inline, protected]

References fPrimaryStreamid.

void XrdClientConn::SetUrl

(

XrdClientUrlInfo

thisUrl

)

[inline]

References fUrl.

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

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

References fMainReadCache, XrdClientMessage::HeaderStatus(), kXR_oksofar, kXR_ok, 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 fMainReadCache, XrdClientReadCache::UnPinCacheBlk(), fWriteWaitAck, and XrdSysCondVar::Broadcast().

Referenced by XrdClient::ProcessUnsolicitedMsg().

void XrdClientConn::UnPinCacheBlk

(

)

Referenced by DoWriteSoftCheckPoint().

bool XrdClientConn::WaitResp

(

int

secsmax

)

[private]

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

Referenced by SendGenCommand().

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

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

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

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

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

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

---

Member Data Documentation

bool XrdClientConn::fConnected [private]

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

XrdOucString XrdClientConn::fgClientHostDomain [static, private]

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

XrdClientConnectionMgr * XrdClientConn::fgConnectionMgr = 0 [static, private]

Referenced by XrdClientConn(), and GetConnectionMgr().

bool XrdClientConn::fGettingAccessToSrv [private]

Referenced by GetAccessToSrv(), and GoToAnotherServer().

short XrdClientConn::fGlobalRedirCnt [protected]

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

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 XrdClientPhyConnection::DoHandShake(), and GoToMetaManager().

XrdClientUrlInfo* XrdClientConn::fLBSUrl [protected]

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

int XrdClientConn::fLogConnID [private]

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

XrdClientReadCache* XrdClientConn::fMainReadCache [private]

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

short XrdClientConn::fMaxGlobalRedirCnt [private]

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

XrdClientUrlInfo* XrdClientConn::fMetaUrl [private]

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

XErrorCode XrdClientConn::fOpenError

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

int XrdClientConn::fOpenSockFD [private]

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

time_t XrdClientConn::fOpTimeLimit [private]

Referenced by SetOpTimeLimit(), and IsOpTimeLimitElapsed().

kXR_unt16 XrdClientConn::fPrimaryStreamid [private]

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

XrdClientAbs* XrdClientConn::fRedirHandler [private]

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

XrdOucString XrdClientConn::fRedirInternalToken [private]

Referenced by DoLogin(), and HandleServerError().

XrdOucString XrdClientConn::fRedirOpaque

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

XrdSysCondVar* XrdClientConn::fREQConnectWait [private]

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

time_t XrdClientConn::fREQConnectWaitTimeLimit [private]

Referenced by CheckREQConnectWaitState(), and SetREQDelayedConnectState().

XrdClientUrlInfo XrdClientConn::fREQUrl [protected]

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

XrdSysCondVar* XrdClientConn::fREQWait [private]

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

XrdSysCondVar* XrdClientConn::fREQWaitResp [private]

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

ServerResponseBody_Attn_asynresp* XrdClientConn::fREQWaitRespData [private]

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

time_t XrdClientConn::fREQWaitTimeLimit [private]

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

long XrdClientConn::fServerProto [private]

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

ERemoteServerType XrdClientConn::fServerType [private]

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

XrdOucHash< XrdClientConn::SessionIDInfo > XrdClientConn::fSessionIDRepo [static, private]

Referenced by DoLogin(), and DelSessionIDRepo().

XrdSysMutex XrdClientConn::fSessionIDRMutex [static, private]

Referenced by DoLogin(), and DelSessionIDRepo().

XrdClientAbsUnsolMsgHandler* XrdClientConn::fUnsolMsgHandler [protected]

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

XrdClientUrlInfo XrdClientConn::fUrl [protected]

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

XrdClientVector<ClientRequest> XrdClientConn::fWriteReqsToRetry [private]

Referenced by Disconnect(), and DoWriteSoftCheckPoint().

XrdSysCondVar* XrdClientConn::fWriteWaitAck [private]

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

struct ServerResponseBody_Error XrdClientConn::LastServerError

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

struct ServerResponseHeader XrdClientConn::LastServerResp

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

SessionIDInfo XrdClientConn::mySessionID [private]

Referenced by DoLogin(), and GetSessionID().

---

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

• XrdClientConn.hh
• XrdClientConn.cc