org.maestro.worker.common

Class WorkerContainer

java.lang.Object

org.maestro.worker.common.WorkerContainer

public final class WorkerContainer
extends Object

This is a container class for multiple workerRuntimeInfos. It is responsible for creating, starting and stopping multiple workerRuntimeInfos at once.

Constructor Summary

Constructors

Constructor and Description
WorkerContainer()

Method Summary

Modifier and Type	Method and Description
List<MaestroWorker>	create(WorkerInitializer initializer, int count)
void	fail(String message)
List<WatchdogObserver>	getObservers()
boolean	isTestInProgress() Checks whether the test is in progress or not
LatencyStats	latencyStats(Evaluator<?> evaluator) Gets the latency statistics
void	start(Evaluator<?> evaluator) Start the execution of the workers for a predefined class
void	stop()
ThroughputStats	throughputStats() Gets the throughput statistics
boolean	waitForComplete(long timeout)

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkerContainer

public WorkerContainer()

Method Detail

create

public List<MaestroWorker> create(WorkerInitializer initializer,
                                  int count)
                           throws IllegalAccessException,
                                  InstantiationException

Throws:

IllegalAccessException

InstantiationException

start

public void start(Evaluator<?> evaluator)

Start the execution of the workers for a predefined class

Parameters:

evaluator - The evaluator that is run along w/ the worker watchdog (ie.: to evaluate the FCL/latency)

stop

public void stop()

fail

public void fail(String message)

isTestInProgress

public boolean isTestInProgress()

Checks whether the test is in progress or not

Returns:

true if a test is in progress or false otherwise

throughputStats

public ThroughputStats throughputStats()

Gets the throughput statistics

Returns:

the throughput statistics

latencyStats

public LatencyStats latencyStats(Evaluator<?> evaluator)

Gets the latency statistics

Returns:

the latency statistics or null if not applicable for the work set in the container

getObservers

public List<WatchdogObserver> getObservers()

waitForComplete

public boolean waitForComplete(long timeout)