#include <XrdXrootdJob.hh>

Inheritance diagram for XrdXrootdJob:

Collaboration diagram for XrdXrootdJob:

Public Member Functions
	XrdXrootdJob (XrdScheduler schp, XrdOucProg pgm, const char *jname, int maxjobs=4)
	~XrdXrootdJob ()
int	Cancel (const char jkey=0, XrdXrootdResponse resp=0)
void	DoIt ()
XrdOucTList *	List (void)
int	Schedule (const char jkey, const char args, XrdXrootdResponse resp, int Opts=0)
Public Member Functions inherited from XrdJob
	XrdJob (const char *desc="")
virtual	~XrdJob ()

Friends
class	XrdXrootdJob2Do

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

Detailed Description

Definition at line 51 of file XrdXrootdJob.hh.

Constructor & Destructor Documentation

◆ XrdXrootdJob()

XrdXrootdJob::XrdXrootdJob	(	XrdScheduler *	schp,
		XrdOucProg *	pgm,
		const char *	jname,
		int	maxjobs = 4 )

Definition at line 454 of file XrdXrootdJob.cc.

                          : XrdJob("Job Scheduler"),
                            JobTable(maxjobs*3)
{
// Initialize the base member here
//
   Sched      = schp;
   theProg    = pgm;
   JobName    = strdup(jname);
   maxJobs    = maxjobs;
   numJobs    = 0;
 
// Schedule ourselves to run 15 minutes from now
//
    schp->Schedule((XrdJob *)this, time(0) + (reScan));
}

References XrdJob::XrdJob(), XrdScheduler::Schedule(), and XrdJob::XrdScheduler.

Here is the call graph for this function:

◆ ~XrdXrootdJob()

XrdXrootdJob::~XrdXrootdJob ( )

Definition at line 482 of file XrdXrootdJob.cc.

{
   if (JobName) free(JobName);
   myMutex.Lock();
   Sched->Cancel((XrdJob *)this);
   myMutex.UnLock();
}

References XrdJob::XrdJob().

Here is the call graph for this function:

Member Function Documentation

◆ Cancel()

int XrdXrootdJob::Cancel	(	const char *	jkey = 0,
		XrdXrootdResponse *	resp = 0 )

Definition at line 494 of file XrdXrootdJob.cc.

{
   XrdXrootdJob2Do *jp = 0;
   int i, jNum, jNext = 0, numcaned = 0;
 
// Lock our data
//
   myMutex.Lock();
 
// Cancel a specific job if a key was passed
//
   if (jkey)
      {if ((jp = JobTable.Find(jkey)))
          {numcaned = 1;
           if (resp) {jp->delClient(resp);
                      if (!jp->numClients) CleanUp(jp);
                     }
               else  CleanUp(jp);
          }
       myMutex.UnLock();
       return numcaned;
      }
 
// Delete multiple jobs
//
   while((jNum = JobTable.Next(jNext)) >= 0)
        {jp = JobTable.Item(jNum);
         if (resp)
            {i = jp->numClients;
             jp->delClient(resp);
             if (i != jp->numClients) numcaned++;
             if (!jp->numClients) CleanUp(jp);
            } else {
             CleanUp(jp);
             numcaned++;
            }
        }
 
// All done
//
   myMutex.UnLock();
   return numcaned;
}

References XrdXrootdJob2Do.

Here is the call graph for this function:

◆ DoIt()

void XrdXrootdJob::DoIt ( )

virtual

Implements XrdJob.

Definition at line 542 of file XrdXrootdJob.cc.

{
   int jNum, jNext = 0;
   XrdXrootdJob2Do *jp;
 
// Scan through all of the jobs looking for disconnected clients
//
   while((jNum = JobTable.Next(jNext)) >= 0)
        {myMutex.Lock();
         if ((jp = JobTable.Item(jNum)))
            {if (jp->JobMark) {if (!jp->verClient()) CleanUp(jp);}
                else jp->JobMark = 1;
            }
         myMutex.UnLock();
        }
 
// Schedule ourselves to run 15 minutes from now
//
    Sched->Schedule((XrdJob *)this, time(0) + (reScan));
}

References XrdJob::XrdJob(), and XrdXrootdJob2Do.

Here is the call graph for this function:

◆ List()

XrdOucTList * XrdXrootdJob::List ( void )

Definition at line 569 of file XrdXrootdJob.cc.

{
   char *jkey, buff[1024];
   int tlen, jNum, jNext = 0;
   XrdXrootdJob2Do *jp;
   XrdOucTList *tF = 0, *tL = 0, *tp;
 
// Scan through all of the jobs listing each, in turn
//
   while((jNum = JobTable.Next(jNext)) >= 0)
        {myMutex.Lock();
         if ((jp = JobTable.Item(jNum, &jkey)) && (tp = jp->lstClient()))
            {tlen = sprintf(buff, "<job id=\"%s\">%s", JobName, jkey);
            if (tL) tL->next = new XrdOucTList(buff, tlen, tp);
               else tF       = new XrdOucTList(buff, tlen, tp);
            tL = tp->next = new XrdOucTList("</job>", 6);
            }
         myMutex.UnLock();
        }
 
// Return the whole schmear
//
   return tF;
}

References XrdXrootdJob2Do.

Here is the call graph for this function:

◆ Schedule()

int XrdXrootdJob::Schedule	(	const char *	jkey,
		const char **	args,
		XrdXrootdResponse *	resp,
		int	Opts = 0 )

Definition at line 598 of file XrdXrootdJob.cc.

{
   XrdXrootdJob2Do *jp;
   const char *msg = "Job resources currently not available.";
   int jobNum, rc, isSync = Opts & JOB_Sync;
 
// Make sure we have a target
//
   if (!jkey || !(*jkey))
      return resp->Send(kXR_ArgMissing, "Job target not specified.");
 
// First find if this is a duplicate or create a new one
//
   myMutex.Lock();
   if (!(Opts & JOB_Unique) && (jp = JobTable.Find(jkey)))
      {if (jp->Status == XrdXrootdJob2Do::Job_Done)
          {rc = sendResult(resp, args[0], jp);
           myMutex.UnLock();
           return rc;
          }
       if (jp->addClient(resp, Opts) < 0) isSync = 1;
          else msg = "Job scheduled.";
      } else {
       if ((jobNum = JobTable.Alloc()) < 0) isSync = 1;
          else {if ((jp = new XrdXrootdJob2Do(this, jobNum, args, resp, Opts)))
                   {JobTable.Insert(jp, jkey, jobNum);
                    if (numJobs < maxJobs)
                       {Sched->Schedule((XrdJob *)jp);
                        jp->Status = XrdXrootdJob2Do::Job_Active;
                        jp->doRedrive = 1;
                       }
                    numJobs++; msg = "Job Scheduled";
                   }
               }
      }
 
// Tell the client to wait
//
   if (isSync) rc = resp->Send(kXR_wait, 30, msg);
      else     rc = resp->Send(kXR_waitresp, 600, "Job scheduled.");
   myMutex.UnLock();
   return rc;
}