org.hobbit.core.components

Class AbstractDataGenerator

java.lang.Object

org.hobbit.core.components.AbstractComponent

org.hobbit.core.components.AbstractCommandReceivingComponent

org.hobbit.core.components.AbstractPlatformConnectorComponent

org.hobbit.core.components.AbstractDataGenerator

All Implemented Interfaces:

Closeable, AutoCloseable, CommandReceivingComponent, Component, PlatformConnector

public abstract class AbstractDataGenerator
extends AbstractPlatformConnectorComponent

Field Summary

Fields

Modifier and Type	Field and Description
protected int	generatorId The ID of this generator.
protected int	numberOfGenerators The number of data generators that might be running in parallel.
protected DataSender	sender2System Sender for transferring data to the benchmarked system.
protected DataSender	sender2TaskGen Sender for transferring data to the task generators.
private Semaphore	startDataGenMutex Semaphore used to wait for the start signal of the benchmark controller.

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

cmdChannel, cmdQueueFactory, DEFAULT_CMD_RESPONSE_TIMEOUT, defaultContainerType

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

connectionFactory, incomingDataQueueFactory, NUMBER_OF_RETRIES_TO_CONNECT_TO_RABBIT_MQ, outgoingDataQueuefactory, rabbitMQHostName, START_WAITING_TIME_BEFORE_RETRY

Constructor Summary

Constructors

Constructor and Description
AbstractDataGenerator()
AbstractDataGenerator(DataSender sender2TaskGen, DataSender sender2System)

Method Summary

Modifier and Type	Method and Description
void	close()
protected abstract void	generateData()
int	getGeneratorId()
int	getNumberOfGenerators()
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	sendDataToSystemAdapter(byte[] data)
protected void	sendDataToSystemAdapter(InputStream stream)
protected void	sendDataToTaskGenerator(byte[] data)
protected void	sendDataToTaskGenerator(InputStream stream)

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

addContainerObserver, createContainer, getFactoryForIncomingCmdQueues, getFactoryForIncomingDataQueues, getFactoryForOutgoingCmdQueues, getFactoryForOutgoingDataQueues, 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

createConnection, generateSessionQueueName, getHobbitSessionId

Methods inherited from class java.lang.Object

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

Field Detail

startDataGenMutex

private Semaphore startDataGenMutex

Semaphore used to wait for the start signal of the benchmark controller.

generatorId

protected int generatorId

The ID of this generator.

numberOfGenerators

protected int numberOfGenerators

The number of data generators that might be running in parallel.

sender2TaskGen

protected DataSender sender2TaskGen

Sender for transferring data to the task generators.

sender2System

protected DataSender sender2System

Sender for transferring data to the benchmarked system.

Constructor Detail

AbstractDataGenerator

public AbstractDataGenerator()

AbstractDataGenerator

public AbstractDataGenerator(DataSender sender2TaskGen,
                             DataSender sender2System)

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.

Throws:

Exception - if an error occurs during the execution

generateData

protected abstract void generateData()
                              throws Exception

Throws:

Exception

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

sendDataToTaskGenerator

protected void sendDataToTaskGenerator(byte[] data)
                                throws IOException

Throws:

IOException

sendDataToTaskGenerator

protected void sendDataToTaskGenerator(InputStream stream)
                                throws IOException

Throws:

IOException

sendDataToSystemAdapter

protected void sendDataToSystemAdapter(byte[] data)
                                throws IOException

Throws:

IOException

sendDataToSystemAdapter

protected void sendDataToSystemAdapter(InputStream stream)
                                throws IOException

Throws:

IOException

getGeneratorId

public int getGeneratorId()

getNumberOfGenerators

public int getNumberOfGenerators()

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