1 #ifndef __XRDXROOTDTRANSIT_HH_
2 #define __XRDXROOTDTRANSIT_HH_
33 #include <sys/types.h>
72 static int Attn(
XrdLink *lP,
short *theSID,
int rcode,
73 const struct iovec *ioVec,
int ioNum,
int ioLen);
122 bool Run(
const char *xreqP,
131 int Send(
int rcode,
const struct iovec *ioVec,
int ioNum,
int ioLen);
137 int Send(
long long offset,
int dlen,
int fdnum);
146 {
return SetSF(fhandle, seton);}
164 const struct iovec *ioV,
int ioN,
int ioL);
165 bool Fail(
int ecode,
const char *etext);
168 const char *nameP,
const char *protP
170 bool ReqWrite(
char *xdataP,
int xdataL);
171 bool RunCopy(
char *buffP,
int buffL);
173 const struct iovec *ioV,
int ioN,
int ioL);
175 const struct iovec *ioV,
int ioN,
int ioL);
unsigned char kXR_char
Definition: XPtypes.hh:65
XrdXrootd::Bridge::Result * respObj
Definition: XrdXrootdTransit.hh:196
static const char * reqTab
Definition: XrdXrootdTransit.hh:194
XrdProtocol * realProt
Definition: XrdXrootdTransit.hh:195
bool runDone
Definition: XrdXrootdTransit.hh:206
Definition: XrdXrootdTransPend.hh:42
Definition: XrdXrootdBridge.hh:225
int runError
Definition: XrdXrootdTransit.hh:201
bool Fail(int ecode, const char *etext)
XrdXrootdTransit * spanP
Definition: XrdXrootdTransit.hh:186
Definition: XrdOucSFVec.hh:43
Definition: XrdXrootdBridge.hh:61
XrdSysMutex runMutex
Definition: XrdXrootdTransit.hh:193
char * wBuff
Definition: XrdXrootdTransit.hh:210
int SetSF(kXR_char *fhandle, bool seton=false)
int Process(XrdLink *lp)
Handle link activation (replaces parent activation).
Definition: XrdProtocol.hh:116
~WaitReq()
Definition: XrdXrootdTransit.hh:184
Definition: XrdXrootdProtocol.hh:93
int wBLen
Definition: XrdXrootdTransit.hh:209
int runWait
Definition: XrdXrootdTransit.hh:203
static const char * ReqTable()
Initialize the valid request table.
Definition: XrdScheduler.hh:44
int Wait(XrdXrootd::Bridge::Context &rInfo, const struct iovec *ioV, int ioN, int ioL)
Definition: XrdSysPthread.hh:165
int Send(int rcode, const struct iovec *ioVec, int ioNum, int ioLen)
Handle request data response.
int WaitResp(XrdXrootd::Bridge::Context &rInfo, const struct iovec *ioV, int ioN, int ioL)
XrdObject< XrdXrootdTransit > TranLink
Definition: XrdXrootdTransit.hh:190
bool ReqWrite(char *xdataP, int xdataL)
const char * runEText
Definition: XrdXrootdTransit.hh:197
int runStatus
Definition: XrdXrootdTransit.hh:202
Definition: XrdLink.hh:63
static XrdObjectQ< XrdXrootdTransit > TranStack
Definition: XrdXrootdTransit.hh:189
static XrdXrootdTransit * Alloc(XrdXrootd::Bridge::Result *respP, XrdLink *linkP, XrdSecEntity *seceP, const char *nameP, const char *protP)
Get a new transit object.
WaitReq waitJob
Definition: XrdXrootdTransit.hh:192
int AttnCont(XrdXrootdTransPend *tP, int rcode, const struct iovec *ioV, int ioN, int ioL)
Definition: XrdXrootdTransit.hh:52
bool Disc()
Handle dismantlement.
void Reissue()
Reissue a request after a wait.
bool Run(const char *xreqP, char *xdataP=0, int xdataL=0)
Inject an xrootd request into the protocol stack.
static int Attn(XrdLink *lP, short *theSID, int rcode, const struct iovec *ioVec, int ioNum, int ioLen)
Handle attention response (i.e. async response)
time_t cTime
Definition: XrdXrootdTransit.hh:212
WaitReq(XrdXrootdTransit *tP)
Definition: XrdXrootdTransit.hh:181
int runALen
Definition: XrdXrootdTransit.hh:199
void DoIt()
Definition: XrdXrootdTransit.hh:179
void Recycle(XrdLink *lp, int consec, const char *reason)
Handle link shutdown.
Definition: XrdXrootdBridge.hh:293
virtual ~XrdXrootdTransit()
Definition: XrdXrootdTransit.hh:160
int Process()
Handle protocol redrive after wait.
int runABsz
Definition: XrdXrootdTransit.hh:200
int runWTot
Definition: XrdXrootdTransit.hh:204
bool runWCall
Definition: XrdXrootdTransit.hh:208
XrdXrootdTransit()
Constructor & Destructor.
Definition: XrdXrootdTransit.hh:159
bool RunCopy(char *buffP, int buffL)
Definition: XrdSecEntity.hh:51
char * runArgs
Definition: XrdXrootdTransit.hh:198
int runWMax
Definition: XrdXrootdTransit.hh:205
void SetWait(int wtime, bool notify=false)
Set maximum wait time.
Definition: XrdXrootdTransit.hh:152
bool reInvoke
Definition: XrdXrootdTransit.hh:207
int setSF(kXR_char *fhandle, bool seton=false)
Set sendfile() enablement.
Definition: XrdXrootdTransit.hh:145
Definition: XrdXrootdTransit.hh:177
static void Init(XrdScheduler *schedP, int qMax, int qTTL)
Perform one-time initialization.
const char * pName
Definition: XrdXrootdTransit.hh:211