xrootd
Public Member Functions | Public Attributes | Protected Member Functions | Protected Attributes | Private Member Functions | Private Attributes | Static Private Attributes | Friends | List of all members
XrdClient Class Reference

#include <XrdClient.hh>

Inheritance diagram for XrdClient:
Inheritance graph
[legend]
Collaboration diagram for XrdClient:
Collaboration graph
[legend]

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)
 
XrdClientConnGetClientConn () const
 
XrdClientUrlInfo GetCurrentUrl ()
 
struct ServerResponseHeaderLastServerResp ()
 
struct ServerResponseBody_ErrorLastServerError ()
 
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
XrdClientConnfConnModule
 
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
 
XrdSysCondVarfOpenProgCnd
 
XrdClientThread * fOpenerTh
 
bool fOpenWithRefresh
 
XrdSysCondVarfReadWaitData
 
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 
)
virtual XrdClient::~XrdClient ( )
virtual

Member Function Documentation

virtual bool XrdClient::CanRedirOnError ( )
inlineprotectedvirtual
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)
bool XrdClient::IsOpen ( )
inline
bool XrdClient::IsOpen_inprogress ( )
bool XrdClient::IsOpen_wait ( )
virtual

Reimplemented from XrdClientAbs.

bool XrdClient::IsOpenedForWrite ( )
inlineprivate
bool XrdClient::LowOpen ( const char *  file,
kXR_unt16  mode,
kXR_unt16  options,
char *  additionalquery = 0 
)
private
bool XrdClient::Open ( kXR_unt16  mode,
kXR_unt16  options,
bool  doitparallel = true 
)
virtual bool XrdClient::OpenFileWhenRedirected ( char *  newfhandle,
bool &  wasopen 
)
protectedvirtual

Implements XrdClientAbs.

void XrdClient::PrintCounters ( )
private
UnsolRespProcResult XrdClient::ProcessUnsolicitedMsg ( XrdClientUnsolMsgSender sender,
XrdClientMessage *  unsolmsg 
)
virtual
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 
)
kXR_int64 XrdClient::ReadVEach ( char *  buf,
kXR_int64 offsets,
int *  lens,
int &  nbuf 
)
private
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 ( )
void XrdClient::TerminateOpenAttempt ( )
private
bool XrdClient::Truncate ( long long  len)
bool XrdClient::TryOpen ( kXR_unt16  mode,
kXR_unt16  options,
bool  doitparallel 
)
private
bool XrdClient::UseCache ( bool  u = true)
void XrdClient::WaitForNewAsyncData ( )
private
bool XrdClient::Write ( const void *  buf,
long long  offset,
int  len 
)

Friends And Related Function Documentation

void* FileOpenerThread ( void *  ,
XrdClientThread *   
)
friend

Member Data Documentation

XrdSysSemWait XrdClient::fConcOpenSem
staticprivate
XrdClientCounters XrdClient::fCounters
protected
std::vector<std::string> XrdClient::fExcludedHosts
XrdOucString XrdClient::fInitialUrl
private
XrdClientThread* XrdClient::fOpenerTh
private
struct XrdClientOpenInfo XrdClient::fOpenPars
private
XrdSysCondVar* XrdClient::fOpenProgCnd
private
bool XrdClient::fOpenWithRefresh
private
XrdClientReadAheadMgr* XrdClient::fReadAheadMgr
private
long XrdClient::fReadTrimBlockSize
private
XrdSysCondVar* XrdClient::fReadWaitData
private
struct XrdClientStatInfo XrdClient::fStatInfo
private
XrdClientUrlInfo XrdClient::fUrl
private
bool XrdClient::fUseCache
private

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