Inheritance diagram for XrdXrootdJob2Do:

Collaboration diagram for XrdXrootdJob2Do:

Public Types
enum	JobStatus { Job_Active , Job_Cancel , Job_Done , Job_Waiting }

Public Member Functions
	XrdXrootdJob2Do (XrdXrootdJob job, int jnum, const char args, XrdXrootdResponse Resp, int opts)
	~XrdXrootdJob2Do ()
void	DoIt ()
Public Member Functions inherited from XrdJob
	XrdJob (const char *desc="")
virtual	~XrdJob ()

Public Attributes
XrdSys::RAtomic< JobStatus >	Status
Public Attributes inherited from XrdJob
const char *	Comment
XrdJob *	NextJob

Friends
class	XrdXrootdJob

Detailed Description

Definition at line 53 of file XrdXrootdJob.cc.

Member Enumeration Documentation

◆ JobStatus

enum XrdXrootdJob2Do::JobStatus

Enumerator
Job_Active
Job_Cancel
Job_Done
Job_Waiting

Definition at line 60 of file XrdXrootdJob.cc.

60{Job_Active, Job_Cancel, Job_Done, Job_Waiting};

XrdXrootdJob2Do::Job_Waiting

@ Job_Waiting

Definition XrdXrootdJob.cc:60

XrdXrootdJob2Do::Job_Active

@ Job_Active

Definition XrdXrootdJob.cc:60

XrdXrootdJob2Do::Job_Done

@ Job_Done

Definition XrdXrootdJob.cc:60

XrdXrootdJob2Do::Job_Cancel

@ Job_Cancel

Definition XrdXrootdJob.cc:60

Constructor & Destructor Documentation

◆ XrdXrootdJob2Do()

XrdXrootdJob2Do::XrdXrootdJob2Do	(	XrdXrootdJob *	job,
		int	jnum,
		const char **	args,
		XrdXrootdResponse *	Resp,
		int	opts )

Definition at line 123 of file XrdXrootdJob.cc.

                                : XrdJob(job->JobName)
{
   int i;
   for (i = 0; i < argvnum && args[i]; i++) theArgs[i] = strdup(args[i]);
   for (     ; i < argvnum; i++)            theArgs[i] = (char *)0;
   theJob     = job;
   JobRC      = 0;
   JobNum     = jnum;
   JobMark    = 0;
   numClients = 0;
   theResult  = 0;
   doRedrive  = 0;
   Status     = Job_Waiting;
   addClient(resp, opts);
}

References XrdJob::XrdJob(), Job_Waiting, opts, Status, and XrdXrootdJob.

Referenced by DoIt().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ ~XrdXrootdJob2Do()

XrdXrootdJob2Do::~XrdXrootdJob2Do ( )

Definition at line 148 of file XrdXrootdJob.cc.

{
   int i;
 
   for (i = 0; i < numClients; i++) 
       if (!Client[i].isSync) {sendResult(0, 1); break;}
 
   for (i = 0; i < argvnum; i++)
       if (theArgs[i]) free(theArgs[i]);
}

Member Function Documentation

◆ DoIt()

void XrdXrootdJob2Do::DoIt ( )

virtual

Implements XrdJob.

Definition at line 166 of file XrdXrootdJob.cc.

{
   static const char *TraceID = "jobXeq";
   XrdXrootdJob2Do *jp = 0;
   const char *endStat = " completed";
   char *lp = 0;
   int i, rc = 0;
 
// While we were waiting to run we may have been cancelled. If we were not then
// perform the actual function and get the result and send to any async clients
//
   if (Status != Job_Cancel)
      {TRACE(REQ, "Job "<<jobInfo<<" started");
       if ((rc = theJob->theProg->Run(&jobStream, theArgs[1], theArgs[2],
                         theArgs[3], theArgs[4])))
          {Status = Job_Cancel;
           endStat= " failed";
           lp = jobStream.GetLine();
           theJob->myMutex.Lock();
          }
          else {lp = jobStream.GetLine();
                rc = theJob->theProg->RunDone(jobStream);
                theJob->myMutex.Lock();
                if ((rc && rc != -EPIPE) || (rc == -EPIPE && (!lp || !(*lp))))
                   {Status = Job_Cancel; endStat = " failed";}
                   else if (Status != Job_Cancel)
                           {Status = Job_Done;
                            for (i = 0; i < numClients; i++)
                                if (!Client[i].isSync) {sendResult(lp); break;}
                           }
               }
       } else {
        endStat = " cancelled";
        theJob->myMutex.Lock();
       }
 
// Produce a trace record
//
   TRACE(REQ, "Job "<<jobInfo<<endStat);
 
// If the number of jobs > than the max allowed, then redrive a waiting job
// if in fact we represent a legitimate job slot (this could a phantom slot
// due to ourselves being cancelled.
//
   if (doRedrive)
      {if (theJob->numJobs > theJob->maxJobs) Redrive();
       theJob->numJobs--;
      }
 
// If there are no polling clients left or we have been cancelled, then we
// will delete ourselves and, if cancelled, send a notofication to everyone
//
   if (Status != Job_Cancel && numClients) theResult = lp;
      else {if (Status == Job_Cancel) sendResult(lp, (rc ? -1 : 1), rc);
            jp = theJob->JobTable.Remove(JobNum);
           }
 
// At this point we may need to delete ourselves. If so, jp will not be zero.
// This must be the last action in this method.
//
   theJob->myMutex.UnLock();
   if (jp) delete jp;
}