xrootd
|
#include <XrdClient.hh>
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 | |
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 *) |
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] |
virtual bool XrdClient::CanRedirOnError | ( | ) | [inline, protected, virtual] |
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(), main(), ~XrdClient(), and XrdPosixFile::~XrdPosixFile().
bool XrdClient::Copy | ( | const char * | localpath | ) |
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 | ( | ) | [inline, private] |
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(), ServerResponseHeader::dlen, ClientOpenRequest::dlen, Error, XrdClientAbs::fConnModule, ServerResponseBody_Open::fhandle, XrdClientAbs::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().
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(), sleep, 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 | ||
) | [protected, virtual] |
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(), 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, ClientWriteRequest::offset, ClientReadRequest::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_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, ServerResponseHeader::dlen, ClientReadRequest::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(), XrdPosixXrootd::Pread(), XrdPosixXrootd::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 | ( | ) | [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, 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(), 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 XrdPosixXrootd::Fsync(), and Stat().
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 XrdPosixXrootd::Ftruncate().
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, Info, XrdClientOpenInfo::inprogress, XrdClientConn::IsConnected(), 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::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(), XrdPosixXrootd::Pwrite(), and XrdPosixXrootd::Write().
void* FileOpenerThread | ( | void * | arg, |
XrdClientThread * | thr | ||
) | [friend] |
Referenced by TryOpen().
XrdSysSemWait XrdClient::fConcOpenSem [static, private] |
Referenced by TerminateOpenAttempt(), and TryOpen().
XrdClientCounters XrdClient::fCounters [protected] |
Referenced by GetCounters(), Read(), Read_Async(), ReadV(), Write(), and XrdClient().
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] |
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().