org.dice_research.ldcbench.nodes.components

Class NodeComponent

java.lang.Object

org.hobbit.core.components.AbstractComponent

org.hobbit.core.components.AbstractCommandReceivingComponent

org.dice_research.ldcbench.nodes.components.NodeComponent

All Implemented Interfaces:

Closeable, AutoCloseable, AbstractNodeComponent, org.hobbit.core.components.CommandReceivingComponent, org.hobbit.core.components.Component

public abstract class NodeComponent
extends org.hobbit.core.components.AbstractCommandReceivingComponent
implements AbstractNodeComponent

Field Summary

Fields

Modifier and Type	Field and Description
protected String	accessUriTemplate
protected org.dice_research.ldcbench.rabbit.ObjectStreamFanoutExchangeConsumer<org.dice_research.ldcbench.data.NodeMetadata[]>	bcBroadcastConsumer
protected org.apache.jena.rdf.model.Model	benchmarkParamModel
protected com.google.common.util.concurrent.SettableFuture<Integer>	cloudNodeId
protected Semaphore	dataGenerationFinished
protected boolean	dockerized
protected org.hobbit.core.rabbit.SimpleFileReceiver	fileReceiver
protected GraphHandler	graphHandler
protected List<org.dice_research.ldcbench.graph.Graph>	graphs
private static org.slf4j.Logger	LOGGER
protected Semaphore	nodeAcked
protected org.dice_research.ldcbench.data.NodeMetadata[]	nodeMetadata
protected String	nodeURI
protected org.hobbit.core.rabbit.DataReceiver	receiver
protected String	resourceUriTemplate Must be set during initBeforeDataGeneration, would be used as a hostname by which this node should be accessed by the benchmarked system instead of node container's hostname.
protected org.dice_research.ldcbench.generate.SeedGenerator	seedGenerator

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

cmdChannel, cmdQueueFactory, cmdResponseTimeout, DEFAULT_CMD_RESPONSE_TIMEOUT, defaultContainerType, gson

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
NodeComponent()

Method Summary

Modifier and Type	Method and Description
void	close()
protected Thread	createReceiverThread() A method that creates a thread for receiving the data of from the data generator.
protected void	handleBCMessage(org.dice_research.ldcbench.data.NodeMetadata[] nodeMetadata)
void	init()
protected void	joinReceiverThread(Thread receiverThread) Method that triggers the receiver thread to terminate, waits for it to finish its work and checks the received data.
void	receiveCommand(byte command, byte[] data)
void	run()
String	toString()

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

addCommandHeaderId, createContainer, createContainer, createContainer, createContainerAsync, createContainerAsync, extendContainerEnvVariables, getCmdResponseTimeout, handleCmd, handleCmd, sendToCmdQueue, sendToCmdQueue, sendToCmdQueue, setCmdResponseTimeout, stopContainer

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, wait, wait, wait

Methods inherited from interface org.dice_research.ldcbench.nodes.components.AbstractNodeComponent

addResults, initAfterDataGeneration, initBeforeDataGeneration

Field Detail

LOGGER

private static final org.slf4j.Logger LOGGER

benchmarkParamModel

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

seedGenerator

protected org.dice_research.ldcbench.generate.SeedGenerator seedGenerator

dataGenerationFinished

protected Semaphore dataGenerationFinished

nodeAcked

protected Semaphore nodeAcked

cloudNodeId

protected com.google.common.util.concurrent.SettableFuture<Integer> cloudNodeId

nodeURI

protected String nodeURI

dockerized

protected boolean dockerized

resourceUriTemplate

protected String resourceUriTemplate

Must be set during initBeforeDataGeneration, would be used as a hostname by which this node should be accessed by the benchmarked system instead of node container's hostname.

accessUriTemplate

protected String accessUriTemplate

receiver

protected org.hobbit.core.rabbit.DataReceiver receiver

fileReceiver

protected org.hobbit.core.rabbit.SimpleFileReceiver fileReceiver

graphHandler

protected GraphHandler graphHandler

bcBroadcastConsumer

protected org.dice_research.ldcbench.rabbit.ObjectStreamFanoutExchangeConsumer<org.dice_research.ldcbench.data.NodeMetadata[]> bcBroadcastConsumer

nodeMetadata

protected org.dice_research.ldcbench.data.NodeMetadata[] nodeMetadata

graphs

protected List<org.dice_research.ldcbench.graph.Graph> graphs

Constructor Detail

NodeComponent

public NodeComponent()

Method Detail

init

public void init()
          throws Exception

Specified by:

init in interface org.hobbit.core.components.Component

Overrides:

init in class org.hobbit.core.components.AbstractCommandReceivingComponent

Throws:

Exception

createReceiverThread

protected Thread createReceiverThread()
                               throws IOException

A method that creates a thread for receiving the data of from the data generator.

Returns:

Throws:

IOException

joinReceiverThread

protected void joinReceiverThread(Thread receiverThread)
                           throws InterruptedException

Method that triggers the receiver thread to terminate, waits for it to finish its work and checks the received data.

Parameters:

receiverThread -

Throws:

InterruptedException

receiveCommand

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

Specified by:

receiveCommand in interface org.hobbit.core.components.CommandReceivingComponent

handleBCMessage

protected void handleBCMessage(org.dice_research.ldcbench.data.NodeMetadata[] nodeMetadata)

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class org.hobbit.core.components.AbstractCommandReceivingComponent

Throws:

IOException

run

public void run()
         throws Exception

Specified by:

run in interface org.hobbit.core.components.Component

Throws:

Exception

toString

public String toString()

Overrides:

toString in class Object