Inheritance diagram for XrdOfsPrepGPIReal::PrepGRun:

Collaboration diagram for XrdOfsPrepGPIReal::PrepGRun:

Public Member Functions
	PrepGRun (XrdOucProg &pgm)
void	DoIt () override
int	Run (PrepRequest &req, char *bP=0, int bL=0)
void	Sched (PrepRequest *rP)
Public Member Functions inherited from XrdJob
	XrdJob (const char *desc="")
virtual	~XrdJob ()

Public Attributes
PrepGRun *	next
Public Attributes inherited from XrdJob
const char *	Comment
XrdJob *	NextJob

Static Public Attributes
static PrepGRun *	Q = 0

Detailed Description

Definition at line 135 of file XrdOfsPrepGPI.cc.

Constructor & Destructor Documentation

◆ PrepGRun()

XrdOfsPrepGPIReal::PrepGRun::PrepGRun ( XrdOucProg & pgm )

inline

Definition at line 147 of file XrdOfsPrepGPI.cc.

147: prepProg(pgm) {}

Member Function Documentation

◆ DoIt()

void XrdOfsPrepGPIReal::PrepGRun::DoIt ( )

overridevirtual

Implements XrdJob.

Definition at line 229 of file XrdOfsPrepGPI.cc.

{
  
// Run as many requests as we can
//
do{Run(*reqP);
   delete reqP;
   gpiMutex.Lock();
   if ((reqP = PrepRequest::First))
      {if (PrepRequest::First == PrepRequest::Last)
               PrepRequest::First = PrepRequest::Last = 0;
          else PrepRequest::First = PrepRequest::First->next;
      } else {
       next = Q;
       Q    = this;
      }
    gpiMutex.UnLock();
   } while(reqP);
}

References XrdOfsPrepGPIReal::PrepRequest::First, XrdOfsPrepGPIReal::gpiMutex, XrdOfsPrepGPIReal::PrepRequest::Last, next, Q, and Run().

Here is the call graph for this function:

◆ Run()

int XrdOfsPrepGPIReal::PrepGRun::Run	(	PrepRequest &	req,
		char *	bP = 0,
		int	bL = 0 )

Definition at line 277 of file XrdOfsPrepGPI.cc.

{
   EPNAME("Run");
   XrdOucStream cmd;
   char *lp;
   int rc, bytes = 0;
 
// Allocate a arg vector of appropriate size
//
   int n = req.argCnt + req.argMem.size();
   const char **argVec = (const char **)alloca((n+2) * sizeof(char*));
 
// Fill the vector
//
   makeArgs(req, argVec);
 
// Do some debugging
//
   DEBUG(req.tID,"Starting prep for "<<req.reqName<<' '<<req.reqID);
 
// Invoke the program
//
   rc = prepProg.Run(&cmd, argVec, n, req.envVec);
 
// Drain or capture any output
//
   if (!rc)
      {if (Debug)
          {DEBUG(req.tID, req.reqName<<' '<<req.reqID<<" output:");}
       if (!bP) while((lp = cmd.GetLine())) {DEBUG(req.tID," ==> "<<lp);}
          else bytes = Capture(req, cmd, bP, bL);
       rc = prepProg.RunDone(cmd);
      }
 
// Document unsuccessful end
//
   if (rc)
      {char ib[512];
       eLog->Emsg("PrepGRun","Prep exec for",req.Info(ib,sizeof(ib)),"failed.");
      }
 
// Return the error, success or number of bytes
//
   if (bP) return bytes;
   return (rc ? -1 : 0);
}

References XrdOfsPrepGPIReal::PrepRequest::argCnt, XrdOfsPrepGPIReal::PrepRequest::argMem, DEBUG, XrdOfsPrepGPIReal::Debug, XrdOfsPrepGPIReal::eLog, XrdOfsPrepGPIReal::PrepRequest::envVec, EPNAME, XrdOucStream::GetLine(), XrdOfsPrepGPIReal::PrepRequest::Info(), XrdOfsPrepGPIReal::PrepRequest::reqID, XrdOfsPrepGPIReal::PrepRequest::reqName, and XrdOfsPrepGPIReal::PrepRequest::tID.

Referenced by DoIt().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Sched()

void XrdOfsPrepGPIReal::PrepGRun::Sched ( PrepRequest * rP )

inline

Definition at line 143 of file XrdOfsPrepGPI.cc.

                                 {reqP = rP;
                                  schedP->Schedule(this);
                                 }

References XrdOfsPrepGPIReal::schedP.

Member Data Documentation

◆ next

PrepGRun* XrdOfsPrepGPIReal::PrepGRun::next

Definition at line 149 of file XrdOfsPrepGPI.cc.

Referenced by DoIt(), and XrdOfsgetPrepare().

◆ Q

PrepGRun * XrdOfsPrepGPIReal::PrepGRun::Q = 0

static

Definition at line 150 of file XrdOfsPrepGPI.cc.