org.ow2.proactive.scheduler.smartproxy.common

Class JobDatabase

java.lang.Object

org.ow2.proactive.scheduler.smartproxy.common.JobDatabase

public class JobDatabase
extends Object

Database in charge to persist references to awaited jobs in order to prevent data loss.

Field Summary

Fields

Modifier and Type	Field and Description
protected jdbm.PrimaryHashMap<String,AwaitedJob>	awaitedJobs A map of jobs that have been launched and which results are awaited each time a new job is sent to the scheduler for computation, it will be added to this map, as an entry of (JobId, AwaitedJob), where JobId is given as a string.
protected static String	DEFAULT_STATUS_FILENAME Default name of the file used to persist the list of jobs
protected jdbm.RecordManager	recMan Object handling the AwaitedJobsFile connection
protected static String	sessionName
static String	STATUS_RECORD_NAME Name of the jobs backup table being recorded
static File	statusFile File which persists the list of AwaitedJob
protected static String	TMPDIR

Constructor Summary

Constructors

Constructor and Description
JobDatabase()

Method Summary

Modifier and Type	Method and Description
void	cleanDataBase()
void	close()
void	commit()
void	discardAllJobs() This call "reset" the current proxy by removing all knowledge of awaited jobs
void	discardJob(String jobID) Removes the given job of the awaited job list (should rarely be used)
AwaitedJob	getAwaitedJob(String id)
Set<String>	getAwaitedJobsIds()
void	loadJobs() load the awaited jobs from the status file if a InvalidClassException occur, we clean the database
void	putAwaitedJob(String id, AwaitedJob awaitedJob)
AwaitedJob	removeAwaitedJob(String id)
void	setSessionName(String name) Sets the name of this recording session.
void	setTaskTransferring(String id, String taskName, boolean transferring) Sets the given task to transferring status.

Methods inherited from class java.lang.Object

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

Field Detail

TMPDIR

protected static final String TMPDIR

DEFAULT_STATUS_FILENAME

protected static final String DEFAULT_STATUS_FILENAME

Default name of the file used to persist the list of jobs

See Also:

Constant Field Values

sessionName

protected static String sessionName

statusFile

public static File statusFile

File which persists the list of AwaitedJob

STATUS_RECORD_NAME

public static final String STATUS_RECORD_NAME

Name of the jobs backup table being recorded

See Also:

Constant Field Values

recMan

protected jdbm.RecordManager recMan

Object handling the AwaitedJobsFile connection

awaitedJobs

protected jdbm.PrimaryHashMap<String,AwaitedJob> awaitedJobs

A map of jobs that have been launched and which results are awaited each time a new job is sent to the scheduler for computation, it will be added to this map, as an entry of (JobId, AwaitedJob), where JobId is given as a string. When the output data related to this job has been transferred, the corresponding awaited job will be removed from this map. This map is persisted in the status file

Constructor Detail

JobDatabase

public JobDatabase()

Method Detail

cleanDataBase

public void cleanDataBase()

commit

public void commit()
            throws IOException

Throws:

IOException

discardAllJobs

public void discardAllJobs()

This call "reset" the current proxy by removing all knowledge of awaited jobs

discardJob

public void discardJob(String jobID)

Removes the given job of the awaited job list (should rarely be used)

getAwaitedJobsIds

public Set<String> getAwaitedJobsIds()

getAwaitedJob

public AwaitedJob getAwaitedJob(String id)

loadJobs

public void loadJobs()

load the awaited jobs from the status file if a InvalidClassException occur, we clean the database

putAwaitedJob

public void putAwaitedJob(String id,
                          AwaitedJob awaitedJob)

removeAwaitedJob

public AwaitedJob removeAwaitedJob(String id)

setSessionName

public void setSessionName(String name)

Sets the name of this recording session. The name must be an unique word composed of alphanumerical charecter The file used to persist awaited jobs will be named accordingly. If no session name is provided, a generic default name will be used.

Parameters:

name - alphanumerical word

setTaskTransferring

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

Sets the given task to transferring status. This is to avoid duplicate transfers in case of duplicate events

Parameters:

id - jobID

taskName - task name

transferring -

close

public void close()