JobRunner Class Reference

Runs all jobs defined by JobDescProv. More...

Inheritance diagram for JobRunner:

Public Member Functions
	JobRunner (JobDescProv *, const char *cmd, od_ostream *logstrm=0)
	JobDescProv becomes mine. Never pass null. More...
	~JobRunner ()
const JobDescProv *	descProv () const
const ObjectSet< HostNFailInfo > &	hostInfo () const
bool	addHost (const HostData &)
void	removeHost (int)
void	pauseHost (int, bool)
bool	stopAll ()
bool	hostFailed (int) const
bool	isPaused (int) const
bool	isAssigned (const JobInfo &ji) const
int	nrJobs (bool failed=false) const
const JobInfo &	jobInfo (int idx, bool failed=false) const
int	jobsDone () const
int	jobsInProgress () const
int	jobsLeft () const
int	totalJobs () const
JobInfo *	currentJob (const HostNFailInfo *) const
int	nextStep ()
od_int64	nrDone () const
od_int64	totalNr () const
uiString	message () const
uiString	nrDoneText () const
void	setFirstPort (int n)
void	setRshComm (const char *s)
void	setProg (const char *s)
void	setPriority (float)
void	showMachStatus (BufferStringSet &) const
const File::Path &	getBaseFilePath (JobInfo &, const HostData &)
const JobInfo &	curJobInfo () const
IOPar &	curJobIOPar ()
const File::Path &	curJobFilePath ()
const char *	procDir () const
uiString	errorMsg () const
Public Member Functions inherited from Executor
	Executor (const char *nm)
virtual	~Executor ()
virtual int	doStep ()
bool	go (od_ostream *s=0, bool isfirst=true, bool islast=true, int delaybtwnstepsinms=0)
bool	go (od_ostream &s, bool isfirst=true, bool islast=true, int delaybtwnstepsinms=0)
virtual bool	execute ()
Public Member Functions inherited from SequentialTask
	SequentialTask (const char *nm=0)
virtual	~SequentialTask ()
void	setProgressMeter (ProgressMeter *)
	Must be called before execute() More...
ProgressMeter *	progressMeter ()
const ProgressMeter *	progressMeter () const
bool	execute ()
Public Member Functions inherited from Task
virtual	~Task ()
virtual uiRetVal	errorWithDetails () const
virtual void	enableWorkControl (bool=true)
	Must be called before execute() More...
bool	workControlEnabled () const
virtual void	controlWork (Control)
virtual Control	getState () const
Public Member Functions inherited from NamedCallBacker
	NamedCallBacker (const char *nm=0)
	NamedCallBacker (const NamedCallBacker &)
bool	operator== (const NamedCallBacker &oth) const
bool	operator== (const NamedObject &oth) const
virtual Notifier< NamedCallBacker > &	objectToBeDeleted () const
Public Member Functions inherited from CallBacker
	CallBacker ()
	CallBacker (const CallBacker &)
virtual	~CallBacker ()
bool	attachCB (const NotifierAccess &, const CallBack &, bool onlyifnew=false) const
bool	attachCB (const NotifierAccess *notif, const CallBack &cb, bool onlyifnew=false) const
void	detachCB (const NotifierAccess &, const CallBack &) const
void	detachCB (const NotifierAccess *notif, const CallBack &cb) const
bool	isNotifierAttached (const NotifierAccess *) const
	Only for debugging purposes, don't use. More...
virtual bool	isCapsule () const
void	stopReceivingNotifications () const
Public Member Functions inherited from NamedObject
	NamedObject (const char *nm=0)
	NamedObject (const NamedObject &oth)
virtual	~NamedObject ()
NamedObject &	operator= (const NamedObject &)
bool	operator== (const NamedObject &oth) const
virtual const OD::String &	name () const
virtual BufferString	getName () const
virtual void	setName (const char *nm)
bool	getNameFromPar (const IOPar &)
void	putNameInPar (IOPar &) const

Public Attributes
Notifier< JobRunner >	preJobStart
Notifier< JobRunner >	postJobStart
Notifier< JobRunner >	jobFailed
Notifier< JobRunner >	msgAvail
Public Attributes inherited from Executor
Notifier< Executor >	prestep
Notifier< Executor >	poststep
	Only when MoreToDo will be returned. More...

Protected Types
enum	StartRes { Started, NotStarted, JobBad, HostBad }
enum	AssignStat { NotReady, BadHost, JobStarted, NoJobs }
enum	HostStat { OK = 0, SomeFailed = 1, HostFailed = 2 }

Protected Member Functions
JobIOMgr &	iomgr ()
int	doCycle ()
HostNFailInfo *	hostNFailInfoFor (const HostData *) const
void	updateJobInfo ()
void	handleStatusInfo (StatusInfo &)
JobInfo *	gtJob (int descnr)
void	failedJob (JobInfo &, JobInfo::State)
StartRes	startJob (JobInfo &ji, HostNFailInfo &jhi)
bool	runJob (JobInfo &, const HostData &)
AssignStat	assignJob (HostNFailInfo &)
bool	haveIncomplete () const
HostStat	hostStatus (const HostNFailInfo *) const
Protected Member Functions inherited from Executor
virtual bool	goImpl (od_ostream *, bool, bool, int)
Protected Member Functions inherited from Task
	Task (const char *nm=0)
virtual bool	shouldContinue ()
Protected Member Functions inherited from NamedCallBacker
void	sendDelNotif () const
Protected Member Functions inherited from CallBacker
void	detachAllNotifiers () const
	Call from the destructor of your inherited object. More...

Protected Attributes
JobDescProv *	descprov_
ObjectSet< JobInfo >	jobinfos_
ObjectSet< HostNFailInfo >	hostinfo_
ObjectSet< JobInfo >	failedjobs_
BufferString	prog_
BufferString	procdir_
File::Path &	curjobfp_
IOPar &	curjobiop_
JobInfo *	curjobinfo_
od_ostream *	logstrm_
JobIOMgr *	iomgr_
float	prioritylevel_
int	firstport_
BufferString	rshcomm_
int	maxhostfailures_
	host failrs B4 host bad More...
int	maxjobfailures_
	job related job failrs More...
int	maxjobhstfails_
	host related job failrs More...
int	starttimeout_
int	failtimeout_
int	wrapuptimeout_
int	hosttimeout_
int	startwaittime_
	wait B4 next client start More...
uiString	errmsg_
Protected Attributes inherited from SequentialTask
ProgressMeter *	progressmeter_
int	lastupdate_
Protected Attributes inherited from Task
Control	control_
Threads::ConditionVar *	workcontrolcondvar_
Protected Attributes inherited from NamedCallBacker
Notifier< NamedCallBacker >	delnotif_
Threads::Atomic< bool >	delalreadytriggered_
Protected Attributes inherited from NamedObject
BufferString	name_

Private Member Functions
	mODTextTranslationClass (JobRunner)

Additional Inherited Members
Public Types inherited from Task
enum	Control { Run, Pause, Stop }
Static Public Member Functions inherited from SequentialTask
static int	ErrorOccurred ()
static int	Finished ()
static int	MoreToDo ()
static int	WarningAvailable ()
Static Public Member Functions inherited from Task
static uiString	stdMessage ()
static uiString	stdNrDoneText ()
Static Public Member Functions inherited from CallBacker
static void	createReceiverForCurrentThread ()
static void	removeReceiverForCurrentThread ()

Detailed Description

Runs all jobs defined by JobDescProv.

Member Enumeration Documentation

enum JobRunner::AssignStat

protected

Enumerator
NotReady
BadHost
JobStarted
NoJobs

enum JobRunner::HostStat

protected

Enumerator
OK
SomeFailed
HostFailed

enum JobRunner::StartRes

protected

Enumerator
Started
NotStarted
JobBad
HostBad

Constructor & Destructor Documentation

JobRunner::JobRunner	(	JobDescProv *	,
		const char *	cmd,
		od_ostream *	logstrm = 0
	)

JobDescProv becomes mine. Never pass null.

JobRunner::~JobRunner

(

)

Member Function Documentation

bool JobRunner::addHost

(

const HostData &

)

AssignStat JobRunner::assignJob ( HostNFailInfo &  )

protected

const File::Path& JobRunner::curJobFilePath ( )

inline

const JobInfo& JobRunner::curJobInfo ( ) const

inline

IOPar& JobRunner::curJobIOPar ( )

inline

JobInfo* JobRunner::currentJob

(

const HostNFailInfo *

)

const

const JobDescProv* JobRunner::descProv ( ) const

inline

int JobRunner::doCycle ( )

protected

uiString JobRunner::errorMsg

(

)

const

void JobRunner::failedJob ( JobInfo &  , JobInfo::State    )

protected

const File::Path& JobRunner::getBaseFilePath	(	JobInfo &	,
		const HostData &
	)

JobInfo* JobRunner::gtJob ( int  descnr )

protected

void JobRunner::handleStatusInfo ( StatusInfo &  )

protected

bool JobRunner::haveIncomplete ( ) const

protected

bool JobRunner::hostFailed

(

int

)

const

const ObjectSet<HostNFailInfo>& JobRunner::hostInfo ( ) const

inline

HostNFailInfo* JobRunner::hostNFailInfoFor ( const HostData *  ) const

protected

HostStat JobRunner::hostStatus ( const HostNFailInfo *  ) const

protected

JobIOMgr& JobRunner::iomgr ( )

protected

bool JobRunner::isAssigned

(

const JobInfo &

ji

)

const

bool JobRunner::isPaused

(

int

)

const

const JobInfo& JobRunner::jobInfo ( int  idx, bool  failed = false  ) const

inline

int JobRunner::jobsDone

(

)

const

int JobRunner::jobsInProgress

(

)

const

int JobRunner::jobsLeft ( ) const

inline

uiString JobRunner::message ( ) const

virtual

Implements Executor.

JobRunner::mODTextTranslationClass ( JobRunner  )

private

int JobRunner::nextStep ( )

inlinevirtual

Return values

MoreToDo()	Not finished. Call me again.
Finished()	Nothing more to do.
ErrorOccurred()	Something went wrong.

Note

if function returns a value greater than cMoreToDo(),it should be interpreted as cMoreToDo().

Implements SequentialTask.

od_int64 JobRunner::nrDone ( ) const

inlinevirtual

Note

only used for displaying progress.

Implements Executor.

uiString JobRunner::nrDoneText ( ) const

virtual

Implements Executor.

int JobRunner::nrJobs ( bool  failed = false ) const

inline

void JobRunner::pauseHost	(	int	,
		bool
	)

const char* JobRunner::procDir ( ) const

inline

void JobRunner::removeHost

(

int

)

bool JobRunner::runJob ( JobInfo &  , const HostData &    )

protected

void JobRunner::setFirstPort ( int  n )

inline

void JobRunner::setPriority

(

float

)

void JobRunner::setProg ( const char *  s )

inline

void JobRunner::setRshComm ( const char *  s )

inline

void JobRunner::showMachStatus

(

BufferStringSet &

)

const

StartRes JobRunner::startJob ( JobInfo &  ji, HostNFailInfo &  jhi  )

protected

bool JobRunner::stopAll

(

)

int JobRunner::totalJobs ( ) const

inline

od_int64 JobRunner::totalNr ( ) const

inlinevirtual

Reimplemented from Task.

void JobRunner::updateJobInfo ( )

protected

Member Data Documentation

File::Path& JobRunner::curjobfp_

protected

JobInfo* JobRunner::curjobinfo_

protected

IOPar& JobRunner::curjobiop_

protected

JobDescProv* JobRunner::descprov_

protected

uiString JobRunner::errmsg_

protected

ObjectSet<JobInfo> JobRunner::failedjobs_

protected

int JobRunner::failtimeout_

protected

int JobRunner::firstport_

protected

ObjectSet<HostNFailInfo> JobRunner::hostinfo_

protected

int JobRunner::hosttimeout_

protected

JobIOMgr* JobRunner::iomgr_

protected

Notifier<JobRunner> JobRunner::jobFailed

ObjectSet<JobInfo> JobRunner::jobinfos_

protected

od_ostream* JobRunner::logstrm_

protected

int JobRunner::maxhostfailures_

protected

host failrs B4 host bad

int JobRunner::maxjobfailures_

protected

job related job failrs

int JobRunner::maxjobhstfails_

protected

host related job failrs

Notifier<JobRunner> JobRunner::msgAvail

Notifier<JobRunner> JobRunner::postJobStart

Notifier<JobRunner> JobRunner::preJobStart

float JobRunner::prioritylevel_

protected

BufferString JobRunner::procdir_

protected

BufferString JobRunner::prog_

protected

BufferString JobRunner::rshcomm_

protected

int JobRunner::starttimeout_

protected

int JobRunner::startwaittime_

protected

wait B4 next client start

int JobRunner::wrapuptimeout_

protected