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 Member Functions inherited from XrdClientAbs
	XrdClientAbs (XrdClientCallback *XrdCcb=0, void *XrdCcbArg=0)
void	SetParm (const char *parm, int val)
void	SetParm (const char *parm, double val)
XrdClientConn *	GetClientConn () const
XrdClientUrlInfo	GetCurrentUrl ()
struct ServerResponseHeader *	LastServerResp ()
struct ServerResponseBody_Error *	LastServerError ()
bool	Query (kXR_int16 ReqCode, const kXR_char *Args, kXR_char *Resp, kXR_int32 MaxResplen)
bool	Query (kXR_int16 ReqCode, const kXR_char *Args, kXR_char **Resp, kXR_int32 MaxResplen)
Public Member Functions inherited from XrdClientAbsUnsolMsgHandler
virtual	~XrdClientAbsUnsolMsgHandler ()

Public Attributes
std::vector< std::string >	fExcludedHosts

Protected Member Functions
virtual bool	OpenFileWhenRedirected (char *newfhandle, bool &wasopen)
virtual bool	CanRedirOnError ()

Protected Attributes
XrdClientCounters	fCounters
Protected Attributes inherited from XrdClientAbs
XrdClientConn *	fConnModule
char	fHandle [4]
XrdClientCallback *	fXrdCcb
void *	fXrdCcbArg

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

XrdClient::~XrdClient ( )

virtual

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

---

Member Function Documentation

virtual bool XrdClient::CanRedirOnError ( )

inlineprotectedvirtual

Implements XrdClientAbs.

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

bool XrdClient::Close

(

)

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

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

bool XrdClient::Copy

(

const char *

localpath

)

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

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::ReadHits, XrdClientCounters::ReadMisses, XrdClientCounters::ReadMissRate, and XrdClientCounters::ReadRequests.

Referenced by PrintCounters().

bool XrdClient::IsOpen ( )

inline

References fOpenPars, and XrdClientOpenInfo::opened.

Referenced by BWMToken_WaitFor().

bool XrdClient::IsOpen_inprogress

(

)

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

Referenced by main().

bool XrdClient::IsOpen_wait ( )

virtual

Reimplemented from XrdClientAbs.

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

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

bool XrdClient::IsOpenedForWrite ( )

inlineprivate

References fOpenPars, kXR_open_read, and XrdClientOpenInfo::options.

Referenced by CanRedirOnError(), and Close().

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

private

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

Referenced by TryOpen().

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

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

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

bool XrdClient::OpenFileWhenRedirected ( char *  newfhandle, bool &  wasopen  )

protectedvirtual

Implements XrdClientAbs.

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

void XrdClient::PrintCounters ( )

private

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

Referenced by ~XrdClient().

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

virtual

Implements XrdClientAbsUnsolMsgHandler.

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

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

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

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

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

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

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

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

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

Referenced by main().

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

private

void XrdClient::RemoveAllDataFromCache

(

)

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

Referenced by main().

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

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, fReadAheadMgr, XrdClientConn::SetCacheRmPolicy(), XrdClientConn::SetCacheSize(), and XrdClientReadAheadMgr::SetRASize().

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

void XrdClient::SetReadAheadStrategy

(

int

strategy

)

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

Referenced by XrdClient().

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

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

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

bool XrdClient::Sync

(

)

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

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

void XrdClient::TerminateOpenAttempt ( )

private

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

Referenced by ProcessUnsolicitedMsg(), and TryOpen().

bool XrdClient::Truncate

(

long long

len

)

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

Referenced by XrdPosixFile::Trunc().

bool XrdClient::TryOpen ( kXR_unt16  mode, kXR_unt16  options, bool  doitparallel  )

private

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

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

bool XrdClient::UseCache

(

bool

u = true

)

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

void XrdClient::WaitForNewAsyncData ( )

private

References fReadWaitData, and XrdSysCondVar::Wait().

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

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

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

---

Friends And Related Function Documentation

void* FileOpenerThread ( void *  arg, XrdClientThread *  thr  )

friend

Referenced by TryOpen().

---

Member Data Documentation

XrdSysSemWait XrdClient::fConcOpenSem

staticprivate

Referenced by TerminateOpenAttempt(), and TryOpen().

XrdClientCounters XrdClient::fCounters

protected

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

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

Referenced by TryOpen().

XrdOucString XrdClient::fInitialUrl

private

Referenced by Open(), and XrdClient().

XrdClientThread* XrdClient::fOpenerTh

private

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

struct XrdClientOpenInfo XrdClient::fOpenPars

private

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

XrdSysCondVar* XrdClient::fOpenProgCnd

private

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

bool XrdClient::fOpenWithRefresh

private

XrdClientReadAheadMgr* XrdClient::fReadAheadMgr

private

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

long XrdClient::fReadTrimBlockSize

private

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

XrdSysCondVar* XrdClient::fReadWaitData

private

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

struct XrdClientStatInfo XrdClient::fStatInfo

private

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

XrdClientUrlInfo XrdClient::fUrl

private

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

bool XrdClient::fUseCache

private

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

---

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

• XrdClient.hh
• XrdClient.cc