com.bigdata.journal

Class StressTestUnisolatedReadWriteIndex

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.StressTestUnisolatedReadWriteIndex

All Implemented Interfaces:

IProxyTest, junit.framework.Test

public class StressTestUnisolatedReadWriteIndex
extends ProxyTestCase<Journal>

Stress tests for concurrent processing of operations on named unisolated indices where the concurrency is managed by an UnisolatedReadWriteIndex rather than the ConcurrencyManager.

Author:

Bryan Thompson

See Also:

UnisolatedReadWriteIndex

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	StressTestUnisolatedReadWriteIndex.TestOptions Additional properties understood by this test.
static class	StressTestUnisolatedReadWriteIndex.WriteTask A task that writes on named unisolated index(s).

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

TestCase2.MyProperties, TestCase2.RandomType

Field Summary

Fields inherited from class junit.framework.TestCase2

_randomType, log

Constructor Summary

Constructors

Constructor and Description
StressTestUnisolatedReadWriteIndex()
StressTestUnisolatedReadWriteIndex(String name)

Method Summary

Methods

Modifier and Type	Method and Description
static com.bigdata.testutil.ExperimentDriver.Result	doConcurrentClientTest(Journal journal, long timeout, int nresources, int minLocks, int maxLocks, int ntrials, int keyLen, int nops, double failureRate, double commitRate) A stress test of concurrent writers on one or more named indices.
void	setUpComparisonTest(Properties properties)
void	tearDownComparisonTest()
void	test_concurrentClients() A stress test with a small pool of concurrent clients.

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

StressTestUnisolatedReadWriteIndex

public StressTestUnisolatedReadWriteIndex()

StressTestUnisolatedReadWriteIndex

public StressTestUnisolatedReadWriteIndex(String name)

Method Detail

setUpComparisonTest

public void setUpComparisonTest(Properties properties)
                         throws Exception

Throws:

Exception

tearDownComparisonTest

public void tearDownComparisonTest()
                            throws Exception

Throws:

Exception

test_concurrentClients

public void test_concurrentClients()
                            throws InterruptedException

A stress test with a small pool of concurrent clients.

Throws:

InterruptedException

doConcurrentClientTest

public static com.bigdata.testutil.ExperimentDriver.Result doConcurrentClientTest(Journal journal,
                                                                  long timeout,
                                                                  int nresources,
                                                                  int minLocks,
                                                                  int maxLocks,
                                                                  int ntrials,
                                                                  int keyLen,
                                                                  int nops,
                                                                  double failureRate,
                                                                  double commitRate)
                                                                           throws InterruptedException

A stress test of concurrent writers on one or more named indices.

Parameters:

journal - The database.

timeout - The #of seconds before the test will terminate.

nresources - The #of named indices that will be used by the tasks.

minLocks - The minimum #of resources in which a writer will obtain a lock in [0:nresources].

maxLocks - The maximum #of resources in which a writer will obtain a lock in [minLocks:nresources].

ntrials - The #of transactions to execute.

keyLen - The length of the random unsigned byte[] keys used in the operations. The longer the keys the less likely it is that there will be a write-write conflict (that concurrent txs will write on the same key).

nops - The #of operations to be performed in each transaction.

failureRate - The percentage of Writers that will throw a SpuriousException rather than completing normally.

Throws:

InterruptedException