com.bigdata.journal

Class StressTestGroupCommit

java.lang.Object

junit.framework.Assert

junit.framework.TestCase

junit.framework.TestCase2

com.bigdata.io.TestCase3

com.bigdata.journal.AbstractIndexManagerTestCase<S>

com.bigdata.journal.ProxyTestCase<Journal>

com.bigdata.journal.StressTestGroupCommit

All Implemented Interfaces:

com.bigdata.testutil.ExperimentDriver.IComparisonTest, IProxyTest, junit.framework.Test

public class StressTestGroupCommit
extends ProxyTestCase<Journal>
implements com.bigdata.testutil.ExperimentDriver.IComparisonTest

Stress test of the group commit mechanism. This class may be used to tune the performance of a variety of parameters that effect the throughput of group commit. There are other stress tests that show the throughput for more complex tasks or for isolated tasks (transactions). This test focuses purely on the group commit mechanism itself.

The basic test submits a bunch of unisolated write tasks to a WriteExecutorService of a known capacity. The write tasks are designed to have with non-overlapping lock requirements so that they may run with the maximum possible concurrency. The test the examines how many of the tasks make it into the commit group (on average).

In order for there to be a commit, each task must write some data. In the current design each task creates a named index. This means that there is some data to write, but also that some synchronization is required on AbstractJournal._name2Addr.

Author:

Bryan Thompson

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StressTestGroupCommit.GenerateExperiment Experiment generation utility class.
static interface	StressTestGroupCommit.TestOptions Options understood by this stress test.

Nested classes/interfaces inherited from class junit.framework.TestCase2

TestCase2.MyProperties, TestCase2.RandomType

Field Summary

Fields inherited from class com.bigdata.io.TestCase3

r

Fields inherited from class junit.framework.TestCase2

_randomType, log

Constructor Summary

Constructors

Constructor and Description
StressTestGroupCommit()
StressTestGroupCommit(String arg0)

Method Summary

Methods

Modifier and Type	Method and Description
com.bigdata.testutil.ExperimentDriver.Result	doComparisonTest(Properties properties)
static void	main(String[] args) Run the stress test configured in the code.
void	setUpComparisonTest(Properties properties)
void	tearDownComparisonTest()
void	test_groupCommit() Runs a single condition.
void	test_singleThreadIndexCreationRate() Measures the maximum rate at which a single thread can register named indices.
void	test_twothreadIndexCreationRate() Measures the maximum rate at which two threads can register named indices.

Methods inherited from class com.bigdata.journal.ProxyTestCase

getDelegate, getOurDelegate, getProperties, getStore, getStore, reopenStore, setDelegate, setUp, tearDown

Methods inherited from class com.bigdata.journal.AbstractIndexManagerTestCase

checkIfProxy, fail, getRandomData, setUp, tearDown

Methods inherited from class com.bigdata.io.TestCase3

assertCondition, assertCondition, assertEquals, assertEquals, getBytes, getPort, getRandomData, getRandomData

Methods inherited from class junit.framework.TestCase2

assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEqualsWithinUlps, assertSameArray, assertSameArray, assertSameBigDecimal, assertSameBigDecimal, assertSameBigInteger, assertSameBigInteger, assertSameIterator, assertSameIterator, assertSameIteratorAnyOrder, assertSameIteratorAnyOrder, assertSameValue, assertSameValue, assertZeroUlps, assertZeroUlps, fail, getInnerCause, getNormalInt, getProjectBuildPath, getRandomObject, getRandomObject, getRandomOrder, getRandomString, getTestInputStream, getTestResource, getTestResource, getUlps, getUlps, isDEBUG, isDEBUG, isINFO, isINFO, isInnerCause, logProperties

Methods inherited from class junit.framework.TestCase

assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertFalse, assertFalse, assertNotNull, assertNotNull, assertNotSame, assertNotSame, assertNull, assertNull, assertSame, assertSame, assertTrue, assertTrue, countTestCases, createResult, fail, fail, failNotEquals, failNotSame, failSame, format, getName, run, run, runBare, runTest, setName, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface junit.framework.Test

countTestCases, run

Constructor Detail

StressTestGroupCommit

public StressTestGroupCommit()

StressTestGroupCommit

public StressTestGroupCommit(String arg0)

Parameters:

arg0 -

Method Detail

test_singleThreadIndexCreationRate

public void test_singleThreadIndexCreationRate()

Measures the maximum rate at which a single thread can register named indices. This provides an approximate lower bound for throughput using group commit and the same index creation task. The actual throughput could be somewhat higher or lower since access to the index in which the metadata records for the named indices are stored is itself synchronized, but there is other work to be performed by the task, such as the creation of the named index and writing it onto the store to obtain its metadata record.

Note: This is for data collection - it is not really a unit test.

test_twothreadIndexCreationRate

public void test_twothreadIndexCreationRate()
                                     throws InterruptedException

Measures the maximum rate at which two threads can register named indices. This provides a good approximation for the throughput using group commit and the same index creation task when the thread pool has two threads.

Note: This is for data collection - it is not really a unit test.

Throws:

InterruptedException

test_groupCommit

public void test_groupCommit()
                      throws Exception

Runs a single condition.

Throws:

Exception

doComparisonTest

public com.bigdata.testutil.ExperimentDriver.Result doComparisonTest(Properties properties)
                                                              throws Exception

Specified by:

doComparisonTest in interface com.bigdata.testutil.ExperimentDriver.IComparisonTest

Throws:

Exception

setUpComparisonTest

public void setUpComparisonTest(Properties properties)
                         throws Exception

Specified by:

setUpComparisonTest in interface com.bigdata.testutil.ExperimentDriver.IComparisonTest

Throws:

Exception

tearDownComparisonTest

public void tearDownComparisonTest()
                            throws Exception

Specified by:

tearDownComparisonTest in interface com.bigdata.testutil.ExperimentDriver.IComparisonTest

Throws:

Exception

main

public static void main(String[] args)
                 throws Exception

Run the stress test configured in the code.

Parameters:

args -

Throws:

Exception