com.bigdata.concurrent

Class AbstractStressTestNonBlockingLockManager

java.lang.Object

junit.framework.Assert

junit.framework.TestCase

com.bigdata.concurrent.AbstractStressTestNonBlockingLockManager

All Implemented Interfaces:

junit.framework.Test

Direct Known Subclasses:

StressTestNonBlockingLockManagerWithPredeclaredLocks, StressTestNonBlockingLockManagerWithTxDag

public abstract class AbstractStressTestNonBlockingLockManager
extends junit.framework.TestCase

Suite of stress tests of the concurrency control mechanisms (without the database implementation) - See NonBlockingLockManager.

Goals:

1. higher concurrency of unisolated operations on the ds/journal with group commit. this only requires a "lock" per writable named index, e.g., an operation will lock exactly one resource. show consistency of the data in a suite of stress tests with varying #s of threads, tasks, and resources. Each task will lock exactly one resource - the unisolated named index on which it would write. DO THIS W/O the TxDAG first and get group commit debugged before trying to work through the tx commit stuff, which requires the WAITS_FOR graph support.

2. transaction processing integrated with unisolated operations. since a transaction MAY write on more than one index this requires a TxDAG and a queue of resources waiting to get into the granted group (which will always be a singleton since writes on unisolated named indices require exclusive locks). show that concurrency control never deadlocks in a suite of stress tests with varying #s of threads, tasks, resources, and resource locked per task. Again, a resource is a unisolated named index.

Version:

$Id$

Author:

Bryan Thompson

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AbstractStressTestNonBlockingLockManager.Generate Generates an XML file that can be used to (re-)run the concurrency control tests.
static class	AbstractStressTestNonBlockingLockManager.TestOptions Options for doComparisonTest(Properties).
static class	AbstractStressTestNonBlockingLockManager.Wait10ResourceTask<T> Waits 10ms once it acquires its locks.

Field Summary

Fields

Modifier and Type	Field and Description
protected static boolean	DEBUG
protected static boolean	INFO
protected static org.apache.log4j.Logger	log

Constructor Summary

Constructors

Constructor and Description
AbstractStressTestNonBlockingLockManager()
AbstractStressTestNonBlockingLockManager(String arg0)

Method Summary

Methods

Modifier and Type	Method and Description
com.bigdata.testutil.ExperimentDriver.Result	doComparisonTest(Properties properties) Test driver.
void	setUpComparisonTest(Properties properties)
void	tearDownComparisonTest()

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, setUp, tearDown, 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.apache.log4j.Logger log

INFO

protected static final boolean INFO

DEBUG

protected static final boolean DEBUG

Constructor Detail

AbstractStressTestNonBlockingLockManager

public AbstractStressTestNonBlockingLockManager()

AbstractStressTestNonBlockingLockManager

public AbstractStressTestNonBlockingLockManager(String arg0)

Parameters:

arg0 -

Method Detail

doComparisonTest

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

Test driver.

Note: A "resource" is a named index (partition), so set nresources based on your expectations for the #of index partitions on a journal or federation.

Note: The likelyhood of deadlock increases as (a) more locks are requested per task; and (b) fewer resources are available to be locked. When minLocks==maxLocks==nresources then tasks will be serialized since each task requires all resources in order to proceed.

Note: At minLocks==maxLocks==1 this test can be used to explore the behavior of tasks that lock only a single resource, eg., unisolated operations on the DataService.

Throws:

Exception

setUpComparisonTest

public void setUpComparisonTest(Properties properties)
                         throws Exception

Throws:

Exception

tearDownComparisonTest

public void tearDownComparisonTest()
                            throws Exception

Throws:

Exception