org.hobbit.controller

Class ExperimentManager

java.lang.Object

org.hobbit.controller.ExperimentManager

All Implemented Interfaces:

Closeable, AutoCloseable

public class ExperimentManager
extends Object
implements Closeable

This class encapsulates (and synchronizes) all methods that are applied on a running experiment.

Author:

Michael Röder (roeder@informatik.uni-leipzig.de)

Field Summary

Fields

Modifier and Type	Field and Description
static long	CHECK_FOR_FIRST_EXPERIMENT Time interval the experiment manager waits before it checks for the an experiment to start.
static long	CHECK_FOR_NEW_EXPERIMENT Time interval with which the experiment manager checks for a new experiment to start.
private PlatformController	controller The controller this manager belongs to.
private static int	DEFAULT_MAX_EXECUTION_TIME
long	defaultMaxExecutionTime Default time an experiment has to terminate after it has been started.
private Semaphore	experimentMutex Mutex used to synchronize the access to the experimentStatus instance.
private ExperimentStatus	experimentStatus Status of the current experiment.
private Timer	expStartTimer Timer used to trigger the creation of the next benchmark.
private static org.slf4j.Logger	LOGGER

Constructor Summary

Constructors

Modifier	Constructor and Description
	ExperimentManager(PlatformController controller)
protected	ExperimentManager(PlatformController controller, long checkForFirstExperiment, long checkForNewExperiment)

Method Summary

Modifier and Type	Method and Description
void	addStatusInfo(org.hobbit.core.data.status.ControllerStatus status, String userName) Adds the status of the current experiment to the given status object.
void	close()
void	createNextExperiment() Creates the next experiment if there is no experiment running and there is an experiment waiting in the queue.
private void	forceBenchmarkTerminate_unsecured(org.apache.jena.rdf.model.Resource error) Forces the benchmark controller and its child containers to terminate.
protected static String	getSerializedSystemParams(ExperimentConfiguration config, org.hobbit.core.data.BenchmarkMetaData benchmark, org.hobbit.core.data.SystemMetaData system)
private void	handleExperimentTermination_unsecured()
void	handleExperimentTermination() This method handles the storing of the experiment results in the database, the removing of the experiment from the queue and its closing in a synchronized way.
void	notifyExpRuntimeExpired(ExperimentStatus expiredState) Called by the ExperimentAbortTimerTask if the maximum runtime of an experiment has been reached.
void	notifyTermination(String containerId, int exitCode) Handles the termination of the container with the given container Id and the given exit code.
protected void	prefetchImages(org.hobbit.core.data.BenchmarkMetaData benchmark, org.hobbit.core.data.SystemMetaData system)
private void	setResultModel_unsecured(org.apache.jena.rdf.model.Model model) Sets the result model of the current running experiment.
void	setResultModel(byte[] data, Function<? super byte[],? extends org.apache.jena.rdf.model.Model> function) Sets the result model of the current running experiment by transforming the given data into an RDF model using the given function while owning the experimentStatus object and therefore blocking all other operations on that object.
void	setResultModel(org.apache.jena.rdf.model.Model model) Sets the result model of the current running experiment.
private void	startBenchmark_unsecured() Sends the start message to the benchmark controller.
void	stopExperimentIfRunning(String experimentId) Stops the currently running experiment if it has the given experiment id.
void	systemOrBenchmarkReady(boolean systemReportedReady) Handles the messages that either the system or the benchmark controller are ready.
void	taskGenFinished() Changes the state of the internal experiment to ExperimentStatus.States#EVALUATION.

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

private static final org.slf4j.Logger LOGGER

DEFAULT_MAX_EXECUTION_TIME

private static final int DEFAULT_MAX_EXECUTION_TIME

See Also:

Constant Field Values

CHECK_FOR_FIRST_EXPERIMENT

public static final long CHECK_FOR_FIRST_EXPERIMENT

Time interval the experiment manager waits before it checks for the an experiment to start. It is larger than CHECK_FOR_NEW_EXPERIMENT since the system needs some time to initialize all components and we want to make sure that everything is up and running.

See Also:

Constant Field Values

CHECK_FOR_NEW_EXPERIMENT

public static final long CHECK_FOR_NEW_EXPERIMENT

Time interval with which the experiment manager checks for a new experiment to start.

See Also:

Constant Field Values

defaultMaxExecutionTime

public long defaultMaxExecutionTime

Default time an experiment has to terminate after it has been started.

controller

private PlatformController controller

The controller this manager belongs to.

experimentMutex

private Semaphore experimentMutex

Mutex used to synchronize the access to the experimentStatus instance.

experimentStatus

private ExperimentStatus experimentStatus

Status of the current experiment. null if no benchmark is running.

expStartTimer

private Timer expStartTimer

Timer used to trigger the creation of the next benchmark.

Constructor Detail

ExperimentManager

public ExperimentManager(PlatformController controller)

ExperimentManager

protected ExperimentManager(PlatformController controller,
                            long checkForFirstExperiment,
                            long checkForNewExperiment)

Method Detail

createNextExperiment

public void createNextExperiment()

Creates the next experiment if there is no experiment running and there is an experiment waiting in the queue.

getSerializedSystemParams

protected static String getSerializedSystemParams(ExperimentConfiguration config,
                                                  org.hobbit.core.data.BenchmarkMetaData benchmark,
                                                  org.hobbit.core.data.SystemMetaData system)

prefetchImages

protected void prefetchImages(org.hobbit.core.data.BenchmarkMetaData benchmark,
                              org.hobbit.core.data.SystemMetaData system)
                       throws Exception

Throws:

Exception

setResultModel

public void setResultModel(byte[] data,
                           Function<? super byte[],? extends org.apache.jena.rdf.model.Model> function)

Sets the result model of the current running experiment by transforming the given data into an RDF model using the given function while owning the experimentStatus object and therefore blocking all other operations on that object.

Parameters:

data - binary data containing a serialized RDF model

function - a deserialization function transforming the binary data into an RDF model

setResultModel

public void setResultModel(org.apache.jena.rdf.model.Model model)

Sets the result model of the current running experiment.

Parameters:

model - the result model

setResultModel_unsecured

private void setResultModel_unsecured(org.apache.jena.rdf.model.Model model)

Sets the result model of the current running experiment.

Parameters:

model - the result model

handleExperimentTermination

public void handleExperimentTermination()

This method handles the storing of the experiment results in the database, the removing of the experiment from the queue and its closing in a synchronized way.

handleExperimentTermination_unsecured

private void handleExperimentTermination_unsecured()

forceBenchmarkTerminate_unsecured

private void forceBenchmarkTerminate_unsecured(org.apache.jena.rdf.model.Resource error)

Forces the benchmark controller and its child containers to terminate. If the given error is not null it is added to the result model of the experiment.

Parameters:

error - error that is added to the result model of the experiment

notifyTermination

public void notifyTermination(String containerId,
                              int exitCode)

Handles the termination of the container with the given container Id and the given exit code.

Parameters:

containerId - Id of the terminated container

exitCode - exit code of the termination

systemOrBenchmarkReady

public void systemOrBenchmarkReady(boolean systemReportedReady)

Handles the messages that either the system or the benchmark controller are ready.

Parameters:

systemReportedReady - true if the message was sent by the system, false if the benchmark controller is ready

startBenchmark_unsecured

private void startBenchmark_unsecured()
                               throws IOException

Sends the start message to the benchmark controller.

Throws:

IOException - if there is a communication problem or if the name of the system container can not be retrieved from the docker daemon

addStatusInfo

public void addStatusInfo(org.hobbit.core.data.status.ControllerStatus status,
                          String userName)

Adds the status of the current experiment to the given status object.

Parameters:

status - the status object to which the data should be added

taskGenFinished

public void taskGenFinished()

Changes the state of the internal experiment to ExperimentStatus.States#EVALUATION.

notifyExpRuntimeExpired

public void notifyExpRuntimeExpired(ExperimentStatus expiredState)

Called by the ExperimentAbortTimerTask if the maximum runtime of an experiment has been reached.

Parameters:

expiredState - the experiment status the timer was working on which is used to make sure that the timer was started for the currently running experiment.

stopExperimentIfRunning

public void stopExperimentIfRunning(String experimentId)

Stops the currently running experiment if it has the given experiment id.

Parameters:

experimentId - the id of the experiment that should be stopped

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException