com.bigdata.concurrent

Class StressTestNonBlockingLockManagerWithPredeclaredLocks

java.lang.Object

junit.framework.Assert

junit.framework.TestCase

com.bigdata.concurrent.AbstractStressTestNonBlockingLockManager

com.bigdata.concurrent.StressTestNonBlockingLockManagerWithPredeclaredLocks

All Implemented Interfaces:

junit.framework.Test

public class StressTestNonBlockingLockManagerWithPredeclaredLocks
extends AbstractStressTestNonBlockingLockManager

Stress tests where we predeclare locks and sort the lock requests. Under these conditions we DO NOT maintain a TxDag since deadlocks CAN NOT arise.

Version:

$Id$

Author:

Bryan Thompson

Nested Class Summary

Nested classes/interfaces inherited from class com.bigdata.concurrent.AbstractStressTestNonBlockingLockManager

AbstractStressTestNonBlockingLockManager.Generate, AbstractStressTestNonBlockingLockManager.TestOptions, AbstractStressTestNonBlockingLockManager.Wait10ResourceTask<T>

Field Summary

Fields inherited from class com.bigdata.concurrent.AbstractStressTestNonBlockingLockManager

DEBUG, INFO, log

Constructor Summary

Constructors

Constructor and Description
StressTestNonBlockingLockManagerWithPredeclaredLocks()
StressTestNonBlockingLockManagerWithPredeclaredLocks(String name)

Method Summary

Methods

Modifier and Type	Method and Description
void	test_multipleResourceLocking_resources10_predeclareLocks_synchronousQueue_locktries10() Test where each operation locks one or more resources.
void	test_multipleResourceLocking_resources10_predeclareLocks_unboundedQueue_locktries10() Test where each operation locks one or more resources.
void	test_noResourcesDoesNotWait_predeclareLocks_synchronousQueue() Test where no locks are declared.
void	test_noResourcesDoesNotWait_predeclareLocks_unboundedQueue() Test where no locks are declared.

Methods inherited from class com.bigdata.concurrent.AbstractStressTestNonBlockingLockManager

doComparisonTest, setUpComparisonTest, 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

Constructor Detail

StressTestNonBlockingLockManagerWithPredeclaredLocks

public StressTestNonBlockingLockManagerWithPredeclaredLocks()

StressTestNonBlockingLockManagerWithPredeclaredLocks

public StressTestNonBlockingLockManagerWithPredeclaredLocks(String name)

Method Detail

test_noResourcesDoesNotWait_predeclareLocks_unboundedQueue

public void test_noResourcesDoesNotWait_predeclareLocks_unboundedQueue()
                                                                throws Exception

Test where no locks are declared. This should run all tasks with the maximum concurrency. Since there is no timeout, all tasks should complete successfully.

Throws:

Exception

test_noResourcesDoesNotWait_predeclareLocks_synchronousQueue

public void test_noResourcesDoesNotWait_predeclareLocks_synchronousQueue()
                                                                  throws Exception

Test where no locks are declared. This should run all tasks with the maximum concurrency. Since there is no timeout, all tasks should complete successfully.

Throws:

Exception

test_multipleResourceLocking_resources10_predeclareLocks_unboundedQueue_locktries10

public void test_multipleResourceLocking_resources10_predeclareLocks_unboundedQueue_locktries10()
                                                                                         throws Exception

Test where each operation locks one or more resources.

Note: This condition provides the basis for deadlocks. In fact, since we have 10 resource locks for each operation and only 100 operations the chances of a deadlock on any given operation are extremely high. However, since we are predeclaring our locks and the lock requests are being sorted NO deadlocks should result.

Note: Tasks are not necessarily serialized for this case since there are 100 resources, so even though each task obtains 10 locks it is possible for tasks to have non-overlapping lock requests and therefore there can be more than one task executing concurrently.

Throws:

Exception

test_multipleResourceLocking_resources10_predeclareLocks_synchronousQueue_locktries10

public void test_multipleResourceLocking_resources10_predeclareLocks_synchronousQueue_locktries10()
                                                                                           throws Exception

Test where each operation locks one or more resources.

Note: This condition provides the basis for deadlocks. In fact, since we have 10 resource locks for each operation and only 100 operations the chances of a deadlock on any given operation are extremely high. However, since we are predeclaring our locks and the lock requests are being sorted NO deadlocks should result.

Note: Tasks are not necessarily serialized for this case since there are 100 resources, so even though each task obtains 10 locks it is possible for tasks to have non-overlapping lock requests and therefore there can be more than one task executing concurrently.

Throws:

Exception