net.sf.sparql.benchmarking.runners.operations

Class RetryingOperationRunner

java.lang.Object

net.sf.sparql.benchmarking.runners.operations.DefaultOperationRunner

net.sf.sparql.benchmarking.runners.operations.RetryingOperationRunner

All Implemented Interfaces:

OperationRunner

public class RetryingOperationRunner
extends DefaultOperationRunner

An operation runner that will retry the given operation if it produces an error

Author:

rvesse

Constructor Summary

Constructors

Constructor and Description
RetryingOperationRunner(int maxRetries) Creates a new runner

Method Summary

Methods

Modifier and Type	Method and Description
<T extends Options> OperationRun	run(Runner<T> runner, T options, Operation op) Runs the operation returning the statistics as an OperationRun
protected <T extends Options> boolean	shouldRetry(Runner<T> runner, T options, Operation op, OperationRun run) Decides whether the runner should continue retrying

Methods inherited from class java.lang.Object

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

Constructor Detail

RetryingOperationRunner

public RetryingOperationRunner(int maxRetries)

Creates a new runner

Parameters:

maxRetries - Maximum number of retries, a value of 0 means no retries in which case behaviour is equivalent to the base class DefaultOperationRunner

Method Detail

run

public <T extends Options> OperationRun run(Runner<T> runner,
                                   T options,
                                   Operation op)

Description copied from interface: OperationRunner

Runs the operation returning the statistics as an OperationRun

Implementations are also expected to record the information within their the OperationStats object of the provided Operation instance prior to returning the statistics.

Specified by:

run in interface OperationRunner

Overrides:

run in class DefaultOperationRunner

Parameters:

runner - Runner

options - Options

op - Operation to run

Returns:

Operation Run statistics

shouldRetry

protected <T extends Options> boolean shouldRetry(Runner<T> runner,
                                      T options,
                                      Operation op,
                                      OperationRun run)

Decides whether the runner should continue retrying

The default implementation always returns true but derived implementations may want to override this if they only wish to carry out retries under certain circumstances.

Parameters:

runner - Runner

options - Options

op - Operation

run - Results of the most recent failed run

Returns:

True if the runner should retry, false otherwise