33 #include <sys/types.h> 54 int Close(
long long *retsz=0);
56 int Readdir(
char *buff,
int blen);
94 virtual int Close(
long long *retsz=0);
106 ssize_t
Read( off_t,
size_t);
107 ssize_t
Read(
void *, off_t,
size_t);
110 ssize_t
ReadRaw(
void *, off_t,
size_t);
111 ssize_t
Write(
const void *, off_t,
size_t);
123 int Open_ufs(
const char *,
int,
int,
unsigned long long);
142 class XrdOssCreateInfo;
149 struct XrdVersionInfo;
163 int Create(
const char *,
const char *, mode_t,
XrdOucEnv &,
int opts=0);
170 int Lfn2Pfn(
const char *Path,
char *buff,
int blen);
171 const char *
Lfn2Pfn(
const char *Path,
char *buff,
int blen,
int &rc);
172 int Mkdir(
const char *, mode_t mode,
int mkpath=0,
XrdOucEnv *eP=0);
173 int Mkpath(
const char *, mode_t mode);
175 int Reloc(
const char *tident,
const char *path,
176 const char *cgName,
const char *anchor=0);
178 int Rename(
const char *,
const char *,
181 int Stage(
const char *,
const char *,
XrdOucEnv &,
int, mode_t,
unsigned long long );
185 int StatFS(
const char *path,
unsigned long long &Opt,
186 long long &fSize,
long long &fSpace);
191 int StatXP(
const char *path,
unsigned long long &attr,
XrdOucEnv *Env=0);
195 int Stats(
char *bp,
int bl);
207 int MSS_Remdir(
const char *,
const char *) {
return -ENOTSUP;}
315 int BreakLink(
const char *local_path,
struct stat &statbuff);
318 int SetFattr(XrdOssCreateInfo &crInfo,
int datfd, time_t mtime);
321 int getCname(
const char *path,
struct stat *sbuff,
char *cgbuff);
325 time_t
HasFile(
const char *fn,
const char *sfx, time_t *mTime=0);
338 unsigned long long &Fv,
int noMSS);
358 const char *grp,
bool isAsgn);
370 const char *cmd,
const char *arg1=0,
const char *arg2=0);
374 int RenameLink(
char *old_path,
char *new_path);
375 int RenameLink3(
char *cPath,
char *old_path,
char *new_path);
384 #define Check_RO(act, flags, path, opname) \ 385 XRDEXP_REMOTE & (flags = PathOpts(path)); \ 386 if (flags & XRDEXP_NOTRW) \ 387 return OssEroute.Emsg(#act, -XRDOSS_E8005, opname, path) 389 #define Check_RW(act, path, opname) \ 390 if (PathOpts(path) & XRDEXP_NOTRW) \ 391 return OssEroute.Emsg(#act, -XRDOSS_E8005, opname, path) DIR * lclfd
Definition: XrdOssApi.hh:67
bool ateof
Definition: XrdOssApi.hh:70
virtual ~XrdOssFile()
Definition: XrdOssApi.hh:120
int MSS_Xeq(XrdOucStream **xfd, int okerr, const char *cmd, const char *arg1=0, const char *arg2=0)
ssize_t Write(const void *, off_t, size_t)
Definition: XrdOssApi.hh:87
void List_Path(const char *, const char *, unsigned long long, XrdSysError &)
Definition: XrdOssMioFile.hh:36
int xstl(XrdOucStream &Config, XrdSysError &Eroute)
int Rename(const char *, const char *, XrdOucEnv *eP1=0, XrdOucEnv *eP2=0)
int cxpgsz
Definition: XrdOssApi.hh:131
int xfrthreads
Definition: XrdOssApi.hh:295
int OptFlags
Definition: XrdOssApi.hh:244
Definition: XrdOssConfig.hh:48
char * StageCmd
Definition: XrdOssApi.hh:222
static const uint16_t DF_isDir
Object is for a directory.
Definition: XrdOss.hh:393
int StageAln[MaxArgs]
Definition: XrdOssApi.hh:233
int xfrkeep
Definition: XrdOssApi.hh:294
char * xfrFdir
Definition: XrdOssApi.hh:308
int Stage_QT(const char *, const char *, XrdOucEnv &, int, mode_t)
int StageFormat
Definition: XrdOssApi.hh:221
int Open_ufs(const char *, int, int, unsigned long long)
char * StageEvents
Definition: XrdOssApi.hh:227
int StatXP(const char *path, unsigned long long &attr, XrdOucEnv *Env=0)
void * Stage_In(void *carg)
struct stat * Stat
Definition: XrdOssApi.hh:69
char STT_DoN2N
Definition: XrdOssApi.hh:267
XrdOucPListAnchor RPList
Definition: XrdOssApi.hh:254
int MaxTwiddle
Definition: XrdOssApi.hh:217
Definition: XrdOucMsubs.hh:90
short prQSize
Definition: XrdOssApi.hh:277
int xnml(XrdOucStream &Config, XrdSysError &Eroute)
int RenameLink3(char *cPath, char *old_path, char *new_path)
static const int noDread
Definition: XrdOssApi.hh:75
XrdOucName2Name * lcl_N2N
Definition: XrdOssApi.hh:251
int MSS_Rename(const char *, const char *)
Definition: XrdOucPList.hh:88
int xcachescan(XrdOucStream &Config, XrdSysError &Eroute)
int badreqs
Definition: XrdOssApi.hh:301
int GenLocalPath(const char *, char *)
void ConfigSpath(XrdSysError &Eroute, const char *Pn, unsigned long long &Fv, int noMSS)
short prDepth
Definition: XrdOssApi.hh:276
int ConfigStageC(XrdSysError &Eroute)
int(* XrdOssStatInfo_t)(const char *path, struct stat *buff, int opts, XrdOucEnv *envP)
Definition: XrdOssStatInfo.hh:63
int RSSTout
Definition: XrdOssApi.hh:237
int Opendir(const char *, XrdOucEnv &)
int cscanint
Definition: XrdOssApi.hh:290
int xstg(XrdOucStream &Config, XrdSysError &Eroute)
XrdOssFile(const char *tid, int fdnum=-1)
Definition: XrdOssApi.hh:115
void Flush()
Flush filesystem cached pages for this file (used for checksums).
~XrdOssDir()
Definition: XrdOssApi.hh:65
static int AioFailure
Definition: XrdOssApi.hh:125
Definition: XrdOucStream.hh:46
static const uint16_t DF_isFile
Object is for a file.
Definition: XrdOss.hh:394
int Close(long long *retsz=0)
ssize_t Read(off_t, size_t)
char STT_V2
Definition: XrdOssApi.hh:268
char STT_DoARE
Definition: XrdOssApi.hh:269
XrdOssStatInfo_t STT_Func
Definition: XrdOssApi.hh:263
static int AioAllOk
Definition: XrdOssApi.hh:198
int Init(XrdSysLogger *lP, const char *cP)
Definition: XrdOssApi.hh:167
Definition: XrdOucName2Name.hh:48
int StatRet(struct stat *buff)
XrdOucProg * RSSProg
Definition: XrdOssApi.hh:304
int xxfr(XrdOucStream &Config, XrdSysError &Eroute)
ssize_t ReadRaw(void *, off_t, size_t)
int rawio
Definition: XrdOssApi.hh:130
int xfdlimit(XrdOucStream &Config, XrdSysError &Eroute)
void * mssfd
Definition: XrdOssApi.hh:68
int Stats(char *bp, int bl)
int StatVS(XrdOssVSInfo *sP, const char *sname=0, int updt=0)
int prBytes
Definition: XrdOssApi.hh:274
int(* XrdOssStatInfo2_t)(const char *path, struct stat *buff, int opts, XrdOucEnv *envP, const char *lfn)
Definition: XrdOssStatInfo.hh:66
int getStats(char *buff, int blen)
int Mkdir(const char *, mode_t mode, int mkpath=0, XrdOucEnv *eP=0)
int Reloc(const char *tident, const char *path, const char *cgName, const char *anchor=0)
bool isopen
Definition: XrdOssApi.hh:71
char * StageAction
Definition: XrdOssApi.hh:230
time_t HasFile(const char *fn, const char *sfx, time_t *mTime=0)
XrdOssMioFile * mmFile
Definition: XrdOssApi.hh:128
int fuzalloc
Definition: XrdOssApi.hh:289
int StatLS(XrdOucEnv &env, const char *path, char *buff, int &blen)
char * StageMsg
Definition: XrdOssApi.hh:223
void Config_Display(XrdSysError &)
int isCompressed(char *cxidp=0)
int xfrFdln
Definition: XrdOssApi.hh:309
Definition: XrdSysError.hh:89
XrdOucName2Name * the_N2N
Definition: XrdOssApi.hh:253
long long FSize
Definition: XrdOssApi.hh:129
int FDLimit
Definition: XrdOssApi.hh:240
Definition: XrdOssVS.hh:87
int Trace
Definition: XrdOssApi.hh:242
int RenameLink(char *old_path, char *new_path)
int MSS_Stat(const char *, struct stat *buff=0)
int xmemf(XrdOucStream &Config, XrdSysError &Eroute)
int Readdir(char *buff, int blen)
int StageActLen
Definition: XrdOssApi.hh:229
int getCname(const char *path, struct stat *sbuff, char *cgbuff)
int fd
Definition: XrdOss.hh:448
int xpath(XrdOucStream &Config, XrdSysError &Eroute)
int MSS_Remdir(const char *, const char *)
Definition: XrdOssApi.hh:207
int StageRealTime
Definition: XrdOssApi.hh:218
int getID(const char *, XrdOucEnv &, char *, int)
int StatXA(const char *path, char *buff, int &blen, XrdOucEnv *Env=0)
unsigned long long DirFlags
Definition: XrdOssApi.hh:241
int StatFS(const char *path, char *buff, int &blen, XrdOucEnv *Env=0)
void ConfigSpace(XrdSysError &Eroute)
char * ConfigFN
Definition: XrdOssApi.hh:214
OssDPath * DPList
Definition: XrdOssApi.hh:255
int MSS_Unlink(const char *)
int ConfigXeq(char *, XrdOucStream &, XrdSysError &)
static const int isStage
Definition: XrdOssApi.hh:73
int xmaxsz(XrdOucStream &Config, XrdSysError &Eroute)
int xusage(XrdOucStream &Config, XrdSysError &Eroute)
int STT_PreOp
Definition: XrdOssApi.hh:266
int xspaceBuild(char *grp, char *fn, int isxa, XrdSysError &Eroute)
virtual int Close(long long *retsz=0)
int Chmod(const char *, mode_t mode, XrdOucEnv *eP=0)
int BreakLink(const char *local_path, struct stat &statbuff)
Definition: XrdOucProg.hh:37
int GetFile(XrdOssStage_Req *req)
short numDP
Definition: XrdOssApi.hh:257
short USync
Definition: XrdOssApi.hh:310
int totreqs
Definition: XrdOssApi.hh:300
off_t getMmap(void **addr)
int xfrhold
Definition: XrdOssApi.hh:293
Definition: XrdOssCache.hh:78
Definition: XrdOssSpace.hh:35
long long minalloc
Definition: XrdOssApi.hh:287
void ConfigMio(XrdSysError &Eroute)
long long stgbytes
Definition: XrdOssApi.hh:298
Definition: XrdOucEnv.hh:41
int Configure(const char *, XrdSysError &, XrdOucEnv *envP)
int xdefault(XrdOucStream &Config, XrdSysError &Eroute)
int xfrtcount
Definition: XrdOssApi.hh:296
Definition: XrdOucIOVec.hh:40
char * N2N_Parms
Definition: XrdOssApi.hh:250
int ConfigStatLib(XrdSysError &Eroute, XrdOucEnv *envP)
int StageAsync
Definition: XrdOssApi.hh:219
int StageCreate
Definition: XrdOssApi.hh:220
int Init(XrdSysLogger *, const char *, XrdOucEnv *envP)
long long pndbytes
Definition: XrdOssApi.hh:297
int lenDP
Definition: XrdOssApi.hh:256
int Alloc_Local(XrdOssCreateInfo &, XrdOucEnv &)
int MSS_Create(const char *path, mode_t, XrdOucEnv &)
int IsRemote(const char *path)
Definition: XrdOssApi.hh:168
int StatPF(const char *, struct stat *, int)
int xprerd(XrdOucStream &Config, XrdSysError &Eroute)
unsigned long long Find(const char *pathname)
Definition: XrdOucPList.hh:112
ssize_t ReadV(XrdOucIOVec *readV, int)
int xcache(XrdOucStream &Config, XrdSysError &Eroute)
static const int MaxArgs
Definition: XrdOssApi.hh:212
virtual XrdOssDF * newDir(const char *tident)
Definition: XrdOssApi.hh:154
XrdVersionInfo * myVersion
Definition: XrdOssApi.hh:279
XrdOucPListAnchor SPList
Definition: XrdOssApi.hh:246
int Find(XrdOssStage_Req *req, void *carg)
Definition: XrdOssApi.hh:51
char * N2N_Lib
Definition: XrdOssApi.hh:249
int Alloc_Cache(XrdOssCreateInfo &, XrdOucEnv &)
int prActive
Definition: XrdOssApi.hh:275
int ConfigStage(XrdSysError &Eroute)
int FDFence
Definition: XrdOssApi.hh:239
int xfrspeed
Definition: XrdOssApi.hh:291
int isMSSC
Definition: XrdOssApi.hh:236
Definition: XrdOssCache.hh:182
int Ftruncate(unsigned long long)
Definition: XrdSysLogger.hh:52
XrdOucProg * StageProg
Definition: XrdOssApi.hh:303
int prPSize
Definition: XrdOssApi.hh:273
XrdFrcProxy * StageFrm
Definition: XrdOssApi.hh:225
char * QFile
Definition: XrdOssApi.hh:307
Definition: XrdOssApi.hh:151
virtual XrdOssDF * newFile(const char *tident)
Definition: XrdOssApi.hh:156
#define stat(a, b)
Definition: XrdPosix.hh:96
unsigned char dOpts
Definition: XrdOssApi.hh:72
int xfrovhd
Definition: XrdOssApi.hh:292
long long prPMask
Definition: XrdOssApi.hh:272
XrdOucMsubs * StageSnd
Definition: XrdOssApi.hh:224
#define XRDEXP_REMOTE
Definition: XrdOucExport.hh:85
long long totbytes
Definition: XrdOssApi.hh:299
XrdOssCache_FS * cacheP
Definition: XrdOssApi.hh:127
int Mkpath(const char *, mode_t mode)
int getFD()
Definition: XrdOssApi.hh:103
Definition: XrdOss.hh:487
XrdOssStatInfo2_t STT_Fund
Definition: XrdOssApi.hh:264
int StageAnum
Definition: XrdOssApi.hh:234
virtual ~XrdOssSys()
Definition: XrdOssApi.hh:282
char * UDir
Definition: XrdOssApi.hh:306
short numCG
Definition: XrdOssApi.hh:258
int Stage_RT(const char *, const char *, XrdOucEnv &, unsigned long long)
int ConfigProc(XrdSysError &Eroute)
long long prPBits
Definition: XrdOssApi.hh:271
int Stat(const char *, struct stat *, int opts=0, XrdOucEnv *Env=0)
char * RSSCmd
Definition: XrdOssApi.hh:235
static char tryMmap
Definition: XrdOssApi.hh:200
int Unlink(const char *, int Opts=0, XrdOucEnv *eP=0)
virtual int Stage(const char *, const char *, XrdOucEnv &, int, mode_t, unsigned long long)
int ovhalloc
Definition: XrdOssApi.hh:288
static char chkMmap
Definition: XrdOssApi.hh:201
Definition: XrdOssStage.hh:49
char * RemoteRoot
Definition: XrdOssApi.hh:216
void * MSS_Opendir(const char *, int &rc)
XrdOucName2Name * rmt_N2N
Definition: XrdOssApi.hh:252
Definition: XrdOssCache.hh:132
virtual int Open(const char *, int, mode_t, XrdOucEnv &)
int StageEvSize
Definition: XrdOssApi.hh:228
Definition: XrdSfsAio.hh:58
char * STT_Parms
Definition: XrdOssApi.hh:261
char * STT_Lib
Definition: XrdOssApi.hh:260
char * StageArg[MaxArgs]
Definition: XrdOssApi.hh:232
int xspace(XrdOucStream &Config, XrdSysError &Eroute, int *isCD=0)
long long MaxSize
Definition: XrdOssApi.hh:238
int xtrace(XrdOucStream &Config, XrdSysError &Eroute)
void ConfigStats(XrdSysError &Eroute)
Definition: XrdFrcProxy.hh:39
oocx_CXFile * cxobj
Definition: XrdOssApi.hh:126
int GenRemotePath(const char *, char *)
char * LocalRoot
Definition: XrdOssApi.hh:215
bool pfcMode
Definition: XrdOssApi.hh:311
int Remdir(const char *, int Opts=0, XrdOucEnv *eP=0)
void ConfigCache(XrdSysError &Eroute, bool pass2=false)
int ConfigN2N(XrdSysError &Eroute, XrdOucEnv *envP)
unsigned long long PathOpts(const char *path)
Definition: XrdOssApi.hh:174
int Solitary
Definition: XrdOssApi.hh:243
int Truncate(const char *, unsigned long long Size, XrdOucEnv *eP=0)
char cxid[4]
Definition: XrdOssApi.hh:132
int Lfn2Pfn(const char *Path, char *buff, int blen)
static const int noCheck
Definition: XrdOssApi.hh:74
XrdOssDir(const char *tid, DIR *dP=0)
Definition: XrdOssApi.hh:60
int xalloc(XrdOucStream &Config, XrdSysError &Eroute)
int MSS_Readdir(void *fd, char *buff, int blen)
int SetFattr(XrdOssCreateInfo &crInfo, int datfd, time_t mtime)
virtual int Create(const char *, const char *, mode_t, XrdOucEnv &, int opts=0)