XrdClient Class Reference

#include <XrdClient.hh>

Inheritance diagram for XrdClient:

Collaboration diagram for XrdClient:

List of all members.

Public Member Functions
	XrdClient (const char *url, XrdClientCallback *XrdCcb=0, void *XrdCcbArg=0)
virtual	~XrdClient ()
UnsolRespProcResult	ProcessUnsolicitedMsg (XrdClientUnsolMsgSender *sender, XrdClientMessage *unsolmsg)
bool	Close ()
bool	Sync ()
bool	Copy (const char *localpath)
bool	GetCacheInfo (int &size, long long &bytessubmitted, long long &byteshit, long long &misscount, float &missrate, long long &readreqcnt, float &bytesusefulness)
bool	GetCounters (XrdClientCounters *cnt)
bool	IsOpen ()
bool	IsOpen_inprogress ()
bool	IsOpen_wait ()
bool	Open (kXR_unt16 mode, kXR_unt16 options, bool doitparallel=true)
int	Read (void *buf, long long offset, int len)
kXR_int64	ReadV (char *buf, long long *offsets, int *lens, int nbuf)
XReqErrorType	Read_Async (long long offset, int len, bool updatecounters=true)
bool	Stat (struct XrdClientStatInfo *stinfo, bool force=false)
bool	UseCache (bool u=TRUE)
void	RemoveAllDataFromCache ()
void	RemoveDataFromCache (long long begin_offs, long long end_offs, bool remove_overlapped=false)
void	SetCacheParameters (int CacheSize, int ReadAheadSize, int RmPolicy)
void	SetReadAheadStrategy (int strategy)
void	SetBlockReadTrimming (int blocksize)
bool	Truncate (long long len)
bool	Write (const void *buf, long long offset, int len)
Public Attributes
std::vector< std::string >	fExcludedHosts
Protected Member Functions
virtual bool	OpenFileWhenRedirected (char *newfhandle, bool &wasopen)
virtual bool	CanRedirOnError ()
Protected Attributes
XrdClientCounters	fCounters
Private Member Functions
bool	TryOpen (kXR_unt16 mode, kXR_unt16 options, bool doitparallel)
bool	LowOpen (const char *file, kXR_unt16 mode, kXR_unt16 options, char *additionalquery=0)
void	TerminateOpenAttempt ()
void	WaitForNewAsyncData ()
kXR_int64	ReadVEach (char *buf, kXR_int64 *offsets, int *lens, int &nbuf)
bool	IsOpenedForWrite ()
void	PrintCounters ()
Private Attributes
struct XrdClientOpenInfo	fOpenPars
XrdSysCondVar *	fOpenProgCnd
XrdClientThread *	fOpenerTh
bool	fOpenWithRefresh
XrdSysCondVar *	fReadWaitData
struct XrdClientStatInfo	fStatInfo
long	fReadTrimBlockSize
bool	fUseCache
XrdOucString	fInitialUrl
XrdClientUrlInfo	fUrl
XrdClientReadAheadMgr *	fReadAheadMgr
Static Private Attributes
static XrdSysSemWait	fConcOpenSem
Friends
void *	FileOpenerThread (void *, XrdClientThread *)

---

Constructor & Destructor Documentation

XrdClient::XrdClient	(	const char *	url,
		XrdClientCallback *	XrdCcb = 0,
		void *	XrdCcbArg = 0
	)

References fReadAheadMgr, fReadTrimBlockSize, fOpenerTh, fOpenProgCnd, fReadWaitData, fStatInfo, fOpenPars, fCounters, DebugSetLevel, EnvGetLong, NAME_DEBUG, ConnectionManager, Info, XrdClientDebug::kUSERDEBUG, XrdVSTRING, fInitialUrl, XrdClientAbs::fConnModule, XrdClientAbs::XrdClientConn, Error, XrdClientConn::SetRedirHandler(), NAME_READCACHESIZE, NAME_READAHEADSIZE, NAME_READCACHEBLKREMPOLICY, NAME_READAHEADSTRATEGY, SetReadAheadStrategy(), SetBlockReadTrimming(), NAME_READTRIMBLKSZ, fUseCache, and SetCacheParameters().

XrdClient::~XrdClient

(

)

[virtual]

References IsOpen_wait(), Close(), fOpenProgCnd, XrdSysCondVar::Lock(), fOpenerTh, XrdClientThread::Cancel(), XrdClientThread::Join(), XrdSysCondVar::UnLock(), XrdClientAbs::fConnModule, fReadAheadMgr, fReadWaitData, and PrintCounters().

---

Member Function Documentation

virtual bool XrdClient::CanRedirOnError

(

)

[inline, protected, virtual]

Implements XrdClientAbs.

References fOpenPars, XrdClientOpenInfo::opened, and IsOpenedForWrite().

bool XrdClient::Close

(

)

References IsOpen_wait(), Info, XrdClientDebug::kUSERDEBUG, TRUE, XrdClientAbs::fConnModule, XrdClientConn::SetOpTimeLimit(), EnvGetLong, NAME_TRANSACTIONTIMEOUT, XrdClientConn::SetSID(), ClientRequest::header, ClientRequestHdr::streamid, ClientRequest::close, ClientCloseRequest::requestid, kXR_close, ClientCloseRequest::fhandle, XrdClientAbs::fHandle, ClientCloseRequest::dlen, IsOpenedForWrite(), XrdClientConn::DoWriteHardCheckPoint(), XrdClientConn::SendGenCommand(), FALSE, fOpenPars, XrdClientOpenInfo::opened, and XrdClientConn::Disconnect().

Referenced by main(), ~XrdClient(), doCp_xrd2loc(), and XrdPosixFile::~XrdPosixFile().

bool XrdClient::Copy

(

const char *

localpath

)

References IsOpen_wait(), Error, FALSE, Stat(), open(), fStatInfo, XrdClientStatInfo::size, Read(), write(), close, and TRUE.

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

References XrdClientAbs::fConnModule, and XrdClientConn::GetCacheInfo().

bool XrdClient::GetCounters

(

XrdClientCounters *

cnt

)

References fCounters, XrdClientCounters::ReadMisses, XrdClientCounters::ReadRequests, XrdClientCounters::ReadHits, and XrdClientCounters::ReadMissRate.

Referenced by PrintCounters().

bool XrdClient::IsOpen

(

)

[inline]

References fOpenPars, and XrdClientOpenInfo::opened.

Referenced by BWMToken_WaitFor().

bool XrdClient::IsOpen_inprogress

(

)

References fOpenProgCnd, XrdSysCondVar::Lock(), fOpenPars, XrdClientOpenInfo::inprogress, and XrdSysCondVar::UnLock().

Referenced by main().

bool XrdClient::IsOpen_wait

(

)

[virtual]

Reimplemented from XrdClientAbs.

References fOpenProgCnd, XrdSysCondVar::Lock(), fOpenPars, XrdClientOpenInfo::inprogress, XrdSysCondVar::Wait(), fOpenerTh, XrdSysCondVar::UnLock(), XrdClientThread::Join(), and XrdClientOpenInfo::opened.

Referenced by main(), ~XrdClient(), Read(), ReadV(), Write(), Sync(), Stat(), Close(), Copy(), Read_Async(), Truncate(), and ReaderThread_xrd_xtreme().

bool XrdClient::IsOpenedForWrite

(

)

[inline, private]

References fOpenPars, XrdClientOpenInfo::options, and kXR_open_read.

Referenced by Close(), and CanRedirOnError().

bool XrdClient::LowOpen	(	const char *	file,
		kXR_unt16	mode,
		kXR_unt16	options,
		char *	additionalquery = 0
	)		[private]

References XrdClientAbs::fConnModule, XrdClientConn::fRedirOpaque, XrdOucString::length(), XrdClientConn::SetSID(), ClientRequest::header, ClientRequestHdr::streamid, ClientRequestHdr::requestid, kXR_open, ClientRequest::open, ClientOpenRequest::options, kXR_retstat, ClientOpenRequest::mode, ClientOpenRequest::dlen, XrdClientConn::SendGenCommand(), XrdOucString::c_str(), XrdClientConn::LastServerResp, ServerResponseHeader::status, ServerResponseHeader::dlen, XrdClientAbs::fHandle, ServerResponseBody_Open::fhandle, fOpenPars, XrdClientOpenInfo::opened, TRUE, XrdClientOpenInfo::options, XrdClientOpenInfo::mode, Error, Info, XrdClientDebug::kHIDEBUG, fStatInfo, XrdClientStatInfo::id, XrdClientStatInfo::size, XrdClientStatInfo::flags, XrdClientStatInfo::modtime, and XrdClientStatInfo::stated.

Referenced by TryOpen().

bool XrdClient::Open	(	kXR_unt16	mode,
		kXR_unt16	options,
		bool	doitparallel = true
	)

References fOpenPars, XrdClientOpenInfo::opened, FALSE, XrdClientOpenInfo::options, XrdClientOpenInfo::mode, EnvGetLong, NAME_FIRSTCONNECTMAXCNT, XrdClientAbs::fConnModule, XrdClientConn::SetOpTimeLimit(), NAME_TRANSACTIONTIMEOUT, fInitialUrl, XrdClientUrlSet::IsValid(), Error, XrdClientUrlInfo::File, XrdClientUrlSet::Rewind(), XrdClientConn::IsConnected(), XrdClientUrlSet::Size(), XrdClientConn::IsOpTimeLimitElapsed(), XrdClientConn::Disconnect(), TRUE, XrdOucCRC::CRC32(), XrdOucString::c_str(), XrdOucString::length(), XrdClientUrlSet::GetARandomUrl(), XrdClientConn::CheckHostDomain(), XrdClientUrlInfo::Host, Info, XrdClientDebug::kHIDEBUG, XrdClientUrlInfo::Port, XrdClientConn::Connect(), XrdClientUrlSet::EraseUrl(), XrdClientConn::GetLogConnID(), XrdClientConn::SetUrl(), fUrl, XrdClientUrlInfo::GetUrl(), XrdClientConn::GetAccessToSrv(), XrdClientConn::GetRedirCnt(), XrdClientConn::GetMaxRedirCnt(), XrdClientConn::LastServerError, ServerResponseBody_Error::errnum, kXR_NotAuthorized, ServerResponseBody_Error::errmsg, XrdOucString::erasefromend(), XrdClientDebug::kUSERDEBUG, DebugLevel, NAME_RECONNECTWAIT, sleep, XrdClientConn::GetServerType(), kSTRootd, kSTNone, TryOpen(), XrdClientAbs::fXrdCcb, XrdClientCallback::OpenComplete(), and XrdClientAbs::fXrdCcbArg.

Referenced by main(), XrdCnsLogClient::Archive(), XrdCnsLogClient::do_Create(), ReaderThread_xrd_xtreme(), doCp_xrd2xrd(), BWMToken_Init(), doCp_xrd2loc(), PedanticOpen4Write(), and XrdPosixXrootd::Open().

bool XrdClient::OpenFileWhenRedirected	(	char *	newfhandle,
		bool &	wasopen
	)		[protected, virtual]

Implements XrdClientAbs.

References fOpenPars, XrdClientOpenInfo::opened, TRUE, FALSE, Info, XrdClientDebug::kHIDEBUG, XrdClientOpenInfo::options, kXR_delete, kXR_open_updt, kXR_new, TryOpen(), XrdClientOpenInfo::mode, XrdClientAbs::fHandle, and Error.

void XrdClient::PrintCounters

(

)

[private]

References DebugLevel, XrdClientDebug::kUSERDEBUG, GetCounters(), XrdClientCounters::ReadBytes, XrdClientCounters::WrittenBytes, XrdClientCounters::WriteRequests, XrdClientCounters::ReadRequests, XrdClientCounters::ReadMisses, XrdClientCounters::ReadHits, XrdClientCounters::ReadMissRate, XrdClientCounters::ReadVRequests, XrdClientCounters::ReadVSubRequests, XrdClientCounters::ReadVSubChunks, XrdClientCounters::ReadVBytes, XrdClientCounters::ReadVAsyncRequests, XrdClientCounters::ReadVAsyncSubRequests, XrdClientCounters::ReadVAsyncSubChunks, XrdClientCounters::ReadVAsyncBytes, XrdClientCounters::ReadAsyncRequests, and XrdClientCounters::ReadAsyncBytes.

Referenced by ~XrdClient().

UnsolRespProcResult XrdClient::ProcessUnsolicitedMsg	(	XrdClientUnsolMsgSender *	sender,
		XrdClientMessage *	unsolmsg
	)		[virtual]

Implements XrdClientAbsUnsolMsgHandler.

References XrdClientMessage::GetStatusCode(), Info, XrdClientDebug::kHIDEBUG, XrdClientMessage::HeaderSID(), XrdClientMessage::IsAttn(), XrdClientMessage::GetData(), ServerResponseBody_Attn::actnum, kXR_asyncdi, XrdClientDebug::kUSERDEBUG, ServerResponseBody_Attn_asyncdi::wsec, XrdClientAbs::fConnModule, XrdClientConn::SetRequestedDestHost(), fUrl, XrdClientUrlInfo::Host, XrdOucString::c_str(), XrdClientUrlInfo::Port, XrdClientConn::SetREQDelayedConnectState(), kUNSOL_CONTINUE, kXR_asyncrd, ServerResponseBody_Attn_asyncrd::host, ServerResponseBody_Attn_asyncrd::port, kXR_asyncwt, ServerResponseBody_Attn_asyncwt::wsec, XrdClientConn::SetREQPauseState(), kXR_asyncgo, kXR_asynresp, XrdClientConn::ProcessAsynResp(), fReadWaitData, XrdSysCondVar::Broadcast(), TerminateOpenAttempt(), ConnectionManager, XrdClientConn::GetStreamID(), Error, kUNSOL_DISPOSE, SidInfo::outstandingreq, SidInfo::fathersid, XrdClientMessage::HeaderStatus(), kXR_oksofar, kXR_ok, ClientRequest::header, ClientRequestHdr::requestid, kXR_read, ClientRequest::read, ClientReadRequest::offset, SidInfo::reqbyteprogress, XrdClientMessage::fHdr, ServerResponseHeader::dlen, XrdClientConn::SubmitDataToCache(), kUNSOL_KEEP, kXR_readv, XrdClientReadV::SubmitToCacheReadVResp(), XrdClientMessage::DonateData(), kXR_write, ClientRequestHdr::dlen, ClientRequest::write, ClientWriteRequest::offset, XrdClientConn::UnPinCacheBlk(), EnvGetLong, NAME_PURGEWRITTENBLOCKS, XrdClientConn::RemoveDataFromCache(), ClientReadRequest::rlen, XrdClientDebug::kNODEBUG, ServerResponseBody_Error::errmsg, ServerResponseBody_Error::errnum, XrdClientConn::LastServerError, xrdmin, XrdClientMessage::DataLen(), ClientWriteRequest::dlen, and kXR_noErrorYet.

int XrdClient::Read	(	void *	buf,
		long long	offset,
		int	len
	)

References Info, XrdClientDebug::kHIDEBUG, IsOpen_wait(), Error, XrdClientAbs::fConnModule, XrdClientConn::SetOpTimeLimit(), EnvGetLong, NAME_TRANSACTIONTIMEOUT, fCounters, XrdClientCounters::ReadRequests, XrdClientConn::GetCacheInfo(), fUseCache, XrdClientConn::GetServerProtocol(), XrdClientConn::SetSID(), ClientRequest::header, ClientRequestHdr::streamid, ClientRequest::read, ClientReadRequest::requestid, kXR_read, ClientReadRequest::fhandle, XrdClientAbs::fHandle, ClientReadRequest::offset, ClientReadRequest::rlen, ClientReadRequest::dlen, XrdClientConn::SendGenCommand(), FALSE, XrdClientCounters::ReadBytes, XrdClientConn::LastServerResp, ServerResponseHeader::dlen, fReadAheadMgr, XrdClientReadAheadMgr::GetReadAheadHint(), fReadTrimBlockSize, XrdClientConn::CacheWillFit(), xrdmin, Read_Async(), Stat(), xrdmax, XrdClientStatInfo::size, fReadWaitData, XrdSysCondVar::Lock(), XrdClientVector::Clear(), XrdClientConn::GetDataFromCache(), XrdClientVector::GetSize(), XrdSysCondVar::UnLock(), XrdClientCounters::ReadHits, XrdClientDebug::kUSERDEBUG, XrdClientReadAheadMgr::TrimReadRequest(), XrdClientConn::LastServerError, ServerResponseBody_Error::errnum, kXR_noErrorYet, XrdClientConn::IsPhyConnConnected(), XrdSysCondVar::Wait(), NAME_REQUESTTIMEOUT, DebugLevel, XrdClientConn::PrintCache(), ConnectionManager, NAME_REMUSEDCACHEBLKS, and XrdClientConn::RemoveDataFromCache().

Referenced by main(), ReadV(), Copy(), ReaderThread_xrd(), ReaderThread_xrd_xtreme(), and XrdPosixFile::Read().

XReqErrorType XrdClient::Read_Async	(	long long	offset,
		int	len,
		bool	updatecounters = true
	)

References IsOpen_wait(), Error, kGENERICERR, Stat(), xrdmin, fStatInfo, XrdClientStatInfo::size, kOK, fUseCache, XrdClientAbs::fConnModule, XrdClientConn::SubmitPlaceholderToCache(), fCounters, XrdClientCounters::ReadAsyncRequests, XrdClientCounters::ReadAsyncBytes, ClientRequest::read, ClientReadRequest::requestid, kXR_read, ClientReadRequest::fhandle, XrdClientAbs::fHandle, ClientReadRequest::offset, ClientReadRequest::rlen, ClientReadRequest::dlen, Info, XrdClientDebug::kHIDEBUG, XrdClientMStream::SplitReadRequest(), XrdClientVector::GetSize(), read_args::pathid, XrdClientMStream::ReadChunk::streamtosend, XrdClientMStream::ReadChunk::offset, XrdClientMStream::ReadChunk::len, and XrdClientConn::WriteToServer_Async().

Referenced by main(), Read(), ReadV(), and ReaderThread_xrd_xtreme().

kXR_int64 XrdClient::ReadV	(	char *	buf,
		long long *	offsets,
		int *	lens,
		int	nbuf
	)

References IsOpen_wait(), Error, XrdClientAbs::fConnModule, XrdClientConn::GetServerProtocol(), Info, XrdClientDebug::kHIDEBUG, Stat(), XrdClientConn::SetOpTimeLimit(), EnvGetLong, NAME_TRANSACTIONTIMEOUT, XrdClientMStream::GetGoodSplitParameters(), XrdClientReadV::PreProcessChunkRequest(), fStatInfo, XrdClientStatInfo::size, fCounters, XrdClientCounters::ReadVRequests, XrdClientCounters::ReadVAsyncRequests, XrdClientVector::GetSize(), READV_MAXCHUNKS, NAME_MULTISTREAMCNT, XrdClientCounters::ReadVSubRequests, XrdClientCounters::ReadVSubChunks, XrdClientCounters::ReadVBytes, Read(), XrdClientCounters::ReadVAsyncSubRequests, XrdClientCounters::ReadVAsyncSubChunks, XrdClientCounters::ReadVAsyncBytes, Read_Async(), XrdClientReadV::ReqReadV(), XrdClientAbs::fHandle, XrdClientConn::GetParallelStreamToUse(), XrdClientConn::CacheWillFit(), XrdClientDebug::kUSERDEBUG, and SetCacheParameters().

Referenced by main().

kXR_int64 XrdClient::ReadVEach	(	char *	buf,
		kXR_int64 *	offsets,
		int *	lens,
		int &	nbuf
	)		[private]

void XrdClient::RemoveAllDataFromCache

(

)

[inline]

References XrdClientAbs::fConnModule, and XrdClientConn::RemoveAllDataFromCache().

Referenced by main().

void XrdClient::RemoveDataFromCache	(	long long	begin_offs,
		long long	end_offs,
		bool	remove_overlapped = false
	)		[inline]

References XrdClientAbs::fConnModule, and XrdClientConn::RemoveDataFromCache().

Referenced by ReaderThread_xrd(), and ReaderThread_xrd_xtreme().

void XrdClient::SetBlockReadTrimming

(

int

blocksize

)

References fReadTrimBlockSize.

Referenced by XrdClient().

void XrdClient::SetCacheParameters	(	int	CacheSize,
		int	ReadAheadSize,
		int	RmPolicy
	)

References XrdClientAbs::fConnModule, XrdClientConn::SetCacheSize(), XrdClientConn::SetCacheRmPolicy(), fReadAheadMgr, and XrdClientReadAheadMgr::SetRASize().

Referenced by XrdClient(), ReadV(), and ReaderThread_xrd_xtreme().

void XrdClient::SetReadAheadStrategy

(

int

strategy

)

References XrdClientAbs::fConnModule, fReadAheadMgr, XrdClientReadAheadMgr::GetCurrentStrategy(), and XrdClientReadAheadMgr::CreateReadAheadMgr().

Referenced by XrdClient().

bool XrdClient::Stat	(	struct XrdClientStatInfo *	stinfo,
		bool	force = false
	)

References fStatInfo, XrdClientStatInfo::stated, TRUE, IsOpen_wait(), Error, FALSE, Sync(), XrdClientAbs::fConnModule, XrdClientConn::SetSID(), ClientRequest::header, ClientRequestHdr::streamid, ClientRequest::stat, ClientStatRequest::requestid, kXR_stat, ClientStatRequest::reserved, ClientStatRequest::dlen, fUrl, XrdClientUrlInfo::File, XrdOucString::length(), XrdClientConn::SendGenCommand(), XrdOucString::c_str(), XrdClientConn::LastServerResp, ServerResponseHeader::status, Info, XrdClientDebug::kHIDEBUG, XrdClientStatInfo::id, XrdClientStatInfo::size, XrdClientStatInfo::flags, and XrdClientStatInfo::modtime.

Referenced by Read(), ReadV(), Copy(), Read_Async(), doCp_xrd2xrd(), doCp_xrd2loc(), XrdPosixXrootd::Open(), XrdPosixXrootd::OpenCB(), and main().

bool XrdClient::Sync

(

)

References IsOpen_wait(), Error, FALSE, XrdClientAbs::fConnModule, XrdClientConn::DoWriteHardCheckPoint(), XrdClientConn::SetOpTimeLimit(), EnvGetLong, NAME_TRANSACTIONTIMEOUT, XrdClientConn::SetSID(), ClientRequest::header, ClientRequestHdr::streamid, ClientRequest::sync, ClientSyncRequest::requestid, kXR_sync, ClientSyncRequest::fhandle, XrdClientAbs::fHandle, ClientSyncRequest::dlen, and XrdClientConn::SendGenCommand().

Referenced by Stat(), and XrdPosixFile::Sync().

void XrdClient::TerminateOpenAttempt

(

)

[private]

References fOpenProgCnd, XrdSysCondVar::Lock(), fOpenPars, XrdClientOpenInfo::inprogress, XrdSysCondVar::Broadcast(), XrdSysCondVar::UnLock(), fConcOpenSem, and XrdSysSemWait::Post().

Referenced by TryOpen(), and ProcessUnsolicitedMsg().

bool XrdClient::Truncate

(

long long

len

)

References IsOpen_wait(), Info, XrdClientDebug::kUSERDEBUG, XrdClientAbs::fConnModule, XrdClientConn::SetSID(), ClientRequest::header, ClientRequestHdr::streamid, ClientRequest::truncate, ClientTruncateRequest::requestid, kXR_truncate, ClientTruncateRequest::fhandle, XrdClientAbs::fHandle, ClientTruncateRequest::offset, XrdClientConn::SendGenCommand(), FALSE, fStatInfo, XrdClientStatInfo::stated, and XrdClientStatInfo::size.

Referenced by XrdPosixFile::Trunc().

bool XrdClient::TryOpen	(	kXR_unt16	mode,
		kXR_unt16	options,
		bool	doitparallel
	)		[private]

References fOpenPars, XrdClientOpenInfo::inprogress, DFLT_MAXCONCURRENTOPENS, fConcOpenSem, XrdSysSemWait::Wait(), fOpenerTh, FileOpenerThread, XrdClientThread::Run(), Error, XrdSysSemWait::Post(), LowOpen(), fUrl, XrdClientUrlInfo::File, XrdOucString::c_str(), XrdClientMStream::EstablishParallelStreams(), XrdClientAbs::fConnModule, XrdClientConn::IsConnected(), XrdClientOpenInfo::opened, TerminateOpenAttempt(), XrdClientConn::GetMetaUrl(), XrdClientConn::GetCurrentUrl(), XrdClientUrlInfo::Host, XrdClientUrlInfo::Port, XrdClientConn::LastServerError, ServerResponseBody_Error::errnum, kXR_NotAuthorized, XrdClientConn::GetRedirCnt(), XrdClientConn::GetMaxRedirCnt(), XrdClientConn::GetLBSUrl(), fExcludedHosts, Info, XrdClientDebug::kUSERDEBUG, XrdClientConn::Disconnect(), XrdClientConn::GoToMetaManager(), kOK, kXR_refresh, XrdClientConn::LastServerResp, ServerResponseHeader::status, kXR_error, kXR_NotFound, FALSE, XrdClientConn::GoToAnotherServer(), and TRUE.

Referenced by FileOpenerThread(), Open(), and OpenFileWhenRedirected().

bool XrdClient::UseCache

(

bool

u = TRUE

)

References fUseCache, XrdClientAbs::fConnModule, and XrdClientConn::GetCacheInfo().

void XrdClient::WaitForNewAsyncData

(

)

[private]

References fReadWaitData, and XrdSysCondVar::Wait().

bool XrdClient::Write	(	const void *	buf,
		long long	offset,
		int	len
	)

References IsOpen_wait(), Error, FALSE, XrdClientAbs::fConnModule, XrdClientConn::SetOpTimeLimit(), EnvGetLong, NAME_TRANSACTIONTIMEOUT, fCounters, XrdClientCounters::WrittenBytes, XrdClientCounters::WriteRequests, XrdClientConn::SetSID(), ClientRequest::header, ClientRequestHdr::streamid, ClientRequest::write, ClientWriteRequest::requestid, kXR_write, ClientWriteRequest::fhandle, XrdClientAbs::fHandle, fUseCache, ClientWriteRequest::pathid, ClientWriteRequest::dlen, ClientWriteRequest::offset, XrdClientConn::SendGenCommand(), fStatInfo, XrdClientStatInfo::stated, XrdClientStatInfo::size, xrdmax, XrdClientConn::DoWriteSoftCheckPoint(), XrdClientConn::RemoveDataFromCache(), XrdClientMStream::SplitReadRequest(), XrdClientVector::GetSize(), XrdClientConn::WriteToServer_Async(), kOK, kNOMORESTREAMS, and XrdClientConn::DoWriteHardCheckPoint().

Referenced by main(), XrdCnsLogClient::Archive(), and XrdPosixFile::Write().

---

Friends And Related Function Documentation

void* FileOpenerThread	(	void *	arg,
		XrdClientThread *	thr
	)		[friend]

Referenced by TryOpen().

---

Member Data Documentation

XrdSysSemWait XrdClient::fConcOpenSem [static, private]

Referenced by TerminateOpenAttempt(), and TryOpen().

XrdClientCounters XrdClient::fCounters [protected]

Referenced by XrdClient(), Read(), ReadV(), Write(), Read_Async(), and GetCounters().

std::vector<std::string> XrdClient::fExcludedHosts

Referenced by TryOpen().

XrdOucString XrdClient::fInitialUrl [private]

Referenced by XrdClient(), and Open().

XrdClientThread* XrdClient::fOpenerTh [private]

Referenced by XrdClient(), ~XrdClient(), IsOpen_wait(), and TryOpen().

struct XrdClientOpenInfo XrdClient::fOpenPars [private]

Referenced by FileOpenerThread(), XrdClient(), IsOpen_inprogress(), IsOpen_wait(), TerminateOpenAttempt(), Open(), TryOpen(), LowOpen(), Close(), OpenFileWhenRedirected(), IsOpenedForWrite(), CanRedirOnError(), and IsOpen().

XrdSysCondVar* XrdClient::fOpenProgCnd [private]

Referenced by XrdClient(), ~XrdClient(), IsOpen_inprogress(), IsOpen_wait(), and TerminateOpenAttempt().

bool XrdClient::fOpenWithRefresh [private]

XrdClientReadAheadMgr* XrdClient::fReadAheadMgr [private]

Referenced by XrdClient(), ~XrdClient(), Read(), SetCacheParameters(), and SetReadAheadStrategy().

long XrdClient::fReadTrimBlockSize [private]

Referenced by XrdClient(), Read(), and SetBlockReadTrimming().

XrdSysCondVar* XrdClient::fReadWaitData [private]

Referenced by XrdClient(), ~XrdClient(), Read(), ProcessUnsolicitedMsg(), and WaitForNewAsyncData().

struct XrdClientStatInfo XrdClient::fStatInfo [private]

Referenced by XrdClient(), ReadV(), Write(), LowOpen(), Stat(), Copy(), Read_Async(), and Truncate().

XrdClientUrlInfo XrdClient::fUrl [private]

Referenced by Open(), TryOpen(), Stat(), and ProcessUnsolicitedMsg().

bool XrdClient::fUseCache [private]

Referenced by XrdClient(), Read(), Write(), Read_Async(), and UseCache().

---

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

• XrdClient.hh
• XrdClient.cc