XrdClient Class Reference

#include <XrdClient.hh>

Inheritance diagram for XrdClient:

XrdClientAbs XrdClientAbsUnsolMsgHandler 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)

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

XrdClientOpenInfo fOpenPars
XrdSysCondVar * fOpenProgCnd
XrdClientThread * fOpenerTh
bool fOpenWithRefresh
XrdSysCondVar * fReadWaitData
XrdClientStatInfo fStatInfo
long fReadTrimBlockSize
bool fUseCache
XrdOucString fInitialUrl
XrdClientUrlInfo fUrl
XrdClientReadAheadMgr * fReadAheadMgr

Static Private Attributes

static XrdSysSemWait fConcOpenSem

Friends

void * FileOpenerThread (void *, XrdClientThread *)

Detailed Description

Definition at line 98 of file XrdClient.hh.

Constructor & Destructor Documentation

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

Definition at line 63 of file XrdClient.cc.

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(), and XrdClientAbs::XrdClientConn.

XrdClient::~XrdClient (  )  [virtual]

Definition at line 114 of file XrdClient.cc.

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

Member Function Documentation

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

Definition at line 946 of file XrdClient.cc.

References XrdOucString::c_str(), DFLT_MAXCONCURRENTOPENS, XrdClientConn::Disconnect(), ServerResponseBody_Error::errnum, Error, XrdClientMStream::EstablishParallelStreams(), FALSE, fConcOpenSem, XrdClientAbs::fConnModule, XrdClientUrlInfo::File, FileOpenerThread, fOpenerTh, fOpenPars, fUrl, XrdClientConn::GetCurrentUrl(), XrdClientConn::GetLBSUrl(), XrdClientConn::GoToAnotherServer(), XrdClientUrlInfo::Host, i, Info, XrdClientOpenInfo::inprogress, kOK, XrdClientDebug::kUSERDEBUG, kXR_error, 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::LowOpen ( const char *  file,
kXR_unt16  mode,
kXR_unt16  options,
char *  additionalquery = 0 
) [private]

Definition at line 1066 of file XrdClient.cc.

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

Referenced by TryOpen().

void XrdClient::TerminateOpenAttempt (  )  [private]

Definition at line 189 of file XrdClient.cc.

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

Referenced by ProcessUnsolicitedMsg(), and TryOpen().

void XrdClient::WaitForNewAsyncData (  )  [private]

Definition at line 1772 of file XrdClient.cc.

References fReadWaitData, and XrdSysCondVar::Wait().

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

bool XrdClient::IsOpenedForWrite (  )  [inline, private]

Definition at line 148 of file XrdClient.hh.

References fOpenPars, kXR_open_read, and XrdClientOpenInfo::options.

Referenced by CanRedirOnError(), and Close().

void XrdClient::PrintCounters (  )  [private]

Definition at line 1895 of file XrdClient.cc.

References xmlio::cnt, DebugLevel, GetCounters(), and XrdClientDebug::kUSERDEBUG.

Referenced by ~XrdClient().

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

Implements XrdClientAbs.

Definition at line 1240 of file XrdClient.cc.

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().

virtual bool XrdClient::CanRedirOnError (  )  [inline, protected, virtual]

Implements XrdClientAbs.

Definition at line 167 of file XrdClient.hh.

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

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

Implements XrdClientAbsUnsolMsgHandler.

Definition at line 1322 of file XrdClient.cc.

References ServerResponseBody_Attn::actnum, XrdSysCondVar::Broadcast(), XrdOucString::c_str(), ConnectionManager, XrdClientMessage::DataLen(), ClientRequestHdr::dlen, ClientWriteRequest::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(), ServerResponseBody_Attn_asyncrd::host, XrdClientUrlInfo::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, ServerResponseBody_Attn_asyncrd::port, XrdClientUrlInfo::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_asyncdi::wsec, ServerResponseBody_Attn_asyncwt::wsec, and xrdmin.

bool XrdClient::Close (  ) 

Definition at line 1203 of file XrdClient.cc.

References XrdClientConn::DoWriteHardCheckPoint(), EnvGetLong, FALSE, XrdClientAbs::fConnModule, XrdClientAbs::fHandle, fOpenPars, Info, IsOpen_wait(), IsOpenedForWrite(), XrdClientDebug::kUSERDEBUG, kXR_close, NAME_TRANSACTIONTIMEOUT, XrdClientOpenInfo::opened, XrdClientConn::SendGenCommand(), XrdClientConn::SetOpTimeLimit(), XrdClientConn::SetSID(), and TRUE.

Referenced by TXNetFile::Close(), doCp_xrd2loc(), main(), TXNetFile::Open(), TXNetFile::SysClose(), ~XrdClient(), and XrdPosixFile::~XrdPosixFile().

bool XrdClient::Sync (  ) 

Definition at line 912 of file XrdClient.cc.

References XrdClientConn::DoWriteHardCheckPoint(), EnvGetLong, Error, FALSE, XrdClientAbs::fConnModule, XrdClientAbs::fHandle, IsOpen_wait(), kXR_sync, NAME_TRANSACTIONTIMEOUT, XrdClientConn::SendGenCommand(), XrdClientConn::SetOpTimeLimit(), and XrdClientConn::SetSID().

Referenced by TXNetFile::Flush(), and Stat().

bool XrdClient::Copy ( const char *  localpath  ) 

Definition at line 1293 of file XrdClient.cc.

References buf, close, Error, FALSE, free(), fStatInfo, IsOpen_wait(), malloc(), 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 
)

Definition at line 1845 of file XrdClient.cc.

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

Referenced by TXNetFile::GetBytesToPrefetch(), TXNetFile::Print(), and TXNetFile::SynchronizeCacheSize().

bool XrdClient::GetCounters ( XrdClientCounters *  cnt  ) 

Definition at line 1884 of file XrdClient.cc.

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

Referenced by PrintCounters().

bool XrdClient::IsOpen (  )  [inline]

Definition at line 225 of file XrdClient.hh.

References fOpenPars, and XrdClientOpenInfo::opened.

Referenced by BWMToken_WaitFor(), TXNetFile::GetAsyncOpenStatus(), and TXNetFile::IsOpen().

bool XrdClient::IsOpen_inprogress (  ) 

Definition at line 144 of file XrdClient.cc.

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

Referenced by TXNetFile::GetAsyncOpenStatus().

bool XrdClient::IsOpen_wait (  )  [virtual]

Reimplemented from XrdClientAbs.

Definition at line 159 of file XrdClient.cc.

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

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

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

Definition at line 202 of file XrdClient.cc.

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::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(), seed, XrdClientConn::SetOpTimeLimit(), XrdClientConn::SetUrl(), XrdClientUrlSet::Size(), sleep, TRUE, and TryOpen().

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

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

Definition at line 412 of file XrdClient.cc.

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

Referenced by Copy(), main(), TXNetFile::ReadBuffer(), ReaderThread_xrd(), ReaderThread_xrd_xtreme(), and ReadV().

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

Definition at line 667 of file XrdClient.cc.

References XrdClientConn::CacheWillFit(), EnvGetLong, Error, XrdClientAbs::fConnModule, fCounters, XrdClientAbs::fHandle, fStatInfo, XrdClientMStream::GetGoodSplitParameters(), XrdClientConn::GetParallelStreamToUse(), XrdClientConn::GetServerProtocol(), i, if(), Info, IsOpen_wait(), XrdClientDebug::kHIDEBUG, XrdClientDebug::kUSERDEBUG, len, 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(), and TXNetFile::ReadBuffers().

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

Definition at line 1658 of file XrdClient.cc.

References c, Error, XrdClientAbs::fConnModule, fCounters, XrdClientAbs::fHandle, fStatInfo, fUseCache, XrdClientVector< T >::GetSize(), i, Info, IsOpen_wait(), kGENERICERR, XrdClientDebug::kHIDEBUG, kOK, kXR_read, ok, XrdClientCounters::ReadAsyncBytes, XrdClientCounters::ReadAsyncRequests, XrdClientStatInfo::size, XrdClientMStream::SplitReadRequest(), Stat(), XrdClientConn::SubmitPlaceholderToCache(), and xrdmin.

Referenced by main(), Read(), TXNetFile::ReadBufferAsync(), ReaderThread_xrd_xtreme(), and ReadV().

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

Definition at line 1147 of file XrdClient.cc.

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, ok, 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(), Read(), Read_Async(), ReadV(), and TXNetFile::SysStat().

bool XrdClient::UseCache ( bool  u = TRUE  ) 

Definition at line 1780 of file XrdClient.cc.

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

Referenced by TXNetFile::Init(), and TXNetFile::SynchronizeCacheSize().

void XrdClient::RemoveAllDataFromCache (  )  [inline]

Definition at line 262 of file XrdClient.hh.

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

Referenced by main(), and TXNetFile::ResetCache().

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

Definition at line 268 of file XrdClient.hh.

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

Referenced by ReaderThread_xrd(), and ReaderThread_xrd_xtreme().

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

Definition at line 1809 of file XrdClient.cc.

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

Referenced by TXNetFile::CreateXClient(), ReaderThread_xrd_xtreme(), ReadV(), TXNetFile::SynchronizeCacheSize(), and XrdClient().

void XrdClient::SetReadAheadStrategy ( int  strategy  ) 

Definition at line 1819 of file XrdClient.cc.

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

Referenced by TXNetFile::CreateXClient(), and XrdClient().

void XrdClient::SetBlockReadTrimming ( int  blocksize  ) 

Definition at line 1836 of file XrdClient.cc.

References fReadTrimBlockSize.

Referenced by TXNetFile::CreateXClient(), and XrdClient().

bool XrdClient::Truncate ( long long  len  ) 

Definition at line 1742 of file XrdClient.cc.

References FALSE, XrdClientAbs::fConnModule, XrdClientAbs::fHandle, fStatInfo, Info, IsOpen_wait(), XrdClientDebug::kUSERDEBUG, kXR_truncate, ok, XrdClientConn::SendGenCommand(), XrdClientConn::SetSID(), XrdClientStatInfo::size, and XrdClientStatInfo::stated.

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

Definition at line 817 of file XrdClient.cc.

References b, xmlio::cnt, XrdClientConn::DoWriteHardCheckPoint(), XrdClientConn::DoWriteSoftCheckPoint(), EnvGetLong, Error, FALSE, XrdClientAbs::fConnModule, fCounters, XrdClientAbs::fHandle, fStatInfo, fUseCache, XrdClientVector< T >::GetSize(), i, IsOpen_wait(), kNOMORESTREAMS, kOK, kXR_write, NAME_TRANSACTIONTIMEOUT, XrdClientConn::RemoveDataFromCache(), XrdClientConn::SendGenCommand(), XrdClientConn::SetOpTimeLimit(), XrdClientConn::SetSID(), XrdClientStatInfo::size, XrdClientMStream::SplitReadRequest(), XrdClientStatInfo::stated, XrdClientCounters::WriteRequests, XrdClientConn::WriteToServer_Async(), XrdClientCounters::WrittenBytes, and xrdmax.

Referenced by XrdCnsLogClient::Archive(), main(), and TXNetFile::WriteBuffer().

Friends And Related Function Documentation

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

Definition at line 47 of file XrdClient.cc.

Referenced by TryOpen().

Member Data Documentation

struct XrdClientOpenInfo XrdClient::fOpenPars [private]

Definition at line 104 of file XrdClient.hh.

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

XrdSysCondVar* XrdClient::fOpenProgCnd [private]

Definition at line 109 of file XrdClient.hh.

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

XrdClientThread* XrdClient::fOpenerTh [private]

Definition at line 112 of file XrdClient.hh.

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

XrdSysSemWait XrdClient::fConcOpenSem [static, private]

Definition at line 115 of file XrdClient.hh.

Referenced by TerminateOpenAttempt(), and TryOpen().

bool XrdClient::fOpenWithRefresh [private]

Definition at line 117 of file XrdClient.hh.

XrdSysCondVar* XrdClient::fReadWaitData [private]

Definition at line 119 of file XrdClient.hh.

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

struct XrdClientStatInfo XrdClient::fStatInfo [private]

Definition at line 121 of file XrdClient.hh.

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

long XrdClient::fReadTrimBlockSize [private]

Definition at line 123 of file XrdClient.hh.

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

bool XrdClient::fUseCache [private]

Definition at line 125 of file XrdClient.hh.

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

XrdOucString XrdClient::fInitialUrl [private]

Definition at line 127 of file XrdClient.hh.

Referenced by Open(), and XrdClient().

XrdClientUrlInfo XrdClient::fUrl [private]

Definition at line 128 of file XrdClient.hh.

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

XrdClientReadAheadMgr* XrdClient::fReadAheadMgr [private]

Definition at line 157 of file XrdClient.hh.

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

XrdClientCounters XrdClient::fCounters [protected]

Definition at line 162 of file XrdClient.hh.

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

The documentation for this class was generated from the following files:
Generated on Tue Jul 5 16:50:13 2011 for ROOT_528-00b_version by  doxygen 1.5.1