org.hobbit.core.components

Class AbstractSystemAdapter

java.lang.Object

org.hobbit.core.components.AbstractComponent

org.hobbit.core.components.AbstractCommandReceivingComponent

org.hobbit.core.components.AbstractPlatformConnectorComponent

org.hobbit.core.components.AbstractSystemAdapter

All Implemented Interfaces:

Closeable, AutoCloseable, CommandReceivingComponent, Component, GeneratedDataReceivingComponent, PlatformConnector, RabbitQueueFactory, TaskReceivingComponent

public abstract class AbstractSystemAdapter
extends AbstractPlatformConnectorComponent
implements GeneratedDataReceivingComponent, TaskReceivingComponent

This abstract class implements basic functions that can be used to implement a system adapter.

Author:

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

Field Summary

Fields

Modifier and Type	Field and Description
private Exception	cause The cause for an unusual termination.
private Semaphore	causeMutex Mutex used to manage access to the cause object.
private Semaphore	currentlyProcessedMessages Semaphore used to control the number of data messages that can be processed in parallel.
private Semaphore	currentlyProcessedTasks Semaphore used to control the number of tasks that can be processed in parallel.
protected RabbitQueue	dataGen2SystemQueue Queue from the data generator to this evaluation storage.
private static int	DEFAULT_MAX_PARALLEL_PROCESSED_MESSAGES Default value of the maxParallelProcessedMsgs attribute.
private static org.slf4j.Logger	LOGGER
private int	maxParallelProcessedMsgs The maximum number of incoming messages of a single queue that are processed in parallel.
protected RabbitQueue	system2EvalStoreQueue Queue from the benchmarked system to this evaluation storage.
protected org.apache.jena.rdf.model.Model	systemParamModel The RDF model containing the system parameters.
protected RabbitQueue	taskGen2SystemQueue Queue from the task generator to this evaluation storage.
private Semaphore	terminateMutex Mutex used to wait for the terminate signal.

Fields inherited from class org.hobbit.core.components.AbstractCommandReceivingComponent

cmdChannel, cmdConnection, defaultContainerType

Fields inherited from class org.hobbit.core.components.AbstractComponent

connectionFactory, dataConnection, NUMBER_OF_RETRIES_TO_CONNECT_TO_RABBIT_MQ, rabbitMQHostName, START_WAITING_TIME_BEFORE_RETRY

Constructor Summary

Constructors

Constructor and Description
AbstractSystemAdapter() Constructor using the DEFAULT_MAX_PARALLEL_PROCESSED_MESSAGES= 100.
AbstractSystemAdapter(int maxParallelProcessedMsgs) Constructor setting the maximum number of messages processed in parallel.

Method Summary

Modifier and Type	Method and Description
void	close()
void	init() This method initializes the component.
void	receiveCommand(byte command, byte[] data) This method is called if a command is received and might be interesting for this particular component.
void	run() This method executes the component.
protected void	sendResultToEvalStorage(String taskIdString, byte[] data) This method sends the given result data for the task with the given task id to the evaluation storage.
protected void	terminate(Exception cause) Starts termination of the main thread of this system adapter.

Methods inherited from class org.hobbit.core.components.AbstractPlatformConnectorComponent

addContainerObserver, createContainer, createDefaultRabbitQueue, stopContainer

Methods inherited from class org.hobbit.core.components.AbstractCommandReceivingComponent

addCommandHeaderId, createContainer, createContainer, handleCmd, sendToCmdQueue, sendToCmdQueue, sendToCmdQueue

Methods inherited from class org.hobbit.core.components.AbstractComponent

generateSessionQueueName, getHobbitSessionId

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.hobbit.core.components.GeneratedDataReceivingComponent

receiveGeneratedData

Methods inherited from interface org.hobbit.core.components.TaskReceivingComponent

receiveGeneratedTask

Field Detail

LOGGER

private static final org.slf4j.Logger LOGGER

DEFAULT_MAX_PARALLEL_PROCESSED_MESSAGES

private static final int DEFAULT_MAX_PARALLEL_PROCESSED_MESSAGES

Default value of the maxParallelProcessedMsgs attribute.

See Also:

Constant Field Values

terminateMutex

private Semaphore terminateMutex

Mutex used to wait for the terminate signal.

cause

private Exception cause

The cause for an unusual termination.

causeMutex

private Semaphore causeMutex

Mutex used to manage access to the cause object.

currentlyProcessedMessages

private Semaphore currentlyProcessedMessages

Semaphore used to control the number of data messages that can be processed in parallel.

currentlyProcessedTasks

private Semaphore currentlyProcessedTasks

Semaphore used to control the number of tasks that can be processed in parallel.

maxParallelProcessedMsgs

private final int maxParallelProcessedMsgs

The maximum number of incoming messages of a single queue that are processed in parallel. Additional messages have to wait.

dataGen2SystemQueue

protected RabbitQueue dataGen2SystemQueue

Queue from the data generator to this evaluation storage.

taskGen2SystemQueue

protected RabbitQueue taskGen2SystemQueue

Queue from the task generator to this evaluation storage.

system2EvalStoreQueue

protected RabbitQueue system2EvalStoreQueue

Queue from the benchmarked system to this evaluation storage.

systemParamModel

protected org.apache.jena.rdf.model.Model systemParamModel

The RDF model containing the system parameters.

Constructor Detail

AbstractSystemAdapter

public AbstractSystemAdapter()

Constructor using the DEFAULT_MAX_PARALLEL_PROCESSED_MESSAGES= 100.

AbstractSystemAdapter

public AbstractSystemAdapter(int maxParallelProcessedMsgs)

Constructor setting the maximum number of messages processed in parallel.

Parameters:

maxParallelProcessedMsgs - The maximum number of incoming messages of a single queue that are processed in parallel. Additional messages have to wait.

Method Detail

init

public void init()
          throws Exception

Description copied from interface: Component

This method initializes the component.

Specified by:

init in interface Component

Overrides:

init in class AbstractCommandReceivingComponent

Throws:

Exception - if an error occurs during the initialization

run

public void run()
         throws Exception

Description copied from interface: Component

This method executes the component.

Specified by:

run in interface Component

Throws:

Exception - if an error occurs during the execution

receiveCommand

public void receiveCommand(byte command,
                           byte[] data)

Description copied from interface: CommandReceivingComponent

This method is called if a command is received and might be interesting for this particular component.

Specified by:

receiveCommand in interface CommandReceivingComponent

Overrides:

receiveCommand in class AbstractPlatformConnectorComponent

Parameters:

command - the byte encoding the command

data - additional data that was sent together with the command

sendResultToEvalStorage

protected void sendResultToEvalStorage(String taskIdString,
                                       byte[] data)
                                throws IOException

This method sends the given result data for the task with the given task id to the evaluation storage.

Parameters:

taskIdString - the id of the task

data - the data of the task

Throws:

IOException - if there is an error during the sending

terminate

protected void terminate(Exception cause)

Starts termination of the main thread of this system adapter. If a cause is given, it will be thrown causing an abortion from the main thread instead of a normal termination.

Parameters:

cause - the cause for an abortion of the process or {code null} if the component should terminate in a normal way.

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class AbstractCommandReceivingComponent

Throws:

IOException