public class ExperimentRunManager extends java.lang.Object implements IExperimentListener
Modifier and Type | Field and Description |
---|---|
private java.util.Map<IGeppettoProject,java.lang.Integer> |
experimentsCounter |
private GeppettoManager |
geppettoManager |
private IGeppettoManagerCallbackListener |
geppettoManagerCallbackListener |
private static ExperimentRunManager |
instance |
private java.util.Set<IGeppettoProject> |
projectsRunning |
private java.util.Map<IUser,java.util.concurrent.BlockingQueue<IExperiment>> |
queue |
private int |
reqId |
private java.util.Timer |
timer |
Modifier | Constructor and Description |
---|---|
private |
ExperimentRunManager() |
Modifier and Type | Method and Description |
---|---|
private void |
addExperimentToQueue(IUser user,
IExperiment experiment,
ExperimentStatus status) |
void |
cancelExperimentRun(IUser user,
IExperiment experiment) |
boolean |
checkExperiment(IExperiment experiment) |
private void |
decreaseExperimentCounter(IExperiment experiment) |
void |
experimentError(java.lang.String titleMessage,
java.lang.String errorMessage,
java.lang.Exception exception,
IExperiment experiment) |
void |
experimentRunDone(ExperimentRunThread experimentRun,
IExperiment experiment,
RuntimeProject project) |
static ExperimentRunManager |
getInstance() |
java.util.Map<IUser,java.util.concurrent.BlockingQueue<IExperiment>> |
getQueuedExperiments() |
private int |
getReqId() |
private void |
increaseExperimentCounter(IExperiment experimentAboutToRun) |
private void |
loadExperiments() |
void |
queueExperiment(IUser user,
IExperiment experiment) |
(package private) void |
runExperiment(IExperiment experiment) |
void |
setExperimentListener(IGeppettoManagerCallbackListener listener) |
private void |
simulationError(IExperiment experiment) |
private java.util.Map<IUser,java.util.concurrent.BlockingQueue<IExperiment>> queue
private GeppettoManager geppettoManager
private volatile int reqId
private java.util.Timer timer
private IGeppettoManagerCallbackListener geppettoManagerCallbackListener
private java.util.Map<IGeppettoProject,java.lang.Integer> experimentsCounter
private java.util.Set<IGeppettoProject> projectsRunning
private static ExperimentRunManager instance
public static ExperimentRunManager getInstance()
public void queueExperiment(IUser user, IExperiment experiment)
user
- experiment
- public boolean checkExperiment(IExperiment experiment) throws GeppettoInitializationException
experiment
- GeppettoInitializationException
private void decreaseExperimentCounter(IExperiment experiment)
experiment
- private void increaseExperimentCounter(IExperiment experimentAboutToRun)
experimentAboutToRun
- void runExperiment(IExperiment experiment) throws GeppettoExecutionException
GeppettoExecutionException
private void simulationError(IExperiment experiment)
private void loadExperiments() throws GeppettoInitializationException, java.net.MalformedURLException, GeppettoExecutionException
GeppettoInitializationException
java.net.MalformedURLException
GeppettoExecutionException
private void addExperimentToQueue(IUser user, IExperiment experiment, ExperimentStatus status)
user
- experiment
- status
- public void experimentRunDone(ExperimentRunThread experimentRun, IExperiment experiment, RuntimeProject project) throws GeppettoExecutionException
experimentRunDone
in interface IExperimentListener
GeppettoExecutionException
private int getReqId()
public java.util.Map<IUser,java.util.concurrent.BlockingQueue<IExperiment>> getQueuedExperiments()
public void cancelExperimentRun(IUser user, IExperiment experiment) throws GeppettoExecutionException
user
- experiment
- GeppettoExecutionException
public void experimentError(java.lang.String titleMessage, java.lang.String errorMessage, java.lang.Exception exception, IExperiment experiment)
experimentError
in interface IExperimentListener
public void setExperimentListener(IGeppettoManagerCallbackListener listener)