XRootD
XrdOfs.hh
Go to the documentation of this file.
1 #ifndef __OFS_API_H__
2 #define __OFS_API_H__
3 /******************************************************************************/
4 /* */
5 /* X r d O f s . h h */
6 /* */
7 /* (c) 2004 by the Board of Trustees of the Leland Stanford, Jr., University */
8 /* Produced by Andrew Hanushevsky for Stanford University under contract */
9 /* DE-AC02-76-SFO0515 with the Department of Energy */
10 /* */
11 /* This file is part of the XRootD software suite. */
12 /* */
13 /* XRootD is free software: you can redistribute it and/or modify it under */
14 /* the terms of the GNU Lesser General Public License as published by the */
15 /* Free Software Foundation, either version 3 of the License, or (at your */
16 /* option) any later version. */
17 /* */
18 /* XRootD is distributed in the hope that it will be useful, but WITHOUT */
19 /* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or */
20 /* FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public */
21 /* License for more details. */
22 /* */
23 /* You should have received a copy of the GNU Lesser General Public License */
24 /* along with XRootD in a file called COPYING.LESSER (LGPL license) and file */
25 /* COPYING (GPL license). If not, see <http://www.gnu.org/licenses/>. */
26 /* */
27 /* The copyright holder's institutional names and contributor's names may not */
28 /* be used to endorse or promote products derived from this software without */
29 /* specific prior written permission of the institution or contributor. */
30 /******************************************************************************/
31 
32 #include <cstring>
33 #include <dirent.h>
34 #include <sys/types.h>
35 
36 #include "XrdOfs/XrdOfsEvr.hh"
37 #include "XrdOfs/XrdOfsHandle.hh"
38 #include "XrdSys/XrdSysPthread.hh"
40 #include "XrdCms/XrdCmsClient.hh"
41 
42 class XrdNetIF;
43 class XrdOfsEvs;
44 class XrdOfsPocq;
45 class XrdOfsPrepare;
46 class XrdOss;
47 class XrdOssDF;
48 class XrdOssDir;
49 class XrdOucEnv;
50 class XrdOucPListAnchor;
51 class XrdSysError;
52 class XrdSysLogger;
53 class XrdOucStream;
54 class XrdSfsAio;
55 
56 struct XrdVersionInfo;
57 
58 /******************************************************************************/
59 /* X r d O f s D i r e c t o r y */
60 /******************************************************************************/
61 
63 {
64 public:
65 
66  int open(const char *dirName,
67  const XrdSecEntity *client,
68  const char *opaque = 0);
69 
70  const char *nextEntry();
71 
72  int close();
73 
74 inline void copyError(XrdOucErrInfo &einfo) {einfo = error;}
75 
76 const char *FName() {return (const char *)fname;}
77 
78  int autoStat(struct stat *buf);
79 
80  XrdOfsDirectory(XrdOucErrInfo &eInfo, const char *user)
81  : XrdSfsDirectory(eInfo), tident(user ? user : ""),
82  fname(0), dp(0), atEOF(0) {}
83 
84 virtual ~XrdOfsDirectory() {if (dp) close();}
85 
86 protected:
87 const char *tident;
88 char *fname;
90 int atEOF;
91 char dname[MAXNAMLEN];
92 };
93 
95 {
96 public:
97  XrdOfsDirFull(const char *user, int MonID)
98  : XrdOfsDirectory(myEInfo, user), myEInfo(user, MonID)
99  {}
100 
101 virtual ~XrdOfsDirFull() {}
102 
103 private:
104 XrdOucErrInfo myEInfo; // Accessible only by reference error
105 };
106 
107 /******************************************************************************/
108 /* X r d O f s F i l e */
109 /******************************************************************************/
110 
111 class XrdOfsTPC;
112 class XrdOucChkPnt;
113 
114 class XrdOfsFile : public XrdSfsFile
115 {
116 public:
117 
118  int open(const char *fileName,
119  XrdSfsFileOpenMode openMode,
120  mode_t createMode,
121  const XrdSecEntity *client,
122  const char *opaque = 0);
123 
125  struct iov *range=0, int n=0);
126 
127  int close();
128 
129  using XrdSfsFile::fctl;
130 
131  int fctl(const int cmd,
132  const char *args,
133  XrdOucErrInfo &out_error);
134 
135  int fctl(const int cmd,
136  int alen,
137  const char *args,
138  const XrdSecEntity *client = 0);
139 
140  const char *FName() {return (oh ? oh->Name() : "?");}
141 
142  int getMmap(void **Addr, off_t &Size);
143 
145  char *buffer,
146  XrdSfsXferSize rdlen,
147  uint32_t *csvec,
148  uint64_t opts=0);
149 
150  int pgRead(XrdSfsAio *aioparm, uint64_t opts=0);
151 
152 
154  char *buffer,
155  XrdSfsXferSize wrlen,
156  uint32_t *csvec,
157  uint64_t opts=0);
158 
159  int pgWrite(XrdSfsAio *aioparm, uint64_t opts=0);
160 
161 
162  int read(XrdSfsFileOffset fileOffset, // Preread only
163  XrdSfsXferSize amount);
164 
166  char *buffer,
167  XrdSfsXferSize buffer_size);
168 
170  int readCount);
171 
172  int read(XrdSfsAio *aioparm);
173 
175  const char *buffer,
176  XrdSfsXferSize buffer_size);
177 
178  int write(XrdSfsAio *aioparm);
179 
180  int sync();
181 
182  int sync(XrdSfsAio *aiop);
183 
184  int stat(struct stat *buf);
185 
186  int truncate(XrdSfsFileOffset fileOffset);
187 
188  int getCXinfo(char cxtype[4], int &cxrsz);
189 
190  XrdOfsFile(XrdOucErrInfo &eInfo, const char *user);
191 
192  ~XrdOfsFile() {viaDel = 1; if (oh) close();}
193 
194 protected:
195 
196 const char *tident;
201 char viaDel;
202 bool ckpBad;
203 
204 private:
205 
206 void GenFWEvent();
207 int CreateCKP();
208 };
209 
211 {
212 public:
213  XrdOfsFileFull(const char *user, int MonID)
214  : XrdOfsFile(myEInfo, user), myEInfo(user, MonID)
215  {}
216 
217 virtual ~XrdOfsFileFull() {}
218 
219 private:
220 XrdOucErrInfo myEInfo; // Accessible only by reference error
221 };
222 
223 /******************************************************************************/
224 /* C l a s s X r d O f s */
225 /******************************************************************************/
226 
227 class XrdAccAuthorize;
228 class XrdCks;
229 class XrdCmsClient;
230 class XrdOfsConfigPI;
231 class XrdOfsFSctl_PI;
232 class XrdOfsPoscq;
233 class XrdSfsFACtl;
234 
235 class XrdOfs : public XrdSfsFileSystem
236 {
237 friend class XrdOfsDirectory;
238 friend class XrdOfsFile;
239 
240 public:
241 
242 // Object allocation
243 //
244  XrdSfsDirectory *newDir(char *user=0, int MonID=0)
245  {return new XrdOfsDirFull(user, MonID);}
246 
248  {return new XrdOfsDirectory(eInfo, eInfo.getErrUser());}
249 
250  XrdSfsFile *newFile(char *user=0,int MonID=0)
251  {return new XrdOfsFileFull(user, MonID);}
252 
254  {return new XrdOfsFile(eInfo, eInfo.getErrUser());}
255 
256 // Other functions
257 //
258  int chksum( csFunc Func,
259  const char *csName,
260  const char *Path,
261  XrdOucErrInfo &out_error,
262  const XrdSecEntity *client = 0,
263  const char *opaque = 0);
264 
265  int chmod(const char *Name,
267  XrdOucErrInfo &out_error,
268  const XrdSecEntity *client,
269  const char *opaque = 0);
270 
271  void Connect(const XrdSecEntity *client = 0);
272 
273  void Disc(const XrdSecEntity *client = 0);
274 
275  int exists(const char *fileName,
276  XrdSfsFileExistence &exists_flag,
277  XrdOucErrInfo &out_error,
278  const XrdSecEntity *client,
279  const char *opaque = 0);
280 
281  int FAttr( XrdSfsFACtl *faReq,
282  XrdOucErrInfo &eInfo,
283  const XrdSecEntity *client = 0);
284 
285  int FSctl(const int cmd,
286  XrdSfsFSctl &args,
287  XrdOucErrInfo &eInfo,
288  const XrdSecEntity *client = 0);
289 
290  int fsctl(const int cmd,
291  const char *args,
292  XrdOucErrInfo &out_error,
293  const XrdSecEntity *client = 0);
294 
295  int getStats(char *buff, int blen);
296 
297 const char *getVersion();
298 
299  int mkdir(const char *dirName,
301  XrdOucErrInfo &out_error,
302  const XrdSecEntity *client,
303  const char *opaque = 0);
304 
305  int prepare( XrdSfsPrep &pargs,
306  XrdOucErrInfo &out_error,
307  const XrdSecEntity *client = 0);
308 
309  int rem(const char *path,
310  XrdOucErrInfo &out_error,
311  const XrdSecEntity *client,
312  const char *info = 0)
313  {return remove('f', path, out_error, client, info);}
314 
315  int remdir(const char *dirName,
316  XrdOucErrInfo &out_error,
317  const XrdSecEntity *client,
318  const char *info = 0)
319  {return remove('d',dirName,out_error,client,info);}
320 
321  int rename(const char *oldFileName,
322  const char *newFileName,
323  XrdOucErrInfo &out_error,
324  const XrdSecEntity *client,
325  const char *infoO = 0,
326  const char *infoN = 0);
327 
328  int stat(const char *Name,
329  struct stat *buf,
330  XrdOucErrInfo &out_error,
331  const XrdSecEntity *client,
332  const char *opaque = 0);
333 
334  int stat(const char *Name,
335  mode_t &mode,
336  XrdOucErrInfo &out_error,
337  const XrdSecEntity *client,
338  const char *opaque = 0);
339 
340  int truncate(const char *Name,
341  XrdSfsFileOffset fileOffset,
342  XrdOucErrInfo &out_error,
343  const XrdSecEntity *client = 0,
344  const char *opaque = 0);
345 // Management functions
346 //
347 virtual int Configure(XrdSysError &); // Backward Compatibility
348 
349 virtual int Configure(XrdSysError &, XrdOucEnv *);
350 
352 
353  void Config_Display(XrdSysError &);
354 
355  XrdOfs();
356 virtual ~XrdOfs() {} // Too complicate to delete :-)
357 
358 /******************************************************************************/
359 /* C o n f i g u r a t i o n V a l u e s */
360 /******************************************************************************/
361 
362 // Configuration values for this filesystem
363 //
364 enum {Authorize = 0x0001, // Authorization wanted
365  XAttrPlug = 0x0002, // Extended Attribute Plugin
366  isPeer = 0x0050, // Role peer
367  isProxy = 0x0020, // Role proxy
368  isManager = 0x0040, // Role manager
369  isServer = 0x0080, // Role server
370  isSuper = 0x00C0, // Role supervisor
371  isMeta = 0x0100, // Role meta + above
372  haveRole = 0x01F0, // A role is present
373  Forwarding= 0x1000, // Fowarding wanted
374  ThirdPC = 0x2000, // This party copy wanted
375  SubCluster= 0x4000, // all.subcluster directive encountered
376  RdrTPC = 0x8000
377  }; // These are set in Options below
378 
379 int Options; // Various options
380 int myPort; // Port number being used
381 
382 // Directory and file creation mode controls
383 //
384 mode_t dMask[2]; // Min/Max directory mode
385 mode_t fMask[2]; // Min/Max file mode
386 
387 // TPC related things
388 //
389 char *tpcRdrHost[2]; // TPC redirect target or null if none
390 int tpcRdrPort[2]; // TPC redirect target port number
391 
392 // Networking
393 //
395 
396 // Forward options
397 //
398 struct fwdOpt
399  {const char *Cmd;
400  char *Host;
401  int Port;
402  void Reset() {Cmd = 0; Port = 0;
403  if (Host) {free(Host); Host = 0;}
404  }
405  fwdOpt() : Cmd(0), Host(0), Port(0) {}
406  ~fwdOpt() {}
407  };
408 
409 struct fwdOpt fwdCHMOD;
410 struct fwdOpt fwdMKDIR;
411 struct fwdOpt fwdMKPATH;
412 struct fwdOpt fwdMV;
413 struct fwdOpt fwdRM;
414 struct fwdOpt fwdRMDIR;
415 struct fwdOpt fwdTRUNC;
416 
417 static int MaxDelay; // Max delay imposed during staging
418 static int OSSDelay; // Delay to impose when oss interface times out
419 
420 char *ConfigFN; // ->Configuration filename
421 
422 /******************************************************************************/
423 /* P r o t e c t e d I t e m s */
424 /******************************************************************************/
425 
426 protected:
427 
428 XrdOfsEvr evrObject; // Event receiver
429 XrdCmsClient *Finder; // ->Cluster Management Service
430 
431 virtual int ConfigXeq(char *var, XrdOucStream &, XrdSysError &);
432 static int Emsg(const char *, XrdOucErrInfo &, int, const char *x,
433  XrdOfsHandle *hP);
434 static int Emsg(const char *, XrdOucErrInfo &, int, const char *x,
435  const char *y="");
436 static int fsError(XrdOucErrInfo &myError, int rc);
437 const char *Split(const char *Args, const char **Opq, char *Path, int Plen);
438  int Stall(XrdOucErrInfo &, int, const char *);
439  void Unpersist(XrdOfsHandle *hP, int xcev=1);
440  char *WaitTime(int, char *, int);
441 
442 /******************************************************************************/
443 /* P r i v a t e C o n f i g u r a t i o n */
444 /******************************************************************************/
445 
446 private:
447 
448 char *myRole;
449 XrdOfsFSctl_PI *FSctl_PC; // ->FSctl plugin (cache specific)
450 XrdOfsFSctl_PI *FSctl_PI; // ->FSctl plugin
451 XrdAccAuthorize *Authorization; // ->Authorization Service
452 XrdCmsClient *Balancer; // ->Cluster Local Interface
453 XrdOfsEvs *evsObject; // ->Event Notifier
454 XrdOucPListAnchor*ossRPList; // ->Oss exoprt list
455 
456 XrdOfsPoscq *poscQ; // -> poscQ if persist on close enabled
457 char *poscLog; // -> Directory for posc recovery log
458 int poscHold; // Seconds to hold a forced close
459 short poscSync; // Number of requests before sync
460 signed char poscAuto; // 1 -> Automatic persist on close
461 
462 char ossRW; // The oss r/w capability
463 
464 XrdOfsConfigPI *ofsConfig; // Plugin configurator
465 XrdOfsPrepare *prepHandler; // Plugin prepare
466 XrdCks *Cks; // Checksum manager
467 bool CksPfn; // Checksum needs a pfn
468 bool CksRdr; // Checksum may be redirected (i.e. not local)
469 bool prepAuth; // Prepare requires authorization
470 char OssIsProxy; // !0 if we detect the oss plugin is a proxy
471 char myRType[4]; // Role type for consistency with the cms
472 
473 uint64_t ossFeatures; // The oss features
474 
475 int usxMaxNsz; // Maximum length of attribute name
476 int usxMaxVsz; // Maximum length of attribute value
477 
478 static XrdOfsHandle *dummyHandle;
479 XrdSysMutex ocMutex; // Global mutex for open/close
480 
481 bool DirRdr; // Opendir() can be redirected.
482 bool reProxy; // Reproxying required for TPC
483 bool OssHasPGrw; // True: oss implements full rgRead/Write
484 
485 /******************************************************************************/
486 /* O t h e r D a t a */
487 /******************************************************************************/
488 
489 // Internal file attribute methods
490 //
491 int ctlFADel(XrdSfsFACtl &faCtl, XrdOucEnv &faEnv, XrdOucErrInfo &einfo);
492 int ctlFAGet(XrdSfsFACtl &faCtl, XrdOucEnv &faEnv, XrdOucErrInfo &einfo);
493 int ctlFALst(XrdSfsFACtl &faCtl, XrdOucEnv &faEnv, XrdOucErrInfo &einfo);
494 int ctlFASet(XrdSfsFACtl &faCtl, XrdOucEnv &faEnv, XrdOucErrInfo &einfo);
495 
496 // Common functions
497 //
498 int remove(const char type, const char *path, XrdOucErrInfo &out_error,
499  const XrdSecEntity *client, const char *opaque);
500 
501 // Function used during Configuration
502 //
503 int ConfigDispFwd(char *buff, struct fwdOpt &Fwd);
504 int ConfigPosc(XrdSysError &Eroute);
505 int ConfigRedir(XrdSysError &Eroute, XrdOucEnv *EnvInfo);
506 int ConfigTPC(XrdSysError &Eroute, XrdOucEnv *EnvInfo);
507 int ConfigTPC(XrdSysError &Eroute);
508 char *ConfigTPCDir(XrdSysError &Eroute, const char *sfx,
509  const char *xPath=0);
510 const char *Fname(const char *);
511 int Forward(int &Result, XrdOucErrInfo &Resp, struct fwdOpt &Fwd,
512  const char *arg1=0, const char *arg2=0,
513  XrdOucEnv *Env1=0, XrdOucEnv *Env2=0);
514 int FSctl(XrdOfsFile &file, int cmd, int alen, const char *args,
515  const XrdSecEntity *client);
516 int Reformat(XrdOucErrInfo &);
517 const char *theRole(int opts);
518 int xcrds(XrdOucStream &, XrdSysError &);
519 int xcrm(XrdOucStream &, XrdSysError &);
520 int xdirl(XrdOucStream &, XrdSysError &);
521 int xexp(XrdOucStream &, XrdSysError &, bool);
522 int xforward(XrdOucStream &, XrdSysError &);
523 int xmaxd(XrdOucStream &, XrdSysError &);
524 int xnmsg(XrdOucStream &, XrdSysError &);
525 int xnot(XrdOucStream &, XrdSysError &);
526 int xpers(XrdOucStream &, XrdSysError &);
527 int xrole(XrdOucStream &, XrdSysError &);
528 int xtpc(XrdOucStream &, XrdSysError &);
529 int xtpcal(XrdOucStream &, XrdSysError &);
530 int xtpcr(XrdOucStream &, XrdSysError &);
531 int xtrace(XrdOucStream &, XrdSysError &);
532 int xatr(XrdOucStream &, XrdSysError &);
533 };
534 #endif
int stat(const char *path, struct stat *buf)
int Mode
XrdOucString Path
struct myOpts opts
int XrdSfsMode
XrdSfsFileExistence
int XrdSfsFileOpenMode
long long XrdSfsFileOffset
int XrdSfsXferSize
< Prepare parameters
< SFS_FSCTL_PLUGIN/PLUGIO/PLUGXC parms
Definition: XrdCks.hh:92
virtual ~XrdOfsDirFull()
Definition: XrdOfs.hh:101
XrdOfsDirFull(const char *user, int MonID)
Definition: XrdOfs.hh:97
XrdOfsDirectory(XrdOucErrInfo &eInfo, const char *user)
Definition: XrdOfs.hh:80
char dname[MAXNAMLEN]
Definition: XrdOfs.hh:91
virtual ~XrdOfsDirectory()
Definition: XrdOfs.hh:84
const char * nextEntry()
Definition: XrdOfs.cc:299
void copyError(XrdOucErrInfo &einfo)
Definition: XrdOfs.hh:74
const char * tident
Definition: XrdOfs.hh:87
int autoStat(struct stat *buf)
Definition: XrdOfs.cc:402
char * fname
Definition: XrdOfs.hh:88
XrdOssDF * dp
Definition: XrdOfs.hh:89
const char * FName()
Definition: XrdOfs.hh:76
int open(const char *dirName, const XrdSecEntity *client, const char *opaque=0)
Definition: XrdOfs.cc:239
XrdOfsFileFull(const char *user, int MonID)
Definition: XrdOfs.hh:213
virtual ~XrdOfsFileFull()
Definition: XrdOfs.hh:217
XrdOfsFile(XrdOucErrInfo &eInfo, const char *user)
Definition: XrdOfs.cc:442
int getCXinfo(char cxtype[4], int &cxrsz)
Definition: XrdOfs.cc:1732
int checkpoint(XrdSfsFile::cpAct act, struct iov *range=0, int n=0)
Definition: XrdOfs.cc:911
XrdSfsXferSize pgWrite(XrdSfsFileOffset offset, char *buffer, XrdSfsXferSize wrlen, uint32_t *csvec, uint64_t opts=0)
Definition: XrdOfs.cc:1188
XrdSfsXferSize write(XrdSfsFileOffset fileOffset, const char *buffer, XrdSfsXferSize buffer_size)
Definition: XrdOfs.cc:1472
int truncate(XrdSfsFileOffset fileOffset)
Definition: XrdOfs.cc:1685
const char * FName()
Definition: XrdOfs.hh:140
int read(XrdSfsFileOffset fileOffset, XrdSfsXferSize amount)
Definition: XrdOfs.cc:1307
XrdSfsXferSize readv(XrdOucIOVec *readV, int readCount)
Definition: XrdOfs.cc:1394
int open(const char *fileName, XrdSfsFileOpenMode openMode, mode_t createMode, const XrdSecEntity *client, const char *opaque=0)
Definition: XrdOfs.cc:451
XrdSfsXferSize pgRead(XrdSfsFileOffset offset, char *buffer, XrdSfsXferSize rdlen, uint32_t *csvec, uint64_t opts=0)
Definition: XrdOfs.cc:1092
int getMmap(void **Addr, off_t &Size)
Definition: XrdOfs.cc:1575
int close()
Definition: XrdOfs.cc:804
char viaDel
Definition: XrdOfs.hh:201
~XrdOfsFile()
Definition: XrdOfs.hh:192
const char * tident
Definition: XrdOfs.hh:196
int sync()
Definition: XrdOfs.cc:1624
XrdOfsHandle * oh
Definition: XrdOfs.hh:197
int dorawio
Definition: XrdOfs.hh:200
XrdOucChkPnt * myCKP
Definition: XrdOfs.hh:199
bool ckpBad
Definition: XrdOfs.hh:202
XrdOfsTPC * myTPC
Definition: XrdOfs.hh:198
virtual int fctl(const int cmd, const char *args, XrdOucErrInfo &eInfo)=0
int stat(struct stat *buf)
Definition: XrdOfs.cc:1596
const char * Name()
void Connect(const XrdSecEntity *client=0)
Definition: XrdOfs.cc:1962
int chmod(const char *Name, XrdSfsMode Mode, XrdOucErrInfo &out_error, const XrdSecEntity *client, const char *opaque=0)
Definition: XrdOfs.cc:1894
int truncate(const char *Name, XrdSfsFileOffset fileOffset, XrdOucErrInfo &out_error, const XrdSecEntity *client=0, const char *opaque=0)
Definition: XrdOfs.cc:2454
struct fwdOpt fwdTRUNC
Definition: XrdOfs.hh:415
void Disc(const XrdSecEntity *client=0)
Definition: XrdOfs.cc:1975
int prepare(XrdSfsPrep &pargs, XrdOucErrInfo &out_error, const XrdSecEntity *client=0)
Definition: XrdOfs.cc:2149
mode_t dMask[2]
Definition: XrdOfs.hh:384
const char * Split(const char *Args, const char **Opq, char *Path, int Plen)
Definition: XrdOfs.cc:2685
int myPort
Definition: XrdOfs.hh:380
XrdSfsDirectory * newDir(XrdOucErrInfo &eInfo)
Definition: XrdOfs.hh:247
XrdCmsClient * Finder
Definition: XrdOfs.hh:429
mode_t fMask[2]
Definition: XrdOfs.hh:385
int rem(const char *path, XrdOucErrInfo &out_error, const XrdSecEntity *client, const char *info=0)
Definition: XrdOfs.hh:309
XrdSfsDirectory * newDir(char *user=0, int MonID=0)
Definition: XrdOfs.hh:244
char * WaitTime(int, char *, int)
Definition: XrdOfs.cc:2781
struct fwdOpt fwdRMDIR
Definition: XrdOfs.hh:414
XrdOfsEvr evrObject
Definition: XrdOfs.hh:428
static int OSSDelay
Definition: XrdOfs.hh:418
char * ConfigFN
Definition: XrdOfs.hh:420
int tpcRdrPort[2]
Definition: XrdOfs.hh:390
int FAttr(XrdSfsFACtl *faReq, XrdOucErrInfo &eInfo, const XrdSecEntity *client=0)
Definition: XrdOfsFAttr.cc:195
int mkdir(const char *dirName, XrdSfsMode Mode, XrdOucErrInfo &out_error, const XrdSecEntity *client, const char *opaque=0)
Definition: XrdOfs.cc:2074
int remdir(const char *dirName, XrdOucErrInfo &out_error, const XrdSecEntity *client, const char *info=0)
Definition: XrdOfs.hh:315
friend class XrdOfsDirectory
Definition: XrdOfs.hh:237
virtual int Configure(XrdSysError &)
struct fwdOpt fwdMKPATH
Definition: XrdOfs.hh:411
XrdSfsFile * newFile(char *user=0, int MonID=0)
Definition: XrdOfs.hh:250
void Config_Cluster(XrdOss *)
XrdSfsFile * newFile(XrdOucErrInfo &eInfo)
Definition: XrdOfs.hh:253
int fsctl(const int cmd, const char *args, XrdOucErrInfo &out_error, const XrdSecEntity *client=0)
Definition: XrdOfsFSctl.cc:93
void Config_Display(XrdSysError &)
XrdOfs()
Definition: XrdOfs.cc:169
@ isProxy
Definition: XrdOfs.hh:367
@ haveRole
Definition: XrdOfs.hh:372
@ RdrTPC
Definition: XrdOfs.hh:376
@ ThirdPC
Definition: XrdOfs.hh:374
@ isMeta
Definition: XrdOfs.hh:371
@ SubCluster
Definition: XrdOfs.hh:375
@ isManager
Definition: XrdOfs.hh:368
@ isPeer
Definition: XrdOfs.hh:366
@ XAttrPlug
Definition: XrdOfs.hh:365
@ isSuper
Definition: XrdOfs.hh:370
@ isServer
Definition: XrdOfs.hh:369
@ Authorize
Definition: XrdOfs.hh:364
@ Forwarding
Definition: XrdOfs.hh:373
virtual ~XrdOfs()
Definition: XrdOfs.hh:356
char * tpcRdrHost[2]
Definition: XrdOfs.hh:389
int chksum(csFunc Func, const char *csName, const char *Path, XrdOucErrInfo &out_error, const XrdSecEntity *client=0, const char *opaque=0)
Definition: XrdOfs.cc:1783
int rename(const char *oldFileName, const char *newFileName, XrdOucErrInfo &out_error, const XrdSecEntity *client, const char *infoO=0, const char *infoN=0)
Definition: XrdOfs.cc:2257
int Options
Definition: XrdOfs.hh:379
struct fwdOpt fwdMKDIR
Definition: XrdOfs.hh:410
static int MaxDelay
Definition: XrdOfs.hh:417
static int Emsg(const char *, XrdOucErrInfo &, int, const char *x, XrdOfsHandle *hP)
Definition: XrdOfs.cc:2513
struct fwdOpt fwdMV
Definition: XrdOfs.hh:412
XrdNetIF * myIF
Definition: XrdOfs.hh:394
static int fsError(XrdOucErrInfo &myError, int rc)
Definition: XrdOfs.cc:2628
friend class XrdOfsFile
Definition: XrdOfs.hh:238
int FSctl(const int cmd, XrdSfsFSctl &args, XrdOucErrInfo &eInfo, const XrdSecEntity *client=0)
Definition: XrdOfsFSctl.cc:263
int stat(const char *Name, struct stat *buf, XrdOucErrInfo &out_error, const XrdSecEntity *client, const char *opaque=0)
Definition: XrdOfs.cc:2361
const char * getVersion()
struct fwdOpt fwdRM
Definition: XrdOfs.hh:413
virtual int ConfigXeq(char *var, XrdOucStream &, XrdSysError &)
int getStats(char *buff, int blen)
Definition: XrdOfs.cc:2051
struct fwdOpt fwdCHMOD
Definition: XrdOfs.hh:409
int Stall(XrdOucErrInfo &, int, const char *)
Definition: XrdOfs.cc:2702
int exists(const char *fileName, XrdSfsFileExistence &exists_flag, XrdOucErrInfo &out_error, const XrdSecEntity *client, const char *opaque=0)
Definition: XrdOfs.cc:1988
void Unpersist(XrdOfsHandle *hP, int xcev=1)
Definition: XrdOfs.cc:2738
const char * getErrUser()
XrdOucErrInfo & error
virtual void EnvInfo(XrdOucEnv *envP)
virtual int fctl(const int cmd, const char *args, XrdOucErrInfo &eInfo)=0
const char * Cmd
Definition: XrdOfs.hh:399
char * Host
Definition: XrdOfs.hh:400
void Reset()
Definition: XrdOfs.hh:402