org.maestro.tests

Class AbstractTestExecutor

java.lang.Object

org.maestro.tests.AbstractTestExecutor

All Implemented Interfaces:

TestExecutor

Direct Known Subclasses:

AbstractFixedRateExecutor, FlexibleTestExecutor, IncrementalTestExecutor

public abstract class AbstractTestExecutor
extends Object
implements TestExecutor

A simple test executor that should be extensible for most usages

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractTestExecutor(Maestro maestro, ReportsDownloader reportsDownloader)

Method Summary

Modifier and Type	Method and Description
protected void	drain()
protected Maestro	getMaestro()
protected ReportsDownloader	getReportsDownloader()
Instant	getStartTime()
protected long	getTimeout(AbstractTestProfile testProfile)
protected boolean	isFailed(MaestroNote note)
boolean	isRunning()
protected boolean	isTestFailed(MaestroNote note)
protected int	peerCount(AbstractTestProfile testProfile)
protected void	startServices() Start connected peers
protected void	startServices(AbstractTestProfile testProfile) Start connected peers
void	stopServices() Stop connected peers
protected void	testStart()
protected void	testStop()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.maestro.tests.TestExecutor

getCoolDownPeriod, run

Constructor Detail

AbstractTestExecutor

protected AbstractTestExecutor(Maestro maestro,
                               ReportsDownloader reportsDownloader)

Method Detail

getMaestro

protected Maestro getMaestro()

getReportsDownloader

protected ReportsDownloader getReportsDownloader()

testStart

protected void testStart()

testStop

protected void testStop()

isRunning

public boolean isRunning()

getStartTime

public Instant getStartTime()

startServices

protected void startServices()
                      throws MaestroConnectionException

Start connected peers

Throws:

MaestroConnectionException - if there's a connection error while communicating w/ the Maestro broker

startServices

protected void startServices(AbstractTestProfile testProfile)
                      throws MaestroConnectionException

Start connected peers

Parameters:

testProfile - the test profile in use

Throws:

MaestroConnectionException - if there's a connection error while communicating w/ the Maestro broker

stopServices

public final void stopServices()
                        throws MaestroConnectionException

Stop connected peers

Throws:

MaestroConnectionException - if there's a connection error while communicating w/ the Maestro broker

peerCount

protected int peerCount(AbstractTestProfile testProfile)
                 throws InterruptedException

Throws:

InterruptedException

isTestFailed

protected boolean isTestFailed(MaestroNote note)

isFailed

protected boolean isFailed(MaestroNote note)

getTimeout

protected long getTimeout(AbstractTestProfile testProfile)

drain

protected void drain()