org.ow2.proactive.scheduler.core

Class SchedulerStateImpl<T extends JobState>

java.lang.Object

org.ow2.proactive.scheduler.core.SchedulerStateImpl<T>

All Implemented Interfaces:

Serializable, SchedulerState<T>

public final class SchedulerStateImpl<T extends JobState>
extends Object
implements SchedulerState<T>

This class is a representation of the whole scheduler initial jobs list state.
It is basically represented by 3 lists of jobs, and its scheduling status.

Since:

ProActive Scheduling 0.9

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_MAX_FINISHED_JOBS_SIZE

Constructor Summary

Constructors

Constructor and Description
SchedulerStateImpl() ProActive Empty constructor.
SchedulerStateImpl(SchedulerStatus status) State with status

Method Summary

Modifier and Type	Method and Description
SchedulerStateImpl	copy()
SchedulerStateImpl	filterOnUser(String name) Filter the state on the given user name and return a new instance of scheduler state impl After this call, this instance remains the same.
Vector<T>	getFinishedJobs() To get the finishedJobs
Vector<T>	getPendingJobs() To get the pendingJobs
Vector<T>	getRunningJobs() To get the runningJobs
SchedulerStatus	getStatus() Get the status of the scheduler
int	getTotalNbJobs() Returns the total number of jobs.
SchedulerUsers	getUsers() Returns the list of connected users.
void	pendingToFinished(T js)
void	pendingToRunning(T js)
void	removeFinished(JobId jobId)
void	removeFinished(T js)
void	runningToFinished(T js)
void	setFinishedJobs(Vector<T> finishedJobs) To set the finishedJobs
void	setPendingJobs(Vector<T> pendingJobs) To set the pendingJobs
void	setRunningJobs(Vector<T> runningJobs) To set the runningJobs
void	setState(SchedulerStatus status)
void	setUsers(SchedulerUsers users) Sets the list of connected users to the given users value.
void	update(NotificationData<?> notification) Updates the scheduler state given the event passed as a parameter
void	update(SchedulerEvent eventType) Updates the scheduler state given the event passed as a parameter
void	update(T js) Updates the scheduler state given the event passed as a parameter

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_MAX_FINISHED_JOBS_SIZE

public static final int DEFAULT_MAX_FINISHED_JOBS_SIZE

See Also:

Constant Field Values

Constructor Detail

SchedulerStateImpl

public SchedulerStateImpl()

ProActive Empty constructor.

SchedulerStateImpl

public SchedulerStateImpl(SchedulerStatus status)

State with status

Method Detail

getFinishedJobs

public Vector<T> getFinishedJobs()

To get the finishedJobs

Specified by:

getFinishedJobs in interface SchedulerState<T extends JobState>

Returns:

the finishedJobs

setFinishedJobs

public void setFinishedJobs(Vector<T> finishedJobs)

To set the finishedJobs

Parameters:

finishedJobs - the finishedJobs to set

getPendingJobs

public Vector<T> getPendingJobs()

To get the pendingJobs

Specified by:

getPendingJobs in interface SchedulerState<T extends JobState>

Returns:

the pendingJobs

setPendingJobs

public void setPendingJobs(Vector<T> pendingJobs)

To set the pendingJobs

Parameters:

pendingJobs - the pendingJobs to set

getRunningJobs

public Vector<T> getRunningJobs()

To get the runningJobs

Specified by:

getRunningJobs in interface SchedulerState<T extends JobState>

Returns:

the runningJobs

setRunningJobs

public void setRunningJobs(Vector<T> runningJobs)

To set the runningJobs

Parameters:

runningJobs - the runningJobs to set

getStatus

public SchedulerStatus getStatus()

Description copied from interface: SchedulerState

Get the status of the scheduler

Specified by:

getStatus in interface SchedulerState<T extends JobState>

Returns:

the status

setState

public void setState(SchedulerStatus status)

Parameters:

status - the status to set

getUsers

public SchedulerUsers getUsers()

Returns the list of connected users.

Specified by:

getUsers in interface SchedulerState<T extends JobState>

Returns:

the list of connected users.

getTotalNbJobs

public int getTotalNbJobs()

Returns the total number of jobs.

Specified by:

getTotalNbJobs in interface SchedulerState<T extends JobState>

Returns:

the total number of jobs.

setUsers

public void setUsers(SchedulerUsers users)

Sets the list of connected users to the given users value.

Parameters:

users - the list of connected users to set.

filterOnUser

public SchedulerStateImpl filterOnUser(String name)

Filter the state on the given user name and return a new instance of scheduler state impl After this call, this instance remains the same.

Specified by:

filterOnUser in interface SchedulerState<T extends JobState>

Parameters:

name - username to be filtered

Returns:

a new state filtered on job owner name

copy

public SchedulerStateImpl copy()

update

public void update(SchedulerEvent eventType)

Updates the scheduler state given the event passed as a parameter

Specified by:

update in interface SchedulerState<T extends JobState>

update

public void update(NotificationData<?> notification)

Description copied from interface: SchedulerState

Updates the scheduler state given the event passed as a parameter

Specified by:

update in interface SchedulerState<T extends JobState>

update

public void update(T js)

Description copied from interface: SchedulerState

Updates the scheduler state given the event passed as a parameter

Specified by:

update in interface SchedulerState<T extends JobState>

pendingToRunning

public void pendingToRunning(T js)

pendingToFinished

public void pendingToFinished(T js)

runningToFinished

public void runningToFinished(T js)

removeFinished

public void removeFinished(T js)

removeFinished

public void removeFinished(JobId jobId)