com.bigdata.concurrent

Class TestNonBlockingLockManagerWithNewDesign

java.lang.Object

junit.framework.Assert

junit.framework.TestCase

com.bigdata.concurrent.TestNonBlockingLockManagerWithNewDesign

All Implemented Interfaces:

junit.framework.Test

public class TestNonBlockingLockManagerWithNewDesign
extends junit.framework.TestCase

basic unit tests.

Version:

$Id$

Author:

Bryan Thompson

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestNonBlockingLockManagerWithNewDesign.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
TestNonBlockingLockManagerWithNewDesign()
TestNonBlockingLockManagerWithNewDesign(String name)

Method Summary

Methods

Modifier and Type	Method and Description
protected <R extends Comparable<R>,T> void	assertLocksHeld(NonBlockingLockManagerWithNewDesign<R> service, NonBlockingLockManagerWithNewDesign.LockFutureTask<R,T> task) Succeeds if the task holds all of its declared locks.
protected <R extends Comparable<R>,T> void	assertLocksNotHeld(NonBlockingLockManagerWithNewDesign<R> service, NonBlockingLockManagerWithNewDesign.LockFutureTask<R,T> task) Succeeds if the task holds none of its declared locks.
void	test_runOne() Test ability to run a Callable on the service, get() the result, and then shutdown the service.
void	test_runOneThrowsException() Test ability to run a Callable on the service which throws an exception, get() the result, and then shutdown the service.
void	test_runOneWithLock() Test ability to obtain a lock, run a Callable on the service, get() the result, and then shutdown the service.
void	test_runOneWithLockAndReleaseLockFromTask() Test ability to obtain a lock, run a Callable on the service that releases its locks during its computation, verify that the locks were released, get() the result, and then shutdown the service.
void	test_shutdown() Test startup and normal shutdown.
void	test_shutdownNow() Test startup and fast shutdown.
void	test_submitOneThenCancel() Test ability to submit a Callable to the service and verify that is reported at ready(Runnable) and that we can cancel the Future.

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

TestNonBlockingLockManagerWithNewDesign

public TestNonBlockingLockManagerWithNewDesign()

TestNonBlockingLockManagerWithNewDesign

public TestNonBlockingLockManagerWithNewDesign(String name)

Method Detail

test_shutdownNow

public void test_shutdownNow()
                      throws InterruptedException,
                             ExecutionException

Test startup and fast shutdown.

Throws:

InterruptedException

ExecutionException

test_shutdown

public void test_shutdown()
                   throws InterruptedException,
                          ExecutionException

Test startup and normal shutdown.

Throws:

InterruptedException

ExecutionException

test_submitOneThenCancel

public void test_submitOneThenCancel()
                              throws InterruptedException,
                                     ExecutionException

Test ability to submit a Callable to the service and verify that is reported at ready(Runnable) and that we can cancel the Future.

Throws:

InterruptedException

ExecutionException

test_runOne

public void test_runOne()
                 throws InterruptedException,
                        ExecutionException,
                        TimeoutException

Test ability to run a Callable on the service, get() the result, and then shutdown the service.

Throws:

InterruptedException

ExecutionException

TimeoutException

TimeoutException

test_runOneThrowsException

public void test_runOneThrowsException()
                                throws InterruptedException,
                                       ExecutionException,
                                       TimeoutException

Test ability to run a Callable on the service which throws an exception, get() the result, and then shutdown the service.

Throws:

InterruptedException

ExecutionException

TimeoutException

TimeoutException

assertLocksHeld

protected <R extends Comparable<R>,T> void assertLocksHeld(NonBlockingLockManagerWithNewDesign<R> service,
                                               NonBlockingLockManagerWithNewDesign.LockFutureTask<R,T> task)

Succeeds if the task holds all of its declared locks.

Type Parameters:

R -

T -

Parameters:

service -

task -

assertLocksNotHeld

protected <R extends Comparable<R>,T> void assertLocksNotHeld(NonBlockingLockManagerWithNewDesign<R> service,
                                                  NonBlockingLockManagerWithNewDesign.LockFutureTask<R,T> task)

Succeeds if the task holds none of its declared locks.

Type Parameters:

R -

T -

Parameters:

service -

task -

test_runOneWithLock

public void test_runOneWithLock()
                         throws InterruptedException,
                                ExecutionException,
                                TimeoutException

Test ability to obtain a lock, run a Callable on the service, get() the result, and then shutdown the service.

Throws:

InterruptedException

ExecutionException

TimeoutException

TimeoutException

test_runOneWithLockAndReleaseLockFromTask

public void test_runOneWithLockAndReleaseLockFromTask()
                                               throws InterruptedException,
                                                      ExecutionException,
                                                      TimeoutException

Test ability to obtain a lock, run a Callable on the service that releases its locks during its computation, verify that the locks were released, get() the result, and then shutdown the service.

Throws:

InterruptedException

ExecutionException

TimeoutException

TimeoutException