95virtual int Close(
long long *retsz=0);
99int Fctl(
int cmd,
int alen,
const char *args,
char **resp=0);
109ssize_t
Read(
void *, off_t,
size_t);
113ssize_t
Write(
const void *, off_t,
size_t);
125int Open_ufs(
const char *,
int,
int,
unsigned long long);
144class XrdOssCreateInfo;
151struct XrdVersionInfo;
173int Lfn2Pfn(
const char *Path,
char *buff,
int blen);
174const char *
Lfn2Pfn(
const char *Path,
char *buff,
int blen,
int &rc);
178int Reloc(
const char *tident,
const char *path,
179 const char *cgName,
const char *anchor=0);
184int Stage(
const char *,
const char *,
XrdOucEnv &,
int, mode_t,
unsigned long long );
188int StatFS(
const char *path,
unsigned long long &Opt,
189 long long &fSize,
long long &fSpace);
321int SetFattr(XrdOssCreateInfo &crInfo,
int datfd, time_t mtime);
328time_t
HasFile(
const char *fn,
const char *sfx, time_t *mTime=0);
341 unsigned long long &Fv,
int noMSS);
361 const char *grp,
bool isAsgn);
373 const char *cmd,
const char *arg1=0,
const char *arg2=0);
387#define Check_RO(act, flags, path, opname) \
388 XRDEXP_REMOTE & (flags = PathOpts(path)); \
389 if (flags & XRDEXP_NOTRW) \
390 return OssEroute.Emsg(#act, -XRDOSS_E8005, opname, path)
392#define Check_RW(act, path, opname) \
393 if (PathOpts(path) & XRDEXP_NOTRW) \
394 return OssEroute.Emsg(#act, -XRDOSS_E8005, opname, path)
int(* XrdOssStatInfo2_t)(const char *path, struct stat *buff, int opts, XrdOucEnv *envP, const char *lfn)
Definition XrdOssStatInfo.hh:93
int(* XrdOssStatInfo_t)(const char *path, struct stat *buff, int opts, XrdOucEnv *envP)
Definition XrdOssStatInfo.hh:90
#define XRDOSS_HASNAIO
Definition XrdOss.hh:480
#define XRDEXP_REMOTE
Definition XrdOucExport.hh:85
#define stat(a, b)
Definition XrdPosix.hh:96
Definition XrdFrcProxy.hh:40
Definition XrdOssCache.hh:133
Definition XrdOssCache.hh:183
Definition XrdOssCache.hh:79
static const uint16_t DF_isFile
Object is for a file.
Definition XrdOss.hh:393
int fd
Definition XrdOss.hh:455
static const uint16_t DF_isDir
Object is for a directory.
Definition XrdOss.hh:392
Definition XrdOssApi.hh:52
void * mssfd
Definition XrdOssApi.hh:69
int StatRet(struct stat *buff)
int Opendir(const char *, XrdOucEnv &)
XrdOssDir(const char *tid, DIR *dP=0)
Definition XrdOssApi.hh:61
bool isopen
Definition XrdOssApi.hh:72
struct stat * Stat
Definition XrdOssApi.hh:70
DIR * lclfd
Definition XrdOssApi.hh:68
~XrdOssDir()
Definition XrdOssApi.hh:66
static const int noCheck
Definition XrdOssApi.hh:75
static const int noDread
Definition XrdOssApi.hh:76
int getFD()
Definition XrdOssApi.hh:58
int Readdir(char *buff, int blen)
bool ateof
Definition XrdOssApi.hh:71
int Close(long long *retsz=0)
unsigned char dOpts
Definition XrdOssApi.hh:73
static const int isStage
Definition XrdOssApi.hh:74
Definition XrdOssApi.hh:89
int Write(XrdSfsAio *aiop)
oocx_CXFile * cxobj
Definition XrdOssApi.hh:128
virtual ~XrdOssFile()
Definition XrdOssApi.hh:122
virtual int Close(long long *retsz=0)
int Open_ufs(const char *, int, int, unsigned long long)
int isCompressed(char *cxidp=0)
virtual int Open(const char *, int, mode_t, XrdOucEnv &)
ssize_t Read(off_t, size_t)
int Fctl(int cmd, int alen, const char *args, char **resp=0)
int Read(XrdSfsAio *aiop)
long long FSize
Definition XrdOssApi.hh:131
off_t getMmap(void **addr)
ssize_t Read(void *, off_t, size_t)
XrdOssMioFile * mmFile
Definition XrdOssApi.hh:130
int Fsync(XrdSfsAio *aiop)
int rawio
Definition XrdOssApi.hh:132
static int AioFailure
Definition XrdOssApi.hh:127
XrdOssFile(const char *tid, int fdnum=-1)
Definition XrdOssApi.hh:117
void Flush()
Flush filesystem cached pages for this file (used for checksums).
ssize_t ReadV(XrdOucIOVec *readV, int)
int cxpgsz
Definition XrdOssApi.hh:133
XrdOssCache_FS * cacheP
Definition XrdOssApi.hh:129
int getFD()
Definition XrdOssApi.hh:105
char cxid[4]
Definition XrdOssApi.hh:134
int Ftruncate(unsigned long long)
ssize_t Write(const void *, off_t, size_t)
ssize_t ReadRaw(void *, off_t, size_t)
Definition XrdOssMioFile.hh:37
Definition XrdOssSpace.hh:36
Definition XrdOssStage.hh:50
Definition XrdOssApi.hh:154
void Config_Display(XrdSysError &)
int xstg(XrdOucStream &Config, XrdSysError &Eroute)
int badreqs
Definition XrdOssApi.hh:304
int GenRemotePath(const char *, char *)
int StageCreate
Definition XrdOssApi.hh:223
XrdOucPListAnchor SPList
Definition XrdOssApi.hh:249
char STT_DoN2N
Definition XrdOssApi.hh:270
char STT_V2
Definition XrdOssApi.hh:271
int ConfigXeq(char *, XrdOucStream &, XrdSysError &)
int FDLimit
Definition XrdOssApi.hh:243
int totreqs
Definition XrdOssApi.hh:303
int Configure(const char *, XrdSysError &, XrdOucEnv *envP)
char * LocalRoot
Definition XrdOssApi.hh:218
OssDPath * DPList
Definition XrdOssApi.hh:258
int StatLS(XrdOucEnv &env, const char *path, char *buff, int &blen)
int STT_PreOp
Definition XrdOssApi.hh:269
int MSS_Readdir(void *fd, char *buff, int blen)
int SetFattr(XrdOssCreateInfo &crInfo, int datfd, time_t mtime)
int MSS_Rename(const char *, const char *)
char * N2N_Parms
Definition XrdOssApi.hh:253
int xtrace(XrdOucStream &Config, XrdSysError &Eroute)
time_t HasFile(const char *fn, const char *sfx, time_t *mTime=0)
int StatVS(XrdOssVSInfo *sP, const char *sname=0, int updt=0)
short numCG
Definition XrdOssApi.hh:261
long long totbytes
Definition XrdOssApi.hh:302
long long minalloc
Definition XrdOssApi.hh:290
int StageAln[MaxArgs]
Definition XrdOssApi.hh:236
int IsRemote(const char *path)
Definition XrdOssApi.hh:171
int StatXP(const char *path, unsigned long long &attr, XrdOucEnv *Env=0)
int Init(XrdSysLogger *, const char *, XrdOucEnv *envP)
char * StageEvents
Definition XrdOssApi.hh:230
int Stage_RT(const char *, const char *, XrdOucEnv &, unsigned long long)
int getStats(char *buff, int blen)
int xstl(XrdOucStream &Config, XrdSysError &Eroute)
void ConfigSpace(XrdSysError &Eroute)
int Mkdir(const char *, mode_t mode, int mkpath=0, XrdOucEnv *eP=0)
int getCname(const char *path, struct stat *sbuff, char *cgbuff)
int StageRealTime
Definition XrdOssApi.hh:221
short prDepth
Definition XrdOssApi.hh:279
int FDFence
Definition XrdOssApi.hh:242
int Unlink(const char *, int Opts=0, XrdOucEnv *eP=0)
int ConfigStage(XrdSysError &Eroute)
int xusage(XrdOucStream &Config, XrdSysError &Eroute)
static char chkMmap
Definition XrdOssApi.hh:204
int StatXA(const char *path, char *buff, int &blen, XrdOucEnv *Env=0)
int xfrthreads
Definition XrdOssApi.hh:298
int OptFlags
Definition XrdOssApi.hh:247
int xspace(XrdOucStream &Config, XrdSysError &Eroute, int *isCD=0)
int StatFS(const char *path, unsigned long long &Opt, long long &fSize, long long &fSpace)
int isMSSC
Definition XrdOssApi.hh:239
void List_Path(const char *, const char *, unsigned long long, XrdSysError &)
char * QFile
Definition XrdOssApi.hh:310
int prBytes
Definition XrdOssApi.hh:277
int xmemf(XrdOucStream &Config, XrdSysError &Eroute)
int RenameLink3(char *cPath, char *old_path, char *new_path)
void * Stage_In(void *carg)
virtual int Stage(const char *, const char *, XrdOucEnv &, int, mode_t, unsigned long long)
int Alloc_Cache(XrdOssCreateInfo &, XrdOucEnv &)
char * ConfigFN
Definition XrdOssApi.hh:217
int StageFormat
Definition XrdOssApi.hh:224
int ovhalloc
Definition XrdOssApi.hh:291
void ConfigMio(XrdSysError &Eroute)
void ConfigStats(XrdSysError &Eroute)
virtual ~XrdOssSys()
Definition XrdOssApi.hh:285
char * StageAction
Definition XrdOssApi.hh:233
int xcachescan(XrdOucStream &Config, XrdSysError &Eroute)
char STT_DoARE
Definition XrdOssApi.hh:272
char * UDir
Definition XrdOssApi.hh:309
int StageActLen
Definition XrdOssApi.hh:232
short USync
Definition XrdOssApi.hh:313
int xfdlimit(XrdOucStream &Config, XrdSysError &Eroute)
int ConfigN2N(XrdSysError &Eroute, XrdOucEnv *envP)
XrdOucProg * StageProg
Definition XrdOssApi.hh:306
XrdOucName2Name * the_N2N
Definition XrdOssApi.hh:256
void ConfigStats(dev_t Devnum, char *lP)
int StatFS(const char *path, char *buff, int &blen, XrdOucEnv *Env=0)
short prQSize
Definition XrdOssApi.hh:280
const char * Lfn2Pfn(const char *Path, char *buff, int blen, int &rc)
char * StageArg[MaxArgs]
Definition XrdOssApi.hh:235
long long MaxSize
Definition XrdOssApi.hh:241
int StageAnum
Definition XrdOssApi.hh:237
unsigned long long PathOpts(const char *path)
Definition XrdOssApi.hh:177
int Mkpath(const char *, mode_t mode)
int prPSize
Definition XrdOssApi.hh:276
static const int MaxArgs
Definition XrdOssApi.hh:215
int GetFile(XrdOssStage_Req *req)
int Init(XrdSysLogger *lP, const char *cP)
Definition XrdOssApi.hh:170
int Trace
Definition XrdOssApi.hh:245
int Rename(const char *, const char *, XrdOucEnv *eP1=0, XrdOucEnv *eP2=0)
int GenLocalPath(const char *, char *)
int RSSTout
Definition XrdOssApi.hh:240
int prActive
Definition XrdOssApi.hh:278
int MSS_Unlink(const char *)
int xfrspeed
Definition XrdOssApi.hh:294
XrdOucName2Name * lcl_N2N
Definition XrdOssApi.hh:254
long long prPMask
Definition XrdOssApi.hh:275
long long prPBits
Definition XrdOssApi.hh:274
XrdOssStatInfo_t STT_Func
Definition XrdOssApi.hh:266
virtual XrdOssDF * newFile(const char *tident)
Definition XrdOssApi.hh:158
int xspaceBuild(OssSpaceConfig &sInfo, XrdSysError &Eroute)
int fuzalloc
Definition XrdOssApi.hh:292
int BreakLink(const char *local_path, struct stat &statbuff)
int cscanint
Definition XrdOssApi.hh:293
int StageAsync
Definition XrdOssApi.hh:222
int xprerd(XrdOucStream &Config, XrdSysError &Eroute)
int ConfigStatLib(XrdSysError &Eroute, XrdOucEnv *envP)
void ConfigSpace(const char *Lfn)
XrdOucProg * RSSProg
Definition XrdOssApi.hh:307
char * STT_Parms
Definition XrdOssApi.hh:264
virtual XrdOssDF * newDir(const char *tident)
Definition XrdOssApi.hh:156
XrdOssStatInfo2_t STT_Fund
Definition XrdOssApi.hh:267
long long pndbytes
Definition XrdOssApi.hh:300
int xspace(XrdOucStream &Config, XrdSysError &Eroute, const char *grp, bool isAsgn)
int xpath(XrdOucStream &Config, XrdSysError &Eroute)
static char tryMmap
Definition XrdOssApi.hh:203
int Lfn2Pfn(const char *Path, char *buff, int blen)
XrdVersionInfo * myVersion
Definition XrdOssApi.hh:282
char * N2N_Lib
Definition XrdOssApi.hh:252
int xfrovhd
Definition XrdOssApi.hh:295
int MSS_Stat(const char *, struct stat *buff=0)
int MSS_Remdir(const char *, const char *)
Definition XrdOssApi.hh:210
int xcache(XrdOucStream &Config, XrdSysError &Eroute)
long long stgbytes
Definition XrdOssApi.hh:301
int Find(XrdOssStage_Req *req, void *carg)
void ConfigSpath(XrdSysError &Eroute, const char *Pn, unsigned long long &Fv, int noMSS)
int Stat(const char *, struct stat *, int opts=0, XrdOucEnv *Env=0)
char * STT_Lib
Definition XrdOssApi.hh:263
int ConfigStageC(XrdSysError &Eroute)
int xfrFdln
Definition XrdOssApi.hh:312
XrdOucMsubs * StageSnd
Definition XrdOssApi.hh:227
int xxfr(XrdOucStream &Config, XrdSysError &Eroute)
short numDP
Definition XrdOssApi.hh:260
XrdFrcProxy * StageFrm
Definition XrdOssApi.hh:228
unsigned long long DirFlags
Definition XrdOssApi.hh:244
int Remdir(const char *, int Opts=0, XrdOucEnv *eP=0)
int StatPF(const char *, struct stat *, int)
int Chmod(const char *, mode_t mode, XrdOucEnv *eP=0)
int MSS_Create(const char *path, mode_t, XrdOucEnv &)
int StageEvSize
Definition XrdOssApi.hh:231
int getID(const char *, XrdOucEnv &, char *, int)
int lenDP
Definition XrdOssApi.hh:259
XrdOucPListAnchor RPList
Definition XrdOssApi.hh:257
int Stats(char *bp, int bl)
int xfrhold
Definition XrdOssApi.hh:296
static int AioAllOk
Definition XrdOssApi.hh:201
int CalcTime(XrdOssStage_Req *req)
int ConfigProc(XrdSysError &Eroute)
bool pfcMode
Definition XrdOssApi.hh:314
int Reloc(const char *tident, const char *path, const char *cgName, const char *anchor=0)
int xfrtcount
Definition XrdOssApi.hh:299
int RenameLink(char *old_path, char *new_path)
int Truncate(const char *, unsigned long long Size, XrdOucEnv *eP=0)
int Stage_QT(const char *, const char *, XrdOucEnv &, int, mode_t)
int MSS_Xeq(XrdOucStream **xfd, int okerr, const char *cmd, const char *arg1=0, const char *arg2=0)
void ConfigCache(XrdSysError &Eroute, bool pass2=false)
char * StageCmd
Definition XrdOssApi.hh:225
char * StageMsg
Definition XrdOssApi.hh:226
char * RemoteRoot
Definition XrdOssApi.hh:219
int xmaxsz(XrdOucStream &Config, XrdSysError &Eroute)
uint64_t Features()
Definition XrdOssApi.hh:166
int xfrkeep
Definition XrdOssApi.hh:297
int Alloc_Local(XrdOssCreateInfo &, XrdOucEnv &)
int Solitary
Definition XrdOssApi.hh:246
int MaxTwiddle
Definition XrdOssApi.hh:220
char * RSSCmd
Definition XrdOssApi.hh:238
int xdefault(XrdOucStream &Config, XrdSysError &Eroute)
void * MSS_Opendir(const char *, int &rc)
virtual int Create(const char *, const char *, mode_t, XrdOucEnv &, int opts=0)
int xnml(XrdOucStream &Config, XrdSysError &Eroute)
XrdOucName2Name * rmt_N2N
Definition XrdOssApi.hh:255
int xalloc(XrdOucStream &Config, XrdSysError &Eroute)
char * xfrFdir
Definition XrdOssApi.hh:311
Definition XrdOssVS.hh:88
Definition XrdOucEnv.hh:42
Definition XrdOucMsubs.hh:91
Definition XrdOucName2Name.hh:49
Definition XrdOucPList.hh:89
unsigned long long Find(const char *pathname)
Definition XrdOucPList.hh:112
Definition XrdOucProg.hh:38
Definition XrdOucStream.hh:47
Definition XrdSfsAio.hh:59
Definition XrdSysError.hh:90
Definition XrdSysLogger.hh:53
Definition XrdOssConfig.hh:49
Definition XrdOssConfig.hh:58
Definition XrdOucIOVec.hh:41