org.ow2.proactive.scheduler.smartproxy.common

Class JobTracker

java.lang.Object

org.ow2.proactive.scheduler.smartproxy.common.JobTracker

Direct Known Subclasses:

JobTrackerImpl, RestJobTrackerImpl

public abstract class JobTracker
extends Object

JobTracker is in charge to track jobs and associated tasks. In summary, it records jobs which have been submit to the scheduler for execution and allows to manage these records. Most actions are synchronized with the scheduler to retrieve and remove job or task outputs remotely.

Field Summary

Fields

Modifier and Type	Field and Description
protected JobDatabase	jobDatabase
static org.apache.log4j.Logger	logger

Constructor Summary

Constructors

Constructor and Description
JobTracker()

Method Summary

Modifier and Type	Method and Description
void	cleanDataBase()
void	close()
void	discardAllJobs()
void	discardJob(String jobID)
AwaitedJob	getAwaitedJob(String id)
Set<String>	getAwaitedJobsIds()
boolean	isAwaitedJob(String id)
void	loadJobs()
void	putAwaitedJob(String id, AwaitedJob aj)
abstract void	removeAwaitedJob(String id) Removes from the proxy knowledge all info related with the given job.
abstract void	removeAwaitedTask(String id, String taskName) Removes from the proxy knowledge all info related with the given task.
void	setSessionName(String name)
void	setTaskTransferring(String id, String taskName, boolean transferring)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

logger

public static final org.apache.log4j.Logger logger

jobDatabase

protected final JobDatabase jobDatabase

Constructor Detail

JobTracker

public JobTracker()

Method Detail

removeAwaitedJob

public abstract void removeAwaitedJob(String id)

Removes from the proxy knowledge all info related with the given job. This will also delete every folder created by the job in the shared input and output spaces.

Parameters:

id - job ID

removeAwaitedTask

public abstract void removeAwaitedTask(String id,
                                       String taskName)

Removes from the proxy knowledge all info related with the given task. If all tasks of a job have been removed this way, the job itself will be removed.

Parameters:

id - job ID

taskName - task name

close

public void close()

setSessionName

public void setSessionName(String name)

loadJobs

public void loadJobs()

cleanDataBase

public void cleanDataBase()

discardAllJobs

public void discardAllJobs()

discardJob

public void discardJob(String jobID)

getAwaitedJobsIds

public Set<String> getAwaitedJobsIds()

getAwaitedJob

public AwaitedJob getAwaitedJob(String id)

isAwaitedJob

public boolean isAwaitedJob(String id)

putAwaitedJob

public void putAwaitedJob(String id,
                          AwaitedJob aj)

setTaskTransferring

public void setTaskTransferring(String id,
                                String taskName,
                                boolean transferring)