XrdXrootdJob Class Reference

#include <XrdXrootdJob.hh>

Inheritance diagram for XrdXrootdJob:

Collaboration diagram for XrdXrootdJob:

Public Member Functions
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)
	XrdXrootdJob (XrdScheduler *schp, XrdOucProg *pgm, const char *jname, int maxjobs=4)
	~XrdXrootdJob ()
Public Member Functions inherited from XrdJob
	XrdJob (const char *desc="")
virtual	~XrdJob ()

Private Member Functions
void	CleanUp (XrdXrootdJob2Do *jp)
int	sendResult (XrdXrootdResponse *resp, const char *rpfx, XrdXrootdJob2Do *job)

Private Attributes
XrdSysMutex	myMutex
XrdScheduler *	Sched
XrdOucTable< XrdXrootdJob2Do >	JobTable
XrdOucProg *	theProg
char *	JobName
int	maxJobs
int	numJobs

Static Private Attributes
static const int	reScan = 15*60

Friends
class	XrdXrootdJob2Do

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

Constructor & Destructor Documentation

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

References JobName, maxJobs, numJobs, reScan, Sched, XrdScheduler::Schedule(), and theProg.

XrdXrootdJob::~XrdXrootdJob

(

)

References XrdScheduler::Cancel(), JobName, XrdSysMutex::Lock(), myMutex, Sched, and XrdSysMutex::UnLock().

Member Function Documentation

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

References CleanUp(), XrdXrootdJob2Do::delClient(), XrdOucTable< T >::Find(), XrdOucTable< T >::Item(), JobTable, XrdSysMutex::Lock(), myMutex, XrdOucTable< T >::Next(), XrdXrootdJob2Do::numClients, and XrdSysMutex::UnLock().

Referenced by XrdXrootdAdmin::do_Cj(), and XrdXrootdProtocol::do_CKsum().

void XrdXrootdJob::CleanUp ( XrdXrootdJob2Do *  jp )

private

References XrdOucStream::Drain(), XrdXrootdJob2Do::Job_Active, XrdXrootdJob2Do::Job_Cancel, XrdXrootdJob2Do::Job_Done, XrdXrootdJob2Do::Job_Waiting, XrdXrootdJob2Do::jobStream, numJobs, Sched, XrdScheduler::Schedule(), and XrdXrootdJob2Do::Status.

Referenced by Cancel(), DoIt(), and sendResult().

void XrdXrootdJob::DoIt ( )

virtual

Implements XrdJob.

References CleanUp(), XrdOucTable< T >::Item(), XrdXrootdJob2Do::JobMark, JobTable, XrdSysMutex::Lock(), myMutex, XrdOucTable< T >::Next(), reScan, Sched, XrdScheduler::Schedule(), XrdSysMutex::UnLock(), and XrdXrootdJob2Do::verClient().

XrdOucTList * XrdXrootdJob::List

(

void

)

References XrdOucTable< T >::Item(), JobName, JobTable, XrdSysMutex::Lock(), XrdXrootdJob2Do::lstClient(), myMutex, XrdOucTable< T >::Next(), and XrdSysMutex::UnLock().

Referenced by XrdXrootdAdmin::do_Lsj_Xeq().

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

References XrdXrootdJob2Do::addClient(), XrdOucTable< T >::Alloc(), XrdXrootdJob2Do::doRedrive, XrdOucTable< T >::Find(), XrdOucTable< T >::Insert(), XrdXrootdJob2Do::Job_Active, XrdXrootdJob2Do::Job_Done, JOB_Sync, JOB_Unique, JobTable, kXR_ArgMissing, kXR_wait, kXR_waitresp, XrdSysMutex::Lock(), maxJobs, myMutex, numJobs, Sched, XrdScheduler::Schedule(), XrdXrootdResponse::Send(), sendResult(), XrdXrootdJob2Do::Status, XrdSysMutex::UnLock(), and XrdXrootdJob2Do.

Referenced by XrdXrootdProtocol::do_CKsum().

int XrdXrootdJob::sendResult ( XrdXrootdResponse *  resp, const char *  rpfx, XrdXrootdJob2Do *  job  )

private

References CleanUp(), XrdXrootdJob2Do::delClient(), kXR_ServerError, XrdXrootdJob2Do::numClients, XrdXrootdResponse::Send(), and XrdXrootdJob2Do::theResult.

Referenced by Schedule().

Friends And Related Function Documentation

friend class XrdXrootdJob2Do

friend

Referenced by Schedule().

Member Data Documentation

char* XrdXrootdJob::JobName

private

Referenced by List(), XrdXrootdJob(), and ~XrdXrootdJob().

XrdOucTable<XrdXrootdJob2Do> XrdXrootdJob::JobTable

private

Referenced by Cancel(), XrdXrootdJob2Do::DoIt(), DoIt(), List(), XrdXrootdJob2Do::Redrive(), Schedule(), and XrdXrootdJob2Do::verClient().

int XrdXrootdJob::maxJobs

private

Referenced by XrdXrootdJob2Do::DoIt(), Schedule(), and XrdXrootdJob().

XrdSysMutex XrdXrootdJob::myMutex

private

Referenced by Cancel(), XrdXrootdJob2Do::DoIt(), DoIt(), List(), Schedule(), and ~XrdXrootdJob().

int XrdXrootdJob::numJobs

private

Referenced by CleanUp(), XrdXrootdJob2Do::DoIt(), Schedule(), XrdXrootdJob2Do::verClient(), and XrdXrootdJob().

const int XrdXrootdJob::reScan = 15*60

staticprivate

Referenced by DoIt(), and XrdXrootdJob().

XrdScheduler* XrdXrootdJob::Sched

private

Referenced by CleanUp(), DoIt(), XrdXrootdJob2Do::Redrive(), Schedule(), XrdXrootdJob(), and ~XrdXrootdJob().

XrdOucProg* XrdXrootdJob::theProg

private

Referenced by XrdXrootdJob2Do::DoIt(), and XrdXrootdJob().

---

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

• XrdXrootdJob.hh
• XrdXrootdJob.cc