#include <XrdXrootdTransit.hh>

Inheritance diagram for XrdXrootdTransit:

Collaboration diagram for XrdXrootdTransit:

Public Member Functions
	XrdXrootdTransit ()
	Constructor & Destructor.

virtual	~XrdXrootdTransit ()

bool	Disc ()
	Handle dismantlement.

void	Proceed ()
	Resume processing after a waitresp completion.

int	Process (XrdLink *lp)
	Handle link activation (replaces parent activation).

void	Recycle (XrdLink lp, int consec, const char reason)
	Handle link shutdown.

void	Redrive ()
	Redrive a request after a wait.

bool	Run (const char xreqP, char xdataP=0, int xdataL=0)
	Inject an xrootd request into the protocol stack.

int	Send (int rcode, const struct iovec *ioVec, int ioNum, int ioLen)
	Handle request data response.

int	Send (long long offset, int dlen, int fdnum)
	Handle request sendfile response.

int	Send (XrdOucSFVec *sfvec, int sfvnum, int dlen)

int	setSF (kXR_char *fhandle, bool seton=false)
	Set sendfile() enablement.

void	SetWait (int wtime, bool notify=false)
	Set maximum wait time.

Public Member Functions inherited from XrdXrootd::Bridge
	Bridge ()
	Constructor & Destructor.

Public Member Functions inherited from XrdXrootdProtocol
	XrdXrootdProtocol ()

	~XrdXrootdProtocol ()

void	aioUpdate (int val)

void	aioUpdReq (int val)

XrdSfsXioHandle	Claim (const char *buff, int datasz, int minasz=0) override

int	do_WriteSpan ()

void	DoIt () override

int	getData (gdCallBack gdcbP, const char dtype, char *buff, int blen)

int	getData (gdCallBack gdcbP, const char dtype, struct iovec *iov, int iovn)

int	getDump (const char *dtype, int dlen)

int	getPathID ()

XrdProtocol *	Match (XrdLink *lp) override

XrdXrootdProtocol	operator= (const XrdXrootdProtocol &rhs)=delete

int	Process2 ()

int	ProcSig ()

int	SendFile (int fildes) override

int	SendFile (XrdOucSFVec *sfvec, int sfvnum) override

void	SetFD (int fildes) override

int	Stats (char *buff, int blen, int do_sync=0) override

void	StreamNOP ()

XrdSfsXioHandle	Swap (const char *buff, XrdSfsXioHandle h=0) override

XrdXrootdProtocol *	VerifyStream (int &rc, int pID, bool lok=true)

Public Member Functions inherited from XrdProtocol
	XrdProtocol (const char *jname)

virtual	~XrdProtocol ()

Public Member Functions inherited from XrdJob
	XrdJob (const char *desc="")

virtual	~XrdJob ()

Public Member Functions inherited from XrdXrootd::gdCallBack
	gdCallBack ()

virtual	~gdCallBack ()

virtual void	gdFail ()

Public Member Functions inherited from XrdSfsDio
	XrdSfsDio ()
	Constructor and destructor.

virtual	~XrdSfsDio ()

Public Member Functions inherited from XrdSfsXio
	XrdSfsXio (XrdSfsXioImpl &xioimpl)

virtual	~XrdSfsXio ()
	Constructor and destructor.

Static Public Member Functions
static XrdXrootdTransit *	Alloc (XrdXrootd::Bridge::Result respP, XrdLink linkP, XrdSecEntity seceP, const char nameP, const char *protP)
	Get a new transit object.

static int	Attn (XrdLink lP, short theSID, int rcode, const struct iovec *ioVec, int ioNum, int ioLen)
	Handle attention response (i.e. async response)

static void	Init (XrdScheduler *schedP, int qMax, int qTTL)
	Perform one-time initialization.

static const char *	ReqTable ()
	Initialize the valid request table.

Static Public Member Functions inherited from XrdXrootd::Bridge
static Bridge *	Login (Result rsltP, XrdLink linkP, XrdSecEntity seceP, const char nameP, const char *protP)

Static Public Member Functions inherited from XrdXrootdProtocol
static char *	Buffer (XrdSfsXioHandle h, int *bsz)

static int	Configure (char parms, XrdProtocol_Config pi)

static void	Reclaim (XrdSfsXioHandle h)

Static Public Member Functions inherited from XrdSfsXio
static char *	Buffer (XrdSfsXioHandle theHand, int *buffsz=0)

static void	Reclaim (XrdSfsXioHandle theHand)

Additional Inherited Members
Public Attributes inherited from XrdJob
const char *	Comment

XrdJob *	NextJob

Static Public Attributes inherited from XrdXrootdProtocol
static bool	as_aioOK = true

static bool	as_force = false

static int	as_maxperlnk = 8

static int	as_maxperreq = 8

static int	as_maxpersrv = 4096

static int	as_maxstalls = 4

static int	as_miniosz = 98304

static int	as_minsfsz = 8192

static bool	as_nosf = false

static short	as_okstutter = 1

static int	as_seghalf = 32768

static int	as_segsize = 65536

static bool	as_syncw = false

static short	as_timeout = 45

static const int	maxStreams = 16

Protected Member Functions inherited from XrdXrootd::Bridge
virtual	~Bridge ()

Protected Member Functions inherited from XrdXrootdProtocol
void	MonAuth ()

int	SetSF (kXR_char *fhandle, bool seton=false)

Static Protected Member Functions inherited from XrdXrootdProtocol
static unsigned int	getSID ()

Protected Attributes inherited from XrdXrootdProtocol
bool	ableTLS

char *	AppName

XrdBuffer *	argp

XrdSecProtocol *	AuthProt

unsigned char	CapVer

XrdSecEntity *	Client

int	clientPV

int	clientRN

int	cumReadP

int	cumReads

int	cumReadV

int	cumSegsV

int	cumSegsW

int	cumWrites

int	cumWritV

char	doTLS

XrdSysCondVar2 *	endNote

XrdSecEntity	Entity

XrdXrootdFileTable *	FTab

struct XrdXrootdProtocol::GetDataCtl	gdCtl

int	halfBSize

int	hcNext

int	hcNow

int	hcPrev

XrdXrootd::IOParms	IO

bool	isActive

bool	isDead

bool	isLinkWT

bool	isNOP

bool	isTLS

XrdLink *	Link

RAtomic_int	linkAioReq

XrdXrootdMonitor::User	Monitor

int	myBlast

int	myBlen

char *	myBuff

unsigned int	mySID

int	myStalls

bool	newPio

int	numFiles

int	numReadP

int	numReads

int	numReadV

int	numSegsV

int	numSegsW

int	numWrites

int	numWritV

short	PathID

XrdXrootdPgwCtl *	pgwCtl

XrdXrootdPio *	pioFirst

XrdXrootdPio *	pioFree

XrdXrootdPio *	pioLast

bool	pmDone

XrdNetPMark::Handle *	pmHandle

int	PrepareCount

XrdSecProtect *	Protect

short	rdType

XrdXrootdReqID	ReqID

ClientRequest	Request

char	reserved [3]

XrdXrootdResponse	Response

int(XrdXrootdProtocol::*	Resume )()

int(XrdXrootdProtocol::*	ResumePio )()

XrdSysSemaphore *	reTry

unsigned char	rvSeq

char	sigBuff [64]

bool	sigHere

bool	sigNeed

bool	sigRead

SecurityRequest	sigReq

ClientRequest	sigReq2Ver

bool	sigWarn

char	Status

XrdXrootdProtocol *	Stream [maxStreams]

XrdSysMutex	streamMutex

long long	totReadP

XrdSysMutex	unbindMutex

XrdXrootdWVInfo *	wvInfo

unsigned char	wvSeq

Static Protected Attributes inherited from XrdXrootdProtocol
static XrdNetSocket *	AdminSock = 0

static XrdBuffManager *	BPool

static XrdSecService *	CIA = 0

static bool	CL_Redir = false

static XrdSecProtector *	DHS = 0

static XrdSfsFileSystem *	digFS = 0

static XrdSysError &	eDest = XrdXrootd::eLog

static uint64_t	fsFeatures = 0

static int	hailWait

static int	hcMax = 28657

static bool	isProxy = false

static char	isRedir = 0

static char	JobCKCGI =0

static XrdXrootdJob *	JobCKS = 0

static char *	JobCKT = 0

static XrdOucTList *	JobCKTLST = 0

static char	JobLCL = 0

static time_t	keepT = 86400

static bool	LimitError = true

static XrdXrootdFileLock *	Locker

static int	maxBuffsz

static const int	maxPio = 4

static int	maxReadv_ior

static int	maxTransz = 262144

static const char *	myCName = 0

static int	myCNlen = 0

static gid_t	myGID = 0

static const char *	myGName = "?"

static int	myGNLen = 1

static const char *	myInst = 0

static int	myPID = static_cast<int>(getpid())

static int	myRole = 0

static int	myRolf = 0

static uid_t	myUID = 0

static const char *	myUName = "?"

static int	myUNLen = 1

static char *	Notify = 0

static bool	OD_Bypass = false

static bool	OD_Redir = false

static int	OD_Stall = 33

static XrdSfsFileSystem *	osFS

static XrdNetPMark *	PMark = 0

static int	Port

static bool	PrepareAlt = false

static int	PrepareLimit = -1

static XrdOucReqID *	PrepID = 0

static int	readWait

static int	redirIPHold = 86060

static XrdXrootdRedirPI *	RedirPI = 0

static const char	Req_TLSData = 0x01

static const char	Req_TLSGPFile = 0x02

static const char	Req_TLSLogin = 0x04

static const char	Req_TLSSess = 0x08

static const char	Req_TLSTPC = 0x10

static struct XrdXrootdProtocol::RD_Table	Route [RD_Num]

static struct XrdXrootdProtocol::RC_Table	RouteClient

static XrdXrootdXPath	RPList

static XrdXrootdXPath	RQList

static int	RQLxist = 0

static XrdScheduler *	Sched

static XrdXrootdStats *	SI

static RAtomic_int	srvrAioOps = {0}

static char	tlsCap = 0

static XrdTlsContext *	tlsCtx = 0

static char	tlsNot = 0

static int	tlsPort = 0

static const char *	TraceID = "Protocol"

static int	usxMaxNsz = kXR_faMaxNlen

static int	usxMaxVsz = kXR_faMaxVlen

static char *	usxParms = 0

static int	Window

static XrdXrootdXPath	XPList

Detailed Description

Definition at line 55 of file XrdXrootdTransit.hh.

Constructor & Destructor Documentation

◆ XrdXrootdTransit()

XrdXrootdTransit::XrdXrootdTransit ( )

inline

Constructor & Destructor.

Definition at line 162 of file XrdXrootdTransit.hh.

                                 : TranLink(this),
                                   respJob(this, &XrdXrootdTransit::Proceed,
                                           "Transit proceed"),
                                   waitJob(this, &XrdXrootdTransit::Redrive,
                                           "Transit redrive")
                                 {}

References XrdXrootdTransit(), Proceed(), and Redrive().

Referenced by XrdXrootdTransit(), and Alloc().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ ~XrdXrootdTransit()

virtual XrdXrootdTransit::~XrdXrootdTransit ( )

inlinevirtual

Definition at line 168 of file XrdXrootdTransit.hh.

168{}

Member Function Documentation

◆ Alloc()

XrdXrootdTransit * XrdXrootdTransit::Alloc	(	XrdXrootd::Bridge::Result *	respP,
		XrdLink *	linkP,
		XrdSecEntity *	seceP,
		const char *	nameP,
		const char *	protP )

static

Get a new transit object.

Definition at line 77 of file XrdXrootdTransit.cc.

{
   XrdXrootdTransit *xp;
 
// Simply return a new transit object masquerading as a bridge
//
   if (!(xp = TranStack.Pop())) xp = new XrdXrootdTransit();
   xp->Init(rsltP, linkP, seceP, nameP, protP);
   return xp;
}

References XrdXrootdTransit(), and Init().

Referenced by XrdXrootd::Bridge::Login().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Attn()

int XrdXrootdTransit::Attn	(	XrdLink *	lP,
		short *	theSID,
		int	rcode,
		const struct iovec *	ioVec,
		int	ioNum,
		int	ioLen )

static

Handle attention response (i.e. async response)

Definition at line 97 of file XrdXrootdTransit.cc.

{
   XrdXrootdTransPend *tP;
 
// Find the request
//
   if (!(tP = XrdXrootdTransPend::Remove(lP, *theSID)))
      {TRACE(REQ, "Unable to find request for " <<lP->ID <<" sid=" <<*theSID);
       return 0;
      }
 
// Resume the request as we have been waiting for the response.
//
   return tP->bridge->AttnCont(tP, rcode, ioV, ioN, ioL);
}

References XrdXrootdTransPend::bridge, XrdLink::ID, XrdXrootdTransPend::Remove(), and TRACE.

Referenced by XrdXrootdResponse::Send().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Disc()

bool XrdXrootdTransit::Disc ( )

virtual

Handle dismantlement.

Implements XrdXrootd::Bridge.

Definition at line 158 of file XrdXrootdTransit.cc.

{
   char buff[128];
 
// We do not allow disconnection while we are active
//
   if (runStatus.fetch_add(1, std::memory_order_acq_rel)) return false;
 
// Reconnect original protocol to the link
//
   Link->setProtocol(realProt);
 
// Now we need to recycle our xrootd part
//
   sprintf(buff, "%s disconnection", pName);
   XrdXrootdProtocol::Recycle(Link, time(0)-cTime, buff);
 
// Now just free up our object.
//
   TranStack.Push(&TranLink);
   return true;
}

References XrdXrootdProtocol::Link, and XrdXrootdProtocol::Recycle().

Here is the call graph for this function:

◆ Init()

void XrdXrootdTransit::Init	(	XrdScheduler *	schedP,
		int	qMax,
		int	qTTL )

static

Perform one-time initialization.

Definition at line 208 of file XrdXrootdTransit.cc.

{
   TranStack.Set(schedP, &XrdXrootdTrace, TRACE_MEM);
   TranStack.Set(qMax, qTTL);
}

References TRACE_MEM, XrdJob::XrdScheduler, and XrdXrootdTrace.

Referenced by Alloc(), and XrdXrootdProtocol::Configure().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Proceed()

void XrdXrootdTransit::Proceed ( )

Resume processing after a waitresp completion.

Definition at line 326 of file XrdXrootdTransit.cc.

{
   int rc;
 
// If we were interrupted in a reinvoke state, resume that state.
//
   if (reInvoke) rc = Process(Link);
      else rc = 0;
 
// Handle ending status
//
   if (rc >= 0) Link->Enable();
      else if (rc != -EINPROGRESS) Link->Close();
}

References XrdXrootdProtocol::Link, and Process().

Referenced by XrdXrootdTransit().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Process()

int XrdXrootdTransit::Process ( XrdLink * lp )

virtual

Handle link activation (replaces parent activation).

Reimplemented from XrdXrootdProtocol.

Definition at line 345 of file XrdXrootdTransit.cc.

{
   int rc;
 
// This entry is serialized via link processing and data is now available.
// One of the following will be returned.
//
// < 0 -> Stop getting requests,
//        -EINPROGRESS leave link disabled but otherwise all is well
//        -n           Error, disable and close the link
// = 0 -> OK, get next request, if allowed, o/w enable the link
// > 0 -> Slow link, stop getting requests  and enable the link
//
 
// Reflect data is present to the underlying protocol and if Run() has been
// called we need to dispatch that request. This may be iterative.
//
do{rc = realProt->Process((reInvoke ? 0 : lp));
   if (rc >= 0 && runStatus.load(std::memory_order_acquire))
      {reInvoke = (rc == 0);
       if (runError) rc = Fatal(rc);
          else {runDone = false;
                rc = (Resume ? XrdXrootdProtocol::Process(lp) : Process2());
                if (rc >= 0)
                   {if (runWait) rc = -EINPROGRESS;
                    if (!runDone) return rc;
                    runStatus.store(0, std::memory_order_release);
                   }
               }
      } else reInvoke = false;
   } while(rc >= 0 && reInvoke);
 
// Make sure that we indicate that we are no longer active
//
   runStatus.store(0, std::memory_order_release);
 
// All done
//
   return (rc ? rc : 1);
}

References XrdXrootdProtocol::Process(), XrdXrootdProtocol::Process2(), and XrdXrootdProtocol::Resume.

Referenced by Proceed().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Recycle()

void XrdXrootdTransit::Recycle	(	XrdLink *	lp,
		int	consec,
		const char *	reason )

virtual

Handle link shutdown.

Reimplemented from XrdXrootdProtocol.

Definition at line 390 of file XrdXrootdTransit.cc.

{
 
// Set ourselves as active so we can't get more requests
//
   runStatus.fetch_add(1, std::memory_order_acq_rel);
 
// If we were active then we will need to quiesce before dismantling ourselves.
// Note that Recycle() can only be called if the link is enabled. So, this bit
// of code is improbable but we check it anyway.
//
   if (runWait > 0) {
       TRACEP(EMSG, "WARNING: Recycle is canceling wait job; the wait job might already be running during recycle.");
       Sched->Cancel(&waitJob);
   }
 
// First we need to recycle the real protocol
//
   if (realProt) realProt->Recycle(lp, consec, reason);
 
// Now we need to recycle our xrootd part
//
   XrdXrootdProtocol::Recycle(lp, consec, reason);
 
// Release the argument buffer
//
   if (runArgs) {free(runArgs); runArgs = 0;}
 
// Delete all pending requests
//
   XrdXrootdTransPend::Clear(this);
 
// Now just free up our object.
//
   TranStack.Push(&TranLink);
}

References XrdXrootdTransPend::Clear(), EMSG, XrdXrootdProtocol::Recycle(), XrdXrootdProtocol::Sched, and TRACEP.

Here is the call graph for this function:

◆ Redrive()

void XrdXrootdTransit::Redrive ( )

Redrive a request after a wait.

Definition at line 431 of file XrdXrootdTransit.cc.

{
   static int  eCode         = htonl(kXR_NoMemory);
   static char eText[]       = "Insufficent memory to re-issue request";
   static struct iovec ioV[] = {{(char *)&eCode,sizeof(eCode)},
                                {(char *)&eText,sizeof(eText)}};
   int rc;
 
// Do some tracing
//
   TRACEP(REQ, "Bridge redrive runStatus="<<runStatus.load(std::memory_order_acquire)
               <<" runError="<<runError
               <<" runWait="<<runWait<<" runWTot="<<runWTot);
 
// Update wait statistics
//
   runWTot += runWait;
   runWait = 0;
 
// While we are running asynchronously, there is no way that this object can
// be deleted while a timer is outstanding as the link has been disabled. So,
// we can reissue the request with little worry.
//
// This is a bit tricky here as a redriven request may result in a wait. If
// this happens we cannot hand the result off to the real protocol until we
// wait and successfully redrive. The wait handling occurs asynchronously
// so all we need to do is honor it here.
//
   if (!runALen || RunCopy(runArgs, runALen)) {
      do{rc = Process2();
         TRACEP(REQ, "Bridge redrive Process2 rc="<<rc
                     <<" runError="<<runError<<" runWait="<<runWait);
        if (rc == 0 && !runWait && !runError) {
          rc = realProt->Process(NULL);
          TRACEP(REQ, "Bridge redrive callback rc="<<rc
                      <<" runStatus="<<runStatus.load(std::memory_order_acquire));
        }
      } while((rc == 0) && !runError && !runWait);
   }
      else rc = Send(kXR_error, ioV, 2, 0);
 
// Defer the request if need be
//
   if (rc >= 0 && runWait) return;
   runWTot = 0;
 
// Indicate we are no longer active
//
   runStatus.store(0, std::memory_order_release);
 
// If the link needs to be terminated, terminate the link. Otherwise, we can
// enable the link for new requests at this point.
//
   if (rc < 0) Link->Close();
      else     Link->Enable();
}

References kXR_error, kXR_NoMemory, XrdXrootdProtocol::Link, XrdXrootdProtocol::Process2(), Send(), and TRACEP.

Referenced by XrdXrootdTransit().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ ReqTable()

const char * XrdXrootdTransit::ReqTable ( )

static

Initialize the valid request table.

Definition at line 494 of file XrdXrootdTransit.cc.

{
   static char rTab[kXR_truncate-kXR_auth+1];
 
// Initialize the table
//
   memset(rTab, 0, sizeof(rTab));
   rTab[KXR_INDEX(kXR_chmod)]     = 1;
   rTab[KXR_INDEX(kXR_close)]     = 1;
   rTab[KXR_INDEX(kXR_dirlist)]   = 1;
   rTab[KXR_INDEX(kXR_locate)]    = 1;
   rTab[KXR_INDEX(kXR_mkdir)]     = 1;
   rTab[KXR_INDEX(kXR_mv)]        = 1;
   rTab[KXR_INDEX(kXR_open)]      = 1;
   rTab[KXR_INDEX(kXR_prepare)]   = 1;
   rTab[KXR_INDEX(kXR_protocol)]  = 1;
   rTab[KXR_INDEX(kXR_query)]     = 1;
   rTab[KXR_INDEX(kXR_read)]      = 2;
   rTab[KXR_INDEX(kXR_readv)]     = 2;
   rTab[KXR_INDEX(kXR_rm)]        = 1;
   rTab[KXR_INDEX(kXR_rmdir)]     = 1;
   rTab[KXR_INDEX(kXR_set)]       = 1;
   rTab[KXR_INDEX(kXR_stat)]      = 1;
   rTab[KXR_INDEX(kXR_statx)]     = 1;
   rTab[KXR_INDEX(kXR_sync)]      = 1;
   rTab[KXR_INDEX(kXR_truncate)]  = 1;
   rTab[KXR_INDEX(kXR_write)]     = 2;
 
// Now return the address
//
   return rTab;
}

References kXR_auth, kXR_chmod, kXR_close, kXR_dirlist, KXR_INDEX, kXR_locate, kXR_mkdir, kXR_mv, kXR_open, kXR_prepare, kXR_protocol, kXR_query, kXR_read, kXR_readv, kXR_rm, kXR_rmdir, kXR_set, kXR_stat, kXR_statx, kXR_sync, kXR_truncate, and kXR_write.

◆ Run()

bool XrdXrootdTransit::Run	(	const char *	xreqP,
		char *	xdataP = 0,
		int	xdataL = 0 )

virtual

Inject an xrootd request into the protocol stack.

Parameters

xreqP	xrootd request header
xdataP	xrootd request data (optional)
xdataL	xrootd request data length

Implements XrdXrootd::Bridge.

Definition at line 558 of file XrdXrootdTransit.cc.

{
   int movLen;
 
// We do not allow re-entry if we are curently processing a request.
// It will be reset, as need, when a response is effected.
//
 
   if (runStatus.fetch_add(1, std::memory_order_acq_rel))
      {TRACEP(REQ, "Bridge request failed due to re-entry");
       return false;
      }
 
// Copy the request header
//
   memcpy((void *)&Request, (void *)xreqP, sizeof(Request));
 
// Validate that we can actually handle this request
//
   Request.header.requestid = ntohs(Request.header.requestid);
   if (Request.header.requestid & 0x8000
   || Request.header.requestid > static_cast<kXR_unt16>(kXR_truncate)
   || !reqTab[Request.header.requestid - kXR_auth])
      {TRACEP(REQ, "Unsupported bridge request");
       return Fail(kXR_Unsupported, "Unsupported bridge request");
      }
 
// Validate the data length
//
   Request.header.dlen      = ntohl(Request.header.dlen);
   if (Request.header.dlen < 0)
      {TRACEP(REQ, "Invalid request data length");
       return Fail(kXR_ArgInvalid, "Invalid request data length");
      }
 
// Copy the stream id and trace this request
//
   Response.Set(Request.header.streamid);
   TRACEP(REQ, "Bridge req=" <<Request.header.requestid
               <<" dlen=" <<Request.header.dlen <<" blen=" <<xdataL);
 
// If this is a write request, we will need to do a lot more
//
   if (Request.header.requestid == kXR_write) return ReqWrite(xdataP, xdataL);
 
// Obtain any needed buffer and handle any existing data arguments. Also, we
// need to keep a shadow copy of the request arguments should we get a wait
// and will need to re-issue the request (the server mangles the args).
//
   if (Request.header.dlen)
      {movLen = (xdataL < Request.header.dlen ? xdataL : Request.header.dlen);
       if (!RunCopy(xdataP, movLen)) return true;
       if (!runArgs || movLen > runABsz)
          {if (runArgs) free(runArgs);
           if (!(runArgs = (char *)malloc(movLen)))
              {TRACEP(REQ, "Failed to allocate memory");
               return Fail(kXR_NoMemory, "Insufficient memory");
              }
           runABsz = movLen;
          }
       memcpy(runArgs, xdataP, movLen); runALen = movLen;
       if ((myBlen = Request.header.dlen - movLen))
          {myBuff = argp->buff + movLen;
           Resume = &XrdXrootdProtocol::Process2;
           return true;
          }
      } else runALen = 0;
 
// If we have all the data, indicate request accepted.
//
   runError = 0;
   Resume   = 0;
   return true;
}

References XrdXrootdProtocol::argp, kXR_ArgInvalid, kXR_auth, kXR_NoMemory, kXR_truncate, kXR_Unsupported, kXR_write, XrdXrootdProtocol::myBlen, XrdXrootdProtocol::myBuff, XrdXrootdProtocol::Process2(), XrdXrootdProtocol::Request, XrdXrootdProtocol::Response, XrdXrootdProtocol::Resume, and TRACEP.

Here is the call graph for this function:

◆ Send() [1/3]

int XrdXrootdTransit::Send	(	int	rcode,
		const struct iovec *	ioVec,
		int	ioNum,
		int	ioLen )

Handle request data response.

Definition at line 660 of file XrdXrootdTransit.cc.

{
   XrdXrootd::Bridge::Context rInfo(Link, Request.header.streamid,
                                          Request.header.requestid);
   const char *eMsg;
   int         rc;
   bool        aOK;
 
// Invoke the result object (we initially assume this is the final result)
//
   runDone = true;
   switch(rcode)
         {case kXR_error:
                   rc = XRD_GETNUM(ioV[0].iov_base);
                   eMsg = (ioN < 2 ? "" : (const char *)ioV[1].iov_base);
                   if (wBuff) respObj->Free(rInfo, wBuff, wBLen);
                   aOK = respObj->Error(rInfo, rc, eMsg);
                   break;
          case kXR_ok:
                   if (wBuff)  respObj->Free(rInfo, wBuff, wBLen);
                   aOK = (ioN ? respObj->Data(rInfo, ioV, ioN, ioL, true)
                              : respObj->Done(rInfo));
                   break;
          case kXR_oksofar:
                   aOK = respObj->Data(rInfo, ioV, ioN, ioL, false);
                   runDone = false;
                   break;
          case kXR_redirect:
                   if (wBuff) respObj->Free(rInfo, wBuff, wBLen);
                   rc = XRD_GETNUM(ioV[0].iov_base);
                   aOK = respObj->Redir(rInfo,rc,(const char *)ioV[1].iov_base);
                   break;
          case kXR_wait:
                   return Wait(rInfo, ioV, ioN, ioL);
                   break;
          case kXR_waitresp:
                   runDone = false;
                   return WaitResp(rInfo, ioV, ioN, ioL);
                   break;
          default: if (wBuff) respObj->Free(rInfo, wBuff, wBLen);
                   aOK = respObj->Error(rInfo, kXR_ServerError,
                                       "internal logic error");
                   break;
         };
 
// All done
//
   return (aOK ? 0 : -1);
}

References eMsg, kXR_error, kXR_ok, kXR_oksofar, kXR_redirect, kXR_ServerError, kXR_wait, kXR_waitresp, XrdXrootdProtocol::Link, XrdXrootdProtocol::Request, and XRD_GETNUM.

Referenced by Redrive().

Here is the caller graph for this function:

◆ Send() [2/3]

int XrdXrootdTransit::Send	(	long long	offset,
		int	dlen,
		int	fdnum )

Handle request sendfile response.

Definition at line 712 of file XrdXrootdTransit.cc.

{
   XrdXrootdTransSend sfInfo(Link, Request.header.streamid,
                                   Request.header.requestid,
                                   offset, dlen, fdnum);
 
// Effect callback (this is always a final result)
//
   runDone = true;
   return (respObj->File(sfInfo, dlen) ? 0 : -1);
}

References XrdXrootdProtocol::Link, and XrdXrootdProtocol::Request.

◆ Send() [3/3]

int XrdXrootdTransit::Send	(	XrdOucSFVec *	sfvec,
		int	sfvnum,
		int	dlen )

Definition at line 726 of file XrdXrootdTransit.cc.

{
   XrdXrootdTransSend sfInfo(Link, Request.header.streamid,
                                   Request.header.requestid,
                                   sfvec, sfvnum, dlen);
 
// Effect callback (this is always a final result)
//
   runDone = true;
   return (respObj->File(sfInfo, dlen) ? 0 : -1);
}

References XrdXrootdProtocol::Link, and XrdXrootdProtocol::Request.

◆ setSF()

int XrdXrootdTransit::setSF	(	kXR_char *	fhandle,
		bool	seton = false )

inlinevirtual

Set sendfile() enablement.

Implements XrdXrootd::Bridge.

Definition at line 148 of file XrdXrootdTransit.hh.

149 {return SetSF(fhandle, seton);}

XrdXrootdProtocol::SetSF

int SetSF(kXR_char *fhandle, bool seton=false)

Definition XrdXrootdXeq.cc:4314

References XrdXrootdProtocol::SetSF().

Here is the call graph for this function:

◆ SetWait()

void XrdXrootdTransit::SetWait	(	int	wtime,
		bool	notify = false )

inlinevirtual

Set maximum wait time.

Implements XrdXrootd::Bridge.

Definition at line 155 of file XrdXrootdTransit.hh.

156 {runWMax = wtime; runWCall = notify;}

The documentation for this class was generated from the following files:

Public Member Functions

Static Public Member Functions

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ XrdXrootdTransit()

◆ ~XrdXrootdTransit()

Member Function Documentation

◆ Alloc()

◆ Attn()

◆ Disc()

◆ Init()

◆ Proceed()

◆ Process()

◆ Recycle()

◆ Redrive()

◆ ReqTable()

◆ Run()

◆ Send() [1/3]

◆ Send() [2/3]

◆ Send() [3/3]

◆ setSF()

◆ SetWait()