34 #include <sys/types.h>
56 struct XrdVersionInfo;
66 int open(
const char *dirName,
68 const char *opaque = 0);
118 int open(
const char *fileName,
122 const char *opaque = 0);
125 struct iov *range=0,
int n=0);
131 int fctl(
const int cmd,
135 int fctl(
const int cmd,
142 int getMmap(
void **Addr, off_t &Size);
188 int getCXinfo(
char cxtype[4],
int &cxrsz);
263 const char *opaque = 0);
265 int chmod(
const char *Name,
269 const char *opaque = 0);
275 int exists(
const char *fileName,
279 const char *opaque = 0);
285 int FSctl(
const int cmd,
290 int fsctl(
const int cmd,
299 int mkdir(
const char *dirName,
303 const char *opaque = 0);
312 const char *info = 0)
313 {
return remove(
'f', path, out_error, client, info);}
318 const char *info = 0)
319 {
return remove(
'd',dirName,out_error,client,info);}
321 int rename(
const char *oldFileName,
322 const char *newFileName,
325 const char *infoO = 0,
326 const char *infoN = 0);
328 int stat(
const char *Name,
332 const char *opaque = 0);
334 int stat(
const char *Name,
338 const char *opaque = 0);
344 const char *opaque = 0);
432 const char *
Split(
const char *Args,
const char **Opq,
char *Path,
int Plen);
492 int remove(
const char type,
const char *path,
XrdOucErrInfo &out_error,
503 const char *xPath=0);
504 const char *
Fname(
const char *);
506 const char *arg1=0,
const char *arg2=0,
int ConfigPosc(XrdSysError &Eroute)
int xtpcr(XrdOucStream &, XrdSysError &)
XrdOfsPoscq * poscQ
Definition: XrdOfs.hh:450
bool reProxy
Definition: XrdOfs.hh:476
bool CksPfn
Definition: XrdOfs.hh:461
int poscHold
Definition: XrdOfs.hh:452
Definition: XrdOfs.hh:374
Definition: XrdOfs.hh:375
void Unpersist(XrdOfsHandle *hP, int xcev=1)
int xforward(XrdOucStream &, XrdSysError &)
XrdSfsFile * newFile(XrdOucErrInfo &eInfo)
Definition: XrdOfs.hh:253
XrdSfsXferSize pgRead(XrdSfsFileOffset offset, char *buffer, XrdSfsXferSize rdlen, uint32_t *csvec, uint64_t opts=0)
Definition: XrdOfs.hh:210
XrdSfsXferSize pgWrite(XrdSfsFileOffset offset, char *buffer, XrdSfsXferSize wrlen, uint32_t *csvec, uint64_t opts=0)
~fwdOpt()
Definition: XrdOfs.hh:401
char * WaitTime(int, char *, int)
int xmaxd(XrdOucStream &, XrdSysError &)
XrdSfsFile * newFile(char *user=0, int MonID=0)
Definition: XrdOfs.hh:250
Definition: XrdOfs.hh:366
struct fwdOpt fwdTRUNC
Definition: XrdOfs.hh:410
Definition: XrdOfsPoscq.hh:41
Definition: XrdOucPList.hh:88
const char * Fname(const char *)
int exists(const char *fileName, XrdSfsFileExistence &exists_flag, XrdOucErrInfo &out_error, const XrdSecEntity *client, const char *opaque=0)
const char * Split(const char *Args, const char **Opq, char *Path, int Plen)
char * poscLog
Definition: XrdOfs.hh:451
static int MaxDelay
Definition: XrdOfs.hh:412
int read(XrdSfsFileOffset fileOffset, XrdSfsXferSize amount)
int ctlFASet(XrdSfsFACtl &faCtl, XrdOucEnv &faEnv, XrdOucErrInfo &einfo)
int xcrds(XrdOucStream &, XrdSysError &)
int rename(const char *oldFileName, const char *newFileName, XrdOucErrInfo &out_error, const XrdSecEntity *client, const char *infoO=0, const char *infoN=0)
struct fwdOpt fwdCHMOD
Definition: XrdOfs.hh:404
int fctl(const int cmd, const char *args, XrdOucErrInfo &out_error)
XrdSfsXferSize write(XrdSfsFileOffset fileOffset, const char *buffer, XrdSfsXferSize buffer_size)
int dorawio
Definition: XrdOfs.hh:200
char OssIsProxy
Definition: XrdOfs.hh:464
XrdNetIF * myIF
Definition: XrdOfs.hh:389
Definition: XrdOfsEvs.hh:120
Definition: XrdOfs.hh:364
struct fwdOpt fwdMV
Definition: XrdOfs.hh:407
Definition: XrdOucStream.hh:46
XrdOucChkPnt * myCKP
Definition: XrdOfs.hh:199
int XrdSfsXferSize
Definition: XrdSfsInterface.hh:129
const char * theRole(int opts)
XrdOucErrInfo myEInfo
Definition: XrdOfs.hh:220
int usxMaxNsz
Definition: XrdOfs.hh:469
XrdSfsFileExistence
Definition: XrdSfsInterface.hh:131
bool ckpBad
Definition: XrdOfs.hh:202
Definition: XrdOfsEvr.hh:42
virtual ~XrdOfs()
Definition: XrdOfs.hh:356
XrdSfsDirectory * newDir(char *user=0, int MonID=0)
Definition: XrdOfs.hh:244
int stat(struct stat *buf)
XrdOfsFile(XrdOucErrInfo &eInfo, const char *user)
char * Host
Definition: XrdOfs.hh:395
Definition: XrdCmsClient.hh:115
virtual int fctl(const int cmd, const char *args, XrdOucErrInfo &eInfo)=0
int ctlFADel(XrdSfsFACtl &faCtl, XrdOucEnv &faEnv, XrdOucErrInfo &einfo)
Definition: XrdNetIF.hh:48
int xnmsg(XrdOucStream &, XrdSysError &)
int Stall(XrdOucErrInfo &, int, const char *)
Definition: XrdOucChkPnt.hh:40
Definition: XrdAccAuthorize.hh:65
struct fwdOpt fwdRM
Definition: XrdOfs.hh:408
XrdOfsHandle * oh
Definition: XrdOfs.hh:197
static int fsError(XrdOucErrInfo &myError, int rc)
int open(const char *fileName, XrdSfsFileOpenMode openMode, mode_t createMode, const XrdSecEntity *client, const char *opaque=0)
friend class XrdOfsDirectory
Definition: XrdOfs.hh:237
virtual ~XrdOfsDirectory()
Definition: XrdOfs.hh:84
XrdCmsClient * Balancer
Definition: XrdOfs.hh:446
int tpcRdrPort[2]
Definition: XrdOfs.hh:385
char * tpcRdrHost[2]
Definition: XrdOfs.hh:384
void Connect(const XrdSecEntity *client=0)
int truncate(const char *Name, XrdSfsFileOffset fileOffset, XrdOucErrInfo &out_error, const XrdSecEntity *client=0, const char *opaque=0)
Definition: XrdSfsFAttr.hh:72
Definition: XrdSysError.hh:89
int autoStat(struct stat *buf)
Definition: XrdOfs.hh:371
int stat(const char *Name, struct stat *buf, XrdOucErrInfo &out_error, const XrdSecEntity *client, const char *opaque=0)
const char * Cmd
Definition: XrdOfs.hh:394
XrdOfsFileFull(const char *user, int MonID)
Definition: XrdOfs.hh:213
Definition: XrdOfsTPC.hh:47
int Reformat(XrdOucErrInfo &)
bool prepAuth
Definition: XrdOfs.hh:463
XrdCmsClient * Finder
Definition: XrdOfs.hh:424
char * fname
Definition: XrdOfs.hh:88
virtual int ConfigXeq(char *var, XrdOucStream &, XrdSysError &)
int open(const char *dirName, const XrdSecEntity *client, const char *opaque=0)
Definition: XrdSfsInterface.hh:238
XrdSysMutex ocMutex
Definition: XrdOfs.hh:473
Definition: XrdOfsHandle.hh:125
int xtpcal(XrdOucStream &, XrdSysError &)
Definition: XrdSysPthread.hh:164
const char * Name()
Definition: XrdOfsHandle.hh:148
Definition: XrdOucIOVec.hh:65
char * ConfigFN
Definition: XrdOfs.hh:415
long long XrdSfsFileOffset
Definition: XrdSfsInterface.hh:126
void Reset()
Definition: XrdOfs.hh:397
virtual ~XrdOfsDirFull()
Definition: XrdOfs.hh:101
int xtpc(XrdOucStream &, XrdSysError &)
Definition: XrdOfs.hh:365
< SFS_FSCTL_PLUGIN/PLUGIO parms
Definition: XrdSfsInterface.hh:159
int mkdir(const char *dirName, XrdSfsMode Mode, XrdOucErrInfo &out_error, const XrdSecEntity *client, const char *opaque=0)
void Disc(const XrdSecEntity *client=0)
const char * tident
Definition: XrdOfs.hh:196
int rem(const char *path, XrdOucErrInfo &out_error, const XrdSecEntity *client, const char *info=0)
Definition: XrdOfs.hh:309
XrdSfsXferSize readv(XrdOucIOVec *readV, int readCount)
char viaDel
Definition: XrdOfs.hh:201
int xnot(XrdOucStream &, XrdSysError &)
Definition: XrdOfs.hh:372
char ossRW
Definition: XrdOfs.hh:456
int truncate(XrdSfsFileOffset fileOffset)
XrdSfsDirectory * newDir(XrdOucErrInfo &eInfo)
Definition: XrdOfs.hh:247
Definition: XrdOucErrInfo.hh:100
int fsctl(const int cmd, const char *args, XrdOucErrInfo &out_error, const XrdSecEntity *client=0)
~XrdOfsFile()
Definition: XrdOfs.hh:192
Definition: XrdOfsConfigPI.hh:60
Definition: XrdOucEnv.hh:41
XrdOfsTPC * myTPC
Definition: XrdOfs.hh:198
const char * getVersion()
Definition: XrdOucIOVec.hh:40
XrdOfsEvr evrObject
Definition: XrdOfs.hh:423
int ctlFAGet(XrdSfsFACtl &faCtl, XrdOucEnv &faEnv, XrdOucErrInfo &einfo)
XrdCks * Cks
Definition: XrdOfs.hh:460
XrdOfsPrepare * prepHandler
Definition: XrdOfs.hh:459
int chksum(csFunc Func, const char *csName, const char *Path, XrdOucErrInfo &out_error, const XrdSecEntity *client=0, const char *opaque=0)
Definition: XrdOfs.hh:370
static int Emsg(const char *, XrdOucErrInfo &, int, const char *x, XrdOfsHandle *hP)
int ConfigDispFwd(char *buff, struct fwdOpt &Fwd)
int xpers(XrdOucStream &, XrdSysError &)
char dname[MAXNAMLEN]
Definition: XrdOfs.hh:91
Definition: XrdOfsFSctl_PI.hh:51
int remdir(const char *dirName, XrdOucErrInfo &out_error, const XrdSecEntity *client, const char *info=0)
Definition: XrdOfs.hh:315
Definition: XrdOfs.hh:235
bool OssHasPGrw
Definition: XrdOfs.hh:477
Definition: XrdOfs.hh:373
char * myRole
Definition: XrdOfs.hh:443
Definition: XrdOssApi.hh:51
int getMmap(void **Addr, off_t &Size)
int getStats(char *buff, int blen)
struct fwdOpt fwdMKPATH
Definition: XrdOfs.hh:406
void copyError(XrdOucErrInfo &einfo)
Definition: XrdOfs.hh:74
cpAct
Definition: XrdSfsInterface.hh:428
int xatr(XrdOucStream &, XrdSysError &)
int checkpoint(XrdSfsFile::cpAct act, struct iov *range=0, int n=0)
short poscSync
Definition: XrdOfs.hh:453
int getCXinfo(char cxtype[4], int &cxrsz)
Definition: XrdSysLogger.hh:52
signed char poscAuto
Definition: XrdOfs.hh:454
int FAttr(XrdSfsFACtl *faReq, XrdOucErrInfo &eInfo, const XrdSecEntity *client=0)
int FSctl(const int cmd, XrdSfsFSctl &args, XrdOucErrInfo &eInfo, const XrdSecEntity *client=0)
static int OSSDelay
Definition: XrdOfs.hh:413
Definition: XrdOfs.hh:376
int chmod(const char *Name, XrdSfsMode Mode, XrdOucErrInfo &out_error, const XrdSecEntity *client, const char *opaque=0)
XrdOfsEvs * evsObject
Definition: XrdOfs.hh:447
int xdirl(XrdOucStream &, XrdSysError &)
bool DirRdr
Definition: XrdOfs.hh:475
#define stat(a, b)
Definition: XrdPosix.hh:96
void Config_Cluster(XrdOss *)
int xexp(XrdOucStream &, XrdSysError &, bool)
Definition: XrdOfs.hh:367
int xtrace(XrdOucStream &, XrdSysError &)
const char * tident
Definition: XrdOfs.hh:87
Definition: XrdOfs.hh:114
int xrole(XrdOucStream &, XrdSysError &)
char myRType[4]
Definition: XrdOfs.hh:465
int ctlFALst(XrdSfsFACtl &faCtl, XrdOucEnv &faEnv, XrdOucErrInfo &einfo)
XrdOucPListAnchor * ossRPList
Definition: XrdOfs.hh:448
Definition: XrdOfs.hh:368
struct fwdOpt fwdMKDIR
Definition: XrdOfs.hh:405
int XrdSfsMode
Definition: XrdSfsInterface.hh:128
const char * getErrUser()
Definition: XrdOucErrInfo.hh:297
XrdOfsFSctl_PI * FSctl_PI
Definition: XrdOfs.hh:444
int prepare(XrdSfsPrep &pargs, XrdOucErrInfo &out_error, const XrdSecEntity *client=0)
virtual int Configure(XrdSysError &)
Definition: XrdOss.hh:497
int usxMaxVsz
Definition: XrdOfs.hh:470
XrdOfsDirFull(const char *user, int MonID)
Definition: XrdOfs.hh:97
Definition: XrdOfs.hh:393
int myPort
Definition: XrdOfs.hh:380
XrdOfsConfigPI * ofsConfig
Definition: XrdOfs.hh:458
bool CksRdr
Definition: XrdOfs.hh:462
int atEOF
Definition: XrdOfs.hh:90
int Forward(int &Result, XrdOucErrInfo &Resp, struct fwdOpt &Fwd, const char *arg1=0, const char *arg2=0, XrdOucEnv *Env1=0, XrdOucEnv *Env2=0)
int ConfigTPC(XrdSysError &Eroute, XrdOucEnv *EnvInfo)
friend class XrdOfsFile
Definition: XrdOfs.hh:238
int Options
Definition: XrdOfs.hh:379
Definition: XrdSecEntity.hh:63
XrdOssDF * dp
Definition: XrdOfs.hh:89
Definition: XrdOfs.hh:369
Definition: XrdSfsAio.hh:58
XrdAccAuthorize * Authorization
Definition: XrdOfs.hh:445
Definition: XrdSfsInterface.hh:364
< Prepare parameters
Definition: XrdSfsInterface.hh:167
XrdOucErrInfo & error
Definition: XrdSfsInterface.hh:247
Definition: XrdOfsPrepare.hh:46
void Config_Display(XrdSysError &)
char * ConfigTPCDir(XrdSysError &Eroute, const char *sfx, const char *xPath=0)
XrdOucErrInfo myEInfo
Definition: XrdOfs.hh:104
struct fwdOpt fwdRMDIR
Definition: XrdOfs.hh:409
int XrdSfsFileOpenMode
Definition: XrdSfsInterface.hh:127
fwdOpt()
Definition: XrdOfs.hh:400
XrdOfsDirectory(XrdOucErrInfo &eInfo, const char *user)
Definition: XrdOfs.hh:80
const char * FName()
Definition: XrdOfs.hh:140
virtual ~XrdOfsFileFull()
Definition: XrdOfs.hh:217
int Port
Definition: XrdOfs.hh:396
static XrdOfsHandle * dummyHandle
Definition: XrdOfs.hh:472
const char * FName()
Definition: XrdOfs.hh:76
uint64_t ossFeatures
Definition: XrdOfs.hh:467
int ConfigRedir(XrdSysError &Eroute, XrdOucEnv *EnvInfo)