Go to the documentation of this file. 1 #ifndef __XROOTD_PROTOCOL_H__
2 #define __XROOTD_PROTOCOL_H__
34 #include <sys/types.h>
55 #define XRD_LOGGEDIN 1
56 #define XRD_NEED_AUTH 2
57 #define XRD_BOUNDPATH 8
60 #define __attribute__(x)
92 class XrdXrootdWVInfo;
129 int Stats(
char *buff,
int blen,
int do_sync=0);
150 int do_CKsum(
char *algT,
const char *Path,
char *Opaque);
209 const char *Path,
char *Cgi);
210 int fsOvrld(
char opc,
const char *Path,
char *Cgi);
213 int getData(
const char *dtype,
char *buff,
int blen);
226 int StatGen(
struct stat &buf,
char *xxBuff,
int xxLen,
bool xa=
false);
232 static int xexpdo(
char *path,
int popt=0);
241 static bool xred_php(
char *val,
char *hP[2],
int rPort[2]);
243 static bool xred_xok(
int func,
char *rHost[2],
int rPort[2]);
251 int faALen,
int faCode,
bool doAChk);
int hcNext
Definition: XrdXrootdProtocol.hh:431
Definition: XrdXrootdJob.hh:52
bool isActive
Definition: XrdXrootdProtocol.hh:442
@ RD_mv
Definition: XrdXrootdProtocol.hh:142
long long bytes2send
Definition: XrdXrootdProtocol.hh:452
int reserved
Definition: XrdXrootdProtocol.hh:389
bool isDead
Definition: XrdXrootdProtocol.hh:443
int fsOvrld(char opc, const char *Path, char *Cgi)
XrdBuffer * argp
Definition: XrdXrootdProtocol.hh:384
static const int maxRvecsz
Definition: XrdXrootdProtocol.hh:357
bool doWrite
Definition: XrdXrootdProtocol.hh:457
Definition: XrdSfsXio.hh:55
static int myUNLen
Definition: XrdXrootdProtocol.hh:290
int do_QconfCX(XrdOucTokenizer &qcargs, char *val)
static const char Req_TLSSess
Definition: XrdXrootdProtocol.hh:336
static char JobLCL
Definition: XrdXrootdProtocol.hh:310
int hcNow
Definition: XrdXrootdProtocol.hh:432
@ RD_open1
Definition: XrdXrootdProtocol.hh:144
int cumWrites
Definition: XrdXrootdProtocol.hh:378
int cumSegsV
Definition: XrdXrootdProtocol.hh:375
static XrdSecProtector * DHS
Definition: XrdXrootdProtocol.hh:274
XrdLink * Link
Definition: XrdXrootdProtocol.hh:383
Definition: XrdSysPthread.hh:166
static int as_miniosz
Definition: XrdXrootdProtocol.hh:347
ClientRequest Request
Definition: XrdXrootdProtocol.hh:477
XrdSecProtect * Protect
Definition: XrdXrootdProtocol.hh:399
bool doPgIO
Definition: XrdXrootdProtocol.hh:456
XrdXrootdMonitor::User Monitor
Definition: XrdXrootdProtocol.hh:386
static int as_maxperreq
Definition: XrdXrootdProtocol.hh:345
RD_func
Definition: XrdXrootdProtocol.hh:141
short rdType
Definition: XrdXrootdProtocol.hh:390
static int xfsL(XrdOucStream &Config, char *val, int lix)
static int OD_Stall
Definition: XrdXrootdProtocol.hh:323
Definition: XrdSfsInterface.hh:816
bool sigNeed
Definition: XrdXrootdProtocol.hh:405
Definition: XrdXrootdMonitor.hh:75
XrdSfsXioHandle Swap(const char *buff, XrdSfsXioHandle h=0)
static int xsecl(XrdOucStream &Config)
static XrdXrootdFileLock * Locker
Definition: XrdXrootdProtocol.hh:276
static XrdXrootdJob * JobCKS
Definition: XrdXrootdProtocol.hh:312
static XrdXrootdXPath RQList
Definition: XrdXrootdProtocol.hh:269
int Stats(char *buff, int blen, int do_sync=0)
static XrdBuffManager * BPool
Definition: XrdXrootdProtocol.hh:278
char * myBuff
Definition: XrdXrootdProtocol.hh:413
bool sigWarn
Definition: XrdXrootdProtocol.hh:408
static int hailWait
Definition: XrdXrootdProtocol.hh:301
int do_DirStat(XrdSfsDirectory *dp, char *pbuff, char *opaque)
XrdXrootdPio * pioLast
Definition: XrdXrootdProtocol.hh:449
static int hcMax
Definition: XrdXrootdProtocol.hh:429
static char * JobCKT
Definition: XrdXrootdProtocol.hh:313
@ RD_prepare
Definition: XrdXrootdProtocol.hh:142
static bool ConfigFS(const char *path, XrdOucEnv &xEnv, const char *cfn)
static bool PrepareAlt
Definition: XrdXrootdProtocol.hh:468
static bool OD_Redir
Definition: XrdXrootdProtocol.hh:325
void Recycle(XrdLink *lp, int consec, const char *reason)
Definition: XrdBuffer.hh:72
int do_ReadAll(int asyncOK=1)
short PathID
Definition: XrdXrootdProtocol.hh:454
bool doWriteC
Definition: XrdXrootdProtocol.hh:458
XrdXrootdWVInfo * wvInfo
Definition: XrdXrootdProtocol.hh:418
Definition: XrdXrootdXPath.hh:43
int(XrdXrootdProtocol::* Resume)()
Definition: XrdXrootdProtocol.hh:416
@ RD_locate
Definition: XrdXrootdProtocol.hh:141
static char * Notify
Definition: XrdXrootdProtocol.hh:306
unsigned char kXR_char
Definition: XPtypes.hh:65
unsigned char CapVer
Definition: XrdXrootdProtocol.hh:392
int getBuff(const int isRead, int Quantum)
Definition: XrdSecInterface.hh:552
@ RD_ovld
Definition: XrdXrootdProtocol.hh:143
@ RD_prepstg
Definition: XrdXrootdProtocol.hh:142
static int xtlsr(XrdOucStream &Config)
class XrdBuffer * XrdSfsXioHandle
Definition: XrdSfsXio.hh:46
int clientPV
Definition: XrdXrootdProtocol.hh:387
static int Squash(char *)
Definition: XrdXrootdReqID.hh:36
Definition: XrdProtocol.hh:56
static int as_nosf
Definition: XrdXrootdProtocol.hh:353
Definition: XrdXrootdResponse.hh:49
static uid_t myUID
Definition: XrdXrootdProtocol.hh:288
bool sigRead
Definition: XrdXrootdProtocol.hh:407
int XeqFASet(XrdSfsFACtl &ctl, char *faVars, int faVLen)
void Assign(const XrdXrootdProtocol &rhs)
XrdSfsXioHandle Claim(const char *buff, int datasz, int minasz=0)
int aio_Error(const char *op, int ecode)
static gid_t myGID
Definition: XrdXrootdProtocol.hh:287
bool isNOP
Definition: XrdXrootdProtocol.hh:445
int getData(const char *dtype, char *buff, int blen)
static XrdSysError eDest
Definition: XrdXrootdProtocol.hh:279
static int Port
Definition: XrdXrootdProtocol.hh:303
static int maxBuffsz
Definition: XrdXrootdProtocol.hh:355
static int as_maxpersrv
Definition: XrdXrootdProtocol.hh:346
int myIOLen
Definition: XrdXrootdProtocol.hh:424
int clientRN
Definition: XrdXrootdProtocol.hh:388
static XrdObjectQ< XrdXrootdProtocol > ProtStack
Definition: XrdXrootdProtocol.hh:258
int SetSF(kXR_char *fhandle, bool seton=false)
bool sigHere
Definition: XrdXrootdProtocol.hh:406
static XrdNetSocket * AdminSock
Definition: XrdXrootdProtocol.hh:297
Definition: XrdXrootdStats.hh:40
static int xapath(XrdOucStream &Config)
static void Reclaim(XrdSfsXioHandle h)
static int xasync(XrdOucStream &Config)
static bool xred_xok(int func, char *rHost[2], int rPort[2])
unsigned char rvSeq
Definition: XrdXrootdProtocol.hh:459
Definition: XrdXrootdPio.hh:39
Definition: XrdOucStream.hh:47
int numWrites
Definition: XrdXrootdProtocol.hh:369
static int xlimit(XrdOucStream &Config)
int cumReadP
Definition: XrdXrootdProtocol.hh:373
int fsError(int rc, char opc, XrdOucErrInfo &myError, const char *Path, char *Cgi)
static int RQLxist
Definition: XrdXrootdProtocol.hh:282
int myBlast
Definition: XrdXrootdProtocol.hh:415
static int Quantum
Definition: XrdXrootdAio.hh:146
@ RD_mkdir
Definition: XrdXrootdProtocol.hh:141
int numReadV
Definition: XrdXrootdProtocol.hh:365
static int tlsPort
Definition: XrdXrootdProtocol.hh:305
Definition: XrdTlsContext.hh:37
static int usxMaxVsz
Definition: XrdXrootdProtocol.hh:330
~XrdXrootdProtocol()
Definition: XrdXrootdProtocol.hh:135
static int myPID
Definition: XrdXrootdProtocol.hh:283
int numFiles
Definition: XrdXrootdProtocol.hh:370
static int xtls(XrdOucStream &Config)
static int ConfigSecurity(XrdOucEnv &xEnv, const char *cfn)
int do_CKsum(char *algT, const char *Path, char *Opaque)
int StatGen(struct stat &buf, char *xxBuff, int xxLen, bool xa=false)
int myEInfo[2]
Definition: XrdXrootdProtocol.hh:422
static int xprep(XrdOucStream &Config)
Definition: XrdXrootdFile.hh:148
static const char * TraceID
Definition: XrdXrootdProtocol.hh:281
static XrdSecService * CIA
Definition: XrdXrootdProtocol.hh:273
char sigBuff[64]
Definition: XrdXrootdProtocol.hh:404
static bool LimitError
Definition: XrdXrootdProtocol.hh:469
static XrdXrootdXPath RPList
Definition: XrdXrootdProtocol.hh:268
@ RD_open3
Definition: XrdXrootdProtocol.hh:144
bool isBound
Definition: XrdXrootdProtocol.hh:444
XrdSecProtocol * AuthProt
Definition: XrdXrootdProtocol.hh:397
int numSegsV
Definition: XrdXrootdProtocol.hh:366
static int myRole
Definition: XrdXrootdProtocol.hh:284
Definition: XrdSfsInterface.hh:239
long long myWVBytes
Definition: XrdXrootdProtocol.hh:421
static char * Buffer(XrdSfsXioHandle h, int *bsz)
static bool OD_Bypass
Definition: XrdXrootdProtocol.hh:324
long long bytes2recv
Definition: XrdXrootdProtocol.hh:451
SecurityRequest sigReq
Definition: XrdXrootdProtocol.hh:403
Definition: XrdSysPthread.hh:404
bool ableTLS
Definition: XrdXrootdProtocol.hh:463
int numReadP
Definition: XrdXrootdProtocol.hh:364
XrdXrootdReqID ReqID
Definition: XrdXrootdProtocol.hh:476
Definition: XrdOucEnv.hh:42
static const char * myInst
Definition: XrdXrootdProtocol.hh:280
static int xlog(XrdOucStream &Config)
Definition: XProtocol.hh:788
int vpEmsg(const char *op, char *fn)
bool isTLS
Definition: XrdXrootdProtocol.hh:464
char doTLS
Definition: XrdXrootdProtocol.hh:462
char * Host[2]
Definition: XrdXrootdProtocol.hh:320
static int readWait
Definition: XrdXrootdProtocol.hh:302
XrdXrootdFileTable * FTab
Definition: XrdXrootdProtocol.hh:385
static int xexpdo(char *path, int popt=0)
Definition: XrdXrootdAio.hh:99
static int as_segsize
Definition: XrdXrootdProtocol.hh:349
Definition: XrdScheduler.hh:45
int SendFile(XrdOucSFVec *sfvec, int sfvnum)
int XeqFALst(XrdSfsFACtl &ctl)
Definition: XProtocol.hh:822
static const int maxPio
Definition: XrdXrootdProtocol.hh:447
int ProcFAttr(char *faPath, char *faCgi, char *faArgs, int faALen, int faCode, bool doAChk)
static int xdig(XrdOucStream &Config)
int cumWritV
Definition: XrdXrootdProtocol.hh:376
int myBlen
Definition: XrdXrootdProtocol.hh:414
Definition: XrdXrootdFileLock.hh:33
static XrdXrootdStats * SI
Definition: XrdXrootdProtocol.hh:362
int numSegsW
Definition: XrdXrootdProtocol.hh:368
@ RD_rm
Definition: XrdXrootdProtocol.hh:142
static int maxTransz
Definition: XrdXrootdProtocol.hh:356
unsigned int mySID
Definition: XrdXrootdProtocol.hh:441
static int CheckSum(XrdOucStream *, char **, int)
@ RD_trunc
Definition: XrdXrootdProtocol.hh:143
Definition: XrdLink.hh:52
unsigned short myFlags
Definition: XrdXrootdProtocol.hh:455
int do_ReadNone(int &retc, int &pathID)
static XrdSfsFileSystem * osFS
Definition: XrdXrootdProtocol.hh:271
static int Config(const char *fn)
static int xexp(XrdOucStream &Config)
static XrdSfsFileSystem * digFS
Definition: XrdXrootdProtocol.hh:272
static int CheckTLS(const char *tlsProt)
@ RD_stat
Definition: XrdXrootdProtocol.hh:143
static unsigned int getSID()
static int as_minsfsz
Definition: XrdXrootdProtocol.hh:348
Definition: XrdSecProtect.hh:56
static struct XrdXrootdProtocol::RD_Table Route[RD_Num]
Definition: XrdOucReqID.hh:42
Definition: XrdNetSocket.hh:48
static int as_maxstalls
Definition: XrdXrootdProtocol.hh:350
int numReads
Definition: XrdXrootdProtocol.hh:363
int cumReads
Definition: XrdXrootdProtocol.hh:372
static int xgpf(XrdOucStream &Config)
static int as_noaio
Definition: XrdXrootdProtocol.hh:352
static int PrepareLimit
Definition: XrdXrootdProtocol.hh:472
Definition: XrdSecProtector.hh:73
static int xred(XrdOucStream &Config)
static XrdXrootdXPath XPList
Definition: XrdXrootdProtocol.hh:270
Definition: XrdSecInterface.hh:131
int do_Offload(int pathID, bool isWrite, bool ispgio=false)
XrdSysSemaphore * reTry
Definition: XrdXrootdProtocol.hh:439
static int xfso(XrdOucStream &Config)
int cumReadV
Definition: XrdXrootdProtocol.hh:374
Definition: XrdSfsFAttr.hh:73
Definition: XrdXrootdFile.hh:98
static const char * myCName
Definition: XrdXrootdProtocol.hh:307
static int Configure(char *parms, XrdProtocol_Config *pi)
XrdSecEntity Entity
Definition: XrdXrootdProtocol.hh:398
static const char Req_TLSGPFile
Definition: XrdXrootdProtocol.hh:334
static int xtrace(XrdOucStream &Config)
static int myCNlen
Definition: XrdXrootdProtocol.hh:308
static int xcksum(XrdOucStream &Config)
XrdXrootdPio * pioFirst
Definition: XrdXrootdProtocol.hh:448
static char JobCKCGI
Definition: XrdXrootdProtocol.hh:311
@ RD_rmdir
Definition: XrdXrootdProtocol.hh:142
static void ConfigGStream(XrdOucEnv &myEnv, XrdOucEnv *urEnv)
int do_Prepare(bool isQuery=false)
XrdSecEntity * Client
Definition: XrdXrootdProtocol.hh:396
static int myGNLen
Definition: XrdXrootdProtocol.hh:289
short RDSz[2]
Definition: XrdXrootdProtocol.hh:322
XrdXrootdFile * myFile
Definition: XrdXrootdProtocol.hh:417
static char * usxParms
Definition: XrdXrootdProtocol.hh:331
static int Window
Definition: XrdXrootdProtocol.hh:304
Definition: XrdProtocol.hh:125
int rpEmsg(const char *op, char *fn)
static int xmon(XrdOucStream &Config)
bool logLogin(bool xauth=false)
int PrepareCount
Definition: XrdXrootdProtocol.hh:471
int hcPrev
Definition: XrdXrootdProtocol.hh:430
Definition: XrdSfsDio.hh:47
static int myRolf
Definition: XrdXrootdProtocol.hh:285
static uint64_t fsFeatures
Definition: XrdXrootdProtocol.hh:316
Definition: XrdSecEntity.hh:64
static XrdScheduler * Sched
Definition: XrdXrootdProtocol.hh:277
int getPathID(bool isRead)
Definition: XrdOucErrInfo.hh:99
Definition: XrdBuffer.hh:42
Definition: XrdXrootdProtocol.hh:96
static bool ConfigFS(XrdOucEnv &xEnv, const char *cfn)
XrdXrootdProtocol * Stream[maxStreams]
Definition: XrdXrootdProtocol.hh:440
@ RD_Num
Definition: XrdXrootdProtocol.hh:144
#define stat(a, b)
Definition: XrdPosix.hh:96
static int as_syncw
Definition: XrdXrootdProtocol.hh:354
static void xred_set(RD_func func, char *rHost[2], int rPort[2])
static XrdTlsContext * tlsCtx
Definition: XrdXrootdProtocol.hh:275
Definition: XrdOucSFVec.hh:43
char Status
Definition: XrdXrootdProtocol.hh:391
int fsRedirNoEnt(const char *eMsg, char *Cgi, int popt)
@ RD_dirlist
Definition: XrdXrootdProtocol.hh:141
Definition: XrdOucTrace.hh:36
int halfBSize
Definition: XrdXrootdProtocol.hh:433
static time_t keepT
Definition: XrdXrootdProtocol.hh:293
Definition: XrdOucTokenizer.hh:33
int numWritV
Definition: XrdXrootdProtocol.hh:367
static XrdOucReqID * PrepID
Definition: XrdXrootdProtocol.hh:315
static const char * myGName
Definition: XrdXrootdProtocol.hh:291
static bool xred_php(char *val, char *hP[2], int rPort[2])
Definition: XrdSysError.hh:90
XrdObject< XrdXrootdProtocol > ProtLink
Definition: XrdXrootdProtocol.hh:259
static const char Req_TLSTPC
Definition: XrdXrootdProtocol.hh:337
@ RD_chmod
Definition: XrdXrootdProtocol.hh:141
static const char Req_TLSData
Definition: XrdXrootdProtocol.hh:333
static char tlsNot
Definition: XrdXrootdProtocol.hh:340
int XeqFADel(XrdSfsFACtl &ctl, char *faVars, int faVLen)
XrdXrootdPio * pioFree
Definition: XrdXrootdProtocol.hh:450
XrdXrootdProtocol operator=(const XrdXrootdProtocol &rhs)=delete
int do_Set_Mon(XrdOucTokenizer &setargs)
static char isRedir
Definition: XrdXrootdProtocol.hh:309
XrdXrootdAioReq * myAioReq
Definition: XrdXrootdProtocol.hh:412
XrdProtocol * Match(XrdLink *lp)
static int rpCheck(char *fn, char **opaque)
int XeqFAGet(XrdSfsFACtl &ctl, char *faVars, int faVLen)
int myStalls
Definition: XrdXrootdProtocol.hh:425
void DoIt()
Definition: XrdXrootdProtocol.hh:107
Definition: XrdXrootdMonitor.hh:142
static const int maxWvecsz
Definition: XrdXrootdProtocol.hh:358
long long myOffset
Definition: XrdXrootdProtocol.hh:420
static int usxMaxNsz
Definition: XrdXrootdProtocol.hh:329
static const int maxStreams
Definition: XrdXrootdProtocol.hh:437
ClientRequest sigReq2Ver
Definition: XrdXrootdProtocol.hh:402
Definition: XrdOucTList.hh:42
static char tlsCap
Definition: XrdXrootdProtocol.hh:339
@ RD_open4
Definition: XrdXrootdProtocol.hh:144
@ RD_chksum
Definition: XrdXrootdProtocol.hh:141
static int mapMode(int mode)
int cumSegsW
Definition: XrdXrootdProtocol.hh:377
static const char Req_TLSLogin
Definition: XrdXrootdProtocol.hh:335
Definition: XrdXrootdProtocol.hh:320
int XeqFALsd(XrdSfsFACtl &ctl)
XrdXrootdResponse Response
Definition: XrdXrootdProtocol.hh:478
static int xfsl(XrdOucStream &Config)
static int as_force
Definition: XrdXrootdProtocol.hh:351
unsigned short Port[2]
Definition: XrdXrootdProtocol.hh:321
XrdSysMutex streamMutex
Definition: XrdXrootdProtocol.hh:438
static XrdOucTList * JobCKTLST
Definition: XrdXrootdProtocol.hh:314
unsigned char wvSeq
Definition: XrdXrootdProtocol.hh:460
static const char * myUName
Definition: XrdXrootdProtocol.hh:292
char * AppName
Definition: XrdXrootdProtocol.hh:400
long long totReadP
Definition: XrdXrootdProtocol.hh:379
Definition: XrdXrootdAdmin.hh:44
static int as_maxperlnk
Definition: XrdXrootdProtocol.hh:344
@ RD_open2
Definition: XrdXrootdProtocol.hh:144