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) |
![]() | |
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) |
![]() | |
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 |
![]() | |
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 *) |
XrdClient::XrdClient | ( | const char * | url, |
XrdClientCallback * | XrdCcb = 0 , |
||
void * | XrdCcbArg = 0 |
||
) |
|
virtual |
|
inlineprotectedvirtual |
Implements XrdClientAbs.
References XrdClientStatInfo::size.
bool XrdClient::Close | ( | ) |
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 | ||
) |
bool XrdClient::GetCounters | ( | XrdClientCounters * | cnt | ) |
|
inline |
References XrdClientOpenInfo::mode, and XrdClientOpenInfo::options.
bool XrdClient::IsOpen_inprogress | ( | ) |
|
virtual |
Reimplemented from XrdClientAbs.
|
inlineprivate |
References kXR_open_read.
|
private |
|
protectedvirtual |
Implements XrdClientAbs.
|
private |
|
virtual |
Implements XrdClientAbsUnsolMsgHandler.
int XrdClient::Read | ( | void * | buf, |
long long | offset, | ||
int | len | ||
) |
XReqErrorType XrdClient::Read_Async | ( | long long | offset, |
int | len, | ||
bool | updatecounters = true |
||
) |
kXR_int64 XrdClient::ReadV | ( | char * | buf, |
long long * | offsets, | ||
int * | lens, | ||
int | nbuf | ||
) |
void XrdClient::RemoveAllDataFromCache | ( | ) |
void XrdClient::RemoveDataFromCache | ( | long long | begin_offs, |
long long | end_offs, | ||
bool | remove_overlapped = false |
||
) |
void XrdClient::SetBlockReadTrimming | ( | int | blocksize | ) |
void XrdClient::SetCacheParameters | ( | int | CacheSize, |
int | ReadAheadSize, | ||
int | RmPolicy | ||
) |
void XrdClient::SetReadAheadStrategy | ( | int | strategy | ) |
bool XrdClient::Stat | ( | struct XrdClientStatInfo * | stinfo, |
bool | force = false |
||
) |
bool XrdClient::Sync | ( | ) |
|
private |
bool XrdClient::Truncate | ( | long long | len | ) |
bool XrdClient::UseCache | ( | bool | u = true | ) |
|
private |
bool XrdClient::Write | ( | const void * | buf, |
long long | offset, | ||
int | len | ||
) |
|
friend |
|
staticprivate |
|
protected |
std::vector<std::string> XrdClient::fExcludedHosts |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |