XRootD
XrdXrootdProtocol.hh
Go to the documentation of this file.
1 #ifndef __XROOTD_PROTOCOL_H__
2 #define __XROOTD_PROTOCOL_H__
3 /******************************************************************************/
4 /* */
5 /* X r d X r o o t d P r o t o c o l . 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 <cstdlib>
33 #include <unistd.h>
34 #include <sys/types.h>
35 
36 #include "XrdNet/XrdNetPMark.hh"
37 #include "XrdSys/XrdSysError.hh"
38 #include "XrdSys/XrdSysPthread.hh"
39 #include "XrdSys/XrdSysRAtomic.hh"
41 #include "XrdSfs/XrdSfsDio.hh"
42 #include "XrdSfs/XrdSfsXioImpl.hh"
43 
44 #include "Xrd/XrdObject.hh"
45 #include "Xrd/XrdProtocol.hh"
49 #include "XProtocol/XProtocol.hh"
50 
51 /******************************************************************************/
52 /* D e f i n e s */
53 /******************************************************************************/
54 
55 #define ROOTD_PQ 2012
56 
57 #define XRD_LOGGEDIN 1
58 #define XRD_NEED_AUTH 2
59 #define XRD_BOUNDPATH 8
60 
61 #ifndef __GNUC__
62 #define __attribute__(x)
63 #endif
64 
65 /******************************************************************************/
66 /* x r d _ P r o t o c o l _ X R o o t d */
67 /******************************************************************************/
68 
69 class XrdNetSocket;
70 class XrdOucEnv;
71 class XrdOucErrInfo;
72 class XrdOucReqID;
73 class XrdOucStream;
74 class XrdOucTList;
75 class XrdOucTokenizer;
76 class XrdSecProtect;
77 class XrdSecProtector;
78 class XrdSfsDirectory;
79 class XrdSfsFileSystem;
80 class XrdSecProtocol;
81 class XrdBuffer;
82 class XrdLink;
83 class XrdTlsContext;
84 class XrdXrootdFile;
85 class XrdXrootdFileLock;
86 class XrdXrootdFileTable;
87 class XrdXrootdJob;
88 class XrdXrootdMonitor;
89 class XrdXrootdPgwCtl;
90 class XrdXrootdPio;
91 class XrdXrootdStats;
92 class XrdXrootdXPath;
93 
94 struct XrdSfsFACtl;
95 struct XrdXrootdWVInfo;
96 
97 /******************************************************************************/
98 /* N a m e s p a c e X r d X r o o t d */
99 /******************************************************************************/
100 
101 namespace XrdXrootd
102 {
103 /******************************************************************************/
104 /* g d C a l l B a c k */
105 /******************************************************************************/
106 
107 class gdCallBack // Used for new style getData() with callback
108 {
109 public:
110 
111 // Called when getData with a buffer successfully completed with a suspension.
112 // A direct return is made if there was no suspension. Return values and action:
113 // >1 If getData with a buffer was called while in the callback, the operation
114 // is performed with a subsequent callback. Otherwise, a fatal error results.
115 // =0 Variable discard holds the number of bytes to be discarded from the
116 // from the socket (default 0). Return is made to link-level.
117 // <0 Considered a fatal link error.
118 //
119 virtual int gdDone() = 0;
120 
121 // Called when a fatal link error occurs during reading.
122 //
123 virtual void gdFail() {} // Called when a link failure occurs
124 
126 virtual ~gdCallBack() {}
127 };
128 
129 /******************************************************************************/
130 /* I O P a r m s */
131 /******************************************************************************/
132 
133 struct IOParms
134 {
136 union {
137 long long Offset;
138 long long WVBytes;
139 int EInfo[2];
140  };
141 int IOLen;
142 unsigned short Flags;
143 char reserved;
144 char Mode;
145 static const int useBasic = 0;
146 static const int useMMap = 1;
147 static const int useSF = 2;
148 };
149 }
150 
151 /******************************************************************************/
152 /* C l a s s X r d X r o o t d P r o t o c o l */
153 /******************************************************************************/
154 
156  public XrdSfsDio, public XrdSfsXio
157 {
158 friend class XrdXrootdAdmin;
159 public:
160 
161  void aioUpdate(int val) {srvrAioOps += val;}
162 
163  void aioUpdReq(int val) {linkAioReq += val;}
164 
165 static char *Buffer(XrdSfsXioHandle h, int *bsz); // XrdSfsXio
166 
167 XrdSfsXioHandle Claim(const char *buff, int datasz, int minasz=0) override;// XrdSfsXio
168 
169 static int Configure(char *parms, XrdProtocol_Config *pi);
170 
171  void DoIt() override {(*this.*Resume)();}
172 
173  int do_WriteSpan();
174 
175  int getData(gdCallBack *gdcbP, const char *dtype,
176  char *buff, int blen);
177 
178  int getData(gdCallBack *gdcbP, const char *dtype,
179  struct iovec *iov, int iovn);
180 
181  int getDump(const char *dtype, int dlen);
182 
183  int getPathID() {return PathID;}
184 
185  XrdProtocol *Match(XrdLink *lp) override;
186 
187  int Process(XrdLink *lp) override; // Sync: Job->Link.DoIt->Process
188 
189  int Process2();
190 
191  int ProcSig();
192 
193  void Recycle(XrdLink *lp, int consec, const char *reason) override;
194 
195 static void Reclaim(XrdSfsXioHandle h); // XrdSfsXio
196 
197  int SendFile(int fildes) override; // XrdSfsDio
198 
199  int SendFile(XrdOucSFVec *sfvec, int sfvnum) override; // XrdSfsDio
200 
201  void SetFD(int fildes) override; // XrdSfsDio
202 
203  int Stats(char *buff, int blen, int do_sync=0) override;
204 
205  void StreamNOP();
206 
207 XrdSfsXioHandle Swap(const char *buff, XrdSfsXioHandle h=0) override; // XrdSfsXio
208 
209 XrdXrootdProtocol *VerifyStream(int &rc, int pID, bool lok=true);
210 
213  ~XrdXrootdProtocol() {Cleanup();}
214 
215 static const int maxStreams = 16;
216 
217 // async configuration values (referenced outside this class)
218 //
219 static int as_maxperlnk; // Max async requests per link
220 static int as_maxperreq; // Max async ops per request
221 static int as_maxpersrv; // Max async ops per server
222 static int as_miniosz; // Min async request size
223 static int as_minsfsz; // Min sendf request size
224 static int as_seghalf;
225 static int as_segsize; // Aio quantum (optimal)
226 static int as_maxstalls; // Maximum stalls we will tolerate
227 static short as_okstutter; // Allowable stutters per transfer unit
228 static short as_timeout; // request timeout (usually < stream timeout)
229 static bool as_force; // aio to be forced
230 static bool as_aioOK; // aio is enabled
231 static bool as_nosf; // sendfile is disabled
232 static bool as_syncw; // writes to be synchronous
233 
234 private:
235 
236 // Note that Route[] structure (below) must have RD_Num elements!
237 //
238 enum RD_func {RD_chmod = 0, RD_chksum, RD_dirlist, RD_locate, RD_mkdir,
239  RD_mv, RD_prepare, RD_prepstg, RD_rm, RD_rmdir,
240  RD_stat, RD_trunc, RD_ovld, RD_client,
241  RD_open1, RD_open2, RD_open3, RD_open4, RD_Num};
242 
243  int do_Auth();
244  int do_Bind();
245  int do_ChkPnt();
246  int do_ChkPntXeq();
247  int do_Chmod();
248  int do_CKsum(int canit);
249  int do_CKsum(char *algT, const char *Path, char *Opaque);
250  int do_Close();
251  int do_Dirlist();
252  int do_DirStat(XrdSfsDirectory *dp, char *pbuff, char *opaque);
253  int do_Endsess();
254  int do_FAttr();
255  int do_gpFile();
256  int do_Login();
257  int do_Locate();
258  int do_Mkdir();
259  int do_Mv();
260  int do_Offload(int (XrdXrootdProtocol::*Invoke)(), int pathID);
261  int do_OffloadIO();
262  int do_Open();
263  bool do_PgClose(XrdXrootdFile *fP, int &rc);
264  int do_PgRead();
265  int do_PgRIO();
266  int do_PgWrite();
267  bool do_PgWAIO(int &rc);
268  int do_PgWIO();
269  int do_PgWIO(bool isFresh);
270  bool do_PgWIORetry(int &rc);
271  bool do_PgWIOSetup(XrdXrootdPgwCtl *pgwCtl);
272  int do_Ping();
273  int do_Prepare(bool isQuery=false);
274  int do_Protocol();
275  int do_Qconf();
276  int do_QconfCX(XrdOucTokenizer &qcargs, char *val);
277  int do_Qfh();
278  int do_Qopaque(short);
279  int do_Qspace();
280  int do_Query();
281  int do_Qxattr();
282  int do_Read();
283  int do_ReadV();
284  int do_ReadAll();
285  int do_ReadNone(int &retc, int &pathID);
286  int do_Rm();
287  int do_Rmdir();
288  int do_Set();
289  int do_Set_Cache(XrdOucTokenizer &setargs);
290  int do_Set_Mon(XrdOucTokenizer &setargs);
291  int do_Stat();
292  int do_Statx();
293  int do_Sync();
294  int do_Truncate();
295  int do_Write();
296  int do_WriteAio();
297  int do_WriteAll();
298  int do_WriteCont();
299  int do_WriteNone();
300  int do_WriteNone(int pathid, XErrorCode ec=kXR_noErrorYet,
301  const char *emsg=0);
302  int do_WriteNoneMsg();
303  int do_WriteV();
304  int do_WriteVec();
305 
306  int gdDone() override {return do_PgWIO(false);}
307 
308  void Assign(const XrdXrootdProtocol &rhs);
309 static int CheckSum(XrdOucStream *, char **, int);
310  void Cleanup();
311 static int Config(const char *fn);
312 static bool ConfigMon(XrdProtocol_Config *pi, XrdOucEnv &xrootdEnv);
313 static int ConfigSecurity(XrdOucEnv &xEnv, const char *cfn);
314  int fsError(int rc, char opc, XrdOucErrInfo &myError,
315  const char *Path, char *Cgi);
316  int fsOvrld(char opc, const char *Path, char *Cgi);
317  int fsRedirNoEnt(const char *eMsg, char *Cgi, int popt);
318  int getBuff(const int isRead, int Quantum);
319  char *getCksType(char *opaque, char *cspec=0, int cslen=0);
320  int getData(const char *dtype, char *buff, int blen);
321  int getDataCont();
322  int getDataIovCont();
323  int getDumpCont();
324  bool logLogin(bool xauth=false);
325 static int mapMode(int mode);
326  void Reset();
327 static int rpCheck(char *fn, char **opaque);
328  int rpEmsg(const char *op, char *fn);
329  int vpEmsg(const char *op, char *fn);
330 static int CheckTLS(const char *tlsProt);
331 static bool ConfigFS(XrdOucEnv &xEnv, const char *cfn);
332 static bool ConfigFS(const char *path, XrdOucEnv &xEnv, const char *cfn);
333 static bool ConfigGStream(XrdOucEnv &myEnv, XrdOucEnv *urEnv);
334 static int Squash(char *);
335  int StatGen(struct stat &buf, char *xxBuff, int xxLen, bool xa=false);
336 static int xapath(XrdOucStream &Config);
337 static int xasync(XrdOucStream &Config);
338 static int xcksum(XrdOucStream &Config);
339 static int xbif(XrdOucStream &Config);
340 static int xdig(XrdOucStream &Config);
341 static int xexp(XrdOucStream &Config);
342 static int xexpdo(char *path, int popt=0);
343 static int xfsl(XrdOucStream &Config);
344 static int xfsL(XrdOucStream &Config, char *val, int lix);
345 static int xfso(XrdOucStream &Config);
346 static int xgpf(XrdOucStream &Config);
347 static int xprep(XrdOucStream &Config);
348 static int xlog(XrdOucStream &Config);
349 static int xmon(XrdOucStream &Config);
350 static char *xmondest(const char *what, char *val);
351 static int xmongs(XrdOucStream &Config);
352 static bool xmongsend(XrdOucStream &Config, char *val, char *&dest,
353  int &opt, int &fmt, int &hdr);
354 static int xred(XrdOucStream &Config);
355 static int xred_clnt(XrdOucStream &Config, char *hP[2], int rPort[2]);
356 static bool xred_php(char *val, char *hP[2], int rPort[2], const char *what,
357  bool optport=false);
358 static void xred_set(RD_func func, char *rHost[2], int rPort[2]);
359 static bool xred_xok(int func, char *rHost[2], int rPort[2]);
360 static int xsecl(XrdOucStream &Config);
361 static int xtls(XrdOucStream &Config);
362 static int xtlsr(XrdOucStream &Config);
363 static int xtrace(XrdOucStream &Config);
364 static int xlimit(XrdOucStream &Config);
365 
366  int ProcFAttr(char *faPath, char *faCgi, char *faArgs,
367  int faALen, int faCode, bool doAChk);
368  int XeqFADel(XrdSfsFACtl &ctl, char *faVars, int faVLen);
369  int XeqFAGet(XrdSfsFACtl &ctl, char *faVars, int faVLen);
370  int XeqFALsd(XrdSfsFACtl &ctl);
371  int XeqFALst(XrdSfsFACtl &ctl);
372  int XeqFASet(XrdSfsFACtl &ctl, char *faVars, int faVLen);
373 
374 static XrdObjectQ<XrdXrootdProtocol> ProtStack;
376 
377 protected:
378 
379 static unsigned int getSID();
380 
381  void MonAuth();
382  int SetSF(kXR_char *fhandle, bool seton=false);
383 
384 static XrdXrootdXPath RPList; // Redirected paths
385 static XrdXrootdXPath RQList; // Redirected paths for ENOENT
386 static XrdXrootdXPath XPList; // Exported paths
387 static XrdSfsFileSystem *osFS; // The filesystem
388 static XrdSfsFileSystem *digFS; // The filesystem (digFS)
389 static XrdSecService *CIA; // Authentication Server
390 static XrdSecProtector *DHS; // Protection Server
391 static XrdTlsContext *tlsCtx; // Protection Server TLS available
392 static XrdXrootdFileLock *Locker; // File lock handler
393 static XrdScheduler *Sched; // System scheduler
394 static XrdBuffManager *BPool; // Buffer manager
395 static XrdSysError &eDest; // Error message handler
396 static XrdNetPMark *PMark; // Packet marking API
397 static const char *myInst;
398 static const char *TraceID;
399 static int RQLxist; // Something is present in RQList
400 static int myPID;
401 static int myRole; // Role for kXR_protocol (>= 2.9.7)
402 static int myRolf; // Role for kXR_protocol (< 2.9.7)
403 
404 static gid_t myGID;
405 static uid_t myUID;
406 static int myGNLen;
407 static int myUNLen;
408 static const char *myGName;
409 static const char *myUName;
410 static time_t keepT;
411 
412 // Admin control area
413 //
415 
416 // Processing configuration values
417 //
418 static int hailWait;
419 static int readWait;
420 static int Port;
421 static int Window;
422 static int tlsPort;
423 static char *Notify;
424 static const char *myCName;
425 static int myCNlen;
426 static char isRedir;
427 static char JobLCL;
428 static char JobCKCGI;
430 static char *JobCKT;
433 static uint64_t fsFeatures;
434 
435 // Static redirection
436 //
437 static struct RD_Table {char *Host[2];
438  unsigned short Port[2];
439  short RDSz[2];} Route[RD_Num];
440 
441 static struct RC_Table {char *Domain[4];
442  short DomCnt;
443  bool pvtIP;
445 
446 static int OD_Stall;
447 static bool OD_Bypass;
448 static bool OD_Redir;
449 
450 static bool CL_Redir;
451 
452 static bool isProxy;
453 
454 // Extended attributes
455 //
456 static int usxMaxNsz;
457 static int usxMaxVsz;
458 static char *usxParms;
459 
460 // TLS configuration
461 //
462 static const char Req_TLSData = 0x01;
463 static const char Req_TLSGPFile= 0x02;
464 static const char Req_TLSLogin = 0x04;
465 static const char Req_TLSSess = 0x08;
466 static const char Req_TLSTPC = 0x10;
467 
468 static char tlsCap; // TLS requirements for capable clients
469 static char tlsNot; // TLS requirements for incapable clients
470 
471 // Buffer configuration
472 //
473 static int maxBuffsz; // Maximum buffer size we can have
474 static int maxTransz; // Maximum transfer size we can have
475 static int maxReadv_ior; // Maximum readv element length
476 
477 // Statistical area
478 //
480 int numReads; // Count for kXR_read
481 int numReadP; // Count for kXR_read pre-preads
482 int numReadV; // Count for kkR_readv
483 int numSegsV; // Count for kkR_readv segmens
484 int numWritV; // Count for kkR_write
485 int numSegsW; // Count for kkR_writev segmens
486 int numWrites; // Count
487 int numFiles; // Count
488 
489 int cumReads; // Count less numReads
490 int cumReadP; // Count less numReadP
491 int cumReadV; // Count less numReadV
492 int cumSegsV; // Count less numSegsV
493 int cumWritV; // Count less numWritV
494 int cumSegsW; // Count less numSegsW
495 int cumWrites; // Count less numWrites
496 int myStalls; // Number of stalls
497 long long totReadP; // Bytes
498 
499 // Data local to each protocol/link combination
500 //
506 int clientPV; // Protocol version + capabilities
507 int clientRN; // Release as maj.min.patch (1 byte each).
508 bool pmDone; // Packet marking has been enabled
509 char reserved[3];
510 short rdType;
511 char Status;
512 unsigned char CapVer;
513 
514 // Authentication area
515 //
520 char *AppName;
521 
522 // Request signing area
523 //
524 ClientRequest sigReq2Ver; // Request to verify
525 SecurityRequest sigReq; // Signature request
526 char sigBuff[64]; // Signature payload SHA256 + blowfish
527 bool sigNeed; // Signature target present
528 bool sigHere; // Signature request present
529 bool sigRead; // Signature being read
530 bool sigWarn; // Once for unneeded signature
531 
532 // Async I/O area, these need to be atomic
533 //
534 RAtomic_int linkAioReq; // Aio requests inflight for link
535 static RAtomic_int srvrAioOps; // Aio operations inflight for server
536 
537 // Buffer information, used to drive getData(), and (*Resume)()
538 //
540 char *myBuff;
541 int myBlen;
543 
545 {
546 int iovNum;
547 int iovNow;
548 union {int iovAdj;
549  int BuffLen;
550  int DumpLen;
551  };
552 bool useCB;
553 char Status;
554 unsigned char stalls;
556 union {struct iovec *iovVec;
557  char *Buffer;
558  };
559 const char *ioDType;
561 
562 static const int inNone = 0;
563 static const int inCallBk = 1;
564 static const int inData = 2;
565 static const int inDataIov = 3;
566 static const int inDump = 4;
567 
568 static const int Active = 1; // linkWait: thread is waiting for link
569 static const int Terminate = 3; // linkWait: thread should immediately exit
570 
572 
574 int (XrdXrootdProtocol::*ResumePio)(); //Used by Offload
577 
578 // Buffer resize control area
579 //
580 static int hcMax;
581  int hcPrev;
582  int hcNext;
583  int hcNow;
585 
586 // This area is used for parallel streams
587 //
588 XrdSysMutex unbindMutex; // If locked always before streamMutex
593 unsigned int mySID;
594 bool isActive;
595 bool isLinkWT;
596 bool isNOP;
597 bool isDead;
598 
599 static const int maxPio = 4;
603 
604 short PathID; // Path for this protocol object
605 bool newPio; // True when initially scheduled
606 unsigned char rvSeq;
607 unsigned char wvSeq;
608 
609 char doTLS; // TLS requirements for client
610 bool ableTLS; // T->Client is able to use TLS
611 bool isTLS; // T->Client using TLS on control stream
612 
613 // Track usage limts.
614 //
615 static bool PrepareAlt; // Use alternate prepare handling
616 static bool LimitError; // Indicates that hitting a limit should result in an error response.
617  // If false, when possible, silently ignore errors.
619 static int PrepareLimit;
620 
621 // Buffers to handle client requests
622 //
626 };
627 #endif
XErrorCode
Definition: XProtocol.hh:989
@ kXR_noErrorYet
Definition: XProtocol.hh:1027
unsigned char kXR_char
Definition: XPtypes.hh:65
#define stat(a, b)
Definition: XrdPosix.hh:101
XrdOucString Path
#define eMsg(x)
int emsg(int rc, char *msg)
class XrdBuffer * XrdSfsXioHandle
Definition: XrdSfsXio.hh:46
static XrdXrootdStats * SI
static const char * myInst
int SendFile(int fildes) override
XrdXrootdProtocol * VerifyStream(int &rc, int pID, bool lok=true)
static XrdSfsFileSystem * digFS
int SetSF(kXR_char *fhandle, bool seton=false)
XrdSecProtect * Protect
int getData(gdCallBack *gdcbP, const char *dtype, struct iovec *iov, int iovn)
XrdNetPMark::Handle * pmHandle
static XrdNetPMark * PMark
XrdXrootdProtocol * Stream[maxStreams]
XrdXrootd::IOParms IO
static short as_okstutter
static XrdXrootdXPath RPList
static XrdNetSocket * AdminSock
XrdSecEntity * Client
static const char Req_TLSGPFile
XrdProtocol * Match(XrdLink *lp) override
struct XrdXrootdProtocol::GetDataCtl gdCtl
ClientRequest sigReq2Ver
void aioUpdate(int val)
void SetFD(int fildes) override
static const char Req_TLSSess
XrdXrootdWVInfo * wvInfo
XrdXrootdPgwCtl * pgwCtl
static void Reclaim(XrdSfsXioHandle h)
XrdSysSemaphore * reTry
XrdXrootdFileTable * FTab
static XrdXrootdJob * JobCKS
static XrdSysError & eDest
void aioUpdReq(int val)
static unsigned int getSID()
XrdSecProtocol * AuthProt
int getData(gdCallBack *gdcbP, const char *dtype, char *buff, int blen)
XrdSfsXioHandle Claim(const char *buff, int datasz, int minasz=0) override
static char * usxParms
XrdXrootdMonitor::User Monitor
static const char * myCName
XrdXrootdPio * pioFree
static const char Req_TLSData
XrdSfsXioHandle Swap(const char *buff, XrdSfsXioHandle h=0) override
static XrdXrootdFileLock * Locker
static const int maxPio
SecurityRequest sigReq
int(XrdXrootdProtocol::* Resume)()
static const char Req_TLSTPC
static XrdTlsContext * tlsCtx
XrdXrootdPio * pioLast
static XrdXrootdXPath XPList
static XrdScheduler * Sched
static struct XrdXrootdProtocol::RC_Table RouteClient
int Process(XrdLink *lp) override
void Recycle(XrdLink *lp, int consec, const char *reason) override
static char * Buffer(XrdSfsXioHandle h, int *bsz)
static const char * myUName
static const char Req_TLSLogin
XrdXrootdResponse Response
int(XrdXrootdProtocol::* ResumePio)()
static const char * TraceID
void DoIt() override
static int Configure(char *parms, XrdProtocol_Config *pi)
int Stats(char *buff, int blen, int do_sync=0) override
static const int maxStreams
int getDump(const char *dtype, int dlen)
static XrdOucTList * JobCKTLST
static XrdXrootdXPath RQList
static XrdSecProtector * DHS
static XrdBuffManager * BPool
static XrdSecService * CIA
static RAtomic_int srvrAioOps
static const char * myGName
static uint64_t fsFeatures
XrdXrootdReqID ReqID
static XrdOucReqID * PrepID
XrdXrootdPio * pioFirst
XrdSysCondVar2 * endNote
static struct XrdXrootdProtocol::RD_Table Route[RD_Num]
static XrdSfsFileSystem * osFS
XrdXrootdProtocol operator=(const XrdXrootdProtocol &rhs)=delete
virtual int gdDone()=0
XrdCmsConfig Config
XrdXrootd::gdCallBack * CallBack
static const int useSF
static const int useBasic
XrdXrootdFile * File
static const int useMMap