org.apache.jackrabbit.oak.scalability.benchmarks

Class ConcurrentReader

java.lang.Object

org.apache.jackrabbit.oak.scalability.benchmarks.ScalabilityBenchmark

org.apache.jackrabbit.oak.scalability.benchmarks.ConcurrentReader

Direct Known Subclasses:

ConcurrentWriter

public class ConcurrentReader
extends ScalabilityBenchmark

Reads random paths concurrently with multiple readers/writers configured with WRITERS and READERS.

The following system JVM properties can be defined to configure the benchmark behavior.

• concurrentWriters - Controls the number of concurrent background threads for writing nodes. Defaults to 0.
• concurrentReaders - Controls the number of concurrent background threads for reading nodes. Defaults to 0.
• assets - Controls the number of nodes to read/write in the background threads. Defaults to 100.

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
ConcurrentReader()

Method Summary

Methods

Modifier and Type	Method and Description
void	afterExecute(Repository repository, Credentials credentials, ScalabilityAbstractSuite.ExecutionContext context) Run any cleanup necessary after the benchmark
void	beforeExecute(Repository repository, Credentials credentials, ScalabilityAbstractSuite.ExecutionContext context) Run any preparatory steps before the benchmark.
void	execute(Repository repository, Credentials credentials, ScalabilityAbstractSuite.ExecutionContext context) Runs the benchmark against the given repository.

Methods inherited from class org.apache.jackrabbit.oak.scalability.benchmarks.ScalabilityBenchmark

toString

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final org.slf4j.Logger LOG

Constructor Detail

ConcurrentReader

public ConcurrentReader()

Method Detail

beforeExecute

public void beforeExecute(Repository repository,
                 Credentials credentials,
                 ScalabilityAbstractSuite.ExecutionContext context)
                   throws Exception

Description copied from class: ScalabilityBenchmark

Run any preparatory steps before the benchmark.

Overrides:

beforeExecute in class ScalabilityBenchmark

Parameters:

repository - the repository instance

credentials - the credentials

context - the execution context

Throws:

Exception

afterExecute

public void afterExecute(Repository repository,
                Credentials credentials,
                ScalabilityAbstractSuite.ExecutionContext context)

Description copied from class: ScalabilityBenchmark

Run any cleanup necessary after the benchmark

Overrides:

afterExecute in class ScalabilityBenchmark

Parameters:

repository - the repository instance

credentials - the credentials

context - the execution context

execute

public void execute(Repository repository,
           Credentials credentials,
           ScalabilityAbstractSuite.ExecutionContext context)
             throws Exception

Description copied from class: ScalabilityBenchmark

Runs the benchmark against the given repository.

Specified by:

execute in class ScalabilityBenchmark

Parameters:

repository - the repository instance

credentials - the credentials

context - the execution context

Throws:

Exception