org.globus.cog.karajan.util
Class StateManager

java.lang.Object
  org.globus.cog.karajan.util.StateManager

public class StateManager
extends Object

Nested Class Summary

static class	StateManager._Checkpoint
static class	StateManager._RunningElement
static class	StateManager._State
class	StateManager.Task

Constructor Summary

StateManager(ExecutionContext ec)

Method Summary

void	abortContext(ThreadingContext context)
void	actionPerformed()
void	checkpoint(String fileName)
String[]	getCheckpoints()
boolean	getCheckpointsEnabled()
Collection	getEvents()
Map	getExecuting()
Integer	getInterval()
String	getName()
long	getWaitTime()
boolean	isRestartComplete()
boolean	isTimestamped()
void	registerElement(FlowElement el, VariableStack stack)
boolean	request()
static void	resume(StateManager._Checkpoint checkpoint)
void	setCheckpointsEnabled(boolean checkpointsEnabled)
void	setInterval(Integer interval)
void	setName(String name)
void	setRestartComplete(boolean b)
void	setTimestamped(boolean timestamped)
void	setWaitTime(long l)
void	stop()
void	unregisterElement(FlowElement el, VariableStack stack)

Methods inherited from class java.lang.Object

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

Constructor Detail

StateManager

public StateManager(ExecutionContext ec)

Method Detail

registerElement

public void registerElement(FlowElement el,
                            VariableStack stack)
                     throws VariableNotFoundException

Throws:

VariableNotFoundException

unregisterElement

public void unregisterElement(FlowElement el,
                              VariableStack stack)
                       throws VariableNotFoundException

Throws:

VariableNotFoundException

abortContext

public void abortContext(ThreadingContext context)

getWaitTime

public long getWaitTime()

setWaitTime

public void setWaitTime(long l)

actionPerformed

public void actionPerformed()

request

public boolean request()

isRestartComplete

public boolean isRestartComplete()

setRestartComplete

public void setRestartComplete(boolean b)

checkpoint

public void checkpoint(String fileName)

getEvents

public Collection getEvents()

getCheckpoints

public String[] getCheckpoints()

getInterval

public Integer getInterval()

setInterval

public void setInterval(Integer interval)

getName

public String getName()

setName

public void setName(String name)

getCheckpointsEnabled

public boolean getCheckpointsEnabled()

setCheckpointsEnabled

public void setCheckpointsEnabled(boolean checkpointsEnabled)

stop

public void stop()

resume

public static void resume(StateManager._Checkpoint checkpoint)

getExecuting

public Map getExecuting()

isTimestamped

public boolean isTimestamped()

setTimestamped

public void setTimestamped(boolean timestamped)